Class ProcessEvictingWindowReader<IN,OUT,KEY,W extends Window>
- java.lang.Object
-
- org.apache.flink.api.common.functions.AbstractRichFunction
-
- org.apache.flink.state.api.functions.WindowReaderFunction<StreamRecord<IN>,OUT,KEY,W>
-
- org.apache.flink.state.api.input.operator.window.EvictingWindowReaderFunction<IN,IN,OUT,KEY,W>
-
- org.apache.flink.state.api.input.operator.window.ProcessEvictingWindowReader<IN,OUT,KEY,W>
-
- All Implemented Interfaces:
Serializable
,Function
,RichFunction
@Internal public class ProcessEvictingWindowReader<IN,OUT,KEY,W extends Window> extends EvictingWindowReaderFunction<IN,IN,OUT,KEY,W>
A wrapper function for reading an evicting window with no pre-aggregation.- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.flink.state.api.functions.WindowReaderFunction
WindowReaderFunction.Context<W extends Window>
-
-
Constructor Summary
Constructors Constructor Description ProcessEvictingWindowReader(WindowReaderFunction<IN,OUT,KEY,W> wrappedFunction)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Iterable<IN>
transform(Iterable<StreamRecord<IN>> elements)
-
Methods inherited from class org.apache.flink.state.api.input.operator.window.EvictingWindowReaderFunction
close, open, readWindow, setRuntimeContext
-
Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction
getIterationRuntimeContext, getRuntimeContext
-
-
-
-
Constructor Detail
-
ProcessEvictingWindowReader
public ProcessEvictingWindowReader(WindowReaderFunction<IN,OUT,KEY,W> wrappedFunction)
-
-