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

Class JoinOperatorSetsBase.JoinOperatorSetsPredicateBase

java.lang.Object

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

Direct Known Subclasses:

JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate

Enclosing class:

JoinOperatorSetsBase<I1,I2>

public class JoinOperatorSetsBase.JoinOperatorSetsPredicateBase
extends Object

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

Modifier and Type	Field	Description
protected org.apache.flink.api.common.operators.Keys<I1>	keys1

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	JoinOperatorSetsPredicateBase(org.apache.flink.api.common.operators.Keys<I1> keys1)

Method Summary

Modifier and Type	Method	Description
protected JoinOperator.DefaultJoin<I1,I2>	createDefaultJoin(org.apache.flink.api.common.operators.Keys<I2> keys2)
protected JoinFunctionAssigner<I1,I2>	createJoinFunctionAssigner(org.apache.flink.api.common.operators.Keys<I2> keys2)
JoinFunctionAssigner<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.
JoinFunctionAssigner<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> JoinFunctionAssigner<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 java.lang.Object

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

Field Detail

keys1

protected final org.apache.flink.api.common.operators.Keys<I1> keys1

Constructor Detail

JoinOperatorSetsPredicateBase

protected JoinOperatorSetsPredicateBase(org.apache.flink.api.common.operators.Keys<I1> keys1)

Method Detail

equalTo

public JoinFunctionAssigner<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 JoinFunctionAssigner needs to be finished by providing a JoinFunction by calling JoinFunctionAssigner.with(JoinFunction)

Parameters:

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

Returns:

A JoinFunctionAssigner.

equalTo

public JoinFunctionAssigner<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 JoinFunctionAssigner needs to be finished by providing a JoinFunction by calling JoinFunctionAssigner.with(JoinFunction)

Parameters:

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

Returns:

A JoinFunctionAssigner.

equalTo

public <K> JoinFunctionAssigner<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 JoinFunctionAssigner needs to be finished by providing a JoinFunction by calling JoinFunctionAssigner.with(JoinFunction)

Parameters:

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

Returns:

A JoinFunctionAssigner.

createJoinFunctionAssigner

protected JoinFunctionAssigner<I1,I2> createJoinFunctionAssigner(org.apache.flink.api.common.operators.Keys<I2> keys2)

createDefaultJoin

protected JoinOperator.DefaultJoin<I1,I2> createDefaultJoin(org.apache.flink.api.common.operators.Keys<I2> keys2)