org.apache.flink.api.scala.extensions.impl.acceptPartialFunctions
The wrapped co-group data set
Co-groups the data sets using the function fun
to project elements from both in
the resulting data set
Co-groups the data sets using the function fun
to project elements from both in
the resulting data set
The return type of the projection, for which type information must be known
The function that defines the projection of the co-group operation
A fully co-grouped data set of Os
Wraps a co-group 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 left data set items
The type of the right data set items