V1
- first value typeV2
- second value typeVR
- joined value typepublic interface ValueJoiner<V1,V2,VR>
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.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)