All Methods Instance Methods Concrete Methods
Modifier and Type |
Method |
Description |
KTableKTableJoinNode<K,V1,V2,VR> |
build() |
|
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
withJoinOtherProcessorParameters(ProcessorParameters<K,Change<V2>> joinOtherProcessorParameters) |
|
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
withJoinOtherStoreNames(java.lang.String[] joinOtherStoreNames) |
|
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
withJoinThisProcessorParameters(ProcessorParameters<K,Change<V1>> joinThisProcessorParameters) |
|
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
withJoinThisStoreNames(java.lang.String[] joinThisStoreNames) |
|
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde) |
|
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> |
withQueryableStoreName(java.lang.String queryableStoreName) |
|
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
withStoreBuilder(StoreBuilder<TimestampedKeyValueStore<K,VR>> storeBuilder) |
|
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
withThisJoinSideNodeName(java.lang.String thisJoinSide) |
|
KTableKTableJoinNode.KTableKTableJoinNodeBuilder<K,V1,V2,VR> |
withValueSerde(org.apache.kafka.common.serialization.Serde<VR> valueSerde) |
|