Skip to content

Commit

Permalink
feat: add new_partitions field for CloseStream for Cloud Bigtable Cha…
Browse files Browse the repository at this point in the history 
…ngeStream (#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
  • Loading branch information
@gcf-owl-bot
gcf-owl-bot[bot] committed Feb 28, 2023
1 parent 87261a9 commit 0e283bf
Show file tree
Hide file tree
Showing 3 changed files with 815 additions and 162 deletions.
186 changes: 94 additions & 92 deletions proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/BigtableProto.java
View file
Expand Up @@ -225,7 +225,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
+ "able.v2.StreamContinuationTokensH\000\022,\n\010en"
+ "d_time\030\005 \001(\0132\032.google.protobuf.Timestamp"
+ "\0225\n\022heartbeat_duration\030\007 \001(\0132\031.google.pr"
+ "otobuf.DurationB\014\n\nstart_from\"\353\t\n\030ReadCh"
+ "otobuf.DurationB\014\n\nstart_from\"\251\n\n\030ReadCh"
+ "angeStreamResponse\022N\n\013data_change\030\001 \001(\0132"
+ "7.google.bigtable.v2.ReadChangeStreamRes"
+ "ponse.DataChangeH\000\022K\n\theartbeat\030\002 \001(\01326."
Expand Down Expand Up @@ -253,99 +253,101 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
+ "\003\032\221\001\n\tHeartbeat\022G\n\022continuation_token\030\001 "
+ "\001(\0132+.google.bigtable.v2.StreamContinuat"
+ "ionToken\022;\n\027estimated_low_watermark\030\002 \001("
+ "\0132\032.google.protobuf.Timestamp\032{\n\013CloseSt"
+ "ream\022\"\n\006status\030\001 \001(\0132\022.google.rpc.Status"
+ "\022H\n\023continuation_tokens\030\002 \003(\0132+.google.b"
+ "igtable.v2.StreamContinuationTokenB\017\n\rst"
+ "ream_record2\327\030\n\010Bigtable\022\233\002\n\010ReadRows\022#."
+ "google.bigtable.v2.ReadRowsRequest\032$.goo"
+ "gle.bigtable.v2.ReadRowsResponse\"\301\001\202\323\344\223\002"
+ ">\"9/v2/{table_name=projects/*/instances/"
+ "*/tables/*}:readRows:\001*\212\323\344\223\002N\022:\n\ntable_n"
+ "ame\022,{table_name=projects/*/instances/*/"
+ "tables/*}\022\020\n\016app_profile_id\332A\ntable_name"
+ "\332A\031table_name,app_profile_id0\001\022\254\002\n\rSampl"
+ "eRowKeys\022(.google.bigtable.v2.SampleRowK"
+ "eysRequest\032).google.bigtable.v2.SampleRo"
+ "wKeysResponse\"\303\001\202\323\344\223\002@\022>/v2/{table_name="
+ "projects/*/instances/*/tables/*}:sampleR"
+ "owKeys\212\323\344\223\002N\022:\n\ntable_name\022,{table_name="
+ "\0132\032.google.protobuf.Timestamp\032\270\001\n\013CloseS"
+ "tream\022\"\n\006status\030\001 \001(\0132\022.google.rpc.Statu"
+ "s\022H\n\023continuation_tokens\030\002 \003(\0132+.google."
+ "bigtable.v2.StreamContinuationToken\022;\n\016n"
+ "ew_partitions\030\003 \003(\0132#.google.bigtable.v2"
+ ".StreamPartitionB\017\n\rstream_record2\327\030\n\010Bi"
+ "gtable\022\233\002\n\010ReadRows\022#.google.bigtable.v2"
+ ".ReadRowsRequest\032$.google.bigtable.v2.Re"
+ "adRowsResponse\"\301\001\202\323\344\223\002>\"9/v2/{table_name"
+ "=projects/*/instances/*/tables/*}:readRo"
+ "ws:\001*\212\323\344\223\002N\022:\n\ntable_name\022,{table_name=p"
+ "rojects/*/instances/*/tables/*}\022\020\n\016app_p"
+ "rofile_id\332A\ntable_name\332A\031table_name,app_"
+ "profile_id0\001\022\254\002\n\rSampleRowKeys\022(.google."
+ "bigtable.v2.SampleRowKeysRequest\032).googl"
+ "e.bigtable.v2.SampleRowKeysResponse\"\303\001\202\323"
+ "\344\223\002@\022>/v2/{table_name=projects/*/instanc"
+ "es/*/tables/*}:sampleRowKeys\212\323\344\223\002N\022:\n\nta"
+ "ble_name\022,{table_name=projects/*/instanc"
+ "es/*/tables/*}\022\020\n\016app_profile_id\332A\ntable"
+ "_name\332A\031table_name,app_profile_id0\001\022\301\002\n\t"
+ "MutateRow\022$.google.bigtable.v2.MutateRow"
+ "Request\032%.google.bigtable.v2.MutateRowRe"
+ "sponse\"\346\001\202\323\344\223\002?\":/v2/{table_name=project"
+ "s/*/instances/*/tables/*}:mutateRow:\001*\212\323"
+ "\344\223\002N\022:\n\ntable_name\022,{table_name=projects"
+ "/*/instances/*/tables/*}\022\020\n\016app_profile_"
+ "id\332A\034table_name,row_key,mutations\332A+tabl"
+ "e_name,row_key,mutations,app_profile_id\022"
+ "\263\002\n\nMutateRows\022%.google.bigtable.v2.Muta"
+ "teRowsRequest\032&.google.bigtable.v2.Mutat"
+ "eRowsResponse\"\323\001\202\323\344\223\002@\";/v2/{table_name="
+ "projects/*/instances/*/tables/*}:mutateR"
+ "ows:\001*\212\323\344\223\002N\022:\n\ntable_name\022,{table_name="
+ "projects/*/instances/*/tables/*}\022\020\n\016app_"
+ "profile_id\332A\ntable_name\332A\031table_name,app"
+ "_profile_id0\001\022\301\002\n\tMutateRow\022$.google.big"
+ "table.v2.MutateRowRequest\032%.google.bigta"
+ "ble.v2.MutateRowResponse\"\346\001\202\323\344\223\002?\":/v2/{"
+ "profile_id\332A\022table_name,entries\332A!table_"
+ "name,entries,app_profile_id0\001\022\255\003\n\021CheckA"
+ "ndMutateRow\022,.google.bigtable.v2.CheckAn"
+ "dMutateRowRequest\032-.google.bigtable.v2.C"
+ "heckAndMutateRowResponse\"\272\002\202\323\344\223\002G\"B/v2/{"
+ "table_name=projects/*/instances/*/tables"
+ "/*}:mutateRow:\001*\212\323\344\223\002N\022:\n\ntable_name\022,{t"
+ "able_name=projects/*/instances/*/tables/"
+ "*}\022\020\n\016app_profile_id\332A\034table_name,row_ke"
+ "y,mutations\332A+table_name,row_key,mutatio"
+ "ns,app_profile_id\022\263\002\n\nMutateRows\022%.googl"
+ "e.bigtable.v2.MutateRowsRequest\032&.google"
+ ".bigtable.v2.MutateRowsResponse\"\323\001\202\323\344\223\002@"
+ "\";/v2/{table_name=projects/*/instances/*"
+ "/tables/*}:mutateRows:\001*\212\323\344\223\002N\022:\n\ntable_"
+ "/*}:checkAndMutateRow:\001*\212\323\344\223\002N\022:\n\ntable_"
+ "name\022,{table_name=projects/*/instances/*"
+ "/tables/*}\022\020\n\016app_profile_id\332A\022table_nam"
+ "e,entries\332A!table_name,entries,app_profi"
+ "le_id0\001\022\255\003\n\021CheckAndMutateRow\022,.google.b"
+ "igtable.v2.CheckAndMutateRowRequest\032-.go"
+ "ogle.bigtable.v2.CheckAndMutateRowRespon"
+ "se\"\272\002\202\323\344\223\002G\"B/v2/{table_name=projects/*/"
+ "instances/*/tables/*}:checkAndMutateRow:"
+ "\001*\212\323\344\223\002N\022:\n\ntable_name\022,{table_name=proj"
+ "ects/*/instances/*/tables/*}\022\020\n\016app_prof"
+ "ile_id\332ABtable_name,row_key,predicate_fi"
+ "lter,true_mutations,false_mutations\332AQta"
+ "ble_name,row_key,predicate_filter,true_m"
+ "utations,false_mutations,app_profile_id\022"
+ "\356\001\n\013PingAndWarm\022&.google.bigtable.v2.Pin"
+ "gAndWarmRequest\032\'.google.bigtable.v2.Pin"
+ "gAndWarmResponse\"\215\001\202\323\344\223\002+\"&/v2/{name=pro"
+ "jects/*/instances/*}:ping:\001*\212\323\344\223\0029\022%\n\004na"
+ "me\022\035{name=projects/*/instances/*}\022\020\n\016app"
+ "_profile_id\332A\004name\332A\023name,app_profile_id"
+ "\022\335\002\n\022ReadModifyWriteRow\022-.google.bigtabl"
+ "e.v2.ReadModifyWriteRowRequest\032..google."
+ "bigtable.v2.ReadModifyWriteRowResponse\"\347"
+ "\001\202\323\344\223\002H\"C/v2/{table_name=projects/*/inst"
+ "ances/*/tables/*}:readModifyWriteRow:\001*\212"
+ "\323\344\223\002N\022:\n\ntable_name\022,{table_name=project"
+ "s/*/instances/*/tables/*}\022\020\n\016app_profile"
+ "_id\332A\030table_name,row_key,rules\332A\'table_n"
+ "ame,row_key,rules,app_profile_id\022\273\002\n%Gen"
+ "erateInitialChangeStreamPartitions\022@.goo"
+ "gle.bigtable.v2.GenerateInitialChangeStr"
+ "eamPartitionsRequest\032A.google.bigtable.v"
+ "2.GenerateInitialChangeStreamPartitionsR"
+ "esponse\"\212\001\202\323\344\223\002[\"V/v2/{table_name=projec"
+ "ts/*/instances/*/tables/*}:generateIniti"
+ "alChangeStreamPartitions:\001*\332A\ntable_name"
+ "\332A\031table_name,app_profile_id0\001\022\346\001\n\020ReadC"
+ "hangeStream\022+.google.bigtable.v2.ReadCha"
+ "ngeStreamRequest\032,.google.bigtable.v2.Re"
+ "adChangeStreamResponse\"u\202\323\344\223\002F\"A/v2/{tab"
+ "le_name=projects/*/instances/*/tables/*}"
+ ":readChangeStream:\001*\332A\ntable_name\332A\031tabl"
+ "e_name,app_profile_id0\001\032\333\002\312A\027bigtable.go"
+ "ogleapis.com\322A\275\002https://www.googleapis.c"
+ "om/auth/bigtable.data,https://www.google"
+ "apis.com/auth/bigtable.data.readonly,htt"
+ "ps://www.googleapis.com/auth/cloud-bigta"
+ "ble.data,https://www.googleapis.com/auth"
+ "/cloud-bigtable.data.readonly,https://ww"
+ "w.googleapis.com/auth/cloud-platform,htt"
+ "ps://www.googleapis.com/auth/cloud-platf"
+ "orm.read-onlyB\353\002\n\026com.google.bigtable.v2"
+ "B\rBigtableProtoP\001Z:google.golang.org/gen"
+ "proto/googleapis/bigtable/v2;bigtable\252\002\030"
+ "Google.Cloud.Bigtable.V2\312\002\030Google\\Cloud\\"
+ "Bigtable\\V2\352\002\033Google::Cloud::Bigtable::V"
+ "2\352AP\n%bigtableadmin.googleapis.com/Insta"
+ "nce\022\'projects/{project}/instances/{insta"
+ "nce}\352A\\\n\"bigtableadmin.googleapis.com/Ta"
+ "ble\0226projects/{project}/instances/{insta"
+ "nce}/tables/{table}b\006proto3"
+ "/tables/*}\022\020\n\016app_profile_id\332ABtable_nam"
+ "e,row_key,predicate_filter,true_mutation"
+ "s,false_mutations\332AQtable_name,row_key,p"
+ "redicate_filter,true_mutations,false_mut"
+ "ations,app_profile_id\022\356\001\n\013PingAndWarm\022&."
+ "google.bigtable.v2.PingAndWarmRequest\032\'."
+ "google.bigtable.v2.PingAndWarmResponse\"\215"
+ "\001\202\323\344\223\002+\"&/v2/{name=projects/*/instances/"
+ "*}:ping:\001*\212\323\344\223\0029\022%\n\004name\022\035{name=projects"
+ "/*/instances/*}\022\020\n\016app_profile_id\332A\004name"
+ "\332A\023name,app_profile_id\022\335\002\n\022ReadModifyWri"
+ "teRow\022-.google.bigtable.v2.ReadModifyWri"
+ "teRowRequest\032..google.bigtable.v2.ReadMo"
+ "difyWriteRowResponse\"\347\001\202\323\344\223\002H\"C/v2/{tabl"
+ "e_name=projects/*/instances/*/tables/*}:"
+ "readModifyWriteRow:\001*\212\323\344\223\002N\022:\n\ntable_nam"
+ "e\022,{table_name=projects/*/instances/*/ta"
+ "bles/*}\022\020\n\016app_profile_id\332A\030table_name,r"
+ "ow_key,rules\332A\'table_name,row_key,rules,"
+ "app_profile_id\022\273\002\n%GenerateInitialChange"
+ "StreamPartitions\022@.google.bigtable.v2.Ge"
+ "nerateInitialChangeStreamPartitionsReque"
+ "st\032A.google.bigtable.v2.GenerateInitialC"
+ "hangeStreamPartitionsResponse\"\212\001\202\323\344\223\002[\"V"
+ "/v2/{table_name=projects/*/instances/*/t"
+ "ables/*}:generateInitialChangeStreamPart"
+ "itions:\001*\332A\ntable_name\332A\031table_name,app_"
+ "profile_id0\001\022\346\001\n\020ReadChangeStream\022+.goog"
+ "le.bigtable.v2.ReadChangeStreamRequest\032,"
+ ".google.bigtable.v2.ReadChangeStreamResp"
+ "onse\"u\202\323\344\223\002F\"A/v2/{table_name=projects/*"
+ "/instances/*/tables/*}:readChangeStream:"
+ "\001*\332A\ntable_name\332A\031table_name,app_profile"
+ "_id0\001\032\333\002\312A\027bigtable.googleapis.com\322A\275\002ht"
+ "tps://www.googleapis.com/auth/bigtable.d"
+ "ata,https://www.googleapis.com/auth/bigt"
+ "able.data.readonly,https://www.googleapi"
+ "s.com/auth/cloud-bigtable.data,https://w"
+ "ww.googleapis.com/auth/cloud-bigtable.da"
+ "ta.readonly,https://www.googleapis.com/a"
+ "uth/cloud-platform,https://www.googleapi"
+ "s.com/auth/cloud-platform.read-onlyB\353\002\n\026"
+ "com.google.bigtable.v2B\rBigtableProtoP\001Z"
+ ":google.golang.org/genproto/googleapis/b"
+ "igtable/v2;bigtable\252\002\030Google.Cloud.Bigta"
+ "ble.V2\312\002\030Google\\Cloud\\Bigtable\\V2\352\002\033Goog"
+ "le::Cloud::Bigtable::V2\352AP\n%bigtableadmi"
+ "n.googleapis.com/Instance\022\'projects/{pro"
+ "ject}/instances/{instance}\352A\\\n\"bigtablea"
+ "dmin.googleapis.com/Table\0226projects/{pro"
+ "ject}/instances/{instance}/tables/{table"
+ "}b\006proto3"
};
descriptor =
com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(
Expand Down Expand Up @@ -604,7 +606,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_bigtable_v2_ReadChangeStreamResponse_CloseStream_descriptor,
new java.lang.String[] {
"Status", "ContinuationTokens",
"Status", "ContinuationTokens", "NewPartitions",
});
com.google.protobuf.ExtensionRegistry registry =
com.google.protobuf.ExtensionRegistry.newInstance();
Expand Down

0 comments on commit 0e283bf

Please sign in to comment.