Class StreamExecGroupTableAggregate

    • Constructor Detail

      • StreamExecGroupTableAggregate

        public StreamExecGroupTableAggregate​(ReadableConfig tableConfig,
                                             int[] grouping,
                                             org.apache.calcite.rel.core.AggregateCall[] aggCalls,
                                             boolean[] aggCallNeedRetractions,
                                             boolean generateUpdateBefore,
                                             boolean needRetraction,
                                             InputProperty inputProperty,
                                             RowType outputType,
                                             String description)
    • Method Detail

      • translateToPlanInternal

        protected Transformation<RowData> translateToPlanInternal​(org.apache.flink.table.planner.delegation.PlannerBase planner,
                                                                  ExecNodeConfig config)
        Description copied from class: ExecNodeBase
        Internal method, translates this node into a Flink operator.
        Specified by:
        translateToPlanInternal in class ExecNodeBase<RowData>
        Parameters:
        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.