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