Class TimeAttributeWindowingStrategy
- java.lang.Object
-
- org.apache.flink.table.planner.plan.logical.WindowingStrategy
-
- org.apache.flink.table.planner.plan.logical.TimeAttributeWindowingStrategy
-
public class TimeAttributeWindowingStrategy extends WindowingStrategy
A windowing strategy that gets windows by calculating on time attribute column.
-
-
Field Summary
Fields Modifier and Type Field Description static String
FIELD_NAME_TIME_ATTRIBUTE_INDEX
-
Fields inherited from class org.apache.flink.table.planner.plan.logical.WindowingStrategy
FIELD_NAME_IS_ROWTIME, FIELD_NAME_TIME_ATTRIBUTE_TYPE, FIELD_NAME_WINDOW, isRowtime, timeAttributeType, window
-
-
Constructor Summary
Constructors Constructor Description TimeAttributeWindowingStrategy(WindowSpec window, LogicalType timeAttributeType, int timeAttributeIndex)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
getTimeAttributeIndex()
String
toSummaryString(String[] inputFieldNames)
-
Methods inherited from class org.apache.flink.table.planner.plan.logical.WindowingStrategy
getTimeAttributeType, getWindow, isProctime, isRowtime
-
-
-
-
Field Detail
-
FIELD_NAME_TIME_ATTRIBUTE_INDEX
public static final String FIELD_NAME_TIME_ATTRIBUTE_INDEX
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
TimeAttributeWindowingStrategy
public TimeAttributeWindowingStrategy(WindowSpec window, LogicalType timeAttributeType, int timeAttributeIndex)
-
-
Method Detail
-
toSummaryString
public String toSummaryString(String[] inputFieldNames)
- Specified by:
toSummaryString
in classWindowingStrategy
-
getTimeAttributeIndex
public int getTimeAttributeIndex()
-
-