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

类 StreamExecAggregateBase

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.stream.StreamExecAggregateBase

所有已实现的接口:

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

直接已知子类:

StreamExecGlobalGroupAggregate, StreamExecGroupAggregate, StreamExecGroupWindowAggregate, StreamExecIncrementalGroupAggregate, StreamExecLocalGroupAggregate, StreamExecPythonGroupAggregate, StreamExecPythonGroupWindowAggregate, StreamExecWindowAggregateBase

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

The base class for aggregate ExecNode.

字段概要

字段

限定符和类型	字段和说明
static String	FIELD_NAME_AGG_CALL_NEED_RETRACTIONS
static String	FIELD_NAME_AGG_CALLS
static String	FIELD_NAME_GENERATE_UPDATE_BEFORE
static String	FIELD_NAME_GROUPING
static String	FIELD_NAME_NEED_RETRACTION

从接口继承的字段 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

构造器概要

构造器

限定符	构造器和说明
protected	StreamExecAggregateBase(int id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.LogicalType outputType, String description)

方法概要

从类继承的方法 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

字段详细资料

FIELD_NAME_GROUPING

public static final String FIELD_NAME_GROUPING

另请参阅:

常量字段值

FIELD_NAME_AGG_CALLS

public static final String FIELD_NAME_AGG_CALLS

另请参阅:

常量字段值

FIELD_NAME_AGG_CALL_NEED_RETRACTIONS

public static final String FIELD_NAME_AGG_CALL_NEED_RETRACTIONS

另请参阅:

常量字段值

FIELD_NAME_GENERATE_UPDATE_BEFORE

public static final String FIELD_NAME_GENERATE_UPDATE_BEFORE

另请参阅:

常量字段值

FIELD_NAME_NEED_RETRACTION

public static final String FIELD_NAME_NEED_RETRACTION

另请参阅:

常量字段值

构造器详细资料

StreamExecAggregateBase

protected StreamExecAggregateBase(int id,
                                  ExecNodeContext context,
                                  org.apache.flink.configuration.ReadableConfig persistedConfig,
                                  List<InputProperty> inputProperties,
                                  org.apache.flink.table.types.logical.LogicalType outputType,
                                  String description)