You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2016/12/09 02:41:54 UTC
[2/2] incubator-beam git commit: Add support for having an empty
CountingInput/CountingSource
Add support for having an empty CountingInput/CountingSource
This closes #1557
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ddb59125
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ddb59125
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/ddb59125
Branch: refs/heads/master
Commit: ddb59125aeacb809b7695c203fe8b1a40e36aed2
Parents: 40bd276 30ff1ee
Author: Luke Cwik <lc...@google.com>
Authored: Thu Dec 8 18:41:42 2016 -0800
Committer: Luke Cwik <lc...@google.com>
Committed: Thu Dec 8 18:41:42 2016 -0800
----------------------------------------------------------------------
.../org/apache/beam/sdk/io/CountingInput.java | 12 ++++++----
.../org/apache/beam/sdk/io/CountingSource.java | 12 ++++++----
.../apache/beam/sdk/io/CountingInputTest.java | 23 +++++++++++++++++++-
.../apache/beam/sdk/io/CountingSourceTest.java | 10 +++++++++
4 files changed, 48 insertions(+), 9 deletions(-)
----------------------------------------------------------------------