Uses of Interface
org.apache.storm.spout.ISpout
Packages that use ISpout
Package
Description
ElasticSearch examples classes.
-
Uses of ISpout in org.apache.storm
Classes in org.apache.storm that implement ISpout -
Uses of ISpout in org.apache.storm.clojure
Classes in org.apache.storm.clojure that implement ISpout -
Uses of ISpout in org.apache.storm.drpc
Classes in org.apache.storm.drpc that implement ISpout -
Uses of ISpout in org.apache.storm.elasticsearch.bolt
Classes in org.apache.storm.elasticsearch.bolt that implement ISpout -
Uses of ISpout in org.apache.storm.executor.spout
Constructors in org.apache.storm.executor.spout with parameters of type ISpoutModifierConstructorDescriptionSpoutOutputCollectorImpl
(ISpout spout, SpoutExecutor executor, Task taskData, MutableLong emittedCount, boolean hasAckers, Random random, Boolean isEventLoggers, Boolean isDebug, RotatingMap<Long, TupleInfo> pending) -
Uses of ISpout in org.apache.storm.flux.wrappers.spouts
Classes in org.apache.storm.flux.wrappers.spouts that implement ISpoutModifier 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 ISpout in org.apache.storm.hdfs.bolt
Classes in org.apache.storm.hdfs.bolt that implement ISpoutModifier and TypeClassDescriptionstatic class
static class
-
Uses of ISpout in org.apache.storm.hdfs.spout
Classes in org.apache.storm.hdfs.spout that implement ISpout -
Uses of ISpout in org.apache.storm.hive.bolt
Classes in org.apache.storm.hive.bolt that implement ISpoutModifier and TypeClassDescriptionstatic class
static class
static class
-
Uses of ISpout in org.apache.storm.jdbc.spout
Classes in org.apache.storm.jdbc.spout that implement ISpout -
Uses of ISpout in org.apache.storm.jms.spout
Classes in org.apache.storm.jms.spout that implement ISpoutModifier and TypeClassDescriptionclass
A StormSpout
implementation that listens to a JMS topic or queue and outputs tuples based on the messages it receives. -
Uses of ISpout in org.apache.storm.kafka.spout
Classes in org.apache.storm.kafka.spout that implement ISpout -
Uses of ISpout in org.apache.storm.lambda
Classes in org.apache.storm.lambda that implement ISpout -
Uses of ISpout in org.apache.storm.loadgen
Classes in org.apache.storm.loadgen that implement ISpoutModifier and TypeClassDescriptionclass
A spout that simulates a real world spout based off of statistics about it.static class
-
Uses of ISpout in org.apache.storm.perf.spout
Classes in org.apache.storm.perf.spout that implement ISpoutModifier and TypeClassDescriptionclass
class
class
Spout pre-computes a list with 30k fixed length random strings.class
-
Uses of ISpout in org.apache.storm.redis.topology
Classes in org.apache.storm.redis.topology that implement ISpout -
Uses of ISpout in org.apache.storm.spout
Classes in org.apache.storm.spout that implement ISpoutModifier and TypeClassDescriptionclass
Emits checkpoint tuples which is used to save the state of theIStatefulComponent
across the topology.class
-
Uses of ISpout in org.apache.storm.sql.runtime.datasource.socket.spout
Classes in org.apache.storm.sql.runtime.datasource.socket.spout that implement ISpout -
Uses of ISpout in org.apache.storm.st.topology.window
Classes in org.apache.storm.st.topology.window that implement ISpout -
Uses of ISpout in org.apache.storm.starter
Classes in org.apache.storm.starter that implement ISpoutModifier and TypeClassDescriptionstatic class
static class
static class
static class
static class
-
Uses of ISpout in org.apache.storm.starter.spout
Classes in org.apache.storm.starter.spout that implement ISpoutModifier and TypeClassDescriptionclass
Emits a random integer and a timestamp value (offset by one day), every 100 ms.class
static class
-
Uses of ISpout in org.apache.storm.testing
Classes in org.apache.storm.testing that implement ISpoutModifier and TypeClassDescriptionclass
class
class
class
class
class
class
-
Uses of ISpout in org.apache.storm.topology
Subinterfaces of ISpout in org.apache.storm.topologyModifier and TypeInterfaceDescriptioninterface
When writing topologies using Java,IRichBolt
andIRichSpout
are the main interfaces to use to implement components of the topology. -
Uses of ISpout in org.apache.storm.topology.base
Classes in org.apache.storm.topology.base that implement ISpout -
Uses of ISpout in org.apache.storm.trident.spout
Classes in org.apache.storm.trident.spout that implement ISpout -
Uses of ISpout in org.apache.storm.trident.topology
Classes in org.apache.storm.trident.topology that implement ISpout