This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 695dd4116ef Fix comment phrase and name (#29052)
add 0850a6c9523 Remove Avro-related code from Java SDK "core" module
add 5fd1245d5d1 Merge pull request #27851: Remove Avro-related code from
Java SDK "core" module
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 10 +-
sdks/java/core/build.gradle | 6 +-
.../java/org/apache/beam/sdk/coders/AvroCoder.java | 820 --------
.../apache/beam/sdk/coders/AvroGenericCoder.java | 40 -
.../main/java/org/apache/beam/sdk/io/AvroIO.java | 2031 --------------------
.../apache/beam/sdk/io/AvroSchemaIOProvider.java | 157 --
.../main/java/org/apache/beam/sdk/io/AvroSink.java | 167 --
.../java/org/apache/beam/sdk/io/AvroSource.java | 773 --------
.../beam/sdk/io/ConstantAvroDestination.java | 156 --
.../org/apache/beam/sdk/io/CountingSource.java | 30 +-
.../beam/sdk/io/DynamicAvroDestinations.java | 61 -
.../beam/sdk/io/SerializableAvroCodecFactory.java | 119 --
.../apache/beam/sdk/schemas/AvroRecordSchema.java | 64 -
.../org/apache/beam/sdk/schemas/io/Providers.java | 27 +-
.../io/payloads/AvroPayloadSerializerProvider.java | 47 -
.../beam/sdk/schemas/utils/AvroByteBuddyUtils.java | 149 --
.../apache/beam/sdk/schemas/utils/AvroUtils.java | 1396 --------------
.../org/apache/beam/sdk/coders/AvroCoderTest.java | 1106 -----------
.../apache/beam/sdk/coders/AvroCoderTestPojo.java | 51 -
.../apache/beam/sdk/coders/CoderRegistryTest.java | 4 +-
.../apache/beam/sdk/coders/DefaultCoderTest.java | 6 +-
.../apache/beam/sdk/coders/MockDefaultCoder.java} | 42 +-
.../java/org/apache/beam/sdk/io/AvroIOTest.java | 1627 ----------------
.../beam/sdk/io/AvroSchemaIOProviderTest.java | 173 --
.../org/apache/beam/sdk/io/AvroSourceTest.java | 843 --------
.../test/java/org/apache/beam/sdk/io/ReadTest.java | 3 +-
.../sdk/io/SerializableAvroCodecFactoryTest.java | 93 -
.../apache/beam/sdk/schemas/AvroSchemaTest.java | 496 -----
.../apache/beam/sdk/schemas/SchemaCoderTest.java | 55 -
.../io/AvroPayloadSerializerProviderTest.java | 64 -
.../beam/sdk/schemas/transforms/ConvertTest.java | 14 -
.../beam/sdk/schemas/utils/AvroGenerators.java | 220 ---
.../beam/sdk/schemas/utils/AvroUtilsTest.java | 914 ---------
.../beam/sdk/schemas/utils/TestJavaBeans.java | 12 +-
.../extensions/avro/coders/DefaultCoderTest.java | 61 -
sdks/java/extensions/timeseries/build.gradle | 1 +
sdks/java/extensions/zetasketch/build.gradle | 1 +
sdks/java/harness/build.gradle | 6 +
sdks/java/io/clickhouse/build.gradle | 1 +
sdks/java/io/contextualtextio/build.gradle | 1 +
.../pubsub/PubsubReadSchemaTransformProvider.java | 2 +-
.../pubsub/PubsubWriteSchemaTransformProvider.java | 2 +-
.../beam/sdk/io/gcp/pubsub/PubsubIOTest.java | 2 +-
sdks/java/io/kafka/build.gradle | 2 +-
.../org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 2 +-
.../test/unit/read/SnowflakeIOReadTest.java | 2 +-
sdks/java/io/thrift/build.gradle | 1 +
47 files changed, 97 insertions(+), 11763 deletions(-)
delete mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/AvroCoder.java
delete mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/AvroGenericCoder.java
delete mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java
delete mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroSchemaIOProvider.java
delete mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroSink.java
delete mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroSource.java
delete mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/io/ConstantAvroDestination.java
delete mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/io/DynamicAvroDestinations.java
delete mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/io/SerializableAvroCodecFactory.java
delete mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/AvroRecordSchema.java
delete mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/payloads/AvroPayloadSerializerProvider.java
delete mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AvroByteBuddyUtils.java
delete mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AvroUtils.java
delete mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/coders/AvroCoderTest.java
delete mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/coders/AvroCoderTestPojo.java
copy
sdks/java/{io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/internal/UuidCoder.java
=> core/src/test/java/org/apache/beam/sdk/coders/MockDefaultCoder.java} (55%)
delete mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/io/AvroIOTest.java
delete mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/io/AvroSchemaIOProviderTest.java
delete mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/io/AvroSourceTest.java
delete mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/io/SerializableAvroCodecFactoryTest.java
delete mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/AvroSchemaTest.java
delete mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/io/AvroPayloadSerializerProviderTest.java
delete mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/utils/AvroGenerators.java
delete mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/utils/AvroUtilsTest.java
delete mode 100644
sdks/java/extensions/avro/src/test/java/org/apache/beam/sdk/extensions/avro/coders/DefaultCoderTest.java