Package | Description |
---|---|
org.apache.storm.loadgen |
Modifier and Type | Field and Description |
---|---|
List<OutputStream> |
LoadCompConf.streams |
Modifier and Type | Method and Description |
---|---|
OutputStream |
OutputStream.Builder.build() |
static OutputStream |
OutputStream.fromConf(Map<String,Object> conf)
Create an output stream from a config.
|
OutputStream |
OutputStream.remap(String origId,
Map<GlobalStreamId,GlobalStreamId> remappedStreams) |
OutputStream |
OutputStream.scaleThroughput(double v) |
Modifier and Type | Method and Description |
---|---|
List<OutputStream> |
LoadCompConf.Builder.getStreams() |
Modifier and Type | Method and Description |
---|---|
LoadCompConf.Builder |
LoadCompConf.Builder.withStream(OutputStream stream)
Add in a single OutputStream to this component.
|
Modifier and Type | Method and Description |
---|---|
LoadCompConf.Builder |
LoadCompConf.Builder.withStreams(List<OutputStream> streams) |
Constructor and Description |
---|
OutputStreamEngine(OutputStream stats)
Create an engine that can simulate the given stats.
|
Constructor and Description |
---|
LoadCompConf(String id,
int parallelism,
List<OutputStream> streams,
double cpuLoad,
double memoryLoad,
SlowExecutorPattern slp)
Create a new LoadCompConf with the given values.
|
Copyright © 2020 The Apache Software Foundation. All rights reserved.