Skip to content

KStreamImpl

KStreamImpl is a KStream.

Creating Instance

KStreamImpl takes the following to be created:

KStreamImpl is created when:

  • InternalStreamsBuilder is requested to stream
  • others

repartitionRequired Flag

KStreamImpl is given a repartitionRequired flag when created.

doJoin

KStream<K, VR> doJoin(
  KStream<K, VO> otherStream,
  ValueJoinerWithKey<? super K, ? super V, ? super VO, ? extends VR> joiner,
  JoinWindows windows,
  StreamJoined<K, V, VO> streamJoined,
  KStreamImplJoin join)

In the end, doJoin requests the given KStreamImplJoin to join.

doJoin is used when:

groupBy

KGroupedStream<KR, V> groupBy(
  KeyValueMapper<? super K, ? super V, KR> keySelector)
KGroupedStream<KR, V> groupBy(
  KeyValueMapper<? super K, ? super V, KR> keySelector,
  Grouped<KR, V> grouped)

groupBy...FIXME

In the end, groupBy creates a KGroupedStreamImpl (with the repartitionRequired flag enabled).

groupBy is part of the KStream abstraction.

groupByKey

KGroupedStream<K, V> groupByKey()
KGroupedStream<K, V> groupByKey(
  Grouped<K, V> grouped)

groupByKey creates a KGroupedStreamImpl.

groupByKey is part of the KStream abstraction.

Back to top