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 class
FastWordCountTopology.FastRandomSentenceSpout
static class
FastWordCountTopology.SplitSentence
static class
FastWordCountTopology.WordCount
-
Constructor Summary
Constructors Constructor Description FastWordCountTopology()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static void
kill(Nimbus.Iface client, String name)
static void
main(String[] args)
static void
printMetrics(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
-
-