Class FileReadWordCountTopo

java.lang.Object
org.apache.storm.perf.FileReadWordCountTopo

public class FileReadWordCountTopo extends Object
This topo helps measure speed of word count.

Spout loads a file into memory on initialization, then emits the lines in an endless loop.