Package org.apache.storm.loadgen
Class OutputStreamEngine
- java.lang.Object
-
- org.apache.storm.loadgen.OutputStreamEngine
-
public class OutputStreamEngine extends Object
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
Fields Modifier and Type Field Description StringstreamName
-
Constructor Summary
Constructors Constructor Description OutputStreamEngine(OutputStream stats)Create an engine that can simulate the given stats.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description intnextInt(int bound)StringnextKey()Get the next key to emit.LongshouldEmit()Should we emit or not.
-
-
-
Field Detail
-
streamName
public final String streamName
-
-
Constructor Detail
-
OutputStreamEngine
public OutputStreamEngine(OutputStream stats)
Create an engine that can simulate the given stats.- Parameters:
stats- the stats to follow
-
-