You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2016/05/20 23:57:39 UTC
[2/2] incubator-beam git commit: This closes #353
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 <dh...@google.com>
Authored: Fri May 20 16:55:57 2016 -0700
Committer: Dan Halperin <dh...@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(-)
----------------------------------------------------------------------