Repository: beam Updated Branches: refs/heads/master 714fdd292 -> 29e054a8d
This closes #2587 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/29e054a8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/29e054a8 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/29e054a8 Branch: refs/heads/master Commit: 29e054a8d7ffe6a061dbbe9a1885185b02f4e8ec Parents: 714fdd2 418c304 Author: Thomas Groh <tg...@google.com> Authored: Wed Apr 19 10:53:30 2017 -0700 Committer: Thomas Groh <tg...@google.com> Committed: Wed Apr 19 10:53:30 2017 -0700 ---------------------------------------------------------------------- .../core/construction/UnconsumedReads.java | 72 +++++++++++++ .../core/construction/UnconsumedReadsTest.java | 105 +++++++++++++++++++ .../beam/runners/dataflow/DataflowRunner.java | 4 + .../runners/dataflow/DataflowRunnerTest.java | 24 +++++ 4 files changed, 205 insertions(+) ----------------------------------------------------------------------
