Uses of Class
org.apache.storm.topology.BasicOutputCollector

Packages that use BasicOutputCollector

Package	Description
org.apache.storm.drpc
org.apache.storm.flux.examples
org.apache.storm.flux.wrappers.bolts
org.apache.storm.hbase.topology
org.apache.storm.lambda
org.apache.storm.loadgen
org.apache.storm.mongodb.topology
org.apache.storm.perf.bolt
org.apache.storm.redis.topology
org.apache.storm.rocketmq.topology
org.apache.storm.starter
org.apache.storm.starter.bolt
org.apache.storm.testing
org.apache.storm.topology
org.apache.storm.trident.spout

Uses of BasicOutputCollector in org.apache.storm.drpc

Methods in org.apache.storm.drpc with parameters of type BasicOutputCollector

Modifier and Type	Method and Description
void	PrepareRequest.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 BasicOutputCollector

Modifier and Type	Method and Description
void	TestPrintBolt.execute(Tuple tuple, BasicOutputCollector collector)
void	WordCounter.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 BasicOutputCollector

Modifier and Type	Method and Description
void	LogInfoBolt.execute(Tuple tuple, BasicOutputCollector basicOutputCollector)

Uses of BasicOutputCollector in org.apache.storm.hbase.topology

Methods in org.apache.storm.hbase.topology with parameters of type BasicOutputCollector

Modifier and Type	Method and Description
void	TotalWordCounter.execute(Tuple input, BasicOutputCollector collector)
void	WordCounter.execute(Tuple input, BasicOutputCollector collector)

Uses of BasicOutputCollector in org.apache.storm.lambda

Methods in org.apache.storm.lambda with parameters of type BasicOutputCollector

Modifier and Type	Method and Description
void	LambdaConsumerBolt.execute(Tuple input, BasicOutputCollector collector)
void	LambdaBiConsumerBolt.execute(Tuple input, BasicOutputCollector collector)

Constructor parameters in org.apache.storm.lambda with type arguments of type BasicOutputCollector

Constructor and Description
LambdaBiConsumerBolt(SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer, String[] fields)

Uses of BasicOutputCollector in org.apache.storm.loadgen

Methods in org.apache.storm.loadgen with parameters of type BasicOutputCollector

Modifier and Type	Method and Description
void	ThroughputVsLatency.SplitSentence.execute(Tuple tuple, BasicOutputCollector collector)
void	ThroughputVsLatency.WordCount.execute(Tuple tuple, BasicOutputCollector collector)

Uses of BasicOutputCollector in org.apache.storm.mongodb.topology

Methods in org.apache.storm.mongodb.topology with parameters of type BasicOutputCollector

Modifier and Type	Method and Description
void	TotalWordCounter.execute(Tuple input, BasicOutputCollector collector)
void	WordCounter.execute(Tuple input, BasicOutputCollector collector)

Uses of BasicOutputCollector in org.apache.storm.perf.bolt

Methods in org.apache.storm.perf.bolt with parameters of type BasicOutputCollector

Modifier and Type	Method and Description
void	CountBolt.execute(Tuple tuple, BasicOutputCollector collector)
void	SplitSentenceBolt.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 BasicOutputCollector

Modifier and Type	Method and Description
void	WordCounter.execute(Tuple input, BasicOutputCollector collector)

Uses of BasicOutputCollector in org.apache.storm.rocketmq.topology

Methods in org.apache.storm.rocketmq.topology with parameters of type BasicOutputCollector

Modifier and Type	Method and Description
void	WordCounter.execute(Tuple input, BasicOutputCollector collector)

Uses of BasicOutputCollector in org.apache.storm.starter

Methods in org.apache.storm.starter with parameters of type BasicOutputCollector

Modifier and Type	Method and Description
void	StatefulTopology.PrinterBolt.execute(Tuple tuple, BasicOutputCollector collector)
void	AnchoredWordCount.SplitSentence.execute(Tuple tuple, BasicOutputCollector collector)
void	AnchoredWordCount.WordCount.execute(Tuple tuple, BasicOutputCollector collector)
void	InOrderDeliveryTest.Check.execute(Tuple tuple, BasicOutputCollector collector)
void	WordCountTopologyNode.WordCount.execute(Tuple tuple, BasicOutputCollector collector)
void	BasicDRPCTopology.ExclaimBolt.execute(Tuple tuple, BasicOutputCollector collector)
void	BlobStoreAPIWordCountTopology.FilterWords.execute(Tuple tuple, BasicOutputCollector collector)
void	ManualDRPC.ExclamationBolt.execute(Tuple tuple, BasicOutputCollector collector)
void	FastWordCountTopology.SplitSentence.execute(Tuple tuple, BasicOutputCollector collector)
void	FastWordCountTopology.WordCount.execute(Tuple tuple, BasicOutputCollector collector)
void	ReachTopology.GetTweeters.execute(Tuple tuple, BasicOutputCollector collector)
void	ReachTopology.GetFollowers.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 BasicOutputCollector

Modifier and Type	Method and Description
void	WordCountBolt.execute(Tuple tuple, BasicOutputCollector collector)
void	PrinterBolt.execute(Tuple tuple, BasicOutputCollector collector)
void	AbstractRankerBolt.execute(Tuple tuple, BasicOutputCollector collector) This method functions as a template method (design pattern).

Uses of BasicOutputCollector in org.apache.storm.testing

Methods in org.apache.storm.testing with parameters of type BasicOutputCollector

Modifier and Type	Method and Description
void	TestConfBolt.execute(Tuple input, BasicOutputCollector collector)
void	PrepareBatchBolt.execute(Tuple input, BasicOutputCollector collector)
void	IdentityBolt.execute(Tuple input, BasicOutputCollector collector)
void	TestWordCounter.execute(Tuple input, BasicOutputCollector collector)

Uses of BasicOutputCollector in org.apache.storm.topology

Methods in org.apache.storm.topology with parameters of type BasicOutputCollector

Modifier and Type	Method and Description
void	IBasicBolt.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 BasicOutputCollector

Modifier and Type	Method and Description
BoltDeclarer	TopologyBuilder.setBolt(String id, SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer, Number parallelismHint, String... fields) Define a new bolt in this topology.
BoltDeclarer	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 BasicOutputCollector

Modifier and Type	Method and Description
void	TridentSpoutCoordinator.execute(Tuple tuple, BasicOutputCollector collector)