Package org.apache.storm.perf

Class Summary

Class	Description
BackPressureTopo
ConstSpoutIdBoltNullBoltTopo	ConstSpout -> IdBolt -> DevNullBolt This topology measures speed of messaging between spouts->bolt and bolt->bolt ConstSpout : Continuously emits a constant string IdBolt : clones and emits input tuples DevNullBolt : discards incoming tuples.
ConstSpoutNullBoltTopo	This topo helps measure the messaging peak throughput between a spout and a bolt.
ConstSpoutOnlyTopo	This topo helps measure how fast a spout can produce data (so no bolts are attached).
FileReadWordCountTopo	This topo helps measure speed of word count.
HdfsSpoutNullBoltTopo	This topo helps measure speed of reading from Hdfs.
KafkaClientHdfsTopo	This topo helps measure speed of reading from Kafka and writing to Hdfs.
KafkaClientHdfsTopo.LineWriter
KafkaClientSpoutNullBoltTopo	Benchmark topology for measuring spout read/emit/ack performance.
LowThroughputTopo
SimplifiedWordCountTopo
StrGenSpoutHdfsBoltTopo	This topo helps measure speed of writing to Hdfs.
StrGenSpoutHdfsBoltTopo.LineWriter
ThroughputMeter