Package | Description |
---|---|
org.apache.flink.api.java.operators | |
org.apache.flink.api.scala |
Modifier and Type | Class and Description |
---|---|
static class |
JoinOperator.DefaultJoin<I1,I2>
|
static class |
JoinOperator.ProjectJoin<I1,I2,OUT extends Tuple>
|
Modifier and Type | Method and Description |
---|---|
<R> JoinOperator.EquiJoin<I1,I2,R> |
JoinOperator.DefaultJoin.with(FlatJoinFunction<I1,I2,R> function)
Finalizes a Join transformation by applying a
RichFlatJoinFunction to each pair of joined elements.Each JoinFunction call returns exactly one element. |
<R> JoinOperator.EquiJoin<I1,I2,R> |
JoinOperator.DefaultJoin.with(JoinFunction<I1,I2,R> function) |
Constructor and Description |
---|
JoinDataSet(JoinOperator.EquiJoin<L,R,scala.Tuple2<L,R>> defaultJoin,
DataSet<L> leftInput,
DataSet<R> rightInput,
Keys<L> leftKeys,
Keys<R> rightKeys) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.