From 13a489efc9a62a6fc350a8aedf7e5b7afd2ed254 Mon Sep 17 00:00:00 2001 From: ahmedabu98 Date: Wed, 25 Jan 2023 23:14:58 +0000 Subject: [PATCH] Fix SchemaTransform identifiers --- .../providers/BigQueryDirectReadSchemaTransformProvider.java | 2 +- .../sdk/io/gcp/pubsub/PubsubSchemaTransformReadProvider.java | 3 +-- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryDirectReadSchemaTransformProvider.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryDirectReadSchemaTransformProvider.java index 5282dfafc769..0bbef315ceb2 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryDirectReadSchemaTransformProvider.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryDirectReadSchemaTransformProvider.java @@ -79,7 +79,7 @@ protected SchemaTransform from(BigQueryDirectReadSchemaTransformConfiguration co @Override public String identifier() { - return String.format("beam:transform:org.apache.beam:bigquery_storage_read:v1"); + return "beam:schematransform:org.apache.beam:bigquery_storage_read:v1"; } @Override diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubSchemaTransformReadProvider.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubSchemaTransformReadProvider.java index de092a5e6011..096b598de17b 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubSchemaTransformReadProvider.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubSchemaTransformReadProvider.java @@ -54,7 +54,6 @@ @AutoService(SchemaTransformProvider.class) public class PubsubSchemaTransformReadProvider extends TypedSchemaTransformProvider { - private static final String API = "pubsub"; static final String OUTPUT_TAG = "OUTPUT"; /** Returns the expected class of the configuration. */ @@ -74,7 +73,7 @@ protected SchemaTransform from(PubsubSchemaTransformReadConfiguration configurat /** Implementation of the {@link TypedSchemaTransformProvider} identifier method. */ @Override public String identifier() { - return String.format("%s:read", API); + return "beam:schematransform:org.apache.beam:pubsub_read:v1"; } /**