public class AggregateDataSet<T> extends DataSet<T>
DataSet.aggregate
. This can be used to chain more aggregations to the
one aggregate operator.
Constructor and Description |
---|
AggregateDataSet(ScalaAggregateOperator<T> set,
scala.reflect.ClassTag<T> evidence$1) |
Modifier and Type | Method and Description |
---|---|
AggregateDataSet<T> |
and(Aggregations agg,
int field)
Adds the given aggregation on the given field to the previous aggregation operation.
|
AggregateDataSet<T> |
and(Aggregations agg,
String field)
Adds the given aggregation on the given field to the previous aggregation operation.
|
AggregateDataSet<T> |
andMax(int field)
Syntactic sugar for
and with MAX |
AggregateDataSet<T> |
andMax(String field)
Syntactic sugar for
and with MAX |
AggregateDataSet<T> |
andMin(int field)
Syntactic sugar for
and with MIN |
AggregateDataSet<T> |
andMin(String field)
Syntactic sugar for
and with MIN |
AggregateDataSet<T> |
andSum(int field)
Syntactic sugar for
and with SUM |
AggregateDataSet<T> |
andSum(String field)
Syntactic sugar for
and with SUM |
aggregate, aggregate, clean, coGroup, collect, combineGroup, combineGroup, count, cross, crossWithHuge, crossWithTiny, distinct, distinct, distinct, distinct, filter, filter, first, flatMap, flatMap, flatMap, fullOuterJoin, fullOuterJoin, getExecutionEnvironment, getParallelism, getType, groupBy, groupBy, groupBy, iterate, iterateDelta, iterateDelta, iterateDelta, iterateDelta, iterateWithTermination, javaSet, join, join, joinWithHuge, joinWithTiny, leftOuterJoin, leftOuterJoin, map, map, mapPartition, mapPartition, mapPartition, max, max, maxBy, min, min, minBy, name, output, partitionByHash, partitionByHash, partitionByHash, partitionByRange, partitionByRange, partitionByRange, partitionCustom, partitionCustom, partitionCustom, print, print, printOnTaskManager, printToErr, printToErr, rebalance, reduce, reduce, reduceGroup, reduceGroup, reduceGroup, registerAggregator, rightOuterJoin, rightOuterJoin, setParallelism, sortPartition, sortPartition, sortPartition, sum, sum, union, withBroadcastSet, withForwardedFields, withForwardedFieldsFirst, withForwardedFieldsSecond, withParameters, write, writeAsCsv, writeAsText
public AggregateDataSet(ScalaAggregateOperator<T> set, scala.reflect.ClassTag<T> evidence$1)
public AggregateDataSet<T> and(Aggregations agg, int field)
This only works on Tuple DataSets.
public AggregateDataSet<T> and(Aggregations agg, String field)
This only works on CaseClass DataSets.
public AggregateDataSet<T> andSum(int field)
and
with SUM
public AggregateDataSet<T> andMax(int field)
and
with MAX
public AggregateDataSet<T> andMin(int field)
and
with MIN
public AggregateDataSet<T> andSum(String field)
and
with SUM
public AggregateDataSet<T> andMax(String field)
and
with MAX
public AggregateDataSet<T> andMin(String field)
and
with MIN
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.