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/04/14 20:06:52 UTC
[3/3] beam git commit: This closes #2539
This closes #2539
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/89ff0b14
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/89ff0b14
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/89ff0b14
Branch: refs/heads/master
Commit: 89ff0b145fac64ec6f5a38d8df708d226890c7ac
Parents: cf9ac45 bd79f4d
Author: Ahmet Altay <al...@altay-macbookpro2.roam.corp.google.com>
Authored: Fri Apr 14 13:06:32 2017 -0700
Committer: Ahmet Altay <al...@altay-macbookpro2.roam.corp.google.com>
Committed: Fri Apr 14 13:06:32 2017 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/io/concat_source.py | 74 +++++++++-----------
.../apache_beam/io/filebasedsource_test.py | 2 +-
sdks/python/apache_beam/io/fileio.py | 6 +-
sdks/python/apache_beam/io/filesystems_util.py | 3 +-
sdks/python/apache_beam/io/gcp/bigquery.py | 13 ++--
.../io/gcp/datastore/v1/datastoreio.py | 4 +-
.../apache_beam/io/gcp/datastore/v1/helper.py | 16 ++---
.../io/gcp/datastore/v1/query_splitter.py | 2 +-
sdks/python/apache_beam/io/gcp/gcsfilesystem.py | 3 +-
.../io/gcp/tests/bigquery_matcher.py | 3 +-
sdks/python/apache_beam/io/iobase.py | 7 +-
sdks/python/apache_beam/io/localfilesystem.py | 3 +-
sdks/python/apache_beam/io/range_trackers.py | 19 +++--
sdks/python/apache_beam/io/source_test_utils.py | 7 +-
sdks/python/apache_beam/io/textio.py | 13 ++--
sdks/python/apache_beam/metrics/cells.py | 28 ++++----
sdks/python/apache_beam/metrics/execution.py | 3 +-
sdks/python/apache_beam/metrics/metric.py | 9 +--
sdks/python/apache_beam/runners/common.py | 9 +--
.../runners/dataflow/dataflow_metrics_test.py | 3 +-
.../runners/dataflow/dataflow_runner.py | 6 +-
.../runners/dataflow/internal/apiclient.py | 8 +--
.../runners/dataflow/internal/dependency.py | 6 +-
.../runners/dataflow/test_dataflow_runner.py | 4 --
.../runners/direct/bundle_factory.py | 14 ++--
.../runners/direct/evaluation_context.py | 10 +--
.../apache_beam/runners/direct/executor.py | 9 +--
.../runners/direct/transform_evaluator.py | 7 --
sdks/python/apache_beam/runners/runner.py | 3 +-
.../apache_beam/tests/pipeline_verifiers.py | 7 +-
sdks/python/apache_beam/transforms/combiners.py | 58 +++++++--------
.../apache_beam/transforms/combiners_test.py | 4 +-
sdks/python/apache_beam/typehints/decorators.py | 3 +-
sdks/python/apache_beam/typehints/typehints.py | 3 +-
34 files changed, 149 insertions(+), 220 deletions(-)
----------------------------------------------------------------------