org.apache.flink.api.scala.extensions.impl.acceptPartialFunctions
The wrapped data set
Applies a predicate fun
to each item of the data set, keeping only those for which
the predicate holds
Applies a predicate fun
to each item of the data set, keeping only those for which
the predicate holds
The predicate to be tested on each item
A dataset of R
Applies a function fun
to each item of the dataset, producing a collection of items
that will be flattened in the resulting data set
Applies a function fun
to each item of the dataset, producing a collection of items
that will be flattened in the resulting data set
The type of the items in the returned data set
The function to be applied to each item
A dataset of R
Groups the items according to a grouping function fun
Groups the items according to a grouping function fun
The return type of the grouping function, for which type information must be known
The grouping function
A grouped data set of Ts
Applies a function fun
to a partition as a whole
Applies a function fun
to a partition as a whole
The type of the items in the returned data set
The function to be applied on the whole partition
A dataset of R
Applies a function fun
to each item of the data set
Applies a function fun
to each item of the data set
The type of the items in the returned data set
The function to be applied to each item
A dataset of R
Applies a reducer fun
to a grouped data set
Applies a reducer fun
to a grouped data set
The type of the items in the returned data set
The function to be applied to the whole grouping
A dataset of Rs
Applies a reducer fun
to the data set
Applies a reducer fun
to the data set
The reducing function to be applied on the whole data set
A data set of Rs
Wraps a data set, allowing to use anonymous partial functions to perform extraction of items in a tuple, case class instance or collection
The type of the data set items