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, StreamJoined), KStream.leftJoin(KStream, ValueJoiner, JoinWindows), KStream.leftJoin(KStream, ValueJoiner, JoinWindows, StreamJoined), KStream.outerJoin(KStream, ValueJoiner, JoinWindows), KStream.outerJoin(KStream, ValueJoiner, JoinWindows, StreamJoined), KStream.join(KTable, ValueJoiner), KStream.join(KTable, ValueJoiner, Joined), KStream.leftJoin(KTable, ValueJoiner), KStream.leftJoin(KTable, ValueJoiner, Joined), KTable.join(KTable, ValueJoiner), KTable.leftJoin(KTable, ValueJoiner), KTable.outerJoin(KTable, ValueJoiner)| Modifier and Type | Method and Description |
|---|---|
VR | apply(V1 value1, V2 value2)Return a joined value consisting of value1 and value2. |