beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [4/4] incubator-beam git commit: This closes #283
Date Mon, 09 May 2016 18:46:57 GMT
This closes #283


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

Branch: refs/heads/master
Commit: 272493ed7c86b81f3573ea341f6a2ff138da9800
Parents: da1b755 0518fc6
Author: Kenneth Knowles <klk@google.com>
Authored: Mon May 9 11:46:21 2016 -0700
Committer: Kenneth Knowles <klk@google.com>
Committed: Mon May 9 11:46:21 2016 -0700

----------------------------------------------------------------------
 .../beam/runners/direct/CommittedResult.java    |  16 ++-
 .../direct/ExecutorServiceParallelExecutor.java |  65 +++++-----
 .../direct/InMemoryWatermarkManager.java        |   7 +-
 .../direct/InProcessEvaluationContext.java      |   6 +-
 .../direct/InProcessTransformResult.java        |   7 +
 .../runners/direct/StepTransformResult.java     |  17 +++
 .../runners/direct/CommittedResultTest.java     |  34 ++++-
 .../direct/InMemoryWatermarkManagerTest.java    | 127 ++++++++++++++++---
 .../runners/direct/TransformExecutorTest.java   |  11 +-
 9 files changed, 239 insertions(+), 51 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/272493ed/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/272493ed/runners/direct-java/src/main/java/org/apache/beam/runners/direct/InProcessEvaluationContext.java
----------------------------------------------------------------------


Mime
View raw message