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.
This topo helps measure the messaging peak throughput between a spout and a bolt.
This topo helps measure how fast a spout can produce data (so no bolts are attached).
This topo helps measure speed of word count.
This topo helps measure speed of reading from Hdfs.
This topo helps measure speed of reading from Kafka and writing to Hdfs.
Benchmark topology for measuring spout read/emit/ack performance.
This topo helps measure speed of writing to Hdfs.
Copyright © 2020 The Apache Software Foundation. All rights reserved.