# Uses of Interface
org.apache.storm.topology.IRichBolt

Packages that use IRichBolt
Package
Description
org.apache.storm
org.apache.storm.clojure
org.apache.storm.coordination
org.apache.storm.drpc
org.apache.storm.flux.wrappers.bolts
org.apache.storm.hdfs.bolt
org.apache.storm.hdfs.spout
org.apache.storm.jdbc.bolt
org.apache.storm.jms.bolt
org.apache.storm.jms.example
org.apache.storm.kafka.bolt
org.apache.storm.kafka.spout
org.apache.storm.loadgen
org.apache.storm.perf.bolt
org.apache.storm.perf.utils
org.apache.storm.redis.bolt
org.apache.storm.redis.topology
org.apache.storm.sql.runtime
org.apache.storm.sql.runtime.datasource.socket.bolt
org.apache.storm.starter
org.apache.storm.starter.bolt
org.apache.storm.streams
org.apache.storm.testing
org.apache.storm.topology
org.apache.storm.topology.base
org.apache.storm.trident.topology

- ## Uses of IRichBolt in org.apache.storm

  Classes in org.apache.storm that implement IRichBolt
  Modifier and Type
  Class
  Description
  `static class`
  `ExclamationTopology.ExclamationBolt`

- ## Uses of IRichBolt in org.apache.storm.clojure

  Classes in org.apache.storm.clojure that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `ClojureBolt`
  `class`
  `RichShellBolt`

- ## Uses of IRichBolt in org.apache.storm.coordination

  Classes in org.apache.storm.coordination that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `BatchBoltExecutor`
  `class`
  `CoordinatedBolt`
  Coordination requires the request ids to be globally unique for awhile.
  Constructors in org.apache.storm.coordination with parameters of type IRichBolt
  Modifier
  Constructor
  Description
  ``
  `CoordinatedBolt(IRichBolt delegate)`
  ``
  `CoordinatedBolt(IRichBolt delegate, String sourceComponent, CoordinatedBolt.SourceArgs sourceArgs, CoordinatedBolt.IdStreamSpec idStreamSpec)`
  ``
  `CoordinatedBolt(IRichBolt delegate, Map<String,CoordinatedBolt.SourceArgs> sourceArgs, CoordinatedBolt.IdStreamSpec idStreamSpec)`

- ## Uses of IRichBolt in org.apache.storm.drpc

  Classes in org.apache.storm.drpc that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `JoinResult`
  `class`
  `KeyedFairBolt`
  `class`
  `ReturnResults`
  Methods in org.apache.storm.drpc with parameters of type IRichBolt
  Modifier and Type
  Method
  Description
  `LinearDRPCInputDeclarer`
  LinearDRPCTopologyBuilder.`addBolt(IRichBolt bolt)`
  Deprecated.
  `LinearDRPCInputDeclarer`
  LinearDRPCTopologyBuilder.`addBolt(IRichBolt bolt, Number parallelism)`
  Deprecated.
  Constructors in org.apache.storm.drpc with parameters of type IRichBolt
  Modifier
  Constructor
  Description
  ``
  `KeyedFairBolt(IRichBolt delegate)`

- ## Uses of IRichBolt in org.apache.storm.flux.wrappers.bolts

  Classes in org.apache.storm.flux.wrappers.bolts that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `FluxShellBolt`
  A generic `ShellBolt` implementation that allows you specify output fields and even streams without having to subclass `ShellBolt` to do so.

- ## Uses of IRichBolt in org.apache.storm.hdfs.bolt

  Classes in org.apache.storm.hdfs.bolt that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `AbstractHdfsBolt`
  `class`
  `AvroGenericRecordBolt`
  `class`
  `HdfsBolt`
  `static class`
  `HdfsFileTopology.MyBolt`
  `class`
  `SequenceFileBolt`
  `static class`
  `SequenceFileTopology.MyBolt`

- ## Uses of IRichBolt in org.apache.storm.hdfs.spout

  Classes in org.apache.storm.hdfs.spout that implement IRichBolt
  Modifier and Type
  Class
  Description
  `static class`
  `HdfsSpoutTopology.ConstBolt`

- ## Uses of IRichBolt in org.apache.storm.jdbc.bolt

  Classes in org.apache.storm.jdbc.bolt that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `AbstractJdbcBolt`
  `class`
  `JdbcInsertBolt`
  Basic bolt for writing to any Database table.
  `class`
  `JdbcLookupBolt`
  Basic bolt for querying from any database.

- ## Uses of IRichBolt in org.apache.storm.jms.bolt

  Classes in org.apache.storm.jms.bolt that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `JmsBolt`
  A JmsBolt receives `org.apache.storm.tuple.Tuple` objects from a Storm topology and publishes JMS Messages to a destination (topic or queue).

- ## Uses of IRichBolt in org.apache.storm.jms.example

  Classes in org.apache.storm.jms.example that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `GenericBolt`
  A generic `org.apache.storm.topology.IRichBolt` implementation for testing/debugging the Storm JMS Spout and example topologies.

- ## Uses of IRichBolt in org.apache.storm.kafka.bolt

  Classes in org.apache.storm.kafka.bolt that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `KafkaBolt<K,V>`
  Bolt implementation that can send Tuple data to Kafka.

- ## Uses of IRichBolt in org.apache.storm.kafka.spout

  Classes in org.apache.storm.kafka.spout that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `KafkaSpoutTestBolt`

- ## Uses of IRichBolt in org.apache.storm.loadgen

  Classes in org.apache.storm.loadgen that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `LoadBolt`
  A bolt that simulates a real world bolt based off of statistics about it.

- ## Uses of IRichBolt in org.apache.storm.perf.bolt

  Classes in org.apache.storm.perf.bolt that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `DevNullBolt`
  `class`
  `IdBolt`

- ## Uses of IRichBolt in org.apache.storm.perf.utils

  Classes in org.apache.storm.perf.utils that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `IdentityBolt`

- ## Uses of IRichBolt in org.apache.storm.redis.bolt

  Classes in org.apache.storm.redis.bolt that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `AbstractRedisBolt`
  AbstractRedisBolt class is for users to implement custom bolts which makes interaction with Redis.
  `class`
  `RedisFilterBolt`
  Basic bolt for querying from Redis and filters out if key/field doesn't exist.
  `class`
  `RedisLookupBolt`
  Basic bolt for querying from Redis and emits response as tuple.
  `class`
  `RedisStoreBolt`
  Basic bolt for writing to Redis.

- ## Uses of IRichBolt in org.apache.storm.redis.topology

  Classes in org.apache.storm.redis.topology that implement IRichBolt
  Modifier and Type
  Class
  Description
  `static class`
  `LookupWordCount.PrintWordTotalCountBolt`
  `static class`
  `WhitelistWordCount.PrintWordTotalCountBolt`

- ## Uses of IRichBolt in org.apache.storm.sql.runtime

  Methods in org.apache.storm.sql.runtime that return IRichBolt
  Modifier and Type
  Method
  Description
  `IRichBolt`
  ISqlStreamsDataSource.`getConsumer()`
  Provides instance of IRichBolt which can be used as consumer in topology.

- ## Uses of IRichBolt in org.apache.storm.sql.runtime.datasource.socket.bolt

  Classes in org.apache.storm.sql.runtime.datasource.socket.bolt that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `SocketBolt`
  The Bolt implementation for Socket.

- ## Uses of IRichBolt in org.apache.storm.starter

  Classes in org.apache.storm.starter that implement IRichBolt
  Modifier and Type
  Class
  Description
  `static class`
  `BlobStoreAPIWordCountTopology.SplitSentence`
  `static class`
  `ExclamationTopology.ExclamationBolt`
  `static class`
  `MultipleLoggerTopology.ExclamationLoggingBolt`
  `static class`
  `MultiThreadWordCountTopology.MultiThreadedSplitSentence`
  `static class`
  `ResourceAwareExampleTopology.ExclamationBolt`
  `static class`
  `WordCountTopology.SplitSentence`
  `static class`
  `WordCountTopologyNode.SplitSentence`

- ## Uses of IRichBolt in org.apache.storm.starter.bolt

  Classes in org.apache.storm.starter.bolt that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `RollingCountAggBolt`
  This bolt aggregates counts from multiple upstream bolts.
  `class`
  `RollingCountBolt`
  This bolt performs rolling counts of incoming objects, i.e.
  `class`
  `SingleJoinBolt`
  Example of a simple custom bolt for joining two streams.

- ## Uses of IRichBolt in org.apache.storm.streams

  Methods in org.apache.storm.streams with parameters of type IRichBolt
  Modifier and Type
  Method
  Description
  `void`
  Stream.`to(IRichBolt bolt)`
  Sends the elements of this stream to a bolt.
  `void`
  Stream.`to(IRichBolt bolt, int parallelism)`
  Sends the elements of this stream to a bolt.

- ## Uses of IRichBolt in org.apache.storm.testing

  Classes in org.apache.storm.testing that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `BoltTracker`
  `class`
  `PythonShellMetricsBolt`
  `class`
  `TestAggregatesCounter`
  `class`
  `TestEventOrderCheckBolt`
  `class`
  `TestGlobalCount`
  `class`
  `TestPlannerBolt`
  `class`
  `TupleCaptureBolt`
  Constructors in org.apache.storm.testing with parameters of type IRichBolt
  Modifier
  Constructor
  Description
  ``
  `BoltTracker(IRichBolt delegate, String id)`

- ## Uses of IRichBolt in org.apache.storm.topology

  Classes in org.apache.storm.topology that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `BaseStatefulBoltExecutor`
  Base class that abstracts the common logic for executing bolts in a stateful topology.
  `class`
  `BasicBoltExecutor`
  `class`
  `CheckpointTupleForwarder`
  Wraps `IRichBolt` and forwards checkpoint tuples in a stateful topology.
  `class`
  `PersistentWindowedBoltExecutor<T extends State>`
  Wraps a `IStatefulWindowedBolt` and handles the execution.
  `class`
  `StatefulBoltExecutor<T extends State>`
  Wraps a `IStatefulBolt` and manages the state of the bolt.
  `class`
  `StatefulWindowedBoltExecutor<T extends State>`
  Wraps a `IStatefulWindowedBolt` and handles the execution.
  `class`
  `WindowedBoltExecutor`
  An `IWindowedBolt` wrapper that does the windowing of tuples.
  Methods in org.apache.storm.topology with parameters of type IRichBolt
  Modifier and Type
  Method
  Description
  `BoltDeclarer`
  TopologyBuilder.`setBolt(String id, IRichBolt bolt)`
  Define a new bolt in this topology with parallelism of just one thread.
  `BoltDeclarer`
  TopologyBuilder.`setBolt(String id, IRichBolt bolt, Number parallelismHint)`
  Define a new bolt in this topology with the specified amount of parallelism.
  Constructors in org.apache.storm.topology with parameters of type IRichBolt
  Modifier
  Constructor
  Description
  ``
  `CheckpointTupleForwarder(IRichBolt bolt)`

- ## Uses of IRichBolt in org.apache.storm.topology.base

  Classes in org.apache.storm.topology.base that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `BaseRichBolt`
  `class`
  `BaseTickTupleAwareRichBolt`
  This class is based on BaseRichBolt, but is aware of tick tuple.

- ## Uses of IRichBolt in org.apache.storm.trident.topology

  Classes in org.apache.storm.trident.topology that implement IRichBolt
  Modifier and Type
  Class
  Description
  `class`
  `TridentBoltExecutor`