Package | Description |
---|---|
org.apache.flink.api.java.operators |
Modifier and Type | Class and Description |
---|---|
static class |
JoinOperator.DefaultJoin<I1,I2>
A Join transformation that wraps pairs of joining elements into
Tuple2 . |
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. |
<R> JoinOperator.EquiJoin<I1,I2,R> |
JoinOperator.DefaultJoin.with(JoinFunction<I1,I2,R> function) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.