You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ga...@apache.org on 2018/03/31 01:25:42 UTC
[23/44] hive git commit: HIVE-18755 Modifications to the metastore
for catalogs (Alan Gates, reviewed by Thejas Nair)
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>