Class RichWindowFunction<IN,OUT,KEY,W extends Window>
- java.lang.Object
-
- org.apache.flink.api.common.functions.AbstractRichFunction
-
- org.apache.flink.streaming.api.functions.windowing.RichWindowFunction<IN,OUT,KEY,W>
-
- Type Parameters:
IN
- The type of the input value.OUT
- The type of the output value.KEY
- The type of the key.W
- The type ofWindow
that this window function can be applied on.
- All Implemented Interfaces:
Serializable
,Function
,RichFunction
,WindowFunction<IN,OUT,KEY,W>
- Direct Known Subclasses:
HadoopReducerWrappedFunction
@Public public abstract class RichWindowFunction<IN,OUT,KEY,W extends Window> extends AbstractRichFunction implements WindowFunction<IN,OUT,KEY,W>
Rich variant of theWindowFunction
. As aRichFunction
, it gives access to theRuntimeContext
and provides setup and tear-down methods:RichFunction.open(OpenContext)
andRichFunction.close()
.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description RichWindowFunction()
-
Method Summary
-
Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.streaming.api.functions.windowing.WindowFunction
apply
-
-