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/20 04:56:45 UTC
[beam] branch nightly-refs/heads/master updated (9d0fc05d004 -> 69cd6ef06b3)
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 9d0fc05d004 Fix sklearn requirement file in Py311 (#27152)
add 5223ab466e7 Select dedicated avro datum reader and writer (#26320)
add 5e587578de8 Update numpy requirement in /sdks/python (#27160)
add bfd3017e241 Bump google.golang.org/api from 0.127.0 to 0.128.0 in /sdks (#27163)
add 69cd6ef06b3 Bump github.com/tetratelabs/wazero from 1.2.0 to 1.2.1 in /sdks (#27162)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
.../util/AvroCoderCloudObjectTranslator.java | 29 ++-
.../runners/dataflow/util/CloudObjectsTest.java | 10 +-
sdks/go.mod | 4 +-
sdks/go.sum | 8 +-
sdks/java/extensions/avro/build.gradle | 69 +++--
.../beam/sdk/extensions/avro/coders/AvroCoder.java | 257 +++++++++---------
.../extensions/avro/coders/AvroGenericCoder.java | 5 +-
.../sdk/extensions/avro/io/AvroDatumFactory.java | 196 ++++++++++++++
.../apache/beam/sdk/extensions/avro/io/AvroIO.java | 194 +++++++++++---
.../beam/sdk/extensions/avro/io/AvroSink.java | 40 ++-
.../beam/sdk/extensions/avro/io/AvroSource.java | 123 +++++----
.../extensions/avro/schemas/AvroRecordSchema.java | 5 +-
.../schemas/utils/AvroJavaTimeConversions.java | 288 +++++++++++++++++++++
.../schemas/utils/AvroJodaTimeConversions.java | 154 +++++++++++
.../extensions/avro/schemas/utils/AvroUtils.java | 38 ++-
.../beam/sdk/extensions/avro/schemas/test.avsc | 71 ++---
.../sdk/extensions/avro/coders/AvroCoderTest.java | 148 +++++++----
.../beam/sdk/extensions/avro/io/AvroIOTest.java | 4 +-
.../sdk/extensions/avro/io/AvroSourceTest.java | 40 +--
.../avro/schemas/TestAvroConversionFactory.java | 41 +++
.../extensions/avro/schemas/TestAvroFactory.java | 66 +++--
.../avro/schemas/utils/AvroUtilsTest.java | 34 ++-
.../AvroWriteSchemaTransformFormatProvider.java | 4 +-
.../ParquetWriteSchemaTransformFormatProvider.java | 4 +-
.../AvroReadSchemaTransformFormatProviderTest.java | 8 +-
...AvroWriteSchemaTransformFormatProviderTest.java | 4 +-
...rquetReadSchemaTransformFormatProviderTest.java | 8 +-
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 7 +-
.../beam/sdk/io/gcp/pubsub/PubsubIOTest.java | 4 +-
sdks/python/build-requirements.txt | 2 +-
31 files changed, 1425 insertions(+), 441 deletions(-)
create mode 100644 sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/io/AvroDatumFactory.java
create mode 100644 sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/schemas/utils/AvroJavaTimeConversions.java
create mode 100644 sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/schemas/utils/AvroJodaTimeConversions.java
create mode 100644 sdks/java/extensions/avro/src/test/java/org/apache/beam/sdk/extensions/avro/schemas/TestAvroConversionFactory.java