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 <rober...@gmail.com> Authored: Fri Jun 2 09:16:43 2017 -0700 Committer: Robert Bradshaw <rober...@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(-) ----------------------------------------------------------------------