Package org.apache.storm.st.topology
Interface TestableTopology
-
- All Known Implementing Classes:
SlidingTimeCorrectness
,SlidingWindowCorrectness
,TumblingTimeCorrectness
,TumblingWindowCorrectness
public interface TestableTopology
-
-
Field Summary
Fields Modifier and Type Field Description static String
DUMMY_FIELD
static long
MAX_SPOUT_EMITS
static int
TIMEDATA_SLEEP_BETWEEN_EMITS_MS
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description int
getBoltExecutors()
String
getBoltName()
int
getSpoutExecutors()
String
getSpoutName()
StormTopology
newTopology()
-
-
-
Field Detail
-
DUMMY_FIELD
static final String DUMMY_FIELD
- See Also:
- Constant Field Values
-
TIMEDATA_SLEEP_BETWEEN_EMITS_MS
static final int TIMEDATA_SLEEP_BETWEEN_EMITS_MS
- See Also:
- Constant Field Values
-
MAX_SPOUT_EMITS
static final long MAX_SPOUT_EMITS
-
-
Method Detail
-
newTopology
StormTopology newTopology()
-
getBoltName
String getBoltName()
-
getBoltExecutors
int getBoltExecutors()
-
getSpoutName
String getSpoutName()
-
getSpoutExecutors
int getSpoutExecutors()
-
-