[beam] branch master updated: Move WC integration test to generic registration (#22248)

[lo...@apache.org]

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

lostluck 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 cc10d15c92d Move WC integration test to generic registration (#22248)
cc10d15c92d is described below

commit cc10d15c92d5261a76e2beb6df449804a26254e5
Author: Jack McCluskey <34...@users.noreply.github.com>
AuthorDate: Tue Jul 12 20:11:11 2022 -0400

    Move WC integration test to generic registration (#22248)
---
 sdks/go/test/integration/wordcount/wordcount.go | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/sdks/go/test/integration/wordcount/wordcount.go b/sdks/go/test/integration/wordcount/wordcount.go
index 483f5028509..e5886070d05 100644
--- a/sdks/go/test/integration/wordcount/wordcount.go
+++ b/sdks/go/test/integration/wordcount/wordcount.go
@@ -24,6 +24,7 @@ import (
 
 	"github.com/apache/beam/sdks/v2/go/pkg/beam"
 	"github.com/apache/beam/sdks/v2/go/pkg/beam/io/textio"
+	"github.com/apache/beam/sdks/v2/go/pkg/beam/register"
 	"github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert"
 	"github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/stats"
 )
@@ -36,8 +37,10 @@ var (
 )
 
 func init() {
-	beam.RegisterFunction(extractFn)
-	beam.RegisterFunction(formatFn)
+	register.Function3x0(extractFn)
+	register.Function2x1(formatFn)
+
+	register.Emitter1[string]()
 }
 
 // CountWords is a composite transform that counts the words of a PCollection