Skip to content

AbstractStream

AbstractStream<K, V> is a base abstraction of KTables and KStreams.

Implementations

  • CogroupedKStreamImpl
  • KGroupedStreamImpl
  • KGroupedTableImpl
  • KStreamImpl
  • KTableImpl
  • SessionWindowedCogroupedKStreamImpl
  • SessionWindowedKStreamImpl
  • SlidingWindowedCogroupedKStreamImpl
  • SlidingWindowedKStreamImpl
  • TimeWindowedCogroupedKStreamImpl
  • TimeWindowedKStreamImpl

Creating Instance

AbstractStream takes the following to be created:

Abstract Class

AbstractStream is an abstract class and cannot be created directly. It is created indirectly for the concrete AbstractStreams.

ensureCopartitionWith

Set<String> ensureCopartitionWith(
  Collection<? extends AbstractStream<K, ?>> otherStreams)

ensureCopartitionWith requests the InternalStreamsBuilder for the InternalTopologyBuilder that is in turn requested to copartitionSources (with the subTopologySourceNodes and the subTopologySourceNodes of all the other AbstractStreams).

ensureCopartitionWith returns the subTopologySourceNodes and the subTopologySourceNodes of all the other AbstractStreams.

ensureCopartitionWith is used when:

  • CogroupedStreamAggregateBuilder is requested to processRepartitions
  • KStreamImpl is requested to doJoin and doStreamTableJoin
  • KTableImpl is requested to doJoin
Back to top