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

Class JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate

java.lang.Object

org.apache.flink.api.java.operators.join.JoinOperatorSetsBase.JoinOperatorSetsPredicateBase

org.apache.flink.api.java.operators.JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate

Enclosing class:

JoinOperator.JoinOperatorSets<I1,I2>

@Public
public class JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate
extends JoinOperatorSetsBase.JoinOperatorSetsPredicateBase

Intermediate step of a Join transformation.

To continue the Join transformation, select the join key of the second input DataSet by calling equalTo(int...) or equalTo(KeySelector).

Field Summary

Fields inherited from class org.apache.flink.api.java.operators.join.JoinOperatorSetsBase.JoinOperatorSetsPredicateBase

keys1

Method Summary

Modifier and Type	Method	Description
JoinOperator.DefaultJoin<I1,I2>	equalTo(int... fields)	Continues a Join transformation and defines the Tuple fields of the second join DataSet that should be used as join keys.
JoinOperator.DefaultJoin<I1,I2>	equalTo(String... fields)	Continues a Join transformation and defines the fields of the second join DataSet that should be used as join keys.
<K> JoinOperator.DefaultJoin<I1,I2>	equalTo(org.apache.flink.api.java.functions.KeySelector<I2,K> keySelector)	Continues a Join transformation and defines a KeySelector function for the second join DataSet.

Methods inherited from class org.apache.flink.api.java.operators.join.JoinOperatorSetsBase.JoinOperatorSetsPredicateBase

createDefaultJoin, createJoinFunctionAssigner

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

equalTo

public JoinOperator.DefaultJoin<I1,I2> equalTo(int... fields)

Continues a Join transformation and defines the Tuple fields of the second join DataSet that should be used as join keys.

Note: Fields can only be selected as join keys on Tuple DataSets.

The resulting JoinOperator.DefaultJoin wraps each pair of joining elements into a Tuple2, with the element of the first input being the first field of the tuple and the element of the second input being the second field of the tuple.

Overrides:

equalTo in class JoinOperatorSetsBase.JoinOperatorSetsPredicateBase

Parameters:

fields - The indexes of the Tuple fields of the second join DataSet that should be used as keys.

Returns:

A DefaultJoin that represents the joined DataSet.

equalTo

public JoinOperator.DefaultJoin<I1,I2> equalTo(String... fields)

Continues a Join transformation and defines the fields of the second join DataSet that should be used as join keys.

The resulting JoinOperator.DefaultJoin wraps each pair of joining elements into a Tuple2, with the element of the first input being the first field of the tuple and the element of the second input being the second field of the tuple.

Overrides:

equalTo in class JoinOperatorSetsBase.JoinOperatorSetsPredicateBase

Parameters:

fields - The fields of the second join DataSet that should be used as keys.

Returns:

A DefaultJoin that represents the joined DataSet.

equalTo

public <K> JoinOperator.DefaultJoin<I1,I2> equalTo(org.apache.flink.api.java.functions.KeySelector<I2,K> keySelector)

Continues a Join transformation and defines a KeySelector function for the second join DataSet.

The KeySelector function is called for each element of the second DataSet and extracts a single key value on which the DataSet is joined.

The resulting JoinOperator.DefaultJoin wraps each pair of joining elements into a Tuple2, with the element of the first input being the first field of the tuple and the element of the second input being the second field of the tuple.

Overrides:

equalTo in class JoinOperatorSetsBase.JoinOperatorSetsPredicateBase

Parameters:

keySelector - The KeySelector function which extracts the key values from the second DataSet on which it is joined.

Returns:

A DefaultJoin that represents the joined DataSet.