http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py index cf36654..bded16a 100644 --- a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py +++ b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py @@ -38,6 +38,30 @@ class Iface(fb303.FacebookService.Iface): """ pass + def create_catalog(self, catalog): + """ + Parameters: + - catalog + """ + pass + + def get_catalog(self, catName): + """ + Parameters: + - catName + """ + pass + + def get_catalogs(self): + pass + + def drop_catalog(self, catName): + """ + Parameters: + - catName + """ + pass + def create_database(self, database): """ Parameters: @@ -324,9 +348,10 @@ class Iface(fb303.FacebookService.Iface): """ pass - def update_creation_metadata(self, dbname, tbl_name, creation_metadata): + def update_creation_metadata(self, catName, dbname, tbl_name, creation_metadata): """ Parameters: + - catName - dbname - tbl_name - creation_metadata @@ -1597,6 +1622,139 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 return + def create_catalog(self, catalog): + """ + Parameters: + - catalog + """ + self.send_create_catalog(catalog) + self.recv_create_catalog() + + def send_create_catalog(self, catalog): + self._oprot.writeMessageBegin('create_catalog', TMessageType.CALL, self._seqid) + args = create_catalog_args() + args.catalog = catalog + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_create_catalog(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = create_catalog_result() + result.read(iprot) + iprot.readMessageEnd() + if result.o1 is not None: + raise result.o1 + if result.o2 is not None: + raise result.o2 + if result.o3 is not None: + raise result.o3 + return + + def get_catalog(self, catName): + """ + Parameters: + - catName + """ + self.send_get_catalog(catName) + return self.recv_get_catalog() + + def send_get_catalog(self, catName): + self._oprot.writeMessageBegin('get_catalog', TMessageType.CALL, self._seqid) + args = get_catalog_args() + args.catName = catName + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_get_catalog(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = get_catalog_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.o1 is not None: + raise result.o1 + if result.o2 is not None: + raise result.o2 + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_catalog failed: unknown result") + + def get_catalogs(self): + self.send_get_catalogs() + return self.recv_get_catalogs() + + def send_get_catalogs(self): + self._oprot.writeMessageBegin('get_catalogs', TMessageType.CALL, self._seqid) + args = get_catalogs_args() + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_get_catalogs(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = get_catalogs_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.o1 is not None: + raise result.o1 + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_catalogs failed: unknown result") + + def drop_catalog(self, catName): + """ + Parameters: + - catName + """ + self.send_drop_catalog(catName) + self.recv_drop_catalog() + + def send_drop_catalog(self, catName): + self._oprot.writeMessageBegin('drop_catalog', TMessageType.CALL, self._seqid) + args = drop_catalog_args() + args.catName = catName + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_drop_catalog(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = drop_catalog_result() + result.read(iprot) + iprot.readMessageEnd() + if result.o1 is not None: + raise result.o1 + if result.o2 is not None: + raise result.o2 + if result.o3 is not None: + raise result.o3 + return + def create_database(self, database): """ Parameters: @@ -2925,19 +3083,21 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o3 raise TApplicationException(TApplicationException.MISSING_RESULT, "get_materialization_invalidation_info failed: unknown result") - def update_creation_metadata(self, dbname, tbl_name, creation_metadata): + def update_creation_metadata(self, catName, dbname, tbl_name, creation_metadata): """ Parameters: + - catName - dbname - tbl_name - creation_metadata """ - self.send_update_creation_metadata(dbname, tbl_name, creation_metadata) + self.send_update_creation_metadata(catName, dbname, tbl_name, creation_metadata) self.recv_update_creation_metadata() - def send_update_creation_metadata(self, dbname, tbl_name, creation_metadata): + def send_update_creation_metadata(self, catName, dbname, tbl_name, creation_metadata): self._oprot.writeMessageBegin('update_creation_metadata', TMessageType.CALL, self._seqid) args = update_creation_metadata_args() + args.catName = catName args.dbname = dbname args.tbl_name = tbl_name args.creation_metadata = creation_metadata @@ -8557,6 +8717,10 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): fb303.FacebookService.Processor.__init__(self, handler) self._processMap["getMetaConf"] = Processor.process_getMetaConf self._processMap["setMetaConf"] = Processor.process_setMetaConf + self._processMap["create_catalog"] = Processor.process_create_catalog + self._processMap["get_catalog"] = Processor.process_get_catalog + self._processMap["get_catalogs"] = Processor.process_get_catalogs + self._processMap["drop_catalog"] = Processor.process_drop_catalog self._processMap["create_database"] = Processor.process_create_database self._processMap["get_database"] = Processor.process_get_database self._processMap["drop_database"] = Processor.process_drop_database @@ -8811,6 +8975,109 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_create_catalog(self, seqid, iprot, oprot): + args = create_catalog_args() + args.read(iprot) + iprot.readMessageEnd() + result = create_catalog_result() + try: + self._handler.create_catalog(args.catalog) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except AlreadyExistsException as o1: + msg_type = TMessageType.REPLY + result.o1 = o1 + except InvalidObjectException as o2: + msg_type = TMessageType.REPLY + result.o2 = o2 + except MetaException as o3: + msg_type = TMessageType.REPLY + result.o3 = o3 + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("create_catalog", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_get_catalog(self, seqid, iprot, oprot): + args = get_catalog_args() + args.read(iprot) + iprot.readMessageEnd() + result = get_catalog_result() + try: + result.success = self._handler.get_catalog(args.catName) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except NoSuchObjectException as o1: + msg_type = TMessageType.REPLY + result.o1 = o1 + except MetaException as o2: + msg_type = TMessageType.REPLY + result.o2 = o2 + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_catalog", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_get_catalogs(self, seqid, iprot, oprot): + args = get_catalogs_args() + args.read(iprot) + iprot.readMessageEnd() + result = get_catalogs_result() + try: + result.success = self._handler.get_catalogs() + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY + result.o1 = o1 + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_catalogs", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_drop_catalog(self, seqid, iprot, oprot): + args = drop_catalog_args() + args.read(iprot) + iprot.readMessageEnd() + result = drop_catalog_result() + try: + self._handler.drop_catalog(args.catName) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except NoSuchObjectException as o1: + msg_type = TMessageType.REPLY + result.o1 = o1 + except InvalidOperationException as o2: + msg_type = TMessageType.REPLY + result.o2 = o2 + except MetaException as o3: + msg_type = TMessageType.REPLY + result.o3 = o3 + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("drop_catalog", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_create_database(self, seqid, iprot, oprot): args = create_database_args() args.read(iprot) @@ -9754,7 +10021,7 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): iprot.readMessageEnd() result = update_creation_metadata_result() try: - self._handler.update_creation_metadata(args.dbname, args.tbl_name, args.creation_metadata) + self._handler.update_creation_metadata(args.catName, args.dbname, args.tbl_name, args.creation_metadata) msg_type = TMessageType.REPLY except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): raise @@ -13912,19 +14179,19 @@ class setMetaConf_result: def __ne__(self, other): return not (self == other) -class create_database_args: +class create_catalog_args: """ Attributes: - - database + - catalog """ thrift_spec = ( None, # 0 - (1, TType.STRUCT, 'database', (Database, Database.thrift_spec), None, ), # 1 + (1, TType.STRUCT, 'catalog', (CreateCatalogRequest, CreateCatalogRequest.thrift_spec), None, ), # 1 ) - def __init__(self, database=None,): - self.database = database + def __init__(self, catalog=None,): + self.catalog = catalog def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -13937,8 +14204,8 @@ class create_database_args: break if fid == 1: if ftype == TType.STRUCT: - self.database = Database() - self.database.read(iprot) + self.catalog = CreateCatalogRequest() + self.catalog.read(iprot) else: iprot.skip(ftype) else: @@ -13950,10 +14217,10 @@ class create_database_args: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('create_database_args') - if self.database is not None: - oprot.writeFieldBegin('database', TType.STRUCT, 1) - self.database.write(oprot) + oprot.writeStructBegin('create_catalog_args') + if self.catalog is not None: + oprot.writeFieldBegin('catalog', TType.STRUCT, 1) + self.catalog.write(oprot) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -13964,7 +14231,7 @@ class create_database_args: def __hash__(self): value = 17 - value = (value * 31) ^ hash(self.database) + value = (value * 31) ^ hash(self.catalog) return value def __repr__(self): @@ -13978,7 +14245,7 @@ class create_database_args: def __ne__(self, other): return not (self == other) -class create_database_result: +class create_catalog_result: """ Attributes: - o1 @@ -14034,7 +14301,451 @@ class create_database_result: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('create_database_result') + oprot.writeStructBegin('create_catalog_result') + if self.o1 is not None: + oprot.writeFieldBegin('o1', TType.STRUCT, 1) + self.o1.write(oprot) + oprot.writeFieldEnd() + if self.o2 is not None: + oprot.writeFieldBegin('o2', TType.STRUCT, 2) + self.o2.write(oprot) + oprot.writeFieldEnd() + if self.o3 is not None: + oprot.writeFieldBegin('o3', TType.STRUCT, 3) + self.o3.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.o1) + value = (value * 31) ^ hash(self.o2) + value = (value * 31) ^ hash(self.o3) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class get_catalog_args: + """ + Attributes: + - catName + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'catName', (GetCatalogRequest, GetCatalogRequest.thrift_spec), None, ), # 1 + ) + + def __init__(self, catName=None,): + self.catName = catName + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRUCT: + self.catName = GetCatalogRequest() + self.catName.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('get_catalog_args') + if self.catName is not None: + oprot.writeFieldBegin('catName', TType.STRUCT, 1) + self.catName.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.catName) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class get_catalog_result: + """ + Attributes: + - success + - o1 + - o2 + """ + + thrift_spec = ( + (0, TType.STRUCT, 'success', (GetCatalogResponse, GetCatalogResponse.thrift_spec), None, ), # 0 + (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 2 + ) + + def __init__(self, success=None, o1=None, o2=None,): + self.success = success + self.o1 = o1 + self.o2 = o2 + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 0: + if ftype == TType.STRUCT: + self.success = GetCatalogResponse() + self.success.read(iprot) + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.o1 = NoSuchObjectException() + self.o1.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.o2 = MetaException() + self.o2.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('get_catalog_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.STRUCT, 0) + self.success.write(oprot) + oprot.writeFieldEnd() + if self.o1 is not None: + oprot.writeFieldBegin('o1', TType.STRUCT, 1) + self.o1.write(oprot) + oprot.writeFieldEnd() + if self.o2 is not None: + oprot.writeFieldBegin('o2', TType.STRUCT, 2) + self.o2.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + value = (value * 31) ^ hash(self.o1) + value = (value * 31) ^ hash(self.o2) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class get_catalogs_args: + + thrift_spec = ( + ) + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('get_catalogs_args') + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class get_catalogs_result: + """ + Attributes: + - success + - o1 + """ + + thrift_spec = ( + (0, TType.STRUCT, 'success', (GetCatalogsResponse, GetCatalogsResponse.thrift_spec), None, ), # 0 + (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1 + ) + + def __init__(self, success=None, o1=None,): + self.success = success + self.o1 = o1 + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 0: + if ftype == TType.STRUCT: + self.success = GetCatalogsResponse() + self.success.read(iprot) + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.o1 = MetaException() + self.o1.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('get_catalogs_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.STRUCT, 0) + self.success.write(oprot) + oprot.writeFieldEnd() + if self.o1 is not None: + oprot.writeFieldBegin('o1', TType.STRUCT, 1) + self.o1.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + value = (value * 31) ^ hash(self.o1) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class drop_catalog_args: + """ + Attributes: + - catName + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'catName', (DropCatalogRequest, DropCatalogRequest.thrift_spec), None, ), # 1 + ) + + def __init__(self, catName=None,): + self.catName = catName + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRUCT: + self.catName = DropCatalogRequest() + self.catName.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('drop_catalog_args') + if self.catName is not None: + oprot.writeFieldBegin('catName', TType.STRUCT, 1) + self.catName.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.catName) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class drop_catalog_result: + """ + Attributes: + - o1 + - o2 + - o3 + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'o2', (InvalidOperationException, InvalidOperationException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'o3', (MetaException, MetaException.thrift_spec), None, ), # 3 + ) + + def __init__(self, o1=None, o2=None, o3=None,): + self.o1 = o1 + self.o2 = o2 + self.o3 = o3 + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRUCT: + self.o1 = NoSuchObjectException() + self.o1.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.o2 = InvalidOperationException() + self.o2.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.o3 = MetaException() + self.o3.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('drop_catalog_result') if self.o1 is not None: oprot.writeFieldBegin('o1', TType.STRUCT, 1) self.o1.write(oprot) @@ -14072,19 +14783,19 @@ class create_database_result: def __ne__(self, other): return not (self == other) -class get_database_args: +class create_database_args: """ Attributes: - - name + - database """ thrift_spec = ( None, # 0 - (1, TType.STRING, 'name', None, None, ), # 1 + (1, TType.STRUCT, 'database', (Database, Database.thrift_spec), None, ), # 1 ) - def __init__(self, name=None,): - self.name = name + def __init__(self, database=None,): + self.database = database def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -14096,8 +14807,9 @@ class get_database_args: if ftype == TType.STOP: break if fid == 1: - if ftype == TType.STRING: - self.name = iprot.readString() + if ftype == TType.STRUCT: + self.database = Database() + self.database.read(iprot) else: iprot.skip(ftype) else: @@ -14109,10 +14821,10 @@ class get_database_args: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('get_database_args') - if self.name is not None: - oprot.writeFieldBegin('name', TType.STRING, 1) - oprot.writeString(self.name) + oprot.writeStructBegin('create_database_args') + if self.database is not None: + oprot.writeFieldBegin('database', TType.STRUCT, 1) + self.database.write(oprot) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -14123,7 +14835,7 @@ class get_database_args: def __hash__(self): value = 17 - value = (value * 31) ^ hash(self.name) + value = (value * 31) ^ hash(self.database) return value def __repr__(self): @@ -14137,24 +14849,25 @@ class get_database_args: def __ne__(self, other): return not (self == other) -class get_database_result: +class create_database_result: """ Attributes: - - success - o1 - o2 + - o3 """ thrift_spec = ( - (0, TType.STRUCT, 'success', (Database, Database.thrift_spec), None, ), # 0 - (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1 - (2, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 2 + None, # 0 + (1, TType.STRUCT, 'o1', (AlreadyExistsException, AlreadyExistsException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'o2', (InvalidObjectException, InvalidObjectException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'o3', (MetaException, MetaException.thrift_spec), None, ), # 3 ) - def __init__(self, success=None, o1=None, o2=None,): - self.success = success + def __init__(self, o1=None, o2=None, o3=None,): self.o1 = o1 self.o2 = o2 + self.o3 = o3 def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -14165,24 +14878,24 @@ class get_database_result: (fname, ftype, fid) = iprot.readFieldBegin() if ftype == TType.STOP: break - if fid == 0: - if ftype == TType.STRUCT: - self.success = Database() - self.success.read(iprot) - else: - iprot.skip(ftype) - elif fid == 1: + if fid == 1: if ftype == TType.STRUCT: - self.o1 = NoSuchObjectException() + self.o1 = AlreadyExistsException() self.o1.read(iprot) else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRUCT: - self.o2 = MetaException() + self.o2 = InvalidObjectException() self.o2.read(iprot) else: iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.o3 = MetaException() + self.o3.read(iprot) + else: + iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() @@ -14192,11 +14905,7 @@ class get_database_result: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('get_database_result') - if self.success is not None: - oprot.writeFieldBegin('success', TType.STRUCT, 0) - self.success.write(oprot) - oprot.writeFieldEnd() + oprot.writeStructBegin('create_database_result') if self.o1 is not None: oprot.writeFieldBegin('o1', TType.STRUCT, 1) self.o1.write(oprot) @@ -14205,6 +14914,10 @@ class get_database_result: oprot.writeFieldBegin('o2', TType.STRUCT, 2) self.o2.write(oprot) oprot.writeFieldEnd() + if self.o3 is not None: + oprot.writeFieldBegin('o3', TType.STRUCT, 3) + self.o3.write(oprot) + oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -14214,9 +14927,9 @@ class get_database_result: def __hash__(self): value = 17 - value = (value * 31) ^ hash(self.success) value = (value * 31) ^ hash(self.o1) value = (value * 31) ^ hash(self.o2) + value = (value * 31) ^ hash(self.o3) return value def __repr__(self): @@ -14230,25 +14943,19 @@ class get_database_result: def __ne__(self, other): return not (self == other) -class drop_database_args: +class get_database_args: """ Attributes: - name - - deleteData - - cascade """ thrift_spec = ( None, # 0 (1, TType.STRING, 'name', None, None, ), # 1 - (2, TType.BOOL, 'deleteData', None, None, ), # 2 - (3, TType.BOOL, 'cascade', None, None, ), # 3 ) - def __init__(self, name=None, deleteData=None, cascade=None,): + def __init__(self, name=None,): self.name = name - self.deleteData = deleteData - self.cascade = cascade def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -14264,16 +14971,6 @@ class drop_database_args: self.name = iprot.readString() else: iprot.skip(ftype) - elif fid == 2: - if ftype == TType.BOOL: - self.deleteData = iprot.readBool() - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.BOOL: - self.cascade = iprot.readBool() - else: - iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() @@ -14283,19 +14980,11 @@ class drop_database_args: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('drop_database_args') + oprot.writeStructBegin('get_database_args') if self.name is not None: oprot.writeFieldBegin('name', TType.STRING, 1) oprot.writeString(self.name) oprot.writeFieldEnd() - if self.deleteData is not None: - oprot.writeFieldBegin('deleteData', TType.BOOL, 2) - oprot.writeBool(self.deleteData) - oprot.writeFieldEnd() - if self.cascade is not None: - oprot.writeFieldBegin('cascade', TType.BOOL, 3) - oprot.writeBool(self.cascade) - oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -14306,8 +14995,6 @@ class drop_database_args: def __hash__(self): value = 17 value = (value * 31) ^ hash(self.name) - value = (value * 31) ^ hash(self.deleteData) - value = (value * 31) ^ hash(self.cascade) return value def __repr__(self): @@ -14321,25 +15008,24 @@ class drop_database_args: def __ne__(self, other): return not (self == other) -class drop_database_result: +class get_database_result: """ Attributes: + - success - o1 - o2 - - o3 """ thrift_spec = ( - None, # 0 + (0, TType.STRUCT, 'success', (Database, Database.thrift_spec), None, ), # 0 (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1 - (2, TType.STRUCT, 'o2', (InvalidOperationException, InvalidOperationException.thrift_spec), None, ), # 2 - (3, TType.STRUCT, 'o3', (MetaException, MetaException.thrift_spec), None, ), # 3 + (2, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 2 ) - def __init__(self, o1=None, o2=None, o3=None,): + def __init__(self, success=None, o1=None, o2=None,): + self.success = success self.o1 = o1 self.o2 = o2 - self.o3 = o3 def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -14350,7 +15036,13 @@ class drop_database_result: (fname, ftype, fid) = iprot.readFieldBegin() if ftype == TType.STOP: break - if fid == 1: + if fid == 0: + if ftype == TType.STRUCT: + self.success = Database() + self.success.read(iprot) + else: + iprot.skip(ftype) + elif fid == 1: if ftype == TType.STRUCT: self.o1 = NoSuchObjectException() self.o1.read(iprot) @@ -14358,16 +15050,10 @@ class drop_database_result: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRUCT: - self.o2 = InvalidOperationException() + self.o2 = MetaException() self.o2.read(iprot) else: iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRUCT: - self.o3 = MetaException() - self.o3.read(iprot) - else: - iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() @@ -14377,7 +15063,11 @@ class drop_database_result: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('drop_database_result') + oprot.writeStructBegin('get_database_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.STRUCT, 0) + self.success.write(oprot) + oprot.writeFieldEnd() if self.o1 is not None: oprot.writeFieldBegin('o1', TType.STRUCT, 1) self.o1.write(oprot) @@ -14386,10 +15076,6 @@ class drop_database_result: oprot.writeFieldBegin('o2', TType.STRUCT, 2) self.o2.write(oprot) oprot.writeFieldEnd() - if self.o3 is not None: - oprot.writeFieldBegin('o3', TType.STRUCT, 3) - self.o3.write(oprot) - oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -14399,9 +15085,9 @@ class drop_database_result: def __hash__(self): value = 17 + value = (value * 31) ^ hash(self.success) value = (value * 31) ^ hash(self.o1) value = (value * 31) ^ hash(self.o2) - value = (value * 31) ^ hash(self.o3) return value def __repr__(self): @@ -14415,19 +15101,25 @@ class drop_database_result: def __ne__(self, other): return not (self == other) -class get_databases_args: +class drop_database_args: """ Attributes: - - pattern + - name + - deleteData + - cascade """ thrift_spec = ( None, # 0 - (1, TType.STRING, 'pattern', None, None, ), # 1 + (1, TType.STRING, 'name', None, None, ), # 1 + (2, TType.BOOL, 'deleteData', None, None, ), # 2 + (3, TType.BOOL, 'cascade', None, None, ), # 3 ) - def __init__(self, pattern=None,): - self.pattern = pattern + def __init__(self, name=None, deleteData=None, cascade=None,): + self.name = name + self.deleteData = deleteData + self.cascade = cascade def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -14440,7 +15132,17 @@ class get_databases_args: break if fid == 1: if ftype == TType.STRING: - self.pattern = iprot.readString() + self.name = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.BOOL: + self.deleteData = iprot.readBool() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.BOOL: + self.cascade = iprot.readBool() else: iprot.skip(ftype) else: @@ -14452,10 +15154,18 @@ class get_databases_args: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('get_databases_args') - if self.pattern is not None: - oprot.writeFieldBegin('pattern', TType.STRING, 1) - oprot.writeString(self.pattern) + oprot.writeStructBegin('drop_database_args') + if self.name is not None: + oprot.writeFieldBegin('name', TType.STRING, 1) + oprot.writeString(self.name) + oprot.writeFieldEnd() + if self.deleteData is not None: + oprot.writeFieldBegin('deleteData', TType.BOOL, 2) + oprot.writeBool(self.deleteData) + oprot.writeFieldEnd() + if self.cascade is not None: + oprot.writeFieldBegin('cascade', TType.BOOL, 3) + oprot.writeBool(self.cascade) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -14466,7 +15176,9 @@ class get_databases_args: def __hash__(self): value = 17 - value = (value * 31) ^ hash(self.pattern) + value = (value * 31) ^ hash(self.name) + value = (value * 31) ^ hash(self.deleteData) + value = (value * 31) ^ hash(self.cascade) return value def __repr__(self): @@ -14480,21 +15192,25 @@ class get_databases_args: def __ne__(self, other): return not (self == other) -class get_databases_result: +class drop_database_result: """ Attributes: - - success - o1 + - o2 + - o3 """ thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0 - (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1 + None, # 0 + (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'o2', (InvalidOperationException, InvalidOperationException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'o3', (MetaException, MetaException.thrift_spec), None, ), # 3 ) - def __init__(self, success=None, o1=None,): - self.success = success + def __init__(self, o1=None, o2=None, o3=None,): self.o1 = o1 + self.o2 = o2 + self.o3 = o3 def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -14505,20 +15221,22 @@ class get_databases_result: (fname, ftype, fid) = iprot.readFieldBegin() if ftype == TType.STOP: break - if fid == 0: - if ftype == TType.LIST: - self.success = [] - (_etype791, _size788) = iprot.readListBegin() - for _i792 in xrange(_size788): - _elem793 = iprot.readString() - self.success.append(_elem793) - iprot.readListEnd() + if fid == 1: + if ftype == TType.STRUCT: + self.o1 = NoSuchObjectException() + self.o1.read(iprot) else: iprot.skip(ftype) - elif fid == 1: + elif fid == 2: if ftype == TType.STRUCT: - self.o1 = MetaException() - self.o1.read(iprot) + self.o2 = InvalidOperationException() + self.o2.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.o3 = MetaException() + self.o3.read(iprot) else: iprot.skip(ftype) else: @@ -14530,18 +15248,19 @@ class get_databases_result: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('get_databases_result') - if self.success is not None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRING, len(self.success)) - for iter794 in self.success: - oprot.writeString(iter794) - oprot.writeListEnd() - oprot.writeFieldEnd() + oprot.writeStructBegin('drop_database_result') if self.o1 is not None: oprot.writeFieldBegin('o1', TType.STRUCT, 1) self.o1.write(oprot) oprot.writeFieldEnd() + if self.o2 is not None: + oprot.writeFieldBegin('o2', TType.STRUCT, 2) + self.o2.write(oprot) + oprot.writeFieldEnd() + if self.o3 is not None: + oprot.writeFieldBegin('o3', TType.STRUCT, 3) + self.o3.write(oprot) + oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -14551,8 +15270,9 @@ class get_databases_result: def __hash__(self): value = 17 - value = (value * 31) ^ hash(self.success) value = (value * 31) ^ hash(self.o1) + value = (value * 31) ^ hash(self.o2) + value = (value * 31) ^ hash(self.o3) return value def __repr__(self): @@ -14566,11 +15286,20 @@ class get_databases_result: def __ne__(self, other): return not (self == other) -class get_all_databases_args: +class get_databases_args: + """ + Attributes: + - pattern + """ thrift_spec = ( + None, # 0 + (1, TType.STRING, 'pattern', None, None, ), # 1 ) + def __init__(self, pattern=None,): + self.pattern = pattern + def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) @@ -14580,6 +15309,11 @@ class get_all_databases_args: (fname, ftype, fid) = iprot.readFieldBegin() if ftype == TType.STOP: break + if fid == 1: + if ftype == TType.STRING: + self.pattern = iprot.readString() + else: + iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() @@ -14589,7 +15323,11 @@ class get_all_databases_args: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('get_all_databases_args') + oprot.writeStructBegin('get_databases_args') + if self.pattern is not None: + oprot.writeFieldBegin('pattern', TType.STRING, 1) + oprot.writeString(self.pattern) + oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -14599,6 +15337,7 @@ class get_all_databases_args: def __hash__(self): value = 17 + value = (value * 31) ^ hash(self.pattern) return value def __repr__(self): @@ -14612,7 +15351,7 @@ class get_all_databases_args: def __ne__(self, other): return not (self == other) -class get_all_databases_result: +class get_databases_result: """ Attributes: - success @@ -14662,7 +15401,7 @@ class get_all_databases_result: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('get_all_databases_result') + oprot.writeStructBegin('get_databases_result') if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) @@ -14698,6 +15437,138 @@ class get_all_databases_result: def __ne__(self, other): return not (self == other) +class get_all_databases_args: + + thrift_spec = ( + ) + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('get_all_databases_args') + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class get_all_databases_result: + """ + Attributes: + - success + - o1 + """ + + thrift_spec = ( + (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0 + (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1 + ) + + def __init__(self, success=None, o1=None,): + self.success = success + self.o1 = o1 + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 0: + if ftype == TType.LIST: + self.success = [] + (_etype805, _size802) = iprot.readListBegin() + for _i806 in xrange(_size802): + _elem807 = iprot.readString() + self.success.append(_elem807) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.o1 = MetaException() + self.o1.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('get_all_databases_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.LIST, 0) + oprot.writeListBegin(TType.STRING, len(self.success)) + for iter808 in self.success: + oprot.writeString(iter808) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.o1 is not None: + oprot.writeFieldBegin('o1', TType.STRUCT, 1) + self.o1.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + value = (value * 31) ^ hash(self.o1) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + class alter_database_args: """ Attributes: @@ -15437,12 +16308,12 @@ class get_type_all_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype803, _vtype804, _size802 ) = iprot.readMapBegin() - for _i806 in xrange(_size802): - _key807 = iprot.readString() - _val808 = Type() - _val808.read(iprot) - self.success[_key807] = _val808 + (_ktype810, _vtype811, _size809 ) = iprot.readMapBegin() + for _i813 in xrange(_size809): + _key814 = iprot.readString() + _val815 = Type() + _val815.read(iprot) + self.success[_key814] = _val815 iprot.readMapEnd() else: iprot.skip(ftype) @@ -15465,9 +16336,9 @@ class get_type_all_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success)) - for kiter809,viter810 in self.success.items(): - oprot.writeString(kiter809) - viter810.write(oprot) + for kiter816,viter817 in self.success.items(): + oprot.writeString(kiter816) + viter817.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -15610,11 +16481,11 @@ class get_fields_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype814, _size811) = iprot.readListBegin() - for _i815 in xrange(_size811): - _elem816 = FieldSchema() - _elem816.read(iprot) - self.success.append(_elem816) + (_etype821, _size818) = iprot.readListBegin() + for _i822 in xrange(_size818): + _elem823 = FieldSchema() + _elem823.read(iprot) + self.success.append(_elem823) iprot.readListEnd() else: iprot.skip(ftype) @@ -15649,8 +16520,8 @@ class get_fields_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter817 in self.success: - iter817.write(oprot) + for iter824 in self.success: + iter824.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15817,11 +16688,11 @@ class get_fields_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype821, _size818) = iprot.readListBegin() - for _i822 in xrange(_size818): - _elem823 = FieldSchema() - _elem823.read(iprot) - self.success.append(_elem823) + (_etype828, _size825) = iprot.readListBegin() + for _i829 in xrange(_size825): + _elem830 = FieldSchema() + _elem830.read(iprot) + self.success.append(_elem830) iprot.readListEnd() else: iprot.skip(ftype) @@ -15856,8 +16727,8 @@ class get_fields_with_environment_context_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter824 in self.success: - iter824.write(oprot) + for iter831 in self.success: + iter831.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16010,11 +16881,11 @@ class get_schema_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype828, _size825) = iprot.readListBegin() - for _i829 in xrange(_size825): - _elem830 = FieldSchema() - _elem830.read(iprot) - self.success.append(_elem830) + (_etype835, _size832) = iprot.readListBegin() + for _i836 in xrange(_size832): + _elem837 = FieldSchema() + _elem837.read(iprot) + self.success.append(_elem837) iprot.readListEnd() else: iprot.skip(ftype) @@ -16049,8 +16920,8 @@ class get_schema_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter831 in self.success: - iter831.write(oprot) + for iter838 in self.success: + iter838.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16217,11 +17088,11 @@ class get_schema_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype835, _size832) = iprot.readListBegin() - for _i836 in xrange(_size832): - _elem837 = FieldSchema() - _elem837.read(iprot) - self.success.append(_elem837) + (_etype842, _size839) = iprot.readListBegin() + for _i843 in xrange(_size839): + _elem844 = FieldSchema() + _elem844.read(iprot) + self.success.append(_elem844) iprot.readListEnd() else: iprot.skip(ftype) @@ -16256,8 +17127,8 @@ class get_schema_with_environment_context_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter838 in self.success: - iter838.write(oprot) + for iter845 in self.success: + iter845.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16710,66 +17581,66 @@ class create_table_with_constraints_args: elif fid == 2: if ftype == TType.LIST: self.primaryKeys = [] - (_etype842, _size839) = iprot.readListBegin() - for _i843 in xrange(_size839): - _elem844 = SQLPrimaryKey() - _elem844.read(iprot) - self.primaryKeys.append(_elem844) + (_etype849, _size846) = iprot.readListBegin() + for _i850 in xrange(_size846): + _elem851 = SQLPrimaryKey() + _elem851.read(iprot) + self.primaryKeys.append(_elem851) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.LIST: self.foreignKeys = [] - (_etype848, _size845) = iprot.readListBegin() - for _i849 in xrange(_size845): - _elem850 = SQLForeignKey() - _elem850.read(iprot) - self.foreignKeys.append(_elem850) + (_etype855, _size852) = iprot.readListBegin() + for _i856 in xrange(_size852): + _elem857 = SQLForeignKey() + _elem857.read(iprot) + self.foreignKeys.append(_elem857) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.LIST: self.uniqueConstraints = [] - (_etype854, _size851) = iprot.readListBegin() - for _i855 in xrange(_size851): - _elem856 = SQLUniqueConstraint() - _elem856.read(iprot) - self.uniqueConstraints.append(_elem856) + (_etype861, _size858) = iprot.readListBegin() + for _i862 in xrange(_size858): + _elem863 = SQLUniqueConstraint() + _elem863.read(iprot) + self.uniqueConstraints.append(_elem863) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.LIST: self.notNullConstraints = [] - (_etype860, _size857) = iprot.readListBegin() - for _i861 in xrange(_size857): - _elem862 = SQLNotNullConstraint() - _elem862.read(iprot) - self.notNullConstraints.append(_elem862) + (_etype867, _size864) = iprot.readListBegin() + for _i868 in xrange(_size864): + _elem869 = SQLNotNullConstraint() + _elem869.read(iprot) + self.notNullConstraints.append(_elem869) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 6: if ftype == TType.LIST: self.defaultConstraints = [] - (_etype866, _size863) = iprot.readListBegin() - for _i867 in xrange(_size863): - _elem868 = SQLDefaultConstraint() - _elem868.read(iprot) - self.defaultConstraints.append(_elem868) + (_etype873, _size870) = iprot.readListBegin() + for _i874 in xrange(_size870): + _elem875 = SQLDefaultConstraint() + _elem875.read(iprot) + self.defaultConstraints.append(_elem875) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 7: if ftype == TType.LIST: self.checkConstraints = [] - (_etype872, _size869) = iprot.readListBegin() - for _i873 in xrange(_size869): - _elem874 = SQLCheckConstraint() - _elem874.read(iprot) - self.checkConstraints.append(_elem874) + (_etype879, _size876) = iprot.readListBegin() + for _i880 in xrange(_size876): + _elem881 = SQLCheckConstraint() + _elem881.read(iprot) + self.checkConstraints.append(_elem881) iprot.readListEnd() else: iprot.skip(ftype) @@ -16790,43 +17661,43 @@ class create_table_with_constraints_args: if self.primaryKeys is not None: oprot.writeFieldBegin('primaryKeys', TType.LIST, 2) oprot.writeListBegin(TType.STRUCT, len(self.primaryKeys)) - for iter875 in self.primaryKeys: - iter875.write(oprot) + for iter882 in self.primaryKeys: + iter882.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.foreignKeys is not None: oprot.writeFieldBegin('foreignKeys', TType.LIST, 3) oprot.writeListBegin(TType.STRUCT, len(self.foreignKeys)) - for iter876 in self.foreignKeys: - iter876.write(oprot) + for iter883 in self.foreignKeys: + iter883.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.uniqueConstraints is not None: oprot.writeFieldBegin('uniqueConstraints', TType.LIST, 4) oprot.writeListBegin(TType.STRUCT, len(self.uniqueConstraints)) - for iter877 in self.uniqueConstraints: - iter877.write(oprot) + for iter884 in self.uniqueConstraints: + iter884.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.notNullConstraints is not None: oprot.writeFieldBegin('notNullConstraints', TType.LIST, 5) oprot.writeListBegin(TType.STRUCT, len(self.notNullConstraints)) - for iter878 in self.notNullConstraints: - iter878.write(oprot) + for iter885 in self.notNullConstraints: + iter885.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.defaultConstraints is not None: oprot.writeFieldBegin('defaultConstraints', TType.LIST, 6) oprot.writeListBegin(TType.STRUCT, len(self.defaultConstraints)) - for iter879 in self.defaultConstraints: - iter879.write(oprot) + for iter886 in self.defaultConstraints: + iter886.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.checkConstraints is not None: oprot.writeFieldBegin('checkConstraints', TType.LIST, 7) oprot.writeListBegin(TType.STRUCT, len(self.checkConstraints)) - for iter880 in self.checkConstraints: - iter880.write(oprot) + for iter887 in self.checkConstraints: + iter887.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -18386,10 +19257,10 @@ class truncate_table_args: elif fid == 3: if ftype == TType.LIST: self.partNames = [] - (_etype884, _size881) = iprot.readListBegin() - for _i885 in xrange(_size881): - _elem886 = iprot.readString() - self.partNames.append(_elem886) + (_etype891, _size888) = iprot.readListBegin() + for _i892 in xrange(_size888): + _elem893 = iprot.readString() + self.partNames.append(_elem893) iprot.readListEnd() else: iprot.skip(ftype) @@ -18414,8 +19285,8 @@ class truncate_table_args: if self.partNames is not None: oprot.writeFieldBegin('partNames', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.partNames)) - for iter887 in self.partNames: - oprot.writeString(iter887) + for iter894 in self.partNames: + oprot.writeString(iter894) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -18615,10 +19486,10 @@ class get_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype891, _size888) = iprot.readListBegin() - for _i892 in xrange(_size888): - _elem893 = iprot.readString() - self.success.append(_elem893) + (_etype898, _size895) = iprot.readListBegin() + for _i899 in xrange(_size895): + _elem900 = iprot.readString() + self.success.append(_elem900) iprot.readListEnd() else: iprot.skip(ftype) @@ -18641,8 +19512,8 @@ class get_tables_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter894 in self.success: - oprot.writeString(iter894) + for iter901 in self.success: + oprot.writeString(iter901) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18792,10 +19663,10 @@ class get_tables_by_type_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype898, _size895) = iprot.readListBegin() - for _i899 in xrange(_size895): - _elem900 = iprot.readString() - self.success.append(_elem900) + (_etype905, _size902) = iprot.readListBegin() + for _i906 in xrange(_size902): + _elem907 = iprot.readString() + self.success.append(_elem907) iprot.readListEnd() else: iprot.skip(ftype) @@ -18818,8 +19689,8 @@ class get_tables_by_type_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter901 in self.success: - oprot.writeString(iter901) + for iter908 in self.success: + oprot.writeString(iter908) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18943,10 +19814,10 @@ class get_materialized_views_for_rewriting_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype905, _size902) = iprot.readListBegin() - for _i906 in xrange(_size902): - _elem907 = iprot.readString() - self.success.append(_elem907) + (_etype912, _size909) = iprot.readListBegin() + for _i913 in xrange(_size909): + _elem914 = iprot.readString() + self.success.append(_elem914) iprot.readListEnd() else: iprot.skip(ftype) @@ -18969,8 +19840,8 @@ class get_materialized_views_for_rewriting_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter908 in self.success: - oprot.writeString(iter908) + for iter915 in self.success: + oprot.writeString(iter915) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -19043,10 +19914,10 @@ class get_table_meta_args: elif fid == 3: if ftype == TType.LIST: self.tbl_types = [] - (_etype912, _size909) = iprot.readListBegin() - for _i913 in xrange(_size909): - _elem914 = iprot.readString() - self.tbl_types.append(_elem914) + (_etype919, _size916) = iprot.readListBegin() + for _i920 in xrange(_size916): + _elem921 = iprot.readString() + self.tbl_types.append(_elem921) iprot.readListEnd() else: iprot.skip(ftype) @@ -19071,8 +19942,8 @@ class get_table_meta_args: if self.tbl_types is not None: oprot.writeFieldBegin('tbl_types', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.tbl_types)) - for iter915 in self.tbl_types: - oprot.writeString(iter915) + for iter922 in self.tbl_types: + oprot.writeString(iter922) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -19128,11 +19999,11 @@ class get_table_meta_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype919, _size916) = iprot.readListBegin() - for _i920 in xrange(_size916): - _elem921 = TableMeta() - _elem921.read(iprot) - self.success.append(_elem921) + (_etype926, _size923) = iprot.readListBegin() + for _i927 in xrange(_size923): + _elem928 = TableMeta() + _elem928.read(iprot) + self.success.append(_elem928) iprot.readListEnd() else: iprot.skip(ftype) @@ -19155,8 +20026,8 @@ class get_table_meta_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter922 in self.success: - iter922.write(oprot) + for iter929 in self.success: + iter929.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -19280,10 +20151,10 @@ class get_all_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype926, _size923) = iprot.readListBegin() - for _i927 in xrange(_size923): - _elem928 = iprot.readString() - self.success.append(_elem928) + (_etype933, _size930) = iprot.readListBegin() + for _i934 in xrange(_size930): + _elem935 = iprot.readString() + self.success.append(_elem935) iprot.readListEnd() else: iprot.skip(ftype) @@ -19306,8 +20177,8 @@ class get_all_tables_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter929 in self.success: - oprot.writeString(iter929) + for iter936 in self.success: + oprot.writeString(iter936) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -19543,10 +20414,10 @@ class get_table_objects_by_name_args: elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] - (_etype933, _size930) = iprot.readListBegin() - for _i934 in xrange(_size930): - _elem935 = iprot.readString() - self.tbl_names.append(_elem935) + (_etype940, _size937) = iprot.readListBegin() + for _i941 in xrange(_size937): + _elem942 = iprot.readString() + self.tbl_names.append(_elem942) iprot.readListEnd() else: iprot.skip(ftype) @@ -19567,8 +20438,8 @@ class get_table_objects_by_name_args: if self.tbl_names is not None: oprot.writeFieldBegin('tbl_names', TType.LIST, 2) oprot.writeListBegin(TType.STRING, len(self.tbl_names)) - for iter936 in self.tbl_names: - oprot.writeString(iter936) + for iter943 in self.tbl_names: + oprot.writeString(iter943) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -19620,11 +20491,11 @@ class get_table_objects_by_name_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype940, _size937) = iprot.readListBegin() - for _i941 in xrange(_size937): - _elem942 = Table() - _elem942.read(iprot) - self.success.append(_elem942) + (_etype947, _size944) = iprot.readListBegin() + for _i948 in xrange(_size944): + _elem949 = Table() + _elem949.read(iprot) + self.success.append(_elem949) iprot.readListEnd() else: iprot.skip(ftype) @@ -19641,8 +20512,8 @@ class get_table_objects_by_name_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter943 in self.success: - iter943.write(oprot) + for iter950 in self.success: + iter950.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -20034,10 +20905,10 @@ class get_materialization_invalidation_info_args: elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] - (_etype947, _size944) = iprot.readListBegin() - for _i948 in xrange(_size944): - _elem949 = iprot.readString() - self.tbl_names.append(_elem949) + (_etype954, _size951) = iprot.readListBegin() + for _i955 in xrange(_size951): + _elem956 = iprot.readString() + self.tbl_names.append(_elem956) iprot.readListEnd() else: iprot.skip(ftype) @@ -20058,8 +20929,8 @@ class get_materialization_invalidation_info_args: if self.tbl_names is not None: oprot.writeFieldBegin('tbl_names', TType.LIST, 2) oprot.writeListBegin(TType.STRING, len(self.tbl_names)) - for iter950 in self.tbl_names: - oprot.writeString(iter950) + for iter957 in self.tbl_names: + oprot.writeString(iter957) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -20120,12 +20991,12 @@ class get_materialization_invalidation_info_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype952, _vtype953, _size951 ) = iprot.readMapBegin() - for _i955 in xrange(_size951): - _key956 = iprot.readString() - _val957 = Materialization() - _val957.read(iprot) - self.success[_key956] = _val957 + (_ktype959, _vtype960, _size958 ) = iprot.readMapBegin() + for _i962 in xrange(_size958): + _key963 = iprot.readString() + _val964 = Materialization() + _val964.read(iprot) + self.success[_key963] = _val964 iprot.readMapEnd() else: iprot.skip(ftype) @@ -20160,9 +21031,9 @@ class get_materialization_invalidation_info_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success)) - for kiter958,viter959 in self.success.items(): - oprot.writeString(kiter958) - viter959.write(oprot) + for kiter965,viter966 in self.success.items(): + oprot.writeString(kiter965) + viter966.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -20206,6 +21077,7 @@ class get_materialization_invalidation_info_result: class update_creation_metadata_args: """ Attributes: + - catName - dbname - tbl_name - creation_metadata @@ -20213,12 +21085,14 @@ class update_creation_metadata_args: thrift_spec = ( None, # 0 - (1, TType.STRING, 'dbname', None, None, ), # 1 - (2, TType.STRING, 'tbl_name', None, None, ), # 2 - (3, TType.STRUCT, 'creation_metadata', (CreationMetadata, CreationMetadata.thrift_spec), None, ), # 3 + (1, TType.STRING, 'catName', None, None, ), # 1 + (2, TType.STRING, 'dbname', None, None, ), # 2 + (3, TType.STRING, 'tbl_name', None, None, ), # 3 + (4, TType.STRUCT, 'creation_metadata', (CreationMetadata, CreationMetadata.thrift_spec), None, ), # 4 ) - def __init__(self, dbname=None, tbl_name=None, creation_metadata=None,): + def __init__(self, catName=None, dbname=None, tbl_name=None, creation_metadata=None,): + self.catName = catName self.dbname = dbname self.tbl_name = tbl_name self.creation_metadata = creation_metadata @@ -20234,15 +21108,20 @@ class update_creation_metadata_args: break if fid == 1: if ftype == TType.STRING: - self.dbname = iprot.readString() + self.catName = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.tbl_name = iprot.readString() + self.dbname = iprot.readString() else: iprot.skip(ftype) elif fid == 3: + if ftype == TType.STRING: + self.tbl_name = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 4: if ftype == TType.STRUCT: self.creation_metadata = CreationMetadata() self.creation_metadata.read(iprot) @@ -20258,16 +21137,20 @@ class update_creation_metadata_args: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return oprot.writeStructBegin('update_creation_metadata_args') + if self.catName is not None: + oprot.writeFieldBegin('catName', TType.STRING, 1) + oprot.writeString(self.catName) + oprot.writeFieldEnd() if self.dbname is not None: - oprot.writeFieldBegin('dbname', TType.STRING, 1) + oprot.writeFieldBegin('dbname', TType.STRING, 2) oprot.writeString(self.dbname) oprot.writeFieldEnd() if self.tbl_name is not None: - oprot.writeFieldBegin('tbl_name', TType.STRING, 2) + oprot.writeFieldBegin('tbl_name', TType.STRING, 3) oprot.writeString(self.tbl_name) oprot.writeFieldEnd() if self.creation_metadata is not None: - oprot.writeFieldBegin('creation_metadata', TType.STRUCT, 3) + oprot.writeFieldBegin('creation_metadata', TType.STRUCT, 4) self.creation_metadata.write(oprot) oprot.writeFieldEnd() oprot.writeFieldStop() @@ -20279,6 +21162,7 @@ class update_creation_metadata_args: def __hash__(self): value = 17 + value = (value * 31) ^ hash(self.catName) value = (value * 31) ^ hash(self.dbname) value = (value * 31) ^ hash(self.tbl_name) value = (value * 31) ^ hash(self.creation_metadata) @@ -20514,10 +21398,10 @@ class get_table_names_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype963, _size960) = iprot.readListBegin() - for _i964 in xrange(_size960): - _elem965 = iprot.readString() - self.success.append(_elem965) + (_etype970, _size967) = iprot.readListBegin() + for _i971 in xrange(_size967): + _elem972 = iprot.readString() + self.success.append(_elem972) iprot.readListEnd() else: iprot.skip(ftype) @@ -20552,8 +21436,8 @@ class get_table_names_by_filter_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter966 in self.success: - oprot.writeString(iter966) + for iter973 in self.success: + oprot.writeString(iter973) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -21523,11 +22407,11 @@ class add_partitions_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype970, _size967) = iprot.readListBegin() - for _i971 in xrange(_size967): - _elem972 = Partition() - _elem972.read(iprot) - self.new_parts.append(_elem972) + (_etype977, _size974) = iprot.readListBegin() + for _i978 in xrange(_size974): + _elem979 = Partition() + _elem979.read(iprot) + self.new_parts.append(_elem979) iprot.readListEnd() else: iprot.skip(ftype) @@ -21544,8 +22428,8 @@ class add_partitions_args: if self.new_parts is not None: oprot.writeFieldBegin('new_parts', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.new_parts)) - for iter973 in self.new_parts: - iter973.write(oprot) + for iter980 in self.new_parts: + iter980.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -21703,11 +22587,11 @@ class add_partitions_pspec_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype977, _size974) = iprot.readListBegin() - for _i978 in xrange(_size974): - _elem979 = PartitionSpec() - _elem979.read(iprot) - self.new_parts.append(_elem979) + (_etype984, _size981) = iprot.readListBegin() + for _i985 in xrange(_size981): + _elem986 = PartitionSpec() + _elem986.read(iprot) + self.new_parts.append(_elem986) iprot.readListEnd() else: iprot.skip(ftype) @@ -21724,8 +22608,8 @@ class add_partitions_pspec_args: if self.new_parts is not None: oprot.writeFieldBegin('new_parts', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.new_parts)) - for iter980 in self.new_parts: - iter980.write(oprot) + for iter987 in self.new_parts: + iter987.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -21899,10 +22783,10 @@ class append_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype984, _size981) = iprot.readListBegin() - for _i985 in xrange(_size981): - _elem986 = iprot.readString() - self.part_vals.append(_elem986) + (_etype991, _size988) = iprot.readListBegin() + for _i992 in xrange(_size988): + _elem993 = iprot.readString() + self.part_vals.append(_elem993) iprot.readListEnd() else: iprot.skip(ftype) @@ -21927,8 +22811,8 @@ class append_partition_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter987 in self.part_vals: - oprot.writeString(iter987) + for iter994 in self.part_vals: + oprot.writeString(iter994) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -22281,10 +23165,10 @@ class append_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype991, _size988) = iprot.readListBegin() - for _i992 in xrange(_size988): - _elem993 = iprot.readString() - self.part_vals.append(_elem993) + (_etype998, _size995) = iprot.readListBegin() + for _i999 in xrange(_size995): + _elem1000 = iprot.readString() + self.part_vals.append(_elem1000) iprot.readListEnd() else: iprot.skip(ftype) @@ -22315,8 +23199,8 @@ class append_partition_with_environment_context_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter994 in self.part_vals: - oprot.writeString(iter994) + for iter1001 in self.part_vals: + oprot.writeString(iter1001) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -22911,10 +23795,10 @@ class drop_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype998, _size995) = iprot.readListBegin() - for _i999 in xrange(_size995): - _elem1000 = iprot.readString() - self.part_vals.append(_elem1000) + (_etype1005, _size1002) = iprot.readListBegin() + for _i1006 in xrange(_size1002): + _elem1007 = iprot.readString() + self.part_vals.append(_elem1007) iprot.readListEnd() else: iprot.skip(ftype) @@ -22944,8 +23828,8 @@ class drop_partition_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter1001 in self.part_vals: - oprot.writeString(iter1001) + for iter1008 in self.part_vals: + oprot.writeString(iter1008) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -23118,10 +24002,10 @@ class drop_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1005, _size1002) = iprot.readListBegin() - for _i1006 in xrange(_size1002): - _elem1007 = iprot.readString() - self.part_vals.append(_elem1007) + (_etype1012, _size1009) = iprot.readListBegin() + for _i1013 in xrange(_size1009): + _elem1014 = iprot.readString() + self.part_vals.append(_elem1014) iprot.readListEnd() else: iprot.skip(ftype) @@ -23157,8 +24041,8 @@ class drop_partition_with_environment_context_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter1008 in self.part_vals: - oprot.writeString(iter1008) + for iter1015 in self.part_vals: + oprot.writeString(iter1015) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -23895,10 +24779,10 @@ class get_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1012, _size1009) = iprot.readListBegin() - for _i1013 in xrange(_size1009): - _elem1014 = iprot.readString() - self.part_vals.append(_elem1014) + (_etype1019, _size1016) = iprot.readListBegin() + for _i1020 in xrange(_size1016): + _elem1021 = iprot.readString() + self.part_vals.append(_elem1021) iprot.readListEnd() else: iprot.skip(ftype) @@ -23923,8 +24807,8 @@ class get_partition_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter1015 in self.part_vals: - oprot.writeString(iter1015) + for iter1022 in self.part_vals: + oprot.writeString(iter1022) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -24083,11 +24967,11 @@ class exchange_partition_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype1017, _vtype1018, _size1016 ) = iprot.readMapBegin() - for _i1020 in xrange(_size1016): - _key1021 = iprot.readString() - _v
<TRUNCATED>
