This closes #2993
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/90103141 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/90103141 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/90103141 Branch: refs/heads/release-2.0.0 Commit: 901031419d722fbc6e1bbea98b0f721a6bb4f184 Parents: 15610e6 d35a645 Author: Thomas Groh <tg...@google.com> Authored: Tue May 9 12:47:32 2017 -0700 Committer: Thomas Groh <tg...@google.com> Committed: Tue May 9 12:47:32 2017 -0700 ---------------------------------------------------------------------- runners/direct-java/pom.xml | 79 ++++++++++++++++++-- .../beam/runners/direct/CompletionCallback.java | 6 ++ .../direct/ExecutorServiceParallelExecutor.java | 27 +++++-- .../GroupAlsoByWindowEvaluatorFactory.java | 6 +- .../beam/runners/direct/TransformExecutor.java | 12 ++- .../direct/DirectRunnerApiSurfaceTest.java | 55 ++++++++++++++ .../apache/beam/runners/direct/MockClock.java | 2 +- .../runners/direct/TransformExecutorTest.java | 5 ++ 8 files changed, 176 insertions(+), 16 deletions(-) ----------------------------------------------------------------------
