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
final String	streamName

Constructor Summary

Constructors

Constructor	Description
OutputStreamEngine(OutputStream stats)	Create an engine that can simulate the given stats.

Method Summary

Modifier and Type	Method	Description
int	nextInt(int bound)
String	nextKey()	Get the next key to emit.
Long	shouldEmit()	Should we emit or not.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

streamName

public final String streamName

Constructor Details

OutputStreamEngine

public OutputStreamEngine(OutputStream stats)

Create an engine that can simulate the given stats.

Parameters:

stats - the stats to follow

Method Details

shouldEmit

public Long shouldEmit()

Should we emit or not.

Returns:

the start time of the message, or null of nothing should be emitted.

nextKey

public String nextKey()

Get the next key to emit.

Returns:

the key that should be emitted.

nextInt

public int nextInt(int bound)