CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.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 |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.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 |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.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.
|
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.sortFirstGroup(int field,
org.apache.flink.api.common.operators.Order order) |
Sorts Tuple elements within a group in
the first input on the specified field in the specified Order.
|
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.sortFirstGroup(String fieldExpression,
org.apache.flink.api.common.operators.Order order) |
Sorts Pojo or Tuple elements within a
group in the first input on the specified field in the specified Order.
|
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.sortSecondGroup(int field,
org.apache.flink.api.common.operators.Order order) |
Sorts Tuple elements within a group in
the second input on the specified field in the specified Order.
|
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.sortSecondGroup(String fieldExpression,
org.apache.flink.api.common.operators.Order order) |
Sorts Pojo or Tuple elements within a
group in the second input on the specified field in the specified Order.
|
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.withPartitioner(org.apache.flink.api.common.functions.Partitioner<?> partitioner) |
Sets a custom partitioner for the CoGroup operation.
|