public class StreamExecGroupWindowAggregate extends StreamExecAggregateBase
ExecNode
for either group window aggregate or group window table aggregate.
The differences between StreamExecWindowAggregate
and StreamExecGroupWindowAggregate
is that, this node is translated from window TVF syntax, but the
* other is from the legacy GROUP WINDOW FUNCTION syntax. In the long future, StreamExecGroupWindowAggregate
will be dropped.
Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_NAMED_WINDOW_PROPERTIES |
static String |
FIELD_NAME_WINDOW |
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 |
---|
StreamExecGroupWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
org.apache.flink.table.planner.plan.logical.LogicalWindow window,
PlannerNamedWindowProperty[] namedWindowProperties,
boolean needRetraction,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecGroupWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
org.apache.flink.table.planner.plan.logical.LogicalWindow window,
PlannerNamedWindowProperty[] namedWindowProperties,
boolean needRetraction,
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_WINDOW
public static final String FIELD_NAME_NAMED_WINDOW_PROPERTIES
public StreamExecGroupWindowAggregate(int[] grouping, org.apache.calcite.rel.core.AggregateCall[] aggCalls, org.apache.flink.table.planner.plan.logical.LogicalWindow window, PlannerNamedWindowProperty[] namedWindowProperties, boolean needRetraction, InputProperty inputProperty, RowType outputType, String description)
public StreamExecGroupWindowAggregate(int[] grouping, org.apache.calcite.rel.core.AggregateCall[] aggCalls, org.apache.flink.table.planner.plan.logical.LogicalWindow window, PlannerNamedWindowProperty[] namedWindowProperties, boolean needRetraction, 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.