Skip to content

AbstractStream

ensureCopartitionWith

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

ensureCopartitionWith...FIXME

ensureCopartitionWith is used when:

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