Package | Description |
---|---|
org.apache.flink.api.scala |
Modifier and Type | Method and Description |
---|---|
JoinDataSet<L,R> |
UnfinishedJoinOperationBase.createDefaultJoin(Keys<L> leftKey,
Keys<R> rightKey) |
JoinDataSet<L,R> |
UnfinishedJoinOperation.createJoinFunctionAssigner(Keys<L> leftKey,
Keys<R> rightKey) |
<K> JoinDataSet<L,R> |
JoinDataSet.withPartitioner(Partitioner<K> partitioner,
TypeInformation<K> evidence$9) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.