kJSSKrSSKJr "SS\5r"SS\5rSrg)N) bigtable_pb2c\rSrSrSrSrSrg) BigtableStubDService for reading from and writing to existing Bigtable tables. cLURS[RR[RR S9UlURS[RR[RR S9Ul URS[RR[RR S9Ul URS[RR[RR S9UlURS[R"R[R$R S9UlURS[R(R[R*R S9Ulg) z/Constructor. Args: channel: A grpc.Channel. z%/google.bigtable.v2.Bigtable/ReadRows)request_serializerresponse_deserializerz*/google.bigtable.v2.Bigtable/SampleRowKeysz&/google.bigtable.v2.Bigtable/MutateRowz'/google.bigtable.v2.Bigtable/MutateRowsz./google.bigtable.v2.Bigtable/CheckAndMutateRowz//google.bigtable.v2.Bigtable/ReadModifyWriteRowN) unary_stream,google_dot_bigtable_dot_v2_dot_bigtable__pb2ReadRowsRequestSerializeToStringReadRowsResponse FromStringReadRowsSampleRowKeysRequestSampleRowKeysResponse SampleRowKeys unary_unaryMutateRowRequestMutateRowResponse MutateRowMutateRowsRequestMutateRowsResponse MutateRowsCheckAndMutateRowRequestCheckAndMutateRowResponseCheckAndMutateRowReadModifyWriteRowRequestReadModifyWriteRowResponseReadModifyWriteRow)selfchannels 7lib/third_party/google/bigtable/v2/bigtable_pb2_grpc.py__init__BigtableStub.__init__ sa ((/GWWiiJ[[ff) DM !--4G\\nnJ``kk. D ((0GXXjjJ\\gg) DN **1GYYkkJ]]hh+ DO %008G``rrJddoo1 D &119GaassJeepp2 D)rrrr!rrN)__name__ __module__ __qualname____firstlineno____doc__r%__static_attributes__r'r$rrs # r'rc<\rSrSrSrSrSrSrSrSr Sr S r g ) BigtableServicer1rcUR[RR5 UR S5 [ S5e)a-Streams back the contents of all requested rows in key order, optionally applying the same Reader filter to each. Depending on their size, rows and cells may be broken up across multiple responses, but atomicity of each row will still be preserved. See the ReadRowsResponse documentation for details. Method not implemented!set_codegrpc StatusCode UNIMPLEMENTED set_detailsNotImplementedErrorr"requestcontexts r$rBigtableServicer.ReadRows57 T__223 12 7 88r'cUR[RR5 UR S5 [ S5e)zReturns a sample of row keys in the table. The returned row keys will delimit contiguous sections of the table of approximately equal size, which can be used to break up the data for distributed tasks like mapreduces. r3r4r;s r$rBigtableServicer.SampleRowKeys@s7  T__223 12 7 88r'cUR[RR5 UR S5 [ S5e)zwMutates a row atomically. Cells already present in the row are left unchanged unless explicitly changed by `mutation`. r3r4r;s r$rBigtableServicer.MutateRowJs7 T__223 12 7 88r'cUR[RR5 UR S5 [ S5e)zMutates multiple rows in a batch. Each individual row is mutated atomically as in MutateRow, but the entire batch is not executed atomically. r3r4r;s r$rBigtableServicer.MutateRowsRs7  T__223 12 7 88r'cUR[RR5 UR S5 [ S5e)zOMutates a row atomically based on the output of a predicate Reader filter. r3r4r;s r$r"BigtableServicer.CheckAndMutateRow[s7 T__223 12 7 88r'cUR[RR5 UR S5 [ S5e)abModifies a row atomically on the server. The method reads the latest existing timestamp and value from the specified columns and writes a new entry based on pre-defined read/modify/write rules. The new value for the timestamp is the greater of the existing timestamp or the current server time. The method returns the new contents of all modified cells. r3r4r;s r$r!#BigtableServicer.ReadModifyWriteRowbr?r'r.N) r(r)r*r+r,rrrrrr!r-r.r'r$r0r01s% 99999 9r'r0c [R"UR[RR [R RS9[R"UR[RR [RRS9[R"UR[RR [RRS9[R"UR[R R [R"RS9[R"UR$[R&R [R(RS9[R"UR*[R,R [R.RS9S.n[R0"SU5nUR3U45 g)N)request_deserializerresponse_serializer)rrrrrr!zgoogle.bigtable.v2.Bigtable)r6unary_stream_rpc_method_handlerrr r rrrrrrunary_unary_rpc_method_handlerrrrrrrrrrr!rr method_handlers_generic_handleradd_generic_rpc_handlers)servicerserverrpc_method_handlersgeneric_handlers r$add_BigtableServicer_to_serverrUns|66   K[[ffJ[[mm ;;  K``kkJ``rr 66   K\\ggJ\\nn 88   K]]hhJ]]oo  >>  $ $KddooJddvv !??  % %KeeppJeeww5@88#%8:/!!?"45r')r6google.bigtable.v2rr objectrr0rUr.r'r$rXs* [' 6' T:9v:9z#6r'