Uses of Class
org.apache.storm.topology.base.BaseRichBolt
Package
Description
ElasticSearch examples classes.
-
Uses of BaseRichBolt in org.apache.storm
-
Uses of BaseRichBolt in org.apache.storm.drpc
-
Uses of BaseRichBolt in org.apache.storm.elasticsearch.bolt
Modifier and TypeClassDescriptionclass
class
Basic bolt for storing tuple to ES document.class
Basic bolt for looking up document in ES.class
Basic bolt for retrieve matched percolate queries. -
Uses of BaseRichBolt in org.apache.storm.hdfs.bolt
Modifier and TypeClassDescriptionclass
class
class
static class
class
static class
-
Uses of BaseRichBolt in org.apache.storm.hdfs.spout
-
Uses of BaseRichBolt in org.apache.storm.hive.bolt
-
Uses of BaseRichBolt in org.apache.storm.jdbc.bolt
Modifier and TypeClassDescriptionclass
class
Basic bolt for writing to any Database table.class
Basic bolt for querying from any database. -
Uses of BaseRichBolt in org.apache.storm.jms.bolt
Modifier and TypeClassDescriptionclass
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
Modifier and TypeClassDescriptionclass
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
Modifier and TypeClassDescriptionclass
KafkaBolt<K,
V> Bolt implementation that can send Tuple data to Kafka. -
Uses of BaseRichBolt in org.apache.storm.kafka.spout
-
Uses of BaseRichBolt in org.apache.storm.loadgen
Modifier and TypeClassDescriptionclass
A bolt that simulates a real world bolt based off of statistics about it. -
Uses of BaseRichBolt in org.apache.storm.perf.bolt
-
Uses of BaseRichBolt in org.apache.storm.perf.utils
-
Uses of BaseRichBolt in org.apache.storm.redis.bolt
Modifier and TypeClassDescriptionclass
AbstractRedisBolt class is for users to implement custom bolts which makes interaction with Redis.class
Basic bolt for querying from Redis and filters out if key/field doesn't exist.class
Basic bolt for querying from Redis and emits response as tuple.class
Basic bolt for writing to Redis. -
Uses of BaseRichBolt in org.apache.storm.redis.topology
Modifier and TypeClassDescriptionstatic class
static class
-
Uses of BaseRichBolt in org.apache.storm.sql.runtime.datasource.socket.bolt
-
Uses of BaseRichBolt in org.apache.storm.starter
Modifier and TypeClassDescriptionstatic class
static class
static class
-
Uses of BaseRichBolt in org.apache.storm.starter.bolt
Modifier and TypeClassDescriptionclass
This bolt aggregates counts from multiple upstream bolts.class
This bolt performs rolling counts of incoming objects, i.e. sliding window based counting.class
Example of a simple custom bolt for joining two streams. -
Uses of BaseRichBolt in org.apache.storm.testing
Modifier and TypeClassDescriptionclass
class
class
class
-
Uses of BaseRichBolt in org.apache.storm.topology.base
Modifier and TypeClassDescriptionclass
This class is based on BaseRichBolt, but is aware of tick tuple.