Uses of Interface
org.apache.storm.topology.IRichSpout

Packages that use IRichSpout

Package	Description
org.apache.storm
org.apache.storm.clojure
org.apache.storm.drpc
org.apache.storm.elasticsearch.bolt	ElasticSearch examples classes.
org.apache.storm.eventhubs.spout
org.apache.storm.flux.model
org.apache.storm.flux.wrappers.spouts
org.apache.storm.hdfs.bolt
org.apache.storm.hdfs.spout
org.apache.storm.hive.bolt
org.apache.storm.jdbc.spout
org.apache.storm.jms.spout
org.apache.storm.kafka.spout
org.apache.storm.kinesis.spout
org.apache.storm.lambda
org.apache.storm.loadgen
org.apache.storm.mongodb.topology
org.apache.storm.mqtt.spout
org.apache.storm.opentsdb
org.apache.storm.perf.spout
org.apache.storm.pmml
org.apache.storm.rocketmq.spout
org.apache.storm.solr.spout
org.apache.storm.spout
org.apache.storm.sql.runtime
org.apache.storm.sql.runtime.datasource.socket.spout
org.apache.storm.st.topology.window
org.apache.storm.starter
org.apache.storm.starter.spout
org.apache.storm.streams
org.apache.storm.testing
org.apache.storm.topology
org.apache.storm.topology.base
org.apache.storm.trident
org.apache.storm.trident.spout
org.apache.storm.trident.topology

Uses of IRichSpout in org.apache.storm

Classes in org.apache.storm that implement IRichSpout

Modifier and Type	Class and Description
static class	ExclamationTopology.FixedOrderWordSpout

Methods in org.apache.storm that return IRichSpout

Modifier and Type	Method and Description
IRichSpout	Thrift.SpoutDetails.getSpout()

Methods in org.apache.storm with parameters of type IRichSpout

Modifier and Type	Method and Description
static SpoutSpec	Thrift.prepareSerializedSpoutDetails(IRichSpout spout, Map<String,StreamInfo> outputs)
static Thrift.SpoutDetails	Thrift.prepareSpoutDetails(IRichSpout spout)
static Thrift.SpoutDetails	Thrift.prepareSpoutDetails(IRichSpout spout, Integer parallelismHint)
static Thrift.SpoutDetails	Thrift.prepareSpoutDetails(IRichSpout spout, Integer parallelismHint, Map<String,Object> conf)

Constructors in org.apache.storm with parameters of type IRichSpout

Constructor and Description
SpoutDetails(IRichSpout spout, Integer parallelism, Map<String,Object> conf)

Uses of IRichSpout in org.apache.storm.clojure

Classes in org.apache.storm.clojure that implement IRichSpout

Modifier and Type	Class and Description
class	ClojureSpout
class	RichShellSpout

Uses of IRichSpout in org.apache.storm.drpc

Classes in org.apache.storm.drpc that implement IRichSpout

Modifier and Type	Class and Description
class	DRPCSpout

Uses of IRichSpout in org.apache.storm.elasticsearch.bolt

Classes in org.apache.storm.elasticsearch.bolt that implement IRichSpout

Modifier and Type	Class and Description
static class	EsIndexTopology.UserDataSpout The user data spout.

Uses of IRichSpout in org.apache.storm.eventhubs.spout

Classes in org.apache.storm.eventhubs.spout that implement IRichSpout

Modifier and Type	Class and Description
class	EventHubSpout

Uses of IRichSpout in org.apache.storm.flux.model

Methods in org.apache.storm.flux.model with parameters of type IRichSpout

Modifier and Type	Method and Description
void	ExecutionContext.addSpout(String id, IRichSpout spout)

Uses of IRichSpout in org.apache.storm.flux.wrappers.spouts

Classes in org.apache.storm.flux.wrappers.spouts that implement IRichSpout

Modifier and Type	Class and Description
class	FluxShellSpout A generic ShellSpout implementation that allows you specify output fields and even streams without having to subclass ShellSpout to do so.

Uses of IRichSpout in org.apache.storm.hdfs.bolt

Classes in org.apache.storm.hdfs.bolt that implement IRichSpout

Modifier and Type	Class and Description
static class	HdfsFileTopology.SentenceSpout
static class	SequenceFileTopology.SentenceSpout

Uses of IRichSpout in org.apache.storm.hdfs.spout

Classes in org.apache.storm.hdfs.spout that implement IRichSpout

Modifier and Type	Class and Description
class	HdfsSpout

Uses of IRichSpout in org.apache.storm.hive.bolt

Classes in org.apache.storm.hive.bolt that implement IRichSpout

Modifier and Type	Class and Description
static class	BucketTestHiveTopology.UserDataSpout
static class	HiveTopology.UserDataSpout
static class	HiveTopologyPartitioned.UserDataSpout

Uses of IRichSpout in org.apache.storm.jdbc.spout

Classes in org.apache.storm.jdbc.spout that implement IRichSpout

Modifier and Type	Class and Description
class	UserSpout

Uses of IRichSpout in org.apache.storm.jms.spout

Classes in org.apache.storm.jms.spout that implement IRichSpout

Modifier and Type	Class and Description
class	JmsSpout A Storm Spout implementation that listens to a JMS topic or queue and outputs tuples based on the messages it receives.

Uses of IRichSpout in org.apache.storm.kafka.spout

Classes in org.apache.storm.kafka.spout that implement IRichSpout

Modifier and Type	Class and Description
class	KafkaSpout<K,V>

Uses of IRichSpout in org.apache.storm.kinesis.spout

Classes in org.apache.storm.kinesis.spout that implement IRichSpout

Modifier and Type	Class and Description
class	KinesisSpout

Uses of IRichSpout in org.apache.storm.lambda

Classes in org.apache.storm.lambda that implement IRichSpout

Modifier and Type	Class and Description
class	LambdaSpout

Uses of IRichSpout in org.apache.storm.loadgen

Classes in org.apache.storm.loadgen that implement IRichSpout

Modifier and Type	Class and Description
class	LoadSpout A spout that simulates a real world spout based off of statistics about it.
static class	ThroughputVsLatency.FastRandomSentenceSpout

Uses of IRichSpout in org.apache.storm.mongodb.topology

Classes in org.apache.storm.mongodb.topology that implement IRichSpout

Modifier and Type	Class and Description
class	WordSpout

Uses of IRichSpout in org.apache.storm.mqtt.spout

Classes in org.apache.storm.mqtt.spout that implement IRichSpout

Modifier and Type	Class and Description
class	MqttSpout

Uses of IRichSpout in org.apache.storm.opentsdb

Classes in org.apache.storm.opentsdb that implement IRichSpout

Modifier and Type	Class and Description
class	MetricGenSpout Spout to generate tuples containing metric data.

Uses of IRichSpout in org.apache.storm.perf.spout

Classes in org.apache.storm.perf.spout that implement IRichSpout

Modifier and Type	Class and Description
class	ConstSpout
class	FileReadSpout
class	StringGenSpout Spout pre-computes a list with 30k fixed length random strings.
class	WordGenSpout

Uses of IRichSpout in org.apache.storm.pmml

Classes in org.apache.storm.pmml that implement IRichSpout

Modifier and Type	Class and Description
class	RawInputFromCSVSpout

Uses of IRichSpout in org.apache.storm.rocketmq.spout

Classes in org.apache.storm.rocketmq.spout that implement IRichSpout

Modifier and Type	Class and Description
class	RocketMqSpout RocketMqSpout uses MQPushConsumer as the default implementation.

Uses of IRichSpout in org.apache.storm.solr.spout

Classes in org.apache.storm.solr.spout that implement IRichSpout

Modifier and Type	Class and Description
class	SolrFieldsSpout
class	SolrJsonSpout

Uses of IRichSpout in org.apache.storm.spout

Classes in org.apache.storm.spout that implement IRichSpout

Modifier and Type	Class and Description
class	CheckpointSpout Emits checkpoint tuples which is used to save the state of the IStatefulComponent across the topology.

Uses of IRichSpout in org.apache.storm.sql.runtime

Methods in org.apache.storm.sql.runtime that return IRichSpout

Modifier and Type	Method and Description
IRichSpout	ISqlStreamsDataSource.getProducer() Provides instance of IRichSpout which can be used as producer in topology.

Uses of IRichSpout in org.apache.storm.sql.runtime.datasource.socket.spout

Classes in org.apache.storm.sql.runtime.datasource.socket.spout that implement IRichSpout

Modifier and Type	Class and Description
class	SocketSpout Spout for Socket data.

Uses of IRichSpout in org.apache.storm.st.topology.window

Classes in org.apache.storm.st.topology.window that implement IRichSpout

Modifier and Type	Class and Description
class	IncrementingSpout
class	TimeDataIncrementingSpout

Uses of IRichSpout in org.apache.storm.starter

Classes in org.apache.storm.starter that implement IRichSpout

Modifier and Type	Class and Description
static class	AnchoredWordCount.RandomSentenceSpout
static class	BlobStoreAPIWordCountTopology.RandomSentenceSpout
static class	FastWordCountTopology.FastRandomSentenceSpout
static class	InOrderDeliveryTest.InOrderSpout
static class	WordCountTopologyNode.RandomSentence

Uses of IRichSpout in org.apache.storm.starter.spout

Classes in org.apache.storm.starter.spout that implement IRichSpout

Modifier and Type	Class and Description
class	RandomIntegerSpout Emits a random integer and a timestamp value (offset by one day), every 100 ms.
class	RandomSentenceSpout
static class	RandomSentenceSpout.TimeStamped

Uses of IRichSpout in org.apache.storm.streams

Methods in org.apache.storm.streams with parameters of type IRichSpout

Modifier and Type	Method and Description
Stream<Tuple>	StreamBuilder.newStream(IRichSpout spout) Creates a new Stream of tuples from the given IRichSpout
Stream<Tuple>	StreamBuilder.newStream(IRichSpout spout, int parallelism) Creates a new Stream of tuples from the given IRichSpout with the given parallelism.
<K,V> PairStream<K,V>	StreamBuilder.newStream(IRichSpout spout, PairValueMapper<K,V> pairValueMapper) Creates a new PairStream of key-value pairs from the given IRichSpout by extracting key and value from tuples via the supplied PairValueMapper.
<K,V> PairStream<K,V>	StreamBuilder.newStream(IRichSpout spout, PairValueMapper<K,V> pairValueMapper, int parallelism) Creates a new PairStream of key-value pairs from the given IRichSpout by extracting key and value from tuples via the supplied PairValueMapper and with the given value of parallelism.
<T> Stream<T>	StreamBuilder.newStream(IRichSpout spout, TupleValueMapper<T> valueMapper) Creates a new Stream of values from the given IRichSpout by extracting field(s) from tuples via the supplied TupleValueMapper.
<T> Stream<T>	StreamBuilder.newStream(IRichSpout spout, TupleValueMapper<T> valueMapper, int parallelism) Creates a new Stream of values from the given IRichSpout by extracting field(s) from tuples via the supplied TupleValueMapper with the given parallelism.

Uses of IRichSpout in org.apache.storm.testing

Classes in org.apache.storm.testing that implement IRichSpout

Modifier and Type	Class and Description
class	FeederSpout
class	FixedTupleSpout
class	PythonShellMetricsSpout
class	SpoutTracker
class	TestEventLogSpout
class	TestPlannerSpout
class	TestWordSpout

Constructors in org.apache.storm.testing with parameters of type IRichSpout

Constructor and Description
SpoutTracker(IRichSpout delegate, String trackId)

Uses of IRichSpout in org.apache.storm.topology

Methods in org.apache.storm.topology with parameters of type IRichSpout

Modifier and Type	Method and Description
SpoutDeclarer	TopologyBuilder.setSpout(String id, IRichSpout spout) Define a new spout in this topology.
SpoutDeclarer	TopologyBuilder.setSpout(String id, IRichSpout spout, Number parallelism_hint) Define a new spout in this topology with the specified parallelism.

Uses of IRichSpout in org.apache.storm.topology.base

Classes in org.apache.storm.topology.base that implement IRichSpout

Modifier and Type	Class and Description
class	BaseRichSpout

Uses of IRichSpout in org.apache.storm.trident

Methods in org.apache.storm.trident with parameters of type IRichSpout

Modifier and Type	Method and Description
Stream	TridentTopology.newStream(String txId, IRichSpout spout)

Uses of IRichSpout in org.apache.storm.trident.spout

Classes in org.apache.storm.trident.spout that implement IRichSpout

Modifier and Type	Class and Description
class	RichSpoutBatchTriggerer

Constructors in org.apache.storm.trident.spout with parameters of type IRichSpout

Constructor and Description
RichSpoutBatchExecutor(IRichSpout spout)
RichSpoutBatchTriggerer(IRichSpout delegate, String streamName, String batchGroup)

Uses of IRichSpout in org.apache.storm.trident.topology

Classes in org.apache.storm.trident.topology that implement IRichSpout

Modifier and Type	Class and Description
class	MasterBatchCoordinator

Methods in org.apache.storm.trident.topology with parameters of type IRichSpout

Modifier and Type	Method and Description
SpoutDeclarer	TridentTopologyBuilder.setBatchPerTupleSpout(String id, String streamName, IRichSpout spout, Integer parallelism, String batchGroup)