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.
Modifier and Type | Class and Description |
---|---|
static class |
FastWordCountTopology.FastRandomSentenceSpout |
static class |
FastWordCountTopology.SplitSentence |
static class |
FastWordCountTopology.WordCount |
Constructor and Description |
---|
FastWordCountTopology() |
Modifier and Type | Method and Description |
---|---|
static void |
kill(Nimbus.Iface client,
String name) |
static void |
main(String[] args) |
static void |
printMetrics(Nimbus.Iface client,
String name) |
public static void printMetrics(Nimbus.Iface client, String name) throws Exception
Exception
public static void kill(Nimbus.Iface client, String name) throws Exception
Exception
Copyright © 2020 The Apache Software Foundation. All rights reserved.