Add annotations to protocol buffers indicating request parameters (via synth). (#7550)

[Internal] This commit should not have any effect on the public interface,
or even the behavior of the client. It picks up some additional metadata
to indicate resources used in request parameters for the purpose of adding
helpers in the generated clients for statically-typed languages.

Author: yoshi-automation

google/cloud/bigquery_storage_v1beta1/proto/avro.proto

@@ -21,6 +21,7 @@ option go_package = "google.golang.org/genproto/googleapis/cloud/bigquery/storag
 option java_outer_classname = "AvroProto";
 option java_package = "com.google.cloud.bigquery.storage.v1beta1";
 
+
 // Avro schema.
 message AvroSchema {
   // Json serialized schema, as described at

google/cloud/bigquery_storage_v1beta1/proto/read_options.proto

@@ -20,6 +20,7 @@ package google.cloud.bigquery.storage.v1beta1;
 option go_package = "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1beta1;storage";
 option java_package = "com.google.cloud.bigquery.storage.v1beta1";
 
+
 // Options dictating how we read a table.
 message TableReadOptions {
   // Optional. Names of the fields in the table that should be read. If empty,

google/cloud/bigquery_storage_v1beta1/proto/storage.proto

@@ -17,6 +17,8 @@ syntax = "proto3";
 
 package google.cloud.bigquery.storage.v1beta1;
 
+import "google/api/annotations.proto";
+import "google/api/resource.proto";
 import "google/cloud/bigquery/storage/v1beta1/avro.proto";
 import "google/cloud/bigquery/storage/v1beta1/read_options.proto";
 import "google/cloud/bigquery/storage/v1beta1/table_reference.proto";
@@ -26,6 +28,7 @@ import "google/protobuf/timestamp.proto";
 option go_package = "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1beta1;storage";
 option java_package = "com.google.cloud.bigquery.storage.v1beta1";
 
+
 // BigQuery storage API.
 //
 // The BigQuery storage API can be used to read data stored in BigQuery.
@@ -42,7 +45,16 @@ service BigQueryStorage {
   //
   // Read sessions automatically expire 24 hours after they are created and do
   // not require manual clean-up by the caller.
-  rpc CreateReadSession(CreateReadSessionRequest) returns (ReadSession) {}
+  rpc CreateReadSession(CreateReadSessionRequest) returns (ReadSession) {
+    option (google.api.http) = {
+      post: "/v1beta1/{table_reference.project_id=projects/*}"
+      body: "*"
+      additional_bindings {
+        post: "/v1beta1/{table_reference.dataset_id=projects/*/datasets/*}"
+        body: "*"
+      }
+    };
+  }
 
   // Reads rows from the table in the format prescribed by the read session.
   // Each response contains one or more table rows, up to a maximum of 10 MiB
@@ -53,13 +65,21 @@ service BigQueryStorage {
   // estimated total number of rows in the read stream. This number is computed
   // based on the total table size and the number of active streams in the read
   // session, and may change as other streams continue to read data.
-  rpc ReadRows(ReadRowsRequest) returns (stream ReadRowsResponse) {}
+  rpc ReadRows(ReadRowsRequest) returns (stream ReadRowsResponse) {
+    option (google.api.http) = {
+      get: "/v1beta1/{read_position.stream.name=projects/*/streams/*}"
+    };
+  }
 
   // Creates additional streams for a ReadSession. This API can be used to
   // dynamically adjust the parallelism of a batch processing task upwards by
   // adding additional workers.
-  rpc BatchCreateReadSessionStreams(BatchCreateReadSessionStreamsRequest)
-      returns (BatchCreateReadSessionStreamsResponse) {}
+  rpc BatchCreateReadSessionStreams(BatchCreateReadSessionStreamsRequest) returns (BatchCreateReadSessionStreamsResponse) {
+    option (google.api.http) = {
+      post: "/v1beta1/{session.name=projects/*/sessions/*}"
+      body: "*"
+    };
+  }
 
   // Triggers the graceful termination of a single stream in a ReadSession. This
   // API can be used to dynamically adjust the parallelism of a batch processing
@@ -75,7 +95,12 @@ service BigQueryStorage {
   // This method will return an error if there are no other live streams
   // in the Session, or if SplitReadStream() has been called on the given
   // Stream.
-  rpc FinalizeStream(FinalizeStreamRequest) returns (google.protobuf.Empty) {}
+  rpc FinalizeStream(FinalizeStreamRequest) returns (google.protobuf.Empty) {
+    option (google.api.http) = {
+      post: "/v1beta1/{stream.name=projects/*/streams/*}"
+      body: "*"
+    };
+  }
 
   // Splits a given read stream into two Streams. These streams are referred to
   // as the primary and the residual of the split. The original stream can still
@@ -90,8 +115,11 @@ service BigQueryStorage {
   // completion.
   //
   // This method is guaranteed to be idempotent.
-  rpc SplitReadStream(SplitReadStreamRequest)
-      returns (SplitReadStreamResponse) {}
+  rpc SplitReadStream(SplitReadStreamRequest) returns (SplitReadStreamResponse) {
+    option (google.api.http) = {
+      get: "/v1beta1/{original_stream.name=projects/*/streams/*}"
+    };
+  }
 }
 
 // Information about a single data stream within a read session.

google/cloud/bigquery_storage_v1beta1/proto/storage_pb2.py

@@ -17,12 +17,14 @@ syntax = "proto3";
 
 package google.cloud.bigquery.storage.v1beta1;
 
+import "google/api/resource.proto";
 import "google/protobuf/timestamp.proto";
 
 option go_package = "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1beta1;storage";
 option java_outer_classname = "TableReferenceProto";
 option java_package = "com.google.cloud.bigquery.storage.v1beta1";
 
+
 // Table reference that includes just the 3 strings needed to identify a table.
 message TableReference {
   // The assigned project ID of the project.