Package org.apache.storm.perf
Class ConstSpoutNullBoltTopo
- java.lang.Object
-
- org.apache.storm.perf.ConstSpoutNullBoltTopo
-
public class ConstSpoutNullBoltTopo extends Object
This topo helps measure the messaging peak throughput between a spout and a bolt.Spout generates a stream of a fixed string.
Bolt will simply ack and discard the tuple received.
-
-
Field Summary
Fields Modifier and Type Field Description static StringBOLT_COUNTstatic StringBOLT_IDstatic StringDEFAULT_GROUPINGstatic StringGROUPINGstatic StringLOCAL_GROPINGstatic StringSHUFFLE_GROUPINGstatic StringSPOUT_COUNTstatic StringSPOUT_IDstatic StringTOPOLOGY_NAME
-
Constructor Summary
Constructors Constructor Description ConstSpoutNullBoltTopo()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static voidmain(String[] args)ConstSpout -> DevNullBolt with configurable grouping (default localOrShuffle).
-
-
-
Field Detail
-
TOPOLOGY_NAME
public static final String TOPOLOGY_NAME
- See Also:
- Constant Field Values
-
SPOUT_ID
public static final String SPOUT_ID
- See Also:
- Constant Field Values
-
BOLT_ID
public static final String BOLT_ID
- See Also:
- Constant Field Values
-
BOLT_COUNT
public static final String BOLT_COUNT
- See Also:
- Constant Field Values
-
SPOUT_COUNT
public static final String SPOUT_COUNT
- See Also:
- Constant Field Values
-
GROUPING
public static final String GROUPING
- See Also:
- Constant Field Values
-
LOCAL_GROPING
public static final String LOCAL_GROPING
- See Also:
- Constant Field Values
-
SHUFFLE_GROUPING
public static final String SHUFFLE_GROUPING
- See Also:
- Constant Field Values
-
DEFAULT_GROUPING
public static final String DEFAULT_GROUPING
- See Also:
- Constant Field Values
-
-