This closes #3661
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9088a3e3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9088a3e3 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9088a3e3 Branch: refs/heads/master Commit: 9088a3e39e79f0b931fd3eec629df1c5e6ef6911 Parents: 4e01fc1 5e99853 Author: chamik...@google.com <chamik...@google.com> Authored: Thu Aug 10 13:39:05 2017 -0700 Committer: chamik...@google.com <chamik...@google.com> Committed: Thu Aug 10 13:39:05 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/io/avroio.py | 103 ++++++++---- sdks/python/apache_beam/io/avroio_test.py | 33 +++- sdks/python/apache_beam/io/filebasedsource.py | 165 ++++++++++++++++--- sdks/python/apache_beam/io/range_trackers.py | 42 +++++ .../apache_beam/io/range_trackers_test.py | 37 +++++ sdks/python/apache_beam/io/textio.py | 82 ++++++++- sdks/python/apache_beam/io/textio_test.py | 95 ++++++++++- 7 files changed, 495 insertions(+), 62 deletions(-) ----------------------------------------------------------------------
