Skip to content

Commit

Permalink
[SQL][DOC][MINOR] Add (Scala-specific) and (Java-specific)
Browse files Browse the repository at this point in the history
## 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 <[email protected]>

Closes apache#14891 from jaceklaskowski/scala-specifics.
  • Loading branch information
jaceklaskowski authored and srowen committed Sep 2, 2016
1 parent 6969dcc commit a3097e2
Showing 1 changed file with 8 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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
Expand All @@ -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]].
Expand All @@ -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]].
Expand All @@ -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.
*
Expand All @@ -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.
*
Expand Down Expand Up @@ -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
Expand All @@ -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
Expand Down

0 comments on commit a3097e2

Please sign in to comment.