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 ea1625ab5f3 Support samza portable UDF metrics. (#25265)
add 513f4b003b1 Adding support for @SchemaFieldDescription annotation that
allows ann… (#25268)
add d36f34df570 Adding SpannerIO.readChangeStreams support for
SchemaTransform (#24999)
add 2b15208feb8 Bump google.golang.org/api from 0.108.0 to 0.109.0 in
/sdks (#25250)
add 47353efb9d5 Add min and max batch size args to model handler (#25395)
add 840ea6e8bc0 Beam/sdks/io/gcp/java/healcare/hl7v2 io read (#25056)
add e0a36a28c11 Remove reuse of GenericRecord instance when reading Avro
from BigQuery (#25320)
add e659c83c60d fixed reading env variable (#25362)
add cbac3e093a4 fix doc on bq sxtorage (#25353)
add 64e40d2c018 [Playground] Fix Test_getRunOrTestCmd on Go 1.20 (#25379)
add 9e067c65392 Fix typo - metdata -> metadata (#25399)
add 41ea9e5268f [prism] Initial commit for READMEs and go.mod (#25404)
add e0749855f99 [prism] Add urns package (#25405)
add 78c15648b51 Add Two Counter Metric in BigQuery Write Schema Transform
(#25155)
add 8283e4fc0dd [prism] Add internal/config package (#25406)
No new revisions were added by this update.
Summary of changes:
playground/backend/go.mod | 2 +-
.../code_processing/code_processing_test.go | 13 +-
playground/infrastructure/grpc_client.py | 3 +-
sdks/go.mod | 19 +-
sdks/go.sum | 12 +-
sdks/go/pkg/beam/runners/prism/README.md | 190 ++++++++++
sdks/go/pkg/beam/runners/prism/internal/README.md | 62 ++++
.../beam/runners/prism/internal/config/config.go | 247 +++++++++++++
.../runners/prism/internal/config/config_test.go | 221 ++++++++++++
.../pkg/beam/runners/prism/internal/urns/urns.go | 128 +++++++
.../prism/internal/urns/urns_test.go} | 30 +-
.../sdk/schemas/FieldValueTypeInformation.java | 18 +
...aFieldName.java => SchemaFieldDescription.java} | 18 +-
.../sdk/schemas/utils/StaticSchemaInference.java | 11 +-
.../beam/sdk/schemas/AutoValueSchemaTest.java | 32 ++
.../beam/sdk/schemas/JavaBeanSchemaTest.java | 11 +
.../beam/sdk/schemas/JavaFieldSchemaTest.java | 9 +
.../beam/sdk/schemas/utils/TestJavaBeans.java | 23 ++
.../apache/beam/sdk/schemas/utils/TestPOJOs.java | 39 ++
.../io/gcp/bigquery/BigQueryStorageAvroReader.java | 10 +-
...ueryStorageWriteApiSchemaTransformProvider.java | 42 ++-
.../apache/beam/sdk/io/gcp/healthcare/HL7v2IO.java | 272 +++++++++++---
.../beam/sdk/io/gcp/healthcare/HL7v2Message.java | 26 ++
...undleParameter.java => HL7v2ReadParameter.java} | 54 ++-
.../sdk/io/gcp/healthcare/HL7v2ReadResponse.java | 96 +++++
.../io/gcp/healthcare/HL7v2ReadResponseCoder.java | 58 +++
.../beam/sdk/io/gcp/spanner/ReadSpannerSchema.java | 37 +-
.../beam/sdk/io/gcp/spanner/SpannerSchema.java | 8 +-
...erChangestreamsReadSchemaTransformProvider.java | 394 +++++++++++++++++++++
.../io/gcp/bigquery/BigQueryIOStorageReadTest.java | 50 +++
...StorageWriteApiSchemaTransformProviderTest.java | 169 +++++++--
.../sdk/io/gcp/healthcare/HL7v2IOReadWriteIT.java | 84 +++++
.../beam/sdk/io/gcp/healthcare/HL7v2IOTest.java | 41 ++-
... => SpannerChangeStreamsSchemaTransformIT.java} | 178 +++++-----
.../inference/pytorch_image_classification.py | 10 +-
.../inference/run_inference_side_inputs.py | 6 +-
sdks/python/apache_beam/ml/inference/base.py | 10 +-
sdks/python/apache_beam/ml/inference/base_test.py | 6 +-
.../documentation/io/built-in/google-bigquery.md | 4 +-
39 files changed, 2367 insertions(+), 276 deletions(-)
create mode 100644 sdks/go/pkg/beam/runners/prism/README.md
create mode 100644 sdks/go/pkg/beam/runners/prism/internal/README.md
create mode 100644 sdks/go/pkg/beam/runners/prism/internal/config/config.go
create mode 100644
sdks/go/pkg/beam/runners/prism/internal/config/config_test.go
create mode 100644 sdks/go/pkg/beam/runners/prism/internal/urns/urns.go
copy sdks/go/pkg/beam/{core/runtime/pipelinex/clone_test.go =>
runners/prism/internal/urns/urns_test.go} (61%)
copy
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/annotations/{SchemaFieldName.java
=> SchemaFieldDescription.java} (82%)
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/{FhirBundleParameter.java
=> HL7v2ReadParameter.java} (51%)
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HL7v2ReadResponse.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HL7v2ReadResponseCoder.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/SpannerChangestreamsReadSchemaTransformProvider.java
copy
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/it/{SpannerChangeStreamPostgresIT.java
=> SpannerChangeStreamsSchemaTransformIT.java} (59%)
