Package org.apache.flink.state.api.input.operator.window

Interface Summary

Interface	Description
WindowContents<S extends State,IN>	An abstraction for transforming any State type into an iterable over its contents.

Class Summary

Class	Description
AggregateEvictingWindowReaderFunction<IN,ACC,R,OUT,KEY,W extends Window>	A wrapper for reading an evicting window operator with an aggregate function.
EvictingWindowReaderFunction<IN,R,OUT,KEY,W extends Window>	Wrapper for reading state from an evicting window operator.
PassThroughReader<KEY,W extends Window,IN>	A WindowReaderFunction that just emits each input element.
ProcessEvictingWindowReader<IN,OUT,KEY,W extends Window>	A wrapper function for reading an evicting window with no pre-aggregation.
ReduceEvictingWindowReaderFunction<IN,OUT,KEY,W extends Window>	A wrapper function for reading state from an evicting window operator with a reduce function.