Package | Description |
---|---|
org.apache.storm.loadgen |
Modifier and Type | Field and Description |
---|---|
NormalDistStats |
InputStream.execTime |
NormalDistStats |
InputStream.processTime |
NormalDistStats |
OutputStream.rate |
Modifier and Type | Method and Description |
---|---|
static NormalDistStats |
NormalDistStats.fromConf(Map<String,Object> conf)
Read the stats from a config.
|
static NormalDistStats |
NormalDistStats.fromConf(Map<String,Object> conf,
Double def)
Read the stats from a config.
|
NormalDistStats |
InputStream.Builder.getExecTime() |
NormalDistStats |
InputStream.Builder.getProcessTime() |
NormalDistStats |
OutputStream.Builder.getRate() |
NormalDistStats |
NormalDistStats.scaleBy(double v)
Scale the stats by v.
|
Modifier and Type | Method and Description |
---|---|
InputStream.Builder |
InputStream.Builder.withExecTime(NormalDistStats execTime) |
InputStream.Builder |
InputStream.Builder.withProcessTime(NormalDistStats processTime) |
OutputStream.Builder |
OutputStream.Builder.withRate(NormalDistStats rate) |
Constructor and Description |
---|
InputStream(String fromComponent,
String toComponent,
String id,
NormalDistStats execTime,
NormalDistStats processTime,
GroupingType groupingType)
Create a new input stream to a bolt.
|
OutputStream(String id,
NormalDistStats rate,
boolean areKeysSkewed)
Create a new stream with stats.
|
Copyright © 2023 The Apache Software Foundation. All rights reserved.