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 Summary
-
Field Summary
-
Constructor Summary
ConstructorDescriptionOutputStream
(String id, NormalDistStats rate, boolean areKeysSkewed) Create a new stream with stats. -
Method Summary
Modifier and TypeMethodDescriptionstatic OutputStream
Create 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
-
areKeysSkewed
public final boolean areKeysSkewed
-
-
Constructor Details
-
OutputStream
Create a new stream with stats.- Parameters:
id
- the id of the streamrate
- the rate of tuples being emitted on this streamareKeysSkewed
- 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
-
fromConf
Create an output stream from a config.- Parameters:
conf
- the config to read from.- Returns:
- the read OutputStream.
-
toConf
Convert this to a conf.- Returns:
- the conf.
-
remap
-
scaleThroughput
-