public class OnUnfinishedKeyPairOperation<L,R,O> extends Object
param: ds The wrapped unfinished key pair operation data set
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 clauseevidence$1
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.