Uses of Interface
org.apache.storm.topology.IBasicBolt
-
-
Uses of IBasicBolt in org.apache.storm.coordination
Methods in org.apache.storm.coordination with parameters of type IBasicBolt Modifier and Type Method Description BoltDeclarer
BatchSubtopologyBuilder. setBolt(String id, IBasicBolt bolt)
BoltDeclarer
BatchSubtopologyBuilder. setBolt(String id, IBasicBolt bolt, Number parallelism)
Constructors in org.apache.storm.coordination with parameters of type IBasicBolt Constructor Description BatchSubtopologyBuilder(String masterBoltId, IBasicBolt masterBolt)
BatchSubtopologyBuilder(String masterBoltId, IBasicBolt masterBolt, Number boltParallelism)
-
Uses of IBasicBolt in org.apache.storm.drpc
Classes in org.apache.storm.drpc that implement IBasicBolt Modifier and Type Class Description class
PrepareRequest
Methods in org.apache.storm.drpc with parameters of type IBasicBolt Modifier and Type Method Description LinearDRPCInputDeclarer
LinearDRPCTopologyBuilder. addBolt(IBasicBolt bolt)
LinearDRPCInputDeclarer
LinearDRPCTopologyBuilder. addBolt(IBasicBolt bolt, Number parallelism)
Constructors in org.apache.storm.drpc with parameters of type IBasicBolt Constructor Description KeyedFairBolt(IBasicBolt delegate)
-
Uses of IBasicBolt in org.apache.storm.flux.examples
Classes in org.apache.storm.flux.examples that implement IBasicBolt Modifier and Type Class Description class
TestPrintBolt
Prints the tuples to stdout.class
WordCounter
This bolt is used by the HBase example. -
Uses of IBasicBolt in org.apache.storm.flux.wrappers.bolts
Classes in org.apache.storm.flux.wrappers.bolts that implement IBasicBolt Modifier and Type Class Description class
LogInfoBolt
Simple bolt that does nothing other than LOG.info() every tuple recieveed. -
Uses of IBasicBolt in org.apache.storm.lambda
Classes in org.apache.storm.lambda that implement IBasicBolt Modifier and Type Class Description class
LambdaBiConsumerBolt
class
LambdaConsumerBolt
-
Uses of IBasicBolt in org.apache.storm.loadgen
Classes in org.apache.storm.loadgen that implement IBasicBolt Modifier and Type Class Description static class
ThroughputVsLatency.SplitSentence
static class
ThroughputVsLatency.WordCount
-
Uses of IBasicBolt in org.apache.storm.perf.bolt
Classes in org.apache.storm.perf.bolt that implement IBasicBolt Modifier and Type Class Description class
CountBolt
class
SplitSentenceBolt
-
Uses of IBasicBolt in org.apache.storm.redis.topology
Classes in org.apache.storm.redis.topology that implement IBasicBolt Modifier and Type Class Description class
WordCounter
-
Uses of IBasicBolt in org.apache.storm.starter
Classes in org.apache.storm.starter that implement IBasicBolt Modifier and Type Class 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
-
Uses of IBasicBolt in org.apache.storm.starter.bolt
Classes in org.apache.storm.starter.bolt that implement IBasicBolt Modifier and Type Class 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 incomingRankings
.class
WordCountBolt
-
Uses of IBasicBolt in org.apache.storm.streams
Methods in org.apache.storm.streams with parameters of type IBasicBolt Modifier and Type Method 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. -
Uses of IBasicBolt in org.apache.storm.testing
Classes in org.apache.storm.testing that implement IBasicBolt Modifier and Type Class Description class
IdentityBolt
class
PrepareBatchBolt
class
TestConfBolt
class
TestWordBytesCounter
class
TestWordCounter
-
Uses of IBasicBolt in org.apache.storm.topology
Methods in org.apache.storm.topology with parameters of type IBasicBolt Modifier and Type Method 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.Constructors in org.apache.storm.topology with parameters of type IBasicBolt Constructor Description BasicBoltExecutor(IBasicBolt bolt)
-
Uses of IBasicBolt in org.apache.storm.topology.base
Classes in org.apache.storm.topology.base that implement IBasicBolt Modifier and Type Class Description class
BaseBasicBolt
-
Uses of IBasicBolt in org.apache.storm.trident.spout
Classes in org.apache.storm.trident.spout that implement IBasicBolt Modifier and Type Class Description class
TridentSpoutCoordinator
-