org.apache.flink.table.planner.plan.nodes.exec.batch

类 BatchExecOverAggregateBase

java.lang.Object

org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase<org.apache.flink.table.data.RowData>

org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecOverAggregateBase

所有已实现的接口:

BatchExecNode<org.apache.flink.table.data.RowData>, InputSortedExecNode<org.apache.flink.table.data.RowData>, ExecNode<org.apache.flink.table.data.RowData>, ExecNodeTranslator<org.apache.flink.table.data.RowData>, SingleTransformationTranslator<org.apache.flink.table.data.RowData>

直接已知子类:

BatchExecOverAggregate, BatchExecPythonOverAggregate

public abstract class BatchExecOverAggregateBase
extends ExecNodeBase<org.apache.flink.table.data.RowData>
implements InputSortedExecNode<org.apache.flink.table.data.RowData>, SingleTransformationTranslator<org.apache.flink.table.data.RowData>

Batch ExecNode base class for sort-based over window aggregate.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	BatchExecOverAggregateBase.OverWindowMode OverWindowMode describes the mode of a group in over window.

字段概要

字段

限定符和类型	字段和说明
protected OverSpec	overSpec

从接口继承的字段 org.apache.flink.table.planner.plan.nodes.exec.ExecNode

FIELD_NAME_CONFIGURATION, FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE, FIELD_NAME_TYPE

构造器概要

构造器

构造器和说明
BatchExecOverAggregateBase(int id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, OverSpec overSpec, InputProperty inputProperty, org.apache.flink.table.types.logical.RowType outputType, String description)

方法概要

限定符和类型	方法和说明
protected List<RexLiteral>	getConstants()
protected org.apache.flink.table.types.logical.RowType	getInputTypeWithConstants()
protected BatchExecOverAggregateBase.OverWindowMode	inferGroupMode(OverSpec.GroupSpec group) Infer the over window mode based on given group info.
protected boolean	isSlidingWindow(OverSpec.GroupSpec group)
protected boolean	isUnboundedFollowingWindow(OverSpec.GroupSpec group)
protected boolean	isUnboundedPrecedingWindow(OverSpec.GroupSpec group)
protected boolean	isUnboundedWindow(OverSpec.GroupSpec group)

从类继承的方法 org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase

accept, createFormattedTransformationDescription, createFormattedTransformationName, createTransformationDescription, createTransformationMeta, createTransformationMeta, createTransformationName, createTransformationUid, getContextFromAnnotation, getDescription, getId, getInputEdges, getInputProperties, getOutputType, getPersistedConfig, getSimplifiedName, inputsContainSingleton, replaceInputEdge, setInputEdges, translateToPlan, translateToPlanInternal

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

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

从接口继承的方法 org.apache.flink.table.planner.plan.nodes.exec.ExecNode

accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setInputEdges

从接口继承的方法 org.apache.flink.table.planner.plan.nodes.exec.ExecNodeTranslator

translateToPlan

字段详细资料

overSpec

protected final OverSpec overSpec

构造器详细资料

BatchExecOverAggregateBase

public BatchExecOverAggregateBase(int id,
                                  ExecNodeContext context,
                                  org.apache.flink.configuration.ReadableConfig persistedConfig,
                                  OverSpec overSpec,
                                  InputProperty inputProperty,
                                  org.apache.flink.table.types.logical.RowType outputType,
                                  String description)

方法详细资料

getInputTypeWithConstants

protected org.apache.flink.table.types.logical.RowType getInputTypeWithConstants()

isUnboundedWindow

protected boolean isUnboundedWindow(OverSpec.GroupSpec group)

isUnboundedPrecedingWindow

protected boolean isUnboundedPrecedingWindow(OverSpec.GroupSpec group)

isUnboundedFollowingWindow

protected boolean isUnboundedFollowingWindow(OverSpec.GroupSpec group)

isSlidingWindow

protected boolean isSlidingWindow(OverSpec.GroupSpec group)

getConstants

protected List<RexLiteral> getConstants()

inferGroupMode

protected BatchExecOverAggregateBase.OverWindowMode inferGroupMode(OverSpec.GroupSpec group)

Infer the over window mode based on given group info.