org.apache.storm.topology

Interface IRichBolt

All Superinterfaces:

IBolt, IComponent, Serializable

All Known Implementing Classes:

AbstractEsBolt, AbstractHBaseBolt, AbstractHdfsBolt, AbstractJdbcBolt, AbstractMongoBolt, AbstractRedisBolt, AvroGenericRecordBolt, BaseCassandraBolt, BaseRichBolt, BaseStatefulBoltExecutor, BaseTickTupleAwareRichBolt, BasicBoltExecutor, BatchBoltExecutor, BatchCassandraWriterBolt, BlobStoreAPIWordCountTopology.SplitSentence, BoltTracker, CassandraWriterBolt, CheckpointTupleForwarder, ClojureBolt, CoordinatedBolt, DevNullBolt, DruidBeamBolt, EsIndexBolt, EsLookupBolt, EsPercolateBolt, EventHubBolt, ExclamationTopology.ExclamationBolt, FluxShellBolt, GenericBolt, HBaseBolt, HBaseLookupBolt, HdfsBolt, HdfsFileTopology.MyBolt, HdfsSpoutTopology.ConstBolt, HiveBolt, IdBolt, IdentityBolt, JdbcInsertBolt, JdbcLookupBolt, JmsBolt, JoinResult, KafkaBolt, KeyedFairBolt, LookupWordCount.PrintWordTotalCountBolt, MongoInsertBolt, MongoUpdateBolt, MqttBolt, MultipleLoggerTopology.ExclamationLoggingBolt, OpenTsdbBolt, PMMLPredictorBolt, PythonShellMetricsBolt, RedisFilterBolt, RedisLookupBolt, RedisStoreBolt, ResourceAwareExampleTopology.ExclamationBolt, ReturnResults, RichShellBolt, RollingCountAggBolt, RollingCountBolt, SequenceFileBolt, SequenceFileTopology.MyBolt, SingleJoinBolt, SolrUpdateBolt, StatefulBoltExecutor, StatefulWindowedBoltExecutor, TestAggregatesCounter, TestEventOrderCheckBolt, TestGlobalCount, TestPlannerBolt, TransactionalSpoutBatchExecutor, TridentBoltExecutor, TupleCaptureBolt, WhitelistWordCount.PrintWordTotalCountBolt, WindowedBoltExecutor, WordCountTopology.SplitSentence, WordCountTopologyNode.SplitSentence

public interface IRichBolt
extends IBolt, IComponent

When writing topologies using Java, IRichBolt and IRichSpout are the main interfaces to use to implement components of the topology.

Method Summary

Methods inherited from interface org.apache.storm.task.IBolt

cleanup, execute, prepare

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

declareOutputFields, getComponentConfiguration