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 and Description
static class	JoinOperator.DefaultJoin<I1,I2> A Join transformation that wraps pairs of joining elements into Tuple2.
static class	JoinOperator.EquiJoin<I1,I2,OUT> A Join transformation that applies a JoinFunction on each pair of joining elements.
static class	JoinOperator.ProjectJoin<I1,I2,OUT extends Tuple> A Join transformation that projects joining elements or fields of joining Tuples into result Tuples.

Methods in org.apache.flink.api.java.operators that return JoinOperator

Modifier and Type	Method and Description
<OUT extends 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(Partitioner<?> partitioner) 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 and Description
<R> JoinOperator<I1,I2,R>	JoinFunctionAssigner.with(FlatJoinFunction<I1,I2,R> joinFunction)
<R> JoinOperator<I1,I2,R>	JoinFunctionAssigner.with(JoinFunction<I1,I2,R> joinFunction)