public abstract class ProcessWindowFunction<IN,OUT,KEY,W extends Window> extends AbstractRichFunction
Modifier and Type | Class and Description |
---|---|
class |
ProcessWindowFunction.Context
The context holding window metadata
|
Constructor and Description |
---|
ProcessWindowFunction() |
Modifier and Type | Method and Description |
---|---|
void |
clear(ProcessWindowFunction.Context context)
Deletes any state in the
ProcessWindowFunction.Context when the Window is purged. |
abstract void |
process(KEY key,
ProcessWindowFunction.Context context,
scala.collection.Iterable<IN> elements,
Collector<OUT> out)
Evaluates the window and outputs none or several elements.
|
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
public abstract void process(KEY key, ProcessWindowFunction.Context context, scala.collection.Iterable<IN> elements, Collector<OUT> out) throws Exception
key
- The key for which this window is evaluated.context
- The context in which the window is being evaluated.elements
- 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(ProcessWindowFunction.Context context) throws Exception
ProcessWindowFunction.Context
when the Window is purged.
context
- The context to which the window is being evaluatedException
- The function may throw exceptions to fail the program and trigger recovery.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.