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
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 .The KeySelector function is called for each element of the first DataSet and extracts a single key value on which the DataSet is grouped. |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate |
where(String... fields)
Continues a CoGroup transformation.
|
public CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate where(int... fields)
Tuple
fields of the first co-grouped DataSet
that should be used as grouping keys.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)
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
.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–2017 The Apache Software Foundation. All rights reserved.