Package | Description |
---|---|
org.apache.storm.loadgen |
Modifier and Type | Field and Description |
---|---|
SlowExecutorPattern |
LoadCompConf.slp |
Modifier and Type | Method and Description |
---|---|
static SlowExecutorPattern |
SlowExecutorPattern.fromConf(Map<String,Object> conf)
Creates a SlowExecutorPattern from a Map config.
|
static SlowExecutorPattern |
SlowExecutorPattern.fromString(String strRepresentation)
Parses a string (command line) representation of "<SLOWNESS>(:<COUNT>)?".
|
Modifier and Type | Method and Description |
---|---|
LoadCompConf |
LoadCompConf.overrideSlowExecutorPattern(SlowExecutorPattern slp)
Override the SlowExecutorPattern with a new one.
|
LoadCompConf.Builder |
LoadCompConf.Builder.withSlowExecutorPattern(SlowExecutorPattern slp) |
Modifier and Type | Method and Description |
---|---|
TopologyLoadConf |
TopologyLoadConf.overrideSlowExecs(Map<String,SlowExecutorPattern> topoSpecific)
Override the SlowExecutorPattern for given components.
|
Constructor and Description |
---|
ExecAndProcessLatencyEngine(SlowExecutorPattern skewedPattern) |
LoadCompConf(String id,
int parallelism,
List<OutputStream> streams,
double cpuLoad,
double memoryLoad,
SlowExecutorPattern slp)
Create a new LoadCompConf with the given values.
|
SplitSentence(SlowExecutorPattern slowness) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.