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 <kirpic...@google.com> Authored: Tue May 16 11:55:58 2017 -0700 Committer: Eugene Kirpichov <kirpic...@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(-) ----------------------------------------------------------------------