org.apache.flink.api.scala.extensions.impl.acceptPartialFunctions
The wrapped grouped data set
Same as a reducing operation but only acts locally, ideal to perform pre-aggregation before a reduction.
Same as a reducing operation but only acts locally, ideal to perform pre-aggregation before a reduction.
The type of the items in the resulting data set
The reducing function
A data set of Rs reduced group-wise
Reduces the data set group-wise with a reducer fun
Reduces the data set group-wise with a reducer fun
The type of the items in the resulting data set
The reducing function
A data set of Rs reduced group-wise
Reduces the whole data set with a reducer fun
Reduces the whole data set with a reducer fun
The reducing function
A reduced data set of Ts
Sorts a group using a sorting function fun
and an Order
Sorts a group using a sorting function fun
and an Order
The key type
The ordering strategy (ascending, descending, etc.)
The sorting function, defining the sorting key
A data set sorted group-wise
Wraps a grouped 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 grouped data set items