Repository: incubator-beam Updated Branches: refs/heads/master 529f266ae -> 522469330
This closes #1225 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/52246933 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/52246933 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/52246933 Branch: refs/heads/master Commit: 522469330dff8a65ff2e3d9b411c00a42c031864 Parents: 529f266 e77d881 Author: Thomas Groh <[email protected]> Authored: Wed Nov 2 10:18:59 2016 -0700 Committer: Thomas Groh <[email protected]> Committed: Wed Nov 2 10:18:59 2016 -0700 ---------------------------------------------------------------------- .../core/GroupByKeyViaGroupByKeyOnly.java | 13 ++-- ...ectGBKIntoKeyedWorkItemsOverrideFactory.java | 2 - .../beam/runners/direct/DirectGroupByKey.java | 42 ++++++------- .../GroupAlsoByWindowEvaluatorFactory.java | 4 +- .../direct/GroupByKeyOnlyEvaluatorFactory.java | 31 +++++----- .../beam/runners/direct/ParDoEvaluator.java | 5 +- .../direct/ParDoMultiEvaluatorHooks.java | 1 + .../direct/ParDoSingleEvaluatorHooks.java | 1 + .../direct/GroupByKeyEvaluatorFactoryTest.java | 29 ++++----- .../GroupByKeyOnlyEvaluatorFactoryTest.java | 31 +++++----- .../beam/runners/direct/ParDoEvaluatorTest.java | 5 +- .../apache/beam/sdk/util/GatherAllPanes.java | 18 +++++- .../sdk/util/ReifyTimestampAndWindowsDoFn.java | 41 ------------- .../sdk/util/ReifyTimestampsAndWindows.java | 63 -------------------- 14 files changed, 94 insertions(+), 192 deletions(-) ----------------------------------------------------------------------
