Uses of Class
org.apache.flink.state.api.functions.WindowReaderFunction

Packages that use WindowReaderFunction

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

Uses of WindowReaderFunction in org.apache.flink.state.api

Methods in org.apache.flink.state.api with parameters of type WindowReaderFunction

Modifier and Type	Method	Description
<K,T,ACC,R,OUT> org.apache.flink.api.java.DataSet<OUT>	EvictingWindowReader.aggregate(String uid, org.apache.flink.api.common.functions.AggregateFunction<T,ACC,R> aggregateFunction, WindowReaderFunction<R,OUT,K,W> readerFunction, org.apache.flink.api.common.typeinfo.TypeInformation<K> keyType, org.apache.flink.api.common.typeinfo.TypeInformation<T> inputType, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType)	Deprecated. Reads window state generated using an AggregateFunction.
<K,T,ACC,R,OUT> org.apache.flink.streaming.api.datastream.DataStream<OUT>	EvictingWindowSavepointReader.aggregate(String uid, org.apache.flink.api.common.functions.AggregateFunction<T,ACC,R> aggregateFunction, WindowReaderFunction<R,OUT,K,W> readerFunction, org.apache.flink.api.common.typeinfo.TypeInformation<K> keyType, org.apache.flink.api.common.typeinfo.TypeInformation<T> inputType, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType)	Reads window state generated using an AggregateFunction.
<K,T,ACC,R,OUT> org.apache.flink.api.java.operators.DataSource<OUT>	WindowReader.aggregate(String uid, org.apache.flink.api.common.functions.AggregateFunction<T,ACC,R> aggregateFunction, WindowReaderFunction<R,OUT,K,W> readerFunction, org.apache.flink.api.common.typeinfo.TypeInformation<K> keyType, org.apache.flink.api.common.typeinfo.TypeInformation<ACC> accType, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType)	Deprecated. Reads window state generated using an AggregateFunction.
<K,T,ACC,R,OUT> org.apache.flink.streaming.api.datastream.DataStream<OUT>	WindowSavepointReader.aggregate(String uid, org.apache.flink.api.common.functions.AggregateFunction<T,ACC,R> aggregateFunction, WindowReaderFunction<R,OUT,K,W> readerFunction, org.apache.flink.api.common.typeinfo.TypeInformation<K> keyType, org.apache.flink.api.common.typeinfo.TypeInformation<ACC> accType, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType)	Reads window state generated using an AggregateFunction.
<K,T,OUT> org.apache.flink.api.java.DataSet<OUT>	EvictingWindowReader.process(String uid, WindowReaderFunction<T,OUT,K,W> readerFunction, org.apache.flink.api.common.typeinfo.TypeInformation<K> keyType, org.apache.flink.api.common.typeinfo.TypeInformation<T> stateType, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType)	Deprecated. Reads window state generated without any preaggregation such as WindowedStream#apply and WindowedStream#process.
<K,T,OUT> org.apache.flink.streaming.api.datastream.DataStream<OUT>	EvictingWindowSavepointReader.process(String uid, WindowReaderFunction<T,OUT,K,W> readerFunction, org.apache.flink.api.common.typeinfo.TypeInformation<K> keyType, org.apache.flink.api.common.typeinfo.TypeInformation<T> stateType, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType)	Reads window state generated without any preaggregation such as WindowedStream#apply and WindowedStream#process.
<K,T,OUT> org.apache.flink.api.java.operators.DataSource<OUT>	WindowReader.process(String uid, WindowReaderFunction<T,OUT,K,W> readerFunction, org.apache.flink.api.common.typeinfo.TypeInformation<K> keyType, org.apache.flink.api.common.typeinfo.TypeInformation<T> stateType, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType)	Deprecated. Reads window state generated without any preaggregation such as WindowedStream#apply and WindowedStream#process.
<K,T,OUT> org.apache.flink.streaming.api.datastream.DataStream<OUT>	WindowSavepointReader.process(String uid, WindowReaderFunction<T,OUT,K,W> readerFunction, org.apache.flink.api.common.typeinfo.TypeInformation<K> keyType, org.apache.flink.api.common.typeinfo.TypeInformation<T> stateType, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType)	Reads window state generated without any preaggregation such as WindowedStream#apply and WindowedStream#process.
<K,T,OUT> org.apache.flink.api.java.DataSet<OUT>	EvictingWindowReader.reduce(String uid, org.apache.flink.api.common.functions.ReduceFunction<T> function, WindowReaderFunction<T,OUT,K,W> readerFunction, org.apache.flink.api.common.typeinfo.TypeInformation<K> keyType, org.apache.flink.api.common.typeinfo.TypeInformation<T> reduceType, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType)	Deprecated. Reads window state generated using a ReduceFunction.
<K,T,OUT> org.apache.flink.streaming.api.datastream.DataStream<OUT>	EvictingWindowSavepointReader.reduce(String uid, org.apache.flink.api.common.functions.ReduceFunction<T> function, WindowReaderFunction<T,OUT,K,W> readerFunction, org.apache.flink.api.common.typeinfo.TypeInformation<K> keyType, org.apache.flink.api.common.typeinfo.TypeInformation<T> reduceType, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType)	Reads window state generated using a ReduceFunction.
<K,T,OUT> org.apache.flink.api.java.operators.DataSource<OUT>	WindowReader.reduce(String uid, org.apache.flink.api.common.functions.ReduceFunction<T> function, WindowReaderFunction<T,OUT,K,W> readerFunction, org.apache.flink.api.common.typeinfo.TypeInformation<K> keyType, org.apache.flink.api.common.typeinfo.TypeInformation<T> reduceType, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType)	Deprecated. Reads window state generated using a ReduceFunction.
<K,T,OUT> org.apache.flink.streaming.api.datastream.DataStream<OUT>	WindowSavepointReader.reduce(String uid, org.apache.flink.api.common.functions.ReduceFunction<T> function, WindowReaderFunction<T,OUT,K,W> readerFunction, org.apache.flink.api.common.typeinfo.TypeInformation<K> keyType, org.apache.flink.api.common.typeinfo.TypeInformation<T> reduceType, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType)	Reads window state generated using a ReduceFunction.

Uses of WindowReaderFunction in org.apache.flink.state.api.input.operator

Methods in org.apache.flink.state.api.input.operator with parameters of type WindowReaderFunction

Modifier and Type	Method	Description
static <KEY,T,ACC,R,OUT,W extends org.apache.flink.streaming.api.windowing.windows.Window> WindowReaderOperator<?,KEY,R,W,OUT>	WindowReaderOperator.aggregate(org.apache.flink.api.common.functions.AggregateFunction<T,ACC,R> function, WindowReaderFunction<R,OUT,KEY,W> readerFunction, org.apache.flink.api.common.typeinfo.TypeInformation<KEY> keyType, org.apache.flink.api.common.typeutils.TypeSerializer<W> windowSerializer, org.apache.flink.api.common.typeinfo.TypeInformation<ACC> accumulatorType)
static <KEY,T,W extends org.apache.flink.streaming.api.windowing.windows.Window,OUT> WindowReaderOperator<?,KEY,org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T>,W,OUT>	WindowReaderOperator.evictingWindow(WindowReaderFunction<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T>,OUT,KEY,W> readerFunction, org.apache.flink.api.common.typeinfo.TypeInformation<KEY> keyType, org.apache.flink.api.common.typeutils.TypeSerializer<W> windowSerializer, org.apache.flink.api.common.typeinfo.TypeInformation<T> stateType, org.apache.flink.api.common.ExecutionConfig config)
static <KEY,T,W extends org.apache.flink.streaming.api.windowing.windows.Window,OUT> WindowReaderOperator<?,KEY,T,W,OUT>	WindowReaderOperator.process(WindowReaderFunction<T,OUT,KEY,W> readerFunction, org.apache.flink.api.common.typeinfo.TypeInformation<KEY> keyType, org.apache.flink.api.common.typeutils.TypeSerializer<W> windowSerializer, org.apache.flink.api.common.typeinfo.TypeInformation<T> stateType)
static <KEY,T,W extends org.apache.flink.streaming.api.windowing.windows.Window,OUT> WindowReaderOperator<?,KEY,T,W,OUT>	WindowReaderOperator.reduce(org.apache.flink.api.common.functions.ReduceFunction<T> function, WindowReaderFunction<T,OUT,KEY,W> reader, org.apache.flink.api.common.typeinfo.TypeInformation<KEY> keyType, org.apache.flink.api.common.typeutils.TypeSerializer<W> windowSerializer, org.apache.flink.api.common.typeinfo.TypeInformation<T> inputType)

Uses of WindowReaderFunction in org.apache.flink.state.api.input.operator.window

Subclasses of WindowReaderFunction in org.apache.flink.state.api.input.operator.window

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

Constructors in org.apache.flink.state.api.input.operator.window with parameters of type WindowReaderFunction

Constructor	Description
AggregateEvictingWindowReaderFunction(WindowReaderFunction<R,OUT,KEY,W> wrappedFunction, org.apache.flink.api.common.functions.AggregateFunction<IN,ACC,R> aggFunction)
EvictingWindowReaderFunction(WindowReaderFunction<R,OUT,KEY,W> wrappedFunction)
ProcessEvictingWindowReader(WindowReaderFunction<IN,OUT,KEY,W> wrappedFunction)
ReduceEvictingWindowReaderFunction(WindowReaderFunction<IN,OUT,KEY,W> wrappedFunction, org.apache.flink.api.common.functions.ReduceFunction<IN> reduceFunction)