Class StreamDef

java.lang.Object
org.apache.storm.flux.model.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 Details

    • StreamDef

      public StreamDef()
  • Method Details

    • 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)
    • getGrouping

      public GroupingDef getGrouping()
    • setGrouping

      public void setGrouping(GroupingDef grouping)