This is an automated email from the ASF dual-hosted git repository.
altay 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 cb08343 python sdk examples: Fixed typo in wordcount example.
new 8724555 Merge pull request #16413 from blais/master
cb08343 is described below
commit cb083434de6be2b623bf290c69a880c2e856cfed
Author: blais <[email protected]>
AuthorDate: Sat Jan 1 23:11:19 2022 -0500
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 b59baa6..12ba343 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.
