This closes #1461
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/26eb4354 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/26eb4354 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/26eb4354 Branch: refs/heads/gearpump-runner Commit: 26eb4354cab72b7c482d8868c99eeb5933fd797e Parents: e04cd47 86173a8 Author: Kenneth Knowles <[email protected]> Authored: Fri Dec 2 15:42:33 2016 -0800 Committer: Kenneth Knowles <[email protected]> Committed: Fri Dec 2 15:42:33 2016 -0800 ---------------------------------------------------------------------- .../GroupAlsoByWindowsViaOutputBufferDoFn.java | 6 +- .../core/GroupByKeyViaGroupByKeyOnly.java | 22 +- .../core/GroupAlsoByWindowsProperties.java | 590 +++++++++++-------- .../beam/sdk/transforms/DoFnAdapters.java | 2 + .../apache/beam/sdk/transforms/DoFnTester.java | 279 +++++---- .../sdk/transforms/reflect/DoFnInvokers.java | 11 - .../beam/sdk/transforms/DoFnTesterTest.java | 38 +- 7 files changed, 536 insertions(+), 412 deletions(-) ----------------------------------------------------------------------
