This is an automated email from the ASF dual-hosted git repository. pabloem pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push: new d9d322b5697 enabling public construction of typed schematransforms (#25010) d9d322b5697 is described below commit d9d322b569784fd9a7d6eb480b2e85368f88bdbb Author: Pablo Estrada <pabl...@users.noreply.github.com> AuthorDate: Wed Jan 18 01:01:38 2023 -0500 enabling public construction of typed schematransforms (#25010) --- .../beam/sdk/io/gcp/pubsub/PubsubWriteSchemaTransformConfiguration.java | 2 +- .../beam/sdk/io/gcp/pubsub/PubsubWriteSchemaTransformProvider.java | 2 +- .../sdk/io/gcp/pubsublite/PubsubLiteWriteSchemaTransformProvider.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubWriteSchemaTransformConfiguration.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubWriteSchemaTransformConfiguration.java index eced2405eb2..ce4548eceb4 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubWriteSchemaTransformConfiguration.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubWriteSchemaTransformConfiguration.java @@ -126,7 +126,7 @@ public abstract class PubsubWriteSchemaTransformConfiguration { */ public abstract Builder setIdAttribute(String value); - abstract PubsubWriteSchemaTransformConfiguration build(); + public abstract PubsubWriteSchemaTransformConfiguration build(); } @DefaultSchema(AutoValueSchema.class) diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubWriteSchemaTransformProvider.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubWriteSchemaTransformProvider.java index cc68cc7772d..3a6b2389b92 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubWriteSchemaTransformProvider.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubWriteSchemaTransformProvider.java @@ -97,7 +97,7 @@ public class PubsubWriteSchemaTransformProvider /** Returns the expected {@link SchemaTransform} of the configuration. */ @Override - protected SchemaTransform from(PubsubWriteSchemaTransformConfiguration configuration) { + public SchemaTransform from(PubsubWriteSchemaTransformConfiguration configuration) { return new PubsubWriteSchemaTransform(configuration); } diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PubsubLiteWriteSchemaTransformProvider.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PubsubLiteWriteSchemaTransformProvider.java index eea8070e6a0..c9922826ace 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PubsubLiteWriteSchemaTransformProvider.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PubsubLiteWriteSchemaTransformProvider.java @@ -59,7 +59,7 @@ public class PubsubLiteWriteSchemaTransformProvider } @Override - protected @UnknownKeyFor @NonNull @Initialized SchemaTransform from( + public @UnknownKeyFor @NonNull @Initialized SchemaTransform from( PubsubLiteWriteSchemaTransformConfiguration configuration) { if (!SUPPORTED_FORMATS.contains(configuration.getFormat())) {