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(-)
----------------------------------------------------------------------


Reply via email to