Skip to content

KStreamImplJoin

Creating Instance

KStreamImplJoin takes the following to be created:

KStreamImplJoin is created when:

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
Back to top