Class StreamDef


  • public class StreamDef
    extends Object
    Represents a stream of tuples from one Storm component (Spout or Bolt) to another (an edge in the topology DAG).

    Required fields are `from` and `to`, which define the source and destination, and the stream `grouping`.

    • Constructor Detail

      • StreamDef

        public StreamDef()
    • Method Detail

      • getTo

        public String getTo()
      • setTo

        public void setTo​(String to)
      • getName

        public String getName()
      • setName

        public void setName​(String name)
      • getFrom

        public String getFrom()
      • setFrom

        public void setFrom​(String from)
      • setGrouping

        public void setGrouping​(GroupingDef grouping)