Class InputStream

java.lang.Object
org.apache.storm.loadgen.InputStream
All Implemented Interfaces:
Serializable

public class InputStream extends Object implements Serializable
A set of measurements about a stream so we can statistically reproduce it.
See Also:
  • Field Details

  • Constructor Details

    • InputStream

      public InputStream(String fromComponent, String toComponent, String id, NormalDistStats execTime, NormalDistStats processTime, GroupingType groupingType)
      Create a new input stream to a bolt.
      Parameters:
      fromComponent - the source component of the stream.
      id - the id of the stream
      execTime - exec time stats
      processTime - process time stats
  • Method Details

    • fromConf

      public static InputStream fromConf(Map<String,Object> conf)
      Create an output stream from a config.
      Parameters:
      conf - the config to read from.
      Returns:
      the read OutputStream.
    • toConf

      public Map<String,Object> toConf()
      Convert this to a conf.
      Returns:
      the conf.
    • gsid

      public GlobalStreamId gsid()
      Get the global stream id for this input stream.
      Returns:
      the GlobalStreamId for this input stream.
    • remap

      public InputStream remap(Map<String,String> remappedComponents, Map<GlobalStreamId,GlobalStreamId> remappedStreams)
      Remap the names of components.
      Parameters:
      remappedComponents - old name to new name of components.
      remappedStreams - old ID to new ID of streams.
      Returns:
      a modified version of this with names remapped.
    • replaceShuffleWithLocalOrShuffle

      public InputStream replaceShuffleWithLocalOrShuffle()
      Replace all SHUFFLE groupings with LOCAL_OR_SHUFFLE.
      Returns:
      a modified copy of this