public final class InternalIterableWindowFunction<IN,OUT,KEY,W extends Window> extends WrappingFunction<WindowFunction<IN,OUT,KEY,W>> implements InternalWindowFunction<Iterable<IN>,OUT,KEY,W>
WindowFunction
that takes an Iterable
when the window state also is an Iterable
.InternalWindowFunction.InternalWindowContext
wrappedFunction
Constructor and Description |
---|
InternalIterableWindowFunction(WindowFunction<IN,OUT,KEY,W> wrappedFunction) |
Modifier and Type | Method and Description |
---|---|
void |
clear(W window,
InternalWindowFunction.InternalWindowContext context)
Deletes any state in the
Context when the Window expires (the watermark passes its
maxTimestamp + allowedLateness ). |
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 task that executes the
function.
|
void |
process(KEY key,
W window,
InternalWindowFunction.InternalWindowContext context,
Iterable<IN> input,
Collector<OUT> out)
Evaluates the window and outputs none or several elements.
|
close, getWrappedFunction, open, setRuntimeContext
public InternalIterableWindowFunction(WindowFunction<IN,OUT,KEY,W> wrappedFunction)
public void process(KEY key, W window, InternalWindowFunction.InternalWindowContext context, Iterable<IN> input, Collector<OUT> out) throws Exception
InternalWindowFunction
process
in interface InternalWindowFunction<Iterable<IN>,OUT,KEY,W extends Window>
context
- The context in which the window 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 void clear(W window, InternalWindowFunction.InternalWindowContext context) throws Exception
InternalWindowFunction
Context
when the Window expires (the watermark passes its
maxTimestamp
+ allowedLateness
).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–2024 The Apache Software Foundation. All rights reserved.