aboutsummaryrefslogtreecommitdiff
path: root/sql/core
diff options
context:
space:
mode:
authorJacek Laskowski <jacek@japila.pl>2016-09-02 10:25:42 +0100
committerSean Owen <sowen@cloudera.com>2016-09-02 10:25:42 +0100
commita3097e2b314b1cd7446c6106a54fe4b49871c26d (patch)
treeef9e21705821de153cd6a20e0b6b2ff4376896db /sql/core
parent6969dcc79a33d715250958b24361f2d43552d840 (diff)
downloadspark-a3097e2b314b1cd7446c6106a54fe4b49871c26d.tar.gz
spark-a3097e2b314b1cd7446c6106a54fe4b49871c26d.tar.bz2
spark-a3097e2b314b1cd7446c6106a54fe4b49871c26d.zip
[SQL][DOC][MINOR] Add (Scala-specific) and (Java-specific)
## What changes were proposed in this pull request? Adds (Scala-specific) and (Java-specific) to Scaladoc. ## How was this patch tested? local build Author: Jacek Laskowski <jacek@japila.pl> Closes #14891 from jaceklaskowski/scala-specifics.
Diffstat (limited to 'sql/core')
-rw-r--r--sql/core/src/main/scala/org/apache/spark/sql/KeyValueGroupedDataset.scala8
1 files changed, 8 insertions, 0 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/KeyValueGroupedDataset.scala b/sql/core/src/main/scala/org/apache/spark/sql/KeyValueGroupedDataset.scala
index 61a3e6e0bc..cea16fba76 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/KeyValueGroupedDataset.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/KeyValueGroupedDataset.scala
@@ -79,6 +79,7 @@ class KeyValueGroupedDataset[K, V] private[sql](
}
/**
+ * (Scala-specific)
* Applies the given function to each group of data. For each unique group, the function will
* be passed the group key and an iterator that contains all of the elements in the group. The
* function can return an iterator containing elements of an arbitrary type which will be returned
@@ -107,6 +108,7 @@ class KeyValueGroupedDataset[K, V] private[sql](
}
/**
+ * (Java-specific)
* Applies the given function to each group of data. For each unique group, the function will
* be passed the group key and an iterator that contains all of the elements in the group. The
* function can return an iterator containing elements of an arbitrary type which will be returned
@@ -129,6 +131,7 @@ class KeyValueGroupedDataset[K, V] private[sql](
}
/**
+ * (Scala-specific)
* Applies the given function to each group of data. For each unique group, the function will
* be passed the group key and an iterator that contains all of the elements in the group. The
* function can return an element of arbitrary type which will be returned as a new [[Dataset]].
@@ -151,6 +154,7 @@ class KeyValueGroupedDataset[K, V] private[sql](
}
/**
+ * (Java-specific)
* Applies the given function to each group of data. For each unique group, the function will
* be passed the group key and an iterator that contains all of the elements in the group. The
* function can return an element of arbitrary type which will be returned as a new [[Dataset]].
@@ -172,6 +176,7 @@ class KeyValueGroupedDataset[K, V] private[sql](
}
/**
+ * (Scala-specific)
* Reduces the elements of each group of data using the specified binary function.
* The given function must be commutative and associative or the result may be non-deterministic.
*
@@ -184,6 +189,7 @@ class KeyValueGroupedDataset[K, V] private[sql](
}
/**
+ * (Java-specific)
* Reduces the elements of each group of data using the specified binary function.
* The given function must be commutative and associative or the result may be non-deterministic.
*
@@ -269,6 +275,7 @@ class KeyValueGroupedDataset[K, V] private[sql](
def count(): Dataset[(K, Long)] = agg(functions.count("*").as(ExpressionEncoder[Long]()))
/**
+ * (Scala-specific)
* Applies the given function to each cogrouped data. For each unique group, the function will
* be passed the grouping key and 2 iterators containing all elements in the group from
* [[Dataset]] `this` and `other`. The function can return an iterator containing elements of an
@@ -293,6 +300,7 @@ class KeyValueGroupedDataset[K, V] private[sql](
}
/**
+ * (Java-specific)
* Applies the given function to each cogrouped data. For each unique group, the function will
* be passed the grouping key and 2 iterators containing all elements in the group from
* [[Dataset]] `this` and `other`. The function can return an iterator containing elements of an