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 List<InputStream>TopologyLoadConf. streamsMethods in org.apache.storm.loadgen that return InputStream Modifier and Type Method Description InputStreamInputStream.Builder. build()static InputStreamInputStream. fromConf(Map<String,Object> conf)Create an output stream from a config.InputStreamInputStream. remap(Map<String,String> remappedComponents, Map<GlobalStreamId,GlobalStreamId> remappedStreams)Remap the names of components.InputStreamInputStream. 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 voidLoadBolt. add(InputStream inputStream)abstract voidGroupingType. assign(BoltDeclarer declarer, InputStream stream)voidExecAndProcessLatencyEngine. simulateProcessAndExecTime(int executorIndex, long startTimeNs, InputStream in, Runnable r)Simulate both process and exec times.
-