Package | Description |
---|---|
org.apache.flink.api.java.operators |
Modifier and Type | Method and Description |
---|---|
SortedGrouping<T> |
SortedGrouping.sortGroup(int field,
Order order)
|
SortedGrouping<T> |
UnsortedGrouping.sortGroup(int field,
Order order)
|
<K> SortedGrouping<T> |
UnsortedGrouping.sortGroup(KeySelector<T,K> keySelector,
Order order)
Sorts elements within a group on a key extracted by the specified
KeySelector in the specified Order . |
SortedGrouping<T> |
SortedGrouping.sortGroup(String field,
Order order)
|
SortedGrouping<T> |
UnsortedGrouping.sortGroup(String field,
Order order)
Sorts Pojos within a group on the specified field in the specified
Order . |
SortedGrouping<T> |
SortedGrouping.withPartitioner(Partitioner<?> partitioner)
Uses a custom partitioner for the grouping.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.