Package | Description |
---|---|
org.apache.flink.api.scala | |
org.apache.flink.api.scala.extensions.impl.acceptPartialFunctions |
Modifier and Type | Class and Description |
---|---|
class |
UnfinishedJoinOperationBase<L,R,O extends JoinFunctionAssigner<L,R>> |
Modifier and Type | Class and Description |
---|---|
class |
JoinDataSet<L,R>
A specific
DataSet that results from a join operation. |
Modifier and Type | Method and Description |
---|---|
JoinFunctionAssigner<L,R> |
UnfinishedOuterJoinOperation.createJoinFunctionAssigner(Keys<L> leftKey,
Keys<R> rightKey) |
<K> JoinFunctionAssigner<L,R> |
JoinFunctionAssigner.withPartitioner(Partitioner<K> part,
TypeInformation<K> evidence$19) |
Constructor and Description |
---|
OnJoinFunctionAssigner(JoinFunctionAssigner<L,R> ds) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.