org.apache.flink.api.scala.extensions.impl.acceptPartialFunctions
Initiates a join or co-group operation, defining the first half of the where clause with the items of the left data set that will be checked for equality with the ones provided by the second half.
Initiates a join or co-group operation, defining the first half of the where clause with the items of the left data set that will be checked for equality with the ones provided by the second half.
The type of the key, for which type information must be known
The function that defines the comparing item of the where clause
A data set of Os
Wraps an unfinished key pair operation, 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
The type of the output data set items