K1 - key value typeV1 - first value typeV2 - second value typeVR - joined value typepublic interface ValueJoinerWithKey<K1,V1,V2,VR>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.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)| Modifier and Type | Method and Description |
|---|---|
VR | apply(K1 readOnlyKey, V1 value1, V2 value2)Return a joined value consisting of readOnlyKey, value1 and value2. |