This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from cc54a46 [BEAM-8427] Add MongoDB to SQL documentation (#10273)
add d11dcd2 [BEAM-8882] Implement Impulse() for BundleBasedRunner.
add 145918a [BEAM-8882] Make Create fn-api agnostic.
add a66d80b [BEAM-8882] Fully specify types for Create composite.
add 02f8ad4 [BEAM-8882] Make Read fn-api agnostic.
add f9b9fa2 [BEAM-8882] Cleanup always-on use_sdf_bounded_source option.
add cdba260 [BEAM-8882] Annotate ParDo and CombineValues operations with
proto pipeline ids.
add 645d881 [BEAM-8882] Unconditionally populate pipeline_proto_coder_id.
add dd1de75 [BEAM-8882] Fix overly-sensitive tests.
add fc72fc2 Fix sdf tests from create.
add 4c22834 [BEAM-8882] Avoid attaching unrecognized properties.
add 62e2333 [BEAM-8882] Accommodations for JRH.
add 0878ecb Minor cleanup.
add 719b8cc Merge pull request #10283 [BEAM-8882] Allow Dataflow to
automatically choose portability.
No new revisions were added by this update.
Summary of changes:
.../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 +--
.../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 ++++++++++---------
.../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 +-
33 files changed, 304 insertions(+), 311 deletions(-)
delete mode 100644
sdks/python/apache_beam/runners/dataflow/native_io/streaming_create.py
