| 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  | TestPrintBoltPrints the tuples to stdout. | 
| class  | WordCounterThis bolt is used by the HBase example. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | LogInfoBoltSimple bolt that does nothing other than LOG.info() every tuple recieveed. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | LambdaBiConsumerBolt | 
| class  | LambdaConsumerBolt | 
| Modifier and Type | Class and Description | 
|---|---|
| static class  | ThroughputVsLatency.SplitSentence | 
| static class  | ThroughputVsLatency.WordCount | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | TotalWordCounter | 
| 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  | StatefulTopology.PrinterBolt | 
| static class  | WordCountTopology.WordCount | 
| static class  | WordCountTopologyNode.WordCount | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | AbstractRankerBoltThis abstract bolt provides the basic behavior of bolts that rank objects according to their count. | 
| class  | IntermediateRankingsBoltThis bolt ranks incoming objects by their count. | 
| class  | PrinterBolt | 
| class  | TotalRankingsBoltThis bolt merges incoming  Rankings. | 
| Modifier and Type | Method and Description | 
|---|---|
| void | Stream. to(IBasicBolt bolt)Sends the elements of this stream to a bolt. | 
| void | Stream. to(IBasicBolt bolt,
  int parallelism)Sends the elements of this stream to a bolt. | 
| Modifier and Type | Class and Description | 
|---|---|
| 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 parallelismHint)Define a new bolt in this topology. | 
| Constructor and Description | 
|---|
| BasicBoltExecutor(IBasicBolt bolt) | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | BaseBasicBolt | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | TridentSpoutCoordinator | 
Copyright © 2022 The Apache Software Foundation. All rights reserved.