Package 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,ExclamationTopology.FixedOrderWordSpout,FastWordCountTopology.FastRandomSentenceSpout,FeederSpout,FileReadSpout,FixedTupleSpout,FluxShellSpout,HdfsFileTopology.SentenceSpout,HdfsSpout,HiveTopology.UserDataSpout,HiveTopologyPartitioned.UserDataSpout,IncrementingSpout,InOrderDeliveryTest.InOrderSpout,JmsSpout,KafkaSpout,LambdaSpout,LoadSpout,MasterBatchCoordinator,PythonShellMetricsSpout,RandomIntegerSpout,RandomSentenceSpout,RandomSentenceSpout.TimeStamped,RichShellSpout,RichSpoutBatchTriggerer,SequenceFileTopology.SentenceSpout,SocketSpout,SpoutTracker,StringGenSpout,TestEventLogSpout,TestPlannerSpout,TestWordSpout,ThroughputVsLatency.FastRandomSentenceSpout,TimeDataIncrementingSpout,UserSpout,WordCountTopologyNode.RandomSentence,WordGenSpout,WordSpout
public interface IRichSpout extends ISpout, IComponent
When writing topologies using Java,IRichBoltandIRichSpoutare the main interfaces to use to implement components of the topology.
-
-
Method Summary
-
Methods inherited from interface org.apache.storm.topology.IComponent
declareOutputFields, getComponentConfiguration
-
-