org.apache.flink.streaming.api.scala.function

Interface AllWindowFunction<IN,OUT,W extends Window>

All Superinterfaces:

Function, Serializable

All Known Implementing Classes:

RichAllWindowFunction

public interface AllWindowFunction<IN,OUT,W extends Window>
extends Function, Serializable

Base interface for functions that are evaluated over non-grouped windows, i.e., windows over all stream partitions.

Method Summary

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

Method Detail

apply

void apply(W window,
           scala.collection.Iterable<IN> input,
           Collector<OUT> out)

Evaluates the window and outputs none or several elements.

Parameters:

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.