public class OnUnfinishedKeyPairOperation<L,R,O> extends Object
Constructor and Description |
---|
OnUnfinishedKeyPairOperation(UnfinishedKeyPairOperation<L,R,O> ds) |
Modifier and Type | Method and Description |
---|---|
<K> HalfUnfinishedKeyPairOperation<L,R,O> |
whereClause(scala.Function1<L,K> fun,
TypeInformation<K> evidence$1)
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 OnUnfinishedKeyPairOperation(UnfinishedKeyPairOperation<L,R,O> ds)
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 clauseCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.