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

类 StreamExecGlobalGroupAggregate

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

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

所有已实现的接口:

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>

@ExecNodeMetadata(name="stream-exec-global-group-aggregate",
                  version=1,
                  consumedOptions={"table.exec.mini-batch.enabled","table.exec.mini-batch.size"},
                  producedTransformations="global-group-aggregate",
                  minPlanVersion=v1_15,
                  minStateVersion=v1_15)
public class StreamExecGlobalGroupAggregate
extends StreamExecAggregateBase

Stream ExecNode for unbounded global group aggregate.

字段概要

字段

限定符和类型	字段和说明
static String	FIELD_NAME_INDEX_OF_COUNT_STAR
static String	FIELD_NAME_LOCAL_AGG_INPUT_ROW_TYPE
static String	GLOBAL_GROUP_AGGREGATE_TRANSFORMATION
protected Integer	indexOfCountStar The position for the existing count star.

从类继承的字段 org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecAggregateBase

FIELD_NAME_AGG_CALL_NEED_RETRACTIONS, FIELD_NAME_AGG_CALLS, FIELD_NAME_GENERATE_UPDATE_BEFORE, FIELD_NAME_GROUPING, 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

构造器概要

构造器

构造器和说明
StreamExecGlobalGroupAggregate(int id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, int[] grouping, org.apache.calcite.rel.core.AggregateCall[] aggCalls, boolean[] aggCallNeedRetractions, org.apache.flink.table.types.logical.RowType localAggInputRowType, boolean generateUpdateBefore, boolean needRetraction, Integer indexOfCountStar, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.RowType outputType, String description)
StreamExecGlobalGroupAggregate(org.apache.flink.configuration.ReadableConfig tableConfig, int[] grouping, org.apache.calcite.rel.core.AggregateCall[] aggCalls, boolean[] aggCallNeedRetractions, org.apache.flink.table.types.logical.RowType localAggInputRowType, boolean generateUpdateBefore, boolean needRetraction, Integer indexOfCountStar, InputProperty inputProperty, org.apache.flink.table.types.logical.RowType outputType, String description)

方法概要

限定符和类型	方法和说明
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config) Internal method, translates this node into a Flink operator.

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

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

字段详细资料

GLOBAL_GROUP_AGGREGATE_TRANSFORMATION

public static final String GLOBAL_GROUP_AGGREGATE_TRANSFORMATION

另请参阅:

常量字段值

FIELD_NAME_LOCAL_AGG_INPUT_ROW_TYPE

public static final String FIELD_NAME_LOCAL_AGG_INPUT_ROW_TYPE

另请参阅:

常量字段值

FIELD_NAME_INDEX_OF_COUNT_STAR

public static final String FIELD_NAME_INDEX_OF_COUNT_STAR

另请参阅:

常量字段值

indexOfCountStar

protected final Integer indexOfCountStar

The position for the existing count star.

构造器详细资料

StreamExecGlobalGroupAggregate

public StreamExecGlobalGroupAggregate(org.apache.flink.configuration.ReadableConfig tableConfig,
                                      int[] grouping,
                                      org.apache.calcite.rel.core.AggregateCall[] aggCalls,
                                      boolean[] aggCallNeedRetractions,
                                      org.apache.flink.table.types.logical.RowType localAggInputRowType,
                                      boolean generateUpdateBefore,
                                      boolean needRetraction,
                                      @Nullable
                                      Integer indexOfCountStar,
                                      InputProperty inputProperty,
                                      org.apache.flink.table.types.logical.RowType outputType,
                                      String description)

StreamExecGlobalGroupAggregate

public StreamExecGlobalGroupAggregate(int id,
                                      ExecNodeContext context,
                                      org.apache.flink.configuration.ReadableConfig persistedConfig,
                                      int[] grouping,
                                      org.apache.calcite.rel.core.AggregateCall[] aggCalls,
                                      boolean[] aggCallNeedRetractions,
                                      org.apache.flink.table.types.logical.RowType localAggInputRowType,
                                      boolean generateUpdateBefore,
                                      boolean needRetraction,
                                      @Nullable
                                      Integer indexOfCountStar,
                                      List<InputProperty> inputProperties,
                                      org.apache.flink.table.types.logical.RowType outputType,
                                      String description)

方法详细资料

translateToPlanInternal

protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
                                                                                                               ExecNodeConfig config)

从类复制的说明: ExecNodeBase

Internal method, translates this node into a Flink operator.

指定者:

translateToPlanInternal 在类中 ExecNodeBase<org.apache.flink.table.data.RowData>

参数:

planner - The planner.

config - per-ExecNode configuration that contains the merged configuration from various layers which all the nodes implementing this method should use, instead of retrieving configuration from the planner. For more details check ExecNodeConfig.