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/18 18:54:24 UTC
[2/2] beam git commit: This closes #2580
This closes #2580
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4124cc68
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4124cc68
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4124cc68
Branch: refs/heads/master
Commit: 4124cc6878d3b28a6a6367ef8cf854f76c85d9ef
Parents: 8f4bb01 d357aea
Author: Eugene Kirpichov <ki...@google.com>
Authored: Tue Apr 18 11:53:56 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Tue Apr 18 11:53:56 2017 -0700
----------------------------------------------------------------------
.../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 +-
16 files changed, 495 insertions(+), 85 deletions(-)
----------------------------------------------------------------------