text: # Generated by the protocol buffer compiler.  DO NOT EDIT!
  # source: query.proto
  
  import sys
  _b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
  from google.protobuf.internal import enum_type_wrapper
  from google.protobuf import descriptor as _descriptor
  from google.protobuf import message as _message
  from google.protobuf import reflection as _reflection
  from google.protobuf import symbol_database as _symbol_database
  from google.protobuf import descriptor_pb2
  # @@protoc_insertion_point(imports)
  
  _sym_db = _symbol_database.Default()
  
  
  import topodata_pb2 as topodata__pb2
  import vtrpc_pb2 as vtrpc__pb2
  
  
  DESCRIPTOR = _descriptor.FileDescriptor(
    name='query.proto',
    package='query',
    syntax='proto3',
    serialized_pb=_b('\n\x0bquery.proto\x12\x05query\x1a\x0etopodata.proto\x1a\x0bvtrpc.proto\"T\n\x06Target\x12\x10\n\x08keyspace\x18\x01 \x01(\t\x12\r\n\x05shard\x18\x02 \x01(\t\x12)\n\x0btablet_type\x18\x03 \x01(\x0e\x32\x14.topodata.TabletType\"\"\n\x0eVTGateCallerID\x12\x10\n\x08username\x18\x01 \x01(\t\"@\n\nEventToken\x12\x11\n\ttimestamp\x18\x01 \x01(\x03\x12\r\n\x05shard\x18\x02 \x01(\t\x12\x10\n\x08position\x18\x03 \x01(\t\"1\n\x05Value\x12\x19\n\x04type\x18\x01 \x01(\x0e\x32\x0b.query.Type\x12\r\n\x05value\x18\x02 \x01(\x0c\"V\n\x0c\x42indVariable\x12\x19\n\x04type\x18\x01 \x01(\x0e\x32\x0b.query.Type\x12\r\n\x05value\x18\x02 \x01(\x0c\x12\x1c\n\x06values\x18\x03 \x03(\x0b\x32\x0c.query.Value\"\xa2\x01\n\nBoundQuery\x12\x0b\n\x03sql\x18\x01 \x01(\t\x12<\n\x0e\x62ind_variables\x18\x02 \x03(\x0b\x32$.query.BoundQuery.BindVariablesEntry\x1aI\n\x12\x42indVariablesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\"\n\x05value\x18\x02 \x01(\x0b\x32\x13.query.BindVariable:\x02\x38\x01\"\xdf\x01\n\x0e\x45xecuteOptions\x12\x1b\n\x13include_event_token\x18\x02 \x01(\x08\x12.\n\x13\x63ompare_event_token\x18\x03 \x01(\x0b\x32\x11.query.EventToken\x12=\n\x0fincluded_fields\x18\x04 \x01(\x0e\x32$.query.ExecuteOptions.IncludedFields\";\n\x0eIncludedFields\x12\x11\n\rTYPE_AND_NAME\x10\x00\x12\r\n\tTYPE_ONLY\x10\x01\x12\x07\n\x03\x41LL\x10\x02J\x04\x08\x01\x10\x02\"\xbf\x01\n\x05\x46ield\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x19\n\x04type\x18\x02 \x01(\x0e\x32\x0b.query.Type\x12\r\n\x05table\x18\x03 \x01(\t\x12\x11\n\torg_table\x18\x04 \x01(\t\x12\x10\n\x08\x64\x61tabase\x18\x05 \x01(\t\x12\x10\n\x08org_name\x18\x06 \x01(\t\x12\x15\n\rcolumn_length\x18\x07 \x01(\r\x12\x0f\n\x07\x63harset\x18\x08 \x01(\r\x12\x10\n\x08\x64\x65\x63imals\x18\t \x01(\r\x12\r\n\x05\x66lags\x18\n \x01(\r\"&\n\x03Row\x12\x0f\n\x07lengths\x18\x01 \x03(\x12\x12\x0e\n\x06values\x18\x02 \x01(\x0c\"G\n\x0cResultExtras\x12&\n\x0b\x65vent_token\x18\x01 \x01(\x0b\x32\x11.query.EventToken\x12\x0f\n\x07\x66resher\x18\x02 \x01(\x08\"\x94\x01\n\x0bQueryResult\x12\x1c\n\x06\x66ields\x18\x01 \x03(\x0b\x32\x0c.query.Field\x12\x15\n\rrows_affected\x18\x02 \x01(\x04\x12\x11\n\tinsert_id\x18\x03 \x01(\x04\x12\x18\n\x04rows\x18\x04 \x03(\x0b\x32\n.query.Row\x12#\n\x06\x65xtras\x18\x05 \x01(\x0b\x32\x13.query.ResultExtras\"\xca\x02\n\x0bStreamEvent\x12\x30\n\nstatements\x18\x01 \x03(\x0b\x32\x1c.query.StreamEvent.Statement\x12&\n\x0b\x65vent_token\x18\x02 \x01(\x0b\x32\x11.query.EventToken\x1a\xe0\x01\n\tStatement\x12\x37\n\x08\x63\x61tegory\x18\x01 \x01(\x0e\x32%.query.StreamEvent.Statement.Category\x12\x12\n\ntable_name\x18\x02 \x01(\t\x12(\n\x12primary_key_fields\x18\x03 \x03(\x0b\x32\x0c.query.Field\x12&\n\x12primary_key_values\x18\x04 \x03(\x0b\x32\n.query.Row\x12\x0b\n\x03sql\x18\x05 \x01(\x0c\"\'\n\x08\x43\x61tegory\x12\t\n\x05\x45rror\x10\x00\x12\x07\n\x03\x44ML\x10\x01\x12\x07\n\x03\x44\x44L\x10\x02\"\xf3\x01\n\x0e\x45xecuteRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12 \n\x05query\x18\x04 \x01(\x0b\x32\x11.query.BoundQuery\x12\x16\n\x0etransaction_id\x18\x05 \x01(\x03\x12&\n\x07options\x18\x06 \x01(\x0b\x32\x15.query.ExecuteOptions\"5\n\x0f\x45xecuteResponse\x12\"\n\x06result\x18\x01 \x01(\x0b\x32\x12.query.QueryResult\"U\n\x0fResultWithError\x12\x1e\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x0f.vtrpc.RPCError\x12\"\n\x06result\x18\x02 \x01(\x0b\x32\x12.query.QueryResult\"\x92\x02\n\x13\x45xecuteBatchRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12\"\n\x07queries\x18\x04 \x03(\x0b\x32\x11.query.BoundQuery\x12\x16\n\x0e\x61s_transaction\x18\x05 \x01(\x08\x12\x16\n\x0etransaction_id\x18\x06 \x01(\x03\x12&\n\x07options\x18\x07 \x01(\x0b\x32\x15.query.ExecuteOptions\";\n\x14\x45xecuteBatchResponse\x12#\n\x07results\x18\x01 \x03(\x0b\x32\x12.query.QueryResult\"\xe1\x01\n\x14StreamExecuteRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12 \n\x05query\x18\x04 \x01(\x0b\x32\x11.query.BoundQuery\x12&\n\x07options\x18\x05 \x01(\x0b\x32\x15.query.ExecuteOptions\";\n\x15StreamExecuteResponse\x12\"\n\x06result\x18\x01 \x01(\x0b\x32\x12.query.QueryResult\"\x8f\x01\n\x0c\x42\x65ginRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\"\'\n\rBeginResponse\x12\x16\n\x0etransaction_id\x18\x01 \x01(\x03\"\xa8\x01\n\rCommitRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12\x16\n\x0etransaction_id\x18\x04 \x01(\x03\"\x10\n\x0e\x43ommitResponse\"\xaa\x01\n\x0fRollbackRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12\x16\n\x0etransaction_id\x18\x04 \x01(\x03\"\x12\n\x10RollbackResponse\"\xb7\x01\n\x0ePrepareRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12\x16\n\x0etransaction_id\x18\x04 \x01(\x03\x12\x0c\n\x04\x64tid\x18\x05 \x01(\t\"\x11\n\x0fPrepareResponse\"\xa6\x01\n\x15\x43ommitPreparedRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12\x0c\n\x04\x64tid\x18\x04 \x01(\t\"\x18\n\x16\x43ommitPreparedResponse\"\xc0\x01\n\x17RollbackPreparedRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12\x16\n\x0etransaction_id\x18\x04 \x01(\x03\x12\x0c\n\x04\x64tid\x18\x05 \x01(\t\"\x1a\n\x18RollbackPreparedResponse\"\xce\x01\n\x18\x43reateTransactionRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12\x0c\n\x04\x64tid\x18\x04 \x01(\t\x12#\n\x0cparticipants\x18\x05 \x03(\x0b\x32\r.query.Target\"\x1b\n\x19\x43reateTransactionResponse\"\xbb\x01\n\x12StartCommitRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12\x16\n\x0etransaction_id\x18\x04 \x01(\x03\x12\x0c\n\x04\x64tid\x18\x05 \x01(\t\"\x15\n\x13StartCommitResponse\"\xbb\x01\n\x12SetRollbackRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12\x16\n\x0etransaction_id\x18\x04 \x01(\x03\x12\x0c\n\x04\x64tid\x18\x05 \x01(\t\"\x15\n\x13SetRollbackResponse\"\xab\x01\n\x1a\x43oncludeTransactionRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12\x0c\n\x04\x64tid\x18\x04 \x01(\t\"\x1d\n\x1b\x43oncludeTransactionResponse\"\xa7\x01\n\x16ReadTransactionRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12\x0c\n\x04\x64tid\x18\x04 \x01(\t\"G\n\x17ReadTransactionResponse\x12,\n\x08metadata\x18\x01 \x01(\x0b\x32\x1a.query.TransactionMetadata\"\xe0\x01\n\x13\x42\x65ginExecuteRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12 \n\x05query\x18\x04 \x01(\x0b\x32\x11.query.BoundQuery\x12&\n\x07options\x18\x05 \x01(\x0b\x32\x15.query.ExecuteOptions\"r\n\x14\x42\x65ginExecuteResponse\x12\x1e\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x0f.vtrpc.RPCError\x12\"\n\x06result\x18\x02 \x01(\x0b\x32\x12.query.QueryResult\x12\x16\n\x0etransaction_id\x18\x03 \x01(\x03\"\xff\x01\n\x18\x42\x65ginExecuteBatchRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12\"\n\x07queries\x18\x04 \x03(\x0b\x32\x11.query.BoundQuery\x12\x16\n\x0e\x61s_transaction\x18\x05 \x01(\x08\x12&\n\x07options\x18\x06 \x01(\x0b\x32\x15.query.ExecuteOptions\"x\n\x19\x42\x65ginExecuteBatchResponse\x12\x1e\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x0f.vtrpc.RPCError\x12#\n\x07results\x18\x02 \x03(\x0b\x32\x12.query.QueryResult\x12\x16\n\x0etransaction_id\x18\x03 \x01(\x03\"\xa5\x01\n\x14MessageStreamRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12\x0c\n\x04name\x18\x04 \x01(\t\";\n\x15MessageStreamResponse\x12\"\n\x06result\x18\x01 \x01(\x0b\x32\x12.query.QueryResult\"\xbd\x01\n\x11MessageAckRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12\x0c\n\x04name\x18\x04 \x01(\t\x12\x19\n\x03ids\x18\x05 \x03(\x0b\x32\x0c.query.Value\"8\n\x12MessageAckResponse\x12\"\n\x06result\x18\x01 \x01(\x0b\x32\x12.query.QueryResult\"\xe7\x02\n\x11SplitQueryRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12 \n\x05query\x18\x04 \x01(\x0b\x32\x11.query.BoundQuery\x12\x14\n\x0csplit_column\x18\x05 \x03(\t\x12\x13\n\x0bsplit_count\x18\x06 \x01(\x03\x12\x1f\n\x17num_rows_per_query_part\x18\x08 \x01(\x03\x12\x35\n\talgorithm\x18\t \x01(\x0e\x32\".query.SplitQueryRequest.Algorithm\",\n\tAlgorithm\x12\x10\n\x0c\x45QUAL_SPLITS\x10\x00\x12\r\n\tFULL_SCAN\x10\x01\"A\n\nQuerySplit\x12 \n\x05query\x18\x01 \x01(\x0b\x32\x11.query.BoundQuery\x12\x11\n\trow_count\x18\x02 \x01(\x03\"8\n\x12SplitQueryResponse\x12\"\n\x07queries\x18\x01 \x03(\x0b\x32\x11.query.QuerySplit\"\x15\n\x13StreamHealthRequest\"\xb6\x01\n\rRealtimeStats\x12\x14\n\x0chealth_error\x18\x01 \x01(\t\x12\x1d\n\x15seconds_behind_master\x18\x02 \x01(\r\x12\x1c\n\x14\x62inlog_players_count\x18\x03 \x01(\x05\x12\x32\n*seconds_behind_master_filtered_replication\x18\x04 \x01(\x03\x12\x11\n\tcpu_usage\x18\x05 \x01(\x01\x12\x0b\n\x03qps\x18\x06 \x01(\x01\"\xa4\x01\n\x14StreamHealthResponse\x12\x1d\n\x06target\x18\x01 \x01(\x0b\x32\r.query.Target\x12\x0f\n\x07serving\x18\x02 \x01(\x08\x12.\n&tablet_externally_reparented_timestamp\x18\x03 \x01(\x03\x12,\n\x0erealtime_stats\x18\x04 \x01(\x0b\x32\x14.query.RealtimeStats\"\xbb\x01\n\x13UpdateStreamRequest\x12,\n\x13\x65\x66\x66\x65\x63tive_caller_id\x18\x01 \x01(\x0b\x32\x0f.vtrpc.CallerID\x12\x32\n\x13immediate_caller_id\x18\x02 \x01(\x0b\x32\x15.query.VTGateCallerID\x12\x1d\n\x06target\x18\x03 \x01(\x0b\x32\r.query.Target\x12\x10\n\x08position\x18\x04 \x01(\t\x12\x11\n\ttimestamp\x18\x05 \x01(\x03\"9\n\x14UpdateStreamResponse\x12!\n\x05\x65vent\x18\x01 \x01(\x0b\x32\x12.query.StreamEvent\"\x86\x01\n\x13TransactionMetadata\x12\x0c\n\x04\x64tid\x18\x01 \x01(\t\x12&\n\x05state\x18\x02 \x01(\x0e\x32\x17.query.TransactionState\x12\x14\n\x0ctime_created\x18\x03 \x01(\x03\x12#\n\x0cparticipants\x18\x04 \x03(\x0b\x32\r.query.Target*\x92\x03\n\tMySqlFlag\x12\t\n\x05\x45MPTY\x10\x00\x12\x11\n\rNOT_NULL_FLAG\x10\x01\x12\x10\n\x0cPRI_KEY_FLAG\x10\x02\x12\x13\n\x0fUNIQUE_KEY_FLAG\x10\x04\x12\x15\n\x11MULTIPLE_KEY_FLAG\x10\x08\x12\r\n\tBLOB_FLAG\x10\x10\x12\x11\n\rUNSIGNED_FLAG\x10 \x12\x11\n\rZEROFILL_FLAG\x10@\x12\x10\n\x0b\x42INARY_FLAG\x10\x80\x01\x12\x0e\n\tENUM_FLAG\x10\x80\x02\x12\x18\n\x13\x41UTO_INCREMENT_FLAG\x10\x80\x04\x12\x13\n\x0eTIMESTAMP_FLAG\x10\x80\x08\x12\r\n\x08SET_FLAG\x10\x80\x10\x12\x1a\n\x15NO_DEFAULT_VALUE_FLAG\x10\x80 \x12\x17\n\x12ON_UPDATE_NOW_FLAG\x10\x80@\x12\x0e\n\x08NUM_FLAG\x10\x80\x80\x02\x12\x13\n\rPART_KEY_FLAG\x10\x80\x80\x01\x12\x10\n\nGROUP_FLAG\x10\x80\x80\x02\x12\x11\n\x0bUNIQUE_FLAG\x10\x80\x80\x04\x12\x11\n\x0b\x42INCMP_FLAG\x10\x80\x80\x08\x1a\x02\x10\x01*k\n\x04\x46lag\x12\x08\n\x04NONE\x10\x00\x12\x0f\n\nISINTEGRAL\x10\x80\x02\x12\x0f\n\nISUNSIGNED\x10\x80\x04\x12\x0c\n\x07ISFLOAT\x10\x80\x08\x12\r\n\x08ISQUOTED\x10\x80\x10\x12\x0b\n\x06ISTEXT\x10\x80 \x12\r\n\x08ISBINARY\x10\x80@*\x89\x03\n\x04Type\x12\r\n\tNULL_TYPE\x10\x00\x12\t\n\x04INT8\x10\x81\x02\x12\n\n\x05UINT8\x10\x82\x06\x12\n\n\x05INT16\x10\x83\x02\x12\x0b\n\x06UINT16\x10\x84\x06\x12\n\n\x05INT24\x10\x85\x02\x12\x0b\n\x06UINT24\x10\x86\x06\x12\n\n\x05INT32\x10\x87\x02\x12\x0b\n\x06UINT32\x10\x88\x06\x12\n\n\x05INT64\x10\x89\x02\x12\x0b\n\x06UINT64\x10\x8a\x06\x12\x0c\n\x07\x46LOAT32\x10\x8b\x08\x12\x0c\n\x07\x46LOAT64\x10\x8c\x08\x12\x0e\n\tTIMESTAMP\x10\x8d\x10\x12\t\n\x04\x44\x41TE\x10\x8e\x10\x12\t\n\x04TIME\x10\x8f\x10\x12\r\n\x08\x44\x41TETIME\x10\x90\x10\x12\t\n\x04YEAR\x10\x91\x06\x12\x0b\n\x07\x44\x45\x43IMAL\x10\x12\x12\t\n\x04TEXT\x10\x93\x30\x12\t\n\x04\x42LOB\x10\x94P\x12\x0c\n\x07VARCHAR\x10\x95\x30\x12\x0e\n\tVARBINARY\x10\x96P\x12\t\n\x04\x43HAR\x10\x97\x30\x12\x0b\n\x06\x42INARY\x10\x98P\x12\x08\n\x03\x42IT\x10\x99\x10\x12\t\n\x04\x45NUM\x10\x9a\x10\x12\x08\n\x03SET\x10\x9b\x10\x12\t\n\x05TUPLE\x10\x1c\x12\r\n\x08GEOMETRY\x10\x9d\x10\x12\t\n\x04JSON\x10\x9e\x10*F\n\x10TransactionState\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x0b\n\x07PREPARE\x10\x01\x12\n\n\x06\x43OMMIT\x10\x02\x12\x0c\n\x08ROLLBACK\x10\x03\x42\x1a\n\x18\x63om.youtube.vitess.protob\x06proto3')
    ,
    dependencies=[topodata__pb2.DESCRIPTOR,vtrpc__pb2.DESCRIPTOR,])
  _sym_db.RegisterFileDescriptor(DESCRIPTOR)
  
  _MYSQLFLAG = _descriptor.EnumDescriptor(
    name='MySqlFlag',
    full_name='query.MySqlFlag',
    filename=None,
    file=DESCRIPTOR,
    values=[
      _descriptor.EnumValueDescriptor(
        name='EMPTY', index=0, number=0,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='NOT_NULL_FLAG', index=1, number=1,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='PRI_KEY_FLAG', index=2, number=2,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='UNIQUE_KEY_FLAG', index=3, number=4,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='MULTIPLE_KEY_FLAG', index=4, number=8,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='BLOB_FLAG', index=5, number=16,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='UNSIGNED_FLAG', index=6, number=32,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='ZEROFILL_FLAG', index=7, number=64,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='BINARY_FLAG', index=8, number=128,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='ENUM_FLAG', index=9, number=256,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='AUTO_INCREMENT_FLAG', index=10, number=512,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='TIMESTAMP_FLAG', index=11, number=1024,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='SET_FLAG', index=12, number=2048,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='NO_DEFAULT_VALUE_FLAG', index=13, number=4096,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='ON_UPDATE_NOW_FLAG', index=14, number=8192,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='NUM_FLAG', index=15, number=32768,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='PART_KEY_FLAG', index=16, number=16384,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='GROUP_FLAG', index=17, number=32768,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='UNIQUE_FLAG', index=18, number=65536,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='BINCMP_FLAG', index=19, number=131072,
        options=None,
        type=None),
    ],
    containing_type=None,
    options=_descriptor._ParseOptions(descriptor_pb2.EnumOptions(), _b('\020\001')),
    serialized_start=7330,
    serialized_end=7732,
  )
  _sym_db.RegisterEnumDescriptor(_MYSQLFLAG)
  
  MySqlFlag = enum_type_wrapper.EnumTypeWrapper(_MYSQLFLAG)
  _FLAG = _descriptor.EnumDescriptor(
    name='Flag',
    full_name='query.Flag',
    filename=None,
    file=DESCRIPTOR,
    values=[
      _descriptor.EnumValueDescriptor(
        name='NONE', index=0, number=0,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='ISINTEGRAL', index=1, number=256,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='ISUNSIGNED', index=2, number=512,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='ISFLOAT', index=3, number=1024,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='ISQUOTED', index=4, number=2048,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='ISTEXT', index=5, number=4096,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='ISBINARY', index=6, number=8192,
        options=None,
        type=None),
    ],
    containing_type=None,
    options=None,
    serialized_start=7734,
    serialized_end=7841,
  )
  _sym_db.RegisterEnumDescriptor(_FLAG)
  
  Flag = enum_type_wrapper.EnumTypeWrapper(_FLAG)
  _TYPE = _descriptor.EnumDescriptor(
    name='Type',
    full_name='query.Type',
    filename=None,
    file=DESCRIPTOR,
    values=[
      _descriptor.EnumValueDescriptor(
        name='NULL_TYPE', index=0, number=0,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='INT8', index=1, number=257,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='UINT8', index=2, number=770,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='INT16', index=3, number=259,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='UINT16', index=4, number=772,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='INT24', index=5, number=261,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='UINT24', index=6, number=774,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='INT32', index=7, number=263,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='UINT32', index=8, number=776,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='INT64', index=9, number=265,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='UINT64', index=10, number=778,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='FLOAT32', index=11, number=1035,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='FLOAT64', index=12, number=1036,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='TIMESTAMP', index=13, number=2061,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='DATE', index=14, number=2062,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='TIME', index=15, number=2063,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='DATETIME', index=16, number=2064,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='YEAR', index=17, number=785,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='DECIMAL', index=18, number=18,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='TEXT', index=19, number=6163,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='BLOB', index=20, number=10260,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='VARCHAR', index=21, number=6165,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='VARBINARY', index=22, number=10262,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='CHAR', index=23, number=6167,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='BINARY', index=24, number=10264,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='BIT', index=25, number=2073,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='ENUM', index=26, number=2074,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='SET', index=27, number=2075,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='TUPLE', index=28, number=28,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='GEOMETRY', index=29, number=2077,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='JSON', index=30, number=2078,
        options=None,
        type=None),
    ],
    containing_type=None,
    options=None,
    serialized_start=7844,
    serialized_end=8237,
  )
  _sym_db.RegisterEnumDescriptor(_TYPE)
  
  Type = enum_type_wrapper.EnumTypeWrapper(_TYPE)
  _TRANSACTIONSTATE = _descriptor.EnumDescriptor(
    name='TransactionState',
    full_name='query.TransactionState',
    filename=None,
    file=DESCRIPTOR,
    values=[
      _descriptor.EnumValueDescriptor(
        name='UNKNOWN', index=0, number=0,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='PREPARE', index=1, number=1,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='COMMIT', index=2, number=2,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='ROLLBACK', index=3, number=3,
        options=None,
        type=None),
    ],
    containing_type=None,
    options=None,
    serialized_start=8239,
    serialized_end=8309,
  )
  _sym_db.RegisterEnumDescriptor(_TRANSACTIONSTATE)
  
  TransactionState = enum_type_wrapper.EnumTypeWrapper(_TRANSACTIONSTATE)
  EMPTY = 0
  NOT_NULL_FLAG = 1
  PRI_KEY_FLAG = 2
  UNIQUE_KEY_FLAG = 4
  MULTIPLE_KEY_FLAG = 8
  BLOB_FLAG = 16
  UNSIGNED_FLAG = 32
  ZEROFILL_FLAG = 64
  BINARY_FLAG = 128
  ENUM_FLAG = 256
  AUTO_INCREMENT_FLAG = 512
  TIMESTAMP_FLAG = 1024
  SET_FLAG = 2048
  NO_DEFAULT_VALUE_FLAG = 4096
  ON_UPDATE_NOW_FLAG = 8192
  NUM_FLAG = 32768
  PART_KEY_FLAG = 16384
  GROUP_FLAG = 32768
  UNIQUE_FLAG = 65536
  BINCMP_FLAG = 131072
  NONE = 0
  ISINTEGRAL = 256
  ISUNSIGNED = 512
  ISFLOAT = 1024
  ISQUOTED = 2048
  ISTEXT = 4096
  ISBINARY = 8192
  NULL_TYPE = 0
  INT8 = 257
  UINT8 = 770
  INT16 = 259
  UINT16 = 772
  INT24 = 261
  UINT24 = 774
  INT32 = 263
  UINT32 = 776
  INT64 = 265
  UINT64 = 778
  FLOAT32 = 1035
  FLOAT64 = 1036
  TIMESTAMP = 2061
  DATE = 2062
  TIME = 2063
  DATETIME = 2064
  YEAR = 785
  DECIMAL = 18
  TEXT = 6163
  BLOB = 10260
  VARCHAR = 6165
  VARBINARY = 10262
  CHAR = 6167
  BINARY = 10264
  BIT = 2073
  ENUM = 2074
  SET = 2075
  TUPLE = 28
  GEOMETRY = 2077
  JSON = 2078
  UNKNOWN = 0
  PREPARE = 1
  COMMIT = 2
  ROLLBACK = 3
  
  
  _EXECUTEOPTIONS_INCLUDEDFIELDS = _descriptor.EnumDescriptor(
    name='IncludedFields',
    full_name='query.ExecuteOptions.IncludedFields',
    filename=None,
    file=DESCRIPTOR,
    values=[
      _descriptor.EnumValueDescriptor(
        name='TYPE_AND_NAME', index=0, number=0,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='TYPE_ONLY', index=1, number=1,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='ALL', index=2, number=2,
        options=None,
        type=None),
    ],
    containing_type=None,
    options=None,
    serialized_start=702,
    serialized_end=761,
  )
  _sym_db.RegisterEnumDescriptor(_EXECUTEOPTIONS_INCLUDEDFIELDS)
  
  _STREAMEVENT_STATEMENT_CATEGORY = _descriptor.EnumDescriptor(
    name='Category',
    full_name='query.StreamEvent.Statement.Category',
    filename=None,
    file=DESCRIPTOR,
    values=[
      _descriptor.EnumValueDescriptor(
        name='Error', index=0, number=0,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='DML', index=1, number=1,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='DDL', index=2, number=2,
        options=None,
        type=None),
    ],
    containing_type=None,
    options=None,
    serialized_start=1519,
    serialized_end=1558,
  )
  _sym_db.RegisterEnumDescriptor(_STREAMEVENT_STATEMENT_CATEGORY)
  
  _SPLITQUERYREQUEST_ALGORITHM = _descriptor.EnumDescriptor(
    name='Algorithm',
    full_name='query.SplitQueryRequest.Algorithm',
    filename=None,
    file=DESCRIPTOR,
    values=[
      _descriptor.EnumValueDescriptor(
        name='EQUAL_SPLITS', index=0, number=0,
        options=None,
        type=None),
      _descriptor.EnumValueDescriptor(
        name='FULL_SCAN', index=1, number=1,
        options=None,
        type=None),
    ],
    containing_type=None,
    options=None,
    serialized_start=6397,
    serialized_end=6441,
  )
  _sym_db.RegisterEnumDescriptor(_SPLITQUERYREQUEST_ALGORITHM)
  
  
  _TARGET = _descriptor.Descriptor(
    name='Target',
    full_name='query.Target',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='keyspace', full_name='query.Target.keyspace', 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='shard', full_name='query.Target.shard', index=1,
        number=2, 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='tablet_type', full_name='query.Target.tablet_type', index=2,
        number=3, type=14, cpp_type=8, label=1,
        has_default_value=False, default_value=0,
        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=51,
    serialized_end=135,
  )
  
  
  _VTGATECALLERID = _descriptor.Descriptor(
    name='VTGateCallerID',
    full_name='query.VTGateCallerID',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='username', full_name='query.VTGateCallerID.username', 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=137,
    serialized_end=171,
  )
  
  
  _EVENTTOKEN = _descriptor.Descriptor(
    name='EventToken',
    full_name='query.EventToken',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='timestamp', full_name='query.EventToken.timestamp', index=0,
        number=1, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='shard', full_name='query.EventToken.shard', index=1,
        number=2, 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='position', full_name='query.EventToken.position', index=2,
        number=3, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=173,
    serialized_end=237,
  )
  
  
  _VALUE = _descriptor.Descriptor(
    name='Value',
    full_name='query.Value',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='type', full_name='query.Value.type', index=0,
        number=1, type=14, cpp_type=8, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='value', full_name='query.Value.value', index=1,
        number=2, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=239,
    serialized_end=288,
  )
  
  
  _BINDVARIABLE = _descriptor.Descriptor(
    name='BindVariable',
    full_name='query.BindVariable',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='type', full_name='query.BindVariable.type', index=0,
        number=1, type=14, cpp_type=8, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='value', full_name='query.BindVariable.value', index=1,
        number=2, 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='values', full_name='query.BindVariable.values', index=2,
        number=3, 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=290,
    serialized_end=376,
  )
  
  
  _BOUNDQUERY_BINDVARIABLESENTRY = _descriptor.Descriptor(
    name='BindVariablesEntry',
    full_name='query.BoundQuery.BindVariablesEntry',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='key', full_name='query.BoundQuery.BindVariablesEntry.key', 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='value', full_name='query.BoundQuery.BindVariablesEntry.value', index=1,
        number=2, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=_descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001')),
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=468,
    serialized_end=541,
  )
  
  _BOUNDQUERY = _descriptor.Descriptor(
    name='BoundQuery',
    full_name='query.BoundQuery',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='sql', full_name='query.BoundQuery.sql', 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='bind_variables', full_name='query.BoundQuery.bind_variables', 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=[_BOUNDQUERY_BINDVARIABLESENTRY, ],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=379,
    serialized_end=541,
  )
  
  
  _EXECUTEOPTIONS = _descriptor.Descriptor(
    name='ExecuteOptions',
    full_name='query.ExecuteOptions',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='include_event_token', full_name='query.ExecuteOptions.include_event_token', index=0,
        number=2, 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='compare_event_token', full_name='query.ExecuteOptions.compare_event_token', index=1,
        number=3, 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='included_fields', full_name='query.ExecuteOptions.included_fields', index=2,
        number=4, type=14, cpp_type=8, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
      _EXECUTEOPTIONS_INCLUDEDFIELDS,
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=544,
    serialized_end=767,
  )
  
  
  _FIELD = _descriptor.Descriptor(
    name='Field',
    full_name='query.Field',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='name', full_name='query.Field.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='type', full_name='query.Field.type', index=1,
        number=2, type=14, cpp_type=8, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='table', full_name='query.Field.table', index=2,
        number=3, 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='org_table', full_name='query.Field.org_table', index=3,
        number=4, 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='database', full_name='query.Field.database', index=4,
        number=5, 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='org_name', full_name='query.Field.org_name', index=5,
        number=6, 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='column_length', full_name='query.Field.column_length', index=6,
        number=7, type=13, cpp_type=3, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='charset', full_name='query.Field.charset', index=7,
        number=8, type=13, cpp_type=3, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='decimals', full_name='query.Field.decimals', index=8,
        number=9, type=13, cpp_type=3, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='flags', full_name='query.Field.flags', index=9,
        number=10, type=13, cpp_type=3, label=1,
        has_default_value=False, default_value=0,
        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=770,
    serialized_end=961,
  )
  
  
  _ROW = _descriptor.Descriptor(
    name='Row',
    full_name='query.Row',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='lengths', full_name='query.Row.lengths', index=0,
        number=1, type=18, cpp_type=2, 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='values', full_name='query.Row.values', index=1,
        number=2, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=963,
    serialized_end=1001,
  )
  
  
  _RESULTEXTRAS = _descriptor.Descriptor(
    name='ResultExtras',
    full_name='query.ResultExtras',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='event_token', full_name='query.ResultExtras.event_token', index=0,
        number=1, 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='fresher', full_name='query.ResultExtras.fresher', index=1,
        number=2, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=1003,
    serialized_end=1074,
  )
  
  
  _QUERYRESULT = _descriptor.Descriptor(
    name='QueryResult',
    full_name='query.QueryResult',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='fields', full_name='query.QueryResult.fields', 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),
      _descriptor.FieldDescriptor(
        name='rows_affected', full_name='query.QueryResult.rows_affected', index=1,
        number=2, type=4, cpp_type=4, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='insert_id', full_name='query.QueryResult.insert_id', index=2,
        number=3, type=4, cpp_type=4, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='rows', full_name='query.QueryResult.rows', index=3,
        number=4, 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),
      _descriptor.FieldDescriptor(
        name='extras', full_name='query.QueryResult.extras', 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=1077,
    serialized_end=1225,
  )
  
  
  _STREAMEVENT_STATEMENT = _descriptor.Descriptor(
    name='Statement',
    full_name='query.StreamEvent.Statement',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='category', full_name='query.StreamEvent.Statement.category', index=0,
        number=1, type=14, cpp_type=8, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='table_name', full_name='query.StreamEvent.Statement.table_name', index=1,
        number=2, 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='primary_key_fields', full_name='query.StreamEvent.Statement.primary_key_fields', index=2,
        number=3, 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),
      _descriptor.FieldDescriptor(
        name='primary_key_values', full_name='query.StreamEvent.Statement.primary_key_values', index=3,
        number=4, 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),
      _descriptor.FieldDescriptor(
        name='sql', full_name='query.StreamEvent.Statement.sql', index=4,
        number=5, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
      _STREAMEVENT_STATEMENT_CATEGORY,
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=1334,
    serialized_end=1558,
  )
  
  _STREAMEVENT = _descriptor.Descriptor(
    name='StreamEvent',
    full_name='query.StreamEvent',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='statements', full_name='query.StreamEvent.statements', 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),
      _descriptor.FieldDescriptor(
        name='event_token', full_name='query.StreamEvent.event_token', index=1,
        number=2, 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),
    ],
    extensions=[
    ],
    nested_types=[_STREAMEVENT_STATEMENT, ],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=1228,
    serialized_end=1558,
  )
  
  
  _EXECUTEREQUEST = _descriptor.Descriptor(
    name='ExecuteRequest',
    full_name='query.ExecuteRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.ExecuteRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.ExecuteRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.ExecuteRequest.target', index=2,
        number=3, 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='query', full_name='query.ExecuteRequest.query', index=3,
        number=4, 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='transaction_id', full_name='query.ExecuteRequest.transaction_id', index=4,
        number=5, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='options', full_name='query.ExecuteRequest.options', index=5,
        number=6, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=1561,
    serialized_end=1804,
  )
  
  
  _EXECUTERESPONSE = _descriptor.Descriptor(
    name='ExecuteResponse',
    full_name='query.ExecuteResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='result', full_name='query.ExecuteResponse.result', index=0,
        number=1, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=1806,
    serialized_end=1859,
  )
  
  
  _RESULTWITHERROR = _descriptor.Descriptor(
    name='ResultWithError',
    full_name='query.ResultWithError',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='error', full_name='query.ResultWithError.error', index=0,
        number=1, 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='result', full_name='query.ResultWithError.result', index=1,
        number=2, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=1861,
    serialized_end=1946,
  )
  
  
  _EXECUTEBATCHREQUEST = _descriptor.Descriptor(
    name='ExecuteBatchRequest',
    full_name='query.ExecuteBatchRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.ExecuteBatchRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.ExecuteBatchRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.ExecuteBatchRequest.target', index=2,
        number=3, 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='queries', full_name='query.ExecuteBatchRequest.queries', index=3,
        number=4, 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),
      _descriptor.FieldDescriptor(
        name='as_transaction', full_name='query.ExecuteBatchRequest.as_transaction', index=4,
        number=5, 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='transaction_id', full_name='query.ExecuteBatchRequest.transaction_id', index=5,
        number=6, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='options', full_name='query.ExecuteBatchRequest.options', index=6,
        number=7, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=1949,
    serialized_end=2223,
  )
  
  
  _EXECUTEBATCHRESPONSE = _descriptor.Descriptor(
    name='ExecuteBatchResponse',
    full_name='query.ExecuteBatchResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='results', full_name='query.ExecuteBatchResponse.results', 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=2225,
    serialized_end=2284,
  )
  
  
  _STREAMEXECUTEREQUEST = _descriptor.Descriptor(
    name='StreamExecuteRequest',
    full_name='query.StreamExecuteRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.StreamExecuteRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.StreamExecuteRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.StreamExecuteRequest.target', index=2,
        number=3, 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='query', full_name='query.StreamExecuteRequest.query', index=3,
        number=4, 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='options', full_name='query.StreamExecuteRequest.options', 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=2287,
    serialized_end=2512,
  )
  
  
  _STREAMEXECUTERESPONSE = _descriptor.Descriptor(
    name='StreamExecuteResponse',
    full_name='query.StreamExecuteResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='result', full_name='query.StreamExecuteResponse.result', index=0,
        number=1, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=2514,
    serialized_end=2573,
  )
  
  
  _BEGINREQUEST = _descriptor.Descriptor(
    name='BeginRequest',
    full_name='query.BeginRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.BeginRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.BeginRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.BeginRequest.target', index=2,
        number=3, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=2576,
    serialized_end=2719,
  )
  
  
  _BEGINRESPONSE = _descriptor.Descriptor(
    name='BeginResponse',
    full_name='query.BeginResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='transaction_id', full_name='query.BeginResponse.transaction_id', index=0,
        number=1, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        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=2721,
    serialized_end=2760,
  )
  
  
  _COMMITREQUEST = _descriptor.Descriptor(
    name='CommitRequest',
    full_name='query.CommitRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.CommitRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.CommitRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.CommitRequest.target', index=2,
        number=3, 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='transaction_id', full_name='query.CommitRequest.transaction_id', index=3,
        number=4, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        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=2763,
    serialized_end=2931,
  )
  
  
  _COMMITRESPONSE = _descriptor.Descriptor(
    name='CommitResponse',
    full_name='query.CommitResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=2933,
    serialized_end=2949,
  )
  
  
  _ROLLBACKREQUEST = _descriptor.Descriptor(
    name='RollbackRequest',
    full_name='query.RollbackRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.RollbackRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.RollbackRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.RollbackRequest.target', index=2,
        number=3, 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='transaction_id', full_name='query.RollbackRequest.transaction_id', index=3,
        number=4, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        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=2952,
    serialized_end=3122,
  )
  
  
  _ROLLBACKRESPONSE = _descriptor.Descriptor(
    name='RollbackResponse',
    full_name='query.RollbackResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=3124,
    serialized_end=3142,
  )
  
  
  _PREPAREREQUEST = _descriptor.Descriptor(
    name='PrepareRequest',
    full_name='query.PrepareRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.PrepareRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.PrepareRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.PrepareRequest.target', index=2,
        number=3, 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='transaction_id', full_name='query.PrepareRequest.transaction_id', index=3,
        number=4, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='dtid', full_name='query.PrepareRequest.dtid', index=4,
        number=5, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=3145,
    serialized_end=3328,
  )
  
  
  _PREPARERESPONSE = _descriptor.Descriptor(
    name='PrepareResponse',
    full_name='query.PrepareResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=3330,
    serialized_end=3347,
  )
  
  
  _COMMITPREPAREDREQUEST = _descriptor.Descriptor(
    name='CommitPreparedRequest',
    full_name='query.CommitPreparedRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.CommitPreparedRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.CommitPreparedRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.CommitPreparedRequest.target', index=2,
        number=3, 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='dtid', full_name='query.CommitPreparedRequest.dtid', index=3,
        number=4, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=3350,
    serialized_end=3516,
  )
  
  
  _COMMITPREPAREDRESPONSE = _descriptor.Descriptor(
    name='CommitPreparedResponse',
    full_name='query.CommitPreparedResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=3518,
    serialized_end=3542,
  )
  
  
  _ROLLBACKPREPAREDREQUEST = _descriptor.Descriptor(
    name='RollbackPreparedRequest',
    full_name='query.RollbackPreparedRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.RollbackPreparedRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.RollbackPreparedRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.RollbackPreparedRequest.target', index=2,
        number=3, 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='transaction_id', full_name='query.RollbackPreparedRequest.transaction_id', index=3,
        number=4, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='dtid', full_name='query.RollbackPreparedRequest.dtid', index=4,
        number=5, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=3545,
    serialized_end=3737,
  )
  
  
  _ROLLBACKPREPAREDRESPONSE = _descriptor.Descriptor(
    name='RollbackPreparedResponse',
    full_name='query.RollbackPreparedResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=3739,
    serialized_end=3765,
  )
  
  
  _CREATETRANSACTIONREQUEST = _descriptor.Descriptor(
    name='CreateTransactionRequest',
    full_name='query.CreateTransactionRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.CreateTransactionRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.CreateTransactionRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.CreateTransactionRequest.target', index=2,
        number=3, 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='dtid', full_name='query.CreateTransactionRequest.dtid', index=3,
        number=4, 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='participants', full_name='query.CreateTransactionRequest.participants', index=4,
        number=5, 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=3768,
    serialized_end=3974,
  )
  
  
  _CREATETRANSACTIONRESPONSE = _descriptor.Descriptor(
    name='CreateTransactionResponse',
    full_name='query.CreateTransactionResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=3976,
    serialized_end=4003,
  )
  
  
  _STARTCOMMITREQUEST = _descriptor.Descriptor(
    name='StartCommitRequest',
    full_name='query.StartCommitRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.StartCommitRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.StartCommitRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.StartCommitRequest.target', index=2,
        number=3, 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='transaction_id', full_name='query.StartCommitRequest.transaction_id', index=3,
        number=4, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='dtid', full_name='query.StartCommitRequest.dtid', index=4,
        number=5, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=4006,
    serialized_end=4193,
  )
  
  
  _STARTCOMMITRESPONSE = _descriptor.Descriptor(
    name='StartCommitResponse',
    full_name='query.StartCommitResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=4195,
    serialized_end=4216,
  )
  
  
  _SETROLLBACKREQUEST = _descriptor.Descriptor(
    name='SetRollbackRequest',
    full_name='query.SetRollbackRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.SetRollbackRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.SetRollbackRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.SetRollbackRequest.target', index=2,
        number=3, 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='transaction_id', full_name='query.SetRollbackRequest.transaction_id', index=3,
        number=4, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='dtid', full_name='query.SetRollbackRequest.dtid', index=4,
        number=5, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=4219,
    serialized_end=4406,
  )
  
  
  _SETROLLBACKRESPONSE = _descriptor.Descriptor(
    name='SetRollbackResponse',
    full_name='query.SetRollbackResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=4408,
    serialized_end=4429,
  )
  
  
  _CONCLUDETRANSACTIONREQUEST = _descriptor.Descriptor(
    name='ConcludeTransactionRequest',
    full_name='query.ConcludeTransactionRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.ConcludeTransactionRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.ConcludeTransactionRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.ConcludeTransactionRequest.target', index=2,
        number=3, 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='dtid', full_name='query.ConcludeTransactionRequest.dtid', index=3,
        number=4, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=4432,
    serialized_end=4603,
  )
  
  
  _CONCLUDETRANSACTIONRESPONSE = _descriptor.Descriptor(
    name='ConcludeTransactionResponse',
    full_name='query.ConcludeTransactionResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=4605,
    serialized_end=4634,
  )
  
  
  _READTRANSACTIONREQUEST = _descriptor.Descriptor(
    name='ReadTransactionRequest',
    full_name='query.ReadTransactionRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.ReadTransactionRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.ReadTransactionRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.ReadTransactionRequest.target', index=2,
        number=3, 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='dtid', full_name='query.ReadTransactionRequest.dtid', index=3,
        number=4, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=4637,
    serialized_end=4804,
  )
  
  
  _READTRANSACTIONRESPONSE = _descriptor.Descriptor(
    name='ReadTransactionResponse',
    full_name='query.ReadTransactionResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='metadata', full_name='query.ReadTransactionResponse.metadata', index=0,
        number=1, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=4806,
    serialized_end=4877,
  )
  
  
  _BEGINEXECUTEREQUEST = _descriptor.Descriptor(
    name='BeginExecuteRequest',
    full_name='query.BeginExecuteRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.BeginExecuteRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.BeginExecuteRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.BeginExecuteRequest.target', index=2,
        number=3, 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='query', full_name='query.BeginExecuteRequest.query', index=3,
        number=4, 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='options', full_name='query.BeginExecuteRequest.options', 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=4880,
    serialized_end=5104,
  )
  
  
  _BEGINEXECUTERESPONSE = _descriptor.Descriptor(
    name='BeginExecuteResponse',
    full_name='query.BeginExecuteResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='error', full_name='query.BeginExecuteResponse.error', index=0,
        number=1, 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='result', full_name='query.BeginExecuteResponse.result', index=1,
        number=2, 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='transaction_id', full_name='query.BeginExecuteResponse.transaction_id', index=2,
        number=3, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        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=5106,
    serialized_end=5220,
  )
  
  
  _BEGINEXECUTEBATCHREQUEST = _descriptor.Descriptor(
    name='BeginExecuteBatchRequest',
    full_name='query.BeginExecuteBatchRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.BeginExecuteBatchRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.BeginExecuteBatchRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.BeginExecuteBatchRequest.target', index=2,
        number=3, 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='queries', full_name='query.BeginExecuteBatchRequest.queries', index=3,
        number=4, 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),
      _descriptor.FieldDescriptor(
        name='as_transaction', full_name='query.BeginExecuteBatchRequest.as_transaction', index=4,
        number=5, 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='options', full_name='query.BeginExecuteBatchRequest.options', index=5,
        number=6, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=5223,
    serialized_end=5478,
  )
  
  
  _BEGINEXECUTEBATCHRESPONSE = _descriptor.Descriptor(
    name='BeginExecuteBatchResponse',
    full_name='query.BeginExecuteBatchResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='error', full_name='query.BeginExecuteBatchResponse.error', index=0,
        number=1, 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='results', full_name='query.BeginExecuteBatchResponse.results', 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),
      _descriptor.FieldDescriptor(
        name='transaction_id', full_name='query.BeginExecuteBatchResponse.transaction_id', index=2,
        number=3, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        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=5480,
    serialized_end=5600,
  )
  
  
  _MESSAGESTREAMREQUEST = _descriptor.Descriptor(
    name='MessageStreamRequest',
    full_name='query.MessageStreamRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.MessageStreamRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.MessageStreamRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.MessageStreamRequest.target', index=2,
        number=3, 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='name', full_name='query.MessageStreamRequest.name', index=3,
        number=4, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=5603,
    serialized_end=5768,
  )
  
  
  _MESSAGESTREAMRESPONSE = _descriptor.Descriptor(
    name='MessageStreamResponse',
    full_name='query.MessageStreamResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='result', full_name='query.MessageStreamResponse.result', index=0,
        number=1, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=5770,
    serialized_end=5829,
  )
  
  
  _MESSAGEACKREQUEST = _descriptor.Descriptor(
    name='MessageAckRequest',
    full_name='query.MessageAckRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.MessageAckRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.MessageAckRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.MessageAckRequest.target', index=2,
        number=3, 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='name', full_name='query.MessageAckRequest.name', index=3,
        number=4, 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='ids', full_name='query.MessageAckRequest.ids', index=4,
        number=5, 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=5832,
    serialized_end=6021,
  )
  
  
  _MESSAGEACKRESPONSE = _descriptor.Descriptor(
    name='MessageAckResponse',
    full_name='query.MessageAckResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='result', full_name='query.MessageAckResponse.result', index=0,
        number=1, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=6023,
    serialized_end=6079,
  )
  
  
  _SPLITQUERYREQUEST = _descriptor.Descriptor(
    name='SplitQueryRequest',
    full_name='query.SplitQueryRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.SplitQueryRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.SplitQueryRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.SplitQueryRequest.target', index=2,
        number=3, 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='query', full_name='query.SplitQueryRequest.query', index=3,
        number=4, 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='split_column', full_name='query.SplitQueryRequest.split_column', index=4,
        number=5, type=9, 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='split_count', full_name='query.SplitQueryRequest.split_count', index=5,
        number=6, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='num_rows_per_query_part', full_name='query.SplitQueryRequest.num_rows_per_query_part', index=6,
        number=8, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='algorithm', full_name='query.SplitQueryRequest.algorithm', index=7,
        number=9, type=14, cpp_type=8, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
      _SPLITQUERYREQUEST_ALGORITHM,
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=6082,
    serialized_end=6441,
  )
  
  
  _QUERYSPLIT = _descriptor.Descriptor(
    name='QuerySplit',
    full_name='query.QuerySplit',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='query', full_name='query.QuerySplit.query', index=0,
        number=1, 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='row_count', full_name='query.QuerySplit.row_count', index=1,
        number=2, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        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=6443,
    serialized_end=6508,
  )
  
  
  _SPLITQUERYRESPONSE = _descriptor.Descriptor(
    name='SplitQueryResponse',
    full_name='query.SplitQueryResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='queries', full_name='query.SplitQueryResponse.queries', 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=6510,
    serialized_end=6566,
  )
  
  
  _STREAMHEALTHREQUEST = _descriptor.Descriptor(
    name='StreamHealthRequest',
    full_name='query.StreamHealthRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=6568,
    serialized_end=6589,
  )
  
  
  _REALTIMESTATS = _descriptor.Descriptor(
    name='RealtimeStats',
    full_name='query.RealtimeStats',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='health_error', full_name='query.RealtimeStats.health_error', 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='seconds_behind_master', full_name='query.RealtimeStats.seconds_behind_master', index=1,
        number=2, type=13, cpp_type=3, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='binlog_players_count', full_name='query.RealtimeStats.binlog_players_count', index=2,
        number=3, type=5, cpp_type=1, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='seconds_behind_master_filtered_replication', full_name='query.RealtimeStats.seconds_behind_master_filtered_replication', index=3,
        number=4, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='cpu_usage', full_name='query.RealtimeStats.cpu_usage', index=4,
        number=5, type=1, cpp_type=5, label=1,
        has_default_value=False, default_value=float(0),
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='qps', full_name='query.RealtimeStats.qps', index=5,
        number=6, type=1, cpp_type=5, label=1,
        has_default_value=False, default_value=float(0),
        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=6592,
    serialized_end=6774,
  )
  
  
  _STREAMHEALTHRESPONSE = _descriptor.Descriptor(
    name='StreamHealthResponse',
    full_name='query.StreamHealthResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='target', full_name='query.StreamHealthResponse.target', index=0,
        number=1, 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='serving', full_name='query.StreamHealthResponse.serving', index=1,
        number=2, 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='tablet_externally_reparented_timestamp', full_name='query.StreamHealthResponse.tablet_externally_reparented_timestamp', index=2,
        number=3, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='realtime_stats', full_name='query.StreamHealthResponse.realtime_stats', index=3,
        number=4, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=6777,
    serialized_end=6941,
  )
  
  
  _UPDATESTREAMREQUEST = _descriptor.Descriptor(
    name='UpdateStreamRequest',
    full_name='query.UpdateStreamRequest',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='effective_caller_id', full_name='query.UpdateStreamRequest.effective_caller_id', index=0,
        number=1, 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='immediate_caller_id', full_name='query.UpdateStreamRequest.immediate_caller_id', index=1,
        number=2, 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='target', full_name='query.UpdateStreamRequest.target', index=2,
        number=3, 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='position', full_name='query.UpdateStreamRequest.position', index=3,
        number=4, 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='timestamp', full_name='query.UpdateStreamRequest.timestamp', index=4,
        number=5, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        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=6944,
    serialized_end=7131,
  )
  
  
  _UPDATESTREAMRESPONSE = _descriptor.Descriptor(
    name='UpdateStreamResponse',
    full_name='query.UpdateStreamResponse',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='event', full_name='query.UpdateStreamResponse.event', index=0,
        number=1, 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),
    ],
    extensions=[
    ],
    nested_types=[],
    enum_types=[
    ],
    options=None,
    is_extendable=False,
    syntax='proto3',
    extension_ranges=[],
    oneofs=[
    ],
    serialized_start=7133,
    serialized_end=7190,
  )
  
  
  _TRANSACTIONMETADATA = _descriptor.Descriptor(
    name='TransactionMetadata',
    full_name='query.TransactionMetadata',
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
      _descriptor.FieldDescriptor(
        name='dtid', full_name='query.TransactionMetadata.dtid', 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='state', full_name='query.TransactionMetadata.state', index=1,
        number=2, type=14, cpp_type=8, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='time_created', full_name='query.TransactionMetadata.time_created', index=2,
        number=3, type=3, cpp_type=2, label=1,
        has_default_value=False, default_value=0,
        message_type=None, enum_type=None, containing_type=None,
        is_extension=False, extension_scope=None,
        options=None),
      _descriptor.FieldDescriptor(
        name='participants', full_name='query.TransactionMetadata.participants', index=3,
        number=4, 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=7193,
    serialized_end=7327,
  )
  
  _TARGET.fields_by_name['tablet_type'].enum_type = topodata__pb2._TABLETTYPE
  _VALUE.fields_by_name['type'].enum_type = _TYPE
  _BINDVARIABLE.fields_by_name['type'].enum_type = _TYPE
  _BINDVARIABLE.fields_by_name['values'].message_type = _VALUE
  _BOUNDQUERY_BINDVARIABLESENTRY.fields_by_name['value'].message_type = _BINDVARIABLE
  _BOUNDQUERY_BINDVARIABLESENTRY.containing_type = _BOUNDQUERY
  _BOUNDQUERY.fields_by_name['bind_variables'].message_type = _BOUNDQUERY_BINDVARIABLESENTRY
  _EXECUTEOPTIONS.fields_by_name['compare_event_token'].message_type = _EVENTTOKEN
  _EXECUTEOPTIONS.fields_by_name['included_fields'].enum_type = _EXECUTEOPTIONS_INCLUDEDFIELDS
  _EXECUTEOPTIONS_INCLUDEDFIELDS.containing_type = _EXECUTEOPTIONS
  _FIELD.fields_by_name['type'].enum_type = _TYPE
  _RESULTEXTRAS.fields_by_name['event_token'].message_type = _EVENTTOKEN
  _QUERYRESULT.fields_by_name['fields'].message_type = _FIELD
  _QUERYRESULT.fields_by_name['rows'].message_type = _ROW
  _QUERYRESULT.fields_by_name['extras'].message_type = _RESULTEXTRAS
  _STREAMEVENT_STATEMENT.fields_by_name['category'].enum_type = _STREAMEVENT_STATEMENT_CATEGORY
  _STREAMEVENT_STATEMENT.fields_by_name['primary_key_fields'].message_type = _FIELD
  _STREAMEVENT_STATEMENT.fields_by_name['primary_key_values'].message_type = _ROW
  _STREAMEVENT_STATEMENT.containing_type = _STREAMEVENT
  _STREAMEVENT_STATEMENT_CATEGORY.containing_type = _STREAMEVENT_STATEMENT
  _STREAMEVENT.fields_by_name['statements'].message_type = _STREAMEVENT_STATEMENT
  _STREAMEVENT.fields_by_name['event_token'].message_type = _EVENTTOKEN
  _EXECUTEREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _EXECUTEREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _EXECUTEREQUEST.fields_by_name['target'].message_type = _TARGET
  _EXECUTEREQUEST.fields_by_name['query'].message_type = _BOUNDQUERY
  _EXECUTEREQUEST.fields_by_name['options'].message_type = _EXECUTEOPTIONS
  _EXECUTERESPONSE.fields_by_name['result'].message_type = _QUERYRESULT
  _RESULTWITHERROR.fields_by_name['error'].message_type = vtrpc__pb2._RPCERROR
  _RESULTWITHERROR.fields_by_name['result'].message_type = _QUERYRESULT
  _EXECUTEBATCHREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _EXECUTEBATCHREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _EXECUTEBATCHREQUEST.fields_by_name['target'].message_type = _TARGET
  _EXECUTEBATCHREQUEST.fields_by_name['queries'].message_type = _BOUNDQUERY
  _EXECUTEBATCHREQUEST.fields_by_name['options'].message_type = _EXECUTEOPTIONS
  _EXECUTEBATCHRESPONSE.fields_by_name['results'].message_type = _QUERYRESULT
  _STREAMEXECUTEREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _STREAMEXECUTEREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _STREAMEXECUTEREQUEST.fields_by_name['target'].message_type = _TARGET
  _STREAMEXECUTEREQUEST.fields_by_name['query'].message_type = _BOUNDQUERY
  _STREAMEXECUTEREQUEST.fields_by_name['options'].message_type = _EXECUTEOPTIONS
  _STREAMEXECUTERESPONSE.fields_by_name['result'].message_type = _QUERYRESULT
  _BEGINREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _BEGINREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _BEGINREQUEST.fields_by_name['target'].message_type = _TARGET
  _COMMITREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _COMMITREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _COMMITREQUEST.fields_by_name['target'].message_type = _TARGET
  _ROLLBACKREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _ROLLBACKREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _ROLLBACKREQUEST.fields_by_name['target'].message_type = _TARGET
  _PREPAREREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _PREPAREREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _PREPAREREQUEST.fields_by_name['target'].message_type = _TARGET
  _COMMITPREPAREDREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _COMMITPREPAREDREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _COMMITPREPAREDREQUEST.fields_by_name['target'].message_type = _TARGET
  _ROLLBACKPREPAREDREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _ROLLBACKPREPAREDREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _ROLLBACKPREPAREDREQUEST.fields_by_name['target'].message_type = _TARGET
  _CREATETRANSACTIONREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _CREATETRANSACTIONREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _CREATETRANSACTIONREQUEST.fields_by_name['target'].message_type = _TARGET
  _CREATETRANSACTIONREQUEST.fields_by_name['participants'].message_type = _TARGET
  _STARTCOMMITREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _STARTCOMMITREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _STARTCOMMITREQUEST.fields_by_name['target'].message_type = _TARGET
  _SETROLLBACKREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _SETROLLBACKREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _SETROLLBACKREQUEST.fields_by_name['target'].message_type = _TARGET
  _CONCLUDETRANSACTIONREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _CONCLUDETRANSACTIONREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _CONCLUDETRANSACTIONREQUEST.fields_by_name['target'].message_type = _TARGET
  _READTRANSACTIONREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _READTRANSACTIONREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _READTRANSACTIONREQUEST.fields_by_name['target'].message_type = _TARGET
  _READTRANSACTIONRESPONSE.fields_by_name['metadata'].message_type = _TRANSACTIONMETADATA
  _BEGINEXECUTEREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _BEGINEXECUTEREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _BEGINEXECUTEREQUEST.fields_by_name['target'].message_type = _TARGET
  _BEGINEXECUTEREQUEST.fields_by_name['query'].message_type = _BOUNDQUERY
  _BEGINEXECUTEREQUEST.fields_by_name['options'].message_type = _EXECUTEOPTIONS
  _BEGINEXECUTERESPONSE.fields_by_name['error'].message_type = vtrpc__pb2._RPCERROR
  _BEGINEXECUTERESPONSE.fields_by_name['result'].message_type = _QUERYRESULT
  _BEGINEXECUTEBATCHREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _BEGINEXECUTEBATCHREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _BEGINEXECUTEBATCHREQUEST.fields_by_name['target'].message_type = _TARGET
  _BEGINEXECUTEBATCHREQUEST.fields_by_name['queries'].message_type = _BOUNDQUERY
  _BEGINEXECUTEBATCHREQUEST.fields_by_name['options'].message_type = _EXECUTEOPTIONS
  _BEGINEXECUTEBATCHRESPONSE.fields_by_name['error'].message_type = vtrpc__pb2._RPCERROR
  _BEGINEXECUTEBATCHRESPONSE.fields_by_name['results'].message_type = _QUERYRESULT
  _MESSAGESTREAMREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _MESSAGESTREAMREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _MESSAGESTREAMREQUEST.fields_by_name['target'].message_type = _TARGET
  _MESSAGESTREAMRESPONSE.fields_by_name['result'].message_type = _QUERYRESULT
  _MESSAGEACKREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _MESSAGEACKREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _MESSAGEACKREQUEST.fields_by_name['target'].message_type = _TARGET
  _MESSAGEACKREQUEST.fields_by_name['ids'].message_type = _VALUE
  _MESSAGEACKRESPONSE.fields_by_name['result'].message_type = _QUERYRESULT
  _SPLITQUERYREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _SPLITQUERYREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _SPLITQUERYREQUEST.fields_by_name['target'].message_type = _TARGET
  _SPLITQUERYREQUEST.fields_by_name['query'].message_type = _BOUNDQUERY
  _SPLITQUERYREQUEST.fields_by_name['algorithm'].enum_type = _SPLITQUERYREQUEST_ALGORITHM
  _SPLITQUERYREQUEST_ALGORITHM.containing_type = _SPLITQUERYREQUEST
  _QUERYSPLIT.fields_by_name['query'].message_type = _BOUNDQUERY
  _SPLITQUERYRESPONSE.fields_by_name['queries'].message_type = _QUERYSPLIT
  _STREAMHEALTHRESPONSE.fields_by_name['target'].message_type = _TARGET
  _STREAMHEALTHRESPONSE.fields_by_name['realtime_stats'].message_type = _REALTIMESTATS
  _UPDATESTREAMREQUEST.fields_by_name['effective_caller_id'].message_type = vtrpc__pb2._CALLERID
  _UPDATESTREAMREQUEST.fields_by_name['immediate_caller_id'].message_type = _VTGATECALLERID
  _UPDATESTREAMREQUEST.fields_by_name['target'].message_type = _TARGET
  _UPDATESTREAMRESPONSE.fields_by_name['event'].message_type = _STREAMEVENT
  _TRANSACTIONMETADATA.fields_by_name['state'].enum_type = _TRANSACTIONSTATE
  _TRANSACTIONMETADATA.fields_by_name['participants'].message_type = _TARGET
  DESCRIPTOR.message_types_by_name['Target'] = _TARGET
  DESCRIPTOR.message_types_by_name['VTGateCallerID'] = _VTGATECALLERID
  DESCRIPTOR.message_types_by_name['EventToken'] = _EVENTTOKEN
  DESCRIPTOR.message_types_by_name['Value'] = _VALUE
  DESCRIPTOR.message_types_by_name['BindVariable'] = _BINDVARIABLE
  DESCRIPTOR.message_types_by_name['BoundQuery'] = _BOUNDQUERY
  DESCRIPTOR.message_types_by_name['ExecuteOptions'] = _EXECUTEOPTIONS
  DESCRIPTOR.message_types_by_name['Field'] = _FIELD
  DESCRIPTOR.message_types_by_name['Row'] = _ROW
  DESCRIPTOR.message_types_by_name['ResultExtras'] = _RESULTEXTRAS
  DESCRIPTOR.message_types_by_name['QueryResult'] = _QUERYRESULT
  DESCRIPTOR.message_types_by_name['StreamEvent'] = _STREAMEVENT
  DESCRIPTOR.message_types_by_name['ExecuteRequest'] = _EXECUTEREQUEST
  DESCRIPTOR.message_types_by_name['ExecuteResponse'] = _EXECUTERESPONSE
  DESCRIPTOR.message_types_by_name['ResultWithError'] = _RESULTWITHERROR
  DESCRIPTOR.message_types_by_name['ExecuteBatchRequest'] = _EXECUTEBATCHREQUEST
  DESCRIPTOR.message_types_by_name['ExecuteBatchResponse'] = _EXECUTEBATCHRESPONSE
  DESCRIPTOR.message_types_by_name['StreamExecuteRequest'] = _STREAMEXECUTEREQUEST
  DESCRIPTOR.message_types_by_name['StreamExecuteResponse'] = _STREAMEXECUTERESPONSE
  DESCRIPTOR.message_types_by_name['BeginRequest'] = _BEGINREQUEST
  DESCRIPTOR.message_types_by_name['BeginResponse'] = _BEGINRESPONSE
  DESCRIPTOR.message_types_by_name['CommitRequest'] = _COMMITREQUEST
  DESCRIPTOR.message_types_by_name['CommitResponse'] = _COMMITRESPONSE
  DESCRIPTOR.message_types_by_name['RollbackRequest'] = _ROLLBACKREQUEST
  DESCRIPTOR.message_types_by_name['RollbackResponse'] = _ROLLBACKRESPONSE
  DESCRIPTOR.message_types_by_name['PrepareRequest'] = _PREPAREREQUEST
  DESCRIPTOR.message_types_by_name['PrepareResponse'] = _PREPARERESPONSE
  DESCRIPTOR.message_types_by_name['CommitPreparedRequest'] = _COMMITPREPAREDREQUEST
  DESCRIPTOR.message_types_by_name['CommitPreparedResponse'] = _COMMITPREPAREDRESPONSE
  DESCRIPTOR.message_types_by_name['RollbackPreparedRequest'] = _ROLLBACKPREPAREDREQUEST
  DESCRIPTOR.message_types_by_name['RollbackPreparedResponse'] = _ROLLBACKPREPAREDRESPONSE
  DESCRIPTOR.message_types_by_name['CreateTransactionRequest'] = _CREATETRANSACTIONREQUEST
  DESCRIPTOR.message_types_by_name['CreateTransactionResponse'] = _CREATETRANSACTIONRESPONSE
  DESCRIPTOR.message_types_by_name['StartCommitRequest'] = _STARTCOMMITREQUEST
  DESCRIPTOR.message_types_by_name['StartCommitResponse'] = _STARTCOMMITRESPONSE
  DESCRIPTOR.message_types_by_name['SetRollbackRequest'] = _SETROLLBACKREQUEST
  DESCRIPTOR.message_types_by_name['SetRollbackResponse'] = _SETROLLBACKRESPONSE
  DESCRIPTOR.message_types_by_name['ConcludeTransactionRequest'] = _CONCLUDETRANSACTIONREQUEST
  DESCRIPTOR.message_types_by_name['ConcludeTransactionResponse'] = _CONCLUDETRANSACTIONRESPONSE
  DESCRIPTOR.message_types_by_name['ReadTransactionRequest'] = _READTRANSACTIONREQUEST
  DESCRIPTOR.message_types_by_name['ReadTransactionResponse'] = _READTRANSACTIONRESPONSE
  DESCRIPTOR.message_types_by_name['BeginExecuteRequest'] = _BEGINEXECUTEREQUEST
  DESCRIPTOR.message_types_by_name['BeginExecuteResponse'] = _BEGINEXECUTERESPONSE
  DESCRIPTOR.message_types_by_name['BeginExecuteBatchRequest'] = _BEGINEXECUTEBATCHREQUEST
  DESCRIPTOR.message_types_by_name['BeginExecuteBatchResponse'] = _BEGINEXECUTEBATCHRESPONSE
  DESCRIPTOR.message_types_by_name['MessageStreamRequest'] = _MESSAGESTREAMREQUEST
  DESCRIPTOR.message_types_by_name['MessageStreamResponse'] = _MESSAGESTREAMRESPONSE
  DESCRIPTOR.message_types_by_name['MessageAckRequest'] = _MESSAGEACKREQUEST
  DESCRIPTOR.message_types_by_name['MessageAckResponse'] = _MESSAGEACKRESPONSE
  DESCRIPTOR.message_types_by_name['SplitQueryRequest'] = _SPLITQUERYREQUEST
  DESCRIPTOR.message_types_by_name['QuerySplit'] = _QUERYSPLIT
  DESCRIPTOR.message_types_by_name['SplitQueryResponse'] = _SPLITQUERYRESPONSE
  DESCRIPTOR.message_types_by_name['StreamHealthRequest'] = _STREAMHEALTHREQUEST
  DESCRIPTOR.message_types_by_name['RealtimeStats'] = _REALTIMESTATS
  DESCRIPTOR.message_types_by_name['StreamHealthResponse'] = _STREAMHEALTHRESPONSE
  DESCRIPTOR.message_types_by_name['UpdateStreamRequest'] = _UPDATESTREAMREQUEST
  DESCRIPTOR.message_types_by_name['UpdateStreamResponse'] = _UPDATESTREAMRESPONSE
  DESCRIPTOR.message_types_by_name['TransactionMetadata'] = _TRANSACTIONMETADATA
  DESCRIPTOR.enum_types_by_name['MySqlFlag'] = _MYSQLFLAG
  DESCRIPTOR.enum_types_by_name['Flag'] = _FLAG
  DESCRIPTOR.enum_types_by_name['Type'] = _TYPE
  DESCRIPTOR.enum_types_by_name['TransactionState'] = _TRANSACTIONSTATE
  
  Target = _reflection.GeneratedProtocolMessageType('Target', (_message.Message,), dict(
    DESCRIPTOR = _TARGET,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.Target)
    ))
  _sym_db.RegisterMessage(Target)
  
  VTGateCallerID = _reflection.GeneratedProtocolMessageType('VTGateCallerID', (_message.Message,), dict(
    DESCRIPTOR = _VTGATECALLERID,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.VTGateCallerID)
    ))
  _sym_db.RegisterMessage(VTGateCallerID)
  
  EventToken = _reflection.GeneratedProtocolMessageType('EventToken', (_message.Message,), dict(
    DESCRIPTOR = _EVENTTOKEN,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.EventToken)
    ))
  _sym_db.RegisterMessage(EventToken)
  
  Value = _reflection.GeneratedProtocolMessageType('Value', (_message.Message,), dict(
    DESCRIPTOR = _VALUE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.Value)
    ))
  _sym_db.RegisterMessage(Value)
  
  BindVariable = _reflection.GeneratedProtocolMessageType('BindVariable', (_message.Message,), dict(
    DESCRIPTOR = _BINDVARIABLE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.BindVariable)
    ))
  _sym_db.RegisterMessage(BindVariable)
  
  BoundQuery = _reflection.GeneratedProtocolMessageType('BoundQuery', (_message.Message,), dict(
  
    BindVariablesEntry = _reflection.GeneratedProtocolMessageType('BindVariablesEntry', (_message.Message,), dict(
      DESCRIPTOR = _BOUNDQUERY_BINDVARIABLESENTRY,
      __module__ = 'query_pb2'
      # @@protoc_insertion_point(class_scope:query.BoundQuery.BindVariablesEntry)
      ))
    ,
    DESCRIPTOR = _BOUNDQUERY,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.BoundQuery)
    ))
  _sym_db.RegisterMessage(BoundQuery)
  _sym_db.RegisterMessage(BoundQuery.BindVariablesEntry)
  
  ExecuteOptions = _reflection.GeneratedProtocolMessageType('ExecuteOptions', (_message.Message,), dict(
    DESCRIPTOR = _EXECUTEOPTIONS,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.ExecuteOptions)
    ))
  _sym_db.RegisterMessage(ExecuteOptions)
  
  Field = _reflection.GeneratedProtocolMessageType('Field', (_message.Message,), dict(
    DESCRIPTOR = _FIELD,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.Field)
    ))
  _sym_db.RegisterMessage(Field)
  
  Row = _reflection.GeneratedProtocolMessageType('Row', (_message.Message,), dict(
    DESCRIPTOR = _ROW,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.Row)
    ))
  _sym_db.RegisterMessage(Row)
  
  ResultExtras = _reflection.GeneratedProtocolMessageType('ResultExtras', (_message.Message,), dict(
    DESCRIPTOR = _RESULTEXTRAS,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.ResultExtras)
    ))
  _sym_db.RegisterMessage(ResultExtras)
  
  QueryResult = _reflection.GeneratedProtocolMessageType('QueryResult', (_message.Message,), dict(
    DESCRIPTOR = _QUERYRESULT,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.QueryResult)
    ))
  _sym_db.RegisterMessage(QueryResult)
  
  StreamEvent = _reflection.GeneratedProtocolMessageType('StreamEvent', (_message.Message,), dict(
  
    Statement = _reflection.GeneratedProtocolMessageType('Statement', (_message.Message,), dict(
      DESCRIPTOR = _STREAMEVENT_STATEMENT,
      __module__ = 'query_pb2'
      # @@protoc_insertion_point(class_scope:query.StreamEvent.Statement)
      ))
    ,
    DESCRIPTOR = _STREAMEVENT,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.StreamEvent)
    ))
  _sym_db.RegisterMessage(StreamEvent)
  _sym_db.RegisterMessage(StreamEvent.Statement)
  
  ExecuteRequest = _reflection.GeneratedProtocolMessageType('ExecuteRequest', (_message.Message,), dict(
    DESCRIPTOR = _EXECUTEREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.ExecuteRequest)
    ))
  _sym_db.RegisterMessage(ExecuteRequest)
  
  ExecuteResponse = _reflection.GeneratedProtocolMessageType('ExecuteResponse', (_message.Message,), dict(
    DESCRIPTOR = _EXECUTERESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.ExecuteResponse)
    ))
  _sym_db.RegisterMessage(ExecuteResponse)
  
  ResultWithError = _reflection.GeneratedProtocolMessageType('ResultWithError', (_message.Message,), dict(
    DESCRIPTOR = _RESULTWITHERROR,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.ResultWithError)
    ))
  _sym_db.RegisterMessage(ResultWithError)
  
  ExecuteBatchRequest = _reflection.GeneratedProtocolMessageType('ExecuteBatchRequest', (_message.Message,), dict(
    DESCRIPTOR = _EXECUTEBATCHREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.ExecuteBatchRequest)
    ))
  _sym_db.RegisterMessage(ExecuteBatchRequest)
  
  ExecuteBatchResponse = _reflection.GeneratedProtocolMessageType('ExecuteBatchResponse', (_message.Message,), dict(
    DESCRIPTOR = _EXECUTEBATCHRESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.ExecuteBatchResponse)
    ))
  _sym_db.RegisterMessage(ExecuteBatchResponse)
  
  StreamExecuteRequest = _reflection.GeneratedProtocolMessageType('StreamExecuteRequest', (_message.Message,), dict(
    DESCRIPTOR = _STREAMEXECUTEREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.StreamExecuteRequest)
    ))
  _sym_db.RegisterMessage(StreamExecuteRequest)
  
  StreamExecuteResponse = _reflection.GeneratedProtocolMessageType('StreamExecuteResponse', (_message.Message,), dict(
    DESCRIPTOR = _STREAMEXECUTERESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.StreamExecuteResponse)
    ))
  _sym_db.RegisterMessage(StreamExecuteResponse)
  
  BeginRequest = _reflection.GeneratedProtocolMessageType('BeginRequest', (_message.Message,), dict(
    DESCRIPTOR = _BEGINREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.BeginRequest)
    ))
  _sym_db.RegisterMessage(BeginRequest)
  
  BeginResponse = _reflection.GeneratedProtocolMessageType('BeginResponse', (_message.Message,), dict(
    DESCRIPTOR = _BEGINRESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.BeginResponse)
    ))
  _sym_db.RegisterMessage(BeginResponse)
  
  CommitRequest = _reflection.GeneratedProtocolMessageType('CommitRequest', (_message.Message,), dict(
    DESCRIPTOR = _COMMITREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.CommitRequest)
    ))
  _sym_db.RegisterMessage(CommitRequest)
  
  CommitResponse = _reflection.GeneratedProtocolMessageType('CommitResponse', (_message.Message,), dict(
    DESCRIPTOR = _COMMITRESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.CommitResponse)
    ))
  _sym_db.RegisterMessage(CommitResponse)
  
  RollbackRequest = _reflection.GeneratedProtocolMessageType('RollbackRequest', (_message.Message,), dict(
    DESCRIPTOR = _ROLLBACKREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.RollbackRequest)
    ))
  _sym_db.RegisterMessage(RollbackRequest)
  
  RollbackResponse = _reflection.GeneratedProtocolMessageType('RollbackResponse', (_message.Message,), dict(
    DESCRIPTOR = _ROLLBACKRESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.RollbackResponse)
    ))
  _sym_db.RegisterMessage(RollbackResponse)
  
  PrepareRequest = _reflection.GeneratedProtocolMessageType('PrepareRequest', (_message.Message,), dict(
    DESCRIPTOR = _PREPAREREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.PrepareRequest)
    ))
  _sym_db.RegisterMessage(PrepareRequest)
  
  PrepareResponse = _reflection.GeneratedProtocolMessageType('PrepareResponse', (_message.Message,), dict(
    DESCRIPTOR = _PREPARERESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.PrepareResponse)
    ))
  _sym_db.RegisterMessage(PrepareResponse)
  
  CommitPreparedRequest = _reflection.GeneratedProtocolMessageType('CommitPreparedRequest', (_message.Message,), dict(
    DESCRIPTOR = _COMMITPREPAREDREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.CommitPreparedRequest)
    ))
  _sym_db.RegisterMessage(CommitPreparedRequest)
  
  CommitPreparedResponse = _reflection.GeneratedProtocolMessageType('CommitPreparedResponse', (_message.Message,), dict(
    DESCRIPTOR = _COMMITPREPAREDRESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.CommitPreparedResponse)
    ))
  _sym_db.RegisterMessage(CommitPreparedResponse)
  
  RollbackPreparedRequest = _reflection.GeneratedProtocolMessageType('RollbackPreparedRequest', (_message.Message,), dict(
    DESCRIPTOR = _ROLLBACKPREPAREDREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.RollbackPreparedRequest)
    ))
  _sym_db.RegisterMessage(RollbackPreparedRequest)
  
  RollbackPreparedResponse = _reflection.GeneratedProtocolMessageType('RollbackPreparedResponse', (_message.Message,), dict(
    DESCRIPTOR = _ROLLBACKPREPAREDRESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.RollbackPreparedResponse)
    ))
  _sym_db.RegisterMessage(RollbackPreparedResponse)
  
  CreateTransactionRequest = _reflection.GeneratedProtocolMessageType('CreateTransactionRequest', (_message.Message,), dict(
    DESCRIPTOR = _CREATETRANSACTIONREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.CreateTransactionRequest)
    ))
  _sym_db.RegisterMessage(CreateTransactionRequest)
  
  CreateTransactionResponse = _reflection.GeneratedProtocolMessageType('CreateTransactionResponse', (_message.Message,), dict(
    DESCRIPTOR = _CREATETRANSACTIONRESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.CreateTransactionResponse)
    ))
  _sym_db.RegisterMessage(CreateTransactionResponse)
  
  StartCommitRequest = _reflection.GeneratedProtocolMessageType('StartCommitRequest', (_message.Message,), dict(
    DESCRIPTOR = _STARTCOMMITREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.StartCommitRequest)
    ))
  _sym_db.RegisterMessage(StartCommitRequest)
  
  StartCommitResponse = _reflection.GeneratedProtocolMessageType('StartCommitResponse', (_message.Message,), dict(
    DESCRIPTOR = _STARTCOMMITRESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.StartCommitResponse)
    ))
  _sym_db.RegisterMessage(StartCommitResponse)
  
  SetRollbackRequest = _reflection.GeneratedProtocolMessageType('SetRollbackRequest', (_message.Message,), dict(
    DESCRIPTOR = _SETROLLBACKREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.SetRollbackRequest)
    ))
  _sym_db.RegisterMessage(SetRollbackRequest)
  
  SetRollbackResponse = _reflection.GeneratedProtocolMessageType('SetRollbackResponse', (_message.Message,), dict(
    DESCRIPTOR = _SETROLLBACKRESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.SetRollbackResponse)
    ))
  _sym_db.RegisterMessage(SetRollbackResponse)
  
  ConcludeTransactionRequest = _reflection.GeneratedProtocolMessageType('ConcludeTransactionRequest', (_message.Message,), dict(
    DESCRIPTOR = _CONCLUDETRANSACTIONREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.ConcludeTransactionRequest)
    ))
  _sym_db.RegisterMessage(ConcludeTransactionRequest)
  
  ConcludeTransactionResponse = _reflection.GeneratedProtocolMessageType('ConcludeTransactionResponse', (_message.Message,), dict(
    DESCRIPTOR = _CONCLUDETRANSACTIONRESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.ConcludeTransactionResponse)
    ))
  _sym_db.RegisterMessage(ConcludeTransactionResponse)
  
  ReadTransactionRequest = _reflection.GeneratedProtocolMessageType('ReadTransactionRequest', (_message.Message,), dict(
    DESCRIPTOR = _READTRANSACTIONREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.ReadTransactionRequest)
    ))
  _sym_db.RegisterMessage(ReadTransactionRequest)
  
  ReadTransactionResponse = _reflection.GeneratedProtocolMessageType('ReadTransactionResponse', (_message.Message,), dict(
    DESCRIPTOR = _READTRANSACTIONRESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.ReadTransactionResponse)
    ))
  _sym_db.RegisterMessage(ReadTransactionResponse)
  
  BeginExecuteRequest = _reflection.GeneratedProtocolMessageType('BeginExecuteRequest', (_message.Message,), dict(
    DESCRIPTOR = _BEGINEXECUTEREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.BeginExecuteRequest)
    ))
  _sym_db.RegisterMessage(BeginExecuteRequest)
  
  BeginExecuteResponse = _reflection.GeneratedProtocolMessageType('BeginExecuteResponse', (_message.Message,), dict(
    DESCRIPTOR = _BEGINEXECUTERESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.BeginExecuteResponse)
    ))
  _sym_db.RegisterMessage(BeginExecuteResponse)
  
  BeginExecuteBatchRequest = _reflection.GeneratedProtocolMessageType('BeginExecuteBatchRequest', (_message.Message,), dict(
    DESCRIPTOR = _BEGINEXECUTEBATCHREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.BeginExecuteBatchRequest)
    ))
  _sym_db.RegisterMessage(BeginExecuteBatchRequest)
  
  BeginExecuteBatchResponse = _reflection.GeneratedProtocolMessageType('BeginExecuteBatchResponse', (_message.Message,), dict(
    DESCRIPTOR = _BEGINEXECUTEBATCHRESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.BeginExecuteBatchResponse)
    ))
  _sym_db.RegisterMessage(BeginExecuteBatchResponse)
  
  MessageStreamRequest = _reflection.GeneratedProtocolMessageType('MessageStreamRequest', (_message.Message,), dict(
    DESCRIPTOR = _MESSAGESTREAMREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.MessageStreamRequest)
    ))
  _sym_db.RegisterMessage(MessageStreamRequest)
  
  MessageStreamResponse = _reflection.GeneratedProtocolMessageType('MessageStreamResponse', (_message.Message,), dict(
    DESCRIPTOR = _MESSAGESTREAMRESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.MessageStreamResponse)
    ))
  _sym_db.RegisterMessage(MessageStreamResponse)
  
  MessageAckRequest = _reflection.GeneratedProtocolMessageType('MessageAckRequest', (_message.Message,), dict(
    DESCRIPTOR = _MESSAGEACKREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.MessageAckRequest)
    ))
  _sym_db.RegisterMessage(MessageAckRequest)
  
  MessageAckResponse = _reflection.GeneratedProtocolMessageType('MessageAckResponse', (_message.Message,), dict(
    DESCRIPTOR = _MESSAGEACKRESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.MessageAckResponse)
    ))
  _sym_db.RegisterMessage(MessageAckResponse)
  
  SplitQueryRequest = _reflection.GeneratedProtocolMessageType('SplitQueryRequest', (_message.Message,), dict(
    DESCRIPTOR = _SPLITQUERYREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.SplitQueryRequest)
    ))
  _sym_db.RegisterMessage(SplitQueryRequest)
  
  QuerySplit = _reflection.GeneratedProtocolMessageType('QuerySplit', (_message.Message,), dict(
    DESCRIPTOR = _QUERYSPLIT,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.QuerySplit)
    ))
  _sym_db.RegisterMessage(QuerySplit)
  
  SplitQueryResponse = _reflection.GeneratedProtocolMessageType('SplitQueryResponse', (_message.Message,), dict(
    DESCRIPTOR = _SPLITQUERYRESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.SplitQueryResponse)
    ))
  _sym_db.RegisterMessage(SplitQueryResponse)
  
  StreamHealthRequest = _reflection.GeneratedProtocolMessageType('StreamHealthRequest', (_message.Message,), dict(
    DESCRIPTOR = _STREAMHEALTHREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.StreamHealthRequest)
    ))
  _sym_db.RegisterMessage(StreamHealthRequest)
  
  RealtimeStats = _reflection.GeneratedProtocolMessageType('RealtimeStats', (_message.Message,), dict(
    DESCRIPTOR = _REALTIMESTATS,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.RealtimeStats)
    ))
  _sym_db.RegisterMessage(RealtimeStats)
  
  StreamHealthResponse = _reflection.GeneratedProtocolMessageType('StreamHealthResponse', (_message.Message,), dict(
    DESCRIPTOR = _STREAMHEALTHRESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.StreamHealthResponse)
    ))
  _sym_db.RegisterMessage(StreamHealthResponse)
  
  UpdateStreamRequest = _reflection.GeneratedProtocolMessageType('UpdateStreamRequest', (_message.Message,), dict(
    DESCRIPTOR = _UPDATESTREAMREQUEST,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.UpdateStreamRequest)
    ))
  _sym_db.RegisterMessage(UpdateStreamRequest)
  
  UpdateStreamResponse = _reflection.GeneratedProtocolMessageType('UpdateStreamResponse', (_message.Message,), dict(
    DESCRIPTOR = _UPDATESTREAMRESPONSE,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.UpdateStreamResponse)
    ))
  _sym_db.RegisterMessage(UpdateStreamResponse)
  
  TransactionMetadata = _reflection.GeneratedProtocolMessageType('TransactionMetadata', (_message.Message,), dict(
    DESCRIPTOR = _TRANSACTIONMETADATA,
    __module__ = 'query_pb2'
    # @@protoc_insertion_point(class_scope:query.TransactionMetadata)
    ))
  _sym_db.RegisterMessage(TransactionMetadata)
  
  
  DESCRIPTOR.has_options = True
  DESCRIPTOR._options = _descriptor._ParseOptions(descriptor_pb2.FileOptions(), _b('\n\030com.youtube.vitess.proto'))
  _MYSQLFLAG.has_options = True
  _MYSQLFLAG._options = _descriptor._ParseOptions(descriptor_pb2.EnumOptions(), _b('\020\001'))
  _BOUNDQUERY_BINDVARIABLESENTRY.has_options = True
  _BOUNDQUERY_BINDVARIABLESENTRY._options = _descriptor._ParseOptions(descriptor_pb2.MessageOptions(), _b('8\001'))
  import grpc
  from grpc.beta import implementations as beta_implementations
  from grpc.beta import interfaces as beta_interfaces
  from grpc.framework.common import cardinality
  from grpc.framework.interfaces.face import utilities as face_utilities
  # @@protoc_insertion_point(module_scope)
  