Package org.apache.kafka.streams.kstream.internals.graph

Class StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR>

java.lang.Object

org.apache.kafka.streams.kstream.internals.graph.StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR>

Enclosing class:

StreamStreamJoinNode<K,V1,V2,VR>

public static final class StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR>
extends Object

Method Summary

Modifier and Type	Method	Description
StreamStreamJoinNode<K,V1,V2,VR>	build()
StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR>	withJoined(Joined<K,V1,V2> joined)
StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR>	withJoinMergeProcessorParameters(ProcessorParameters<K,VR> joinMergeProcessorParameters)
StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR>	withJoinOtherProcessorParameters(ProcessorParameters<K,V2> joinOtherProcessParameters)
StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR>	withJoinThisProcessorParameters(ProcessorParameters<K,V1> joinThisProcessorParameters)
StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR>	withNodeName(String nodeName)
StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR>	withOtherWindowedStreamProcessorParameters(ProcessorParameters<K,V2> otherWindowedStreamProcessorParameters)
StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR>	withOtherWindowStoreBuilder(StoreBuilder<WindowStore<K,V2>> otherWindowStoreBuilder)
StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR>	withThisWindowedStreamProcessorParameters(ProcessorParameters<K,V1> thisWindowedStreamProcessorParameters)
StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR>	withThisWindowStoreBuilder(StoreBuilder<WindowStore<K,V1>> thisWindowStoreBuilder)
StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR>	withValueJoiner(ValueJoiner<? super V1,? super V2,? extends VR> valueJoiner)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

withValueJoiner

public StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR> withValueJoiner(ValueJoiner<? super V1,? super V2,? extends VR> valueJoiner)

withJoinThisProcessorParameters

public StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR> withJoinThisProcessorParameters(ProcessorParameters<K,V1> joinThisProcessorParameters)

withNodeName

public StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR> withNodeName(String nodeName)

withJoinOtherProcessorParameters

public StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR> withJoinOtherProcessorParameters(ProcessorParameters<K,V2> joinOtherProcessParameters)

withJoinMergeProcessorParameters

public StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR> withJoinMergeProcessorParameters(ProcessorParameters<K,VR> joinMergeProcessorParameters)

withThisWindowedStreamProcessorParameters

public StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR> withThisWindowedStreamProcessorParameters(ProcessorParameters<K,V1> thisWindowedStreamProcessorParameters)

withOtherWindowedStreamProcessorParameters

public StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR> withOtherWindowedStreamProcessorParameters(ProcessorParameters<K,V2> otherWindowedStreamProcessorParameters)

withThisWindowStoreBuilder

public StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR> withThisWindowStoreBuilder(StoreBuilder<WindowStore<K,V1>> thisWindowStoreBuilder)

withOtherWindowStoreBuilder

public StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR> withOtherWindowStoreBuilder(StoreBuilder<WindowStore<K,V2>> otherWindowStoreBuilder)

withJoined

public StreamStreamJoinNode.StreamStreamJoinNodeBuilder<K,V1,V2,VR> withJoined(Joined<K,V1,V2> joined)

build

public StreamStreamJoinNode<K,V1,V2,VR> build()