public class StreamExecGlobalGroupAggregate extends StreamExecAggregateBase
ExecNode
for unbounded global group aggregate.Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_INDEX_OF_COUNT_STAR |
static String |
FIELD_NAME_LOCAL_AGG_INPUT_ROW_TYPE |
protected Integer |
indexOfCountStar
The position for the existing count star.
|
FIELD_NAME_AGG_CALL_NEED_RETRACTIONS, FIELD_NAME_AGG_CALLS, FIELD_NAME_GENERATE_UPDATE_BEFORE, FIELD_NAME_GROUPING, FIELD_NAME_NEED_RETRACTION
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and Description |
---|
StreamExecGlobalGroupAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
RowType localAggInputRowType,
boolean generateUpdateBefore,
boolean needRetraction,
Integer indexOfCountStar,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecGlobalGroupAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
boolean[] aggCallNeedRetractions,
RowType localAggInputRowType,
boolean generateUpdateBefore,
boolean needRetraction,
Integer indexOfCountStar,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
protected Transformation<RowData> |
translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
Internal method, translates this node into a Flink operator.
|
accept, getDescription, getId, getInputEdges, getInputProperties, getNewNodeId, getOutputType, inputsContainSingleton, replaceInputEdge, resetIdCounter, setInputEdges, translateToPlan
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setInputEdges
translateToPlan
public static final String FIELD_NAME_LOCAL_AGG_INPUT_ROW_TYPE
public static final String FIELD_NAME_INDEX_OF_COUNT_STAR
protected final Integer indexOfCountStar
public StreamExecGlobalGroupAggregate(int[] grouping, org.apache.calcite.rel.core.AggregateCall[] aggCalls, boolean[] aggCallNeedRetractions, RowType localAggInputRowType, boolean generateUpdateBefore, boolean needRetraction, @Nullable Integer indexOfCountStar, InputProperty inputProperty, RowType outputType, String description)
public StreamExecGlobalGroupAggregate(int[] grouping, org.apache.calcite.rel.core.AggregateCall[] aggCalls, boolean[] aggCallNeedRetractions, RowType localAggInputRowType, boolean generateUpdateBefore, boolean needRetraction, @Nullable Integer indexOfCountStar, int id, List<InputProperty> inputProperties, RowType outputType, String description)
protected Transformation<RowData> translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
ExecNodeBase
translateToPlanInternal
in class ExecNodeBase<RowData>
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.