public final class ScalaWindowFunction<IN,OUT,KEY,W extends Window> extends Object implements WindowFunction<IN,OUT,KEY,W>
Constructor and Description |
---|
ScalaWindowFunction(scala.Function4<KEY,W,scala.collection.Iterable<IN>,Collector<OUT>,scala.runtime.BoxedUnit> function) |
Modifier and Type | Method and Description |
---|---|
void |
apply(KEY key,
W window,
Iterable<IN> input,
Collector<OUT> out)
Evaluates the window and outputs none or several elements.
|
public void apply(KEY key, W window, Iterable<IN> input, Collector<OUT> out) throws Exception
WindowFunction
apply
in interface WindowFunction<IN,OUT,KEY,W extends Window>
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–2018 The Apache Software Foundation. All rights reserved.