Package | Description |
---|---|
org.apache.flink.api.table.runtime.aggregate |
Constructor and Description |
---|
AggregateMapFunction(Aggregate<?>[] aggregates,
int[] aggFields,
int[] groupingKeys,
TypeInformation<OUT> returnType) |
AggregateReduceCombineFunction(Aggregate<?>[] aggregates,
scala.Tuple2<Object,Object>[] groupKeysMapping,
scala.Tuple2<Object,Object>[] aggregateMapping,
int intermediateRowArity) |
AggregateReduceGroupFunction(Aggregate<?>[] aggregates,
scala.Tuple2<Object,Object>[] groupKeysMapping,
scala.Tuple2<Object,Object>[] aggregateMapping,
int intermediateRowArity) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.