Package org.apache.storm.perf
Class ConstSpoutNullBoltTopo
java.lang.Object
org.apache.storm.perf.ConstSpoutNullBoltTopo
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 Details- 
TOPOLOGY_NAME- See Also:
 
- 
SPOUT_ID- See Also:
 
- 
BOLT_ID- See Also:
 
- 
BOLT_COUNT- See Also:
 
- 
SPOUT_COUNT- See Also:
 
- 
GROUPING- See Also:
 
- 
LOCAL_GROPING- See Also:
 
- 
SHUFFLE_GROUPING- See Also:
 
- 
DEFAULT_GROUPING- See Also:
 
 
- 
- 
Constructor Details- 
ConstSpoutNullBoltTopopublic ConstSpoutNullBoltTopo()
 
- 
- 
Method Details- 
mainConstSpout -> DevNullBolt with configurable grouping (default localOrShuffle).- Throws:
- Exception
 
 
-