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
-
ConstSpoutNullBoltTopo
public ConstSpoutNullBoltTopo()
-
-
Method Details
-
main
ConstSpout -> DevNullBolt with configurable grouping (default localOrShuffle).- Throws:
Exception
-