Merge pull request #21966: add new pubsub urn

apache · Jul 12, 2022 · 029a2e3 · 029a2e3
2 parents c7e77f9 + d69b217
commit 029a2e3
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/model/pipeline/src/main/proto/org/apache/beam/model/pipeline/v1/beam_runner_api.proto b/model/pipeline/src/main/proto/org/apache/beam/model/pipeline/v1/beam_runner_api.proto
@@ -362,6 +362,10 @@ message StandardPTransforms {
  // Payload: PubSubWritePayload.
  PUBSUB_WRITE = 5 [(beam_urn) = "beam:transform:pubsub_write:v1"];
 
+ // Used for pubsub dynamic destinations.
+ // Payload: PubSubWritePayload.
+ PUBSUB_WRITE_V2 = 7 [(beam_urn) = "beam:transform:pubsub_write:v2"];
+
  // Represents the GroupIntoBatches.WithShardedKey operation.
  // Payload: GroupIntoBatchesPayload
  GROUP_INTO_BATCHES_WITH_SHARDED_KEY = 6 [(beam_urn) = "beam:transform:group_into_batches_with_sharded_key:v1"];