| 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.
|
| Constructor and Description |
|---|
CoordinatedBolt(IRichBolt delegate) |
CoordinatedBolt(IRichBolt delegate,
Map<String,CoordinatedBolt.SourceArgs> sourceArgs,
CoordinatedBolt.IdStreamSpec idStreamSpec) |
CoordinatedBolt(IRichBolt delegate,
String sourceComponent,
CoordinatedBolt.SourceArgs sourceArgs,
CoordinatedBolt.IdStreamSpec idStreamSpec) |
| Modifier and Type | Class and Description |
|---|---|
class |
JoinResult |
class |
KeyedFairBolt |
class |
ReturnResults |
| Modifier and Type | Method and Description |
|---|---|
LinearDRPCInputDeclarer |
LinearDRPCTopologyBuilder.addBolt(IRichBolt bolt)
Deprecated.
|
LinearDRPCInputDeclarer |
LinearDRPCTopologyBuilder.addBolt(IRichBolt bolt,
Number parallelism)
Deprecated.
|
| Constructor and Description |
|---|
KeyedFairBolt(IRichBolt delegate) |
| Modifier and Type | Class and Description |
|---|---|
class |
BoltTracker |
class |
PythonShellMetricsBolt |
class |
TestAggregatesCounter |
class |
TestEventOrderCheckBolt |
class |
TestGlobalCount |
class |
TestPlannerBolt |
class |
TupleCaptureBolt |
| Constructor and Description |
|---|
BoltTracker(IRichBolt delegate,
String id) |
| Modifier and Type | Class and Description |
|---|---|
class |
BasicBoltExecutor |
| Modifier and Type | Method and Description |
|---|---|
BoltDeclarer |
TopologyBuilder.setBolt(String id,
IRichBolt bolt)
Define a new bolt in this topology with parallelism of just one thread.
|
BoltDeclarer |
TopologyBuilder.setBolt(String id,
IRichBolt bolt,
Number parallelism_hint)
Define a new bolt in this topology with the specified amount of parallelism.
|
| Modifier and Type | Class and Description |
|---|---|
class |
BaseRichBolt |
| Modifier and Type | Class and Description |
|---|---|
class |
TransactionalSpoutBatchExecutor |
| Modifier and Type | Class and Description |
|---|---|
class |
TridentBoltExecutor |
Copyright © 2015. All rights reserved.