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	Description
final List<InputStream>	TopologyLoadConf.streams

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

Modifier and Type	Method	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	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.