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 2017/04/21 17:53:12 UTC
[28/50] [abbrv] beam git commit: This closes #2587
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 <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(+)
----------------------------------------------------------------------