Skip to content


KStreamAggregate<K, V, T> is a KStreamAggProcessorSupplier.

Creating Instance

KStreamAggregate takes the following to be created:

  • Name of a State Store
  • Initializer (of T values)
  • Aggregator<? super K, ? super V, T>

KStreamAggregate is created when:

  • CogroupedStreamAggregateBuilder is requested to build (a KTable)
  • KGroupedStreamImpl is requested to aggregate and doCount
Back to top