Package | Description |
---|---|
org.apache.flink.api.scala |
Modifier and Type | Method and Description |
---|---|
AggregateDataSet<T> |
GroupedDataSet.aggregate(Aggregations agg,
int field)
Creates a new
DataSet by aggregating the specified field using the given aggregation
function. |
static AggregateDataSet<T> |
CrossDataSet.aggregate(Aggregations agg,
int field) |
AggregateDataSet<T> |
DataSet.aggregate(Aggregations agg,
int field)
Creates a new
DataSet by aggregating the specified tuple field using the given aggregation
function. |
AggregateDataSet<T> |
GroupedDataSet.aggregate(Aggregations agg,
String field)
Creates a new
DataSet by aggregating the specified tuple field using the given aggregation
function. |
static AggregateDataSet<T> |
CrossDataSet.aggregate(Aggregations agg,
String field) |
AggregateDataSet<T> |
DataSet.aggregate(Aggregations agg,
String field)
Creates a new
DataSet by aggregating the specified field using the given aggregation
function. |
AggregateDataSet<T> |
AggregateDataSet.and(Aggregations agg,
int field)
Adds the given aggregation on the given field to the previous aggregation operation.
|
AggregateDataSet<T> |
AggregateDataSet.and(Aggregations agg,
String field)
Adds the given aggregation on the given field to the previous aggregation operation.
|
AggregateDataSet<T> |
AggregateDataSet.andMax(int field)
Syntactic sugar for
and with MAX |
AggregateDataSet<T> |
AggregateDataSet.andMax(String field)
Syntactic sugar for
and with MAX |
AggregateDataSet<T> |
AggregateDataSet.andMin(int field)
Syntactic sugar for
and with MIN |
AggregateDataSet<T> |
AggregateDataSet.andMin(String field)
Syntactic sugar for
and with MIN |
AggregateDataSet<T> |
AggregateDataSet.andSum(int field)
Syntactic sugar for
and with SUM |
AggregateDataSet<T> |
AggregateDataSet.andSum(String field)
Syntactic sugar for
and with SUM |
AggregateDataSet<T> |
GroupedDataSet.max(int field)
Syntactic sugar for
aggregate with MAX |
static AggregateDataSet<T> |
CrossDataSet.max(int field) |
AggregateDataSet<T> |
DataSet.max(int field)
Syntactic sugar for
aggregate with MAX |
AggregateDataSet<T> |
GroupedDataSet.max(String field)
Syntactic sugar for
aggregate with MAX |
static AggregateDataSet<T> |
CrossDataSet.max(String field) |
AggregateDataSet<T> |
DataSet.max(String field)
Syntactic sugar for
aggregate with MAX |
AggregateDataSet<T> |
GroupedDataSet.min(int field)
Syntactic sugar for
aggregate with MIN |
static AggregateDataSet<T> |
CrossDataSet.min(int field) |
AggregateDataSet<T> |
DataSet.min(int field)
Syntactic sugar for
aggregate with MIN |
AggregateDataSet<T> |
GroupedDataSet.min(String field)
Syntactic sugar for
aggregate with MIN |
static AggregateDataSet<T> |
CrossDataSet.min(String field) |
AggregateDataSet<T> |
DataSet.min(String field)
Syntactic sugar for
aggregate with MIN |
AggregateDataSet<T> |
GroupedDataSet.sum(int field)
Syntactic sugar for
aggregate with SUM |
static AggregateDataSet<T> |
CrossDataSet.sum(int field) |
AggregateDataSet<T> |
DataSet.sum(int field)
Syntactic sugar for
aggregate with SUM |
AggregateDataSet<T> |
GroupedDataSet.sum(String field)
Syntactic sugar for
aggregate with SUM |
static AggregateDataSet<T> |
CrossDataSet.sum(String field) |
AggregateDataSet<T> |
DataSet.sum(String field)
Syntactic sugar for
aggregate with SUM |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.