Package 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
@Public
public class JoinOperatorSetsBase<I1,I2>
extends Object

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.

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	Description
class	JoinOperatorSetsBase.JoinOperatorSetsPredicateBase	Deprecated. Intermediate step of a Join transformation.

Field Summary

Fields

Modifier and Type	Field	Description
protected DataSet<I1>	input1	Deprecated.
protected DataSet<I2>	input2	Deprecated.
protected org.apache.flink.api.common.operators.base.JoinOperatorBase.JoinHint	joinHint	Deprecated.
protected JoinType	joinType	Deprecated.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
JoinOperatorSetsBase.JoinOperatorSetsPredicateBase	where(int... fields)	Deprecated. Continues a Join transformation.
JoinOperatorSetsBase.JoinOperatorSetsPredicateBase	where(String... fields)	Deprecated. Continues a Join transformation.
<K> JoinOperatorSetsBase.JoinOperatorSetsPredicateBase	where(org.apache.flink.api.java.functions.KeySelector<I1,K> keySelector)	Deprecated. 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

Field Detail

input1

protected final DataSet<I1> input1

Deprecated.

input2

protected final DataSet<I2> input2

Deprecated.

joinHint

protected final org.apache.flink.api.common.operators.base.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,
                            org.apache.flink.api.common.operators.base.JoinOperatorBase.JoinHint hint)

Deprecated.

JoinOperatorSetsBase

public JoinOperatorSetsBase(DataSet<I1> input1,
                            DataSet<I2> input2,
                            org.apache.flink.api.common.operators.base.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(org.apache.flink.api.java.functions.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