Uses of Class
org.apache.storm.loadgen.InputStream

Packages that use InputStream

Package	Description
org.apache.storm.loadgen

Uses of InputStream in org.apache.storm.loadgen

Fields in org.apache.storm.loadgen with type parameters of type InputStream

Modifier and Type	Field and Description
List<InputStream>	TopologyLoadConf.streams

Methods in org.apache.storm.loadgen that return InputStream

Modifier and Type	Method and Description
InputStream	InputStream.Builder.build()
static InputStream	InputStream.fromConf(Map<String,Object> conf) Create an output stream from a config.
InputStream	InputStream.remap(Map<String,String> remappedComponents, Map<GlobalStreamId,GlobalStreamId> remappedStreams) Remap the names of components.
InputStream	InputStream.replaceShuffleWithLocalOrShuffle() Replace all SHUFFLE groupings with LOCAL_OR_SHUFFLE.

Methods in org.apache.storm.loadgen with parameters of type InputStream

Modifier and Type	Method and Description
void	LoadBolt.add(InputStream inputStream)
abstract void	GroupingType.assign(BoltDeclarer declarer, InputStream stream)
void	ExecAndProcessLatencyEngine.simulateProcessAndExecTime(int executorIndex, long startTimeNs, InputStream in, Runnable r) Simulate both process and exec times.

Constructor parameters in org.apache.storm.loadgen with type arguments of type InputStream

Constructor and Description
TopologyLoadConf(String name, Map<String,Object> topoConf, List<LoadCompConf> spouts, List<LoadCompConf> bolts, List<InputStream> streams) Constructor.