Uses of Class
org.apache.storm.topology.BasicOutputCollector
Package
Description
-
Uses of BasicOutputCollector in org.apache.storm.drpc
Modifier and TypeMethodDescriptionvoid
PrepareRequest.execute
(Tuple tuple, BasicOutputCollector collector) -
Uses of BasicOutputCollector in org.apache.storm.flux.examples
Modifier and TypeMethodDescriptionvoid
TestPrintBolt.execute
(Tuple tuple, BasicOutputCollector collector) void
WordCounter.execute
(Tuple input, BasicOutputCollector collector) -
Uses of BasicOutputCollector in org.apache.storm.flux.wrappers.bolts
Modifier and TypeMethodDescriptionvoid
LogInfoBolt.execute
(Tuple tuple, BasicOutputCollector basicOutputCollector) -
Uses of BasicOutputCollector in org.apache.storm.lambda
Modifier and TypeMethodDescriptionvoid
LambdaBiConsumerBolt.execute
(Tuple input, BasicOutputCollector collector) void
LambdaConsumerBolt.execute
(Tuple input, BasicOutputCollector collector) ModifierConstructorDescriptionLambdaBiConsumerBolt
(SerializableBiConsumer<Tuple, BasicOutputCollector> biConsumer, String[] fields) -
Uses of BasicOutputCollector in org.apache.storm.loadgen
Modifier and TypeMethodDescriptionvoid
ThroughputVsLatency.SplitSentence.execute
(Tuple tuple, BasicOutputCollector collector) void
ThroughputVsLatency.WordCount.execute
(Tuple tuple, BasicOutputCollector collector) -
Uses of BasicOutputCollector in org.apache.storm.perf.bolt
Modifier and TypeMethodDescriptionvoid
CountBolt.execute
(Tuple tuple, BasicOutputCollector collector) void
SplitSentenceBolt.execute
(Tuple input, BasicOutputCollector collector) -
Uses of BasicOutputCollector in org.apache.storm.redis.topology
Modifier and TypeMethodDescriptionvoid
WordCounter.execute
(Tuple input, BasicOutputCollector collector) -
Uses of BasicOutputCollector in org.apache.storm.starter
Modifier and TypeMethodDescriptionvoid
AnchoredWordCount.SplitSentence.execute
(Tuple tuple, BasicOutputCollector collector) void
AnchoredWordCount.WordCount.execute
(Tuple tuple, BasicOutputCollector collector) void
BasicDRPCTopology.ExclaimBolt.execute
(Tuple tuple, BasicOutputCollector collector) void
BlobStoreAPIWordCountTopology.FilterWords.execute
(Tuple tuple, BasicOutputCollector collector) void
FastWordCountTopology.SplitSentence.execute
(Tuple tuple, BasicOutputCollector collector) void
FastWordCountTopology.WordCount.execute
(Tuple tuple, BasicOutputCollector collector) void
InOrderDeliveryTest.Check.execute
(Tuple tuple, BasicOutputCollector collector) void
ManualDRPC.ExclamationBolt.execute
(Tuple tuple, BasicOutputCollector collector) void
ReachTopology.GetFollowers.execute
(Tuple tuple, BasicOutputCollector collector) void
ReachTopology.GetTweeters.execute
(Tuple tuple, BasicOutputCollector collector) void
StatefulTopology.PrinterBolt.execute
(Tuple tuple, BasicOutputCollector collector) void
WordCountTopologyNode.WordCount.execute
(Tuple tuple, BasicOutputCollector collector) -
Uses of BasicOutputCollector in org.apache.storm.starter.bolt
Modifier and TypeMethodDescriptionfinal void
AbstractRankerBolt.execute
(Tuple tuple, BasicOutputCollector collector) This method functions as a template method (design pattern).void
PrinterBolt.execute
(Tuple tuple, BasicOutputCollector collector) void
WordCountBolt.execute
(Tuple tuple, BasicOutputCollector collector) -
Uses of BasicOutputCollector in org.apache.storm.testing
Modifier and TypeMethodDescriptionvoid
IdentityBolt.execute
(Tuple input, BasicOutputCollector collector) void
PrepareBatchBolt.execute
(Tuple input, BasicOutputCollector collector) void
TestConfBolt.execute
(Tuple input, BasicOutputCollector collector) void
TestWordCounter.execute
(Tuple input, BasicOutputCollector collector) -
Uses of BasicOutputCollector in org.apache.storm.topology
Modifier and TypeMethodDescriptionvoid
IBasicBolt.execute
(Tuple input, BasicOutputCollector collector) Process the input tuple and optionally emit new tuples based on the input tuple.Modifier and TypeMethodDescriptionTopologyBuilder.setBolt
(String id, SerializableBiConsumer<Tuple, BasicOutputCollector> biConsumer, Number parallelismHint, String... fields) Define a new bolt in this topology.TopologyBuilder.setBolt
(String id, SerializableBiConsumer<Tuple, BasicOutputCollector> biConsumer, String... fields) Define a new bolt in this topology. -
Uses of BasicOutputCollector in org.apache.storm.trident.spout
Modifier and TypeMethodDescriptionvoid
TridentSpoutCoordinator.execute
(Tuple tuple, BasicOutputCollector collector)