Uses of Class
org.apache.storm.loadgen.InputStream
-
Uses of InputStream in org.apache.storm.loadgen
Modifier and TypeMethodDescriptionInputStream.Builder.build()
static InputStream
Create 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.Modifier and TypeMethodDescriptionvoid
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.