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 Summary
-
Constructor Summary
ConstructorDescriptionOutputStreamEngine
(OutputStream stats) Create an engine that can simulate the given stats. -
Method Summary
-
Field Details
-
streamName
-
-
Constructor Details
-
OutputStreamEngine
Create an engine that can simulate the given stats.- Parameters:
stats
- the stats to follow
-
-
Method Details
-
shouldEmit
Should we emit or not.- Returns:
- the start time of the message, or null of nothing should be emitted.
-
nextKey
Get the next key to emit.- Returns:
- the key that should be emitted.
-
nextInt
public int nextInt(int bound)
-