public class StreamExecGlobalWindowAggregate extends StreamExecWindowAggregateBase
ExecNode
for window table-valued based global aggregate.Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_LOCAL_AGG_INPUT_ROW_TYPE |
FIELD_NAME_NAMED_WINDOW_PROPERTIES, FIELD_NAME_WINDOWING, WINDOW_AGG_MEMORY_RATIO
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 |
---|
StreamExecGlobalWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
PlannerNamedWindowProperty[] namedWindowProperties,
InputProperty inputProperty,
RowType localAggInputRowType,
RowType outputType,
String description) |
StreamExecGlobalWindowAggregate(int[] grouping,
org.apache.calcite.rel.core.AggregateCall[] aggCalls,
WindowingStrategy windowing,
PlannerNamedWindowProperty[] namedWindowProperties,
int id,
List<InputProperty> inputProperties,
RowType localAggInputRowType,
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.
|
convertToLogicalTypes, createSliceAssigner, createSliceAssigner
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 StreamExecGlobalWindowAggregate(int[] grouping, org.apache.calcite.rel.core.AggregateCall[] aggCalls, WindowingStrategy windowing, PlannerNamedWindowProperty[] namedWindowProperties, InputProperty inputProperty, RowType localAggInputRowType, RowType outputType, String description)
public StreamExecGlobalWindowAggregate(int[] grouping, org.apache.calcite.rel.core.AggregateCall[] aggCalls, WindowingStrategy windowing, PlannerNamedWindowProperty[] namedWindowProperties, int id, List<InputProperty> inputProperties, RowType localAggInputRowType, 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.