This closes #3111
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/36a6cd69 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/36a6cd69 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/36a6cd69 Branch: refs/heads/master Commit: 36a6cd69aa01b7e122e6e84ff1218adc7ba059c9 Parents: 652fcb7 2f17782 Author: Ahmet Altay <al...@google.com> Authored: Thu May 11 18:04:24 2017 -0700 Committer: Ahmet Altay <al...@google.com> Committed: Thu May 11 18:04:24 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/io/__init__.py | 2 +- sdks/python/apache_beam/io/avroio.py | 4 +- sdks/python/apache_beam/io/filebasedsink.py | 299 ++++++++++++++++++ .../python/apache_beam/io/filebasedsink_test.py | 303 ++++++++++++++++++ sdks/python/apache_beam/io/fileio.py | 304 ------------------- sdks/python/apache_beam/io/fileio_test.py | 303 ------------------ sdks/python/apache_beam/io/gcp/gcsio.py | 6 +- sdks/python/apache_beam/io/iobase.py | 12 +- sdks/python/apache_beam/io/textio.py | 4 +- sdks/python/apache_beam/io/tfrecordio.py | 6 +- .../apache_beam/testing/pipeline_verifiers.py | 4 +- 11 files changed, 623 insertions(+), 624 deletions(-) ----------------------------------------------------------------------
