You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ke...@apache.org on 2016/03/18 04:38:12 UTC

[2/2] incubator-beam git commit: This closes #53

This closes #53


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d3934682
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d3934682
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/d3934682

Branch: refs/heads/master
Commit: d3934682313b41688536599da7c19831335f3960
Parents: c303260 636d53a
Author: Kenneth Knowles <kl...@google.com>
Authored: Thu Mar 17 20:37:59 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Thu Mar 17 20:37:59 2016 -0700

----------------------------------------------------------------------
 .../runners/inprocess/CompletionCallback.java   |  33 ++
 .../ExecutorServiceParallelExecutor.java        | 394 +++++++++++++++++++
 .../inprocess/InMemoryWatermarkManager.java     |   2 +-
 .../inprocess/InProcessEvaluationContext.java   |  21 +-
 .../runners/inprocess/InProcessExecutor.java    |  46 +++
 .../inprocess/InProcessPipelineOptions.java     |   7 +-
 .../inprocess/InProcessPipelineRunner.java      |  25 --
 .../runners/inprocess/TransformExecutor.java    | 114 ++++++
 .../inprocess/TransformExecutorService.java     |  34 ++
 .../inprocess/TransformExecutorServices.java    | 153 +++++++
 .../TransformExecutorServicesTest.java          | 134 +++++++
 .../inprocess/TransformExecutorTest.java        | 312 +++++++++++++++
 12 files changed, 1247 insertions(+), 28 deletions(-)
----------------------------------------------------------------------