Modifier and Type | Class and Description |
---|---|
class |
ClojureBolt |
class |
RichShellBolt |
Modifier and Type | Class and Description |
---|---|
class |
BatchBoltExecutor |
class |
CoordinatedBolt
Coordination requires the request ids to be globally unique for awhile.
|
Modifier and Type | Class and Description |
---|---|
class |
JoinResult |
class |
KeyedFairBolt |
class |
ReturnResults |
Modifier and Type | Class and Description |
---|---|
class |
MetricsConsumerBolt |
class |
SystemBolt |
Modifier and Type | Field and Description |
---|---|
IBolt |
TaskBundle.task |
Constructor and Description |
---|
TaskBundle(IBolt task,
int componentId) |
Modifier and Type | Class and Description |
---|---|
class |
ShellBolt
A bolt that shells out to another process to process tuples.
|
Modifier and Type | Class and Description |
---|---|
class |
BoltTracker |
class |
NonRichBoltTracker |
class |
PythonShellMetricsBolt |
class |
TestAggregatesCounter |
class |
TestEventOrderCheckBolt |
class |
TestGlobalCount |
class |
TestPlannerBolt |
class |
TupleCaptureBolt |
Constructor and Description |
---|
NonRichBoltTracker(IBolt delegate,
String id) |
Modifier and Type | Interface and Description |
---|---|
interface |
IRichBolt
When writing topologies using Java,
IRichBolt and IRichSpout are the main interfaces
to use to implement components of the topology. |
Modifier and Type | Class and Description |
---|---|
class |
BasicBoltExecutor |
Modifier and Type | Class and Description |
---|---|
class |
BaseRichBolt |
Modifier and Type | Class and Description |
---|---|
class |
TransactionalSpoutBatchExecutor |
Modifier and Type | Class and Description |
---|---|
class |
AbstractHBaseBolt |
class |
HBaseBolt
Basic bolt for writing to HBase.
|
class |
HBaseLookupBolt
Basic bolt for querying from HBase.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractHdfsBolt |
class |
HdfsBolt |
class |
SequenceFileBolt |
Modifier and Type | Class and Description |
---|---|
class |
KafkaBolt<K,V>
Bolt implementation that can send Tuple data to Kafka
It expects the producer configuration and topic in storm config under
'kafka.broker.properties' and 'topic'
respectively.
|
Modifier and Type | Class and Description |
---|---|
static class |
ExclamationTopology.ExclamationBolt |
static class |
WordCountTopology.SplitSentence |
static class |
WordCountTopologyNode.SplitSentence |
Modifier and Type | Class and Description |
---|---|
class |
RollingCountBolt
This bolt performs rolling counts of incoming objects, i.e.
|
class |
SingleJoinBolt |
Modifier and Type | Class and Description |
---|---|
class |
TridentBoltExecutor |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.