GroupedStreamAggregateBuilder

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

GroupedStreamAggregateBuilder takes the following to be created:

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:

repartitionIfRequired Internal Method

String repartitionIfRequired(final String queryableStoreName)

repartitionIfRequired…​FIXME

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

results matching ""

    No results matching ""