[2/2] incubator-beam git commit: [BEAM-961] This closes #1505

[jbonofre]

[BEAM-961] This closes #1505


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/493c04fa
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/493c04fa
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/493c04fa

Branch: refs/heads/master
Commit: 493c04faa12b8bb7483e5805bd4eb4e3280feaca
Parents: 1efda59 41ae08b
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Authored: Tue Dec 6 11:17:02 2016 +0100
Committer: Jean-Baptiste Onofré <jbono...@apache.org>
Committed: Tue Dec 6 11:17:02 2016 +0100

----------------------------------------------------------------------
 .../org/apache/beam/sdk/io/CountingInput.java   | 42 ++++++++++++++++----
 .../org/apache/beam/sdk/io/CountingSource.java  | 11 +++++
 .../apache/beam/sdk/io/CountingInputTest.java   | 42 +++++++++++++++-----
 3 files changed, 76 insertions(+), 19 deletions(-)
----------------------------------------------------------------------