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 b6108465589 Remove SuppressWarnings from NoopLock.java (#27416)
add 89cd2383859 [prism] Regs for filter and stats transform tests. (#27586)
add b54bf522fae [prism] middle sized fixes, avro, datastore, spanner
(#27588)
add 6aec5d12953 Bugfix for Timestamp Overflow in BigQueryIO's
StorageWriteAPI (#27413)
add cf20649a204 [prism] registrations for Regression tests. (#27589)
add 64552f73b38 [prism] Simpler io changes to add TestMain. (#27587)
add 7d5d4321c79 [Python] Create BigQuery wrapper with pipeline options
when performing reads (#27583)
add 98cef8bb617 [GCP] [BigQuery] Handle `totalBytesProcessed` `NoneType`
(#27474)
add 7d69493947a Group transformed and non transformed elements using hash
in MLTransform TFTProcessHandler (#27544)
add a02ecdca058 add the cookbook link (#27604)
add c0164f50488 Fix correct netty version (#27591)
add 736ef422046 Remove SuppressWarnings
add da21fe8195c Merge pull request #27596: Remove SuppressWarnings from
TransformServiceConfig
add f0f6d3ba33b [prism] Fix top for unfused execution. Move to register.
(#27585)
add 97cb32ea5dd Fix Python Flink runner load tests & Stop publish Python
SDK image in beam_portability (#27595)
No new revisions were added by this update.
Summary of changes:
.test-infra/jenkins/LoadTestsBuilder.groovy | 6 +-
.../jenkins/job_LoadTests_Combine_Flink_Go.groovy | 4 +-
.../job_LoadTests_Combine_Flink_Python.groovy | 3 +-
.../jenkins/job_LoadTests_GBK_Flink_Go.groovy | 4 +-
.../jenkins/job_LoadTests_GBK_Flink_Python.groovy | 3 +-
.../jenkins/job_LoadTests_ParDo_Flink_Go.groovy | 4 +-
.../job_LoadTests_ParDo_Flink_Python.groovy | 3 +-
.../job_LoadTests_SideInput_Flink_Go.groovy | 4 +-
.../jenkins/job_LoadTests_coGBK_Flink_Go.groovy | 4 +-
.../job_LoadTests_coGBK_Flink_Python.groovy | 3 +-
...Commit_Python_Chicago_Taxi_Example_Flink.groovy | 3 +-
.../jenkins/job_Publish_Docker_Snapshots.groovy | 4 +-
CHANGES.md | 2 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 3 +-
.../fnexecution/environment/DockerCommand.java | 41 +++-
sdks/go/pkg/beam/io/avroio/avroio.go | 9 +-
sdks/go/pkg/beam/io/avroio/avroio_test.go | 33 ++-
sdks/go/pkg/beam/io/bigtableio/bigtable_test.go | 5 +
sdks/go/pkg/beam/io/databaseio/database_test.go | 4 +
sdks/go/pkg/beam/io/datastoreio/datastore_test.go | 24 +-
sdks/go/pkg/beam/io/fhirio/deidentify_test.go | 6 +
sdks/go/pkg/beam/io/fileio/match_test.go | 4 +
sdks/go/pkg/beam/io/parquetio/parquetio_test.go | 4 +
sdks/go/pkg/beam/io/spannerio/common.go | 13 +-
sdks/go/pkg/beam/io/spannerio/read_test.go | 6 +-
sdks/go/pkg/beam/io/spannerio/write_test.go | 4 +-
sdks/go/pkg/beam/io/textio/textio_test.go | 18 +-
sdks/go/pkg/beam/transforms/filter/filter.go | 10 +-
sdks/go/pkg/beam/transforms/filter/filter.shims.go | 201 -----------------
sdks/go/pkg/beam/transforms/filter/filter_test.go | 17 ++
sdks/go/pkg/beam/transforms/stats/count_test.go | 9 +
sdks/go/pkg/beam/transforms/stats/max_test.go | 6 +
sdks/go/pkg/beam/transforms/stats/quantiles.go | 8 +-
.../go/pkg/beam/transforms/stats/quantiles_test.go | 51 +----
sdks/go/pkg/beam/transforms/top/top.go | 15 +-
sdks/go/pkg/beam/transforms/top/top.shims.go | 185 ----------------
sdks/go/pkg/beam/transforms/top/top_test.go | 54 +++--
sdks/go/pkg/beam/x/debug/head_test.go | 4 +
sdks/go/test/regression/lperror.go | 7 +
sdks/go/test/regression/pardo.go | 12 +
.../io/gcp/bigquery/TableRowToStorageApiProto.java | 22 +-
.../bigquery/TableRowToStorageApiProtoTest.java | 24 +-
.../transformservice/TransformServiceConfig.java | 1 -
sdks/python/apache_beam/io/gcp/bigquery.py | 36 ++-
sdks/python/apache_beam/ml/transforms/handlers.py | 125 ++++++++++-
.../apache_beam/ml/transforms/handlers_test.py | 245 +++++++++++++++++++++
sdks/python/apache_beam/ml/transforms/tft.py | 7 +
sdks/python/apache_beam/ml/transforms/tft_test.py | 49 ++++-
.../site/content/en/get-started/beam-overview.md | 3 +-
.../partials/section-menu/en/get-started.html | 4 +-
50 files changed, 748 insertions(+), 568 deletions(-)
delete mode 100644 sdks/go/pkg/beam/transforms/filter/filter.shims.go
delete mode 100644 sdks/go/pkg/beam/transforms/top/top.shims.go
