public class StreamSourceNode<K,V> extends StreamsGraphNode
Constructor and Description |
---|
StreamSourceNode(java.lang.String nodeName,
java.util.Collection<java.lang.String> topicNames,
ConsumedInternal<K,V> consumedInternal) |
StreamSourceNode(java.lang.String nodeName,
java.util.regex.Pattern topicPattern,
ConsumedInternal<K,V> consumedInternal) |
Modifier and Type | Method and Description |
---|---|
ConsumedInternal<K,V> |
consumedInternal() |
java.util.Collection<java.lang.String> |
getTopicNames() |
org.apache.kafka.common.serialization.Serde<K> |
keySerde() |
java.util.regex.Pattern |
topicPattern() |
java.lang.String |
toString() |
org.apache.kafka.common.serialization.Serde<V> |
valueSerde() |
void |
writeToTopology(InternalTopologyBuilder topologyBuilder) |
addChild, allParentsWrittenToTopology, buildPriority, children, clearChildren, hasWrittenToTopology, isKeyChangingOperation, isMergeNode, isValueChangingOperation, keyChangingOperation, nodeName, parentNodes, removeChild, repartitionRequired, setBuildPriority, setHasWrittenToTopology, setMergeNode, setValueChangingOperation
public StreamSourceNode(java.lang.String nodeName, java.util.Collection<java.lang.String> topicNames, ConsumedInternal<K,V> consumedInternal)
public StreamSourceNode(java.lang.String nodeName, java.util.regex.Pattern topicPattern, ConsumedInternal<K,V> consumedInternal)
public java.util.Collection<java.lang.String> getTopicNames()
public java.util.regex.Pattern topicPattern()
public ConsumedInternal<K,V> consumedInternal()
public org.apache.kafka.common.serialization.Serde<K> keySerde()
public org.apache.kafka.common.serialization.Serde<V> valueSerde()
public java.lang.String toString()
toString
in class StreamsGraphNode
public void writeToTopology(InternalTopologyBuilder topologyBuilder)
writeToTopology
in class StreamsGraphNode