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

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)