public final class CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate extends Object
DataSet
by calling
equalTo(int...)
or equalTo(KeySelector)
.Modifier and Type | Class and Description |
---|---|
class |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
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 .The KeySelector function is called for each element of the second DataSet and extracts a single key value on which the DataSet is grouped. |
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.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
.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–2017 The Apache Software Foundation. All rights reserved.