You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ar...@apache.org on 2022/12/28 14:53:40 UTC
[beam] 01/01: Merge pull request #24294: Create Avro extension for Java SDK
This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit bab773fdcf1abe96a7f912a1f4a2795014a22e36
Merge: 994f733a409 150877e6494
Author: Alexey Romanenko <33...@users.noreply.github.com>
AuthorDate: Wed Dec 28 15:53:31 2022 +0100
Merge pull request #24294: Create Avro extension for Java SDK
.../org/apache/beam/sdk/io/BlockBasedSource.java | 4 +-
.../apache/beam/sdk/io/DefaultFilenamePolicy.java | 2 +-
.../beam/sdk/io/ReadAllViaFileBasedSource.java | 2 +-
sdks/java/extensions/avro/build.gradle | 56 +
.../beam/sdk/extensions/avro/coders/AvroCoder.java | 820 ++++++++
.../extensions/avro/coders/AvroGenericCoder.java | 32 +
.../sdk/extensions/avro/coders/package-info.java | 29 +
.../apache/beam/sdk/extensions/avro/io/AvroIO.java | 2043 ++++++++++++++++++++
.../extensions/avro/io/AvroSchemaIOProvider.java | 150 ++
.../beam/sdk/extensions/avro/io/AvroSink.java | 161 ++
.../beam/sdk/extensions/avro/io/AvroSource.java | 777 ++++++++
.../avro/io/ConstantAvroDestination.java | 148 ++
.../avro/io/DynamicAvroDestinations.java | 55 +
.../avro/io/SerializableAvroCodecFactory.java | 112 ++
.../beam/sdk/extensions/avro/io/package-info.java | 26 +
.../extensions/avro/schemas/AvroRecordSchema.java | 64 +
.../io/payloads/AvroPayloadSerializerProvider.java | 44 +
.../avro/schemas/io/payloads/package-info.java | 27 +
.../sdk/extensions/avro/schemas/package-info.java | 29 +
.../avro/schemas/utils/AvroByteBuddyUtils.java | 142 ++
.../extensions/avro/schemas/utils/AvroUtils.java | 1374 +++++++++++++
.../avro/schemas/utils/package-info.java | 26 +
.../apache/beam/sdk/extensions/avro/io/user.avsc | 10 +
.../beam/sdk/extensions/avro/schemas/test.avsc | 30 +
.../sdk/extensions/avro/coders/AvroCoderTest.java | 1108 +++++++++++
.../extensions/avro/coders/AvroCoderTestPojo.java | 51 +
.../beam/sdk/extensions/avro/io/AvroIOTest.java | 1587 +++++++++++++++
.../avro/io/AvroSchemaIOProviderTest.java | 174 ++
.../sdk/extensions/avro/io/AvroSourceTest.java | 846 ++++++++
.../avro/io/SerializableAvroCodecFactoryTest.java | 93 +
.../extensions/avro/schemas/AvroSchemaTest.java | 497 +++++
.../io/AvroPayloadSerializerProviderTest.java | 64 +
.../avro/schemas/utils/AvroGenerators.java | 220 +++
.../avro/schemas/utils/AvroUtilsTest.java | 895 +++++++++
settings.gradle.kts | 1 +
35 files changed, 11695 insertions(+), 4 deletions(-)