public class UnfinishedJoinOperation<L,R> extends UnfinishedJoinOperationBase<L,R,JoinDataSet<L,R>>
DataSet.join()
.
The keys for the left and right side must be specified using first where
and then equalTo
.
For example:
val left = ...
val right = ...
val joinResult = left.join(right).where(...).equalTo(...)
Constructor and Description |
---|
UnfinishedJoinOperation(DataSet<L> leftSet,
DataSet<R> rightSet,
JoinOperatorBase.JoinHint joinHint) |
Modifier and Type | Method and Description |
---|---|
JoinDataSet<L,R> |
createJoinFunctionAssigner(Keys<L> leftKey,
Keys<R> rightKey) |
createDefaultJoin, finish, joinHint, joinType
leftInput, rightInput, where, where, where
public UnfinishedJoinOperation(DataSet<L> leftSet, DataSet<R> rightSet, JoinOperatorBase.JoinHint joinHint)
public JoinDataSet<L,R> createJoinFunctionAssigner(Keys<L> leftKey, Keys<R> rightKey)
createJoinFunctionAssigner
in class UnfinishedJoinOperationBase<L,R,JoinDataSet<L,R>>
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.