diff options
| author | Reynold Xin <rxin@databricks.com> | 2015-11-21 15:00:37 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-11-21 15:00:37 -0800 |
| commit | ff442bbcffd4f93cfcc2f76d160011e725d2fb3f (patch) | |
| tree | 9a0a5756f29de2f3021cf2c0c9ac5aae6bc7e7e2 /core/src/main/java | |
| parent | 596710268e29e8f624c3ba2fade08b66ec7084eb (diff) | |
| download | spark-ff442bbcffd4f93cfcc2f76d160011e725d2fb3f.tar.gz spark-ff442bbcffd4f93cfcc2f76d160011e725d2fb3f.tar.bz2 spark-ff442bbcffd4f93cfcc2f76d160011e725d2fb3f.zip | |
[SPARK-11899][SQL] API audit for GroupedDataset.
1. Renamed map to mapGroup, flatMap to flatMapGroup.
2. Renamed asKey -> keyAs.
3. Added more documentation.
4. Changed type parameter T to V on GroupedDataset.
5. Added since versions for all functions.
Author: Reynold Xin <rxin@databricks.com>
Closes #9880 from rxin/SPARK-11899.
Diffstat (limited to 'core/src/main/java')
| -rw-r--r-- | core/src/main/java/org/apache/spark/api/java/function/MapGroupFunction.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/java/org/apache/spark/api/java/function/MapGroupFunction.java b/core/src/main/java/org/apache/spark/api/java/function/MapGroupFunction.java index 2935f9986a..4f3f222e06 100644 --- a/core/src/main/java/org/apache/spark/api/java/function/MapGroupFunction.java +++ b/core/src/main/java/org/apache/spark/api/java/function/MapGroupFunction.java @@ -21,7 +21,7 @@ import java.io.Serializable; import java.util.Iterator; /** - * Base interface for a map function used in GroupedDataset's map function. + * Base interface for a map function used in GroupedDataset's mapGroup function. */ public interface MapGroupFunction<K, V, R> extends Serializable { R call(K key, Iterator<V> values) throws Exception; |