public final class CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction extends Object
Modifier and Type | Method and Description |
---|---|
Partitioner<?> |
getPartitioner()
Gets the custom partitioner used by this join, or
null , if none is set. |
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 |
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 |
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 |
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. |
<R> CoGroupOperator<I1,I2,R> |
with(CoGroupFunction<I1,I2,R> function)
Finalizes a CoGroup transformation by applying a
RichCoGroupFunction to groups of elements with identical keys.Each CoGroupFunction call returns an arbitrary number of keys. |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
withPartitioner(Partitioner<?> partitioner)
Sets a custom partitioner for the CoGroup operation.
|
public CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction withPartitioner(Partitioner<?> partitioner)
NOTE: A custom partitioner can only be used with single-field CoGroup keys, not with composite CoGroup keys.
partitioner
- The custom partitioner to be used.public Partitioner<?> getPartitioner()
null
, if none is set.public <R> CoGroupOperator<I1,I2,R> with(CoGroupFunction<I1,I2,R> function)
RichCoGroupFunction
to groups of elements with identical keys.function
- The CoGroupFunction that is called for all groups of elements with identical keys.RichCoGroupFunction
,
DataSet
public CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction sortFirstGroup(int field, Order order)
Tuple
elements within a group in the first input on the
specified field in the specified Order
.sortFirstGroup(int, Order)
calls.public CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction sortSecondGroup(int field, Order order)
Tuple
elements within a group in the second input on the
specified field in the specified Order
.sortSecondGroup(int, Order)
calls.public CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction sortFirstGroup(String fieldExpression, Order order)
Tuple
elements within a group in the first input on the
specified field in the specified Order
.sortFirstGroup(String, Order)
calls.fieldExpression
- The expression to the field on which the group is to be sorted.order
- The Order in which the specified Tuple field is sorted.Order
public CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction sortSecondGroup(String fieldExpression, Order order)
Tuple
elements within a group in the second input on the
specified field in the specified Order
.sortSecondGroup(String, Order)
calls.fieldExpression
- The expression to the field on which the group is to be sorted.order
- The Order in which the specified Tuple field is sorted.Order
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.