You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2017/02/22 00:05:00 UTC
[3/3] beam git commit: This closes #2051
This closes #2051
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c3141ed9
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c3141ed9
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c3141ed9
Branch: refs/heads/master
Commit: c3141ed99ec467dcf577a1ba9d46f80a694444db
Parents: 2982238 22f3fb8
Author: Ahmet Altay <al...@google.com>
Authored: Tue Feb 21 16:04:47 2017 -0800
Committer: Ahmet Altay <al...@google.com>
Committed: Tue Feb 21 16:04:47 2017 -0800
----------------------------------------------------------------------
.../examples/cookbook/datastore_wordcount.py | 4 +-
.../examples/snippets/snippets_test.py | 18 +++
.../internal/google_cloud_platform/__init__.py | 16 ++
.../google_cloud_platform/json_value.py | 147 +++++++++++++++++++
.../google_cloud_platform/json_value_test.py | 93 ++++++++++++
sdks/python/apache_beam/internal/json_value.py | 141 ------------------
.../apache_beam/internal/json_value_test.py | 84 -----------
sdks/python/apache_beam/io/__init__.py | 11 +-
sdks/python/apache_beam/io/fileio.py | 21 ++-
.../io/google_cloud_platform/bigquery.py | 9 +-
.../io/google_cloud_platform/bigquery_test.py | 19 ++-
.../datastore/v1/datastoreio.py | 10 +-
.../datastore/v1/datastoreio_test.py | 16 +-
.../datastore/v1/fake_datastore.py | 10 +-
.../datastore/v1/helper.py | 23 ++-
.../datastore/v1/helper_test.py | 21 ++-
.../datastore/v1/query_splitter.py | 26 ++--
.../datastore/v1/query_splitter_test.py | 17 ++-
.../io/google_cloud_platform/gcsio_test.py | 12 +-
.../internal/clients/bigquery/__init__.py | 12 +-
.../internal/clients/storage/__init__.py | 12 +-
sdks/python/apache_beam/runners/__init__.py | 5 +-
.../google_cloud_dataflow/dataflow_runner.py | 2 +-
.../dataflow_runner_test.py | 9 ++
.../google_cloud_dataflow/internal/apiclient.py | 2 +-
.../internal/apiclient_test.py | 13 +-
.../internal/clients/dataflow/__init__.py | 12 +-
.../clients/dataflow/message_matchers_test.py | 14 +-
.../template_runner_test.py | 13 +-
.../test_dataflow_runner.py | 40 +++++
sdks/python/apache_beam/runners/runner_test.py | 31 ++--
.../python/apache_beam/runners/test/__init__.py | 8 +-
.../runners/test/test_dataflow_runner.py | 40 -----
.../apache_beam/tests/pipeline_verifiers.py | 10 +-
.../tests/pipeline_verifiers_test.py | 7 +-
sdks/python/apache_beam/utils/retry.py | 13 +-
sdks/python/apache_beam/utils/retry_test.py | 14 +-
sdks/python/pom.xml | 2 +-
sdks/python/setup.py | 20 ++-
sdks/python/tox.ini | 37 ++++-
40 files changed, 643 insertions(+), 371 deletions(-)
----------------------------------------------------------------------