public static final class InternalTopologyBuilder.Source extends InternalTopologyBuilder.AbstractNode implements TopologyDescription.Source
Constructor and Description |
---|
Source(java.lang.String name,
java.util.Set<java.lang.String> topics,
java.util.regex.Pattern pattern) |
Modifier and Type | Method and Description |
---|---|
void |
addPredecessor(TopologyDescription.Node predecessor) |
boolean |
equals(java.lang.Object o) |
int |
hashCode() |
java.util.regex.Pattern |
topicPattern()
The pattern used to match topic names that is reading from.
|
java.lang.String |
topics()
Deprecated.
|
java.util.Set<java.lang.String> |
topicSet()
The topic names this source node is reading from.
|
java.lang.String |
toString() |
addSuccessor, name, predecessors, successors
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
name, predecessors, successors
public Source(java.lang.String name, java.util.Set<java.lang.String> topics, java.util.regex.Pattern pattern)
@Deprecated public java.lang.String topics()
TopologyDescription.Source
topics
in interface TopologyDescription.Source
public java.util.Set<java.lang.String> topicSet()
TopologyDescription.Source
topicSet
in interface TopologyDescription.Source
public java.util.regex.Pattern topicPattern()
TopologyDescription.Source
topicPattern
in interface TopologyDescription.Source
public void addPredecessor(TopologyDescription.Node predecessor)
addPredecessor
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