Package | Description |
---|---|
org.apache.storm.loadgen |
Modifier and Type | Method and Description |
---|---|
TopologyLoadConf |
TopologyLoadConf.anonymize()
Create a new version of this topology with identifiable information removed.
|
static TopologyLoadConf |
TopologyLoadConf.fromConf(File file)
Parse the TopologyLoadConf from a file in YAML format.
|
static TopologyLoadConf |
TopologyLoadConf.fromConf(Map<String,Object> conf)
Parse the TopologyLoadConf from a config map.
|
TopologyLoadConf |
TopologyLoadConf.overrideSlowExecs(Map<String,SlowExecutorPattern> topoSpecific)
Override the SlowExecutorPattern for given components.
|
TopologyLoadConf |
TopologyLoadConf.replaceShuffleWithLocalOrShuffle() |
TopologyLoadConf |
TopologyLoadConf.scaleParallel(double v,
Map<String,Double> topoSpecific)
Scale all of the components in the topology by a percentage (but keep the throughput the same).
|
TopologyLoadConf |
TopologyLoadConf.scaleThroughput(double v,
Map<String,Double> topoSpecific)
Scale the throughput of the entire topology by a percentage.
|
TopologyLoadConf |
TopologyLoadConf.withName(String baseName) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.