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 2016/12/13 21:38:04 UTC
[3/3] incubator-beam git commit: This closes #1541
This closes #1541
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a52600b6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a52600b6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a52600b6
Branch: refs/heads/master
Commit: a52600b68112af93f865d0c815cf9ea368cb1fe0
Parents: 596f255 267edaa
Author: Kenneth Knowles <kl...@google.com>
Authored: Tue Dec 13 13:37:46 2016 -0800
Committer: Kenneth Knowles <kl...@google.com>
Committed: Tue Dec 13 13:37:46 2016 -0800
----------------------------------------------------------------------
.../runners/core/PerKeyCombineFnRunner.java | 149 +++++++++++++++++++
.../runners/core/PerKeyCombineFnRunners.java | 1 -
.../FlinkMergingNonShuffleReduceFunction.java | 2 +-
.../FlinkMergingPartialReduceFunction.java | 2 +-
.../functions/FlinkMergingReduceFunction.java | 2 +-
.../functions/FlinkPartialReduceFunction.java | 2 +-
.../functions/FlinkReduceFunction.java | 2 +-
.../beam/runners/dataflow/dataflow.properties | 4 +-
.../beam/sdk/util/PerKeyCombineFnRunner.java | 148 ------------------
9 files changed, 156 insertions(+), 156 deletions(-)
----------------------------------------------------------------------