This closes #697
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7809f6bd Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7809f6bd Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/7809f6bd Branch: refs/heads/master Commit: 7809f6bd2cd3605ce389a174aba242ea08860f88 Parents: cf14644 902997d Author: Kenneth Knowles <[email protected]> Authored: Mon Jul 25 12:11:27 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Mon Jul 25 12:11:27 2016 -0700 ---------------------------------------------------------------------- .../core/GroupAlsoByWindowViaWindowSetDoFn.java | 16 ++-- .../beam/sdk/util/GroupAlsoByWindowsDoFn.java | 10 ++- .../GroupAlsoByWindowsViaOutputBufferDoFn.java | 10 +-- .../sdk/util/GroupByKeyViaGroupByKeyOnly.java | 79 +++++++++++++++++--- .../sdk/util/GroupAlsoByWindowsProperties.java | 50 +++++++++++-- ...oupAlsoByWindowsViaOutputBufferDoFnTest.java | 8 +- .../GroupAlsoByWindowEvaluatorFactory.java | 30 ++++++++ .../beam/runners/direct/ParDoEvaluator.java | 4 +- .../direct/ParDoMultiEvaluatorFactory.java | 6 ++ .../direct/ParDoSingleEvaluatorFactory.java | 6 ++ .../direct/WriteWithShardingFactory.java | 7 +- .../beam/runners/direct/ParDoEvaluatorTest.java | 1 + .../FlinkGroupAlsoByWindowWrapper.java | 31 +++++--- .../spark/translation/TransformTranslator.java | 70 ++++++++++++++++- .../apache/beam/sdk/transforms/DoFnTester.java | 41 +++++++++- .../sdk/util/state/StateInternalsFactory.java | 36 +++++++++ 16 files changed, 349 insertions(+), 56 deletions(-) ----------------------------------------------------------------------
