Merge pull request #25175: Fix SchemaTransform identifiers

apache · Jan 26, 2023 · 2c45ac4 · 2c45ac4
2 parents f565a94 + 13a489e
commit 2c45ac4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/.../apache/beam/sdk/io/gcp/bigquery/providers/BigQueryDirectReadSchemaTransformProvider.java b/.../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/...rm/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubSchemaTransformReadProvider.java b/...rm/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubSchemaTransformReadProvider.java
@@ -54,7 +54,6 @@
 @AutoService(SchemaTransformProvider.class)
 public class PubsubSchemaTransformReadProvider
     extends TypedSchemaTransformProvider<PubsubSchemaTransformReadConfiguration> {
-  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";
   }
 
   /**