Package | Description |
---|---|
org.apache.flink.api.scala |
Modifier and Type | Method and Description |
---|---|
<O> UnfinishedJoinOperation<T,O> |
DataSet.join(DataSet<O> other)
Creates a new DataSet by joining
this DataSet with the other DataSet. |
<O> UnfinishedJoinOperation<T,O> |
DataSet.join(DataSet<O> other,
JoinOperatorBase.JoinHint strategy)
Special
join operation for explicitly telling the system what join strategy to use. |
<O> UnfinishedJoinOperation<T,O> |
DataSet.joinWithHuge(DataSet<O> other)
Special
join operation for explicitly telling the system that the left side is assumed
to be a lot smaller than the right side of the join. |
<O> UnfinishedJoinOperation<T,O> |
DataSet.joinWithTiny(DataSet<O> other)
Special
join operation for explicitly telling the system that the right side is assumed
to be a lot smaller than the left side of the join. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.