Uses of Interface
org.apache.storm.topology.IRichBolt
Packages that use IRichBolt
Package
Description
-
Uses of IRichBolt in org.apache.storm
Classes in org.apache.storm that implement IRichBolt -
Uses of IRichBolt in org.apache.storm.clojure
Classes in org.apache.storm.clojure that implement IRichBolt -
Uses of IRichBolt in org.apache.storm.coordination
Classes in org.apache.storm.coordination that implement IRichBoltModifier and TypeClassDescriptionclassclassCoordination requires the request ids to be globally unique for awhile.Constructors in org.apache.storm.coordination with parameters of type IRichBoltModifierConstructorDescriptionCoordinatedBolt(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 IRichBoltMethods in org.apache.storm.drpc with parameters of type IRichBoltModifier and TypeMethodDescriptionDeprecated.Deprecated.Constructors in org.apache.storm.drpc with parameters of type IRichBolt -
Uses of IRichBolt in org.apache.storm.flux.wrappers.bolts
Classes in org.apache.storm.flux.wrappers.bolts that implement IRichBoltModifier and TypeClassDescriptionclassA 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 IRichBoltModifier and TypeClassDescriptionclassclassclassstatic classclassstatic class -
Uses of IRichBolt in org.apache.storm.hdfs.spout
Classes in org.apache.storm.hdfs.spout that implement IRichBolt -
Uses of IRichBolt in org.apache.storm.jdbc.bolt
Classes in org.apache.storm.jdbc.bolt that implement IRichBoltModifier and TypeClassDescriptionclassclassBasic bolt for writing to any Database table.classBasic bolt for querying from any database. -
Uses of IRichBolt in org.apache.storm.jms.bolt
Classes in org.apache.storm.jms.bolt that implement IRichBoltModifier and TypeClassDescriptionclassA JmsBolt receivesorg.apache.storm.tuple.Tupleobjects 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 IRichBoltModifier and TypeClassDescriptionclassA genericorg.apache.storm.topology.IRichBoltimplementation 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 IRichBoltModifier and TypeClassDescriptionclassKafkaBolt<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 -
Uses of IRichBolt in org.apache.storm.loadgen
Classes in org.apache.storm.loadgen that implement IRichBoltModifier and TypeClassDescriptionclassA 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 -
Uses of IRichBolt in org.apache.storm.perf.utils
Classes in org.apache.storm.perf.utils that implement IRichBolt -
Uses of IRichBolt in org.apache.storm.redis.bolt
Classes in org.apache.storm.redis.bolt that implement IRichBoltModifier and TypeClassDescriptionclassAbstractRedisBolt class is for users to implement custom bolts which makes interaction with Redis.classBasic bolt for querying from Redis and filters out if key/field doesn't exist.classBasic bolt for querying from Redis and emits response as tuple.classBasic bolt for writing to Redis. -
Uses of IRichBolt in org.apache.storm.redis.topology
Classes in org.apache.storm.redis.topology that implement IRichBoltModifier and TypeClassDescriptionstatic classstatic class -
Uses of IRichBolt in org.apache.storm.sql.runtime
Methods in org.apache.storm.sql.runtime that return IRichBoltModifier and TypeMethodDescriptionISqlStreamsDataSource.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 -
Uses of IRichBolt in org.apache.storm.starter
Classes in org.apache.storm.starter that implement IRichBoltModifier and TypeClassDescriptionstatic classstatic classstatic classstatic classstatic classstatic classstatic class -
Uses of IRichBolt in org.apache.storm.starter.bolt
Classes in org.apache.storm.starter.bolt that implement IRichBoltModifier and TypeClassDescriptionclassThis bolt aggregates counts from multiple upstream bolts.classThis bolt performs rolling counts of incoming objects, i.e.classExample 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 -
Uses of IRichBolt in org.apache.storm.testing
Classes in org.apache.storm.testing that implement IRichBoltModifier and TypeClassDescriptionclassclassclassclassclassclassclassConstructors in org.apache.storm.testing with parameters of type IRichBolt -
Uses of IRichBolt in org.apache.storm.topology
Classes in org.apache.storm.topology that implement IRichBoltModifier and TypeClassDescriptionclassBase class that abstracts the common logic for executing bolts in a stateful topology.classclassWrapsIRichBoltand forwards checkpoint tuples in a stateful topology.classPersistentWindowedBoltExecutor<T extends State>Wraps aIStatefulWindowedBoltand handles the execution.classStatefulBoltExecutor<T extends State>Wraps aIStatefulBoltand manages the state of the bolt.classStatefulWindowedBoltExecutor<T extends State>Wraps aIStatefulWindowedBoltand handles the execution.classAnIWindowedBoltwrapper that does the windowing of tuples.Methods in org.apache.storm.topology with parameters of type IRichBoltModifier and TypeMethodDescriptionDefine a new bolt in this topology with parallelism of just one thread.Define a new bolt in this topology with the specified amount of parallelism.Constructors in org.apache.storm.topology with parameters of type IRichBolt -
Uses of IRichBolt in org.apache.storm.topology.base
Classes in org.apache.storm.topology.base that implement IRichBoltModifier and TypeClassDescriptionclassclassThis 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