This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from 1653a97 (commit)
to 70ddf84 (commit)
from 1653a97 [BEAM-9782] Update README for instructions on updating katas
(#13329)
add 62e8aeb [BEAM-8569] Add changes note about Hadoop 3 support
add 010af43 Merge pull request #13354: [BEAM-8569] Add changes note about
Hadoop 3 support
add ed33e8c [BEAM-11207] Adding PipelineResult to session runner. (#13371)
add 5f133ca [BEAM-11211] parquetio_test using multiple pyarrow versions
add 1a6b9d8 Merge pull request #13369: [BEAM-11211] parquetio_test using
multiple pyarrow versions
add d4c82ec Make UsesTestStream extend UsesUnboundedPCollections for
exclusion in batch only runners
add 434bce5 Merge pull request #13376 from Make UsesTestStream extend
UsesUnboundedPCollections for exclusion in batch-only runners
add 53a26ae [BEAM-11092] Add bigquery io request count metric,
implementing HarnessMonitoringInfos and process_wide metrics
add 7c28db2 Merge pull request #13217 from [BEAM-11092] Add bigquery io
request count metric, implementing HarnessMonitoringInfos and process_wide
metrics
add cdb882d [BEAM-11303] Use sum as the post-agg for size (#13379)
add fc52b63 Update SDF programming guide.
add 774185b Merge pull request #13326 from [BEAM-10480] Update SDF
programming guide
add a267d96 [BEAM-9615] Switch options for logical types. (#13366)
add 532b024 [BEAM-10475]Add WithShardedKey variation of GroupIntoBatches
transform in Python SDK. (#13292)
add 70ddf84 [BEAM-11188] Adding unit test for mergeExpandedWithPipeline
(#13370)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 2 +-
.../core/runtime/graphx/schema/logicaltypes.go | 121 ++++++++++++
.../pkg/beam/core/runtime/graphx/schema/schema.go | 115 ++++-------
.../beam/core/runtime/graphx/schema/schema_test.go | 55 ++++--
sdks/go/pkg/beam/core/runtime/graphx/xlang.go | 2 +-
sdks/go/pkg/beam/core/runtime/graphx/xlang_test.go | 218 +++++++++++++++++++++
sdks/go/pkg/beam/runners/session/session.go | 6 +-
.../apache/beam/sdk/testing/UsesTestStream.java | 2 +-
sdks/python/apache_beam/dataframe/frames.py | 16 +-
sdks/python/apache_beam/dataframe/frames_test.py | 18 +-
sdks/python/apache_beam/internal/metrics/metric.py | 90 +++++++++
.../apache_beam/internal/metrics/metric_test.py | 41 ++++
sdks/python/apache_beam/io/gcp/bigquery_tools.py | 36 +++-
.../utils.py => io/gcp/resource_identifiers.py} | 32 ++-
sdks/python/apache_beam/metrics/cells.py | 22 ++-
sdks/python/apache_beam/metrics/execution.pxd | 4 +-
sdks/python/apache_beam/metrics/execution.py | 71 ++++---
sdks/python/apache_beam/metrics/metric.py | 18 +-
sdks/python/apache_beam/metrics/metricbase.py | 42 +++-
.../python/apache_beam/metrics/monitoring_infos.py | 21 +-
.../apache_beam/metrics/monitoring_infos_test.py | 35 ++++
.../apache_beam/runners/worker/sdk_worker.py | 38 ++--
.../apache_beam/runners/worker/sdk_worker_test.py | 60 ++++++
sdks/python/apache_beam/transforms/util.py | 49 ++++-
sdks/python/apache_beam/transforms/util_test.py | 17 ++
sdks/python/apache_beam/utils/sharded_key.py | 2 +-
sdks/python/test-suites/tox/common.gradle | 3 +-
sdks/python/test-suites/tox/py38/build.gradle | 7 +
sdks/python/tox.ini | 21 ++
.../content/en/documentation/programming-guide.md | 85 ++++++--
30 files changed, 1044 insertions(+), 205 deletions(-)
create mode 100644 sdks/go/pkg/beam/core/runtime/graphx/schema/logicaltypes.go
copy sdks/python/apache_beam/{runners/job/utils.py =>
io/gcp/resource_identifiers.py} (56%)
