I1
- The type of the first input DataSet of the CoGroup transformation.I2
- The type of the second input DataSet of the CoGroup transformation.public static final class CoGroupOperator.CoGroupOperatorSets<I1,I2> extends Object
To continue the CoGroup transformation, select the grouping key of the first input DataSet
by calling where(int...)
or
where(KeySelector)
.
Modifier and Type | Class and Description |
---|---|
class |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate
Intermediate step of a CoGroup transformation.
|
Constructor and Description |
---|
CoGroupOperatorSets(DataSet<I1> input1,
DataSet<I2> input2) |
Modifier and Type | Method and Description |
---|---|
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate |
where(int... fields)
Continues a CoGroup transformation.
|
<K> CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate |
where(KeySelector<I1,K> keyExtractor)
Continues a CoGroup transformation and defines a
KeySelector function for the
first co-grouped DataSet . |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate |
where(String... fields)
Continues a CoGroup transformation.
|
public CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate where(int... fields)
Defines the Tuple
fields of the first co-grouped DataSet
that should
be used as grouping keys.
Note: Fields can only be selected as grouping keys on Tuple DataSets.
fields
- The indexes of the Tuple fields of the first co-grouped DataSets that
should be used as keys.CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.equalTo(int...)
to continue the CoGroup.Tuple
,
DataSet
public CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate where(String... fields)
Defines the fields of the first co-grouped DataSet
that should be used as
grouping keys. Fields are the names of member fields of the underlying type of the data
set.
fields
- The fields of the first co-grouped DataSets that should be used as keys.CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.equalTo(int...)
to continue the CoGroup.Tuple
,
DataSet
public <K> CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate where(KeySelector<I1,K> keyExtractor)
KeySelector
function for the
first co-grouped DataSet
.
The KeySelector function is called for each element of the first DataSet and extracts a single key value on which the DataSet is grouped.
keyExtractor
- The KeySelector function which extracts the key values from the
DataSet on which it is grouped.CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.equalTo(int...)
to continue the CoGroup.KeySelector
,
DataSet
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.