Package | Description |
---|---|
org.apache.flink.api.java | |
org.apache.flink.api.java.operators |
Modifier and Type | Method and Description |
---|---|
AggregateOperator<T> |
DataSet.aggregate(Aggregations agg,
int field)
|
AggregateOperator<T> |
DataSet.max(int field)
Syntactic sugar for
DataSet.aggregate(Aggregations, int) using Aggregations.MAX as
the aggregation function. |
AggregateOperator<T> |
DataSet.min(int field)
Syntactic sugar for
DataSet.aggregate(Aggregations, int) using Aggregations.MIN as
the aggregation function. |
AggregateOperator<T> |
DataSet.sum(int field)
Syntactic sugar for aggregate (SUM, field).
|
Modifier and Type | Method and Description |
---|---|
AggregateOperator<T> |
UnsortedGrouping.aggregate(Aggregations agg,
int field)
|
AggregateOperator<IN> |
AggregateOperator.and(Aggregations function,
int field) |
AggregateOperator<IN> |
AggregateOperator.andMax(int field) |
AggregateOperator<IN> |
AggregateOperator.andMin(int field) |
AggregateOperator<IN> |
AggregateOperator.andSum(int field) |
AggregateOperator<T> |
UnsortedGrouping.max(int field)
Syntactic sugar for aggregate (MAX, field).
|
AggregateOperator<T> |
UnsortedGrouping.min(int field)
Syntactic sugar for aggregate (MIN, field).
|
AggregateOperator<T> |
UnsortedGrouping.sum(int field)
Syntactic sugar for aggregate (SUM, field).
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.