You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2017/06/02 16:17:11 UTC
[4/5] beam git commit: Closes #3222
Closes #3222
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2f9428c3
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2f9428c3
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2f9428c3
Branch: refs/heads/master
Commit: 2f9428c3e5e648d147fa68afdd13db7f6bfbcb0b
Parents: 7a075cc 99907b9
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Fri Jun 2 09:16:43 2017 -0700
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Fri Jun 2 09:16:43 2017 -0700
----------------------------------------------------------------------
pom.xml | 6 +
runners/core-construction-java/pom.xml | 5 +
.../WindowingStrategyTranslation.java | 149 +++++++++++++++----
.../WindowingStrategyTranslationTest.java | 9 ++
.../src/main/proto/standard_window_fns.proto | 53 +++++++
.../runners/dataflow/dataflow_runner.py | 39 ++++-
.../runners/dataflow/dataflow_runner_test.py | 11 ++
.../runners/dataflow/internal/dependency.py | 2 +-
sdks/python/apache_beam/transforms/window.py | 57 ++++---
sdks/python/apache_beam/utils/proto_utils.py | 6 +
sdks/python/apache_beam/utils/urns.py | 10 +-
sdks/python/run_pylint.sh | 5 +-
12 files changed, 292 insertions(+), 60 deletions(-)
----------------------------------------------------------------------