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

Class KStreamSessionWindowAggregate<K,V,Agg>

java.lang.Object

org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregate<K,V,Agg>

All Implemented Interfaces:

KStreamAggProcessorSupplier<K,Windowed<K>,V,Agg>, ConnectedStoreProvider, ProcessorSupplier<K,V>

public class KStreamSessionWindowAggregate<K,V,Agg>
extends Object
implements KStreamAggProcessorSupplier<K,Windowed<K>,V,Agg>

Constructor Summary

Constructors

Constructor	Description
KStreamSessionWindowAggregate(SessionWindows windows, String storeName, Initializer<Agg> initializer, Aggregator<? super K,? super V,Agg> aggregator, Merger<? super K,Agg> sessionMerger)

Method Summary

Modifier and Type	Method	Description
void	enableSendingOldValues()
Processor<K,V>	get()	Return a new Processor instance.
KTableValueGetterSupplier<Windowed<K>,Agg>	view()
SessionWindows	windows()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

stores

Constructor Detail

KStreamSessionWindowAggregate

public KStreamSessionWindowAggregate(SessionWindows windows,
                                     String storeName,
                                     Initializer<Agg> initializer,
                                     Aggregator<? super K,? super V,Agg> aggregator,
                                     Merger<? super K,Agg> sessionMerger)

Method Detail

get

public Processor<K,V> get()

Description copied from interface: ProcessorSupplier

Return a new Processor instance.

Specified by:

get in interface ProcessorSupplier<K,V>

Returns:

a new Processor instance

windows

public SessionWindows windows()

enableSendingOldValues

public void enableSendingOldValues()

Specified by:

enableSendingOldValues in interface KStreamAggProcessorSupplier<K,Windowed<K>,V,Agg>

view

public KTableValueGetterSupplier<Windowed<K>,Agg> view()

Specified by:

view in interface KStreamAggProcessorSupplier<K,Windowed<K>,V,Agg>