kafka-streams-internals-KStreamAggProcessorSupplier.adoc

KStreamAggProcessorSupplier Contract

KStreamAggProcessorSupplier is the extension contract of ProcessorSuppliers that allows implementations for views and to turn sendingOldValues flag on.

package org.apache.kafka.streams.kstream.internals;

interface KStreamAggProcessorSupplier<K, RK, V, T> extends ProcessorSupplier<K, V> {
  void enableSendingOldValues();
  KTableValueGetterSupplier<RK, T> view();
}

Table 1. KStreamAggProcessorSupplier Contract

Method	Description
enableSendingOldValues	Used when…​FIXME
view	Used when…​FIXME

Table 2. KStreamAggProcessorSuppliers

KStreamAggProcessorSupplier	Description
KStreamWindowReduce
KStreamAggregate
KStreamSessionWindowAggregate
KStreamReduce
KStreamWindowAggregate