public abstract class UnfinishedKeyPairOperation<L,R,O> extends Object
finish
to
create the actual operation using the provided keys.
This way, we have a central point where all the key-providing happens and don't need to change the specific operations if the supported key types change.
We use the type parameter O
to specify the type of the resulting operation. For join
this would be JoinDataSet[L, R]
and for coGroup it would be CoGroupDataSet[L, R]
. This
way the user gets the correct type for the finished operation.
Constructor and Description |
---|
UnfinishedKeyPairOperation(DataSet<L> leftInput,
DataSet<R> rightInput) |
Modifier and Type | Method and Description |
---|---|
abstract O |
finish(Keys<L> leftKey,
Keys<R> rightKey) |
DataSet<L> |
leftInput() |
DataSet<R> |
rightInput() |
<K> HalfUnfinishedKeyPairOperation<L,R,O> |
where(scala.Function1<L,K> fun,
TypeInformation<K> evidence$1)
Specify the key selector function for the left side of the key based operation.
|
HalfUnfinishedKeyPairOperation<L,R,O> |
where(scala.collection.Seq<Object> leftKeys)
Specify the key fields for the left side of the key based operation.
|
HalfUnfinishedKeyPairOperation<L,R,O> |
where(String firstLeftField,
scala.collection.Seq<String> otherLeftFields)
Specify the key fields for the left side of the key based operation.
|
public HalfUnfinishedKeyPairOperation<L,R,O> where(scala.collection.Seq<Object> leftKeys)
HalfUnfinishedKeyPairOperation
on which equalTo
must be called to specify the
key for the right side. The result after specifying the right side key is the finished
operation.
This only works on Tuple DataSet
.
public HalfUnfinishedKeyPairOperation<L,R,O> where(String firstLeftField, scala.collection.Seq<String> otherLeftFields)
HalfUnfinishedKeyPairOperation
on which equalTo
must be called to specify the
key for the right side. The result after specifying the right side key is the finished
operation.public <K> HalfUnfinishedKeyPairOperation<L,R,O> where(scala.Function1<L,K> fun, TypeInformation<K> evidence$1)
HalfUnfinishedKeyPairOperation
on which equalTo
must be called to specify the
key for the right side. The result after specifying the right side key is the finished
operation.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.