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 arefrom and to, which define the source and destination, and the stream grouping.| Constructor and Description |
|---|
StreamDef() |
| Modifier and Type | Method and 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) |
public String getTo()
public void setTo(String to)
public String getName()
public void setName(String name)
public String getFrom()
public void setFrom(String from)
public GroupingDef getGrouping()
public void setGrouping(GroupingDef grouping)
Copyright © 2021 The Apache Software Foundation. All rights reserved.