Closes #955
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/753cc9c2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/753cc9c2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/753cc9c2 Branch: refs/heads/python-sdk Commit: 753cc9c2e432beb4175902b28b3f9f788bc87f14 Parents: 0fa9c4b d189f83 Author: Robert Bradshaw <rober...@google.com> Authored: Fri Sep 23 13:50:02 2016 -0700 Committer: Robert Bradshaw <rober...@google.com> Committed: Fri Sep 23 13:50:02 2016 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/io/concat_source.py | 264 +++++++++++++++++++ .../python/apache_beam/io/concat_source_test.py | 222 ++++++++++++++++ sdks/python/apache_beam/io/filebasedsource.py | 81 +----- .../apache_beam/io/filebasedsource_test.py | 12 +- sdks/python/apache_beam/io/iobase.py | 4 +- sdks/python/apache_beam/io/range_trackers.py | 2 +- sdks/python/apache_beam/io/source_test_utils.py | 27 +- sdks/python/apache_beam/io/sources_test.py | 1 + 8 files changed, 521 insertions(+), 92 deletions(-) ----------------------------------------------------------------------
