| 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 © 2022 The Apache Software Foundation. All rights reserved.