Package org.apache.storm.loadgen
Class ThroughputVsLatency.FastRandomSentenceSpout
java.lang.Object
org.apache.storm.topology.base.BaseComponent
org.apache.storm.topology.base.BaseRichSpout
org.apache.storm.loadgen.LoadSpout
org.apache.storm.loadgen.ThroughputVsLatency.FastRandomSentenceSpout
- All Implemented Interfaces:
- Serializable,- ISpout,- IComponent,- IRichSpout
- Enclosing class:
- ThroughputVsLatency
- See Also:
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoiddeclareOutputFields(OutputFieldsDeclarer declarer) Declare the output schema for all the streams of this topology.protected ValuesMethods inherited from class org.apache.storm.topology.base.BaseRichSpoutactivate, close, deactivateMethods inherited from class org.apache.storm.topology.base.BaseComponentgetComponentConfigurationMethods inherited from class java.lang.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.storm.topology.IComponentgetComponentConfiguration
- 
Constructor Details- 
FastRandomSentenceSpoutpublic FastRandomSentenceSpout(long ratePerSecond) Constructor.- Parameters:
- ratePerSecond- the rate to emite tuples at.
 
 
- 
- 
Method Details- 
getNextValues- Overrides:
- getNextValuesin class- LoadSpout
 
- 
declareOutputFieldsDescription copied from interface:IComponentDeclare the output schema for all the streams of this topology.- Specified by:
- declareOutputFieldsin interface- IComponent
- Overrides:
- declareOutputFieldsin class- LoadSpout
- Parameters:
- declarer- this is used to declare output stream ids, output fields, and whether or not each output stream is a direct stream
 
 
-