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)
}