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

类 WindowingStrategy

java.lang.Object

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

直接已知子类:

SliceAttachedWindowingStrategy, TimeAttributeWindowingStrategy, WindowAttachedWindowingStrategy

public abstract class WindowingStrategy
extends Object

Logical representation of a windowing strategy.

字段概要

字段

限定符和类型	字段和说明
static String	FIELD_NAME_IS_ROWTIME
static String	FIELD_NAME_TIME_ATTRIBUTE_TYPE
static String	FIELD_NAME_WINDOW
protected boolean	isRowtime
protected org.apache.flink.table.types.logical.LogicalType	timeAttributeType
protected WindowSpec	window

构造器概要

构造器

限定符	构造器和说明
protected	WindowingStrategy(WindowSpec window, org.apache.flink.table.types.logical.LogicalType timeAttributeType)
protected	WindowingStrategy(WindowSpec window, org.apache.flink.table.types.logical.LogicalType timeAttributeType, boolean isRowtime)

方法概要

限定符和类型	方法和说明
org.apache.flink.table.types.logical.LogicalType	getTimeAttributeType()
WindowSpec	getWindow()
boolean	isProctime()
boolean	isRowtime()
abstract String	toSummaryString(String[] inputFieldNames)

从类继承的方法 java.lang.Object

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

字段详细资料

FIELD_NAME_WINDOW

public static final String FIELD_NAME_WINDOW

另请参阅:

常量字段值

FIELD_NAME_TIME_ATTRIBUTE_TYPE

public static final String FIELD_NAME_TIME_ATTRIBUTE_TYPE

另请参阅:

常量字段值

FIELD_NAME_IS_ROWTIME

public static final String FIELD_NAME_IS_ROWTIME

另请参阅:

常量字段值

window

protected final WindowSpec window

timeAttributeType

protected final org.apache.flink.table.types.logical.LogicalType timeAttributeType

isRowtime

protected final boolean isRowtime

构造器详细资料

WindowingStrategy

protected WindowingStrategy(WindowSpec window,
                            org.apache.flink.table.types.logical.LogicalType timeAttributeType)

WindowingStrategy

protected WindowingStrategy(WindowSpec window,
                            org.apache.flink.table.types.logical.LogicalType timeAttributeType,
                            boolean isRowtime)

方法详细资料

toSummaryString

public abstract String toSummaryString(String[] inputFieldNames)

getWindow

public WindowSpec getWindow()

getTimeAttributeType

public org.apache.flink.table.types.logical.LogicalType getTimeAttributeType()

isRowtime

public boolean isRowtime()

isProctime

public boolean isProctime()