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

Deprecated.

All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.

@Deprecated
 @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).

See Also:

FLIP-131: Consolidate the user-facing Dataflow SDKs/APIs (and deprecate the DataSet API

Nested Class Summary

Nested Classes

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

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
JoinOperatorSetsBase.JoinOperatorSetsPredicateBase	where(int... fields) Deprecated. Continues a Join transformation.
<K> JoinOperatorSetsBase.JoinOperatorSetsPredicateBase	where(KeySelector<I1,K> keySelector) Deprecated. Continues a Join transformation and defines a KeySelector function for the first join DataSet.
JoinOperatorSetsBase.JoinOperatorSetsPredicateBase	where(String... fields) Deprecated. 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

Deprecated.

input2

protected final DataSet<I2> input2

Deprecated.

joinHint

protected final JoinOperatorBase.JoinHint joinHint

Deprecated.

joinType

protected final JoinType joinType

Deprecated.

Constructor Detail

JoinOperatorSetsBase

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

Deprecated.

JoinOperatorSetsBase

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

Deprecated.

JoinOperatorSetsBase

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

Deprecated.

Method Detail

where

public JoinOperatorSetsBase.JoinOperatorSetsPredicateBase where(int... fields)

Deprecated.

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)

Deprecated.

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)

Deprecated.

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