Closes #1067
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fd27f684 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fd27f684 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/fd27f684 Branch: refs/heads/python-sdk Commit: fd27f6848d5f5b6096c1538bcfeacb5beaf0068f Parents: 90004a0 893fa2d Author: Robert Bradshaw <rober...@google.com> Authored: Mon Oct 10 12:04:52 2016 -0700 Committer: Robert Bradshaw <rober...@google.com> Committed: Mon Oct 10 12:04:52 2016 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/io/bigquery.py | 10 +- sdks/python/apache_beam/io/fileio.py | 17 +- sdks/python/apache_beam/io/fileio_test.py | 74 ++--- sdks/python/apache_beam/io/iobase.py | 299 +----------------- sdks/python/apache_beam/io/pubsub.py | 6 +- sdks/python/apache_beam/pipeline_test.py | 2 +- .../apache_beam/runners/dataflow/__init__.py | 0 .../runners/dataflow/native_io/__init__.py | 0 .../runners/dataflow/native_io/iobase.py | 310 +++++++++++++++++++ .../python/apache_beam/runners/direct_runner.py | 9 +- .../runners/inprocess/transform_evaluator.py | 5 +- 11 files changed, 385 insertions(+), 347 deletions(-) ----------------------------------------------------------------------