You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/06/30 21:31:32 UTC
[30/50] beam git commit: This closes #3446
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 <pe...@apache.org>
Authored: Thu Jun 29 14:02:59 2017 +0800
Committer: Pei He <pe...@apache.org>
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(-)
----------------------------------------------------------------------