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/05/10 17:14:42 UTC
[2/2] incubator-beam git commit: This closes #310
This closes #310
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7c917a6e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7c917a6e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/7c917a6e
Branch: refs/heads/master
Commit: 7c917a6eecb7c7706ff9b6664cd46bb7e13a00f3
Parents: 9feea23 2d94540
Author: Kenneth Knowles <kl...@google.com>
Authored: Tue May 10 10:14:28 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Tue May 10 10:14:28 2016 -0700
----------------------------------------------------------------------
.../runners/direct/BoundedReadEvaluatorFactory.java | 8 ++------
.../runners/direct/TransformEvaluatorFactory.java | 10 ++++++++--
.../beam/runners/direct/TransformExecutor.java | 9 ++++++---
.../direct/UnboundedReadEvaluatorFactory.java | 8 ++------
.../direct/BoundedReadEvaluatorFactoryTest.java | 16 +++-------------
.../direct/TransformExecutorServicesTest.java | 10 +++++-----
.../beam/runners/direct/TransformExecutorTest.java | 8 ++++----
.../direct/UnboundedReadEvaluatorFactoryTest.java | 13 ++++---------
8 files changed, 34 insertions(+), 48 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/7c917a6e/runners/direct-java/src/main/java/org/apache/beam/runners/direct/UnboundedReadEvaluatorFactory.java
----------------------------------------------------------------------