You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2020/08/13 18:47:10 UTC

[beam] branch aaltay-patch-1 created (now 23f3b49)

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

altay pushed a change to branch aaltay-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git.


      at 23f3b49  Import WordExtractingDoFn from wordcount_with_metrics

This branch includes the following new commits:

     new 23f3b49  Import WordExtractingDoFn from wordcount_with_metrics

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



[beam] 01/01: Import WordExtractingDoFn from wordcount_with_metrics

Posted by al...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

altay pushed a commit to branch aaltay-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 23f3b4931b4917bbc9daa1b76bf7abe4304af4f3
Author: Ahmet Altay <aa...@gmail.com>
AuthorDate: Thu Aug 13 11:46:44 2020 -0700

    Import WordExtractingDoFn from wordcount_with_metrics
    
    streaming wordcount tests relies on the output counters
---
 sdks/python/apache_beam/examples/streaming_wordcount.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sdks/python/apache_beam/examples/streaming_wordcount.py b/sdks/python/apache_beam/examples/streaming_wordcount.py
index a64fda5..14d7e8c 100644
--- a/sdks/python/apache_beam/examples/streaming_wordcount.py
+++ b/sdks/python/apache_beam/examples/streaming_wordcount.py
@@ -29,7 +29,7 @@ from past.builtins import unicode
 
 import apache_beam as beam
 import apache_beam.transforms.window as window
-from apache_beam.examples.wordcount import WordExtractingDoFn
+from apache_beam.examples.wordcount_with_metrics import WordExtractingDoFn
 from apache_beam.options.pipeline_options import PipelineOptions
 from apache_beam.options.pipeline_options import SetupOptions
 from apache_beam.options.pipeline_options import StandardOptions