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

Class Window

java.lang.Object

org.apache.flink.table.runtime.operators.window.Window

All Implemented Interfaces:

Comparable<Window>

Direct Known Subclasses:

CountWindow, TimeWindow

public abstract class Window
extends Object
implements Comparable<Window>

A Window is a grouping of elements into finite buckets. Windows have a maximum timestamp which means that, at some point, all elements that go into one window will have arrived.

Subclasses should implement equals() and hashCode() so that logically same windows are treated the same.

Constructor Summary

Constructors

Constructor and Description
Window()

Method Summary

Modifier and Type	Method and Description
abstract boolean	equals(Object obj)
abstract int	hashCode()
abstract long	maxTimestamp() Gets the largest timestamp that still belongs to this window.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Comparable

compareTo

Constructor Detail

Window

public Window()

Method Detail

maxTimestamp

public abstract long maxTimestamp()

Gets the largest timestamp that still belongs to this window.

Returns:

The largest timestamp that still belongs to this window.

hashCode

public abstract int hashCode()

Overrides:

hashCode in class Object

equals

public abstract boolean equals(Object obj)

Overrides:

equals in class Object