Package | Description |
---|---|
org.apache.storm.loadgen |
Modifier and Type | Field and Description |
---|---|
List<LoadCompConf> |
TopologyLoadConf.bolts |
List<LoadCompConf> |
TopologyLoadConf.spouts |
Modifier and Type | Method and Description |
---|---|
LoadCompConf |
LoadCompConf.Builder.build() |
static LoadCompConf |
LoadCompConf.fromConf(Map<String,Object> conf)
Parse the LoadCompConf from a config Map.
|
LoadCompConf |
LoadCompConf.overrideSlowExecutorPattern(SlowExecutorPattern slp)
Override the SlowExecutorPattern with a new one.
|
LoadCompConf |
LoadCompConf.remap(Map<String,String> remappedComponents,
Map<GlobalStreamId,GlobalStreamId> remappedStreams)
Chenge the name of components and streams according to the parameters passed in.
|
LoadCompConf |
LoadCompConf.scaleParallel(double v)
Scale the parallelism of this component by v.
|
LoadCompConf |
LoadCompConf.scaleThroughput(double v)
Scale the throughput of this component.
|
LoadCompConf |
LoadCompConf.setParallel(int newParallelism)
Set the parallelism of this component, and adjust the throughput so in aggregate it stays the same.
|
Constructor and Description |
---|
LoadBolt(LoadCompConf conf) |
LoadSpout(LoadCompConf conf) |
Constructor and Description |
---|
TopologyLoadConf(String name,
Map<String,Object> topoConf,
List<LoadCompConf> spouts,
List<LoadCompConf> bolts,
List<InputStream> streams)
Constructor.
|
TopologyLoadConf(String name,
Map<String,Object> topoConf,
List<LoadCompConf> spouts,
List<LoadCompConf> bolts,
List<InputStream> streams)
Constructor.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.