Uses of Class
org.apache.storm.topology.BasicOutputCollector
Packages that use BasicOutputCollector
Package
Description
- 
Uses of BasicOutputCollector in org.apache.storm.drpcMethods 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.examplesMethods 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.boltsMethods 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.lambdaMethods 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.loadgenMethods 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.boltMethods 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.topologyMethods 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.starterMethods 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.boltMethods 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.testingMethods 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.topologyMethods 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.spoutMethods in org.apache.storm.trident.spout with parameters of type BasicOutputCollectorModifier and TypeMethodDescriptionvoidTridentSpoutCoordinator.execute(Tuple tuple, BasicOutputCollector collector)