beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [2/2] incubator-beam git commit: This closes #310
Date Tue, 10 May 2016 17:14:42 GMT
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 <klk@google.com>
Authored: Tue May 10 10:14:28 2016 -0700
Committer: Kenneth Knowles <klk@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
----------------------------------------------------------------------


Mime
View raw message