From 3252643e76e9e85c899f09610a9827a7869622e6 Mon Sep 17 00:00:00 2001 From: Danny Hermes Date: Tue, 16 Feb 2016 07:38:43 -0800 Subject: [PATCH] Updating Bigtable generated files. --- .../_generated/_bigtable_cluster_data.proto | 9 +- .../bigtable/_generated/_bigtable_data.proto | 15 ++ .../_generated/_bigtable_service.proto | 7 + .../_bigtable_service_messages.proto | 37 ++++ .../_generated/bigtable_cluster_data_pb2.py | 29 ++- .../bigtable/_generated/bigtable_data_pb2.py | 101 ++++++--- .../bigtable_service_messages_pb2.py | 192 +++++++++++++++--- .../_generated/bigtable_service_pb2.py | 39 +++- 8 files changed, 357 insertions(+), 72 deletions(-) diff --git a/gcloud/bigtable/_generated/_bigtable_cluster_data.proto b/gcloud/bigtable/_generated/_bigtable_cluster_data.proto index cbebe186dd64..c0f8a93f2862 100644 --- a/gcloud/bigtable/_generated/_bigtable_cluster_data.proto +++ b/gcloud/bigtable/_generated/_bigtable_cluster_data.proto @@ -62,11 +62,6 @@ message Cluster { // projects//zones//clusters/[a-z][-a-z0-9]* string name = 1; - // If this cluster has been deleted, the time at which its backup will - // be irrevocably destroyed. Omitted otherwise. - // This cannot be set directly, only through DeleteCluster. - google.protobuf.Timestamp delete_time = 2; - // The operation currently running on the cluster, if any. // This cannot be set directly, only through CreateCluster, UpdateCluster, // or UndeleteCluster. Calls to these methods will be rejected if @@ -91,4 +86,8 @@ enum StorageType { // Data will be stored in SSD, providing low and consistent latencies. STORAGE_SSD = 1; + + // Data will be stored in HDD, providing high and less predictable + // latencies. + STORAGE_HDD = 2; } diff --git a/gcloud/bigtable/_generated/_bigtable_data.proto b/gcloud/bigtable/_generated/_bigtable_data.proto index 86234d22d595..290eb9116ad0 100644 --- a/gcloud/bigtable/_generated/_bigtable_data.proto +++ b/gcloud/bigtable/_generated/_bigtable_data.proto @@ -89,6 +89,15 @@ message RowRange { bytes end_key = 3; } +// Specifies a non-contiguous set of rows. +message RowSet { + // Single rows included in the set. + repeated bytes row_keys = 1; + + // Contiguous row ranges included in the set. + repeated RowRange row_ranges = 2; +} + // Specifies a contiguous range of columns within a single column family. // The range spans from : to // :, where both bounds can be either inclusive or @@ -374,15 +383,21 @@ message RowFilter { ValueRange value_range_filter = 15; // Skips the first N cells of each row, matching all subsequent cells. + // If duplicate cells are present, as is possible when using an Interleave, + // each copy of the cell is counted separately. int32 cells_per_row_offset_filter = 10; // Matches only the first N cells of each row. + // If duplicate cells are present, as is possible when using an Interleave, + // each copy of the cell is counted separately. int32 cells_per_row_limit_filter = 11; // Matches only the most recent N cells within each column. For example, // if N=2, this filter would match column "foo:bar" at timestamps 10 and 9, // skip all earlier cells in "foo:bar", and then begin matching again in // column "foo:bar2". + // If duplicate cells are present, as is possible when using an Interleave, + // each copy of the cell is counted separately. int32 cells_per_column_limit_filter = 12; // Replaces each cell's value with the empty string. diff --git a/gcloud/bigtable/_generated/_bigtable_service.proto b/gcloud/bigtable/_generated/_bigtable_service.proto index 7f9109fdf34b..f1a83d351b63 100644 --- a/gcloud/bigtable/_generated/_bigtable_service.proto +++ b/gcloud/bigtable/_generated/_bigtable_service.proto @@ -51,6 +51,13 @@ service BigtableService { option (google.api.http) = { post: "/v1/{table_name=projects/*/zones/*/clusters/*/tables/*}/rows/{row_key}:mutate" body: "*" }; } + // Mutates multiple rows in a batch. Each individual row is mutated + // atomically as in MutateRow, but the entire batch is not executed + // atomically. + rpc MutateRows(MutateRowsRequest) returns (MutateRowsResponse) { + option (google.api.http) = { post: "/v1/{table_name=projects/*/zones/*/clusters/*/tables/*}:mutateRows" body: "*" }; + } + // Mutates a row atomically based on the output of a predicate Reader filter. rpc CheckAndMutateRow(CheckAndMutateRowRequest) returns (CheckAndMutateRowResponse) { option (google.api.http) = { post: "/v1/{table_name=projects/*/zones/*/clusters/*/tables/*}/rows/{row_key}:checkAndMutate" body: "*" }; diff --git a/gcloud/bigtable/_generated/_bigtable_service_messages.proto b/gcloud/bigtable/_generated/_bigtable_service_messages.proto index dacc0fcad83d..1479fb65eebf 100644 --- a/gcloud/bigtable/_generated/_bigtable_service_messages.proto +++ b/gcloud/bigtable/_generated/_bigtable_service_messages.proto @@ -17,6 +17,7 @@ syntax = "proto3"; package google.bigtable.v1; import "google/bigtable/v1/bigtable_data.proto"; +import "google/rpc/status.proto"; option java_multiple_files = true; option java_outer_classname = "BigtableServiceMessagesProto"; @@ -35,6 +36,11 @@ message ReadRowsRequest { // A range of rows from which to read. RowRange row_range = 3; + + // A set of rows from which to read. Entries need not be in order, and will + // be deduplicated before reading. + // The total serialized size of the set must not exceed 1MB. + RowSet row_set = 8; } // The filter to apply to the contents of the specified row(s). If unset, @@ -124,6 +130,37 @@ message MutateRowRequest { repeated Mutation mutations = 3; } +// Request message for BigtableService.MutateRows. +message MutateRowsRequest { + message Entry { + // The key of the row to which the `mutations` should be applied. + bytes row_key = 1; + + // Changes to be atomically applied to the specified row. Mutations are + // applied in order, meaning that earlier mutations can be masked by + // later ones. + // At least one mutation must be specified. + repeated Mutation mutations = 2; + } + + // The unique name of the table to which the mutations should be applied. + string table_name = 1; + + // The row keys/mutations to be applied in bulk. + // Each entry is applied as an atomic mutation, but the entries may be + // applied in arbitrary order (even between entries for the same row). + // At least one entry must be specified, and in total the entries may + // contain at most 100000 mutations. + repeated Entry entries = 2; +} + +// Response message for BigtableService.MutateRows. +message MutateRowsResponse { + // The results for each Entry from the request, presented in the order + // in which the entries were originally given. + repeated google.rpc.Status statuses = 1; +} + // Request message for BigtableService.CheckAndMutateRowRequest message CheckAndMutateRowRequest { // The unique name of the table to which the conditional mutation should be diff --git a/gcloud/bigtable/_generated/bigtable_cluster_data_pb2.py b/gcloud/bigtable/_generated/bigtable_cluster_data_pb2.py index fa8b7cfc3399..4106aabd082d 100644 --- a/gcloud/bigtable/_generated/bigtable_cluster_data_pb2.py +++ b/gcloud/bigtable/_generated/bigtable_cluster_data_pb2.py @@ -21,7 +21,7 @@ name='google/bigtable/admin/cluster/v1/bigtable_cluster_data.proto', package='google.bigtable.admin.cluster.v1', syntax='proto3', - serialized_pb=b'\n\n\ninterleave\x18\x02 \x01(\x0b\x32(.google.bigtable.v1.RowFilter.InterleaveH\x00\x12<\n\tcondition\x18\x03 \x01(\x0b\x32\'.google.bigtable.v1.RowFilter.ConditionH\x00\x12\x0e\n\x04sink\x18\x10 \x01(\x08H\x00\x12\x19\n\x0fpass_all_filter\x18\x11 \x01(\x08H\x00\x12\x1a\n\x10\x62lock_all_filter\x18\x12 \x01(\x08H\x00\x12\x1e\n\x14row_key_regex_filter\x18\x04 \x01(\x0cH\x00\x12\x1b\n\x11row_sample_filter\x18\x0e \x01(\x01H\x00\x12\"\n\x18\x66\x61mily_name_regex_filter\x18\x05 \x01(\tH\x00\x12\'\n\x1d\x63olumn_qualifier_regex_filter\x18\x06 \x01(\x0cH\x00\x12>\n\x13\x63olumn_range_filter\x18\x07 \x01(\x0b\x32\x1f.google.bigtable.v1.ColumnRangeH\x00\x12\x44\n\x16timestamp_range_filter\x18\x08 \x01(\x0b\x32\".google.bigtable.v1.TimestampRangeH\x00\x12\x1c\n\x12value_regex_filter\x18\t \x01(\x0cH\x00\x12<\n\x12value_range_filter\x18\x0f \x01(\x0b\x32\x1e.google.bigtable.v1.ValueRangeH\x00\x12%\n\x1b\x63\x65lls_per_row_offset_filter\x18\n \x01(\x05H\x00\x12$\n\x1a\x63\x65lls_per_row_limit_filter\x18\x0b \x01(\x05H\x00\x12\'\n\x1d\x63\x65lls_per_column_limit_filter\x18\x0c \x01(\x05H\x00\x12!\n\x17strip_value_transformer\x18\r \x01(\x08H\x00\x12!\n\x17\x61pply_label_transformer\x18\x13 \x01(\tH\x00\x1a\x37\n\x05\x43hain\x12.\n\x07\x66ilters\x18\x01 \x03(\x0b\x32\x1d.google.bigtable.v1.RowFilter\x1a<\n\nInterleave\x12.\n\x07\x66ilters\x18\x01 \x03(\x0b\x32\x1d.google.bigtable.v1.RowFilter\x1a\xad\x01\n\tCondition\x12\x37\n\x10predicate_filter\x18\x01 \x01(\x0b\x32\x1d.google.bigtable.v1.RowFilter\x12\x32\n\x0btrue_filter\x18\x02 \x01(\x0b\x32\x1d.google.bigtable.v1.RowFilter\x12\x33\n\x0c\x66\x61lse_filter\x18\x03 \x01(\x0b\x32\x1d.google.bigtable.v1.RowFilterB\x08\n\x06\x66ilter\"\xc9\x04\n\x08Mutation\x12\x38\n\x08set_cell\x18\x01 \x01(\x0b\x32$.google.bigtable.v1.Mutation.SetCellH\x00\x12K\n\x12\x64\x65lete_from_column\x18\x02 \x01(\x0b\x32-.google.bigtable.v1.Mutation.DeleteFromColumnH\x00\x12K\n\x12\x64\x65lete_from_family\x18\x03 \x01(\x0b\x32-.google.bigtable.v1.Mutation.DeleteFromFamilyH\x00\x12\x45\n\x0f\x64\x65lete_from_row\x18\x04 \x01(\x0b\x32*.google.bigtable.v1.Mutation.DeleteFromRowH\x00\x1a\x61\n\x07SetCell\x12\x13\n\x0b\x66\x61mily_name\x18\x01 \x01(\t\x12\x18\n\x10\x63olumn_qualifier\x18\x02 \x01(\x0c\x12\x18\n\x10timestamp_micros\x18\x03 \x01(\x03\x12\r\n\x05value\x18\x04 \x01(\x0c\x1ay\n\x10\x44\x65leteFromColumn\x12\x13\n\x0b\x66\x61mily_name\x18\x01 \x01(\t\x12\x18\n\x10\x63olumn_qualifier\x18\x02 \x01(\x0c\x12\x36\n\ntime_range\x18\x03 \x01(\x0b\x32\".google.bigtable.v1.TimestampRange\x1a\'\n\x10\x44\x65leteFromFamily\x12\x13\n\x0b\x66\x61mily_name\x18\x01 \x01(\t\x1a\x0f\n\rDeleteFromRowB\n\n\x08mutation\"\x80\x01\n\x13ReadModifyWriteRule\x12\x13\n\x0b\x66\x61mily_name\x18\x01 \x01(\t\x12\x18\n\x10\x63olumn_qualifier\x18\x02 \x01(\x0c\x12\x16\n\x0c\x61ppend_value\x18\x03 \x01(\x0cH\x00\x12\x1a\n\x10increment_amount\x18\x04 \x01(\x03H\x00\x42\x06\n\x04ruleB-\n\x16\x63om.google.bigtable.v1B\x11\x42igtableDataProtoP\x01\x62\x06proto3' + serialized_pb=b'\n&google/bigtable/v1/bigtable_data.proto\x12\x12google.bigtable.v1\"@\n\x03Row\x12\x0b\n\x03key\x18\x01 \x01(\x0c\x12,\n\x08\x66\x61milies\x18\x02 \x03(\x0b\x32\x1a.google.bigtable.v1.Family\"C\n\x06\x46\x61mily\x12\x0c\n\x04name\x18\x01 \x01(\t\x12+\n\x07\x63olumns\x18\x02 \x03(\x0b\x32\x1a.google.bigtable.v1.Column\"D\n\x06\x43olumn\x12\x11\n\tqualifier\x18\x01 \x01(\x0c\x12\'\n\x05\x63\x65lls\x18\x02 \x03(\x0b\x32\x18.google.bigtable.v1.Cell\"?\n\x04\x43\x65ll\x12\x18\n\x10timestamp_micros\x18\x01 \x01(\x03\x12\r\n\x05value\x18\x02 \x01(\x0c\x12\x0e\n\x06labels\x18\x03 \x03(\t\".\n\x08RowRange\x12\x11\n\tstart_key\x18\x02 \x01(\x0c\x12\x0f\n\x07\x65nd_key\x18\x03 \x01(\x0c\"L\n\x06RowSet\x12\x10\n\x08row_keys\x18\x01 \x03(\x0c\x12\x30\n\nrow_ranges\x18\x02 \x03(\x0b\x32\x1c.google.bigtable.v1.RowRange\"\xd6\x01\n\x0b\x43olumnRange\x12\x13\n\x0b\x66\x61mily_name\x18\x01 \x01(\t\x12#\n\x19start_qualifier_inclusive\x18\x02 \x01(\x0cH\x00\x12#\n\x19start_qualifier_exclusive\x18\x03 \x01(\x0cH\x00\x12!\n\x17\x65nd_qualifier_inclusive\x18\x04 \x01(\x0cH\x01\x12!\n\x17\x65nd_qualifier_exclusive\x18\x05 \x01(\x0cH\x01\x42\x11\n\x0fstart_qualifierB\x0f\n\rend_qualifier\"N\n\x0eTimestampRange\x12\x1e\n\x16start_timestamp_micros\x18\x01 \x01(\x03\x12\x1c\n\x14\x65nd_timestamp_micros\x18\x02 \x01(\x03\"\xa8\x01\n\nValueRange\x12\x1f\n\x15start_value_inclusive\x18\x01 \x01(\x0cH\x00\x12\x1f\n\x15start_value_exclusive\x18\x02 \x01(\x0cH\x00\x12\x1d\n\x13\x65nd_value_inclusive\x18\x03 \x01(\x0cH\x01\x12\x1d\n\x13\x65nd_value_exclusive\x18\x04 \x01(\x0cH\x01\x42\r\n\x0bstart_valueB\x0b\n\tend_value\"\xdf\x08\n\tRowFilter\x12\x34\n\x05\x63hain\x18\x01 \x01(\x0b\x32#.google.bigtable.v1.RowFilter.ChainH\x00\x12>\n\ninterleave\x18\x02 \x01(\x0b\x32(.google.bigtable.v1.RowFilter.InterleaveH\x00\x12<\n\tcondition\x18\x03 \x01(\x0b\x32\'.google.bigtable.v1.RowFilter.ConditionH\x00\x12\x0e\n\x04sink\x18\x10 \x01(\x08H\x00\x12\x19\n\x0fpass_all_filter\x18\x11 \x01(\x08H\x00\x12\x1a\n\x10\x62lock_all_filter\x18\x12 \x01(\x08H\x00\x12\x1e\n\x14row_key_regex_filter\x18\x04 \x01(\x0cH\x00\x12\x1b\n\x11row_sample_filter\x18\x0e \x01(\x01H\x00\x12\"\n\x18\x66\x61mily_name_regex_filter\x18\x05 \x01(\tH\x00\x12\'\n\x1d\x63olumn_qualifier_regex_filter\x18\x06 \x01(\x0cH\x00\x12>\n\x13\x63olumn_range_filter\x18\x07 \x01(\x0b\x32\x1f.google.bigtable.v1.ColumnRangeH\x00\x12\x44\n\x16timestamp_range_filter\x18\x08 \x01(\x0b\x32\".google.bigtable.v1.TimestampRangeH\x00\x12\x1c\n\x12value_regex_filter\x18\t \x01(\x0cH\x00\x12<\n\x12value_range_filter\x18\x0f \x01(\x0b\x32\x1e.google.bigtable.v1.ValueRangeH\x00\x12%\n\x1b\x63\x65lls_per_row_offset_filter\x18\n \x01(\x05H\x00\x12$\n\x1a\x63\x65lls_per_row_limit_filter\x18\x0b \x01(\x05H\x00\x12\'\n\x1d\x63\x65lls_per_column_limit_filter\x18\x0c \x01(\x05H\x00\x12!\n\x17strip_value_transformer\x18\r \x01(\x08H\x00\x12!\n\x17\x61pply_label_transformer\x18\x13 \x01(\tH\x00\x1a\x37\n\x05\x43hain\x12.\n\x07\x66ilters\x18\x01 \x03(\x0b\x32\x1d.google.bigtable.v1.RowFilter\x1a<\n\nInterleave\x12.\n\x07\x66ilters\x18\x01 \x03(\x0b\x32\x1d.google.bigtable.v1.RowFilter\x1a\xad\x01\n\tCondition\x12\x37\n\x10predicate_filter\x18\x01 \x01(\x0b\x32\x1d.google.bigtable.v1.RowFilter\x12\x32\n\x0btrue_filter\x18\x02 \x01(\x0b\x32\x1d.google.bigtable.v1.RowFilter\x12\x33\n\x0c\x66\x61lse_filter\x18\x03 \x01(\x0b\x32\x1d.google.bigtable.v1.RowFilterB\x08\n\x06\x66ilter\"\xc9\x04\n\x08Mutation\x12\x38\n\x08set_cell\x18\x01 \x01(\x0b\x32$.google.bigtable.v1.Mutation.SetCellH\x00\x12K\n\x12\x64\x65lete_from_column\x18\x02 \x01(\x0b\x32-.google.bigtable.v1.Mutation.DeleteFromColumnH\x00\x12K\n\x12\x64\x65lete_from_family\x18\x03 \x01(\x0b\x32-.google.bigtable.v1.Mutation.DeleteFromFamilyH\x00\x12\x45\n\x0f\x64\x65lete_from_row\x18\x04 \x01(\x0b\x32*.google.bigtable.v1.Mutation.DeleteFromRowH\x00\x1a\x61\n\x07SetCell\x12\x13\n\x0b\x66\x61mily_name\x18\x01 \x01(\t\x12\x18\n\x10\x63olumn_qualifier\x18\x02 \x01(\x0c\x12\x18\n\x10timestamp_micros\x18\x03 \x01(\x03\x12\r\n\x05value\x18\x04 \x01(\x0c\x1ay\n\x10\x44\x65leteFromColumn\x12\x13\n\x0b\x66\x61mily_name\x18\x01 \x01(\t\x12\x18\n\x10\x63olumn_qualifier\x18\x02 \x01(\x0c\x12\x36\n\ntime_range\x18\x03 \x01(\x0b\x32\".google.bigtable.v1.TimestampRange\x1a\'\n\x10\x44\x65leteFromFamily\x12\x13\n\x0b\x66\x61mily_name\x18\x01 \x01(\t\x1a\x0f\n\rDeleteFromRowB\n\n\x08mutation\"\x80\x01\n\x13ReadModifyWriteRule\x12\x13\n\x0b\x66\x61mily_name\x18\x01 \x01(\t\x12\x18\n\x10\x63olumn_qualifier\x18\x02 \x01(\x0c\x12\x16\n\x0c\x61ppend_value\x18\x03 \x01(\x0cH\x00\x12\x1a\n\x10increment_amount\x18\x04 \x01(\x03H\x00\x42\x06\n\x04ruleB-\n\x16\x63om.google.bigtable.v1B\x11\x42igtableDataProtoP\x01\x62\x06proto3' ) _sym_db.RegisterFileDescriptor(DESCRIPTOR) @@ -221,6 +221,44 @@ ) +_ROWSET = _descriptor.Descriptor( + name='RowSet', + full_name='google.bigtable.v1.RowSet', + filename=None, + file=DESCRIPTOR, + containing_type=None, + fields=[ + _descriptor.FieldDescriptor( + name='row_keys', full_name='google.bigtable.v1.RowSet.row_keys', index=0, + number=1, type=12, cpp_type=9, label=3, + has_default_value=False, default_value=[], + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + options=None), + _descriptor.FieldDescriptor( + name='row_ranges', full_name='google.bigtable.v1.RowSet.row_ranges', index=1, + number=2, type=11, cpp_type=10, label=3, + has_default_value=False, default_value=[], + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + options=None), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=380, + serialized_end=456, +) + + _COLUMNRANGE = _descriptor.Descriptor( name='ColumnRange', full_name='google.bigtable.v1.ColumnRange', @@ -281,8 +319,8 @@ name='end_qualifier', full_name='google.bigtable.v1.ColumnRange.end_qualifier', index=1, containing_type=None, fields=[]), ], - serialized_start=381, - serialized_end=595, + serialized_start=459, + serialized_end=673, ) @@ -319,8 +357,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=597, - serialized_end=675, + serialized_start=675, + serialized_end=753, ) @@ -377,8 +415,8 @@ name='end_value', full_name='google.bigtable.v1.ValueRange.end_value', index=1, containing_type=None, fields=[]), ], - serialized_start=678, - serialized_end=846, + serialized_start=756, + serialized_end=924, ) @@ -408,8 +446,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=1665, - serialized_end=1720, + serialized_start=1743, + serialized_end=1798, ) _ROWFILTER_INTERLEAVE = _descriptor.Descriptor( @@ -438,8 +476,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=1722, - serialized_end=1782, + serialized_start=1800, + serialized_end=1860, ) _ROWFILTER_CONDITION = _descriptor.Descriptor( @@ -482,8 +520,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=1785, - serialized_end=1958, + serialized_start=1863, + serialized_end=2036, ) _ROWFILTER = _descriptor.Descriptor( @@ -641,8 +679,8 @@ name='filter', full_name='google.bigtable.v1.RowFilter.filter', index=0, containing_type=None, fields=[]), ], - serialized_start=849, - serialized_end=1968, + serialized_start=927, + serialized_end=2046, ) @@ -693,8 +731,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=2266, - serialized_end=2363, + serialized_start=2344, + serialized_end=2441, ) _MUTATION_DELETEFROMCOLUMN = _descriptor.Descriptor( @@ -737,8 +775,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=2365, - serialized_end=2486, + serialized_start=2443, + serialized_end=2564, ) _MUTATION_DELETEFROMFAMILY = _descriptor.Descriptor( @@ -767,8 +805,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=2488, - serialized_end=2527, + serialized_start=2566, + serialized_end=2605, ) _MUTATION_DELETEFROMROW = _descriptor.Descriptor( @@ -790,8 +828,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=2529, - serialized_end=2544, + serialized_start=2607, + serialized_end=2622, ) _MUTATION = _descriptor.Descriptor( @@ -844,8 +882,8 @@ name='mutation', full_name='google.bigtable.v1.Mutation.mutation', index=0, containing_type=None, fields=[]), ], - serialized_start=1971, - serialized_end=2556, + serialized_start=2049, + serialized_end=2634, ) @@ -899,13 +937,14 @@ name='rule', full_name='google.bigtable.v1.ReadModifyWriteRule.rule', index=0, containing_type=None, fields=[]), ], - serialized_start=2559, - serialized_end=2687, + serialized_start=2637, + serialized_end=2765, ) _ROW.fields_by_name['families'].message_type = _FAMILY _FAMILY.fields_by_name['columns'].message_type = _COLUMN _COLUMN.fields_by_name['cells'].message_type = _CELL +_ROWSET.fields_by_name['row_ranges'].message_type = _ROWRANGE _COLUMNRANGE.oneofs_by_name['start_qualifier'].fields.append( _COLUMNRANGE.fields_by_name['start_qualifier_inclusive']) _COLUMNRANGE.fields_by_name['start_qualifier_inclusive'].containing_oneof = _COLUMNRANGE.oneofs_by_name['start_qualifier'] @@ -1033,6 +1072,7 @@ DESCRIPTOR.message_types_by_name['Column'] = _COLUMN DESCRIPTOR.message_types_by_name['Cell'] = _CELL DESCRIPTOR.message_types_by_name['RowRange'] = _ROWRANGE +DESCRIPTOR.message_types_by_name['RowSet'] = _ROWSET DESCRIPTOR.message_types_by_name['ColumnRange'] = _COLUMNRANGE DESCRIPTOR.message_types_by_name['TimestampRange'] = _TIMESTAMPRANGE DESCRIPTOR.message_types_by_name['ValueRange'] = _VALUERANGE @@ -1075,6 +1115,13 @@ )) _sym_db.RegisterMessage(RowRange) +RowSet = _reflection.GeneratedProtocolMessageType('RowSet', (_message.Message,), dict( + DESCRIPTOR = _ROWSET, + __module__ = 'google.bigtable.v1.bigtable_data_pb2' + # @@protoc_insertion_point(class_scope:google.bigtable.v1.RowSet) + )) +_sym_db.RegisterMessage(RowSet) + ColumnRange = _reflection.GeneratedProtocolMessageType('ColumnRange', (_message.Message,), dict( DESCRIPTOR = _COLUMNRANGE, __module__ = 'google.bigtable.v1.bigtable_data_pb2' diff --git a/gcloud/bigtable/_generated/bigtable_service_messages_pb2.py b/gcloud/bigtable/_generated/bigtable_service_messages_pb2.py index 83f9b24a2a68..38a478aded74 100644 --- a/gcloud/bigtable/_generated/bigtable_service_messages_pb2.py +++ b/gcloud/bigtable/_generated/bigtable_service_messages_pb2.py @@ -12,15 +12,16 @@ from gcloud.bigtable._generated import bigtable_data_pb2 as google_dot_bigtable_dot_v1_dot_bigtable__data__pb2 +from google.rpc import status_pb2 as google_dot_rpc_dot_status__pb2 DESCRIPTOR = _descriptor.FileDescriptor( name='google/bigtable/v1/bigtable_service_messages.proto', package='google.bigtable.v1', syntax='proto3', - serialized_pb=b'\n2google/bigtable/v1/bigtable_service_messages.proto\x12\x12google.bigtable.v1\x1a&google/bigtable/v1/bigtable_data.proto\"\xdc\x01\n\x0fReadRowsRequest\x12\x12\n\ntable_name\x18\x01 \x01(\t\x12\x11\n\x07row_key\x18\x02 \x01(\x0cH\x00\x12\x31\n\trow_range\x18\x03 \x01(\x0b\x32\x1c.google.bigtable.v1.RowRangeH\x00\x12-\n\x06\x66ilter\x18\x05 \x01(\x0b\x32\x1d.google.bigtable.v1.RowFilter\x12\x1e\n\x16\x61llow_row_interleaving\x18\x06 \x01(\x08\x12\x16\n\x0enum_rows_limit\x18\x07 \x01(\x03\x42\x08\n\x06target\"\xd0\x01\n\x10ReadRowsResponse\x12\x0f\n\x07row_key\x18\x01 \x01(\x0c\x12:\n\x06\x63hunks\x18\x02 \x03(\x0b\x32*.google.bigtable.v1.ReadRowsResponse.Chunk\x1ao\n\x05\x43hunk\x12\x32\n\x0crow_contents\x18\x01 \x01(\x0b\x32\x1a.google.bigtable.v1.FamilyH\x00\x12\x13\n\treset_row\x18\x02 \x01(\x08H\x00\x12\x14\n\ncommit_row\x18\x03 \x01(\x08H\x00\x42\x07\n\x05\x63hunk\"*\n\x14SampleRowKeysRequest\x12\x12\n\ntable_name\x18\x01 \x01(\t\">\n\x15SampleRowKeysResponse\x12\x0f\n\x07row_key\x18\x01 \x01(\x0c\x12\x14\n\x0coffset_bytes\x18\x02 \x01(\x03\"h\n\x10MutateRowRequest\x12\x12\n\ntable_name\x18\x01 \x01(\t\x12\x0f\n\x07row_key\x18\x02 \x01(\x0c\x12/\n\tmutations\x18\x03 \x03(\x0b\x32\x1c.google.bigtable.v1.Mutation\"\xe5\x01\n\x18\x43heckAndMutateRowRequest\x12\x12\n\ntable_name\x18\x01 \x01(\t\x12\x0f\n\x07row_key\x18\x02 \x01(\x0c\x12\x37\n\x10predicate_filter\x18\x06 \x01(\x0b\x32\x1d.google.bigtable.v1.RowFilter\x12\x34\n\x0etrue_mutations\x18\x04 \x03(\x0b\x32\x1c.google.bigtable.v1.Mutation\x12\x35\n\x0f\x66\x61lse_mutations\x18\x05 \x03(\x0b\x32\x1c.google.bigtable.v1.Mutation\"6\n\x19\x43heckAndMutateRowResponse\x12\x19\n\x11predicate_matched\x18\x01 \x01(\x08\"x\n\x19ReadModifyWriteRowRequest\x12\x12\n\ntable_name\x18\x01 \x01(\t\x12\x0f\n\x07row_key\x18\x02 \x01(\x0c\x12\x36\n\x05rules\x18\x03 \x03(\x0b\x32\'.google.bigtable.v1.ReadModifyWriteRuleB8\n\x16\x63om.google.bigtable.v1B\x1c\x42igtableServiceMessagesProtoP\x01\x62\x06proto3' + serialized_pb=b'\n2google/bigtable/v1/bigtable_service_messages.proto\x12\x12google.bigtable.v1\x1a&google/bigtable/v1/bigtable_data.proto\x1a\x17google/rpc/status.proto\"\x8b\x02\n\x0fReadRowsRequest\x12\x12\n\ntable_name\x18\x01 \x01(\t\x12\x11\n\x07row_key\x18\x02 \x01(\x0cH\x00\x12\x31\n\trow_range\x18\x03 \x01(\x0b\x32\x1c.google.bigtable.v1.RowRangeH\x00\x12-\n\x07row_set\x18\x08 \x01(\x0b\x32\x1a.google.bigtable.v1.RowSetH\x00\x12-\n\x06\x66ilter\x18\x05 \x01(\x0b\x32\x1d.google.bigtable.v1.RowFilter\x12\x1e\n\x16\x61llow_row_interleaving\x18\x06 \x01(\x08\x12\x16\n\x0enum_rows_limit\x18\x07 \x01(\x03\x42\x08\n\x06target\"\xd0\x01\n\x10ReadRowsResponse\x12\x0f\n\x07row_key\x18\x01 \x01(\x0c\x12:\n\x06\x63hunks\x18\x02 \x03(\x0b\x32*.google.bigtable.v1.ReadRowsResponse.Chunk\x1ao\n\x05\x43hunk\x12\x32\n\x0crow_contents\x18\x01 \x01(\x0b\x32\x1a.google.bigtable.v1.FamilyH\x00\x12\x13\n\treset_row\x18\x02 \x01(\x08H\x00\x12\x14\n\ncommit_row\x18\x03 \x01(\x08H\x00\x42\x07\n\x05\x63hunk\"*\n\x14SampleRowKeysRequest\x12\x12\n\ntable_name\x18\x01 \x01(\t\">\n\x15SampleRowKeysResponse\x12\x0f\n\x07row_key\x18\x01 \x01(\x0c\x12\x14\n\x0coffset_bytes\x18\x02 \x01(\x03\"h\n\x10MutateRowRequest\x12\x12\n\ntable_name\x18\x01 \x01(\t\x12\x0f\n\x07row_key\x18\x02 \x01(\x0c\x12/\n\tmutations\x18\x03 \x03(\x0b\x32\x1c.google.bigtable.v1.Mutation\"\xb0\x01\n\x11MutateRowsRequest\x12\x12\n\ntable_name\x18\x01 \x01(\t\x12<\n\x07\x65ntries\x18\x02 \x03(\x0b\x32+.google.bigtable.v1.MutateRowsRequest.Entry\x1aI\n\x05\x45ntry\x12\x0f\n\x07row_key\x18\x01 \x01(\x0c\x12/\n\tmutations\x18\x02 \x03(\x0b\x32\x1c.google.bigtable.v1.Mutation\":\n\x12MutateRowsResponse\x12$\n\x08statuses\x18\x01 \x03(\x0b\x32\x12.google.rpc.Status\"\xe5\x01\n\x18\x43heckAndMutateRowRequest\x12\x12\n\ntable_name\x18\x01 \x01(\t\x12\x0f\n\x07row_key\x18\x02 \x01(\x0c\x12\x37\n\x10predicate_filter\x18\x06 \x01(\x0b\x32\x1d.google.bigtable.v1.RowFilter\x12\x34\n\x0etrue_mutations\x18\x04 \x03(\x0b\x32\x1c.google.bigtable.v1.Mutation\x12\x35\n\x0f\x66\x61lse_mutations\x18\x05 \x03(\x0b\x32\x1c.google.bigtable.v1.Mutation\"6\n\x19\x43heckAndMutateRowResponse\x12\x19\n\x11predicate_matched\x18\x01 \x01(\x08\"x\n\x19ReadModifyWriteRowRequest\x12\x12\n\ntable_name\x18\x01 \x01(\t\x12\x0f\n\x07row_key\x18\x02 \x01(\x0c\x12\x36\n\x05rules\x18\x03 \x03(\x0b\x32\'.google.bigtable.v1.ReadModifyWriteRuleB8\n\x16\x63om.google.bigtable.v1B\x1c\x42igtableServiceMessagesProtoP\x01\x62\x06proto3' , - dependencies=[google_dot_bigtable_dot_v1_dot_bigtable__data__pb2.DESCRIPTOR,]) + dependencies=[google_dot_bigtable_dot_v1_dot_bigtable__data__pb2.DESCRIPTOR,google_dot_rpc_dot_status__pb2.DESCRIPTOR,]) _sym_db.RegisterFileDescriptor(DESCRIPTOR) @@ -55,21 +56,28 @@ is_extension=False, extension_scope=None, options=None), _descriptor.FieldDescriptor( - name='filter', full_name='google.bigtable.v1.ReadRowsRequest.filter', index=3, + name='row_set', full_name='google.bigtable.v1.ReadRowsRequest.row_set', index=3, + number=8, type=11, cpp_type=10, label=1, + has_default_value=False, default_value=None, + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + options=None), + _descriptor.FieldDescriptor( + name='filter', full_name='google.bigtable.v1.ReadRowsRequest.filter', index=4, number=5, type=11, cpp_type=10, label=1, has_default_value=False, default_value=None, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), _descriptor.FieldDescriptor( - name='allow_row_interleaving', full_name='google.bigtable.v1.ReadRowsRequest.allow_row_interleaving', index=4, + name='allow_row_interleaving', full_name='google.bigtable.v1.ReadRowsRequest.allow_row_interleaving', index=5, number=6, type=8, cpp_type=7, label=1, has_default_value=False, default_value=False, message_type=None, enum_type=None, containing_type=None, is_extension=False, extension_scope=None, options=None), _descriptor.FieldDescriptor( - name='num_rows_limit', full_name='google.bigtable.v1.ReadRowsRequest.num_rows_limit', index=5, + name='num_rows_limit', full_name='google.bigtable.v1.ReadRowsRequest.num_rows_limit', index=6, number=7, type=3, cpp_type=2, label=1, has_default_value=False, default_value=0, message_type=None, enum_type=None, containing_type=None, @@ -90,8 +98,8 @@ name='target', full_name='google.bigtable.v1.ReadRowsRequest.target', index=0, containing_type=None, fields=[]), ], - serialized_start=115, - serialized_end=335, + serialized_start=140, + serialized_end=407, ) @@ -138,8 +146,8 @@ name='chunk', full_name='google.bigtable.v1.ReadRowsResponse.Chunk.chunk', index=0, containing_type=None, fields=[]), ], - serialized_start=435, - serialized_end=546, + serialized_start=507, + serialized_end=618, ) _READROWSRESPONSE = _descriptor.Descriptor( @@ -175,8 +183,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=338, - serialized_end=546, + serialized_start=410, + serialized_end=618, ) @@ -206,8 +214,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=548, - serialized_end=590, + serialized_start=620, + serialized_end=662, ) @@ -244,8 +252,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=592, - serialized_end=654, + serialized_start=664, + serialized_end=726, ) @@ -289,8 +297,114 @@ extension_ranges=[], oneofs=[ ], - serialized_start=656, - serialized_end=760, + serialized_start=728, + serialized_end=832, +) + + +_MUTATEROWSREQUEST_ENTRY = _descriptor.Descriptor( + name='Entry', + full_name='google.bigtable.v1.MutateRowsRequest.Entry', + filename=None, + file=DESCRIPTOR, + containing_type=None, + fields=[ + _descriptor.FieldDescriptor( + name='row_key', full_name='google.bigtable.v1.MutateRowsRequest.Entry.row_key', index=0, + number=1, type=12, cpp_type=9, label=1, + has_default_value=False, default_value=b"", + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + options=None), + _descriptor.FieldDescriptor( + name='mutations', full_name='google.bigtable.v1.MutateRowsRequest.Entry.mutations', index=1, + number=2, type=11, cpp_type=10, label=3, + has_default_value=False, default_value=[], + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + options=None), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=938, + serialized_end=1011, +) + +_MUTATEROWSREQUEST = _descriptor.Descriptor( + name='MutateRowsRequest', + full_name='google.bigtable.v1.MutateRowsRequest', + filename=None, + file=DESCRIPTOR, + containing_type=None, + fields=[ + _descriptor.FieldDescriptor( + name='table_name', full_name='google.bigtable.v1.MutateRowsRequest.table_name', index=0, + number=1, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + options=None), + _descriptor.FieldDescriptor( + name='entries', full_name='google.bigtable.v1.MutateRowsRequest.entries', index=1, + number=2, type=11, cpp_type=10, label=3, + has_default_value=False, default_value=[], + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + options=None), + ], + extensions=[ + ], + nested_types=[_MUTATEROWSREQUEST_ENTRY, ], + enum_types=[ + ], + options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=835, + serialized_end=1011, +) + + +_MUTATEROWSRESPONSE = _descriptor.Descriptor( + name='MutateRowsResponse', + full_name='google.bigtable.v1.MutateRowsResponse', + filename=None, + file=DESCRIPTOR, + containing_type=None, + fields=[ + _descriptor.FieldDescriptor( + name='statuses', full_name='google.bigtable.v1.MutateRowsResponse.statuses', index=0, + number=1, type=11, cpp_type=10, label=3, + has_default_value=False, default_value=[], + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + options=None), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=1013, + serialized_end=1071, ) @@ -348,8 +462,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=763, - serialized_end=992, + serialized_start=1074, + serialized_end=1303, ) @@ -379,8 +493,8 @@ extension_ranges=[], oneofs=[ ], - serialized_start=994, - serialized_end=1048, + serialized_start=1305, + serialized_end=1359, ) @@ -424,11 +538,12 @@ extension_ranges=[], oneofs=[ ], - serialized_start=1050, - serialized_end=1170, + serialized_start=1361, + serialized_end=1481, ) _READROWSREQUEST.fields_by_name['row_range'].message_type = google_dot_bigtable_dot_v1_dot_bigtable__data__pb2._ROWRANGE +_READROWSREQUEST.fields_by_name['row_set'].message_type = google_dot_bigtable_dot_v1_dot_bigtable__data__pb2._ROWSET _READROWSREQUEST.fields_by_name['filter'].message_type = google_dot_bigtable_dot_v1_dot_bigtable__data__pb2._ROWFILTER _READROWSREQUEST.oneofs_by_name['target'].fields.append( _READROWSREQUEST.fields_by_name['row_key']) @@ -436,6 +551,9 @@ _READROWSREQUEST.oneofs_by_name['target'].fields.append( _READROWSREQUEST.fields_by_name['row_range']) _READROWSREQUEST.fields_by_name['row_range'].containing_oneof = _READROWSREQUEST.oneofs_by_name['target'] +_READROWSREQUEST.oneofs_by_name['target'].fields.append( + _READROWSREQUEST.fields_by_name['row_set']) +_READROWSREQUEST.fields_by_name['row_set'].containing_oneof = _READROWSREQUEST.oneofs_by_name['target'] _READROWSRESPONSE_CHUNK.fields_by_name['row_contents'].message_type = google_dot_bigtable_dot_v1_dot_bigtable__data__pb2._FAMILY _READROWSRESPONSE_CHUNK.containing_type = _READROWSRESPONSE _READROWSRESPONSE_CHUNK.oneofs_by_name['chunk'].fields.append( @@ -449,6 +567,10 @@ _READROWSRESPONSE_CHUNK.fields_by_name['commit_row'].containing_oneof = _READROWSRESPONSE_CHUNK.oneofs_by_name['chunk'] _READROWSRESPONSE.fields_by_name['chunks'].message_type = _READROWSRESPONSE_CHUNK _MUTATEROWREQUEST.fields_by_name['mutations'].message_type = google_dot_bigtable_dot_v1_dot_bigtable__data__pb2._MUTATION +_MUTATEROWSREQUEST_ENTRY.fields_by_name['mutations'].message_type = google_dot_bigtable_dot_v1_dot_bigtable__data__pb2._MUTATION +_MUTATEROWSREQUEST_ENTRY.containing_type = _MUTATEROWSREQUEST +_MUTATEROWSREQUEST.fields_by_name['entries'].message_type = _MUTATEROWSREQUEST_ENTRY +_MUTATEROWSRESPONSE.fields_by_name['statuses'].message_type = google_dot_rpc_dot_status__pb2._STATUS _CHECKANDMUTATEROWREQUEST.fields_by_name['predicate_filter'].message_type = google_dot_bigtable_dot_v1_dot_bigtable__data__pb2._ROWFILTER _CHECKANDMUTATEROWREQUEST.fields_by_name['true_mutations'].message_type = google_dot_bigtable_dot_v1_dot_bigtable__data__pb2._MUTATION _CHECKANDMUTATEROWREQUEST.fields_by_name['false_mutations'].message_type = google_dot_bigtable_dot_v1_dot_bigtable__data__pb2._MUTATION @@ -458,6 +580,8 @@ DESCRIPTOR.message_types_by_name['SampleRowKeysRequest'] = _SAMPLEROWKEYSREQUEST DESCRIPTOR.message_types_by_name['SampleRowKeysResponse'] = _SAMPLEROWKEYSRESPONSE DESCRIPTOR.message_types_by_name['MutateRowRequest'] = _MUTATEROWREQUEST +DESCRIPTOR.message_types_by_name['MutateRowsRequest'] = _MUTATEROWSREQUEST +DESCRIPTOR.message_types_by_name['MutateRowsResponse'] = _MUTATEROWSRESPONSE DESCRIPTOR.message_types_by_name['CheckAndMutateRowRequest'] = _CHECKANDMUTATEROWREQUEST DESCRIPTOR.message_types_by_name['CheckAndMutateRowResponse'] = _CHECKANDMUTATEROWRESPONSE DESCRIPTOR.message_types_by_name['ReadModifyWriteRowRequest'] = _READMODIFYWRITEROWREQUEST @@ -505,6 +629,28 @@ )) _sym_db.RegisterMessage(MutateRowRequest) +MutateRowsRequest = _reflection.GeneratedProtocolMessageType('MutateRowsRequest', (_message.Message,), dict( + + Entry = _reflection.GeneratedProtocolMessageType('Entry', (_message.Message,), dict( + DESCRIPTOR = _MUTATEROWSREQUEST_ENTRY, + __module__ = 'google.bigtable.v1.bigtable_service_messages_pb2' + # @@protoc_insertion_point(class_scope:google.bigtable.v1.MutateRowsRequest.Entry) + )) + , + DESCRIPTOR = _MUTATEROWSREQUEST, + __module__ = 'google.bigtable.v1.bigtable_service_messages_pb2' + # @@protoc_insertion_point(class_scope:google.bigtable.v1.MutateRowsRequest) + )) +_sym_db.RegisterMessage(MutateRowsRequest) +_sym_db.RegisterMessage(MutateRowsRequest.Entry) + +MutateRowsResponse = _reflection.GeneratedProtocolMessageType('MutateRowsResponse', (_message.Message,), dict( + DESCRIPTOR = _MUTATEROWSRESPONSE, + __module__ = 'google.bigtable.v1.bigtable_service_messages_pb2' + # @@protoc_insertion_point(class_scope:google.bigtable.v1.MutateRowsResponse) + )) +_sym_db.RegisterMessage(MutateRowsResponse) + CheckAndMutateRowRequest = _reflection.GeneratedProtocolMessageType('CheckAndMutateRowRequest', (_message.Message,), dict( DESCRIPTOR = _CHECKANDMUTATEROWREQUEST, __module__ = 'google.bigtable.v1.bigtable_service_messages_pb2' diff --git a/gcloud/bigtable/_generated/bigtable_service_pb2.py b/gcloud/bigtable/_generated/bigtable_service_pb2.py index 395bcc9282e4..eac0ec0de082 100644 --- a/gcloud/bigtable/_generated/bigtable_service_pb2.py +++ b/gcloud/bigtable/_generated/bigtable_service_pb2.py @@ -21,7 +21,7 @@ name='google/bigtable/v1/bigtable_service.proto', package='google.bigtable.v1', syntax='proto3', - serialized_pb=b'\n)google/bigtable/v1/bigtable_service.proto\x12\x12google.bigtable.v1\x1a\x1cgoogle/api/annotations.proto\x1a&google/bigtable/v1/bigtable_data.proto\x1a\x32google/bigtable/v1/bigtable_service_messages.proto\x1a\x1bgoogle/protobuf/empty.proto2\xb0\x07\n\x0f\x42igtableService\x12\xa5\x01\n\x08ReadRows\x12#.google.bigtable.v1.ReadRowsRequest\x1a$.google.bigtable.v1.ReadRowsResponse\"L\x82\xd3\xe4\x93\x02\x46\"A/v1/{table_name=projects/*/zones/*/clusters/*/tables/*}/rows:read:\x01*0\x01\x12\xb7\x01\n\rSampleRowKeys\x12(.google.bigtable.v1.SampleRowKeysRequest\x1a).google.bigtable.v1.SampleRowKeysResponse\"O\x82\xd3\xe4\x93\x02I\x12G/v1/{table_name=projects/*/zones/*/clusters/*/tables/*}/rows:sampleKeys0\x01\x12\xa3\x01\n\tMutateRow\x12$.google.bigtable.v1.MutateRowRequest\x1a\x16.google.protobuf.Empty\"X\x82\xd3\xe4\x93\x02R\"M/v1/{table_name=projects/*/zones/*/clusters/*/tables/*}/rows/{row_key}:mutate:\x01*\x12\xd2\x01\n\x11\x43heckAndMutateRow\x12,.google.bigtable.v1.CheckAndMutateRowRequest\x1a-.google.bigtable.v1.CheckAndMutateRowResponse\"`\x82\xd3\xe4\x93\x02Z\"U/v1/{table_name=projects/*/zones/*/clusters/*/tables/*}/rows/{row_key}:checkAndMutate:\x01*\x12\xbf\x01\n\x12ReadModifyWriteRow\x12-.google.bigtable.v1.ReadModifyWriteRowRequest\x1a\x17.google.bigtable.v1.Row\"a\x82\xd3\xe4\x93\x02[\"V/v1/{table_name=projects/*/zones/*/clusters/*/tables/*}/rows/{row_key}:readModifyWrite:\x01*B4\n\x16\x63om.google.bigtable.v1B\x15\x42igtableServicesProtoP\x01\x88\x01\x01\x62\x06proto3' + serialized_pb=b'\n)google/bigtable/v1/bigtable_service.proto\x12\x12google.bigtable.v1\x1a\x1cgoogle/api/annotations.proto\x1a&google/bigtable/v1/bigtable_data.proto\x1a\x32google/bigtable/v1/bigtable_service_messages.proto\x1a\x1bgoogle/protobuf/empty.proto2\xdd\x08\n\x0f\x42igtableService\x12\xa5\x01\n\x08ReadRows\x12#.google.bigtable.v1.ReadRowsRequest\x1a$.google.bigtable.v1.ReadRowsResponse\"L\x82\xd3\xe4\x93\x02\x46\"A/v1/{table_name=projects/*/zones/*/clusters/*/tables/*}/rows:read:\x01*0\x01\x12\xb7\x01\n\rSampleRowKeys\x12(.google.bigtable.v1.SampleRowKeysRequest\x1a).google.bigtable.v1.SampleRowKeysResponse\"O\x82\xd3\xe4\x93\x02I\x12G/v1/{table_name=projects/*/zones/*/clusters/*/tables/*}/rows:sampleKeys0\x01\x12\xa3\x01\n\tMutateRow\x12$.google.bigtable.v1.MutateRowRequest\x1a\x16.google.protobuf.Empty\"X\x82\xd3\xe4\x93\x02R\"M/v1/{table_name=projects/*/zones/*/clusters/*/tables/*}/rows/{row_key}:mutate:\x01*\x12\xaa\x01\n\nMutateRows\x12%.google.bigtable.v1.MutateRowsRequest\x1a&.google.bigtable.v1.MutateRowsResponse\"M\x82\xd3\xe4\x93\x02G\"B/v1/{table_name=projects/*/zones/*/clusters/*/tables/*}:mutateRows:\x01*\x12\xd2\x01\n\x11\x43heckAndMutateRow\x12,.google.bigtable.v1.CheckAndMutateRowRequest\x1a-.google.bigtable.v1.CheckAndMutateRowResponse\"`\x82\xd3\xe4\x93\x02Z\"U/v1/{table_name=projects/*/zones/*/clusters/*/tables/*}/rows/{row_key}:checkAndMutate:\x01*\x12\xbf\x01\n\x12ReadModifyWriteRow\x12-.google.bigtable.v1.ReadModifyWriteRowRequest\x1a\x17.google.bigtable.v1.Row\"a\x82\xd3\xe4\x93\x02[\"V/v1/{table_name=projects/*/zones/*/clusters/*/tables/*}/rows/{row_key}:readModifyWrite:\x01*B4\n\x16\x63om.google.bigtable.v1B\x15\x42igtableServicesProtoP\x01\x88\x01\x01\x62\x06proto3' , dependencies=[google_dot_api_dot_annotations__pb2.DESCRIPTOR,google_dot_bigtable_dot_v1_dot_bigtable__data__pb2.DESCRIPTOR,google_dot_bigtable_dot_v1_dot_bigtable__service__messages__pb2.DESCRIPTOR,google_dot_protobuf_dot_empty__pb2.DESCRIPTOR,]) _sym_db.RegisterFileDescriptor(DESCRIPTOR) @@ -51,6 +51,9 @@ def SampleRowKeys(self, request, context): def MutateRow(self, request, context): raise NotImplementedError() @abc.abstractmethod + def MutateRows(self, request, context): + raise NotImplementedError() + @abc.abstractmethod def CheckAndMutateRow(self, request, context): raise NotImplementedError() @abc.abstractmethod @@ -81,6 +84,10 @@ def MutateRow(self, request): raise NotImplementedError() MutateRow.async = None @abc.abstractmethod + def MutateRows(self, request): + raise NotImplementedError() + MutateRows.async = None + @abc.abstractmethod def CheckAndMutateRow(self, request): raise NotImplementedError() CheckAndMutateRow.async = None @@ -98,6 +105,8 @@ def early_adopter_create_BigtableService_server(servicer, port, private_key=None import gcloud.bigtable._generated.bigtable_service_messages_pb2 import gcloud.bigtable._generated.bigtable_service_messages_pb2 import gcloud.bigtable._generated.bigtable_service_messages_pb2 + import gcloud.bigtable._generated.bigtable_service_messages_pb2 + import gcloud.bigtable._generated.bigtable_service_messages_pb2 import gcloud.bigtable._generated.bigtable_data_pb2 method_service_descriptions = { "CheckAndMutateRow": alpha_utilities.unary_unary_service_description( @@ -110,6 +119,11 @@ def early_adopter_create_BigtableService_server(servicer, port, private_key=None gcloud.bigtable._generated.bigtable_service_messages_pb2.MutateRowRequest.FromString, google.protobuf.empty_pb2.Empty.SerializeToString, ), + "MutateRows": alpha_utilities.unary_unary_service_description( + servicer.MutateRows, + gcloud.bigtable._generated.bigtable_service_messages_pb2.MutateRowsRequest.FromString, + gcloud.bigtable._generated.bigtable_service_messages_pb2.MutateRowsResponse.SerializeToString, + ), "ReadModifyWriteRow": alpha_utilities.unary_unary_service_description( servicer.ReadModifyWriteRow, gcloud.bigtable._generated.bigtable_service_messages_pb2.ReadModifyWriteRowRequest.FromString, @@ -137,6 +151,8 @@ def early_adopter_create_BigtableService_stub(host, port, metadata_transformer=N import gcloud.bigtable._generated.bigtable_service_messages_pb2 import gcloud.bigtable._generated.bigtable_service_messages_pb2 import gcloud.bigtable._generated.bigtable_service_messages_pb2 + import gcloud.bigtable._generated.bigtable_service_messages_pb2 + import gcloud.bigtable._generated.bigtable_service_messages_pb2 import gcloud.bigtable._generated.bigtable_data_pb2 method_invocation_descriptions = { "CheckAndMutateRow": alpha_utilities.unary_unary_invocation_description( @@ -147,6 +163,10 @@ def early_adopter_create_BigtableService_stub(host, port, metadata_transformer=N gcloud.bigtable._generated.bigtable_service_messages_pb2.MutateRowRequest.SerializeToString, google.protobuf.empty_pb2.Empty.FromString, ), + "MutateRows": alpha_utilities.unary_unary_invocation_description( + gcloud.bigtable._generated.bigtable_service_messages_pb2.MutateRowsRequest.SerializeToString, + gcloud.bigtable._generated.bigtable_service_messages_pb2.MutateRowsResponse.FromString, + ), "ReadModifyWriteRow": alpha_utilities.unary_unary_invocation_description( gcloud.bigtable._generated.bigtable_service_messages_pb2.ReadModifyWriteRowRequest.SerializeToString, gcloud.bigtable._generated.bigtable_data_pb2.Row.FromString, @@ -175,6 +195,9 @@ def SampleRowKeys(self, request, context): def MutateRow(self, request, context): raise NotImplementedError() @abc.abstractmethod + def MutateRows(self, request, context): + raise NotImplementedError() + @abc.abstractmethod def CheckAndMutateRow(self, request, context): raise NotImplementedError() @abc.abstractmethod @@ -195,6 +218,10 @@ def MutateRow(self, request, timeout): raise NotImplementedError() MutateRow.future = None @abc.abstractmethod + def MutateRows(self, request, timeout): + raise NotImplementedError() + MutateRows.future = None + @abc.abstractmethod def CheckAndMutateRow(self, request, timeout): raise NotImplementedError() CheckAndMutateRow.future = None @@ -213,10 +240,13 @@ def beta_create_BigtableService_server(servicer, pool=None, pool_size=None, defa import gcloud.bigtable._generated.bigtable_service_messages_pb2 import gcloud.bigtable._generated.bigtable_service_messages_pb2 import gcloud.bigtable._generated.bigtable_service_messages_pb2 + import gcloud.bigtable._generated.bigtable_service_messages_pb2 + import gcloud.bigtable._generated.bigtable_service_messages_pb2 import gcloud.bigtable._generated.bigtable_data_pb2 request_deserializers = { ('google.bigtable.v1.BigtableService', 'CheckAndMutateRow'): gcloud.bigtable._generated.bigtable_service_messages_pb2.CheckAndMutateRowRequest.FromString, ('google.bigtable.v1.BigtableService', 'MutateRow'): gcloud.bigtable._generated.bigtable_service_messages_pb2.MutateRowRequest.FromString, + ('google.bigtable.v1.BigtableService', 'MutateRows'): gcloud.bigtable._generated.bigtable_service_messages_pb2.MutateRowsRequest.FromString, ('google.bigtable.v1.BigtableService', 'ReadModifyWriteRow'): gcloud.bigtable._generated.bigtable_service_messages_pb2.ReadModifyWriteRowRequest.FromString, ('google.bigtable.v1.BigtableService', 'ReadRows'): gcloud.bigtable._generated.bigtable_service_messages_pb2.ReadRowsRequest.FromString, ('google.bigtable.v1.BigtableService', 'SampleRowKeys'): gcloud.bigtable._generated.bigtable_service_messages_pb2.SampleRowKeysRequest.FromString, @@ -224,6 +254,7 @@ def beta_create_BigtableService_server(servicer, pool=None, pool_size=None, defa response_serializers = { ('google.bigtable.v1.BigtableService', 'CheckAndMutateRow'): gcloud.bigtable._generated.bigtable_service_messages_pb2.CheckAndMutateRowResponse.SerializeToString, ('google.bigtable.v1.BigtableService', 'MutateRow'): google.protobuf.empty_pb2.Empty.SerializeToString, + ('google.bigtable.v1.BigtableService', 'MutateRows'): gcloud.bigtable._generated.bigtable_service_messages_pb2.MutateRowsResponse.SerializeToString, ('google.bigtable.v1.BigtableService', 'ReadModifyWriteRow'): gcloud.bigtable._generated.bigtable_data_pb2.Row.SerializeToString, ('google.bigtable.v1.BigtableService', 'ReadRows'): gcloud.bigtable._generated.bigtable_service_messages_pb2.ReadRowsResponse.SerializeToString, ('google.bigtable.v1.BigtableService', 'SampleRowKeys'): gcloud.bigtable._generated.bigtable_service_messages_pb2.SampleRowKeysResponse.SerializeToString, @@ -231,6 +262,7 @@ def beta_create_BigtableService_server(servicer, pool=None, pool_size=None, defa method_implementations = { ('google.bigtable.v1.BigtableService', 'CheckAndMutateRow'): face_utilities.unary_unary_inline(servicer.CheckAndMutateRow), ('google.bigtable.v1.BigtableService', 'MutateRow'): face_utilities.unary_unary_inline(servicer.MutateRow), + ('google.bigtable.v1.BigtableService', 'MutateRows'): face_utilities.unary_unary_inline(servicer.MutateRows), ('google.bigtable.v1.BigtableService', 'ReadModifyWriteRow'): face_utilities.unary_unary_inline(servicer.ReadModifyWriteRow), ('google.bigtable.v1.BigtableService', 'ReadRows'): face_utilities.unary_stream_inline(servicer.ReadRows), ('google.bigtable.v1.BigtableService', 'SampleRowKeys'): face_utilities.unary_stream_inline(servicer.SampleRowKeys), @@ -248,10 +280,13 @@ def beta_create_BigtableService_stub(channel, host=None, metadata_transformer=No import gcloud.bigtable._generated.bigtable_service_messages_pb2 import gcloud.bigtable._generated.bigtable_service_messages_pb2 import gcloud.bigtable._generated.bigtable_service_messages_pb2 + import gcloud.bigtable._generated.bigtable_service_messages_pb2 + import gcloud.bigtable._generated.bigtable_service_messages_pb2 import gcloud.bigtable._generated.bigtable_data_pb2 request_serializers = { ('google.bigtable.v1.BigtableService', 'CheckAndMutateRow'): gcloud.bigtable._generated.bigtable_service_messages_pb2.CheckAndMutateRowRequest.SerializeToString, ('google.bigtable.v1.BigtableService', 'MutateRow'): gcloud.bigtable._generated.bigtable_service_messages_pb2.MutateRowRequest.SerializeToString, + ('google.bigtable.v1.BigtableService', 'MutateRows'): gcloud.bigtable._generated.bigtable_service_messages_pb2.MutateRowsRequest.SerializeToString, ('google.bigtable.v1.BigtableService', 'ReadModifyWriteRow'): gcloud.bigtable._generated.bigtable_service_messages_pb2.ReadModifyWriteRowRequest.SerializeToString, ('google.bigtable.v1.BigtableService', 'ReadRows'): gcloud.bigtable._generated.bigtable_service_messages_pb2.ReadRowsRequest.SerializeToString, ('google.bigtable.v1.BigtableService', 'SampleRowKeys'): gcloud.bigtable._generated.bigtable_service_messages_pb2.SampleRowKeysRequest.SerializeToString, @@ -259,6 +294,7 @@ def beta_create_BigtableService_stub(channel, host=None, metadata_transformer=No response_deserializers = { ('google.bigtable.v1.BigtableService', 'CheckAndMutateRow'): gcloud.bigtable._generated.bigtable_service_messages_pb2.CheckAndMutateRowResponse.FromString, ('google.bigtable.v1.BigtableService', 'MutateRow'): google.protobuf.empty_pb2.Empty.FromString, + ('google.bigtable.v1.BigtableService', 'MutateRows'): gcloud.bigtable._generated.bigtable_service_messages_pb2.MutateRowsResponse.FromString, ('google.bigtable.v1.BigtableService', 'ReadModifyWriteRow'): gcloud.bigtable._generated.bigtable_data_pb2.Row.FromString, ('google.bigtable.v1.BigtableService', 'ReadRows'): gcloud.bigtable._generated.bigtable_service_messages_pb2.ReadRowsResponse.FromString, ('google.bigtable.v1.BigtableService', 'SampleRowKeys'): gcloud.bigtable._generated.bigtable_service_messages_pb2.SampleRowKeysResponse.FromString, @@ -266,6 +302,7 @@ def beta_create_BigtableService_stub(channel, host=None, metadata_transformer=No cardinalities = { 'CheckAndMutateRow': cardinality.Cardinality.UNARY_UNARY, 'MutateRow': cardinality.Cardinality.UNARY_UNARY, + 'MutateRows': cardinality.Cardinality.UNARY_UNARY, 'ReadModifyWriteRow': cardinality.Cardinality.UNARY_UNARY, 'ReadRows': cardinality.Cardinality.UNARY_STREAM, 'SampleRowKeys': cardinality.Cardinality.UNARY_STREAM,