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 |
TestPrintBolt
Prints the tuples to stdout.
|
class |
WordCounter
This bolt is used by the HBase example.
|
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 |
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 |
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 . |
class |
WordCountBolt |
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.