Skip to content

Commit 0e283bf

Browse files
gcf-owl-bot[bot]gcf-owl-bot[bot]
authored
feat: add new_partitions field for CloseStream for Cloud Bigtable ChangeStream (#1654)
- [ ] Regenerate this pull request now. PiperOrigin-RevId: 512957844 Source-Link: https://togithub.com/googleapis/googleapis/commit/c5650ae0426ef1a82de84e5144ba26fcc5bb8549 Source-Link: https://togithub.com/googleapis/googleapis-gen/commit/a71ec9cc0a871286587f1df1c5e434c5bc338f91 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiYTcxZWM5Y2MwYTg3MTI4NjU4N2YxZGYxYzVlNDM0YzViYzMzOGY5MSJ9
1 parent 87261a9 commit 0e283bf

File tree

3 files changed

+815
-162
lines changed

3 files changed

+815
-162
lines changed

‎proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/BigtableProto.java

+94-92
Original file line numberDiff line numberDiff line change
@@ -225,7 +225,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
225225
+ "able.v2.StreamContinuationTokensH\000\022,\n\010en"
226226
+ "d_time\030\005 \001(\0132\032.google.protobuf.Timestamp"
227227
+ "\0225\n\022heartbeat_duration\030\007 \001(\0132\031.google.pr"
228-
+ "otobuf.DurationB\014\n\nstart_from\"\353\t\n\030ReadCh"
228+
+ "otobuf.DurationB\014\n\nstart_from\"\251\n\n\030ReadCh"
229229
+ "angeStreamResponse\022N\n\013data_change\030\001 \001(\0132"
230230
+ "7.google.bigtable.v2.ReadChangeStreamRes"
231231
+ "ponse.DataChangeH\000\022K\n\theartbeat\030\002 \001(\01326."
@@ -253,99 +253,101 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
253253
+ "\003\032\221\001\n\tHeartbeat\022G\n\022continuation_token\030\001 "
254254
+ "\001(\0132+.google.bigtable.v2.StreamContinuat"
255255
+ "ionToken\022;\n\027estimated_low_watermark\030\002 \001("
256-
+ "\0132\032.google.protobuf.Timestamp\032{\n\013CloseSt"
257-
+ "ream\022\"\n\006status\030\001 \001(\0132\022.google.rpc.Status"
258-
+ "\022H\n\023continuation_tokens\030\002 \003(\0132+.google.b"
259-
+ "igtable.v2.StreamContinuationTokenB\017\n\rst"
260-
+ "ream_record2\327\030\n\010Bigtable\022\233\002\n\010ReadRows\022#."
261-
+ "google.bigtable.v2.ReadRowsRequest\032$.goo"
262-
+ "gle.bigtable.v2.ReadRowsResponse\"\301\001\202\323\344\223\002"
263-
+ ">\"9/v2/{table_name=projects/*/instances/"
264-
+ "*/tables/*}:readRows:\001*\212\323\344\223\002N\022:\n\ntable_n"
265-
+ "ame\022,{table_name=projects/*/instances/*/"
266-
+ "tables/*}\022\020\n\016app_profile_id\332A\ntable_name"
267-
+ "\332A\031table_name,app_profile_id0\001\022\254\002\n\rSampl"
268-
+ "eRowKeys\022(.google.bigtable.v2.SampleRowK"
269-
+ "eysRequest\032).google.bigtable.v2.SampleRo"
270-
+ "wKeysResponse\"\303\001\202\323\344\223\002@\022>/v2/{table_name="
271-
+ "projects/*/instances/*/tables/*}:sampleR"
272-
+ "owKeys\212\323\344\223\002N\022:\n\ntable_name\022,{table_name="
256+
+ "\0132\032.google.protobuf.Timestamp\032\270\001\n\013CloseS"
257+
+ "tream\022\"\n\006status\030\001 \001(\0132\022.google.rpc.Statu"
258+
+ "s\022H\n\023continuation_tokens\030\002 \003(\0132+.google."
259+
+ "bigtable.v2.StreamContinuationToken\022;\n\016n"
260+
+ "ew_partitions\030\003 \003(\0132#.google.bigtable.v2"
261+
+ ".StreamPartitionB\017\n\rstream_record2\327\030\n\010Bi"
262+
+ "gtable\022\233\002\n\010ReadRows\022#.google.bigtable.v2"
263+
+ ".ReadRowsRequest\032$.google.bigtable.v2.Re"
264+
+ "adRowsResponse\"\301\001\202\323\344\223\002>\"9/v2/{table_name"
265+
+ "=projects/*/instances/*/tables/*}:readRo"
266+
+ "ws:\001*\212\323\344\223\002N\022:\n\ntable_name\022,{table_name=p"
267+
+ "rojects/*/instances/*/tables/*}\022\020\n\016app_p"
268+
+ "rofile_id\332A\ntable_name\332A\031table_name,app_"
269+
+ "profile_id0\001\022\254\002\n\rSampleRowKeys\022(.google."
270+
+ "bigtable.v2.SampleRowKeysRequest\032).googl"
271+
+ "e.bigtable.v2.SampleRowKeysResponse\"\303\001\202\323"
272+
+ "\344\223\002@\022>/v2/{table_name=projects/*/instanc"
273+
+ "es/*/tables/*}:sampleRowKeys\212\323\344\223\002N\022:\n\nta"
274+
+ "ble_name\022,{table_name=projects/*/instanc"
275+
+ "es/*/tables/*}\022\020\n\016app_profile_id\332A\ntable"
276+
+ "_name\332A\031table_name,app_profile_id0\001\022\301\002\n\t"
277+
+ "MutateRow\022$.google.bigtable.v2.MutateRow"
278+
+ "Request\032%.google.bigtable.v2.MutateRowRe"
279+
+ "sponse\"\346\001\202\323\344\223\002?\":/v2/{table_name=project"
280+
+ "s/*/instances/*/tables/*}:mutateRow:\001*\212\323"
281+
+ "\344\223\002N\022:\n\ntable_name\022,{table_name=projects"
282+
+ "/*/instances/*/tables/*}\022\020\n\016app_profile_"
283+
+ "id\332A\034table_name,row_key,mutations\332A+tabl"
284+
+ "e_name,row_key,mutations,app_profile_id\022"
285+
+ "\263\002\n\nMutateRows\022%.google.bigtable.v2.Muta"
286+
+ "teRowsRequest\032&.google.bigtable.v2.Mutat"
287+
+ "eRowsResponse\"\323\001\202\323\344\223\002@\";/v2/{table_name="
288+
+ "projects/*/instances/*/tables/*}:mutateR"
289+
+ "ows:\001*\212\323\344\223\002N\022:\n\ntable_name\022,{table_name="
273290
+ "projects/*/instances/*/tables/*}\022\020\n\016app_"
274-
+ "profile_id\332A\ntable_name\332A\031table_name,app"
275-
+ "_profile_id0\001\022\301\002\n\tMutateRow\022$.google.big"
276-
+ "table.v2.MutateRowRequest\032%.google.bigta"
277-
+ "ble.v2.MutateRowResponse\"\346\001\202\323\344\223\002?\":/v2/{"
291+
+ "profile_id\332A\022table_name,entries\332A!table_"
292+
+ "name,entries,app_profile_id0\001\022\255\003\n\021CheckA"
293+
+ "ndMutateRow\022,.google.bigtable.v2.CheckAn"
294+
+ "dMutateRowRequest\032-.google.bigtable.v2.C"
295+
+ "heckAndMutateRowResponse\"\272\002\202\323\344\223\002G\"B/v2/{"
278296
+ "table_name=projects/*/instances/*/tables"
279-
+ "/*}:mutateRow:\001*\212\323\344\223\002N\022:\n\ntable_name\022,{t"
280-
+ "able_name=projects/*/instances/*/tables/"
281-
+ "*}\022\020\n\016app_profile_id\332A\034table_name,row_ke"
282-
+ "y,mutations\332A+table_name,row_key,mutatio"
283-
+ "ns,app_profile_id\022\263\002\n\nMutateRows\022%.googl"
284-
+ "e.bigtable.v2.MutateRowsRequest\032&.google"
285-
+ ".bigtable.v2.MutateRowsResponse\"\323\001\202\323\344\223\002@"
286-
+ "\";/v2/{table_name=projects/*/instances/*"
287-
+ "/tables/*}:mutateRows:\001*\212\323\344\223\002N\022:\n\ntable_"
297+
+ "/*}:checkAndMutateRow:\001*\212\323\344\223\002N\022:\n\ntable_"
288298
+ "name\022,{table_name=projects/*/instances/*"
289-
+ "/tables/*}\022\020\n\016app_profile_id\332A\022table_nam"
290-
+ "e,entries\332A!table_name,entries,app_profi"
291-
+ "le_id0\001\022\255\003\n\021CheckAndMutateRow\022,.google.b"
292-
+ "igtable.v2.CheckAndMutateRowRequest\032-.go"
293-
+ "ogle.bigtable.v2.CheckAndMutateRowRespon"
294-
+ "se\"\272\002\202\323\344\223\002G\"B/v2/{table_name=projects/*/"
295-
+ "instances/*/tables/*}:checkAndMutateRow:"
296-
+ "\001*\212\323\344\223\002N\022:\n\ntable_name\022,{table_name=proj"
297-
+ "ects/*/instances/*/tables/*}\022\020\n\016app_prof"
298-
+ "ile_id\332ABtable_name,row_key,predicate_fi"
299-
+ "lter,true_mutations,false_mutations\332AQta"
300-
+ "ble_name,row_key,predicate_filter,true_m"
301-
+ "utations,false_mutations,app_profile_id\022"
302-
+ "\356\001\n\013PingAndWarm\022&.google.bigtable.v2.Pin"
303-
+ "gAndWarmRequest\032\'.google.bigtable.v2.Pin"
304-
+ "gAndWarmResponse\"\215\001\202\323\344\223\002+\"&/v2/{name=pro"
305-
+ "jects/*/instances/*}:ping:\001*\212\323\344\223\0029\022%\n\004na"
306-
+ "me\022\035{name=projects/*/instances/*}\022\020\n\016app"
307-
+ "_profile_id\332A\004name\332A\023name,app_profile_id"
308-
+ "\022\335\002\n\022ReadModifyWriteRow\022-.google.bigtabl"
309-
+ "e.v2.ReadModifyWriteRowRequest\032..google."
310-
+ "bigtable.v2.ReadModifyWriteRowResponse\"\347"
311-
+ "\001\202\323\344\223\002H\"C/v2/{table_name=projects/*/inst"
312-
+ "ances/*/tables/*}:readModifyWriteRow:\001*\212"
313-
+ "\323\344\223\002N\022:\n\ntable_name\022,{table_name=project"
314-
+ "s/*/instances/*/tables/*}\022\020\n\016app_profile"
315-
+ "_id\332A\030table_name,row_key,rules\332A\'table_n"
316-
+ "ame,row_key,rules,app_profile_id\022\273\002\n%Gen"
317-
+ "erateInitialChangeStreamPartitions\022@.goo"
318-
+ "gle.bigtable.v2.GenerateInitialChangeStr"
319-
+ "eamPartitionsRequest\032A.google.bigtable.v"
320-
+ "2.GenerateInitialChangeStreamPartitionsR"
321-
+ "esponse\"\212\001\202\323\344\223\002[\"V/v2/{table_name=projec"
322-
+ "ts/*/instances/*/tables/*}:generateIniti"
323-
+ "alChangeStreamPartitions:\001*\332A\ntable_name"
324-
+ "\332A\031table_name,app_profile_id0\001\022\346\001\n\020ReadC"
325-
+ "hangeStream\022+.google.bigtable.v2.ReadCha"
326-
+ "ngeStreamRequest\032,.google.bigtable.v2.Re"
327-
+ "adChangeStreamResponse\"u\202\323\344\223\002F\"A/v2/{tab"
328-
+ "le_name=projects/*/instances/*/tables/*}"
329-
+ ":readChangeStream:\001*\332A\ntable_name\332A\031tabl"
330-
+ "e_name,app_profile_id0\001\032\333\002\312A\027bigtable.go"
331-
+ "ogleapis.com\322A\275\002https://www.googleapis.c"
332-
+ "om/auth/bigtable.data,https://www.google"
333-
+ "apis.com/auth/bigtable.data.readonly,htt"
334-
+ "ps://www.googleapis.com/auth/cloud-bigta"
335-
+ "ble.data,https://www.googleapis.com/auth"
336-
+ "/cloud-bigtable.data.readonly,https://ww"
337-
+ "w.googleapis.com/auth/cloud-platform,htt"
338-
+ "ps://www.googleapis.com/auth/cloud-platf"
339-
+ "orm.read-onlyB\353\002\n\026com.google.bigtable.v2"
340-
+ "B\rBigtableProtoP\001Z:google.golang.org/gen"
341-
+ "proto/googleapis/bigtable/v2;bigtable\252\002\030"
342-
+ "Google.Cloud.Bigtable.V2\312\002\030Google\\Cloud\\"
343-
+ "Bigtable\\V2\352\002\033Google::Cloud::Bigtable::V"
344-
+ "2\352AP\n%bigtableadmin.googleapis.com/Insta"
345-
+ "nce\022\'projects/{project}/instances/{insta"
346-
+ "nce}\352A\\\n\"bigtableadmin.googleapis.com/Ta"
347-
+ "ble\0226projects/{project}/instances/{insta"
348-
+ "nce}/tables/{table}b\006proto3"
299+
+ "/tables/*}\022\020\n\016app_profile_id\332ABtable_nam"
300+
+ "e,row_key,predicate_filter,true_mutation"
301+
+ "s,false_mutations\332AQtable_name,row_key,p"
302+
+ "redicate_filter,true_mutations,false_mut"
303+
+ "ations,app_profile_id\022\356\001\n\013PingAndWarm\022&."
304+
+ "google.bigtable.v2.PingAndWarmRequest\032\'."
305+
+ "google.bigtable.v2.PingAndWarmResponse\"\215"
306+
+ "\001\202\323\344\223\002+\"&/v2/{name=projects/*/instances/"
307+
+ "*}:ping:\001*\212\323\344\223\0029\022%\n\004name\022\035{name=projects"
308+
+ "/*/instances/*}\022\020\n\016app_profile_id\332A\004name"
309+
+ "\332A\023name,app_profile_id\022\335\002\n\022ReadModifyWri"
310+
+ "teRow\022-.google.bigtable.v2.ReadModifyWri"
311+
+ "teRowRequest\032..google.bigtable.v2.ReadMo"
312+
+ "difyWriteRowResponse\"\347\001\202\323\344\223\002H\"C/v2/{tabl"
313+
+ "e_name=projects/*/instances/*/tables/*}:"
314+
+ "readModifyWriteRow:\001*\212\323\344\223\002N\022:\n\ntable_nam"
315+
+ "e\022,{table_name=projects/*/instances/*/ta"
316+
+ "bles/*}\022\020\n\016app_profile_id\332A\030table_name,r"
317+
+ "ow_key,rules\332A\'table_name,row_key,rules,"
318+
+ "app_profile_id\022\273\002\n%GenerateInitialChange"
319+
+ "StreamPartitions\022@.google.bigtable.v2.Ge"
320+
+ "nerateInitialChangeStreamPartitionsReque"
321+
+ "st\032A.google.bigtable.v2.GenerateInitialC"
322+
+ "hangeStreamPartitionsResponse\"\212\001\202\323\344\223\002[\"V"
323+
+ "/v2/{table_name=projects/*/instances/*/t"
324+
+ "ables/*}:generateInitialChangeStreamPart"
325+
+ "itions:\001*\332A\ntable_name\332A\031table_name,app_"
326+
+ "profile_id0\001\022\346\001\n\020ReadChangeStream\022+.goog"
327+
+ "le.bigtable.v2.ReadChangeStreamRequest\032,"
328+
+ ".google.bigtable.v2.ReadChangeStreamResp"
329+
+ "onse\"u\202\323\344\223\002F\"A/v2/{table_name=projects/*"
330+
+ "/instances/*/tables/*}:readChangeStream:"
331+
+ "\001*\332A\ntable_name\332A\031table_name,app_profile"
332+
+ "_id0\001\032\333\002\312A\027bigtable.googleapis.com\322A\275\002ht"
333+
+ "tps://www.googleapis.com/auth/bigtable.d"
334+
+ "ata,https://www.googleapis.com/auth/bigt"
335+
+ "able.data.readonly,https://www.googleapi"
336+
+ "s.com/auth/cloud-bigtable.data,https://w"
337+
+ "ww.googleapis.com/auth/cloud-bigtable.da"
338+
+ "ta.readonly,https://www.googleapis.com/a"
339+
+ "uth/cloud-platform,https://www.googleapi"
340+
+ "s.com/auth/cloud-platform.read-onlyB\353\002\n\026"
341+
+ "com.google.bigtable.v2B\rBigtableProtoP\001Z"
342+
+ ":google.golang.org/genproto/googleapis/b"
343+
+ "igtable/v2;bigtable\252\002\030Google.Cloud.Bigta"
344+
+ "ble.V2\312\002\030Google\\Cloud\\Bigtable\\V2\352\002\033Goog"
345+
+ "le::Cloud::Bigtable::V2\352AP\n%bigtableadmi"
346+
+ "n.googleapis.com/Instance\022\'projects/{pro"
347+
+ "ject}/instances/{instance}\352A\\\n\"bigtablea"
348+
+ "dmin.googleapis.com/Table\0226projects/{pro"
349+
+ "ject}/instances/{instance}/tables/{table"
350+
+ "}b\006proto3"
349351
};
350352
descriptor =
351353
com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(
@@ -604,7 +606,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
604606
new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
605607
internal_static_google_bigtable_v2_ReadChangeStreamResponse_CloseStream_descriptor,
606608
new java.lang.String[] {
607-
"Status", "ContinuationTokens",
609+
"Status", "ContinuationTokens", "NewPartitions",
608610
});
609611
com.google.protobuf.ExtensionRegistry registry =
610612
com.google.protobuf.ExtensionRegistry.newInstance();

0 commit comments

Comments
 (0)