You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2016/10/10 19:05:15 UTC
[6/6] incubator-beam git commit: Closes #1067
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 <ro...@google.com>
Authored: Mon Oct 10 12:04:52 2016 -0700
Committer: Robert Bradshaw <ro...@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(-)
----------------------------------------------------------------------