@ExecNodeMetadata(name="stream-exec-incremental-group-aggregate", version=1, consumedOptions={"table.exec.mini-batch.enabled","table.exec.mini-batch.size"}, producedTransformations="incremental-group-aggregate", minPlanVersion=v1_15, minStateVersion=v1_15) public class StreamExecIncrementalGroupAggregate extends StreamExecAggregateBase
ExecNode
for unbounded incremental group aggregate.Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_FINAL_AGG_GROUPING |
static String |
FIELD_NAME_PARTIAL_AGG_CALL_NEED_RETRACTIONS |
static String |
FIELD_NAME_PARTIAL_AGG_GROUPING |
static String |
FIELD_NAME_PARTIAL_AGG_NEED_RETRACTION |
static String |
FIELD_NAME_PARTIAL_LOCAL_AGG_INPUT_TYPE |
static String |
FIELD_NAME_PARTIAL_ORIGINAL_AGG_CALLS |
static String |
INCREMENTAL_GROUP_AGGREGATE_TRANSFORMATION |
static String |
STATE_NAME |
FIELD_NAME_AGG_CALL_NEED_RETRACTIONS, FIELD_NAME_AGG_CALLS, FIELD_NAME_GENERATE_UPDATE_BEFORE, FIELD_NAME_GROUPING, FIELD_NAME_NEED_RETRACTION
FIELD_NAME_CONFIGURATION, FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE, FIELD_NAME_STATE, FIELD_NAME_TYPE
Constructor and Description |
---|
StreamExecIncrementalGroupAggregate(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
int[] partialAggGrouping,
int[] finalAggGrouping,
org.apache.calcite.rel.core.AggregateCall[] partialOriginalAggCalls,
boolean[] partialAggCallNeedRetractions,
RowType partialLocalAggInputType,
boolean partialAggNeedRetraction,
List<StateMetadata> stateMetadataList,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecIncrementalGroupAggregate(ReadableConfig tableConfig,
int[] partialAggGrouping,
int[] finalAggGrouping,
org.apache.calcite.rel.core.AggregateCall[] partialOriginalAggCalls,
boolean[] partialAggCallNeedRetractions,
RowType partialLocalAggInputType,
boolean partialAggNeedRetraction,
Long stateTtlFromHint,
InputProperty inputProperty,
RowType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
protected Transformation<RowData> |
translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config)
Internal method, translates this node into a Flink operator.
|
accept, createFormattedTransformationDescription, createFormattedTransformationName, createTransformationDescription, createTransformationMeta, createTransformationMeta, createTransformationName, createTransformationUid, getContextFromAnnotation, getDescription, getId, getInputEdges, getInputProperties, getOutputType, getPersistedConfig, getSimplifiedName, getTransformation, inputsContainSingleton, replaceInputEdge, setCompiled, setInputEdges, supportFusionCodegen, translateToFusionCodegenSpec, translateToFusionCodegenSpecInternal, translateToPlan
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setCompiled, setInputEdges
translateToPlan
supportFusionCodegen, translateToFusionCodegenSpec
public static final String INCREMENTAL_GROUP_AGGREGATE_TRANSFORMATION
public static final String FIELD_NAME_PARTIAL_AGG_GROUPING
public static final String FIELD_NAME_FINAL_AGG_GROUPING
public static final String FIELD_NAME_PARTIAL_ORIGINAL_AGG_CALLS
public static final String FIELD_NAME_PARTIAL_AGG_CALL_NEED_RETRACTIONS
public static final String FIELD_NAME_PARTIAL_LOCAL_AGG_INPUT_TYPE
public static final String FIELD_NAME_PARTIAL_AGG_NEED_RETRACTION
public static final String STATE_NAME
public StreamExecIncrementalGroupAggregate(ReadableConfig tableConfig, int[] partialAggGrouping, int[] finalAggGrouping, org.apache.calcite.rel.core.AggregateCall[] partialOriginalAggCalls, boolean[] partialAggCallNeedRetractions, RowType partialLocalAggInputType, boolean partialAggNeedRetraction, @Nullable Long stateTtlFromHint, InputProperty inputProperty, RowType outputType, String description)
public StreamExecIncrementalGroupAggregate(int id, ExecNodeContext context, ReadableConfig persistedConfig, int[] partialAggGrouping, int[] finalAggGrouping, org.apache.calcite.rel.core.AggregateCall[] partialOriginalAggCalls, boolean[] partialAggCallNeedRetractions, RowType partialLocalAggInputType, boolean partialAggNeedRetraction, @Nullable List<StateMetadata> stateMetadataList, List<InputProperty> inputProperties, RowType outputType, String description)
protected Transformation<RowData> translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
ExecNodeBase
translateToPlanInternal
in class ExecNodeBase<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
.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.