public class OnUnfinishedKeyPairOperation<L,R,O> extends Object
|Constructor and Description|
|Modifier and Type||Method and Description|
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.
public <K> HalfUnfinishedKeyPairOperation<L,R,O> whereClause(scala.Function1<L,K> fun, TypeInformation<K> evidence$1)
fun- The function that defines the comparing item of the where clause
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.