From cb083434de6be2b623bf290c69a880c2e856cfed Mon Sep 17 00:00:00 2001 From: blais Date: Sat, 1 Jan 2022 23:11:19 -0500 Subject: [PATCH] python sdk examples: Fixed typo in wordcount example. --- sdks/python/apache_beam/examples/wordcount.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/examples/wordcount.py b/sdks/python/apache_beam/examples/wordcount.py index b59baa61a469a..12ba3431ac564 100644 --- a/sdks/python/apache_beam/examples/wordcount.py +++ b/sdks/python/apache_beam/examples/wordcount.py @@ -75,7 +75,7 @@ def run(argv=None, save_main_session=True): counts = ( lines | 'Split' >> (beam.ParDo(WordExtractingDoFn()).with_output_types(str)) - | 'PairWIthOne' >> beam.Map(lambda x: (x, 1)) + | 'PairWithOne' >> beam.Map(lambda x: (x, 1)) | 'GroupAndSum' >> beam.CombinePerKey(sum)) # Format the counts into a PCollection of strings.