Package | Description |
---|---|
org.apache.storm.starter | |
org.apache.storm.topology |
Modifier and Type | Class and Description |
---|---|
class |
AnchoredWordCount |
class |
ExclamationTopology
This is a basic example of a Storm topology.
|
class |
LambdaTopology |
class |
MultiThreadWordCountTopology
Some topologies might spawn some threads within bolts to do some work and emit tuples from those threads.
|
class |
RollingTopWords
This topology does a continuous computation of the top N words that the topology has seen in terms of cardinality.
|
class |
SkewedRollingTopWords
This topology does a continuous computation of the top N words that the topology has seen in terms of cardinality.
|
class |
WordCountTopology
This topology demonstrates Storm’s stream groupings and multilang capabilities.
|
Modifier and Type | Method and Description |
---|---|
static void |
ConfigurableTopology.start(ConfigurableTopology topology,
String[] args) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.