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/05/18 20:08:41 UTC
[41/50] [abbrv] beam git commit: This closes #3125
This closes #3125
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f314ab3c
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f314ab3c
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f314ab3c
Branch: refs/heads/gearpump-runner
Commit: f314ab3ce7536eb0274a571cd4baa1c15afc93a5
Parents: 32fd49a 2417949
Author: Eugene Kirpichov <ki...@google.com>
Authored: Tue May 16 11:55:58 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Tue May 16 11:55:58 2017 -0700
----------------------------------------------------------------------
.../beam/runners/core/AssignWindowsDoFn.java | 78 --
.../apache/beam/runners/core/DoFnAdapters.java | 381 ----------
.../apache/beam/runners/core/DoFnRunners.java | 27 +-
.../GroupAlsoByWindowViaOutputBufferDoFn.java | 113 ---
.../core/GroupAlsoByWindowViaWindowSetDoFn.java | 94 ---
.../GroupAlsoByWindowViaWindowSetNewDoFn.java | 6 +-
.../core/GroupAlsoByWindowsAggregators.java | 26 +
.../runners/core/GroupAlsoByWindowsDoFn.java | 39 -
.../core/LateDataDroppingDoFnRunner.java | 3 +-
.../org/apache/beam/runners/core/OldDoFn.java | 335 ---------
.../beam/runners/core/SimpleDoFnRunner.java | 2 +-
.../beam/runners/core/SimpleOldDoFnRunner.java | 499 -------------
.../core/WindowingInternalsAdapters.java | 74 --
...roupAlsoByWindowViaOutputBufferDoFnTest.java | 109 ---
.../core/GroupAlsoByWindowsProperties.java | 744 -------------------
.../apache/beam/runners/core/NoOpOldDoFn.java | 65 --
.../apache/beam/runners/core/OldDoFnTest.java | 51 --
.../runners/core/SimpleOldDoFnRunnerTest.java | 86 ---
.../GroupAlsoByWindowEvaluatorFactory.java | 6 +-
runners/google-cloud-dataflow-java/pom.xml | 2 +-
.../SparkGroupAlsoByWindowViaWindowSet.java | 9 +-
.../spark/translation/SparkAssignWindowFn.java | 4 +-
...SparkGroupAlsoByWindowViaOutputBufferFn.java | 4 +-
23 files changed, 45 insertions(+), 2712 deletions(-)
----------------------------------------------------------------------