Uses of Class
org.apache.storm.loadgen.LoadCompConf
-
Uses of LoadCompConf in org.apache.storm.loadgen
Modifier and TypeFieldDescriptionfinal List<LoadCompConf>
TopologyLoadConf.bolts
final List<LoadCompConf>
TopologyLoadConf.spouts
Modifier and TypeMethodDescriptionLoadCompConf.Builder.build()
static LoadCompConf
Parse the LoadCompConf from a config Map.LoadCompConf.overrideSlowExecutorPattern
(SlowExecutorPattern slp) Override the SlowExecutorPattern with a new one.LoadCompConf.remap
(Map<String, String> remappedComponents, Map<GlobalStreamId, GlobalStreamId> remappedStreams) Chenge the name of components and streams according to the parameters passed in.LoadCompConf.scaleParallel
(double v) Scale the parallelism of this component by v.LoadCompConf.scaleThroughput
(double v) Scale the throughput of this component.LoadCompConf.setParallel
(int newParallelism) Set the parallelism of this component, and adjust the throughput so in aggregate it stays the same.ModifierConstructorDescriptionTopologyLoadConf
(String name, Map<String, Object> topoConf, List<LoadCompConf> spouts, List<LoadCompConf> bolts, List<InputStream> streams) Constructor.