This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 7c780fd Fix small bug in top documentation
new 270d8fe Merge pull request #8401 Fix small bug in top documentation
7c780fd is described below
commit 7c780fd26ee88e011148c162d62a6f3befda64e9
Author: Ted <dam...@desfontain.es>
AuthorDate: Thu Apr 25 15:55:39 2019 +0200
Fix small bug in top documentation
LargestPerKey/SmallestPerKey don't return a single-element PCollection.
---
sdks/go/pkg/beam/transforms/top/top.go | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
diff --git a/sdks/go/pkg/beam/transforms/top/top.go
b/sdks/go/pkg/beam/transforms/top/top.go
index 71122cc..869510a 100644
--- a/sdks/go/pkg/beam/transforms/top/top.go
+++ b/sdks/go/pkg/beam/transforms/top/top.go
@@ -58,8 +58,7 @@ func Largest(s beam.Scope, col beam.PCollection, n int, less
interface{}) beam.P
// LargestPerKey returns the largest N values for each key of a
PCollection<KV<K,T>>.
// The order is defined by the comparator, less : T x T -> bool. It returns a
-// single-element PCollection<KV<K,[]T>> with a slice of the N largest
elements for
-// each key.
+// PCollection<KV<K,[]T>> with a slice of the N largest elements for each key.
func LargestPerKey(s beam.Scope, col beam.PCollection, n int, less
interface{}) beam.PCollection {
s = s.Scope(fmt.Sprintf("top.LargestPerKey(%v)", n))
@@ -89,8 +88,7 @@ func Smallest(s beam.Scope, col beam.PCollection, n int, less
interface{}) beam.
// SmallestPerKey returns the smallest N values for each key of a
PCollection<KV<K,T>>.
// The order is defined by the comparator, less : T x T -> bool. It returns a
-// single-element PCollection<KV<K,[]T>> with a slice of the N smallest
elements for
-// each key.
+// PCollection<KV<K,[]T>> with a slice of the N smallest elements for each key.
func SmallestPerKey(s beam.Scope, col beam.PCollection, n int, less
interface{}) beam.PCollection {
s = s.Scope(fmt.Sprintf("top.SmallestPerKey(%v)", n))
