public final class CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate extends Object
To continue the CoGroup transformation, select the grouping key of the second input
DataSet
by calling equalTo(int...)
or equalTo(KeySelector)
.
Modifier and Type | Class and Description |
---|---|
class |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction
An intermediate
CoGroupOperator without CoGroupFunction applied yet. |
Modifier and Type | Method and Description |
---|---|
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
equalTo(int... fields)
|
<K> CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
equalTo(KeySelector<I2,K> keyExtractor)
Continues a CoGroup transformation and defines a
KeySelector function for the
second co-grouped DataSet . |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
equalTo(String... fields)
Continues a CoGroup transformation and defines the fields of the second co-grouped
DataSet that should be used as grouping keys. |
public CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction equalTo(int... fields)
Tuple
fields of the second
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 second co-grouped DataSet that
should be used as keys.CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.with(org.apache.flink.api.common.functions.CoGroupFunction)
to finalize the CoGroup transformation.public CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction equalTo(String... fields)
DataSet
that should be used as grouping keys.fields
- The fields of the first co-grouped DataSets that should be used as
keys.CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.with(org.apache.flink.api.common.functions.CoGroupFunction)
to finalize the CoGroup transformation.public <K> CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction equalTo(KeySelector<I2,K> keyExtractor)
KeySelector
function for the
second co-grouped DataSet
.
The KeySelector function is called for each element of the second DataSet and extracts a single key value on which the DataSet is grouped.
keyExtractor
- The KeySelector function which extracts the key values from the
second DataSet on which it is grouped.CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.with(org.apache.flink.api.common.functions.CoGroupFunction)
to finalize the CoGroup transformation.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.