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

Class JoinOperator.JoinOperatorSets<I1,I2>

java.lang.Object

org.apache.flink.api.java.operators.join.JoinOperatorSetsBase<I1,I2>

org.apache.flink.api.java.operators.JoinOperator.JoinOperatorSets<I1,I2>

Type Parameters:

I1 - The type of the first input DataSet of the Join transformation.

I2 - The type of the second input DataSet of the Join transformation.

Enclosing class:

JoinOperator<I1,I2,OUT>

@Public
public static final class JoinOperator.JoinOperatorSets<I1,I2>
extends JoinOperatorSetsBase<I1,I2>

Intermediate step of a Join transformation.

To continue the Join transformation, select the join key of the first input DataSet by calling where(int...) or where(org.apache.flink.api.java.functions.KeySelector).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate	Intermediate step of a Join transformation.

Nested classes/interfaces inherited from class org.apache.flink.api.java.operators.join.JoinOperatorSetsBase

JoinOperatorSetsBase.JoinOperatorSetsPredicateBase

Field Summary

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

input1, input2, joinHint, joinType

Constructor Summary

Constructors

Constructor	Description
JoinOperatorSets(DataSet<I1> input1, DataSet<I2> input2)
JoinOperatorSets(DataSet<I1> input1, DataSet<I2> input2, org.apache.flink.api.common.operators.base.JoinOperatorBase.JoinHint hint)

Method Summary

Modifier and Type	Method	Description
JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate	where(int... fields)	Continues a Join transformation.
JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate	where(String... fields)	Continues a Join transformation.
<K> JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate	where(org.apache.flink.api.java.functions.KeySelector<I1,K> keySelector)	Continues a Join transformation and defines a KeySelector function for the first join DataSet.

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinOperatorSets

public JoinOperatorSets(DataSet<I1> input1,
                        DataSet<I2> input2)

JoinOperatorSets

public JoinOperatorSets(DataSet<I1> input1,
                        DataSet<I2> input2,
                        org.apache.flink.api.common.operators.base.JoinOperatorBase.JoinHint hint)

Method Detail

where

public JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate where(int... fields)

Continues a Join transformation.

Defines the Tuple fields of the first join DataSet that should be used as join keys.

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

Overrides:

where in class JoinOperatorSetsBase<I1,I2>

Parameters:

fields - The indexes of the other Tuple fields of the first join DataSets that should be used as keys.

Returns:

An incomplete Join transformation. Call JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate.equalTo(int...) or JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate.equalTo(KeySelector) to continue the Join.

See Also:

Tuple, DataSet

where

public JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate where(String... fields)

Continues a Join transformation.

Defines the fields of the first join DataSet that should be used as grouping keys. Fields are the names of member fields of the underlying type of the data set.

Overrides:

where in class JoinOperatorSetsBase<I1,I2>

Parameters:

fields - The fields of the first join DataSets that should be used as keys.

Returns:

An incomplete Join transformation. Call JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate.equalTo(int...) or JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate.equalTo(KeySelector) to continue the Join.

See Also:

Tuple, DataSet

where

public <K> JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate where(org.apache.flink.api.java.functions.KeySelector<I1,K> keySelector)

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

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

Overrides:

where in class JoinOperatorSetsBase<I1,I2>

Parameters:

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

Returns:

An incomplete Join transformation. Call JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate.equalTo(int...) or JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate.equalTo(KeySelector) to continue the Join.

See Also:

KeySelector, DataSet