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:11 UTC
[beam] 01/01: Import WordExtractingDoFn from wordcount_with_metrics
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