IN- The type of the input value.
OUT- The type of the output value.
KEY- The type of the key.
W- The type of
Windowthat this window function can be applied on.
@Public public interface WindowFunction<IN,OUT,KEY,W extends Window> extends Function, Serializable
|Modifier and Type||Method and Description|
Evaluates the window and outputs none or several elements.
void apply(KEY key, W window, Iterable<IN> input, Collector<OUT> out) throws Exception
key- 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–2023 The Apache Software Foundation. All rights reserved.