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