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 2019/10/07 21:26:35 UTC

[beam] branch master updated: Fix closing region tags

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 48ce3a9  Fix closing region tags
     new be5753d  Merge pull request #9738 from davidcavazos/region-tag-fix
48ce3a9 is described below

commit 48ce3a9b2cb8c42cd84652923e4e9e586e6b7f58
Author: David Cavazos <dc...@google.com>
AuthorDate: Mon Oct 7 10:38:28 2019 -0700

    Fix closing region tags
---
 .../examples/snippets/transforms/elementwise/withtimestamps.py      | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/sdks/python/apache_beam/examples/snippets/transforms/elementwise/withtimestamps.py b/sdks/python/apache_beam/examples/snippets/transforms/elementwise/withtimestamps.py
index d1e2e3f..79a9c44 100644
--- a/sdks/python/apache_beam/examples/snippets/transforms/elementwise/withtimestamps.py
+++ b/sdks/python/apache_beam/examples/snippets/transforms/elementwise/withtimestamps.py
@@ -43,7 +43,7 @@ def withtimestamps_event_time(test=None):
         | 'Get timestamp' >> beam.ParDo(GetTimestamp())
         | beam.Map(print)
     )
-    # [END event_time]
+    # [END withtimestamps_event_time]
     if test:
       test(plant_timestamps)
 
@@ -72,7 +72,7 @@ def withtimestamps_logical_clock(test=None):
         | 'Get timestamp' >> beam.ParDo(GetTimestamp())
         | beam.Map(print)
     )
-    # [END logical_clock]
+    # [END withtimestamps_logical_clock]
     if test:
       test(plant_events)
 
@@ -101,7 +101,7 @@ def withtimestamps_processing_time(test=None):
         | 'Get timestamp' >> beam.ParDo(GetTimestamp())
         | beam.Map(print)
     )
-    # [END processing_time]
+    # [END withtimestamps_processing_time]
     if test:
       test(plant_processing_times)