Package org.apache.storm
Class ExclamationTopology
- java.lang.Object
-
- org.apache.storm.ExclamationTopology
-
public class ExclamationTopology extends Object
This is a basic example of a Storm topology.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ExclamationTopology.ExclamationBolt
static class
ExclamationTopology.FixedOrderWordSpout
-
Field Summary
Fields Modifier and Type Field Description static String
EXCLAIM_1
static String
EXCLAIM_2
static int
EXCLAIM_2_EXECUTORS
static int
SPOUT_EXECUTORS
static String
WORD
-
Constructor Summary
Constructors Constructor Description ExclamationTopology()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static StormTopology
getStormTopology()
static void
main(String[] args)
-
-
-
Field Detail
-
WORD
public static final String WORD
- See Also:
- Constant Field Values
-
EXCLAIM_1
public static final String EXCLAIM_1
- See Also:
- Constant Field Values
-
EXCLAIM_2
public static final String EXCLAIM_2
- See Also:
- Constant Field Values
-
SPOUT_EXECUTORS
public static final int SPOUT_EXECUTORS
- See Also:
- Constant Field Values
-
EXCLAIM_2_EXECUTORS
public static final int EXCLAIM_2_EXECUTORS
- See Also:
- Constant Field Values
-
-
Method Detail
-
getStormTopology
public static StormTopology getStormTopology()
-
-