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 String
getFrom()
GroupingDef
getGrouping()
String
getName()
String
getTo()
void
setFrom(String from)
void
setGrouping(GroupingDef grouping)
void
setName(String name)
void
setTo(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)
-
-