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