| 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 |
|