Package | Description |
---|---|
org.apache.flink.api.scala |
Modifier and Type | Method and Description |
---|---|
<O> UnfinishedOuterJoinOperation<T,O> |
DataSet.fullOuterJoin(DataSet<O> other)
Creates a new DataSet by performing a full outer join of
this DataSet
with the other DataSet, by combining two elements of two DataSets on
key equality. |
<O> UnfinishedOuterJoinOperation<T,O> |
DataSet.fullOuterJoin(DataSet<O> other,
JoinOperatorBase.JoinHint strategy)
Special
fullOuterJoin operation for explicitly telling the system what join strategy to
use. |
<O> UnfinishedOuterJoinOperation<T,O> |
DataSet.leftOuterJoin(DataSet<O> other)
An outer join on the left side.
|
<O> UnfinishedOuterJoinOperation<T,O> |
DataSet.leftOuterJoin(DataSet<O> other,
JoinOperatorBase.JoinHint strategy)
An outer join on the left side.
|
<O> UnfinishedOuterJoinOperation<T,O> |
DataSet.rightOuterJoin(DataSet<O> other)
An outer join on the right side.
|
<O> UnfinishedOuterJoinOperation<T,O> |
DataSet.rightOuterJoin(DataSet<O> other,
JoinOperatorBase.JoinHint strategy)
An outer join on the right side.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.