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

Packages that use IRichSpout

Package	Description
org.apache.storm.clojure
org.apache.storm.drpc
org.apache.storm.elasticsearch.bolt
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
org.apache.storm.kinesis.spout
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.solr.spout
org.apache.storm.spout
org.apache.storm.starter
org.apache.storm.starter.spout
org.apache.storm.testing
org.apache.storm.topology
org.apache.storm.topology.base
org.apache.storm.transactional
org.apache.storm.trident
org.apache.storm.trident.spout
org.apache.storm.trident.topology

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

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

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

Modifier and Type	Class and Description
class	KafkaSpout Deprecated. storm-kafka has been deprecated and will be removed in a future Storm release. Please upgrade to storm-kafka-client. If you need to migrate the committed offsets to the new spout, consider using the storm-kafka-migration tool.

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.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.

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.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.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	ThroughputVsLatency.FastRandomSentenceSpout
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.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.transactional

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

Modifier and Type	Class and Description
class	TransactionalSpoutCoordinator

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)