All Methods Instance Methods Concrete Methods
Modifier and Type |
Method and Description |
KTableKTableJoinNode<K,V1,V2,VR> |
build() |
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
withJoinMergeProcessorParameters(ProcessorParameters<K,VR> joinMergeProcessorParameters) |
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
withJoinOtherProcessorParameters(ProcessorParameters<K,V2> joinOtherProcessorParameters) |
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
withJoinOtherStoreNames(java.lang.String[] joinOtherStoreNames) |
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
withJoinThisProcessorParameters(ProcessorParameters<K,V1> joinThisProcessorParameters) |
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
withJoinThisStoreNames(java.lang.String[] joinThisStoreNames) |
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
withMaterializedInternal(MaterializedInternal materializedInternal) |
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
withNodeName(java.lang.String nodeName) |
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
withOtherJoinSideNodeName(java.lang.String otherJoinSide) |
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
withThisJoinSideNodeName(java.lang.String thisJoinSide) |
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
withValueJoiner(ValueJoiner<? super V1,? super V2,? extends VR> valueJoiner) |