@Internal public class ReduceApplyWindowFunction<K,W extends Window,T,R> extends WrappingFunction<WindowFunction<T,R,K,W>> implements WindowFunction<T,R,K,W>
WindowFunctionthat is used for implementing a fold on a window configuration that only allows
WindowFunctionand cannot directly execute a
|Constructor and Description|
|Modifier and Type||Method and Description|
Evaluates the window and outputs none or several elements.
close, getWrappedFunction, open, setRuntimeContext
WindowFunction<T,R,K,W extends Window>
k- The key for which this window is evaluated.
window- The window that is being evaluated.
input- The elements in the window being evaluated.
out- A collector for emitting elements.
Exception- The function may throw exceptions to fail the program and trigger recovery.
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.