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/jstorm-runner 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(-) ----------------------------------------------------------------------
