Uses of Class
org.apache.storm.topology.base.BaseComponent
Package
Description
ElasticSearch examples classes.
-
Uses of BaseComponent in org.apache.storm
Modifier and TypeClassDescriptionstatic class
static class
-
Uses of BaseComponent in org.apache.storm.drpc
Modifier and TypeClassDescriptionclass
class
class
class
-
Uses of BaseComponent in org.apache.storm.elasticsearch.bolt
Modifier and TypeClassDescriptionclass
class
Basic bolt for storing tuple to ES document.static class
The user data spout.class
Basic bolt for looking up document in ES.class
Basic bolt for retrieve matched percolate queries. -
Uses of BaseComponent in org.apache.storm.flux.examples
Modifier and TypeClassDescriptionclass
Prints the tuples to stdout.class
This bolt is used by the HBase example. -
Uses of BaseComponent in org.apache.storm.flux.wrappers.bolts
Modifier and TypeClassDescriptionclass
Simple bolt that does nothing other than LOG.info() every tuple recieveed. -
Uses of BaseComponent in org.apache.storm.hdfs.bolt
Modifier and TypeClassDescriptionclass
class
class
static class
static class
class
static class
static class
-
Uses of BaseComponent in org.apache.storm.hdfs.spout
-
Uses of BaseComponent in org.apache.storm.hive.bolt
Modifier and TypeClassDescriptionstatic class
class
static class
static class
-
Uses of BaseComponent 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 BaseComponent 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 BaseComponent 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 BaseComponent in org.apache.storm.jms.spout
Modifier and TypeClassDescriptionclass
A StormSpout
implementation that listens to a JMS topic or queue and outputs tuples based on the messages it receives. -
Uses of BaseComponent in org.apache.storm.kafka.bolt
Modifier and TypeClassDescriptionclass
KafkaBolt<K,
V> Bolt implementation that can send Tuple data to Kafka. -
Uses of BaseComponent in org.apache.storm.kafka.spout
-
Uses of BaseComponent in org.apache.storm.lambda
Modifier and TypeClassDescriptionclass
class
class
-
Uses of BaseComponent in org.apache.storm.loadgen
Modifier and TypeClassDescriptionclass
A bolt that simulates a real world bolt based off of statistics about it.class
A spout that simulates a real world spout based off of statistics about it.static class
static class
static class
-
Uses of BaseComponent in org.apache.storm.perf.bolt
Modifier and TypeClassDescriptionclass
class
class
class
-
Uses of BaseComponent in org.apache.storm.perf.spout
Modifier and TypeClassDescriptionclass
class
class
Spout pre-computes a list with 30k fixed length random strings.class
-
Uses of BaseComponent in org.apache.storm.perf.utils
-
Uses of BaseComponent 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 BaseComponent in org.apache.storm.redis.topology
Modifier and TypeClassDescriptionstatic class
static class
-
Uses of BaseComponent in org.apache.storm.spout
Modifier and TypeClassDescriptionclass
Emits checkpoint tuples which is used to save the state of theIStatefulComponent
across the topology. -
Uses of BaseComponent in org.apache.storm.sql.runtime.datasource.socket.bolt
-
Uses of BaseComponent in org.apache.storm.st.topology.window
-
Uses of BaseComponent in org.apache.storm.starter
Modifier and TypeClassDescriptionstatic class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
-
Uses of BaseComponent in org.apache.storm.starter.bolt
Modifier and TypeClassDescriptionclass
This abstract bolt provides the basic behavior of bolts that rank objects according to their count.final class
This bolt ranks incoming objects by their count.class
class
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.final class
This bolt merges incomingRankings
.class
-
Uses of BaseComponent in org.apache.storm.starter.spout
Modifier and TypeClassDescriptionclass
Emits a random integer and a timestamp value (offset by one day), every 100 ms.class
static class
-
Uses of BaseComponent in org.apache.storm.testing
Modifier and TypeClassDescriptionclass
class
class
class
class
class
class
class
class
class
class
class
class
class
-
Uses of BaseComponent in org.apache.storm.topology.base
Modifier and TypeClassDescriptionclass
class
class
class
class
This class is based on BaseRichBolt, but is aware of tick tuple. -
Uses of BaseComponent in org.apache.storm.trident.topology