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/08/04 00:46:04 UTC

[4/4] incubator-beam git commit: This closes #754

This closes #754


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

Branch: refs/heads/master
Commit: 23fa61ce0ce91371134b54618d2fc6ba0c84ef30
Parents: 636b5f7 8e7963f
Author: Kenneth Knowles <kl...@google.com>
Authored: Wed Aug 3 17:45:46 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Wed Aug 3 17:45:46 2016 -0700

----------------------------------------------------------------------
 .../beam/runners/direct/CommittedResult.java    |  23 ++-
 .../beam/runners/direct/CompletionCallback.java |   8 +
 .../beam/runners/direct/EvaluationContext.java  |  11 +-
 .../direct/ExecutorServiceParallelExecutor.java | 163 ++++++++++++-------
 .../runners/direct/StepTransformResult.java     |  20 ++-
 .../beam/runners/direct/TransformExecutor.java  |   1 +
 .../beam/runners/direct/TransformResult.java    |  11 ++
 .../runners/direct/ViewEvaluatorFactory.java    |   9 +-
 .../runners/direct/CommittedResultTest.java     |  26 ++-
 .../runners/direct/EvaluationContextTest.java   |   3 +
 .../runners/direct/StepTransformResultTest.java |  91 +++++++++++
 .../runners/direct/TransformExecutorTest.java   |  33 +++-
 .../runners/direct/WatermarkManagerTest.java    |  11 +-
 13 files changed, 336 insertions(+), 74 deletions(-)
----------------------------------------------------------------------