You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lo...@apache.org on 2022/06/22 23:20:34 UTC

[beam-starter-go] 12/17: Use camelCase

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

lostluck pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/beam-starter-go.git

commit 7f920e02472c651cdbdabd274ae165c538c8ef74
Author: David Cavazos <dc...@google.com>
AuthorDate: Fri Jun 17 14:02:51 2022 -0700

    Use camelCase
    
    Co-authored-by: Robert Burke <lo...@users.noreply.github.com>
---
 main.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/main.go b/main.go
index 2b38c9e..41c3c27 100644
--- a/main.go
+++ b/main.go
@@ -24,7 +24,7 @@ func printAndEmit(element string, emit func(string)) {
 	emit(element)
 }
 
-func my_pipeline(scope beam.Scope, input_text string) beam.PCollection {
+func myPipeline(scope beam.Scope, input_text string) beam.PCollection {
 	elements := beam.Create(scope, "Hello", "World!", input_text)
 	return beam.ParDo(scope, printAndEmit, elements)
 }