Package org.apache.storm.loadgen
Class OutputStreamEngine
java.lang.Object
org.apache.storm.loadgen.OutputStreamEngine
Provides an API to simulate the output of a stream.
 
Right now it is just rate, but in the future we expect to do data skew as well...
- 
Field SummaryFields
- 
Constructor SummaryConstructorsConstructorDescriptionOutputStreamEngine(OutputStream stats) Create an engine that can simulate the given stats.
- 
Method Summary
- 
Field Details- 
streamName
 
- 
- 
Constructor Details- 
OutputStreamEngineCreate an engine that can simulate the given stats.- Parameters:
- stats- the stats to follow
 
 
- 
- 
Method Details- 
shouldEmitShould we emit or not.- Returns:
- the start time of the message, or null of nothing should be emitted.
 
- 
nextKeyGet the next key to emit.- Returns:
- the key that should be emitted.
 
- 
nextIntpublic int nextInt(int bound) 
 
-