You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2022/09/07 01:48:33 UTC

[beam] branch users/damccorm/example created (now 7656a63774e)

This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a change to branch users/damccorm/example
in repository https://gitbox.apache.org/repos/asf/beam.git


      at 7656a63774e Fix example registration input arity

This branch includes the following new commits:

     new 7656a63774e Fix example registration input arity

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



[beam] 01/01: Fix example registration input arity

Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a commit to branch users/damccorm/example
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 7656a63774ebac75906dbee8ecb9b5f62454db0a
Author: Danny McCormick <da...@google.com>
AuthorDate: Tue Sep 6 21:48:26 2022 -0400

    Fix example registration input arity
---
 sdks/go/pkg/beam/register/example_register_test.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/sdks/go/pkg/beam/register/example_register_test.go b/sdks/go/pkg/beam/register/example_register_test.go
index 0b5de858183..19dadc8ab60 100644
--- a/sdks/go/pkg/beam/register/example_register_test.go
+++ b/sdks/go/pkg/beam/register/example_register_test.go
@@ -65,8 +65,8 @@ func (fn *myDoFn2) ProcessElement(word string, iter func(**Foo, *beam.EventTime)
 	return mtime.Now(), word, len(word)
 }
 
-func ExampleDoFn2x1() {
-	// Since myDoFn's ProcessElement call has 2 inputs and 1 output, call DoFn2x1.
+func ExampleDoFn3x1() {
+	// Since myDoFn's ProcessElement call has 3 inputs and 1 output, call DoFn3x1.
 	// Since the inputs to ProcessElement are (string, func(int)), and the output
 	// is int, we pass those parameter types to the function.
 	register.DoFn3x1[string, func(*string) bool, func(int), int](&myDoFn{})