Package | Description |
---|---|
org.apache.flink.api.java.operators |
Modifier and Type | Method and Description |
---|---|
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.equalTo(int... fields)
|
<K> CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.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 |
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. |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.sortFirstGroup(int field,
Order order)
Sorts
Tuple elements within a group in the first input on the
specified field in the specified Order .Note: Only groups of Tuple elements and Pojos can be sorted. Groups can be sorted by multiple fields by chaining sortFirstGroup(int, Order) calls. |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.sortFirstGroup(String fieldExpression,
Order order)
Sorts Pojo or
Tuple elements within a group in the first input on the
specified field in the specified Order .Groups can be sorted by multiple fields by chaining sortFirstGroup(String, Order) calls. |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.sortSecondGroup(int field,
Order order)
Sorts
Tuple elements within a group in the second input on the
specified field in the specified Order .Note: Only groups of Tuple elements and Pojos can be sorted. Groups can be sorted by multiple fields by chaining sortSecondGroup(int, Order) calls. |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.sortSecondGroup(String fieldExpression,
Order order)
Sorts Pojo or
Tuple elements within a group in the second input on the
specified field in the specified Order .Groups can be sorted by multiple fields by chaining sortSecondGroup(String, Order) calls. |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.withPartitioner(Partitioner<?> partitioner)
Sets a custom partitioner for the CoGroup operation.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.