org.apache.flink.streaming.runtime.operators.windowing.functions

Class InternalWindowFunction<IN,OUT,KEY,W extends Window>

java.lang.Object

org.apache.flink.streaming.runtime.operators.windowing.functions.InternalWindowFunction<IN,OUT,KEY,W>

Type Parameters:

IN - The type of the input value.

OUT - The type of the output value.

KEY - The type of the key.

All Implemented Interfaces:

Serializable, Function

Direct Known Subclasses:

InternalIterableWindowFunction, InternalSingleValueWindowFunction

public abstract class InternalWindowFunction<IN,OUT,KEY,W extends Window>
extends Object
implements Function, Serializable

Internal interface for functions that are evaluated over keyed (grouped) windows.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
InternalWindowFunction()

Method Summary

Modifier and Type	Method and Description
abstract void	apply(KEY key, W window, IN input, Collector<OUT> out) Evaluates the window and outputs none or several elements.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InternalWindowFunction

public InternalWindowFunction()

Method Detail

apply

public abstract void apply(KEY key,
                           W window,
                           IN input,
                           Collector<OUT> out)
                    throws Exception

Evaluates the window and outputs none or several elements.

Parameters:

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.

Throws:

Exception - The function may throw exceptions to fail the program and trigger recovery.