org.apache.storm.topology

Interface IRichSpout

All Superinterfaces:

IComponent, ISpout, Serializable

All Known Implementing Classes:

AnchoredWordCount.RandomSentenceSpout, BaseRichSpout, BlobStoreAPIWordCountTopology.RandomSentenceSpout, BucketTestHiveTopology.UserDataSpout, CheckpointSpout, ClojureSpout, ConstSpout, DRPCSpout, EsIndexTopology.UserDataSpout, EventHubSpout, FastWordCountTopology.FastRandomSentenceSpout, FeederSpout, FileReadSpout, FixedTupleSpout, FluxShellSpout, HdfsFileTopology.SentenceSpout, HdfsSpout, HiveTopology.UserDataSpout, HiveTopologyPartitioned.UserDataSpout, InOrderDeliveryTest.InOrderSpout, JmsSpout, KafkaSpout, KafkaSpout, KinesisSpout, MasterBatchCoordinator, MetricGenSpout, MqttSpout, PythonShellMetricsSpout, RandomIntegerSpout, RandomSentenceSpout, RandomSentenceSpout.TimeStamped, RawInputFromCSVSpout, RichShellSpout, RichSpoutBatchTriggerer, SequenceFileTopology.SentenceSpout, SolrFieldsSpout, SolrJsonSpout, SpoutTracker, StringGenSpout, TestEventLogSpout, TestPlannerSpout, TestWordSpout, ThroughputVsLatency.FastRandomSentenceSpout, TransactionalSpoutCoordinator, UserSpout, WordCountTopologyNode.RandomSentence, WordSpout, WordSpout, WordSpout

public interface IRichSpout
extends ISpout, IComponent

When writing topologies using Java, IRichBolt and IRichSpout are the main interfaces to use to implement components of the topology.

Method Summary

Methods inherited from interface org.apache.storm.spout.ISpout

ack, activate, close, deactivate, fail, nextTuple, open

Methods inherited from interface org.apache.storm.topology.IComponent

declareOutputFields, getComponentConfiguration