public class FastWordCountTopology extends Object
WordCount but teh 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.Client client,
String name) |
static void |
main(String[] args) |
static void |
printMetrics(Nimbus.Client client,
String name) |
public static void printMetrics(Nimbus.Client client, String name) throws Exception
Exception
public static void kill(Nimbus.Client client, String name) throws Exception
Exception
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.