You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by pa...@apache.org on 2019/01/08 22:39:21 UTC
[beam] 01/01: Documenting AfterProcessingTime delay.
This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a commit to branch pabloem-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 636732e90e9f9a8743c139067d9e48b2571a1b17
Author: Pablo <pa...@users.noreply.github.com>
AuthorDate: Tue Jan 8 14:39:07 2019 -0800
Documenting AfterProcessingTime delay.
---
sdks/python/apache_beam/transforms/trigger.py | 3 +++
1 file changed, 3 insertions(+)
diff --git a/sdks/python/apache_beam/transforms/trigger.py b/sdks/python/apache_beam/transforms/trigger.py
index 460e711..b8283da 100644
--- a/sdks/python/apache_beam/transforms/trigger.py
+++ b/sdks/python/apache_beam/transforms/trigger.py
@@ -283,6 +283,9 @@ class DefaultTrigger(TriggerFn):
class AfterProcessingTime(TriggerFn):
"""Fire exactly once after a specified delay from processing time.
+ Args:
+ delay: How long to delay a trigger. Specified in milliseconds.
+
AfterProcessingTime is experimental. No backwards compatibility guarantees.
"""