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:20 UTC

[beam] branch pabloem-patch-1 created (now 636732e)

This is an automated email from the ASF dual-hosted git repository.

pabloem pushed a change to branch pabloem-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git.


      at 636732e  Documenting AfterProcessingTime delay.

This branch includes the following new commits:

     new 636732e  Documenting AfterProcessingTime delay.

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



[beam] 01/01: Documenting AfterProcessingTime delay.

Posted by pa...@apache.org.
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.
   """