public final class ScalaAllWindowFunctionWrapper<IN,OUT,W extends Window> extends WrappingFunction<AllWindowFunction<IN,OUT,W>> implements AllWindowFunction<IN,OUT,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 |
---|
ScalaAllWindowFunctionWrapper(AllWindowFunction<IN,OUT,W> func) |
Modifier and Type | Method and Description |
---|---|
void |
apply(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 ScalaAllWindowFunctionWrapper(AllWindowFunction<IN,OUT,W> func)
public void apply(W window, Iterable<IN> input, Collector<OUT> out) throws Exception
AllWindowFunction
apply
in interface AllWindowFunction<IN,OUT,W extends Window>
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.