Uses of Class
org.apache.storm.topology.BasicOutputCollector
Packages that use BasicOutputCollector
Package
Description
-
Uses of BasicOutputCollector in org.apache.storm.drpc
Methods in org.apache.storm.drpc with parameters of type BasicOutputCollectorModifier and TypeMethodDescriptionvoidPrepareRequest.execute(Tuple tuple, BasicOutputCollector collector) -
Uses of BasicOutputCollector in org.apache.storm.flux.examples
Methods in org.apache.storm.flux.examples with parameters of type BasicOutputCollectorModifier and TypeMethodDescriptionvoidTestPrintBolt.execute(Tuple tuple, BasicOutputCollector collector) voidWordCounter.execute(Tuple input, BasicOutputCollector collector) -
Uses of BasicOutputCollector in org.apache.storm.flux.wrappers.bolts
Methods in org.apache.storm.flux.wrappers.bolts with parameters of type BasicOutputCollectorModifier and TypeMethodDescriptionvoidLogInfoBolt.execute(Tuple tuple, BasicOutputCollector basicOutputCollector) -
Uses of BasicOutputCollector in org.apache.storm.lambda
Methods in org.apache.storm.lambda with parameters of type BasicOutputCollectorModifier and TypeMethodDescriptionvoidLambdaBiConsumerBolt.execute(Tuple input, BasicOutputCollector collector) voidLambdaConsumerBolt.execute(Tuple input, BasicOutputCollector collector) Constructor parameters in org.apache.storm.lambda with type arguments of type BasicOutputCollectorModifierConstructorDescriptionLambdaBiConsumerBolt(SerializableBiConsumer<Tuple, BasicOutputCollector> biConsumer, String[] fields) -
Uses of BasicOutputCollector in org.apache.storm.loadgen
Methods in org.apache.storm.loadgen with parameters of type BasicOutputCollectorModifier and TypeMethodDescriptionvoidThroughputVsLatency.SplitSentence.execute(Tuple tuple, BasicOutputCollector collector) voidThroughputVsLatency.WordCount.execute(Tuple tuple, BasicOutputCollector collector) -
Uses of BasicOutputCollector in org.apache.storm.perf.bolt
Methods in org.apache.storm.perf.bolt with parameters of type BasicOutputCollectorModifier and TypeMethodDescriptionvoidCountBolt.execute(Tuple tuple, BasicOutputCollector collector) voidSplitSentenceBolt.execute(Tuple input, BasicOutputCollector collector) -
Uses of BasicOutputCollector in org.apache.storm.redis.topology
Methods in org.apache.storm.redis.topology with parameters of type BasicOutputCollectorModifier and TypeMethodDescriptionvoidWordCounter.execute(Tuple input, BasicOutputCollector collector) -
Uses of BasicOutputCollector in org.apache.storm.starter
Methods in org.apache.storm.starter with parameters of type BasicOutputCollectorModifier and TypeMethodDescriptionvoidAnchoredWordCount.SplitSentence.execute(Tuple tuple, BasicOutputCollector collector) voidAnchoredWordCount.WordCount.execute(Tuple tuple, BasicOutputCollector collector) voidBasicDRPCTopology.ExclaimBolt.execute(Tuple tuple, BasicOutputCollector collector) voidBlobStoreAPIWordCountTopology.FilterWords.execute(Tuple tuple, BasicOutputCollector collector) voidFastWordCountTopology.SplitSentence.execute(Tuple tuple, BasicOutputCollector collector) voidFastWordCountTopology.WordCount.execute(Tuple tuple, BasicOutputCollector collector) voidInOrderDeliveryTest.Check.execute(Tuple tuple, BasicOutputCollector collector) voidManualDRPC.ExclamationBolt.execute(Tuple tuple, BasicOutputCollector collector) voidReachTopology.GetFollowers.execute(Tuple tuple, BasicOutputCollector collector) voidReachTopology.GetTweeters.execute(Tuple tuple, BasicOutputCollector collector) voidStatefulTopology.PrinterBolt.execute(Tuple tuple, BasicOutputCollector collector) voidWordCountTopologyNode.WordCount.execute(Tuple tuple, BasicOutputCollector collector) -
Uses of BasicOutputCollector in org.apache.storm.starter.bolt
Methods in org.apache.storm.starter.bolt with parameters of type BasicOutputCollectorModifier and TypeMethodDescriptionfinal voidAbstractRankerBolt.execute(Tuple tuple, BasicOutputCollector collector) This method functions as a template method (design pattern).voidPrinterBolt.execute(Tuple tuple, BasicOutputCollector collector) voidWordCountBolt.execute(Tuple tuple, BasicOutputCollector collector) -
Uses of BasicOutputCollector in org.apache.storm.testing
Methods in org.apache.storm.testing with parameters of type BasicOutputCollectorModifier and TypeMethodDescriptionvoidIdentityBolt.execute(Tuple input, BasicOutputCollector collector) voidPrepareBatchBolt.execute(Tuple input, BasicOutputCollector collector) voidTestConfBolt.execute(Tuple input, BasicOutputCollector collector) voidTestWordCounter.execute(Tuple input, BasicOutputCollector collector) -
Uses of BasicOutputCollector in org.apache.storm.topology
Methods in org.apache.storm.topology with parameters of type BasicOutputCollectorModifier and TypeMethodDescriptionvoidIBasicBolt.execute(Tuple input, BasicOutputCollector collector) Process the input tuple and optionally emit new tuples based on the input tuple.Method parameters in org.apache.storm.topology with type arguments of type BasicOutputCollectorModifier 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
Methods in org.apache.storm.trident.spout with parameters of type BasicOutputCollectorModifier and TypeMethodDescriptionvoidTridentSpoutCoordinator.execute(Tuple tuple, BasicOutputCollector collector)