Package | Description |
---|---|
org.apache.flink.api.java | |
org.apache.flink.api.java.operators |
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.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.