Package org.apache.flink.table.runtime.util

Class WindowKey

java.lang.Object

org.apache.flink.table.runtime.util.WindowKey

public final class WindowKey
extends Object

The WindowKey structure represents a combination of key and window. This is mainly used in the mini-batch window operators and window is identified by window end timestamp.

Constructor Summary

Constructors

Constructor	Description
WindowKey(long window, RowData key)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
RowData	getKey()
long	getWindow()
int	hashCode()
WindowKey	replace(long window, RowData key)	Replace the currently stored key and window by the given new key and new window.

Methods inherited from class java.lang.Object

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

Constructor Detail

WindowKey

public WindowKey(long window,
                 RowData key)

Method Detail

replace

public WindowKey replace(long window,
                         RowData key)

Replace the currently stored key and window by the given new key and new window.

getWindow

public long getWindow()

getKey

public RowData getKey()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object