public class OnGroupedDataSet<T> extends Object
param: ds The wrapped grouped data set
Constructor and Description |
---|
OnGroupedDataSet(GroupedDataSet<T> ds) |
Modifier and Type | Method and Description |
---|---|
<R> DataSet<R> |
combineGroupWith(scala.Function1<scala.collection.immutable.Stream<T>,R> fun,
TypeInformation<R> evidence$4,
scala.reflect.ClassTag<R> evidence$5)
Same as a reducing operation but only acts locally,
ideal to perform pre-aggregation before a reduction.
|
<R> DataSet<R> |
reduceGroupWith(scala.Function1<scala.collection.immutable.Stream<T>,R> fun,
TypeInformation<R> evidence$2,
scala.reflect.ClassTag<R> evidence$3)
Reduces the data set group-wise with a reducer
fun |
DataSet<T> |
reduceWith(scala.Function2<T,T,T> fun)
Reduces the whole data set with a reducer
fun |
<K> GroupedDataSet<T> |
sortGroupWith(Order order,
scala.Function1<T,K> fun,
TypeInformation<K> evidence$1)
Sorts a group using a sorting function
fun and an Order |
public OnGroupedDataSet(GroupedDataSet<T> ds)
public <K> GroupedDataSet<T> sortGroupWith(Order order, scala.Function1<T,K> fun, TypeInformation<K> evidence$1)
fun
and an Order
fun
- The sorting function, defining the sorting keyorder
- The ordering strategy (ascending, descending, etc.)evidence$1
- (undocumented)public DataSet<T> reduceWith(scala.Function2<T,T,T> fun)
fun
fun
- The reducing functionpublic <R> DataSet<R> reduceGroupWith(scala.Function1<scala.collection.immutable.Stream<T>,R> fun, TypeInformation<R> evidence$2, scala.reflect.ClassTag<R> evidence$3)
fun
fun
- The reducing functionevidence$2
- (undocumented)evidence$3
- (undocumented)public <R> DataSet<R> combineGroupWith(scala.Function1<scala.collection.immutable.Stream<T>,R> fun, TypeInformation<R> evidence$4, scala.reflect.ClassTag<R> evidence$5)
fun
- The reducing functionevidence$4
- (undocumented)evidence$5
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.