public final class ScalaWindowFunctionWrapper<IN,OUT,KEY,W extends Window> extends WrappingFunction<WindowFunction<IN,OUT,KEY,W>> implements WindowFunction<IN,OUT,KEY,W>, RichFunction
The Scala and Java Window functions differ in their type of "Iterable": - Scala WindowFunction: scala.Iterable - Java WindowFunction: java.lang.Iterable
wrappedFunction
Constructor and Description |
---|
ScalaWindowFunctionWrapper(WindowFunction<IN,OUT,KEY,W> func) |
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.
|
IterationRuntimeContext |
getIterationRuntimeContext()
Gets a specialized version of the
RuntimeContext , which has additional information
about the iteration in which the function is executed. |
RuntimeContext |
getRuntimeContext()
Gets the context that contains information about the UDF's runtime, such as the
parallelism of the function, the subtask index of the function, or the name of
the of the task that executes the function.
|
close, getWrappedFunction, open, setRuntimeContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, open, setRuntimeContext
public ScalaWindowFunctionWrapper(WindowFunction<IN,OUT,KEY,W> func)
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.public RuntimeContext getRuntimeContext()
RichFunction
The RuntimeContext also gives access to the
Accumulator
s and the
DistributedCache
.
getRuntimeContext
in interface RichFunction
getRuntimeContext
in class AbstractRichFunction
public IterationRuntimeContext getIterationRuntimeContext()
RichFunction
RuntimeContext
, which has additional information
about the iteration in which the function is executed. This IterationRuntimeContext is only
available if the function is part of an iteration. Otherwise, this method throws an exception.getIterationRuntimeContext
in interface RichFunction
getIterationRuntimeContext
in class AbstractRichFunction
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.