This closes #1254
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/938ac91a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/938ac91a Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/938ac91a Branch: refs/heads/master Commit: 938ac91a91eb886b013e9e54899a6afd07fe3d9e Parents: dc94dbd fc80ba5 Author: Thomas Groh <tg...@google.com> Authored: Wed Nov 16 09:38:36 2016 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Wed Nov 16 09:38:36 2016 -0800 ---------------------------------------------------------------------- .../direct/BoundedReadEvaluatorFactory.java | 82 ++++++++- .../runners/direct/StepTransformResult.java | 6 + .../direct/BoundedReadEvaluatorFactoryTest.java | 184 +++++++++++++++++-- 3 files changed, 247 insertions(+), 25 deletions(-) ----------------------------------------------------------------------