Package | Description |
---|---|
org.apache.flink.table.runtime.aggregate |
Modifier and Type | Method and Description |
---|---|
static scala.Tuple3<scala.Option<DataSetPreAggFunction>,scala.Option<TypeInformation<Row>>,RichGroupReduceFunction<Row,Row>> |
AggregateUtil.createDataSetAggregateFunctions(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
boolean inGroupingSet)
Create functions to compute a
DataSetAggregate . |
scala.Tuple3<scala.Option<DataSetPreAggFunction>,scala.Option<TypeInformation<Row>>,RichGroupReduceFunction<Row,Row>> |
AggregateUtil$.createDataSetAggregateFunctions(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
boolean inGroupingSet)
Create functions to compute a
DataSetAggregate . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.