kafka-streams-internals-GroupedStreamAggregateBuilder.adoc

GroupedStreamAggregateBuilder

GroupedStreamAggregateBuilder is created exclusively for a KGroupedStreamImpl (for KStream.groupBy and KStream.groupByKey streaming operators).

GroupedStreamAggregateBuilder takes the following to be created:

• InternalStreamsBuilder

• GroupedInternal<K, V>

• repartitionRequired flag

• Names of the source nodes

• Name

• StreamsGraphNode

Creating KTableImpl (For KStreamAggProcessorSupplier And New StatefulProcessorNode) — build Method

<T> KTable<K, T> build(
  KStreamAggProcessorSupplier<K, ?, V, T> aggregateSupplier,
  String functionName,
  StoreBuilder storeBuilder,
  boolean isQueryable)

build…​FIXME

Note

build is used when: KGroupedStreamImpl is requested to doAggregate (for reduce, aggregate and count operators after KStream.groupBy and KStream.groupByKey) SessionWindowedKStreamImpl is requested to doCount (for count operator), reduce and aggregate TimeWindowedKStreamImpl is requested to doCount (for count operator), reduce and aggregate

repartitionIfRequired Internal Method

String repartitionIfRequired(final String queryableStoreName)

repartitionIfRequired…​FIXME

Note	repartitionIfRequired is used exclusively when GroupedStreamAggregateBuilder is requested to build.