org.apache.flink.table.planner.plan.logical

Class SliceAttachedWindowingStrategy

java.lang.Object

org.apache.flink.table.planner.plan.logical.WindowingStrategy

org.apache.flink.table.planner.plan.logical.SliceAttachedWindowingStrategy

public class SliceAttachedWindowingStrategy
extends WindowingStrategy

A windowing strategy that gets windows from input columns as window slice have been assigned and attached to the physical columns. The window slice is usually identified by slice end timestamp.

See Also:

for more details about which windows can apply slicing.

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIELD_NAME_SLICE_END

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 and Description
SliceAttachedWindowingStrategy(WindowSpec window, LogicalType timeAttributeType, int sliceEnd)

Method Summary

Modifier and Type	Method and Description
int	getSliceEnd()
String	toSummaryString(String[] inputFieldNames)

Methods inherited from class org.apache.flink.table.planner.plan.logical.WindowingStrategy

getTimeAttributeType, getWindow, isProctime, isRowtime

Methods inherited from class java.lang.Object

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

Field Detail

FIELD_NAME_SLICE_END

public static final String FIELD_NAME_SLICE_END

See Also:

Constant Field Values

Constructor Detail

SliceAttachedWindowingStrategy

public SliceAttachedWindowingStrategy(WindowSpec window,
                                      LogicalType timeAttributeType,
                                      int sliceEnd)

Method Detail

toSummaryString

public String toSummaryString(String[] inputFieldNames)

Specified by:

toSummaryString in class WindowingStrategy

getSliceEnd

public int getSliceEnd()