Uses of Class
org.apache.storm.topology.base.BaseRichBolt
-
-
Uses of BaseRichBolt in org.apache.storm
Subclasses of BaseRichBolt in org.apache.storm Modifier and Type Class Description static class
ExclamationTopology.ExclamationBolt
-
Uses of BaseRichBolt in org.apache.storm.drpc
Subclasses of BaseRichBolt in org.apache.storm.drpc Modifier and Type Class Description class
JoinResult
class
ReturnResults
-
Uses of BaseRichBolt in org.apache.storm.hdfs.bolt
Subclasses of BaseRichBolt in org.apache.storm.hdfs.bolt Modifier and Type Class Description class
AbstractHdfsBolt
class
AvroGenericRecordBolt
class
HdfsBolt
static class
HdfsFileTopology.MyBolt
class
SequenceFileBolt
static class
SequenceFileTopology.MyBolt
-
Uses of BaseRichBolt in org.apache.storm.hdfs.spout
Subclasses of BaseRichBolt in org.apache.storm.hdfs.spout Modifier and Type Class Description static class
HdfsSpoutTopology.ConstBolt
-
Uses of BaseRichBolt in org.apache.storm.hive.bolt
Subclasses of BaseRichBolt in org.apache.storm.hive.bolt Modifier and Type Class Description class
HiveBolt
Deprecated, for removal: This API element is subject to removal in a future version. -
Uses of BaseRichBolt in org.apache.storm.jdbc.bolt
Subclasses of BaseRichBolt in org.apache.storm.jdbc.bolt 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 BaseRichBolt in org.apache.storm.jms.bolt
Subclasses of BaseRichBolt in org.apache.storm.jms.bolt Modifier and Type Class Description class
JmsBolt
A JmsBolt receivesorg.apache.storm.tuple.Tuple
objects from a Storm topology and publishes JMS Messages to a destination (topic or queue). -
Uses of BaseRichBolt in org.apache.storm.jms.example
Subclasses of BaseRichBolt in org.apache.storm.jms.example Modifier and Type Class Description class
GenericBolt
A genericorg.apache.storm.topology.IRichBolt
implementation for testing/debugging the Storm JMS Spout and example topologies. -
Uses of BaseRichBolt in org.apache.storm.kafka.bolt
Subclasses of BaseRichBolt in org.apache.storm.kafka.bolt Modifier and Type Class Description class
KafkaBolt<K,V>
Bolt implementation that can send Tuple data to Kafka. -
Uses of BaseRichBolt in org.apache.storm.kafka.spout
Subclasses of BaseRichBolt in org.apache.storm.kafka.spout Modifier and Type Class Description class
KafkaSpoutTestBolt
-
Uses of BaseRichBolt in org.apache.storm.loadgen
Subclasses of BaseRichBolt in org.apache.storm.loadgen Modifier and Type Class Description class
LoadBolt
A bolt that simulates a real world bolt based off of statistics about it. -
Uses of BaseRichBolt in org.apache.storm.perf.bolt
Subclasses of BaseRichBolt in org.apache.storm.perf.bolt Modifier and Type Class Description class
DevNullBolt
class
IdBolt
-
Uses of BaseRichBolt in org.apache.storm.perf.utils
Subclasses of BaseRichBolt in org.apache.storm.perf.utils Modifier and Type Class Description class
IdentityBolt
-
Uses of BaseRichBolt in org.apache.storm.redis.bolt
Subclasses of BaseRichBolt in org.apache.storm.redis.bolt 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 BaseRichBolt in org.apache.storm.redis.topology
Subclasses of BaseRichBolt in org.apache.storm.redis.topology Modifier and Type Class Description static class
LookupWordCount.PrintWordTotalCountBolt
static class
WhitelistWordCount.PrintWordTotalCountBolt
-
Uses of BaseRichBolt in org.apache.storm.sql.runtime.datasource.socket.bolt
Subclasses of BaseRichBolt in org.apache.storm.sql.runtime.datasource.socket.bolt Modifier and Type Class Description class
SocketBolt
The Bolt implementation for Socket. -
Uses of BaseRichBolt in org.apache.storm.starter
Subclasses of BaseRichBolt in org.apache.storm.starter Modifier and Type Class Description static class
ExclamationTopology.ExclamationBolt
static class
MultipleLoggerTopology.ExclamationLoggingBolt
static class
ResourceAwareExampleTopology.ExclamationBolt
-
Uses of BaseRichBolt in org.apache.storm.starter.bolt
Subclasses of BaseRichBolt in org.apache.storm.starter.bolt 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 BaseRichBolt in org.apache.storm.testing
Subclasses of BaseRichBolt in org.apache.storm.testing Modifier and Type Class Description class
TestAggregatesCounter
class
TestEventOrderCheckBolt
class
TestGlobalCount
class
TestPlannerBolt
-
Uses of BaseRichBolt in org.apache.storm.topology.base
Subclasses of BaseRichBolt in org.apache.storm.topology.base Modifier and Type Class Description class
BaseTickTupleAwareRichBolt
This class is based on BaseRichBolt, but is aware of tick tuple.
-