beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From al...@apache.org
Subject [2/2] beam git commit: This closes #3041
Date Wed, 10 May 2017 15:32:02 GMT
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 <altay@google.com>
Authored: Wed May 10 08:31:41 2017 -0700
Committer: Ahmet Altay <altay@google.com>
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(-)
----------------------------------------------------------------------



Mime
View raw message