public class TableSourceNode<K,V,S extends StateStore> extends StreamSourceNode<K,V>
GlobalKTable
Modifier and Type | Class and Description |
---|---|
static class |
TableSourceNode.TableSourceNodeBuilder<K,V,S extends StateStore> |
Modifier and Type | Method and Description |
---|---|
boolean |
isGlobalKTable() |
static <K,V,S extends StateStore> |
tableSourceNodeBuilder() |
java.lang.String |
toString() |
void |
writeToTopology(InternalTopologyBuilder topologyBuilder) |
consumedInternal, getTopicNames, keySerde, topicPattern, valueSerde
addChild, allParentsWrittenToTopology, buildPriority, children, clearChildren, hasWrittenToTopology, isKeyChangingOperation, isMergeNode, isValueChangingOperation, keyChangingOperation, nodeName, parentNodes, removeChild, repartitionRequired, setBuildPriority, setHasWrittenToTopology, setMergeNode, setValueChangingOperation
public boolean isGlobalKTable()
public java.lang.String toString()
toString
in class StreamSourceNode<K,V>
public static <K,V,S extends StateStore> TableSourceNode.TableSourceNodeBuilder<K,V,S> tableSourceNodeBuilder()
public void writeToTopology(InternalTopologyBuilder topologyBuilder)
writeToTopology
in class StreamSourceNode<K,V>