public class KTableKTableJoinNode<K,V1,V2,VR> extends StreamsGraphNode
Modifier and Type | Class and Description |
---|---|
static class |
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
Modifier and Type | Method and Description |
---|---|
static <K,V1,V2,VR> |
kTableKTableJoinNodeBuilder() |
java.lang.String |
toString() |
void |
writeToTopology(InternalTopologyBuilder topologyBuilder) |
addChild, allParentsWrittenToTopology, buildPriority, children, clearChildren, hasWrittenToTopology, isKeyChangingOperation, isMergeNode, isValueChangingOperation, keyChangingOperation, nodeName, parentNodes, removeChild, repartitionRequired, setBuildPriority, setHasWrittenToTopology, setMergeNode, setValueChangingOperation
public void writeToTopology(InternalTopologyBuilder topologyBuilder)
writeToTopology
in class StreamsGraphNode
public java.lang.String toString()
public static <K,V1,V2,VR> KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> kTableKTableJoinNodeBuilder()