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/gearpump-runner Commit: 29e054a8d7ffe6a061dbbe9a1885185b02f4e8ec Parents: 714fdd2 418c304 Author: Thomas Groh <[email protected]> Authored: Wed Apr 19 10:53:30 2017 -0700 Committer: Thomas Groh <[email protected]> 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(+) ----------------------------------------------------------------------
