You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/11/09 21:54:09 UTC
[1/2] beam git commit: Set OnTimeBehavior in windowing strategy to
FIRE_ALWAYS.
Repository: beam
Updated Branches:
refs/heads/master 491786dcd -> 1b1838ebf
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/19b5fd09
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/19b5fd09
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/19b5fd09
Branch: refs/heads/master
Commit: 19b5fd09271bf90c5ad8ed91a2bd76f68b91f2e2
Parents: 491786d
Author: tvalentyn <tv...@users.noreply.github.com>
Authored: Thu Nov 9 13:16:24 2017 -0800
Committer: GitHub <no...@github.com>
Committed: Thu Nov 9 13:16:24 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/19b5fd09/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 1c05e97..e650b39 100644
--- a/sdks/python/apache_beam/transforms/core.py
+++ b/sdks/python/apache_beam/transforms/core.py
@@ -1548,6 +1548,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
[2/2] beam git commit: [BEAM-2961] Set OnTimeBehavior in windowing
strategy to FIRE_ALWAYS.
Posted by lc...@apache.org.
[BEAM-2961] Set OnTimeBehavior in windowing strategy to FIRE_ALWAYS.
This closes #4108
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1b1838eb
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1b1838eb
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1b1838eb
Branch: refs/heads/master
Commit: 1b1838ebf182668f3bf6a1075536c990b092aa8b
Parents: 491786d 19b5fd0
Author: Luke Cwik <lc...@google.com>
Authored: Thu Nov 9 13:54:01 2017 -0800
Committer: Luke Cwik <lc...@google.com>
Committed: Thu Nov 9 13:54:01 2017 -0800
----------------------------------------------------------------------
sdks/python/apache_beam/transforms/core.py | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------