Package org.apache.kafka.streams.kstream
Interface ValueJoiner<V1,V2,VR>
-
- Type Parameters:
V1
- first value typeV2
- second value typeVR
- joined value type
public interface ValueJoiner<V1,V2,VR>
TheValueJoiner
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 aKStream
-KStream
,KStream
-KTable
, orKTable
-KTable
join.- See Also:
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)
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description VR
apply(V1 value1, V2 value2)
Return a joined value consisting ofvalue1
andvalue2
.
-