KStream<K1, R> join(
KStream<K1, V1> lhs,
KStream<K1, V2> other,
ValueJoiner<? super V1, ? super V2, ? extends R> joiner,
JoinWindows windows,
Joined<K1, V1, V2> joined)
KStreamImplJoin
KStreamImplJoin
is…FIXME
join
Method
join
…FIXME
Note
|
join is used exclusively when KStreamImpl is requested to doJoin (for KStreamImpl.join, KStreamImpl.outerJoin and KStreamImpl.leftJoin operators).
|