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 index 56541f7a74c20..5910a1032eb75 100644 --- 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"];