You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ud...@apache.org on 2019/12/13 01:10:48 UTC
[beam] 01/01: Merge pull request #10330: [BEAM-8882] Cherry pick
#10283 and #10292
This is an automated email from the ASF dual-hosted git repository.
udim pushed a commit to branch release-2.18.0
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 759c078442e2b61c721de529693005061838e2bd
Merge: f44f334 6126a59
Author: Udi Meiri <ud...@users.noreply.github.com>
AuthorDate: Thu Dec 12 17:10:37 2019 -0800
Merge pull request #10330: [BEAM-8882] Cherry pick #10283 and #10292
.../examples/cookbook/bigquery_side_input.py | 4 +-
.../examples/cookbook/bigquery_side_input_test.py | 4 +-
.../apache_beam/examples/snippets/snippets_test.py | 7 +-
.../apache_beam/io/gcp/bigquery_file_loads_test.py | 10 +--
sdks/python/apache_beam/io/iobase.py | 33 +++-------
sdks/python/apache_beam/io/iobase_test.py | 2 -
sdks/python/apache_beam/io/parquetio_test.py | 2 +-
sdks/python/apache_beam/io/textio_test.py | 9 +--
sdks/python/apache_beam/io/tfrecordio_test.py | 4 +-
sdks/python/apache_beam/pipeline_test.py | 8 +--
sdks/python/apache_beam/runners/common.py | 3 +-
.../runners/dataflow/dataflow_runner.py | 69 ++++++++++----------
.../runners/dataflow/dataflow_runner_test.py | 3 +-
.../runners/dataflow/internal/apiclient.py | 7 --
.../apache_beam/runners/dataflow/internal/names.py | 1 +
.../runners/dataflow/native_io/iobase_test.py | 2 +-
.../runners/dataflow/native_io/streaming_create.py | 76 ----------------------
.../runners/dataflow/ptransform_overrides.py | 67 +++++++++++++++----
.../consumer_tracking_pipeline_visitor_test.py | 13 +---
.../runners/direct/direct_runner_test.py | 6 +-
.../runners/direct/sdf_direct_runner_test.py | 10 ++-
.../runners/direct/transform_evaluator.py | 14 +++-
.../runners/interactive/pipeline_analyzer_test.py | 2 +-
.../interactive/pipeline_instrument_test.py | 24 +++----
.../runners/portability/fn_api_runner.py | 3 -
.../runners/portability/fn_api_runner_test.py | 66 ++++++++++---------
.../apache_beam/runners/worker/bundle_processor.py | 28 ++++----
.../apache_beam/runners/worker/log_handler.py | 31 +++++++--
.../apache_beam/runners/worker/log_handler_test.py | 51 ++++++++++++++-
.../apache_beam/runners/worker/sdk_worker.py | 24 +++----
.../apache_beam/runners/worker/statesampler.py | 20 ++++++
.../python/apache_beam/testing/test_stream_test.py | 4 +-
sdks/python/apache_beam/transforms/core.py | 60 ++++++++---------
sdks/python/apache_beam/transforms/ptransform.py | 7 +-
.../apache_beam/transforms/ptransform_test.py | 61 +++++++++++------
.../apache_beam/transforms/userstate_test.py | 2 +-
sdks/python/apache_beam/transforms/util.py | 14 +++-
sdks/python/apache_beam/transforms/util_test.py | 14 ++--
sdks/python/apache_beam/transforms/window_test.py | 7 +-
39 files changed, 429 insertions(+), 343 deletions(-)