Package org.apache.flink.api.java.operators

Class CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate

java.lang.Object

org.apache.flink.api.java.operators.CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate

Enclosing class:

CoGroupOperator.CoGroupOperatorSets<I1,I2>

public final class CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate
extends Object

Intermediate step of a CoGroup transformation.

To continue the CoGroup transformation, select the grouping key of the second input DataSet by calling equalTo(int...) or equalTo(KeySelector).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction	An intermediate CoGroupOperator without CoGroupFunction applied yet.

Method Summary

Modifier and Type	Method	Description
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction	equalTo(int... fields)	Continues a CoGroup transformation and defines the Tuple fields of the second co-grouped DataSet that should be used as grouping keys.
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.
<K> CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction	equalTo(org.apache.flink.api.java.functions.KeySelector<I2,K> keyExtractor)	Continues a CoGroup transformation and defines a KeySelector function for the second co-grouped DataSet.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

equalTo

public CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction equalTo(int... fields)

Continues a CoGroup transformation and defines the 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.

Parameters:

fields - The indexes of the Tuple fields of the second co-grouped DataSet that should be used as keys.

Returns:

An incomplete CoGroup transformation. Call CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.with(org.apache.flink.api.common.functions.CoGroupFunction) to finalize the CoGroup transformation.

equalTo

public 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.

Parameters:

fields - The fields of the first co-grouped DataSets that should be used as keys.

Returns:

An incomplete CoGroup transformation. Call CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.with(org.apache.flink.api.common.functions.CoGroupFunction) to finalize the CoGroup transformation.

equalTo

public <K> CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction equalTo(org.apache.flink.api.java.functions.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.

Parameters:

keyExtractor - The KeySelector function which extracts the key values from the second DataSet on which it is grouped.

Returns:

An incomplete CoGroup transformation. Call CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.with(org.apache.flink.api.common.functions.CoGroupFunction) to finalize the CoGroup transformation.