This closes #3446
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/997bf402 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/997bf402 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/997bf402 Branch: refs/heads/gearpump-runner Commit: 997bf402511d2b2468385fcfd2b3aa4dba52eac5 Parents: b1ece01 2efb0d5 Author: Pei He <[email protected]> Authored: Thu Jun 29 14:02:59 2017 +0800 Committer: Pei He <[email protected]> Committed: Thu Jun 29 14:02:59 2017 +0800 ---------------------------------------------------------------------- .../WindowingStrategyTranslation.java | 26 ++- .../beam/runners/core/ReduceFnRunner.java | 20 ++- .../beam/runners/core/ReduceFnRunnerTest.java | 161 +++++++++++++++++++ .../src/main/proto/beam_runner_api.proto | 14 ++ .../beam/sdk/transforms/windowing/Window.java | 32 ++++ .../beam/sdk/values/WindowingStrategy.java | 46 ++++-- 6 files changed, 282 insertions(+), 17 deletions(-) ----------------------------------------------------------------------
