This closes #353
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4755c5a7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4755c5a7 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/4755c5a7 Branch: refs/heads/master Commit: 4755c5a784d628bdbfc67e4870d231252381ae6e Parents: efd1f95 32a6cde Author: Dan Halperin <dhalp...@google.com> Authored: Fri May 20 16:55:57 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Fri May 20 16:55:57 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/io/AvroSource.java | 166 ++++++++++++------- .../apache/beam/sdk/io/BlockBasedSource.java | 26 +-- .../org/apache/beam/sdk/io/BoundedSource.java | 145 +++++++++++++++- .../apache/beam/sdk/io/CompressedSource.java | 132 +++++++++++++-- .../org/apache/beam/sdk/io/CountingSource.java | 5 + .../org/apache/beam/sdk/io/DatastoreIO.java | 13 ++ .../org/apache/beam/sdk/io/FileBasedSource.java | 2 +- .../apache/beam/sdk/io/OffsetBasedSource.java | 49 +++++- .../java/org/apache/beam/sdk/io/TextIO.java | 20 ++- .../beam/sdk/io/range/OffsetRangeTracker.java | 109 ++++++++++-- .../org/apache/beam/sdk/io/AvroSourceTest.java | 86 +++++++++- .../beam/sdk/io/CompressedSourceTest.java | 107 +++++++++++- .../apache/beam/sdk/io/CountingSourceTest.java | 30 ++++ .../apache/beam/sdk/io/FileBasedSourceTest.java | 2 +- .../beam/sdk/io/OffsetBasedSourceTest.java | 71 +++++++- .../java/org/apache/beam/sdk/io/TextIOTest.java | 114 ++++++++++++- .../sdk/io/range/OffsetRangeTrackerTest.java | 1 - .../apache/beam/sdk/io/hdfs/HDFSFileSource.java | 12 ++ 18 files changed, 969 insertions(+), 121 deletions(-) ----------------------------------------------------------------------
