Uses of Class
org.apache.storm.loadgen.InputStream
Packages that use InputStream
-
Uses of InputStream in org.apache.storm.loadgen
Fields in org.apache.storm.loadgen with type parameters of type InputStreamMethods in org.apache.storm.loadgen that return InputStreamModifier and TypeMethodDescriptionInputStream.Builder.build()static InputStreamCreate an output stream from a config.InputStream.remap(Map<String, String> remappedComponents, Map<GlobalStreamId, GlobalStreamId> remappedStreams) Remap the names of components.InputStream.replaceShuffleWithLocalOrShuffle()Replace all SHUFFLE groupings with LOCAL_OR_SHUFFLE.Methods in org.apache.storm.loadgen with parameters of type InputStreamModifier and TypeMethodDescriptionvoidLoadBolt.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.