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)