public class UnfinishedOuterJoinOperation<L,R> extends UnfinishedJoinOperationBase<L,R,JoinFunctionAssigner<L,R>>
DataSet.fullOuterJoin()
.
The keys for the left and right side must be specified using first where
and then equalTo
.
Note that a join function must always be specified explicitly when construction an outer join operator.
For example:
val left = ...
val right = ...
val joinResult = left.fullOuterJoin(right).where(...).equalTo(...) {
(first, second) => ...
}
Constructor and Description |
---|
UnfinishedOuterJoinOperation(DataSet<L> leftSet,
DataSet<R> rightSet,
JoinOperatorBase.JoinHint joinHint,
JoinType joinType) |
Modifier and Type | Method and Description |
---|---|
JoinFunctionAssigner<L,R> |
createJoinFunctionAssigner(Keys<L> leftKey,
Keys<R> rightKey) |
createDefaultJoin, finish, joinHint, joinType
leftInput, rightInput, where, where, where
public JoinFunctionAssigner<L,R> createJoinFunctionAssigner(Keys<L> leftKey, Keys<R> rightKey)
createJoinFunctionAssigner
in class UnfinishedJoinOperationBase<L,R,JoinFunctionAssigner<L,R>>
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.