public class TumblingTimeCorrectness extends Object implements TestableTopology
Computes sliding window sum
DUMMY_FIELD, MAX_SPOUT_EMITS, TIMEDATA_SLEEP_BETWEEN_EMITS_MS
Constructor and Description |
---|
TumblingTimeCorrectness(int tumbleSec) |
Modifier and Type | Method and Description |
---|---|
int |
getBoltExecutors() |
String |
getBoltName() |
int |
getSpoutExecutors() |
String |
getSpoutName() |
StormTopology |
newTopology() |
public String getBoltName()
getBoltName
in interface TestableTopology
public String getSpoutName()
getSpoutName
in interface TestableTopology
public int getBoltExecutors()
getBoltExecutors
in interface TestableTopology
public int getSpoutExecutors()
getSpoutExecutors
in interface TestableTopology
public StormTopology newTopology()
newTopology
in interface TestableTopology
Copyright © 2019 The Apache Software Foundation. All rights reserved.