Package | Description |
---|---|
org.apache.flink.api.java.operators | |
org.apache.flink.python.api.util |
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.
|
Modifier and Type | Method and Description |
---|---|
<S extends SortedGrouping<?>> |
SetCache.add(int id,
S set)
Adds the given
SortedGrouping to this cache for the given ID. |
Modifier and Type | Method and Description |
---|---|
<T> SortedGrouping<T> |
SetCache.getSortedGrouping(int id)
Returns the cached
SortedGrouping for the given ID. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.