Repository: beam Updated Branches: refs/heads/master a94d680ea -> 1f2634d23
This closes #3579 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1f2634d2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1f2634d2 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1f2634d2 Branch: refs/heads/master Commit: 1f2634d23bfa5b32d88cef236f2080df79e5e47d Parents: a94d680 6ea2eda Author: Thomas Groh <[email protected]> Authored: Fri Jul 28 15:25:11 2017 -0700 Committer: Thomas Groh <[email protected]> Committed: Fri Jul 28 15:25:11 2017 -0700 ---------------------------------------------------------------------- .../beam/runners/direct/DirectRunner.java | 65 +-- .../beam/runners/direct/MultiStepCombine.java | 423 +++++++++++++++++++ .../direct/TransformEvaluatorRegistry.java | 4 + .../runners/direct/MultiStepCombineTest.java | 228 ++++++++++ 4 files changed, 690 insertions(+), 30 deletions(-) ----------------------------------------------------------------------
