Package org.apache.storm.flux.model
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 Summary
Constructors Constructor Description StreamDef()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StringgetFrom()GroupingDefgetGrouping()StringgetName()StringgetTo()voidsetFrom(String from)voidsetGrouping(GroupingDef grouping)voidsetName(String name)voidsetTo(String to)
-
-
-
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)
-
getGrouping
public GroupingDef getGrouping()
-
setGrouping
public void setGrouping(GroupingDef grouping)
-
-