Uses of Interface
org.apache.flink.api.java.operators.join.JoinFunctionAssigner

Packages that use JoinFunctionAssigner

Package	Description
org.apache.flink.api.java.operators
org.apache.flink.api.java.operators.join

Uses of JoinFunctionAssigner in org.apache.flink.api.java.operators

Classes in org.apache.flink.api.java.operators that implement JoinFunctionAssigner

Modifier and Type	Class and Description
static class	JoinOperator.DefaultJoin<I1,I2> A Join transformation that wraps pairs of joining elements into Tuple2.

Uses of JoinFunctionAssigner in org.apache.flink.api.java.operators.join

Methods in org.apache.flink.api.java.operators.join that return JoinFunctionAssigner

Modifier and Type	Method and Description
protected JoinFunctionAssigner<I1,I2>	JoinOperatorSetsBase.JoinOperatorSetsPredicateBase.createJoinFunctionAssigner(Keys<I2> keys2)
JoinFunctionAssigner<I1,I2>	JoinOperatorSetsBase.JoinOperatorSetsPredicateBase.equalTo(int... fields) Continues a Join transformation and defines the Tuple fields of the second join DataSet that should be used as join keys.
<K> JoinFunctionAssigner<I1,I2>	JoinOperatorSetsBase.JoinOperatorSetsPredicateBase.equalTo(KeySelector<I2,K> keySelector) Continues a Join transformation and defines a KeySelector function for the second join DataSet.
JoinFunctionAssigner<I1,I2>	JoinOperatorSetsBase.JoinOperatorSetsPredicateBase.equalTo(String... fields) Continues a Join transformation and defines the fields of the second join DataSet that should be used as join keys.