This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 7a0ad41935f Escape literal tab. (#31548)
add 89494ef1493 Fix usage of two different StateCache in
StreamingDataflowWorker
add 9e422ca1b0f Merge pull request #31555: Fix usage of two different
StateCache in StreamingDataflowWorker
add eda6a39558a Allow context managers to be used for setup/teardown.
(#31458)
add d01c24ce64f Update aws testcontainer to make it compatible with
testcontainers_version = "1.19.7" (#31531)
add aed85746d63 Remove pipeline options override from inside connector
add e26eb125f9f Merge pull request #31412 Remove SpannerIO pipeline
options override
add 2ddfcfb1c18 Correct test name to HashStringsTest (#31497)
add 500ca1778f4 [Python] Add warning to temp_location and staging_location
when the bucket has soft delete enabled (#31550)
add d560aa63d58 make the table name unique in ReadUsingStorageApiTests
(#31552)
add a8205d789a8 Allow flags to be used as jinja template variables.
add b4c83a69cef Less confusing name for argument parser.
add ab94c8fc633 Merge pull request #31549 Allow flags to be used as jinja
template variables.
add acb763a7ac8 Add types to ReadFrom/WriteToBigQuery.
add 0eb8993a19a Full docstrings.
add 3267f7c8a5d Better use of Optional typing.
add 814cc8d3785 Merge pull request #31537 Add documentation and types to
ReadFrom/WriteToBigQuery.
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 4 ++
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
.../dataflow/worker/StreamingDataflowWorker.java | 2 +-
.../org/apache/beam/sdk/io/aws/ITEnvironment.java | 6 +-
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 5 --
.../{map_side_inputs_iter.py => map_context.py} | 53 +++++++++++-----
.../snippets/transforms/elementwise/map_test.py | 17 +++++
.../apache_beam/io/gcp/bigquery_read_it_test.py | 4 +-
sdks/python/apache_beam/io/gcp/gcsio.py | 13 ++++
sdks/python/apache_beam/io/gcp/gcsio_test.py | 15 +++++
sdks/python/apache_beam/ml/transforms/tft_test.py | 2 +-
.../python/apache_beam/options/pipeline_options.py | 22 +++++++
sdks/python/apache_beam/pipeline_test.py | 29 +++++++++
sdks/python/apache_beam/runners/common.pxd | 2 +
sdks/python/apache_beam/runners/common.py | 63 ++++++++++++++++++-
sdks/python/apache_beam/transforms/core.py | 72 ++++++++++++++++++++++
sdks/python/apache_beam/yaml/main.py | 44 ++++++++++++-
sdks/python/apache_beam/yaml/main_test.py | 30 +++++++++
sdks/python/apache_beam/yaml/yaml_io.py | 58 +++++++++++++++--
sdks/python/scripts/generate_pydoc.sh | 2 +
.../transforms/python/elementwise/map.md | 10 +++
.../transforms/python/elementwise/pardo.md | 6 +-
22 files changed, 424 insertions(+), 37 deletions(-)
copy
sdks/python/apache_beam/examples/snippets/transforms/elementwise/{map_side_inputs_iter.py
=> map_context.py} (53%)
