| Modifier and Type | Method and Description |
|---|---|
BoltDeclarer |
BatchSubtopologyBuilder.setBolt(String id,
IBasicBolt bolt) |
BoltDeclarer |
BatchSubtopologyBuilder.setBolt(String id,
IBasicBolt bolt,
Number parallelism) |
| Constructor and Description |
|---|
BatchSubtopologyBuilder(String masterBoltId,
IBasicBolt masterBolt) |
BatchSubtopologyBuilder(String masterBoltId,
IBasicBolt masterBolt,
Number boltParallelism) |
| Modifier and Type | Class and Description |
|---|---|
class |
PrepareRequest |
| Modifier and Type | Method and Description |
|---|---|
LinearDRPCInputDeclarer |
LinearDRPCTopologyBuilder.addBolt(IBasicBolt bolt) |
LinearDRPCInputDeclarer |
LinearDRPCTopologyBuilder.addBolt(IBasicBolt bolt,
Number parallelism) |
| Constructor and Description |
|---|
KeyedFairBolt(IBasicBolt delegate) |
| Modifier and Type | Class and Description |
|---|---|
class |
GlobalCountBolt
Globally count number of messages
|
class |
PartialCountBolt
Partially count number of messages from EventHubs
|
| Modifier and Type | Class and Description |
|---|---|
class |
LogInfoBolt
Simple bolt that does nothing other than LOG.info() every tuple recieveed.
|
| Modifier and Type | Class and Description |
|---|---|
class |
TotalWordCounter |
| Modifier and Type | Class and Description |
|---|---|
class |
WordCounter |
| Modifier and Type | Class and Description |
|---|---|
class |
CountBolt |
class |
SplitSentenceBolt |
| Modifier and Type | Class and Description |
|---|---|
static class |
AnchoredWordCount.SplitSentence |
static class |
AnchoredWordCount.WordCount |
static class |
BasicDRPCTopology.ExclaimBolt |
static class |
BlobStoreAPIWordCountTopology.FilterWords |
static class |
FastWordCountTopology.SplitSentence |
static class |
FastWordCountTopology.WordCount |
static class |
InOrderDeliveryTest.Check |
static class |
ManualDRPC.ExclamationBolt |
static class |
ReachTopology.GetFollowers |
static class |
ReachTopology.GetTweeters |
static class |
ThroughputVsLatency.SplitSentence |
static class |
ThroughputVsLatency.WordCount |
static class |
TransactionalWords.Bucketize |
static class |
WordCountTopology.WordCount |
static class |
WordCountTopologyNode.WordCount |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractRankerBolt
This abstract bolt provides the basic behavior of bolts that rank objects according to their count.
|
class |
IntermediateRankingsBolt
This bolt ranks incoming objects by their count.
|
class |
PrinterBolt |
class |
TotalRankingsBolt
This bolt merges incoming
Rankings. |
| Modifier and Type | Class and Description |
|---|---|
class |
BatchProcessWord |
class |
BatchRepeatA |
class |
IdentityBolt |
class |
PrepareBatchBolt |
class |
TestConfBolt |
class |
TestWordBytesCounter |
class |
TestWordCounter |
| Modifier and Type | Method and Description |
|---|---|
BoltDeclarer |
TopologyBuilder.setBolt(String id,
IBasicBolt bolt)
Define a new bolt in this topology.
|
BoltDeclarer |
TopologyBuilder.setBolt(String id,
IBasicBolt bolt,
Number parallelism_hint)
Define a new bolt in this topology.
|
| Constructor and Description |
|---|
BasicBoltExecutor(IBasicBolt bolt) |
| Modifier and Type | Class and Description |
|---|---|
class |
BaseBasicBolt |
| Modifier and Type | Method and Description |
|---|---|
BoltDeclarer |
TransactionalTopologyBuilder.setBolt(String id,
IBasicBolt bolt)
Deprecated.
|
BoltDeclarer |
TransactionalTopologyBuilder.setBolt(String id,
IBasicBolt bolt,
Number parallelism)
Deprecated.
|
| Modifier and Type | Class and Description |
|---|---|
class |
TridentSpoutCoordinator |
| Modifier and Type | Class and Description |
|---|---|
static class |
StatefulTopology.PrinterBolt |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.