Class TumblingWindowSpec
- java.lang.Object
-
- org.apache.flink.table.planner.plan.logical.TumblingWindowSpec
-
- All Implemented Interfaces:
WindowSpec
public class TumblingWindowSpec extends Object implements WindowSpec
Logical representation of a tumbling window specification.
-
-
Field Summary
Fields Modifier and Type Field Description static String
FIELD_NAME_OFFSET
static String
FIELD_NAME_SIZE
-
Constructor Summary
Constructors Constructor Description TumblingWindowSpec(Duration size, Duration offset)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
Duration
getOffset()
Duration
getSize()
int
hashCode()
boolean
isAlignedWindow()
Return true if the window is aligned.String
toString()
String
toSummaryString(String windowing, String[] inputFieldNames)
-
-
-
Field Detail
-
FIELD_NAME_SIZE
public static final String FIELD_NAME_SIZE
- See Also:
- Constant Field Values
-
FIELD_NAME_OFFSET
public static final String FIELD_NAME_OFFSET
- See Also:
- Constant Field Values
-
-
Method Detail
-
toSummaryString
public String toSummaryString(String windowing, String[] inputFieldNames)
- Specified by:
toSummaryString
in interfaceWindowSpec
-
getSize
public Duration getSize()
-
getOffset
public Duration getOffset()
-
isAlignedWindow
public boolean isAlignedWindow()
Description copied from interface:WindowSpec
Return true if the window is aligned.See more details about aligned window and unaligned window in
WindowAggOperator
.- Specified by:
isAlignedWindow
in interfaceWindowSpec
-
-