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>
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 .The KeySelector function is called for each element of the first DataSet and extracts a single key value on which the DataSet is joined. |
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)
Tuple
fields of the first join DataSet
that should be used as join keys.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)
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
.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–2017 The Apache Software Foundation. All rights reserved.