Uses of Class
org.apache.storm.topology.BasicOutputCollector
-
-
Uses of BasicOutputCollector in org.apache.storm.drpc
Methods in org.apache.storm.drpc with parameters of type BasicOutputCollector Modifier and Type Method 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 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 Description void
LogInfoBolt. execute(Tuple tuple, BasicOutputCollector basicOutputCollector)
-
Uses of BasicOutputCollector in org.apache.storm.lambda
Methods in org.apache.storm.lambda with parameters of type BasicOutputCollector Modifier and Type Method Description void
LambdaBiConsumerBolt. execute(Tuple input, BasicOutputCollector collector)
void
LambdaConsumerBolt. execute(Tuple input, BasicOutputCollector collector)
Constructor parameters in org.apache.storm.lambda with type arguments of type BasicOutputCollector Constructor 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 Description void
ThroughputVsLatency.SplitSentence. execute(Tuple tuple, BasicOutputCollector collector)
void
ThroughputVsLatency.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 BasicOutputCollector Modifier and Type Method 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 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 Description void
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
Methods in org.apache.storm.starter.bolt with parameters of type BasicOutputCollector Modifier and Type Method Description 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
Methods in org.apache.storm.testing with parameters of type BasicOutputCollector Modifier and Type Method Description void
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
Methods in org.apache.storm.topology with parameters of type BasicOutputCollector Modifier and Type Method 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 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 Description void
TridentSpoutCoordinator. execute(Tuple tuple, BasicOutputCollector collector)
-