diff --git a/google-api-grpc/proto-google-cloud-bigquerydatatransfer-v1/src/main/java/com/google/cloud/bigquery/datatransfer/v1/DataSource.java b/google-api-grpc/proto-google-cloud-bigquerydatatransfer-v1/src/main/java/com/google/cloud/bigquery/datatransfer/v1/DataSource.java
index 4e523bfd3799..c15407345d03 100644
--- a/google-api-grpc/proto-google-cloud-bigquerydatatransfer-v1/src/main/java/com/google/cloud/bigquery/datatransfer/v1/DataSource.java
+++ b/google-api-grpc/proto-google-cloud-bigquerydatatransfer-v1/src/main/java/com/google/cloud/bigquery/datatransfer/v1/DataSource.java
@@ -1289,14 +1289,12 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
     }
     if (authorizationType_
         != com.google.cloud.bigquery.datatransfer.v1.DataSource.AuthorizationType
-            .AUTHORIZATION_TYPE_UNSPECIFIED
-            .getNumber()) {
+            .AUTHORIZATION_TYPE_UNSPECIFIED.getNumber()) {
       output.writeEnum(14, authorizationType_);
     }
     if (dataRefreshType_
         != com.google.cloud.bigquery.datatransfer.v1.DataSource.DataRefreshType
-            .DATA_REFRESH_TYPE_UNSPECIFIED
-            .getNumber()) {
+            .DATA_REFRESH_TYPE_UNSPECIFIED.getNumber()) {
       output.writeEnum(15, dataRefreshType_);
     }
     if (defaultDataRefreshWindowDays_ != 0) {
@@ -1365,14 +1363,12 @@ public int getSerializedSize() {
     }
     if (authorizationType_
         != com.google.cloud.bigquery.datatransfer.v1.DataSource.AuthorizationType
-            .AUTHORIZATION_TYPE_UNSPECIFIED
-            .getNumber()) {
+            .AUTHORIZATION_TYPE_UNSPECIFIED.getNumber()) {
       size += com.google.protobuf.CodedOutputStream.computeEnumSize(14, authorizationType_);
     }
     if (dataRefreshType_
         != com.google.cloud.bigquery.datatransfer.v1.DataSource.DataRefreshType
-            .DATA_REFRESH_TYPE_UNSPECIFIED
-            .getNumber()) {
+            .DATA_REFRESH_TYPE_UNSPECIFIED.getNumber()) {
       size += com.google.protobuf.CodedOutputStream.computeEnumSize(15, dataRefreshType_);
     }
     if (defaultDataRefreshWindowDays_ != 0) {
diff --git a/google-api-grpc/proto-google-cloud-bigquerydatatransfer-v1/src/main/java/com/google/cloud/bigquery/datatransfer/v1/ListTransferRunsRequest.java b/google-api-grpc/proto-google-cloud-bigquerydatatransfer-v1/src/main/java/com/google/cloud/bigquery/datatransfer/v1/ListTransferRunsRequest.java
index 557d3cc9f365..cbfee96a1fdd 100644
--- a/google-api-grpc/proto-google-cloud-bigquerydatatransfer-v1/src/main/java/com/google/cloud/bigquery/datatransfer/v1/ListTransferRunsRequest.java
+++ b/google-api-grpc/proto-google-cloud-bigquerydatatransfer-v1/src/main/java/com/google/cloud/bigquery/datatransfer/v1/ListTransferRunsRequest.java
@@ -536,8 +536,7 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
     }
     if (runAttempt_
         != com.google.cloud.bigquery.datatransfer.v1.ListTransferRunsRequest.RunAttempt
-            .RUN_ATTEMPT_UNSPECIFIED
-            .getNumber()) {
+            .RUN_ATTEMPT_UNSPECIFIED.getNumber()) {
       output.writeEnum(5, runAttempt_);
     }
     unknownFields.writeTo(output);
@@ -572,8 +571,7 @@ public int getSerializedSize() {
     }
     if (runAttempt_
         != com.google.cloud.bigquery.datatransfer.v1.ListTransferRunsRequest.RunAttempt
-            .RUN_ATTEMPT_UNSPECIFIED
-            .getNumber()) {
+            .RUN_ATTEMPT_UNSPECIFIED.getNumber()) {
       size += com.google.protobuf.CodedOutputStream.computeEnumSize(5, runAttempt_);
     }
     size += unknownFields.getSerializedSize();
diff --git a/google-api-grpc/proto-google-cloud-bigquerydatatransfer-v1/src/main/java/com/google/cloud/bigquery/datatransfer/v1/TransferMessage.java b/google-api-grpc/proto-google-cloud-bigquerydatatransfer-v1/src/main/java/com/google/cloud/bigquery/datatransfer/v1/TransferMessage.java
index b41a7ee680f2..b6f56e127452 100644
--- a/google-api-grpc/proto-google-cloud-bigquerydatatransfer-v1/src/main/java/com/google/cloud/bigquery/datatransfer/v1/TransferMessage.java
+++ b/google-api-grpc/proto-google-cloud-bigquerydatatransfer-v1/src/main/java/com/google/cloud/bigquery/datatransfer/v1/TransferMessage.java
@@ -421,8 +421,7 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
     }
     if (severity_
         != com.google.cloud.bigquery.datatransfer.v1.TransferMessage.MessageSeverity
-            .MESSAGE_SEVERITY_UNSPECIFIED
-            .getNumber()) {
+            .MESSAGE_SEVERITY_UNSPECIFIED.getNumber()) {
       output.writeEnum(2, severity_);
     }
     if (!getMessageTextBytes().isEmpty()) {
@@ -442,8 +441,7 @@ public int getSerializedSize() {
     }
     if (severity_
         != com.google.cloud.bigquery.datatransfer.v1.TransferMessage.MessageSeverity
-            .MESSAGE_SEVERITY_UNSPECIFIED
-            .getNumber()) {
+            .MESSAGE_SEVERITY_UNSPECIFIED.getNumber()) {
       size += com.google.protobuf.CodedOutputStream.computeEnumSize(2, severity_);
     }
     if (!getMessageTextBytes().isEmpty()) {
diff --git a/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/java/com/google/cloud/bigquery/storage/v1beta1/Storage.java b/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/java/com/google/cloud/bigquery/storage/v1beta1/Storage.java
index b6937c20edb7..c24cabcae70e 100644
--- a/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/java/com/google/cloud/bigquery/storage/v1beta1/Storage.java
+++ b/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/java/com/google/cloud/bigquery/storage/v1beta1/Storage.java
@@ -14259,84 +14259,94 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
     java.lang.String[] descriptorData = {
       "\n3google/cloud/bigquery/storage/v1beta1/"
           + "storage.proto\022%google.cloud.bigquery.sto"
-          + "rage.v1beta1\0320google/cloud/bigquery/stor"
-          + "age/v1beta1/avro.proto\0328google/cloud/big"
-          + "query/storage/v1beta1/read_options.proto"
-          + "\032;google/cloud/bigquery/storage/v1beta1/"
-          + "table_reference.proto\032\033google/protobuf/e"
-          + "mpty.proto\032\037google/protobuf/timestamp.pr"
-          + "oto\")\n\006Stream\022\014\n\004name\030\001 \001(\t\022\021\n\trow_count"
-          + "\030\002 \001(\003\"_\n\016StreamPosition\022=\n\006stream\030\001 \001(\013"
-          + "2-.google.cloud.bigquery.storage.v1beta1"
-          + ".Stream\022\016\n\006offset\030\002 \001(\003\"\200\003\n\013ReadSession\022"
-          + "\014\n\004name\030\001 \001(\t\022/\n\013expire_time\030\002 \001(\0132\032.goo"
-          + "gle.protobuf.Timestamp\022H\n\013avro_schema\030\005 "
-          + "\001(\01321.google.cloud.bigquery.storage.v1be"
-          + "ta1.AvroSchemaH\000\022>\n\007streams\030\004 \003(\0132-.goog"
+          + "rage.v1beta1\032\034google/api/annotations.pro"
+          + "to\0320google/cloud/bigquery/storage/v1beta"
+          + "1/avro.proto\0328google/cloud/bigquery/stor"
+          + "age/v1beta1/read_options.proto\032;google/c"
+          + "loud/bigquery/storage/v1beta1/table_refe"
+          + "rence.proto\032\033google/protobuf/empty.proto"
+          + "\032\037google/protobuf/timestamp.proto\")\n\006Str"
+          + "eam\022\014\n\004name\030\001 \001(\t\022\021\n\trow_count\030\002 \001(\003\"_\n\016"
+          + "StreamPosition\022=\n\006stream\030\001 \001(\0132-.google."
+          + "cloud.bigquery.storage.v1beta1.Stream\022\016\n"
+          + "\006offset\030\002 \001(\003\"\200\003\n\013ReadSession\022\014\n\004name\030\001 "
+          + "\001(\t\022/\n\013expire_time\030\002 \001(\0132\032.google.protob"
+          + "uf.Timestamp\022H\n\013avro_schema\030\005 \001(\01321.goog"
+          + "le.cloud.bigquery.storage.v1beta1.AvroSc"
+          + "hemaH\000\022>\n\007streams\030\004 \003(\0132-.google.cloud.b"
+          + "igquery.storage.v1beta1.Stream\022N\n\017table_"
+          + "reference\030\007 \001(\01325.google.cloud.bigquery."
+          + "storage.v1beta1.TableReference\022N\n\017table_"
+          + "modifiers\030\010 \001(\01325.google.cloud.bigquery."
+          + "storage.v1beta1.TableModifiersB\010\n\006schema"
+          + "\"\367\002\n\030CreateReadSessionRequest\022N\n\017table_r"
+          + "eference\030\001 \001(\01325.google.cloud.bigquery.s"
+          + "torage.v1beta1.TableReference\022\016\n\006parent\030"
+          + "\006 \001(\t\022N\n\017table_modifiers\030\002 \001(\01325.google."
+          + "cloud.bigquery.storage.v1beta1.TableModi"
+          + "fiers\022\031\n\021requested_streams\030\003 \001(\005\022M\n\014read"
+          + "_options\030\004 \001(\01327.google.cloud.bigquery.s"
+          + "torage.v1beta1.TableReadOptions\022A\n\006forma"
+          + "t\030\005 \001(\01621.google.cloud.bigquery.storage."
+          + "v1beta1.DataFormat\"_\n\017ReadRowsRequest\022L\n"
+          + "\rread_position\030\001 \001(\01325.google.cloud.bigq"
+          + "uery.storage.v1beta1.StreamPosition\"+\n\014S"
+          + "treamStatus\022\033\n\023estimated_row_count\030\001 \001(\003"
+          + "\"*\n\016ThrottleStatus\022\030\n\020throttle_percent\030\001"
+          + " \001(\005\"\365\001\n\020ReadRowsResponse\022D\n\tavro_rows\030\003"
+          + " \001(\0132/.google.cloud.bigquery.storage.v1b"
+          + "eta1.AvroRowsH\000\022C\n\006status\030\002 \001(\01323.google"
+          + ".cloud.bigquery.storage.v1beta1.StreamSt"
+          + "atus\022N\n\017throttle_status\030\005 \001(\01325.google.c"
+          + "loud.bigquery.storage.v1beta1.ThrottleSt"
+          + "atusB\006\n\004rows\"\206\001\n$BatchCreateReadSessionS"
+          + "treamsRequest\022C\n\007session\030\001 \001(\01322.google."
+          + "cloud.bigquery.storage.v1beta1.ReadSessi"
+          + "on\022\031\n\021requested_streams\030\002 \001(\005\"g\n%BatchCr"
+          + "eateReadSessionStreamsResponse\022>\n\007stream"
+          + "s\030\001 \003(\0132-.google.cloud.bigquery.storage."
+          + "v1beta1.Stream\"V\n\025FinalizeStreamRequest\022"
+          + "=\n\006stream\030\002 \001(\0132-.google.cloud.bigquery."
+          + "storage.v1beta1.Stream\"`\n\026SplitReadStrea"
+          + "mRequest\022F\n\017original_stream\030\001 \001(\0132-.goog"
           + "le.cloud.bigquery.storage.v1beta1.Stream"
-          + "\022N\n\017table_reference\030\007 \001(\01325.google.cloud"
-          + ".bigquery.storage.v1beta1.TableReference"
-          + "\022N\n\017table_modifiers\030\010 \001(\01325.google.cloud"
-          + ".bigquery.storage.v1beta1.TableModifiers"
-          + "B\010\n\006schema\"\367\002\n\030CreateReadSessionRequest\022"
-          + "N\n\017table_reference\030\001 \001(\01325.google.cloud."
-          + "bigquery.storage.v1beta1.TableReference\022"
-          + "\016\n\006parent\030\006 \001(\t\022N\n\017table_modifiers\030\002 \001(\013"
-          + "25.google.cloud.bigquery.storage.v1beta1"
-          + ".TableModifiers\022\031\n\021requested_streams\030\003 \001"
-          + "(\005\022M\n\014read_options\030\004 \001(\01327.google.cloud."
-          + "bigquery.storage.v1beta1.TableReadOption"
-          + "s\022A\n\006format\030\005 \001(\01621.google.cloud.bigquer"
-          + "y.storage.v1beta1.DataFormat\"_\n\017ReadRows"
-          + "Request\022L\n\rread_position\030\001 \001(\01325.google."
-          + "cloud.bigquery.storage.v1beta1.StreamPos"
-          + "ition\"+\n\014StreamStatus\022\033\n\023estimated_row_c"
-          + "ount\030\001 \001(\003\"*\n\016ThrottleStatus\022\030\n\020throttle"
-          + "_percent\030\001 \001(\005\"\365\001\n\020ReadRowsResponse\022D\n\ta"
-          + "vro_rows\030\003 \001(\0132/.google.cloud.bigquery.s"
-          + "torage.v1beta1.AvroRowsH\000\022C\n\006status\030\002 \001("
-          + "\01323.google.cloud.bigquery.storage.v1beta"
-          + "1.StreamStatus\022N\n\017throttle_status\030\005 \001(\0132"
-          + "5.google.cloud.bigquery.storage.v1beta1."
-          + "ThrottleStatusB\006\n\004rows\"\206\001\n$BatchCreateRe"
-          + "adSessionStreamsRequest\022C\n\007session\030\001 \001(\013"
-          + "22.google.cloud.bigquery.storage.v1beta1"
-          + ".ReadSession\022\031\n\021requested_streams\030\002 \001(\005\""
-          + "g\n%BatchCreateReadSessionStreamsResponse"
-          + "\022>\n\007streams\030\001 \003(\0132-.google.cloud.bigquer"
-          + "y.storage.v1beta1.Stream\"V\n\025FinalizeStre"
-          + "amRequest\022=\n\006stream\030\002 \001(\0132-.google.cloud"
-          + ".bigquery.storage.v1beta1.Stream\"`\n\026Spli"
-          + "tReadStreamRequest\022F\n\017original_stream\030\001 "
-          + "\001(\0132-.google.cloud.bigquery.storage.v1be"
-          + "ta1.Stream\"\251\001\n\027SplitReadStreamResponse\022E"
-          + "\n\016primary_stream\030\001 \001(\0132-.google.cloud.bi"
-          + "gquery.storage.v1beta1.Stream\022G\n\020remaind"
-          + "er_stream\030\002 \001(\0132-.google.cloud.bigquery."
-          + "storage.v1beta1.Stream*3\n\nDataFormat\022\033\n\027"
-          + "DATA_FORMAT_UNSPECIFIED\020\000\022\010\n\004AVRO\020\0012\335\005\n\017"
-          + "BigQueryStorage\022\212\001\n\021CreateReadSession\022?."
-          + "google.cloud.bigquery.storage.v1beta1.Cr"
-          + "eateReadSessionRequest\0322.google.cloud.bi"
-          + "gquery.storage.v1beta1.ReadSession\"\000\022\177\n\010"
-          + "ReadRows\0226.google.cloud.bigquery.storage"
-          + ".v1beta1.ReadRowsRequest\0327.google.cloud."
-          + "bigquery.storage.v1beta1.ReadRowsRespons"
-          + "e\"\0000\001\022\274\001\n\035BatchCreateReadSessionStreams\022"
-          + "K.google.cloud.bigquery.storage.v1beta1."
-          + "BatchCreateReadSessionStreamsRequest\032L.g"
-          + "oogle.cloud.bigquery.storage.v1beta1.Bat"
-          + "chCreateReadSessionStreamsResponse\"\000\022h\n\016"
-          + "FinalizeStream\022<.google.cloud.bigquery.s"
-          + "torage.v1beta1.FinalizeStreamRequest\032\026.g"
-          + "oogle.protobuf.Empty\"\000\022\222\001\n\017SplitReadStre"
-          + "am\022=.google.cloud.bigquery.storage.v1bet"
-          + "a1.SplitReadStreamRequest\032>.google.cloud"
-          + ".bigquery.storage.v1beta1.SplitReadStrea"
-          + "mResponse\"\000By\n)com.google.cloud.bigquery"
-          + ".storage.v1beta1ZLgoogle.golang.org/genp"
-          + "roto/googleapis/cloud/bigquery/storage/v"
-          + "1beta1;storageb\006proto3"
+          + "\"\251\001\n\027SplitReadStreamResponse\022E\n\016primary_"
+          + "stream\030\001 \001(\0132-.google.cloud.bigquery.sto"
+          + "rage.v1beta1.Stream\022G\n\020remainder_stream\030"
+          + "\002 \001(\0132-.google.cloud.bigquery.storage.v1"
+          + "beta1.Stream*3\n\nDataFormat\022\033\n\027DATA_FORMA"
+          + "T_UNSPECIFIED\020\000\022\010\n\004AVRO\020\0012\307\010\n\017BigQuerySt"
+          + "orage\022\207\002\n\021CreateReadSession\022?.google.clo"
+          + "ud.bigquery.storage.v1beta1.CreateReadSe"
+          + "ssionRequest\0322.google.cloud.bigquery.sto"
+          + "rage.v1beta1.ReadSession\"}\202\323\344\223\002w\"0/v1bet"
+          + "a1/{table_reference.project_id=projects/"
+          + "*}:\001*Z@\";/v1beta1/{table_reference.datas"
+          + "et_id=projects/*/datasets/*}:\001*\022\300\001\n\010Read"
+          + "Rows\0226.google.cloud.bigquery.storage.v1b"
+          + "eta1.ReadRowsRequest\0327.google.cloud.bigq"
+          + "uery.storage.v1beta1.ReadRowsResponse\"A\202"
+          + "\323\344\223\002;\0229/v1beta1/{read_position.stream.na"
+          + "me=projects/*/streams/*}0\001\022\364\001\n\035BatchCrea"
+          + "teReadSessionStreams\022K.google.cloud.bigq"
+          + "uery.storage.v1beta1.BatchCreateReadSess"
+          + "ionStreamsRequest\032L.google.cloud.bigquer"
+          + "y.storage.v1beta1.BatchCreateReadSession"
+          + "StreamsResponse\"8\202\323\344\223\0022\"-/v1beta1/{sessi"
+          + "on.name=projects/*/sessions/*}:\001*\022\236\001\n\016Fi"
+          + "nalizeStream\022<.google.cloud.bigquery.sto"
+          + "rage.v1beta1.FinalizeStreamRequest\032\026.goo"
+          + "gle.protobuf.Empty\"6\202\323\344\223\0020\"+/v1beta1/{st"
+          + "ream.name=projects/*/streams/*}:\001*\022\316\001\n\017S"
+          + "plitReadStream\022=.google.cloud.bigquery.s"
+          + "torage.v1beta1.SplitReadStreamRequest\032>."
+          + "google.cloud.bigquery.storage.v1beta1.Sp"
+          + "litReadStreamResponse\"<\202\323\344\223\0026\0224/v1beta1/"
+          + "{original_stream.name=projects/*/streams"
+          + "/*}By\n)com.google.cloud.bigquery.storage"
+          + ".v1beta1ZLgoogle.golang.org/genproto/goo"
+          + "gleapis/cloud/bigquery/storage/v1beta1;s"
+          + "torageb\006proto3"
     };
     com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
         new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() {
@@ -14349,6 +14359,7 @@ public com.google.protobuf.ExtensionRegistry assignDescriptors(
     com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(
         descriptorData,
         new com.google.protobuf.Descriptors.FileDescriptor[] {
+          com.google.api.AnnotationsProto.getDescriptor(),
           com.google.cloud.bigquery.storage.v1beta1.AvroProto.getDescriptor(),
           com.google.cloud.bigquery.storage.v1beta1.ReadOptions.getDescriptor(),
           com.google.cloud.bigquery.storage.v1beta1.TableReferenceProto.getDescriptor(),
@@ -14471,6 +14482,12 @@ public com.google.protobuf.ExtensionRegistry assignDescriptors(
             new java.lang.String[] {
               "PrimaryStream", "RemainderStream",
             });
+    com.google.protobuf.ExtensionRegistry registry =
+        com.google.protobuf.ExtensionRegistry.newInstance();
+    registry.add(com.google.api.AnnotationsProto.http);
+    com.google.protobuf.Descriptors.FileDescriptor.internalUpdateFileDescriptor(
+        descriptor, registry);
+    com.google.api.AnnotationsProto.getDescriptor();
     com.google.cloud.bigquery.storage.v1beta1.AvroProto.getDescriptor();
     com.google.cloud.bigquery.storage.v1beta1.ReadOptions.getDescriptor();
     com.google.cloud.bigquery.storage.v1beta1.TableReferenceProto.getDescriptor();
diff --git a/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/proto/google/cloud/bigquery/storage/v1beta1/storage.proto b/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/proto/google/cloud/bigquery/storage/v1beta1/storage.proto
index 9c4b18519b4b..1ac0483bad0c 100644
--- a/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/proto/google/cloud/bigquery/storage/v1beta1/storage.proto
+++ b/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/proto/google/cloud/bigquery/storage/v1beta1/storage.proto
@@ -17,6 +17,7 @@ syntax = "proto3";
 
 package google.cloud.bigquery.storage.v1beta1;
 
+import "google/api/annotations.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";
@@ -42,7 +43,17 @@ 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) {
+    // This is used only to set header params; this API does not support REST.
+    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 +64,24 @@ 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) {
+    // This is used only to set header params; this API does not support REST.
+    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) {}
+      returns (BatchCreateReadSessionStreamsResponse) {
+    // This is used only to set header params; this API does not support REST.
+    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 +97,13 @@ 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) {
+    // This is used only to set header params; this API does not support REST.
+    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
@@ -91,7 +119,12 @@ service BigQueryStorage {
   //
   // This method is guaranteed to be idempotent.
   rpc SplitReadStream(SplitReadStreamRequest)
-      returns (SplitReadStreamResponse) {}
+      returns (SplitReadStreamResponse) {
+    // This is used only to set header params; this API does not support REST.
+    option (google.api.http) = {
+      get: "/v1beta1/{original_stream.name=projects/*/streams/*}"
+    };
+  }
 }
 
 // Information about a single data stream within a read session.