You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ch...@apache.org on 2017/05/10 08:45:19 UTC
[2/2] beam git commit: This closes #3036
This closes #3036
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1fafaa84
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1fafaa84
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1fafaa84
Branch: refs/heads/master
Commit: 1fafaa8465f88b17dc565cbfd1eb94f2e20c52ff
Parents: b1a2dbe cc3d07a
Author: chamikara@google.com <ch...@google.com>
Authored: Wed May 10 01:44:56 2017 -0700
Committer: chamikara@google.com <ch...@google.com>
Committed: Wed May 10 01:44:56 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(-)
----------------------------------------------------------------------