This closes #2714
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/72b361e9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/72b361e9 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/72b361e9 Branch: refs/heads/master Commit: 72b361e9af1a21bc965408da392a2490e5985f0c Parents: 28180c4 b0a3261 Author: Dan Halperin <[email protected]> Authored: Tue May 9 11:49:17 2017 -0700 Committer: Dan Halperin <[email protected]> Committed: Tue May 9 11:49:17 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(-) ----------------------------------------------------------------------
