diff options
author | Reynold Xin <rxin@databricks.com> | 2015-11-23 22:22:15 -0800 |
---|---|---|
committer | Reynold Xin <rxin@databricks.com> | 2015-11-23 22:22:15 -0800 |
commit | 8d57524662fad4a0760f3bc924e690c2a110e7f7 (patch) | |
tree | f4723119c7eb2f5b2ab0fc75a715761dbda386a0 /core | |
parent | 026ea2eab1f3cde270e8a6391d002915f3e1c6e5 (diff) | |
download | spark-8d57524662fad4a0760f3bc924e690c2a110e7f7.tar.gz spark-8d57524662fad4a0760f3bc924e690c2a110e7f7.tar.bz2 spark-8d57524662fad4a0760f3bc924e690c2a110e7f7.zip |
[SPARK-11933][SQL] Rename mapGroup -> mapGroups and flatMapGroup -> flatMapGroups.
Based on feedback from Matei, this is more consistent with mapPartitions in Spark.
Also addresses some of the cleanups from a previous commit that renames the type variables.
Author: Reynold Xin <rxin@databricks.com>
Closes #9919 from rxin/SPARK-11933.
Diffstat (limited to 'core')
-rw-r--r-- | core/src/main/java/org/apache/spark/api/java/function/FlatMapGroupsFunction.java (renamed from core/src/main/java/org/apache/spark/api/java/function/FlatMapGroupFunction.java) | 2 | ||||
-rw-r--r-- | core/src/main/java/org/apache/spark/api/java/function/MapGroupsFunction.java (renamed from core/src/main/java/org/apache/spark/api/java/function/MapGroupFunction.java) | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/java/org/apache/spark/api/java/function/FlatMapGroupFunction.java b/core/src/main/java/org/apache/spark/api/java/function/FlatMapGroupsFunction.java index 18a2d733ca..d7a80e7b12 100644 --- a/core/src/main/java/org/apache/spark/api/java/function/FlatMapGroupFunction.java +++ b/core/src/main/java/org/apache/spark/api/java/function/FlatMapGroupsFunction.java @@ -23,6 +23,6 @@ import java.util.Iterator; /** * A function that returns zero or more output records from each grouping key and its values. */ -public interface FlatMapGroupFunction<K, V, R> extends Serializable { +public interface FlatMapGroupsFunction<K, V, R> extends Serializable { Iterable<R> call(K key, Iterator<V> values) throws Exception; } 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/MapGroupsFunction.java index 4f3f222e06..faa59eabc8 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/MapGroupsFunction.java @@ -23,6 +23,6 @@ import java.util.Iterator; /** * Base interface for a map function used in GroupedDataset's mapGroup function. */ -public interface MapGroupFunction<K, V, R> extends Serializable { +public interface MapGroupsFunction<K, V, R> extends Serializable { R call(K key, Iterator<V> values) throws Exception; } |