org.apache.kafka.streams.kstream

Interface ValueJoinerWithKey<K1,V1,V2,VR>

Type Parameters:

K1 - key value type

V1 - first value type

V2 - second value type

VR - joined value type

public interface ValueJoinerWithKey<K1,V1,V2,VR>

The ValueJoinerWithKey interface for joining two values into a new value of arbitrary type. This interface provides access to a read-only key that the user should not modify as this would lead to undefined behavior This is a stateless operation, i.e, apply(Object, Object, Object) is invoked individually for each joining record-pair of a KStream-KStream, KStream-KTable, or KTable-KTable join.

See Also:

KStream.join(KStream, ValueJoinerWithKey, JoinWindows), KStream.join(KStream, ValueJoinerWithKey, JoinWindows, StreamJoined), KStream.leftJoin(KStream, ValueJoinerWithKey, JoinWindows), KStream.leftJoin(KStream, ValueJoinerWithKey, JoinWindows, StreamJoined), KStream.outerJoin(KStream, ValueJoinerWithKey, JoinWindows), KStream.outerJoin(KStream, ValueJoinerWithKey, JoinWindows, StreamJoined), KStream.join(KTable, ValueJoinerWithKey), KStream.join(KTable, ValueJoinerWithKey, Joined), KStream.leftJoin(KTable, ValueJoinerWithKey), KStream.leftJoin(KTable, ValueJoinerWithKey, Joined), KStream.join(GlobalKTable, KeyValueMapper, ValueJoinerWithKey), KStream.join(GlobalKTable, KeyValueMapper, ValueJoinerWithKey, Named), KStream.leftJoin(GlobalKTable, KeyValueMapper, ValueJoinerWithKey), KStream.leftJoin(GlobalKTable, KeyValueMapper, ValueJoinerWithKey, Named)

Method Summary

Modifier and Type	Method and Description
VR	apply(K1 readOnlyKey, V1 value1, V2 value2) Return a joined value consisting of readOnlyKey, value1 and value2.

Method Detail

apply

VR apply(K1 readOnlyKey,
         V1 value1,
         V2 value2)

Return a joined value consisting of readOnlyKey, value1 and value2.

Parameters:

readOnlyKey - the key

value1 - the first value for joining

value2 - the second value for joining

Returns:

the joined value