You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2023/06/30 04:40:39 UTC
[beam] branch nightly-refs/heads/master updated (cbeb123949a -> 7890bdcee84)
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 cbeb123949a Bump datastore-v1-proto-client dependency to match libraries-bom (#27285)
add b0d6dbc0c15 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#27295)
add 2601eebbdb9 Bump cloud.google.com/go/storage from 1.30.1 to 1.31.0 in /sdks (#27294)
add 1446295d66d bump govers to 1.20.5 (#27293)
add 04fdf0818c2 Simplify SchemaTransform API (#27202)
add 972d5d5e0c6 Update multi model notebook to remove workarounds (#27305)
add 230d02f578b Use requirements file as a constraint when building the expansion service container
add 7890bdcee84 Merge pull request #27277: Use requirements file as a constraint when building the expansion service container
No new revisions were added by this update.
Summary of changes:
.../arc/images/Dockerfile | 6 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
.../beam-ml/run_inference_multi_model.ipynb | 294 +++++++++------------
sdks/go.mod | 6 +-
sdks/go.sum | 12 +-
sdks/go/run_with_go_version.sh | 2 +-
.../sdk/schemas/transforms/SchemaTransform.java | 7 +-
.../transforms/SchemaTransformProvider.java | 4 +-
.../TypedSchemaTransformProviderTest.java | 5 +-
.../ExpansionServiceSchemaTransformProvider.java | 2 +-
...xpansionServiceSchemaTransformProviderTest.java | 49 +---
.../SqlTransformSchemaTransformProvider.java | 162 ++++++------
.../DebeziumReadSchemaTransformProvider.java | 146 +++++-----
.../io/debezium/DebeziumIOMySqlConnectorIT.java | 3 +-
.../debezium/DebeziumIOPostgresSqlConnectorIT.java | 3 +-
.../debezium/DebeziumReadSchemaTransformTest.java | 3 +-
.../FileReadSchemaTransformProvider.java | 8 +-
.../FileWriteSchemaTransformProvider.java | 8 +-
.../AvroReadSchemaTransformFormatProviderTest.java | 8 +-
.../FileReadSchemaTransformFormatProviderTest.java | 6 +-
.../FileWriteSchemaTransformProviderTest.java | 7 +-
.../JsonReadSchemaTransformFormatProviderTest.java | 8 +-
.../LineReadSchemaTransformFormatProviderTest.java | 8 +-
...rquetReadSchemaTransformFormatProviderTest.java | 8 +-
.../BigQueryExportReadSchemaTransformProvider.java | 29 +-
...QueryFileLoadsWriteSchemaTransformProvider.java | 32 +--
.../BigQueryDirectReadSchemaTransformProvider.java | 20 +-
...ueryStorageWriteApiSchemaTransformProvider.java | 23 +-
.../BigtableReadSchemaTransformProvider.java | 9 +-
.../BigtableWriteSchemaTransformProvider.java | 9 +-
.../pubsub/PubsubReadSchemaTransformProvider.java | 10 +-
.../pubsub/PubsubWriteSchemaTransformProvider.java | 10 +-
.../PubsubLiteReadSchemaTransformProvider.java | 76 +++---
.../PubsubLiteWriteSchemaTransformProvider.java | 73 +++--
.../SpannerWriteSchemaTransformProvider.java | 117 ++++----
...erChangestreamsReadSchemaTransformProvider.java | 85 +++---
...QueryExportReadSchemaTransformProviderTest.java | 38 ++-
...yFileLoadsWriteSchemaTransformProviderTest.java | 24 +-
...QueryDirectReadSchemaTransformProviderTest.java | 10 +-
...StorageWriteApiSchemaTransformProviderTest.java | 24 +-
.../BigtableReadSchemaTransformProviderIT.java | 4 +-
.../BigtableWriteSchemaTransformProviderIT.java | 2 +-
.../PubsubReadSchemaTransformProviderTest.java | 21 +-
.../PubsubWriteSchemaTransformProviderIT.java | 2 +-
.../beam/sdk/io/gcp/pubsublite/ReadWriteIT.java | 6 +-
.../beam/sdk/io/gcp/spanner/SpannerWriteIT.java | 3 +-
.../it/SpannerChangeStreamsSchemaTransformIT.java | 3 +-
.../io/jdbc/JdbcReadSchemaTransformProvider.java | 45 ++--
.../io/jdbc/JdbcWriteSchemaTransformProvider.java | 35 +--
.../jdbc/JdbcReadSchemaTransformProviderTest.java | 16 +-
.../jdbc/JdbcWriteSchemaTransformProviderTest.java | 14 +-
.../io/kafka/KafkaReadSchemaTransformProvider.java | 206 +++++++--------
.../kafka/KafkaWriteSchemaTransformProvider.java | 71 +++--
.../org/apache/beam/sdk/io/kafka/KafkaIOIT.java | 6 +-
.../KafkaReadSchemaTransformProviderTest.java | 41 ++-
.../SingleStoreSchemaTransformReadProvider.java | 23 +-
.../SingleStoreSchemaTransformWriteProvider.java | 23 +-
.../SingleStoreIOSchemaTransformIT.java | 13 +-
sdks/python/expansion-service-container/Dockerfile | 3 +-
59 files changed, 727 insertions(+), 1166 deletions(-)