I1
- The type of the first input DataSet of the Join transformation.I2
- The type of the second input DataSet of the Join transformation.@Public public static final class JoinOperator.JoinOperatorSets<I1,I2> extends JoinOperatorSetsBase<I1,I2>
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)
.
Modifier and Type | Class and Description |
---|---|
class |
JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate
Intermediate step of a Join transformation.
|
JoinOperatorSetsBase.JoinOperatorSetsPredicateBase
input1, input2, joinHint, joinType
Constructor and Description |
---|
JoinOperatorSets(DataSet<I1> input1,
DataSet<I2> input2) |
JoinOperatorSets(DataSet<I1> input1,
DataSet<I2> input2,
JoinOperatorBase.JoinHint hint) |
Modifier and Type | Method and Description |
---|---|
JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate |
where(int... fields)
Continues a Join transformation.
|
<K> JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate |
where(KeySelector<I1,K> keySelector)
Continues a Join transformation and defines a
KeySelector function for the first join
DataSet . |
JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate |
where(String... fields)
Continues a Join transformation.
|
public JoinOperatorSets(DataSet<I1> input1, DataSet<I2> input2, JoinOperatorBase.JoinHint hint)
public JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate where(int... fields)
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.
where
in class JoinOperatorSetsBase<I1,I2>
fields
- The indexes of the other Tuple fields of the first join DataSets that should be
used as keys.JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate.equalTo(int...)
or JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate.equalTo(KeySelector)
to continue the Join.Tuple
,
DataSet
public JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate where(String... fields)
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.
where
in class JoinOperatorSetsBase<I1,I2>
fields
- The fields of the first join DataSets that should be used as keys.JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate.equalTo(int...)
or JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate.equalTo(KeySelector)
to continue the Join.Tuple
,
DataSet
public <K> JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate where(KeySelector<I1,K> keySelector)
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.
where
in class JoinOperatorSetsBase<I1,I2>
keySelector
- The KeySelector function which extracts the key values from the DataSet on
which it is joined.JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate.equalTo(int...)
or JoinOperator.JoinOperatorSets.JoinOperatorSetsPredicate.equalTo(KeySelector)
to continue the Join.KeySelector
,
DataSet
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.