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/jstorm-runner Commit: f7d727c0f7ada7a162f5cb73f658ce52f094dd86 Parents: fdbadfc a3b5f96 Author: Eugene Kirpichov <[email protected]> Authored: Fri Apr 14 23:54:59 2017 -0700 Committer: Eugene Kirpichov <[email protected]> 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(-) ----------------------------------------------------------------------
