beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [2/4] beam git commit: Set OnTimeBehavior in windowing strategy to FIRE_ALWAYS.
Date Fri, 10 Nov 2017 18:11:40 GMT
Set OnTimeBehavior in windowing strategy to FIRE_ALWAYS.

This fixes python side of https://issues.apache.org/jira/browse/BEAM-2961.

Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bddb8699
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bddb8699
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/bddb8699

Branch: refs/heads/release-2.2.0
Commit: bddb86996b5083134ff87abcac1a8db49ef6ba09
Parents: 22dcd73
Author: tvalentyn <tvalentyn@users.noreply.github.com>
Authored: Thu Nov 9 13:16:24 2017 -0800
Committer: Valentyn Tymofieiev <valentyn@google.com>
Committed: Thu Nov 9 13:55:00 2017 -0800

----------------------------------------------------------------------
 sdks/python/apache_beam/transforms/core.py | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/beam/blob/bddb8699/sdks/python/apache_beam/transforms/core.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/transforms/core.py b/sdks/python/apache_beam/transforms/core.py
index 41e20ba..ba60ced 100644
--- a/sdks/python/apache_beam/transforms/core.py
+++ b/sdks/python/apache_beam/transforms/core.py
@@ -1528,6 +1528,7 @@ class Windowing(object):
         output_time=self.timestamp_combiner,
         # TODO(robertwb): Support EMIT_IF_NONEMPTY
         closing_behavior=beam_runner_api_pb2.ClosingBehavior.EMIT_ALWAYS,
+        OnTimeBehavior=beam_runner_api_pb2.OnTimeBehavior.FIRE_ALWAYS,
         allowed_lateness=0)
 
   @staticmethod


Mime
View raw message