org.apache.flink.table.runtime.operators.window.groupwindow.assigners

Class PanedWindowAssigner<W extends Window>

java.lang.Object

org.apache.flink.table.runtime.operators.window.groupwindow.assigners.GroupWindowAssigner<W>

org.apache.flink.table.runtime.operators.window.groupwindow.assigners.PanedWindowAssigner<W>

Type Parameters:

W - The type of Window that this assigner assigns.

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

CumulativeWindowAssigner, SlidingWindowAssigner

public abstract class PanedWindowAssigner<W extends Window>
extends GroupWindowAssigner<W>

A WindowAssigner that window can be split into panes.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PanedWindowAssigner()

Method Summary

Modifier and Type	Method and Description
abstract W	assignPane(Object element, long timestamp) Given the timestamp and element, returns the pane into which it should be placed.
abstract W	getLastWindow(W pane) Gets the last window which the pane belongs to.
abstract Iterable<W>	splitIntoPanes(W window) Splits the given window into panes collection.

Methods inherited from class org.apache.flink.table.runtime.operators.window.groupwindow.assigners.GroupWindowAssigner

assignWindows, getWindowSerializer, isEventTime, open, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

PanedWindowAssigner

public PanedWindowAssigner()

Method Detail

assignPane

public abstract W assignPane(Object element,
                             long timestamp)

Given the timestamp and element, returns the pane into which it should be placed.

Parameters:

element - The element to which windows should be assigned.

timestamp - The timestamp of the element when GroupWindowAssigner.isEventTime() returns true, or the current system time when GroupWindowAssigner.isEventTime() returns false.

splitIntoPanes

public abstract Iterable<W> splitIntoPanes(W window)

Splits the given window into panes collection.

Parameters:

window - the window to be split.

Returns:

the panes iterable

getLastWindow

public abstract W getLastWindow(W pane)

Gets the last window which the pane belongs to.