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

Packages that use BasicOutputCollector

Package	Description
org.apache.storm.drpc
org.apache.storm.eventhubs.samples.bolt
org.apache.storm.flux.wrappers.bolts
org.apache.storm.hbase.topology
org.apache.storm.mongodb.topology
org.apache.storm.perf.bolt
org.apache.storm.redis.topology
org.apache.storm.starter
org.apache.storm.starter.bolt
org.apache.storm.testing
org.apache.storm.topology
org.apache.storm.trident.spout
storm.starter

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.eventhubs.samples.bolt

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

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

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

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

Modifier and Type	Method and Description
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	TestWordCounter.execute(Tuple input, BasicOutputCollector collector)
void	TestConfBolt.execute(Tuple input, BasicOutputCollector collector)
void	PrepareBatchBolt.execute(Tuple input, BasicOutputCollector collector)
void	IdentityBolt.execute(Tuple input, BasicOutputCollector collector)
void	BatchRepeatA.execute(Tuple input, BasicOutputCollector collector)
void	BatchProcessWord.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.

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)

Uses of BasicOutputCollector in storm.starter

Methods in storm.starter with parameters of type BasicOutputCollector

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