Package org.apache.storm.perf
Class FileReadWordCountTopo
- java.lang.Object
-
- org.apache.storm.perf.FileReadWordCountTopo
-
public class FileReadWordCountTopo extends Object
This topo helps measure speed of word count.Spout loads a file into memory on initialization, then emits the lines in an endless loop.
-
-
Field Summary
Fields Modifier and Type Field Description static StringCOUNT_IDstatic StringCOUNT_NUMstatic intDEFAULT_COUNT_BOLT_NUMstatic intDEFAULT_SPLIT_BOLT_NUMstatic intDEFAULT_SPOUT_NUMstatic StringINPUT_FILEstatic StringSPLIT_IDstatic StringSPLIT_NUMstatic StringSPOUT_IDstatic StringSPOUT_NUMstatic StringTOPOLOGY_NAME
-
Constructor Summary
Constructors Constructor Description FileReadWordCountTopo()
-
-
-
Field Detail
-
SPOUT_ID
public static final String SPOUT_ID
- See Also:
- Constant Field Values
-
COUNT_ID
public static final String COUNT_ID
- See Also:
- Constant Field Values
-
SPLIT_ID
public static final String SPLIT_ID
- See Also:
- Constant Field Values
-
TOPOLOGY_NAME
public static final String TOPOLOGY_NAME
- See Also:
- Constant Field Values
-
SPOUT_NUM
public static final String SPOUT_NUM
- See Also:
- Constant Field Values
-
SPLIT_NUM
public static final String SPLIT_NUM
- See Also:
- Constant Field Values
-
COUNT_NUM
public static final String COUNT_NUM
- See Also:
- Constant Field Values
-
INPUT_FILE
public static final String INPUT_FILE
- See Also:
- Constant Field Values
-
DEFAULT_SPOUT_NUM
public static final int DEFAULT_SPOUT_NUM
- See Also:
- Constant Field Values
-
DEFAULT_SPLIT_BOLT_NUM
public static final int DEFAULT_SPLIT_BOLT_NUM
- See Also:
- Constant Field Values
-
DEFAULT_COUNT_BOLT_NUM
public static final int DEFAULT_COUNT_BOLT_NUM
- See Also:
- Constant Field Values
-
-