This is an automated email from the ASF dual-hosted git repository.
boyuanz 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 86c55f4 Add more comments to describe PubSubReadPayload and
PubSubWritePayload.
new 5afe677 Merge pull request #14204 from Add more comments to describe
PubSubReadPayload and PubSubWritePayload.
86c55f4 is described below
commit 86c55f41da7e9fb1c9fd92560a97f2d0f172ffdb
Author: Boyuan Zhang <boyu...@google.com>
AuthorDate: Thu Mar 11 11:04:51 2021 -0800
Add more comments to describe PubSubReadPayload and PubSubWritePayload.
---
model/pipeline/src/main/proto/beam_runner_api.proto | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/model/pipeline/src/main/proto/beam_runner_api.proto
b/model/pipeline/src/main/proto/beam_runner_api.proto
index f609c77..134fcb6 100644
--- a/model/pipeline/src/main/proto/beam_runner_api.proto
+++ b/model/pipeline/src/main/proto/beam_runner_api.proto
@@ -694,6 +694,8 @@ message WriteFilesPayload {
// Payload used by Google Cloud Pub/Sub read transform.
// This can be used by runners that wish to override Beam Pub/Sub read
transform
// with a native implementation.
+// The SDK should guarantee that only one of topic, subscription,
+// topic_runtime_overridden and subscription_runtime_overridden is set.
message PubSubReadPayload {
// Topic to read from. Exactly one of topic or subscription should be set.
@@ -723,6 +725,8 @@ message PubSubReadPayload {
// Payload used by Google Cloud Pub/Sub write transform.
// This can be used by runners that wish to override Beam Pub/Sub write
transform
// with a native implementation.
+// The SDK should guarantee that only one of topic and topic_runtime_overridden
+// is set.
message PubSubWritePayload {
// Topic to write to.
