public static final class InternalTopologyBuilder.Sink extends InternalTopologyBuilder.AbstractNode implements TopologyDescription.Sink
Constructor and Description |
---|
Sink(java.lang.String name,
java.lang.String topic) |
Sink(java.lang.String name,
TopicNameExtractor topicNameExtractor) |
Modifier and Type | Method and Description |
---|---|
void |
addSuccessor(TopologyDescription.Node successor) |
boolean |
equals(java.lang.Object o) |
int |
hashCode() |
java.lang.String |
topic()
The topic name this sink node is writing to.
|
TopicNameExtractor |
topicNameExtractor()
The
TopicNameExtractor class that this sink node uses to dynamically extract the topic name to write to. |
java.lang.String |
toString() |
addPredecessor, name, predecessors, successors
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
name, predecessors, successors
public Sink(java.lang.String name, TopicNameExtractor topicNameExtractor)
public Sink(java.lang.String name, java.lang.String topic)
public java.lang.String topic()
TopologyDescription.Sink
null
if the topic name can only be dynamically determined based on TopicNameExtractor
topic
in interface TopologyDescription.Sink
public TopicNameExtractor topicNameExtractor()
TopologyDescription.Sink
TopicNameExtractor
class that this sink node uses to dynamically extract the topic name to write to.
Could be null
if the topic name is not dynamically determined.topicNameExtractor
in interface TopologyDescription.Sink
TopicNameExtractor
class used get the topic namepublic void addSuccessor(TopologyDescription.Node successor)
addSuccessor
in class InternalTopologyBuilder.AbstractNode
public java.lang.String toString()
toString
in class java.lang.Object
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object