Repository: beam Updated Branches: refs/heads/master ca678d887 -> 599a8ed65
This closes #2101 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/599a8ed6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/599a8ed6 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/599a8ed6 Branch: refs/heads/master Commit: 599a8ed65befb2c42ba0488b556bfb42ce77e215 Parents: ca678d8 eaf9b9b Author: Thomas Groh <tg...@google.com> Authored: Wed Mar 1 17:51:19 2017 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Wed Mar 1 17:51:19 2017 -0800 ---------------------------------------------------------------------- .../translation/ApexPipelineTranslator.java | 2 +- .../translation/WindowAssignTranslator.java | 78 +++++++++++ .../apex/translation/WindowBoundTranslator.java | 78 ----------- .../direct/TransformEvaluatorRegistry.java | 2 +- .../runners/direct/WindowEvaluatorFactory.java | 11 +- .../direct/WindowEvaluatorFactoryTest.java | 46 +------ .../flink/FlinkBatchTransformTranslators.java | 8 +- .../FlinkStreamingTransformTranslators.java | 8 +- .../functions/FlinkAssignWindows.java | 2 +- .../dataflow/DataflowPipelineTranslator.java | 9 +- .../spark/translation/TransformTranslator.java | 8 +- .../spark/translation/TranslationUtils.java | 4 +- .../streaming/StreamingTransformTranslator.java | 8 +- .../beam/sdk/transforms/windowing/Window.java | 43 +++++- .../sdk/transforms/windowing/WindowTest.java | 136 +++++++++++++++++++ 15 files changed, 290 insertions(+), 153 deletions(-) ----------------------------------------------------------------------
