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

Class JoinOperatorSetsBase<I1,I2>

java.lang.Object

org.apache.flink.api.java.operators.join.JoinOperatorSetsBase<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.

Direct Known Subclasses:

JoinOperator.JoinOperatorSets

@Public
public class JoinOperatorSetsBase<I1,I2>
extends Object

Intermediate step of an Outer Join transformation.
To continue the Join transformation, select the join key of the first input DataSet by calling where(int...) or where(KeySelector).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	JoinOperatorSetsBase.JoinOperatorSetsPredicateBase Intermediate step of a Join transformation.

Field Summary

Fields

Modifier and Type	Field and Description
protected DataSet<I1>	input1
protected DataSet<I2>	input2
protected JoinOperatorBase.JoinHint	joinHint
protected JoinType	joinType

Constructor Summary

Constructors

Constructor and Description
JoinOperatorSetsBase(DataSet<I1> input1, DataSet<I2> input2)
JoinOperatorSetsBase(DataSet<I1> input1, DataSet<I2> input2, JoinOperatorBase.JoinHint hint)
JoinOperatorSetsBase(DataSet<I1> input1, DataSet<I2> input2, JoinOperatorBase.JoinHint hint, JoinType type)

Method Summary

Modifier and Type	Method and Description
JoinOperatorSetsBase.JoinOperatorSetsPredicateBase	where(int... fields) Continues a Join transformation.
<K> JoinOperatorSetsBase.JoinOperatorSetsPredicateBase	where(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.
JoinOperatorSetsBase.JoinOperatorSetsPredicateBase	where(String... fields) Continues a Join transformation.

Methods inherited from class java.lang.Object

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

Field Detail

input1

protected final DataSet<I1> input1

input2

protected final DataSet<I2> input2

joinHint

protected final JoinOperatorBase.JoinHint joinHint

joinType

protected final JoinType joinType

Constructor Detail

JoinOperatorSetsBase

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

JoinOperatorSetsBase

public JoinOperatorSetsBase(DataSet<I1> input1,
                            DataSet<I2> input2,
                            JoinOperatorBase.JoinHint hint)

JoinOperatorSetsBase

public JoinOperatorSetsBase(DataSet<I1> input1,
                            DataSet<I2> input2,
                            JoinOperatorBase.JoinHint hint,
                            JoinType type)

Method Detail

where

public JoinOperatorSetsBase.JoinOperatorSetsPredicateBase 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.

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 JoinOperatorSetsBase.JoinOperatorSetsPredicateBase.equalTo(int...) or JoinOperatorSetsBase.JoinOperatorSetsPredicateBase.equalTo(KeySelector) to continue the Join.

See Also:

Tuple, DataSet

where

public JoinOperatorSetsBase.JoinOperatorSetsPredicateBase 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.

Parameters:

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

Returns:

An incomplete Join transformation. Call JoinOperatorSetsBase.JoinOperatorSetsPredicateBase.equalTo(int...) or JoinOperatorSetsBase.JoinOperatorSetsPredicateBase.equalTo(KeySelector) to continue the Join.

See Also:

Tuple, DataSet

where

public <K> JoinOperatorSetsBase.JoinOperatorSetsPredicateBase where(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.

Parameters:

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

Returns:

An incomplete Join transformation. Call JoinOperatorSetsBase.JoinOperatorSetsPredicateBase.equalTo(int...) or JoinOperatorSetsBase.JoinOperatorSetsPredicateBase.equalTo(KeySelector) to continue the Join.

See Also:

KeySelector, DataSet