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.
   """