beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
Subject [beam] branch master updated: Add package description to the debug package.
Date Fri, 18 Jan 2019 18:16:22 GMT
This is an automated email from the ASF dual-hosted git repository.

altay pushed a commit to branch master
in repository

The following commit(s) were added to refs/heads/master by this push:
     new 4e4f479  Add package description to the debug package.
     new 62c54d2  Merge pull request #7544 from lostluck/debug
4e4f479 is described below

commit 4e4f4799b20d457c34b5d90af3361cbf475ba352
Author: Robert Burke <>
AuthorDate: Thu Jan 17 01:03:27 2019 +0000

    Add package description to the debug package.
 sdks/go/pkg/beam/x/debug/doc.go  | 21 +++++++++++++++++++++
 sdks/go/pkg/beam/x/debug/head.go |  3 ---
 2 files changed, 21 insertions(+), 3 deletions(-)

diff --git a/sdks/go/pkg/beam/x/debug/doc.go b/sdks/go/pkg/beam/x/debug/doc.go
new file mode 100644
index 0000000..67498bb
--- /dev/null
+++ b/sdks/go/pkg/beam/x/debug/doc.go
@@ -0,0 +1,21 @@
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements.  See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License.  You may obtain a copy of the License at
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+// Package debug contains pipeline components that may help
+// in debugging pipeline issues.
+package debug
+//go:generate go install
+//go:generate starcgen --package=debug --identifiers=headFn,headKVFn,discardFn,printFn,printKVFn,printGBKFn
diff --git a/sdks/go/pkg/beam/x/debug/head.go b/sdks/go/pkg/beam/x/debug/head.go
index 4e10443..e0ca094 100644
--- a/sdks/go/pkg/beam/x/debug/head.go
+++ b/sdks/go/pkg/beam/x/debug/head.go
@@ -20,9 +20,6 @@ import (
-//go:generate go install
-//go:generate starcgen --package=debug --identifiers=headFn,headKVFn,discardFn,printFn,printKVFn,printGBKFn
 // Head returns the first "n" elements it sees, it doesn't enforce any logic
 // as to what elements they will be.
 func Head(s beam.Scope, col beam.PCollection, n int) beam.PCollection {

View raw message