Package org.apache.kafka.streams.kstream.internals

Interface KStreamAggProcessorSupplier<K,RK,V,T>

All Superinterfaces:

ConnectedStoreProvider, ProcessorSupplier<K,V>

All Known Implementing Classes:

KStreamAggregate, KStreamReduce, KStreamSessionWindowAggregate, KStreamWindowAggregate

public interface KStreamAggProcessorSupplier<K,RK,V,T>
extends ProcessorSupplier<K,V>

Method Summary

Modifier and Type	Method	Description
void	enableSendingOldValues()
KTableValueGetterSupplier<RK,T>	view()

Methods inherited from interface org.apache.kafka.streams.processor.ConnectedStoreProvider

stores

Methods inherited from interface org.apache.kafka.streams.processor.ProcessorSupplier

get

Method Detail

view

KTableValueGetterSupplier<RK,T> view()

enableSendingOldValues

void enableSendingOldValues()