package org.apache.kafka.streams.kstream.internals;
interface KStreamAggProcessorSupplier<K, RK, V, T> extends ProcessorSupplier<K, V> {
void enableSendingOldValues();
KTableValueGetterSupplier<RK, T> view();
}KStreamAggProcessorSupplier Contract
KStreamAggProcessorSupplier is the extension contract of ProcessorSuppliers that allows implementations for views and to turn sendingOldValues flag on.
| Method | Description |
|---|---|
|
|
|
| KStreamAggProcessorSupplier | Description |
|---|---|
|
|
|
|
|
|