org.apache.kafka.streams.kstream

Interface ValueJoiner<V1,V2,VR>

Type Parameters:

V1 - first value type

V2 - second value type

VR - joined value type

@InterfaceStability.Unstable
public interface ValueJoiner<V1,V2,VR>

The ValueJoiner interface for joining two values into a new value of arbitrary type. This is a stateless operation, i.e, apply(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, ValueJoiner, JoinWindows), KStream.join(KStream, ValueJoiner, JoinWindows, org.apache.kafka.common.serialization.Serde, org.apache.kafka.common.serialization.Serde, org.apache.kafka.common.serialization.Serde), KStream.leftJoin(KStream, ValueJoiner, JoinWindows), KStream.leftJoin(KStream, ValueJoiner, JoinWindows, org.apache.kafka.common.serialization.Serde, org.apache.kafka.common.serialization.Serde, org.apache.kafka.common.serialization.Serde), KStream.outerJoin(KStream, ValueJoiner, JoinWindows), KStream.outerJoin(KStream, ValueJoiner, JoinWindows, org.apache.kafka.common.serialization.Serde, org.apache.kafka.common.serialization.Serde, org.apache.kafka.common.serialization.Serde), KStream.join(KTable, ValueJoiner), KStream.join(KTable, ValueJoiner, org.apache.kafka.common.serialization.Serde, org.apache.kafka.common.serialization.Serde), KStream.leftJoin(KTable, ValueJoiner), KStream.leftJoin(KTable, ValueJoiner, org.apache.kafka.common.serialization.Serde, org.apache.kafka.common.serialization.Serde), KTable.join(KTable, ValueJoiner), KTable.leftJoin(KTable, ValueJoiner), KTable.outerJoin(KTable, ValueJoiner)

Method Summary

Methods

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

Method Detail

apply

VR apply(V1 value1,
       V2 value2)

Return a joined value consisting of value1 and value2.

Parameters:

value1 - the first value for joining

value2 - the second value for joining

Returns:

the joined value