Package org.apache.storm.loadgen
Class OutputStream
java.lang.Object
org.apache.storm.loadgen.OutputStream
- All Implemented Interfaces:
- Serializable
A set of measurements about a stream so we can statistically reproduce it.
- See Also:
- 
Nested Class SummaryNested Classes
- 
Field SummaryFields
- 
Constructor SummaryConstructorsConstructorDescriptionOutputStream(String id, NormalDistStats rate, boolean areKeysSkewed) Create a new stream with stats.
- 
Method SummaryModifier and TypeMethodDescriptionstatic OutputStreamCreate an output stream from a config.remap(String origId, Map<GlobalStreamId, GlobalStreamId> remappedStreams) scaleThroughput(double v) toConf()Convert this to a conf.
- 
Field Details- 
id
- 
rate
- 
areKeysSkewedpublic final boolean areKeysSkewed
 
- 
- 
Constructor Details- 
OutputStreamCreate a new stream with stats.- Parameters:
- id- the id of the stream
- rate- the rate of tuples being emitted on this stream
- areKeysSkewed- true if keys are skewed else false. For skewed keys we only simulate it by using a gaussian distribution to the keys instead of an even distribution. Tere is no effort made right not to measure the skewness and reproduce it.
 
 
- 
- 
Method Details- 
fromConfCreate an output stream from a config.- Parameters:
- conf- the config to read from.
- Returns:
- the read OutputStream.
 
- 
toConfConvert this to a conf.- Returns:
- the conf.
 
- 
remap
- 
scaleThroughput
 
-