Uses of Interface
org.apache.storm.topology.IComponent
Package
Description
ElasticSearch examples classes.
-
Uses of IComponent in org.apache.storm
Modifier and TypeClassDescriptionstatic class
static class
-
Uses of IComponent in org.apache.storm.bolt
-
Uses of IComponent in org.apache.storm.clojure
Modifier and TypeClassDescriptionclass
class
class
class
-
Uses of IComponent in org.apache.storm.coordination
Modifier and TypeClassDescriptionclass
class
Coordination requires the request ids to be globally unique for awhile. -
Uses of IComponent in org.apache.storm.drpc
Modifier and TypeClassDescriptionclass
class
class
class
class
-
Uses of IComponent 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 IComponent in org.apache.storm.flux.examples
Modifier and TypeClassDescriptionclass
class
Prints the tuples to stdout.class
class
This bolt is used by the HBase example. -
Uses of IComponent in org.apache.storm.flux.wrappers.bolts
Modifier and TypeClassDescriptionclass
A generic `ShellBolt` implementation that allows you specify output fields and even streams without having to subclass `ShellBolt` to do so.class
Simple bolt that does nothing other than LOG.info() every tuple recieveed. -
Uses of IComponent in org.apache.storm.flux.wrappers.spouts
Modifier and TypeClassDescriptionclass
A generic `ShellSpout` implementation that allows you specify output fields and even streams without having to subclass `ShellSpout` to do so. -
Uses of IComponent in org.apache.storm.hdfs.bolt
Modifier and TypeClassDescriptionclass
class
class
static class
static class
class
static class
static class
-
Uses of IComponent in org.apache.storm.hdfs.spout
-
Uses of IComponent in org.apache.storm.hive.bolt
Modifier and TypeClassDescriptionstatic class
class
static class
static class
-
Uses of IComponent 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 IComponent in org.apache.storm.jdbc.spout
-
Uses of IComponent 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 IComponent 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 IComponent 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 IComponent in org.apache.storm.kafka.bolt
Modifier and TypeClassDescriptionclass
KafkaBolt<K,
V> Bolt implementation that can send Tuple data to Kafka. -
Uses of IComponent in org.apache.storm.kafka.spout
-
Uses of IComponent in org.apache.storm.lambda
Modifier and TypeClassDescriptionclass
class
class
-
Uses of IComponent 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 IComponent in org.apache.storm.perf.bolt
Modifier and TypeClassDescriptionclass
class
class
class
-
Uses of IComponent 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 IComponent in org.apache.storm.perf.utils
-
Uses of IComponent 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 IComponent in org.apache.storm.redis.topology
Modifier and TypeClassDescriptionstatic class
static class
class
class
-
Uses of IComponent 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 IComponent in org.apache.storm.sql.runtime.datasource.socket.bolt
-
Uses of IComponent in org.apache.storm.sql.runtime.datasource.socket.spout
-
Uses of IComponent in org.apache.storm.st.topology.window
Modifier and TypeClassDescriptionclass
class
class
class
-
Uses of IComponent 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
static class
static class
static class
static class
static class
-
Uses of IComponent 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.class
Computes sliding window sum.final class
This bolt merges incomingRankings
.class
-
Uses of IComponent 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 IComponent in org.apache.storm.testing
Modifier and TypeClassDescriptionclass
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
class
-
Uses of IComponent in org.apache.storm.topology
Modifier and TypeInterfaceDescriptioninterface
interface
When writing topologies using Java,IRichBolt
andIRichSpout
are the main interfaces to use to implement components of the topology.interface
When writing topologies using Java,IRichBolt
andIRichSpout
are the main interfaces to use to implement components of the topology.interface
interface
IStatefulBolt<T extends State>
A bolt abstraction for supporting stateful computation.interface
IStatefulComponent<T extends State>
Common methods for stateful components in the topology.interface
IStatefulWindowedBolt<T extends State>
A windowed bolt abstraction for supporting windowing operation with state.interface
A bolt abstraction for supporting time and count based sliding & tumbling windows.Modifier and TypeClassDescriptionclass
Base class that abstracts the common logic for executing bolts in a stateful topology.class
class
WrapsIRichBolt
and forwards checkpoint tuples in a stateful topology.class
PersistentWindowedBoltExecutor<T extends State>
Wraps aIStatefulWindowedBolt
and handles the execution.class
StatefulBoltExecutor<T extends State>
Wraps aIStatefulBolt
and manages the state of the bolt.class
StatefulWindowedBoltExecutor<T extends State>
Wraps aIStatefulWindowedBolt
and handles the execution.class
AnIWindowedBolt
wrapper that does the windowing of tuples. -
Uses of IComponent in org.apache.storm.topology.base
Modifier and TypeClassDescriptionclass
class
class
class
class
class
BaseStatefulBolt<T extends State>
class
BaseStatefulWindowedBolt<T extends State>
class
This class is based on BaseRichBolt, but is aware of tick tuple.class
-
Uses of IComponent in org.apache.storm.trident.planner
Modifier and TypeClassDescriptionclass
A Bolt that does processing for a subsection of the complete graph. -
Uses of IComponent in org.apache.storm.trident.spout
Modifier and TypeClassDescriptionclass
class
class
-
Uses of IComponent in org.apache.storm.trident.topology
-
Uses of IComponent in org.apache.storm.trident.util
Modifier and TypeMethodDescriptionstatic Fields
TridentUtils.getSingleOutputStreamFields
(IComponent component)