From a75c34ed7a11741669121be69a7021a00f1133ce Mon Sep 17 00:00:00 2001 From: yoshi-automation Date: Sat, 23 Mar 2019 00:34:30 -0700 Subject: [PATCH] Regenerate bigquerystorage client --- .../bigquery/storage/v1beta1/Storage.java | 176 ++++++++++-------- .../storage/v1beta1/TableReferenceProto.java | 21 ++- .../cloud/bigquery/storage/v1beta1/avro.proto | 1 + .../storage/v1beta1/read_options.proto | 1 + .../bigquery/storage/v1beta1/storage.proto | 42 ++++- .../storage/v1beta1/table_reference.proto | 2 + .../synth.metadata | 10 +- 7 files changed, 154 insertions(+), 99 deletions(-) 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..e2a37f4a93e0 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,95 @@ 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" - + "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" + + "rage.v1beta1\032\034google/api/annotations.pro" + + "to\032\031google/api/resource.proto\0320google/cl" + + "oud/bigquery/storage/v1beta1/avro.proto\032" + + "8google/cloud/bigquery/storage/v1beta1/r" + + "ead_options.proto\032;google/cloud/bigquery" + + "/storage/v1beta1/table_reference.proto\032\033" + + "google/protobuf/empty.proto\032\037google/prot" + + "obuf/timestamp.proto\")\n\006Stream\022\014\n\004name\030\001" + + " \001(\t\022\021\n\trow_count\030\002 \001(\003\"_\n\016StreamPositio" + + "n\022=\n\006stream\030\001 \001(\0132-.google.cloud.bigquer" + + "y.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.protobuf.Timestamp\022" + + "H\n\013avro_schema\030\005 \001(\01321.google.cloud.bigq" + + "uery.storage.v1beta1.AvroSchemaH\000\022>\n\007str" + + "eams\030\004 \003(\0132-.google.cloud.bigquery.stora" + + "ge.v1beta1.Stream\022N\n\017table_reference\030\007 \001" + + "(\01325.google.cloud.bigquery.storage.v1bet" + + "a1.TableReference\022N\n\017table_modifiers\030\010 \001" + + "(\01325.google.cloud.bigquery.storage.v1bet" + + "a1.TableModifiersB\010\n\006schema\"\367\002\n\030CreateRe" + + "adSessionRequest\022N\n\017table_reference\030\001 \001(" + + "\01325.google.cloud.bigquery.storage.v1beta" + + "1.TableReference\022\016\n\006parent\030\006 \001(\t\022N\n\017tabl" + + "e_modifiers\030\002 \001(\01325.google.cloud.bigquer" + + "y.storage.v1beta1.TableModifiers\022\031\n\021requ" + + "ested_streams\030\003 \001(\005\022M\n\014read_options\030\004 \001(" + + "\01327.google.cloud.bigquery.storage.v1beta" + + "1.TableReadOptions\022A\n\006format\030\005 \001(\01621.goo" + + "gle.cloud.bigquery.storage.v1beta1.DataF" + + "ormat\"_\n\017ReadRowsRequest\022L\n\rread_positio" + + "n\030\001 \001(\01325.google.cloud.bigquery.storage." + + "v1beta1.StreamPosition\"+\n\014StreamStatus\022\033" + + "\n\023estimated_row_count\030\001 \001(\003\"*\n\016ThrottleS" + + "tatus\022\030\n\020throttle_percent\030\001 \001(\005\"\365\001\n\020Read" + + "RowsResponse\022D\n\tavro_rows\030\003 \001(\0132/.google" + + ".cloud.bigquery.storage.v1beta1.AvroRows" + + "H\000\022C\n\006status\030\002 \001(\01323.google.cloud.bigque" + + "ry.storage.v1beta1.StreamStatus\022N\n\017throt" + + "tle_status\030\005 \001(\01325.google.cloud.bigquery" + + ".storage.v1beta1.ThrottleStatusB\006\n\004rows\"" + + "\206\001\n$BatchCreateReadSessionStreamsRequest" + + "\022C\n\007session\030\001 \001(\01322.google.cloud.bigquer" + + "y.storage.v1beta1.ReadSession\022\031\n\021request" + + "ed_streams\030\002 \001(\005\"g\n%BatchCreateReadSessi" + + "onStreamsResponse\022>\n\007streams\030\001 \003(\0132-.goo" + + "gle.cloud.bigquery.storage.v1beta1.Strea" + + "m\"V\n\025FinalizeStreamRequest\022=\n\006stream\030\002 \001" + + "(\0132-.google.cloud.bigquery.storage.v1bet" + + "a1.Stream\"`\n\026SplitReadStreamRequest\022F\n\017o" + + "riginal_stream\030\001 \001(\0132-.google.cloud.bigq" + + "uery.storage.v1beta1.Stream\"\251\001\n\027SplitRea" + + "dStreamResponse\022E\n\016primary_stream\030\001 \001(\0132" + + "-.google.cloud.bigquery.storage.v1beta1." + + "Stream\022G\n\020remainder_stream\030\002 \001(\0132-.googl" + + "e.cloud.bigquery.storage.v1beta1.Stream*" + + "3\n\nDataFormat\022\033\n\027DATA_FORMAT_UNSPECIFIED" + + "\020\000\022\010\n\004AVRO\020\0012\307\010\n\017BigQueryStorage\022\207\002\n\021Cre" + + "ateReadSession\022?.google.cloud.bigquery.s" + + "torage.v1beta1.CreateReadSessionRequest\032" + + "2.google.cloud.bigquery.storage.v1beta1." + + "ReadSession\"}\202\323\344\223\002w\"0/v1beta1/{table_ref" + + "erence.project_id=projects/*}:\001*Z@\";/v1b" + + "eta1/{table_reference.dataset_id=project" + + "s/*/datasets/*}:\001*\022\300\001\n\010ReadRows\0226.google" + + ".cloud.bigquery.storage.v1beta1.ReadRows" + + "Request\0327.google.cloud.bigquery.storage." + + "v1beta1.ReadRowsResponse\"A\202\323\344\223\002;\0229/v1bet" + + "a1/{read_position.stream.name=projects/*" + + "/streams/*}0\001\022\364\001\n\035BatchCreateReadSession" + + "Streams\022K.google.cloud.bigquery.storage." + + "v1beta1.BatchCreateReadSessionStreamsReq" + + "uest\032L.google.cloud.bigquery.storage.v1b" + + "eta1.BatchCreateReadSessionStreamsRespon" + + "se\"8\202\323\344\223\0022\"-/v1beta1/{session.name=proje" + + "cts/*/sessions/*}:\001*\022\236\001\n\016FinalizeStream\022" + + "<.google.cloud.bigquery.storage.v1beta1." + + "FinalizeStreamRequest\032\026.google.protobuf." + + "Empty\"6\202\323\344\223\0020\"+/v1beta1/{stream.name=pro" + + "jects/*/streams/*}:\001*\022\316\001\n\017SplitReadStrea" + + "m\022=.google.cloud.bigquery.storage.v1beta" + + "1.SplitReadStreamRequest\032>.google.cloud." + + "bigquery.storage.v1beta1.SplitReadStream" + + "Response\"<\202\323\344\223\0026\0224/v1beta1/{original_str" + + "eam.name=projects/*/streams/*}By\n)com.go" + + "ogle.cloud.bigquery.storage.v1beta1ZLgoo" + + "gle.golang.org/genproto/googleapis/cloud" + + "/bigquery/storage/v1beta1;storageb\006proto" + + "3" }; com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { @@ -14349,6 +14360,8 @@ 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.api.ResourceProto.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 +14484,13 @@ 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.api.ResourceProto.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/java/com/google/cloud/bigquery/storage/v1beta1/TableReferenceProto.java b/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/java/com/google/cloud/bigquery/storage/v1beta1/TableReferenceProto.java index 0e337fa3da99..75f15fdfa3cd 100644 --- a/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/java/com/google/cloud/bigquery/storage/v1beta1/TableReferenceProto.java +++ b/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/java/com/google/cloud/bigquery/storage/v1beta1/TableReferenceProto.java @@ -1816,15 +1816,16 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { java.lang.String[] descriptorData = { "\n;google/cloud/bigquery/storage/v1beta1/" + "table_reference.proto\022%google.cloud.bigq" - + "uery.storage.v1beta1\032\037google/protobuf/ti" - + "mestamp.proto\"J\n\016TableReference\022\022\n\nproje" - + "ct_id\030\001 \001(\t\022\022\n\ndataset_id\030\002 \001(\t\022\020\n\010table" - + "_id\030\003 \001(\t\"C\n\016TableModifiers\0221\n\rsnapshot_" - + "time\030\001 \001(\0132\032.google.protobuf.TimestampB\216" - + "\001\n)com.google.cloud.bigquery.storage.v1b" - + "eta1B\023TableReferenceProtoZLgoogle.golang" - + ".org/genproto/googleapis/cloud/bigquery/" - + "storage/v1beta1;storageb\006proto3" + + "uery.storage.v1beta1\032\031google/api/resourc" + + "e.proto\032\037google/protobuf/timestamp.proto" + + "\"J\n\016TableReference\022\022\n\nproject_id\030\001 \001(\t\022\022" + + "\n\ndataset_id\030\002 \001(\t\022\020\n\010table_id\030\003 \001(\t\"C\n\016" + + "TableModifiers\0221\n\rsnapshot_time\030\001 \001(\0132\032." + + "google.protobuf.TimestampB\216\001\n)com.google" + + ".cloud.bigquery.storage.v1beta1B\023TableRe" + + "ferenceProtoZLgoogle.golang.org/genproto" + + "/googleapis/cloud/bigquery/storage/v1bet" + + "a1;storageb\006proto3" }; com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { @@ -1837,6 +1838,7 @@ public com.google.protobuf.ExtensionRegistry assignDescriptors( com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom( descriptorData, new com.google.protobuf.Descriptors.FileDescriptor[] { + com.google.api.ResourceProto.getDescriptor(), com.google.protobuf.TimestampProto.getDescriptor(), }, assigner); @@ -1856,6 +1858,7 @@ public com.google.protobuf.ExtensionRegistry assignDescriptors( new java.lang.String[] { "SnapshotTime", }); + com.google.api.ResourceProto.getDescriptor(); com.google.protobuf.TimestampProto.getDescriptor(); } diff --git a/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/proto/google/cloud/bigquery/storage/v1beta1/avro.proto b/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/proto/google/cloud/bigquery/storage/v1beta1/avro.proto index 021d8e44f9f2..699d70a671ec 100644 --- a/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/proto/google/cloud/bigquery/storage/v1beta1/avro.proto +++ b/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/proto/google/cloud/bigquery/storage/v1beta1/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 diff --git a/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/proto/google/cloud/bigquery/storage/v1beta1/read_options.proto b/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/proto/google/cloud/bigquery/storage/v1beta1/read_options.proto index 9591deba7f47..8a3c66699f57 100644 --- a/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/proto/google/cloud/bigquery/storage/v1beta1/read_options.proto +++ b/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/proto/google/cloud/bigquery/storage/v1beta1/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, 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..4ea0b1060707 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,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. diff --git a/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/proto/google/cloud/bigquery/storage/v1beta1/table_reference.proto b/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/proto/google/cloud/bigquery/storage/v1beta1/table_reference.proto index fb74bbf6c642..0d513898d126 100644 --- a/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/proto/google/cloud/bigquery/storage/v1beta1/table_reference.proto +++ b/google-api-grpc/proto-google-cloud-bigquerystorage-v1beta1/src/main/proto/google/cloud/bigquery/storage/v1beta1/table_reference.proto @@ -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. diff --git a/google-cloud-clients/google-cloud-bigquerystorage/synth.metadata b/google-cloud-clients/google-cloud-bigquerystorage/synth.metadata index 53a765afcc6f..b87583c381d3 100644 --- a/google-cloud-clients/google-cloud-bigquerystorage/synth.metadata +++ b/google-cloud-clients/google-cloud-bigquerystorage/synth.metadata @@ -1,19 +1,19 @@ { - "updateTime": "2019-03-01T08:34:57.731402Z", + "updateTime": "2019-03-23T07:34:29.996259Z", "sources": [ { "generator": { "name": "artman", - "version": "0.16.14", - "dockerImage": "googleapis/artman@sha256:f3d61ae45abaeefb6be5f228cda22732c2f1b00fb687c79c4bd4f2c42bb1e1a7" + "version": "0.16.19", + "dockerImage": "googleapis/artman@sha256:70ba28fda87e032ae44e6df41b7fc342c1b0cce1ed90658c4890eb4f613038c2" } }, { "git": { "name": "googleapis", "remote": "https://github.com/googleapis/googleapis.git", - "sha": "41d72d444fbe445f4da89e13be02078734fb7875", - "internalRef": "236230004" + "sha": "621908b5974b0ea5736fde114b2d5d4bd938e99d", + "internalRef": "239857314" } } ],