Package org.apache.storm.starter
Class FastWordCountTopology
- java.lang.Object
-
- org.apache.storm.starter.FastWordCountTopology
-
public class FastWordCountTopology extends Object
WordCount but the spout does not stop, and the bolts are implemented in java. This can show how fast the word count can run.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classFastWordCountTopology.FastRandomSentenceSpoutstatic classFastWordCountTopology.SplitSentencestatic classFastWordCountTopology.WordCount
-
Constructor Summary
Constructors Constructor Description FastWordCountTopology()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static voidkill(Nimbus.Iface client, String name)static voidmain(String[] args)static voidprintMetrics(Nimbus.Iface client, String name)
-
-
-
Method Detail
-
printMetrics
public static void printMetrics(Nimbus.Iface client, String name) throws Exception
- Throws:
Exception
-
kill
public static void kill(Nimbus.Iface client, String name) throws Exception
- Throws:
Exception
-
-