KStreamImplJoin¶

Creating Instance¶

KStreamImplJoin takes the following to be created:

• InternalStreamsBuilder
• leftOuter flag
• rightOuter flag

KStreamImplJoin is created when:

• KStreamImpl is requested to join, leftJoin and outerJoin

join¶

KStream<K1, R> join(
  KStream<K1, V1> lhs,
  KStream<K1, V2> other,
  ValueJoinerWithKey<? super K1, ? super V1, ? super V2, ? extends R> joiner,
  JoinWindows windows,
  StreamJoined<K1, V1, V2> streamJoined)

join...FIXME

join is used when:

• KStreamImpl is requested to doJoin