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,
int finalRowArity) |
AggregateReduceGroupFunction(Aggregate<?>[] aggregates,
scala.Tuple2<Object,Object>[] groupKeysMapping,
scala.Tuple2<Object,Object>[] aggregateMapping,
int intermediateRowArity,
int finalRowArity) |
IncrementalAggregateAllTimeWindowFunction(Aggregate<?>[] aggregates,
scala.Tuple2<Object,Object>[] groupKeysMapping,
scala.Tuple2<Object,Object>[] aggregateMapping,
int finalRowArity,
scala.Option<Object> windowStartPos,
scala.Option<Object> windowEndPos) |
IncrementalAggregateAllWindowFunction(Aggregate<?>[] aggregates,
scala.Tuple2<Object,Object>[] groupKeysMapping,
scala.Tuple2<Object,Object>[] aggregateMapping,
int finalRowArity) |
IncrementalAggregateReduceFunction(Aggregate<?>[] aggregates,
scala.Tuple2<Object,Object>[] groupKeysMapping,
int intermediateRowArity) |
IncrementalAggregateTimeWindowFunction(Aggregate<?>[] aggregates,
scala.Tuple2<Object,Object>[] groupKeysMapping,
scala.Tuple2<Object,Object>[] aggregateMapping,
int finalRowArity,
scala.Option<Object> windowStartPos,
scala.Option<Object> windowEndPos) |
IncrementalAggregateWindowFunction(Aggregate<?>[] aggregates,
scala.Tuple2<Object,Object>[] groupKeysMapping,
scala.Tuple2<Object,Object>[] aggregateMapping,
int finalRowArity) |