Class CountWindow
- java.lang.Object
-
- org.apache.flink.table.runtime.operators.window.Window
-
- org.apache.flink.table.runtime.operators.window.CountWindow
-
- All Implemented Interfaces:
Comparable<Window>
public class CountWindow extends Window
AWindowthat represents a count window. For each count window, we will assign a unique id. Thus this CountWindow can act as namespace part in state. We can attach data to each different CountWindow.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classCountWindow.SerializerThe serializer used to write the CountWindow type.
-
Constructor Summary
Constructors Constructor Description CountWindow(long id)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description intcompareTo(Window o)booleanequals(Object o)longgetId()Gets the id (0-based) of the window.inthashCode()longmaxTimestamp()Gets the largest timestamp that still belongs to this window.StringtoString()
-
-
-
Method Detail
-
getId
public long getId()
Gets the id (0-based) of the window.
-
maxTimestamp
public long maxTimestamp()
Description copied from class:WindowGets the largest timestamp that still belongs to this window.- Specified by:
maxTimestampin classWindow- Returns:
- The largest timestamp that still belongs to this window.
-
compareTo
public int compareTo(Window o)
-
-