From 26735eb9007749cb54ca3fbab6a329955643c5ee Mon Sep 17 00:00:00 2001 From: Pablo Date: Wed, 15 Feb 2023 11:52:17 -0800 Subject: [PATCH] Fix provider to be found by AutoService (#25491) --- .../fileschematransform/FileWriteSchemaTransformProvider.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/sdks/java/io/file-schema-transform/src/main/java/org/apache/beam/sdk/io/fileschematransform/FileWriteSchemaTransformProvider.java b/sdks/java/io/file-schema-transform/src/main/java/org/apache/beam/sdk/io/fileschematransform/FileWriteSchemaTransformProvider.java index ced21527a2fa..b3550e7dbb15 100644 --- a/sdks/java/io/file-schema-transform/src/main/java/org/apache/beam/sdk/io/fileschematransform/FileWriteSchemaTransformProvider.java +++ b/sdks/java/io/file-schema-transform/src/main/java/org/apache/beam/sdk/io/fileschematransform/FileWriteSchemaTransformProvider.java @@ -24,6 +24,7 @@ import static org.apache.beam.sdk.values.TypeDescriptors.rows; import static org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkState; +import com.google.auto.service.AutoService; import java.util.Collections; import java.util.List; import java.util.Map; @@ -32,6 +33,7 @@ import org.apache.beam.sdk.schemas.Schema.Field; import org.apache.beam.sdk.schemas.Schema.FieldType; import org.apache.beam.sdk.schemas.transforms.SchemaTransform; +import org.apache.beam.sdk.schemas.transforms.SchemaTransformProvider; import org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider; import org.apache.beam.sdk.transforms.MapElements; import org.apache.beam.sdk.transforms.PTransform; @@ -44,6 +46,7 @@ * A {@link TypedSchemaTransformProvider} implementation for writing a {@link Row} {@link * PCollection} to file systems, driven by a {@link FileWriteSchemaTransformConfiguration}. */ +@AutoService(SchemaTransformProvider.class) public class FileWriteSchemaTransformProvider extends TypedSchemaTransformProvider {