Package | Description |
---|---|
org.apache.flink.api.java | |
org.apache.flink.api.java.operators | |
org.apache.flink.python.api.util |
Modifier and Type | Method and Description |
---|---|
UnsortedGrouping<T> |
DataSet.groupBy(int... fields)
|
<K> UnsortedGrouping<T> |
DataSet.groupBy(KeySelector<T,K> keyExtractor)
Groups a
DataSet using a KeySelector function. |
UnsortedGrouping<T> |
DataSet.groupBy(String... fields)
Groups a
DataSet using field expressions. |
Modifier and Type | Method and Description |
---|---|
UnsortedGrouping<T> |
UnsortedGrouping.withPartitioner(Partitioner<?> partitioner)
Uses a custom partitioner for the grouping.
|
Modifier and Type | Method and Description |
---|---|
<U extends UnsortedGrouping<?>> |
SetCache.add(int id,
U set)
Adds the given
UnsortedGrouping to this cache for the given ID. |
Modifier and Type | Method and Description |
---|---|
<T> UnsortedGrouping<T> |
SetCache.getUnsortedGrouping(int id)
Returns the cached
UnsortedGrouping for the given ID. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.