You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/04/15 07:07:16 UTC
[3/3] beam git commit: This closes #2500
This closes #2500
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f7d727c0
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f7d727c0
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f7d727c0
Branch: refs/heads/master
Commit: f7d727c0f7ada7a162f5cb73f658ce52f094dd86
Parents: fdbadfc a3b5f96
Author: Eugene Kirpichov <ki...@google.com>
Authored: Fri Apr 14 23:54:59 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Fri Apr 14 23:54:59 2017 -0700
----------------------------------------------------------------------
.../operators/ApexGroupByKeyOperator.java | 225 ++++---------
.../beam/runners/core/AssignWindowsDoFn.java | 78 -----
.../apache/beam/runners/core/DoFnAdapters.java | 328 -------------------
.../apache/beam/runners/core/DoFnRunners.java | 2 +-
.../GroupAlsoByWindowViaOutputBufferDoFn.java | 17 +-
.../core/GroupAlsoByWindowViaWindowSetDoFn.java | 7 +-
.../GroupAlsoByWindowViaWindowSetNewDoFn.java | 11 +-
.../core/GroupAlsoByWindowsAggregators.java | 28 ++
.../runners/core/GroupAlsoByWindowsDoFn.java | 46 ---
.../core/LateDataDroppingDoFnRunner.java | 3 +-
...roupAlsoByWindowViaOutputBufferDoFnTest.java | 4 +-
.../core/GroupAlsoByWindowsProperties.java | 27 +-
.../beam/runners/core/ReduceFnTester.java | 3 +-
.../GroupAlsoByWindowEvaluatorFactory.java | 6 +-
.../SparkGroupAlsoByWindowViaWindowSet.java | 9 +-
.../spark/translation/SparkAssignWindowFn.java | 3 +-
...SparkGroupAlsoByWindowViaOutputBufferFn.java | 8 +-
17 files changed, 148 insertions(+), 657 deletions(-)
----------------------------------------------------------------------