This closes #3041
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d11e9646 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d11e9646 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d11e9646 Branch: refs/heads/release-2.0.0 Commit: d11e96466471c9616c08aa96f287c69b740a8e3c Parents: ac9ce0f c1d7e54 Author: Ahmet Altay <[email protected]> Authored: Wed May 10 08:31:41 2017 -0700 Committer: Ahmet Altay <[email protected]> Committed: Wed May 10 08:31:41 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/coders/coder_impl.py | 57 ++++++++++++---- sdks/python/apache_beam/coders/observable.py | 4 +- sdks/python/apache_beam/coders/slow_stream.py | 16 +++-- sdks/python/apache_beam/coders/typecoders.py | 4 +- sdks/python/apache_beam/internal/gcp/auth.py | 18 +++-- .../apache_beam/internal/gcp/json_value.py | 12 +++- sdks/python/apache_beam/internal/pickler.py | 26 ++++--- sdks/python/apache_beam/internal/util.py | 16 +++-- sdks/python/apache_beam/io/concat_source.py | 8 ++- sdks/python/apache_beam/metrics/cells.py | 32 ++++++--- sdks/python/apache_beam/metrics/execution.py | 7 +- .../apache_beam/runners/api/beam_fn_api_pb2.py | 2 + .../runners/api/beam_fn_api_pb2_grpc.py | 2 + .../runners/api/beam_runner_api_pb2.py | 2 + sdks/python/apache_beam/runners/common.pxd | 4 +- sdks/python/apache_beam/runners/common.py | 28 +++++--- .../runners/dataflow/internal/apiclient.py | 4 +- .../runners/dataflow/internal/dependency.py | 16 +++-- .../runners/dataflow/internal/names.py | 8 ++- .../runners/dataflow/native_io/iobase.py | 2 + .../runners/direct/bundle_factory.py | 16 +++-- sdks/python/apache_beam/runners/direct/clock.py | 5 +- .../consumer_tracking_pipeline_visitor.py | 4 +- .../apache_beam/runners/direct/executor.py | 63 +++++++++-------- .../runners/direct/transform_evaluator.py | 8 ++- .../runners/direct/transform_result.py | 4 +- .../runners/direct/watermark_manager.py | 10 +-- .../apache_beam/runners/pipeline_context.py | 4 +- .../runners/portability/fn_api_runner.py | 2 + .../portability/maptask_executor_runner.py | 2 + sdks/python/apache_beam/runners/runner.py | 8 ++- .../apache_beam/runners/worker/data_plane.py | 2 + .../apache_beam/runners/worker/log_handler.py | 2 + .../python/apache_beam/runners/worker/logger.py | 2 + .../apache_beam/runners/worker/opcounters.py | 2 + .../runners/worker/operation_specs.py | 2 + .../apache_beam/runners/worker/sdk_worker.py | 4 ++ .../runners/worker/sdk_worker_main.py | 2 + .../apache_beam/runners/worker/sideinputs.py | 2 + .../runners/worker/statesampler_fake.py | 2 + sdks/python/apache_beam/transforms/core.py | 12 +++- .../python/apache_beam/transforms/ptransform.py | 14 ++-- sdks/python/apache_beam/transforms/trigger.py | 72 ++++++++++---------- 43 files changed, 346 insertions(+), 166 deletions(-) ----------------------------------------------------------------------
