public final class CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction extends Object
CoGroupOperator
without CoGroupFunction
applied yet.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.
Each CoGroupFunction call returns an arbitrary number of 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
.
Note: Only groups of Tuple elements and Pojos can be sorted.
Groups can be sorted by multiple fields by chaining 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
.
Note: Only groups of Tuple elements and Pojos can be sorted.
Groups can be sorted by multiple fields by chaining 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
.
Groups can be sorted by multiple fields by chaining 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
.
Groups can be sorted by multiple fields by chaining 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–2024 The Apache Software Foundation. All rights reserved.