public class OnDataSet<T> extends Object
Modifier and Type | Method and Description |
---|---|
DataSet<T> |
filterWith(scala.Function1<T,Object> fun)
Applies a predicate
fun to each item of the data set, keeping only those for which
the predicate holds |
<R> DataSet<R> |
flatMapWith(scala.Function1<T,scala.collection.TraversableOnce<R>> fun,
TypeInformation<R> evidence$5,
scala.reflect.ClassTag<R> evidence$6)
Applies a function
fun to each item of the dataset, producing a collection of items
that will be flattened in the resulting data set |
<K> GroupedDataSet<T> |
groupingBy(scala.Function1<T,K> fun,
TypeInformation<K> evidence$9)
Groups the items according to a grouping function
fun |
<R> DataSet<R> |
mapPartitionWith(scala.Function1<scala.collection.immutable.Stream<T>,R> fun,
TypeInformation<R> evidence$3,
scala.reflect.ClassTag<R> evidence$4)
Applies a function
fun to a partition as a whole |
<R> DataSet<R> |
mapWith(scala.Function1<T,R> fun,
TypeInformation<R> evidence$1,
scala.reflect.ClassTag<R> evidence$2)
Applies a function
fun to each item of the data set |
<R> DataSet<R> |
reduceGroupWith(scala.Function1<scala.collection.immutable.Stream<T>,R> fun,
TypeInformation<R> evidence$7,
scala.reflect.ClassTag<R> evidence$8)
Applies a reducer
fun to a grouped data set |
DataSet<T> |
reduceWith(scala.Function2<T,T,T> fun)
Applies a reducer
fun to the data set |
public <R> DataSet<R> mapWith(scala.Function1<T,R> fun, TypeInformation<R> evidence$1, scala.reflect.ClassTag<R> evidence$2)
fun
to each item of the data set
fun
- The function to be applied to each itempublic <R> DataSet<R> mapPartitionWith(scala.Function1<scala.collection.immutable.Stream<T>,R> fun, TypeInformation<R> evidence$3, scala.reflect.ClassTag<R> evidence$4)
fun
to a partition as a whole
fun
- The function to be applied on the whole partitionpublic <R> DataSet<R> flatMapWith(scala.Function1<T,scala.collection.TraversableOnce<R>> fun, TypeInformation<R> evidence$5, scala.reflect.ClassTag<R> evidence$6)
fun
to each item of the dataset, producing a collection of items
that will be flattened in the resulting data set
fun
- The function to be applied to each itempublic DataSet<T> filterWith(scala.Function1<T,Object> fun)
fun
to each item of the data set, keeping only those for which
the predicate holds
fun
- The predicate to be tested on each itempublic DataSet<T> reduceWith(scala.Function2<T,T,T> fun)
fun
to the data set
fun
- The reducing function to be applied on the whole data setpublic <R> DataSet<R> reduceGroupWith(scala.Function1<scala.collection.immutable.Stream<T>,R> fun, TypeInformation<R> evidence$7, scala.reflect.ClassTag<R> evidence$8)
fun
to a grouped data set
fun
- The function to be applied to the whole groupingpublic <K> GroupedDataSet<T> groupingBy(scala.Function1<T,K> fun, TypeInformation<K> evidence$9)
fun
fun
- The grouping functionCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.