Uses of Class
org.apache.flink.api.java.operators.JoinOperator
-
Packages that use JoinOperator Package Description org.apache.flink.api.java.operators org.apache.flink.api.java.operators.join -
-
Uses of JoinOperator in org.apache.flink.api.java.operators
Subclasses of JoinOperator in org.apache.flink.api.java.operators Modifier and Type Class Description static classJoinOperator.DefaultJoin<I1,I2>Deprecated.A Join transformation that wraps pairs of joining elements intoTuple2.static classJoinOperator.EquiJoin<I1,I2,OUT>Deprecated.A Join transformation that applies aJoinFunctionon each pair of joining elements.static classJoinOperator.ProjectJoin<I1,I2,OUT extends org.apache.flink.api.java.tuple.Tuple>Deprecated.A Join transformation that projects joining elements or fields of joiningTuplesinto resultTuples.Methods in org.apache.flink.api.java.operators that return JoinOperator Modifier and Type Method Description <OUT extends org.apache.flink.api.java.tuple.Tuple>
JoinOperator<I1,I2,OUT>JoinOperator.ProjectJoin. types(Class<?>... types)Deprecated.Deprecated method only kept for compatibility.JoinOperator<I1,I2,OUT>JoinOperator.ProjectJoin. withForwardedFieldsFirst(String... forwardedFieldsFirst)JoinOperator<I1,I2,OUT>JoinOperator.ProjectJoin. withForwardedFieldsSecond(String... forwardedFieldsSecond)JoinOperator<I1,I2,OUT>JoinOperator. withPartitioner(org.apache.flink.api.common.functions.Partitioner<?> partitioner)Deprecated.Sets a custom partitioner for this join. -
Uses of JoinOperator in org.apache.flink.api.java.operators.join
Methods in org.apache.flink.api.java.operators.join that return JoinOperator Modifier and Type Method Description <R> JoinOperator<I1,I2,R>JoinFunctionAssigner. with(org.apache.flink.api.common.functions.FlatJoinFunction<I1,I2,R> joinFunction)Deprecated.<R> JoinOperator<I1,I2,R>JoinFunctionAssigner. with(org.apache.flink.api.common.functions.JoinFunction<I1,I2,R> joinFunction)Deprecated.
-