Uses of Class
org.apache.flink.api.java.operators.JoinOperator.DefaultJoin
-
Packages that use JoinOperator.DefaultJoin Package Description org.apache.flink.api.java.operators org.apache.flink.api.java.operators.join -
-
Uses of JoinOperator.DefaultJoin in org.apache.flink.api.java.operators
Methods in org.apache.flink.api.java.operators that return JoinOperator.DefaultJoin Modifier and Type Method Description JoinOperator.DefaultJoin<I1,I2>JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate. equalTo(int... fields)Continues a Join transformation and defines theTuplefields of the second joinDataSetthat should be used as join keys.JoinOperator.DefaultJoin<I1,I2>JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate. equalTo(String... fields)Continues a Join transformation and defines the fields of the second joinDataSetthat should be used as join keys.<K> JoinOperator.DefaultJoin<I1,I2>JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate. equalTo(org.apache.flink.api.java.functions.KeySelector<I2,K> keySelector)Continues a Join transformation and defines aKeySelectorfunction for the second joinDataSet. -
Uses of JoinOperator.DefaultJoin in org.apache.flink.api.java.operators.join
Methods in org.apache.flink.api.java.operators.join that return JoinOperator.DefaultJoin Modifier and Type Method Description protected JoinOperator.DefaultJoin<I1,I2>JoinOperatorSetsBase.JoinOperatorSetsPredicateBase. createDefaultJoin(org.apache.flink.api.common.operators.Keys<I2> keys2)
-