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

Class WindowAttachedWindowingStrategy

java.lang.Object

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

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

public class WindowAttachedWindowingStrategy
extends WindowingStrategy

A windowing strategy that gets windows from input columns as windows have been assigned and attached to the physical columns.

Field Summary

Fields

Modifier and Type	Field	Description
static String	FIELD_NAME_WINDOW_END
static String	FIELD_NAME_WINDOW_START

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
WindowAttachedWindowingStrategy(WindowSpec window, LogicalType timeAttributeType, int windowEnd)	Creates a WindowAttachedWindowingStrategy which only windowEnd is attatched.
WindowAttachedWindowingStrategy(WindowSpec window, LogicalType timeAttributeType, int windowStart, int windowEnd)

Method Summary

Modifier and Type	Method	Description
int	getWindowEnd()
int	getWindowStart()
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_WINDOW_START

public static final String FIELD_NAME_WINDOW_START

See Also:

Constant Field Values

FIELD_NAME_WINDOW_END

public static final String FIELD_NAME_WINDOW_END

See Also:

Constant Field Values

Constructor Detail

WindowAttachedWindowingStrategy

public WindowAttachedWindowingStrategy(WindowSpec window,
                                       LogicalType timeAttributeType,
                                       int windowStart,
                                       int windowEnd)

WindowAttachedWindowingStrategy

public WindowAttachedWindowingStrategy(WindowSpec window,
                                       LogicalType timeAttributeType,
                                       int windowEnd)

Creates a WindowAttachedWindowingStrategy which only windowEnd is attatched.

Method Detail

toSummaryString

public String toSummaryString(String[] inputFieldNames)

Specified by:

toSummaryString in class WindowingStrategy

getWindowStart

public int getWindowStart()

getWindowEnd

public int getWindowEnd()