org.apache.storm.topology

Interface IBasicBolt

All Superinterfaces:

IComponent, Serializable

All Known Implementing Classes:

AbstractRankerBolt, AnchoredWordCount.SplitSentence, AnchoredWordCount.WordCount, BaseBasicBolt, BasicDRPCTopology.ExclaimBolt, BatchProcessWord, BatchRepeatA, BlobStoreAPIWordCountTopology.FilterWords, CountBolt, FastWordCountTopology.SplitSentence, FastWordCountTopology.WordCount, GlobalCountBolt, IdentityBolt, InOrderDeliveryTest.Check, IntermediateRankingsBolt, LogInfoBolt, ManualDRPC.ExclamationBolt, PartialCountBolt, PrepareBatchBolt, PrepareRequest, PrinterBolt, ReachTopology.GetFollowers, ReachTopology.GetTweeters, SplitSentenceBolt, StatefulTopology.PrinterBolt, TestConfBolt, TestWordBytesCounter, TestWordCounter, ThroughputVsLatency.SplitSentence, ThroughputVsLatency.WordCount, TotalRankingsBolt, TotalWordCounter, TransactionalWords.Bucketize, TridentSpoutCoordinator, WordCounter, WordCounter, WordCounter, WordCountTopology.WordCount, WordCountTopologyNode.WordCount

public interface IBasicBolt
extends IComponent

Method Summary

Modifier and Type	Method and Description
void	cleanup()
void	execute(Tuple input, BasicOutputCollector collector) Process the input tuple and optionally emit new tuples based on the input tuple.
void	prepare(Map stormConf, TopologyContext context)

Methods inherited from interface org.apache.storm.topology.IComponent

declareOutputFields, getComponentConfiguration

Method Detail

prepare

void prepare(Map stormConf,
             TopologyContext context)

execute

void execute(Tuple input,
             BasicOutputCollector collector)

Process the input tuple and optionally emit new tuples based on the input tuple.

All acking is managed for you. Throw a FailedException if you want to fail the tuple.

cleanup

void cleanup()