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:41 UTC
[22/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/ttypes.py
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
index fd157b2..faeeea0 100644
--- a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
+++ b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
@@ -570,6 +570,7 @@ class SQLPrimaryKey:
- enable_cstr
- validate_cstr
- rely_cstr
+ - catName
"""
thrift_spec = (
@@ -582,9 +583,10 @@ class SQLPrimaryKey:
(6, TType.BOOL, 'enable_cstr', None, None, ), # 6
(7, TType.BOOL, 'validate_cstr', None, None, ), # 7
(8, TType.BOOL, 'rely_cstr', None, None, ), # 8
+ (9, TType.STRING, 'catName', None, None, ), # 9
)
- def __init__(self, table_db=None, table_name=None, column_name=None, key_seq=None, pk_name=None, enable_cstr=None, validate_cstr=None, rely_cstr=None,):
+ def __init__(self, table_db=None, table_name=None, column_name=None, key_seq=None, pk_name=None, enable_cstr=None, validate_cstr=None, rely_cstr=None, catName=None,):
self.table_db = table_db
self.table_name = table_name
self.column_name = column_name
@@ -593,6 +595,7 @@ class SQLPrimaryKey:
self.enable_cstr = enable_cstr
self.validate_cstr = validate_cstr
self.rely_cstr = rely_cstr
+ 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:
@@ -643,6 +646,11 @@ class SQLPrimaryKey:
self.rely_cstr = iprot.readBool()
else:
iprot.skip(ftype)
+ elif fid == 9:
+ if ftype == TType.STRING:
+ self.catName = iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -685,6 +693,10 @@ class SQLPrimaryKey:
oprot.writeFieldBegin('rely_cstr', TType.BOOL, 8)
oprot.writeBool(self.rely_cstr)
oprot.writeFieldEnd()
+ if self.catName is not None:
+ oprot.writeFieldBegin('catName', TType.STRING, 9)
+ oprot.writeString(self.catName)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -702,6 +714,7 @@ class SQLPrimaryKey:
value = (value * 31) ^ hash(self.enable_cstr)
value = (value * 31) ^ hash(self.validate_cstr)
value = (value * 31) ^ hash(self.rely_cstr)
+ value = (value * 31) ^ hash(self.catName)
return value
def __repr__(self):
@@ -732,6 +745,7 @@ class SQLForeignKey:
- enable_cstr
- validate_cstr
- rely_cstr
+ - catName
"""
thrift_spec = (
@@ -750,9 +764,10 @@ class SQLForeignKey:
(12, TType.BOOL, 'enable_cstr', None, None, ), # 12
(13, TType.BOOL, 'validate_cstr', None, None, ), # 13
(14, TType.BOOL, 'rely_cstr', None, None, ), # 14
+ (15, TType.STRING, 'catName', None, None, ), # 15
)
- def __init__(self, pktable_db=None, pktable_name=None, pkcolumn_name=None, fktable_db=None, fktable_name=None, fkcolumn_name=None, key_seq=None, update_rule=None, delete_rule=None, fk_name=None, pk_name=None, enable_cstr=None, validate_cstr=None, rely_cstr=None,):
+ def __init__(self, pktable_db=None, pktable_name=None, pkcolumn_name=None, fktable_db=None, fktable_name=None, fkcolumn_name=None, key_seq=None, update_rule=None, delete_rule=None, fk_name=None, pk_name=None, enable_cstr=None, validate_cstr=None, rely_cstr=None, catName=None,):
self.pktable_db = pktable_db
self.pktable_name = pktable_name
self.pkcolumn_name = pkcolumn_name
@@ -767,6 +782,7 @@ class SQLForeignKey:
self.enable_cstr = enable_cstr
self.validate_cstr = validate_cstr
self.rely_cstr = rely_cstr
+ 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:
@@ -847,6 +863,11 @@ class SQLForeignKey:
self.rely_cstr = iprot.readBool()
else:
iprot.skip(ftype)
+ elif fid == 15:
+ if ftype == TType.STRING:
+ self.catName = iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -913,6 +934,10 @@ class SQLForeignKey:
oprot.writeFieldBegin('rely_cstr', TType.BOOL, 14)
oprot.writeBool(self.rely_cstr)
oprot.writeFieldEnd()
+ if self.catName is not None:
+ oprot.writeFieldBegin('catName', TType.STRING, 15)
+ oprot.writeString(self.catName)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -936,6 +961,7 @@ class SQLForeignKey:
value = (value * 31) ^ hash(self.enable_cstr)
value = (value * 31) ^ hash(self.validate_cstr)
value = (value * 31) ^ hash(self.rely_cstr)
+ value = (value * 31) ^ hash(self.catName)
return value
def __repr__(self):
@@ -952,6 +978,7 @@ class SQLForeignKey:
class SQLUniqueConstraint:
"""
Attributes:
+ - catName
- table_db
- table_name
- column_name
@@ -964,17 +991,19 @@ class SQLUniqueConstraint:
thrift_spec = (
None, # 0
- (1, TType.STRING, 'table_db', None, None, ), # 1
- (2, TType.STRING, 'table_name', None, None, ), # 2
- (3, TType.STRING, 'column_name', None, None, ), # 3
- (4, TType.I32, 'key_seq', None, None, ), # 4
- (5, TType.STRING, 'uk_name', None, None, ), # 5
- (6, TType.BOOL, 'enable_cstr', None, None, ), # 6
- (7, TType.BOOL, 'validate_cstr', None, None, ), # 7
- (8, TType.BOOL, 'rely_cstr', None, None, ), # 8
+ (1, TType.STRING, 'catName', None, None, ), # 1
+ (2, TType.STRING, 'table_db', None, None, ), # 2
+ (3, TType.STRING, 'table_name', None, None, ), # 3
+ (4, TType.STRING, 'column_name', None, None, ), # 4
+ (5, TType.I32, 'key_seq', None, None, ), # 5
+ (6, TType.STRING, 'uk_name', None, None, ), # 6
+ (7, TType.BOOL, 'enable_cstr', None, None, ), # 7
+ (8, TType.BOOL, 'validate_cstr', None, None, ), # 8
+ (9, TType.BOOL, 'rely_cstr', None, None, ), # 9
)
- def __init__(self, table_db=None, table_name=None, column_name=None, key_seq=None, uk_name=None, enable_cstr=None, validate_cstr=None, rely_cstr=None,):
+ def __init__(self, catName=None, table_db=None, table_name=None, column_name=None, key_seq=None, uk_name=None, enable_cstr=None, validate_cstr=None, rely_cstr=None,):
+ self.catName = catName
self.table_db = table_db
self.table_name = table_name
self.column_name = column_name
@@ -995,40 +1024,45 @@ class SQLUniqueConstraint:
break
if fid == 1:
if ftype == TType.STRING:
- self.table_db = iprot.readString()
+ self.catName = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.table_name = iprot.readString()
+ self.table_db = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.STRING:
- self.column_name = iprot.readString()
+ self.table_name = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 4:
+ if ftype == TType.STRING:
+ self.column_name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
if ftype == TType.I32:
self.key_seq = iprot.readI32()
else:
iprot.skip(ftype)
- elif fid == 5:
+ elif fid == 6:
if ftype == TType.STRING:
self.uk_name = iprot.readString()
else:
iprot.skip(ftype)
- elif fid == 6:
+ elif fid == 7:
if ftype == TType.BOOL:
self.enable_cstr = iprot.readBool()
else:
iprot.skip(ftype)
- elif fid == 7:
+ elif fid == 8:
if ftype == TType.BOOL:
self.validate_cstr = iprot.readBool()
else:
iprot.skip(ftype)
- elif fid == 8:
+ elif fid == 9:
if ftype == TType.BOOL:
self.rely_cstr = iprot.readBool()
else:
@@ -1043,36 +1077,40 @@ class SQLUniqueConstraint:
oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
return
oprot.writeStructBegin('SQLUniqueConstraint')
+ if self.catName is not None:
+ oprot.writeFieldBegin('catName', TType.STRING, 1)
+ oprot.writeString(self.catName)
+ oprot.writeFieldEnd()
if self.table_db is not None:
- oprot.writeFieldBegin('table_db', TType.STRING, 1)
+ oprot.writeFieldBegin('table_db', TType.STRING, 2)
oprot.writeString(self.table_db)
oprot.writeFieldEnd()
if self.table_name is not None:
- oprot.writeFieldBegin('table_name', TType.STRING, 2)
+ oprot.writeFieldBegin('table_name', TType.STRING, 3)
oprot.writeString(self.table_name)
oprot.writeFieldEnd()
if self.column_name is not None:
- oprot.writeFieldBegin('column_name', TType.STRING, 3)
+ oprot.writeFieldBegin('column_name', TType.STRING, 4)
oprot.writeString(self.column_name)
oprot.writeFieldEnd()
if self.key_seq is not None:
- oprot.writeFieldBegin('key_seq', TType.I32, 4)
+ oprot.writeFieldBegin('key_seq', TType.I32, 5)
oprot.writeI32(self.key_seq)
oprot.writeFieldEnd()
if self.uk_name is not None:
- oprot.writeFieldBegin('uk_name', TType.STRING, 5)
+ oprot.writeFieldBegin('uk_name', TType.STRING, 6)
oprot.writeString(self.uk_name)
oprot.writeFieldEnd()
if self.enable_cstr is not None:
- oprot.writeFieldBegin('enable_cstr', TType.BOOL, 6)
+ oprot.writeFieldBegin('enable_cstr', TType.BOOL, 7)
oprot.writeBool(self.enable_cstr)
oprot.writeFieldEnd()
if self.validate_cstr is not None:
- oprot.writeFieldBegin('validate_cstr', TType.BOOL, 7)
+ oprot.writeFieldBegin('validate_cstr', TType.BOOL, 8)
oprot.writeBool(self.validate_cstr)
oprot.writeFieldEnd()
if self.rely_cstr is not None:
- oprot.writeFieldBegin('rely_cstr', TType.BOOL, 8)
+ oprot.writeFieldBegin('rely_cstr', TType.BOOL, 9)
oprot.writeBool(self.rely_cstr)
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -1084,6 +1122,7 @@ class SQLUniqueConstraint:
def __hash__(self):
value = 17
+ value = (value * 31) ^ hash(self.catName)
value = (value * 31) ^ hash(self.table_db)
value = (value * 31) ^ hash(self.table_name)
value = (value * 31) ^ hash(self.column_name)
@@ -1108,6 +1147,7 @@ class SQLUniqueConstraint:
class SQLNotNullConstraint:
"""
Attributes:
+ - catName
- table_db
- table_name
- column_name
@@ -1119,16 +1159,18 @@ class SQLNotNullConstraint:
thrift_spec = (
None, # 0
- (1, TType.STRING, 'table_db', None, None, ), # 1
- (2, TType.STRING, 'table_name', None, None, ), # 2
- (3, TType.STRING, 'column_name', None, None, ), # 3
- (4, TType.STRING, 'nn_name', None, None, ), # 4
- (5, TType.BOOL, 'enable_cstr', None, None, ), # 5
- (6, TType.BOOL, 'validate_cstr', None, None, ), # 6
- (7, TType.BOOL, 'rely_cstr', None, None, ), # 7
+ (1, TType.STRING, 'catName', None, None, ), # 1
+ (2, TType.STRING, 'table_db', None, None, ), # 2
+ (3, TType.STRING, 'table_name', None, None, ), # 3
+ (4, TType.STRING, 'column_name', None, None, ), # 4
+ (5, TType.STRING, 'nn_name', None, None, ), # 5
+ (6, TType.BOOL, 'enable_cstr', None, None, ), # 6
+ (7, TType.BOOL, 'validate_cstr', None, None, ), # 7
+ (8, TType.BOOL, 'rely_cstr', None, None, ), # 8
)
- def __init__(self, table_db=None, table_name=None, column_name=None, nn_name=None, enable_cstr=None, validate_cstr=None, rely_cstr=None,):
+ def __init__(self, catName=None, table_db=None, table_name=None, column_name=None, nn_name=None, enable_cstr=None, validate_cstr=None, rely_cstr=None,):
+ self.catName = catName
self.table_db = table_db
self.table_name = table_name
self.column_name = column_name
@@ -1148,35 +1190,40 @@ class SQLNotNullConstraint:
break
if fid == 1:
if ftype == TType.STRING:
- self.table_db = iprot.readString()
+ self.catName = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.table_name = iprot.readString()
+ self.table_db = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.STRING:
- self.column_name = iprot.readString()
+ self.table_name = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.STRING:
- self.nn_name = iprot.readString()
+ self.column_name = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 5:
+ if ftype == TType.STRING:
+ self.nn_name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
if ftype == TType.BOOL:
self.enable_cstr = iprot.readBool()
else:
iprot.skip(ftype)
- elif fid == 6:
+ elif fid == 7:
if ftype == TType.BOOL:
self.validate_cstr = iprot.readBool()
else:
iprot.skip(ftype)
- elif fid == 7:
+ elif fid == 8:
if ftype == TType.BOOL:
self.rely_cstr = iprot.readBool()
else:
@@ -1191,32 +1238,36 @@ class SQLNotNullConstraint:
oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
return
oprot.writeStructBegin('SQLNotNullConstraint')
+ if self.catName is not None:
+ oprot.writeFieldBegin('catName', TType.STRING, 1)
+ oprot.writeString(self.catName)
+ oprot.writeFieldEnd()
if self.table_db is not None:
- oprot.writeFieldBegin('table_db', TType.STRING, 1)
+ oprot.writeFieldBegin('table_db', TType.STRING, 2)
oprot.writeString(self.table_db)
oprot.writeFieldEnd()
if self.table_name is not None:
- oprot.writeFieldBegin('table_name', TType.STRING, 2)
+ oprot.writeFieldBegin('table_name', TType.STRING, 3)
oprot.writeString(self.table_name)
oprot.writeFieldEnd()
if self.column_name is not None:
- oprot.writeFieldBegin('column_name', TType.STRING, 3)
+ oprot.writeFieldBegin('column_name', TType.STRING, 4)
oprot.writeString(self.column_name)
oprot.writeFieldEnd()
if self.nn_name is not None:
- oprot.writeFieldBegin('nn_name', TType.STRING, 4)
+ oprot.writeFieldBegin('nn_name', TType.STRING, 5)
oprot.writeString(self.nn_name)
oprot.writeFieldEnd()
if self.enable_cstr is not None:
- oprot.writeFieldBegin('enable_cstr', TType.BOOL, 5)
+ oprot.writeFieldBegin('enable_cstr', TType.BOOL, 6)
oprot.writeBool(self.enable_cstr)
oprot.writeFieldEnd()
if self.validate_cstr is not None:
- oprot.writeFieldBegin('validate_cstr', TType.BOOL, 6)
+ oprot.writeFieldBegin('validate_cstr', TType.BOOL, 7)
oprot.writeBool(self.validate_cstr)
oprot.writeFieldEnd()
if self.rely_cstr is not None:
- oprot.writeFieldBegin('rely_cstr', TType.BOOL, 7)
+ oprot.writeFieldBegin('rely_cstr', TType.BOOL, 8)
oprot.writeBool(self.rely_cstr)
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -1228,6 +1279,7 @@ class SQLNotNullConstraint:
def __hash__(self):
value = 17
+ value = (value * 31) ^ hash(self.catName)
value = (value * 31) ^ hash(self.table_db)
value = (value * 31) ^ hash(self.table_name)
value = (value * 31) ^ hash(self.column_name)
@@ -1251,6 +1303,7 @@ class SQLNotNullConstraint:
class SQLDefaultConstraint:
"""
Attributes:
+ - catName
- table_db
- table_name
- column_name
@@ -1263,17 +1316,19 @@ class SQLDefaultConstraint:
thrift_spec = (
None, # 0
- (1, TType.STRING, 'table_db', None, None, ), # 1
- (2, TType.STRING, 'table_name', None, None, ), # 2
- (3, TType.STRING, 'column_name', None, None, ), # 3
- (4, TType.STRING, 'default_value', None, None, ), # 4
- (5, TType.STRING, 'dc_name', None, None, ), # 5
- (6, TType.BOOL, 'enable_cstr', None, None, ), # 6
- (7, TType.BOOL, 'validate_cstr', None, None, ), # 7
- (8, TType.BOOL, 'rely_cstr', None, None, ), # 8
+ (1, TType.STRING, 'catName', None, None, ), # 1
+ (2, TType.STRING, 'table_db', None, None, ), # 2
+ (3, TType.STRING, 'table_name', None, None, ), # 3
+ (4, TType.STRING, 'column_name', None, None, ), # 4
+ (5, TType.STRING, 'default_value', None, None, ), # 5
+ (6, TType.STRING, 'dc_name', None, None, ), # 6
+ (7, TType.BOOL, 'enable_cstr', None, None, ), # 7
+ (8, TType.BOOL, 'validate_cstr', None, None, ), # 8
+ (9, TType.BOOL, 'rely_cstr', None, None, ), # 9
)
- def __init__(self, table_db=None, table_name=None, column_name=None, default_value=None, dc_name=None, enable_cstr=None, validate_cstr=None, rely_cstr=None,):
+ def __init__(self, catName=None, table_db=None, table_name=None, column_name=None, default_value=None, dc_name=None, enable_cstr=None, validate_cstr=None, rely_cstr=None,):
+ self.catName = catName
self.table_db = table_db
self.table_name = table_name
self.column_name = column_name
@@ -1294,40 +1349,45 @@ class SQLDefaultConstraint:
break
if fid == 1:
if ftype == TType.STRING:
- self.table_db = iprot.readString()
+ self.catName = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.table_name = iprot.readString()
+ self.table_db = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.STRING:
- self.column_name = iprot.readString()
+ self.table_name = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.STRING:
- self.default_value = iprot.readString()
+ self.column_name = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.STRING:
- self.dc_name = iprot.readString()
+ self.default_value = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 6:
+ if ftype == TType.STRING:
+ self.dc_name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
if ftype == TType.BOOL:
self.enable_cstr = iprot.readBool()
else:
iprot.skip(ftype)
- elif fid == 7:
+ elif fid == 8:
if ftype == TType.BOOL:
self.validate_cstr = iprot.readBool()
else:
iprot.skip(ftype)
- elif fid == 8:
+ elif fid == 9:
if ftype == TType.BOOL:
self.rely_cstr = iprot.readBool()
else:
@@ -1342,36 +1402,40 @@ class SQLDefaultConstraint:
oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
return
oprot.writeStructBegin('SQLDefaultConstraint')
+ if self.catName is not None:
+ oprot.writeFieldBegin('catName', TType.STRING, 1)
+ oprot.writeString(self.catName)
+ oprot.writeFieldEnd()
if self.table_db is not None:
- oprot.writeFieldBegin('table_db', TType.STRING, 1)
+ oprot.writeFieldBegin('table_db', TType.STRING, 2)
oprot.writeString(self.table_db)
oprot.writeFieldEnd()
if self.table_name is not None:
- oprot.writeFieldBegin('table_name', TType.STRING, 2)
+ oprot.writeFieldBegin('table_name', TType.STRING, 3)
oprot.writeString(self.table_name)
oprot.writeFieldEnd()
if self.column_name is not None:
- oprot.writeFieldBegin('column_name', TType.STRING, 3)
+ oprot.writeFieldBegin('column_name', TType.STRING, 4)
oprot.writeString(self.column_name)
oprot.writeFieldEnd()
if self.default_value is not None:
- oprot.writeFieldBegin('default_value', TType.STRING, 4)
+ oprot.writeFieldBegin('default_value', TType.STRING, 5)
oprot.writeString(self.default_value)
oprot.writeFieldEnd()
if self.dc_name is not None:
- oprot.writeFieldBegin('dc_name', TType.STRING, 5)
+ oprot.writeFieldBegin('dc_name', TType.STRING, 6)
oprot.writeString(self.dc_name)
oprot.writeFieldEnd()
if self.enable_cstr is not None:
- oprot.writeFieldBegin('enable_cstr', TType.BOOL, 6)
+ oprot.writeFieldBegin('enable_cstr', TType.BOOL, 7)
oprot.writeBool(self.enable_cstr)
oprot.writeFieldEnd()
if self.validate_cstr is not None:
- oprot.writeFieldBegin('validate_cstr', TType.BOOL, 7)
+ oprot.writeFieldBegin('validate_cstr', TType.BOOL, 8)
oprot.writeBool(self.validate_cstr)
oprot.writeFieldEnd()
if self.rely_cstr is not None:
- oprot.writeFieldBegin('rely_cstr', TType.BOOL, 8)
+ oprot.writeFieldBegin('rely_cstr', TType.BOOL, 9)
oprot.writeBool(self.rely_cstr)
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -1383,6 +1447,7 @@ class SQLDefaultConstraint:
def __hash__(self):
value = 17
+ value = (value * 31) ^ hash(self.catName)
value = (value * 31) ^ hash(self.table_db)
value = (value * 31) ^ hash(self.table_name)
value = (value * 31) ^ hash(self.column_name)
@@ -1407,6 +1472,7 @@ class SQLDefaultConstraint:
class SQLCheckConstraint:
"""
Attributes:
+ - catName
- table_db
- table_name
- column_name
@@ -1419,17 +1485,19 @@ class SQLCheckConstraint:
thrift_spec = (
None, # 0
- (1, TType.STRING, 'table_db', None, None, ), # 1
- (2, TType.STRING, 'table_name', None, None, ), # 2
- (3, TType.STRING, 'column_name', None, None, ), # 3
- (4, TType.STRING, 'check_expression', None, None, ), # 4
- (5, TType.STRING, 'dc_name', None, None, ), # 5
- (6, TType.BOOL, 'enable_cstr', None, None, ), # 6
- (7, TType.BOOL, 'validate_cstr', None, None, ), # 7
- (8, TType.BOOL, 'rely_cstr', None, None, ), # 8
+ (1, TType.STRING, 'catName', None, None, ), # 1
+ (2, TType.STRING, 'table_db', None, None, ), # 2
+ (3, TType.STRING, 'table_name', None, None, ), # 3
+ (4, TType.STRING, 'column_name', None, None, ), # 4
+ (5, TType.STRING, 'check_expression', None, None, ), # 5
+ (6, TType.STRING, 'dc_name', None, None, ), # 6
+ (7, TType.BOOL, 'enable_cstr', None, None, ), # 7
+ (8, TType.BOOL, 'validate_cstr', None, None, ), # 8
+ (9, TType.BOOL, 'rely_cstr', None, None, ), # 9
)
- def __init__(self, table_db=None, table_name=None, column_name=None, check_expression=None, dc_name=None, enable_cstr=None, validate_cstr=None, rely_cstr=None,):
+ def __init__(self, catName=None, table_db=None, table_name=None, column_name=None, check_expression=None, dc_name=None, enable_cstr=None, validate_cstr=None, rely_cstr=None,):
+ self.catName = catName
self.table_db = table_db
self.table_name = table_name
self.column_name = column_name
@@ -1450,40 +1518,45 @@ class SQLCheckConstraint:
break
if fid == 1:
if ftype == TType.STRING:
- self.table_db = iprot.readString()
+ self.catName = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.table_name = iprot.readString()
+ self.table_db = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.STRING:
- self.column_name = iprot.readString()
+ self.table_name = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.STRING:
- self.check_expression = iprot.readString()
+ self.column_name = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.STRING:
- self.dc_name = iprot.readString()
+ self.check_expression = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 6:
+ if ftype == TType.STRING:
+ self.dc_name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
if ftype == TType.BOOL:
self.enable_cstr = iprot.readBool()
else:
iprot.skip(ftype)
- elif fid == 7:
+ elif fid == 8:
if ftype == TType.BOOL:
self.validate_cstr = iprot.readBool()
else:
iprot.skip(ftype)
- elif fid == 8:
+ elif fid == 9:
if ftype == TType.BOOL:
self.rely_cstr = iprot.readBool()
else:
@@ -1498,36 +1571,40 @@ class SQLCheckConstraint:
oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
return
oprot.writeStructBegin('SQLCheckConstraint')
+ if self.catName is not None:
+ oprot.writeFieldBegin('catName', TType.STRING, 1)
+ oprot.writeString(self.catName)
+ oprot.writeFieldEnd()
if self.table_db is not None:
- oprot.writeFieldBegin('table_db', TType.STRING, 1)
+ oprot.writeFieldBegin('table_db', TType.STRING, 2)
oprot.writeString(self.table_db)
oprot.writeFieldEnd()
if self.table_name is not None:
- oprot.writeFieldBegin('table_name', TType.STRING, 2)
+ oprot.writeFieldBegin('table_name', TType.STRING, 3)
oprot.writeString(self.table_name)
oprot.writeFieldEnd()
if self.column_name is not None:
- oprot.writeFieldBegin('column_name', TType.STRING, 3)
+ oprot.writeFieldBegin('column_name', TType.STRING, 4)
oprot.writeString(self.column_name)
oprot.writeFieldEnd()
if self.check_expression is not None:
- oprot.writeFieldBegin('check_expression', TType.STRING, 4)
+ oprot.writeFieldBegin('check_expression', TType.STRING, 5)
oprot.writeString(self.check_expression)
oprot.writeFieldEnd()
if self.dc_name is not None:
- oprot.writeFieldBegin('dc_name', TType.STRING, 5)
+ oprot.writeFieldBegin('dc_name', TType.STRING, 6)
oprot.writeString(self.dc_name)
oprot.writeFieldEnd()
if self.enable_cstr is not None:
- oprot.writeFieldBegin('enable_cstr', TType.BOOL, 6)
+ oprot.writeFieldBegin('enable_cstr', TType.BOOL, 7)
oprot.writeBool(self.enable_cstr)
oprot.writeFieldEnd()
if self.validate_cstr is not None:
- oprot.writeFieldBegin('validate_cstr', TType.BOOL, 7)
+ oprot.writeFieldBegin('validate_cstr', TType.BOOL, 8)
oprot.writeBool(self.validate_cstr)
oprot.writeFieldEnd()
if self.rely_cstr is not None:
- oprot.writeFieldBegin('rely_cstr', TType.BOOL, 8)
+ oprot.writeFieldBegin('rely_cstr', TType.BOOL, 9)
oprot.writeBool(self.rely_cstr)
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -1539,6 +1616,7 @@ class SQLCheckConstraint:
def __hash__(self):
value = 17
+ value = (value * 31) ^ hash(self.catName)
value = (value * 31) ^ hash(self.table_db)
value = (value * 31) ^ hash(self.table_name)
value = (value * 31) ^ hash(self.column_name)
@@ -1681,6 +1759,7 @@ class HiveObjectRef:
- objectName
- partValues
- columnName
+ - catName
"""
thrift_spec = (
@@ -1690,14 +1769,16 @@ class HiveObjectRef:
(3, TType.STRING, 'objectName', None, None, ), # 3
(4, TType.LIST, 'partValues', (TType.STRING,None), None, ), # 4
(5, TType.STRING, 'columnName', None, None, ), # 5
+ (6, TType.STRING, 'catName', None, None, ), # 6
)
- def __init__(self, objectType=None, dbName=None, objectName=None, partValues=None, columnName=None,):
+ def __init__(self, objectType=None, dbName=None, objectName=None, partValues=None, columnName=None, catName=None,):
self.objectType = objectType
self.dbName = dbName
self.objectName = objectName
self.partValues = partValues
self.columnName = columnName
+ 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:
@@ -1738,6 +1819,11 @@ class HiveObjectRef:
self.columnName = iprot.readString()
else:
iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.STRING:
+ self.catName = iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -1771,6 +1857,10 @@ class HiveObjectRef:
oprot.writeFieldBegin('columnName', TType.STRING, 5)
oprot.writeString(self.columnName)
oprot.writeFieldEnd()
+ if self.catName is not None:
+ oprot.writeFieldBegin('catName', TType.STRING, 6)
+ oprot.writeString(self.catName)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -1785,6 +1875,7 @@ class HiveObjectRef:
value = (value * 31) ^ hash(self.objectName)
value = (value * 31) ^ hash(self.partValues)
value = (value * 31) ^ hash(self.columnName)
+ value = (value * 31) ^ hash(self.catName)
return value
def __repr__(self):
@@ -3143,16 +3234,12 @@ class GrantRevokeRoleResponse:
def __ne__(self, other):
return not (self == other)
-class Database:
+class Catalog:
"""
Attributes:
- name
- description
- locationUri
- - parameters
- - privileges
- - ownerName
- - ownerType
"""
thrift_spec = (
@@ -3160,20 +3247,12 @@ class Database:
(1, TType.STRING, 'name', None, None, ), # 1
(2, TType.STRING, 'description', None, None, ), # 2
(3, TType.STRING, 'locationUri', None, None, ), # 3
- (4, TType.MAP, 'parameters', (TType.STRING,None,TType.STRING,None), None, ), # 4
- (5, TType.STRUCT, 'privileges', (PrincipalPrivilegeSet, PrincipalPrivilegeSet.thrift_spec), None, ), # 5
- (6, TType.STRING, 'ownerName', None, None, ), # 6
- (7, TType.I32, 'ownerType', None, None, ), # 7
)
- def __init__(self, name=None, description=None, locationUri=None, parameters=None, privileges=None, ownerName=None, ownerType=None,):
+ def __init__(self, name=None, description=None, locationUri=None,):
self.name = name
self.description = description
self.locationUri = locationUri
- self.parameters = parameters
- self.privileges = privileges
- self.ownerName = ownerName
- self.ownerType = ownerType
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:
@@ -3199,33 +3278,6 @@ class Database:
self.locationUri = iprot.readString()
else:
iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.MAP:
- self.parameters = {}
- (_ktype84, _vtype85, _size83 ) = iprot.readMapBegin()
- for _i87 in xrange(_size83):
- _key88 = iprot.readString()
- _val89 = iprot.readString()
- self.parameters[_key88] = _val89
- iprot.readMapEnd()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.STRUCT:
- self.privileges = PrincipalPrivilegeSet()
- self.privileges.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.STRING:
- self.ownerName = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.I32:
- self.ownerType = iprot.readI32()
- else:
- iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -3235,7 +3287,7 @@ class Database:
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('Database')
+ oprot.writeStructBegin('Catalog')
if self.name is not None:
oprot.writeFieldBegin('name', TType.STRING, 1)
oprot.writeString(self.name)
@@ -3248,26 +3300,6 @@ class Database:
oprot.writeFieldBegin('locationUri', TType.STRING, 3)
oprot.writeString(self.locationUri)
oprot.writeFieldEnd()
- if self.parameters is not None:
- oprot.writeFieldBegin('parameters', TType.MAP, 4)
- oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.parameters))
- for kiter90,viter91 in self.parameters.items():
- oprot.writeString(kiter90)
- oprot.writeString(viter91)
- oprot.writeMapEnd()
- oprot.writeFieldEnd()
- if self.privileges is not None:
- oprot.writeFieldBegin('privileges', TType.STRUCT, 5)
- self.privileges.write(oprot)
- oprot.writeFieldEnd()
- if self.ownerName is not None:
- oprot.writeFieldBegin('ownerName', TType.STRING, 6)
- oprot.writeString(self.ownerName)
- oprot.writeFieldEnd()
- if self.ownerType is not None:
- oprot.writeFieldBegin('ownerType', TType.I32, 7)
- oprot.writeI32(self.ownerType)
- oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -3280,10 +3312,6 @@ class Database:
value = (value * 31) ^ hash(self.name)
value = (value * 31) ^ hash(self.description)
value = (value * 31) ^ hash(self.locationUri)
- value = (value * 31) ^ hash(self.parameters)
- value = (value * 31) ^ hash(self.privileges)
- value = (value * 31) ^ hash(self.ownerName)
- value = (value * 31) ^ hash(self.ownerType)
return value
def __repr__(self):
@@ -3297,37 +3325,19 @@ class Database:
def __ne__(self, other):
return not (self == other)
-class SerDeInfo:
+class CreateCatalogRequest:
"""
Attributes:
- - name
- - serializationLib
- - parameters
- - description
- - serializerClass
- - deserializerClass
- - serdeType
+ - catalog
"""
thrift_spec = (
None, # 0
- (1, TType.STRING, 'name', None, None, ), # 1
- (2, TType.STRING, 'serializationLib', None, None, ), # 2
- (3, TType.MAP, 'parameters', (TType.STRING,None,TType.STRING,None), None, ), # 3
- (4, TType.STRING, 'description', None, None, ), # 4
- (5, TType.STRING, 'serializerClass', None, None, ), # 5
- (6, TType.STRING, 'deserializerClass', None, None, ), # 6
- (7, TType.I32, 'serdeType', None, None, ), # 7
+ (1, TType.STRUCT, 'catalog', (Catalog, Catalog.thrift_spec), None, ), # 1
)
- def __init__(self, name=None, serializationLib=None, parameters=None, description=None, serializerClass=None, deserializerClass=None, serdeType=None,):
- self.name = name
- self.serializationLib = serializationLib
- self.parameters = parameters
- self.description = description
- self.serializerClass = serializerClass
- self.deserializerClass = deserializerClass
- self.serdeType = serdeType
+ 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:
@@ -3339,44 +3349,9 @@ class SerDeInfo:
if ftype == TType.STOP:
break
if fid == 1:
- if ftype == TType.STRING:
- self.name = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.serializationLib = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.MAP:
- self.parameters = {}
- (_ktype93, _vtype94, _size92 ) = iprot.readMapBegin()
- for _i96 in xrange(_size92):
- _key97 = iprot.readString()
- _val98 = iprot.readString()
- self.parameters[_key97] = _val98
- iprot.readMapEnd()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.STRING:
- self.description = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.STRING:
- self.serializerClass = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.STRING:
- self.deserializerClass = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.I32:
- self.serdeType = iprot.readI32()
+ if ftype == TType.STRUCT:
+ self.catalog = Catalog()
+ self.catalog.read(iprot)
else:
iprot.skip(ftype)
else:
@@ -3388,8 +3363,563 @@ class SerDeInfo:
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('SerDeInfo')
- if self.name is not None:
+ oprot.writeStructBegin('CreateCatalogRequest')
+ if self.catalog is not None:
+ oprot.writeFieldBegin('catalog', TType.STRUCT, 1)
+ self.catalog.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.catalog)
+ 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 GetCatalogRequest:
+ """
+ Attributes:
+ - name
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'name', None, None, ), # 1
+ )
+
+ def __init__(self, name=None,):
+ self.name = name
+
+ 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.STRING:
+ self.name = iprot.readString()
+ 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('GetCatalogRequest')
+ if self.name is not None:
+ oprot.writeFieldBegin('name', TType.STRING, 1)
+ oprot.writeString(self.name)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.name)
+ 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 GetCatalogResponse:
+ """
+ Attributes:
+ - catalog
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'catalog', (Catalog, Catalog.thrift_spec), None, ), # 1
+ )
+
+ 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:
+ 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.catalog = Catalog()
+ self.catalog.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('GetCatalogResponse')
+ if self.catalog is not None:
+ oprot.writeFieldBegin('catalog', TType.STRUCT, 1)
+ self.catalog.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.catalog)
+ 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 GetCatalogsResponse:
+ """
+ Attributes:
+ - names
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.LIST, 'names', (TType.STRING,None), None, ), # 1
+ )
+
+ def __init__(self, names=None,):
+ self.names = names
+
+ 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.LIST:
+ self.names = []
+ (_etype86, _size83) = iprot.readListBegin()
+ for _i87 in xrange(_size83):
+ _elem88 = iprot.readString()
+ self.names.append(_elem88)
+ iprot.readListEnd()
+ 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('GetCatalogsResponse')
+ if self.names is not None:
+ oprot.writeFieldBegin('names', TType.LIST, 1)
+ oprot.writeListBegin(TType.STRING, len(self.names))
+ for iter89 in self.names:
+ oprot.writeString(iter89)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.names)
+ 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 DropCatalogRequest:
+ """
+ Attributes:
+ - name
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'name', None, None, ), # 1
+ )
+
+ def __init__(self, name=None,):
+ self.name = name
+
+ 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.STRING:
+ self.name = iprot.readString()
+ 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('DropCatalogRequest')
+ if self.name is not None:
+ oprot.writeFieldBegin('name', TType.STRING, 1)
+ oprot.writeString(self.name)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.name)
+ 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 Database:
+ """
+ Attributes:
+ - name
+ - description
+ - locationUri
+ - parameters
+ - privileges
+ - ownerName
+ - ownerType
+ - catalogName
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'name', None, None, ), # 1
+ (2, TType.STRING, 'description', None, None, ), # 2
+ (3, TType.STRING, 'locationUri', None, None, ), # 3
+ (4, TType.MAP, 'parameters', (TType.STRING,None,TType.STRING,None), None, ), # 4
+ (5, TType.STRUCT, 'privileges', (PrincipalPrivilegeSet, PrincipalPrivilegeSet.thrift_spec), None, ), # 5
+ (6, TType.STRING, 'ownerName', None, None, ), # 6
+ (7, TType.I32, 'ownerType', None, None, ), # 7
+ (8, TType.STRING, 'catalogName', None, None, ), # 8
+ )
+
+ def __init__(self, name=None, description=None, locationUri=None, parameters=None, privileges=None, ownerName=None, ownerType=None, catalogName=None,):
+ self.name = name
+ self.description = description
+ self.locationUri = locationUri
+ self.parameters = parameters
+ self.privileges = privileges
+ self.ownerName = ownerName
+ self.ownerType = ownerType
+ self.catalogName = catalogName
+
+ 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.STRING:
+ self.name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.description = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.locationUri = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.MAP:
+ self.parameters = {}
+ (_ktype91, _vtype92, _size90 ) = iprot.readMapBegin()
+ for _i94 in xrange(_size90):
+ _key95 = iprot.readString()
+ _val96 = iprot.readString()
+ self.parameters[_key95] = _val96
+ iprot.readMapEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.STRUCT:
+ self.privileges = PrincipalPrivilegeSet()
+ self.privileges.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.STRING:
+ self.ownerName = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.I32:
+ self.ownerType = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ elif fid == 8:
+ if ftype == TType.STRING:
+ self.catalogName = iprot.readString()
+ 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('Database')
+ if self.name is not None:
+ oprot.writeFieldBegin('name', TType.STRING, 1)
+ oprot.writeString(self.name)
+ oprot.writeFieldEnd()
+ if self.description is not None:
+ oprot.writeFieldBegin('description', TType.STRING, 2)
+ oprot.writeString(self.description)
+ oprot.writeFieldEnd()
+ if self.locationUri is not None:
+ oprot.writeFieldBegin('locationUri', TType.STRING, 3)
+ oprot.writeString(self.locationUri)
+ oprot.writeFieldEnd()
+ if self.parameters is not None:
+ oprot.writeFieldBegin('parameters', TType.MAP, 4)
+ oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.parameters))
+ for kiter97,viter98 in self.parameters.items():
+ oprot.writeString(kiter97)
+ oprot.writeString(viter98)
+ oprot.writeMapEnd()
+ oprot.writeFieldEnd()
+ if self.privileges is not None:
+ oprot.writeFieldBegin('privileges', TType.STRUCT, 5)
+ self.privileges.write(oprot)
+ oprot.writeFieldEnd()
+ if self.ownerName is not None:
+ oprot.writeFieldBegin('ownerName', TType.STRING, 6)
+ oprot.writeString(self.ownerName)
+ oprot.writeFieldEnd()
+ if self.ownerType is not None:
+ oprot.writeFieldBegin('ownerType', TType.I32, 7)
+ oprot.writeI32(self.ownerType)
+ oprot.writeFieldEnd()
+ if self.catalogName is not None:
+ oprot.writeFieldBegin('catalogName', TType.STRING, 8)
+ oprot.writeString(self.catalogName)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.name)
+ value = (value * 31) ^ hash(self.description)
+ value = (value * 31) ^ hash(self.locationUri)
+ value = (value * 31) ^ hash(self.parameters)
+ value = (value * 31) ^ hash(self.privileges)
+ value = (value * 31) ^ hash(self.ownerName)
+ value = (value * 31) ^ hash(self.ownerType)
+ value = (value * 31) ^ hash(self.catalogName)
+ 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 SerDeInfo:
+ """
+ Attributes:
+ - name
+ - serializationLib
+ - parameters
+ - description
+ - serializerClass
+ - deserializerClass
+ - serdeType
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'name', None, None, ), # 1
+ (2, TType.STRING, 'serializationLib', None, None, ), # 2
+ (3, TType.MAP, 'parameters', (TType.STRING,None,TType.STRING,None), None, ), # 3
+ (4, TType.STRING, 'description', None, None, ), # 4
+ (5, TType.STRING, 'serializerClass', None, None, ), # 5
+ (6, TType.STRING, 'deserializerClass', None, None, ), # 6
+ (7, TType.I32, 'serdeType', None, None, ), # 7
+ )
+
+ def __init__(self, name=None, serializationLib=None, parameters=None, description=None, serializerClass=None, deserializerClass=None, serdeType=None,):
+ self.name = name
+ self.serializationLib = serializationLib
+ self.parameters = parameters
+ self.description = description
+ self.serializerClass = serializerClass
+ self.deserializerClass = deserializerClass
+ self.serdeType = serdeType
+
+ 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.STRING:
+ self.name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.serializationLib = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.MAP:
+ self.parameters = {}
+ (_ktype100, _vtype101, _size99 ) = iprot.readMapBegin()
+ for _i103 in xrange(_size99):
+ _key104 = iprot.readString()
+ _val105 = iprot.readString()
+ self.parameters[_key104] = _val105
+ iprot.readMapEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.description = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.STRING:
+ self.serializerClass = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.STRING:
+ self.deserializerClass = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.I32:
+ self.serdeType = iprot.readI32()
+ 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('SerDeInfo')
+ if self.name is not None:
oprot.writeFieldBegin('name', TType.STRING, 1)
oprot.writeString(self.name)
oprot.writeFieldEnd()
@@ -3400,9 +3930,9 @@ class SerDeInfo:
if self.parameters is not None:
oprot.writeFieldBegin('parameters', TType.MAP, 3)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.parameters))
- for kiter99,viter100 in self.parameters.items():
- oprot.writeString(kiter99)
- oprot.writeString(viter100)
+ for kiter106,viter107 in self.parameters.items():
+ oprot.writeString(kiter106)
+ oprot.writeString(viter107)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.description is not None:
@@ -3560,41 +4090,41 @@ class SkewedInfo:
if fid == 1:
if ftype == TType.LIST:
self.skewedColNames = []
- (_etype104, _size101) = iprot.readListBegin()
- for _i105 in xrange(_size101):
- _elem106 = iprot.readString()
- self.skewedColNames.append(_elem106)
+ (_etype111, _size108) = iprot.readListBegin()
+ for _i112 in xrange(_size108):
+ _elem113 = iprot.readString()
+ self.skewedColNames.append(_elem113)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.LIST:
self.skewedColValues = []
- (_etype110, _size107) = iprot.readListBegin()
- for _i111 in xrange(_size107):
- _elem112 = []
- (_etype116, _size113) = iprot.readListBegin()
- for _i117 in xrange(_size113):
- _elem118 = iprot.readString()
- _elem112.append(_elem118)
+ (_etype117, _size114) = iprot.readListBegin()
+ for _i118 in xrange(_size114):
+ _elem119 = []
+ (_etype123, _size120) = iprot.readListBegin()
+ for _i124 in xrange(_size120):
+ _elem125 = iprot.readString()
+ _elem119.append(_elem125)
iprot.readListEnd()
- self.skewedColValues.append(_elem112)
+ self.skewedColValues.append(_elem119)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.MAP:
self.skewedColValueLocationMaps = {}
- (_ktype120, _vtype121, _size119 ) = iprot.readMapBegin()
- for _i123 in xrange(_size119):
- _key124 = []
- (_etype129, _size126) = iprot.readListBegin()
- for _i130 in xrange(_size126):
- _elem131 = iprot.readString()
- _key124.append(_elem131)
+ (_ktype127, _vtype128, _size126 ) = iprot.readMapBegin()
+ for _i130 in xrange(_size126):
+ _key131 = []
+ (_etype136, _size133) = iprot.readListBegin()
+ for _i137 in xrange(_size133):
+ _elem138 = iprot.readString()
+ _key131.append(_elem138)
iprot.readListEnd()
- _val125 = iprot.readString()
- self.skewedColValueLocationMaps[_key124] = _val125
+ _val132 = iprot.readString()
+ self.skewedColValueLocationMaps[_key131] = _val132
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -3611,29 +4141,29 @@ class SkewedInfo:
if self.skewedColNames is not None:
oprot.writeFieldBegin('skewedColNames', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.skewedColNames))
- for iter132 in self.skewedColNames:
- oprot.writeString(iter132)
+ for iter139 in self.skewedColNames:
+ oprot.writeString(iter139)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.skewedColValues is not None:
oprot.writeFieldBegin('skewedColValues', TType.LIST, 2)
oprot.writeListBegin(TType.LIST, len(self.skewedColValues))
- for iter133 in self.skewedColValues:
- oprot.writeListBegin(TType.STRING, len(iter133))
- for iter134 in iter133:
- oprot.writeString(iter134)
+ for iter140 in self.skewedColValues:
+ oprot.writeListBegin(TType.STRING, len(iter140))
+ for iter141 in iter140:
+ oprot.writeString(iter141)
oprot.writeListEnd()
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.skewedColValueLocationMaps is not None:
oprot.writeFieldBegin('skewedColValueLocationMaps', TType.MAP, 3)
oprot.writeMapBegin(TType.LIST, TType.STRING, len(self.skewedColValueLocationMaps))
- for kiter135,viter136 in self.skewedColValueLocationMaps.items():
- oprot.writeListBegin(TType.STRING, len(kiter135))
- for iter137 in kiter135:
- oprot.writeString(iter137)
+ for kiter142,viter143 in self.skewedColValueLocationMaps.items():
+ oprot.writeListBegin(TType.STRING, len(kiter142))
+ for iter144 in kiter142:
+ oprot.writeString(iter144)
oprot.writeListEnd()
- oprot.writeString(viter136)
+ oprot.writeString(viter143)
oprot.writeMapEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -3720,11 +4250,11 @@ class StorageDescriptor:
if fid == 1:
if ftype == TType.LIST:
self.cols = []
- (_etype141, _size138) = iprot.readListBegin()
- for _i142 in xrange(_size138):
- _elem143 = FieldSchema()
- _elem143.read(iprot)
- self.cols.append(_elem143)
+ (_etype148, _size145) = iprot.readListBegin()
+ for _i149 in xrange(_size145):
+ _elem150 = FieldSchema()
+ _elem150.read(iprot)
+ self.cols.append(_elem150)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -3762,32 +4292,32 @@ class StorageDescriptor:
elif fid == 8:
if ftype == TType.LIST:
self.bucketCols = []
- (_etype147, _size144) = iprot.readListBegin()
- for _i148 in xrange(_size144):
- _elem149 = iprot.readString()
- self.bucketCols.append(_elem149)
+ (_etype154, _size151) = iprot.readListBegin()
+ for _i155 in xrange(_size151):
+ _elem156 = iprot.readString()
+ self.bucketCols.append(_elem156)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 9:
if ftype == TType.LIST:
self.sortCols = []
- (_etype153, _size150) = iprot.readListBegin()
- for _i154 in xrange(_size150):
- _elem155 = Order()
- _elem155.read(iprot)
- self.sortCols.append(_elem155)
+ (_etype160, _size157) = iprot.readListBegin()
+ for _i161 in xrange(_size157):
+ _elem162 = Order()
+ _elem162.read(iprot)
+ self.sortCols.append(_elem162)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 10:
if ftype == TType.MAP:
self.parameters = {}
- (_ktype157, _vtype158, _size156 ) = iprot.readMapBegin()
- for _i160 in xrange(_size156):
- _key161 = iprot.readString()
- _val162 = iprot.readString()
- self.parameters[_key161] = _val162
+ (_ktype164, _vtype165, _size163 ) = iprot.readMapBegin()
+ for _i167 in xrange(_size163):
+ _key168 = iprot.readString()
+ _val169 = iprot.readString()
+ self.parameters[_key168] = _val169
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -3815,8 +4345,8 @@ class StorageDescriptor:
if self.cols is not None:
oprot.writeFieldBegin('cols', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.cols))
- for iter163 in self.cols:
- iter163.write(oprot)
+ for iter170 in self.cols:
+ iter170.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.location is not None:
@@ -3846,23 +4376,23 @@ class StorageDescriptor:
if self.bucketCols is not None:
oprot.writeFieldBegin('bucketCols', TType.LIST, 8)
oprot.writeListBegin(TType.STRING, len(self.bucketCols))
- for iter164 in self.bucketCols:
- oprot.writeString(iter164)
+ for iter171 in self.bucketCols:
+ oprot.writeString(iter171)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.sortCols is not None:
oprot.writeFieldBegin('sortCols', TType.LIST, 9)
oprot.writeListBegin(TType.STRUCT, len(self.sortCols))
- for iter165 in self.sortCols:
- iter165.write(oprot)
+ for iter172 in self.sortCols:
+ iter172.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.parameters is not None:
oprot.writeFieldBegin('parameters', TType.MAP, 10)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.parameters))
- for kiter166,viter167 in self.parameters.items():
- oprot.writeString(kiter166)
- oprot.writeString(viter167)
+ for kiter173,viter174 in self.parameters.items():
+ oprot.writeString(kiter173)
+ oprot.writeString(viter174)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.skewedInfo is not None:
@@ -3926,6 +4456,7 @@ class Table:
- temporary
- rewriteEnabled
- creationMetadata
+ - catName
"""
thrift_spec = (
@@ -3946,9 +4477,10 @@ class Table:
(14, TType.BOOL, 'temporary', None, False, ), # 14
(15, TType.BOOL, 'rewriteEnabled', None, None, ), # 15
(16, TType.STRUCT, 'creationMetadata', (CreationMetadata, CreationMetadata.thrift_spec), None, ), # 16
+ (17, TType.STRING, 'catName', None, None, ), # 17
)
- def __init__(self, tableName=None, dbName=None, owner=None, createTime=None, lastAccessTime=None, retention=None, sd=None, partitionKeys=None, parameters=None, viewOriginalText=None, viewExpandedText=None, tableType=None, privileges=None, temporary=thrift_spec[14][4], rewriteEnabled=None, creationMetadata=None,):
+ def __init__(self, tableName=None, dbName=None, owner=None, createTime=None, lastAccessTime=None, retention=None, sd=None, partitionKeys=None, parameters=None, viewOriginalText=None, viewExpandedText=None, tableType=None, privileges=None, temporary=thrift_spec[14][4], rewriteEnabled=None, creationMetadata=None, catName=None,):
self.tableName = tableName
self.dbName = dbName
self.owner = owner
@@ -3965,6 +4497,7 @@ class Table:
self.temporary = temporary
self.rewriteEnabled = rewriteEnabled
self.creationMetadata = creationMetadata
+ 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:
@@ -4014,22 +4547,22 @@ class Table:
elif fid == 8:
if ftype == TType.LIST:
self.partitionKeys = []
- (_etype171, _size168) = iprot.readListBegin()
- for _i172 in xrange(_size168):
- _elem173 = FieldSchema()
- _elem173.read(iprot)
- self.partitionKeys.append(_elem173)
+ (_etype178, _size175) = iprot.readListBegin()
+ for _i179 in xrange(_size175):
+ _elem180 = FieldSchema()
+ _elem180.read(iprot)
+ self.partitionKeys.append(_elem180)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 9:
if ftype == TType.MAP:
self.parameters = {}
- (_ktype175, _vtype176, _size174 ) = iprot.readMapBegin()
- for _i178 in xrange(_size174):
- _key179 = iprot.readString()
- _val180 = iprot.readString()
- self.parameters[_key179] = _val180
+ (_ktype182, _vtype183, _size181 ) = iprot.readMapBegin()
+ for _i185 in xrange(_size181):
+ _key186 = iprot.readString()
+ _val187 = iprot.readString()
+ self.parameters[_key186] = _val187
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -4070,6 +4603,11 @@ class Table:
self.creationMetadata.read(iprot)
else:
iprot.skip(ftype)
+ elif fid == 17:
+ if ftype == TType.STRING:
+ self.catName = iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -4111,16 +4649,16 @@ class Table:
if self.partitionKeys is not None:
oprot.writeFieldBegin('partitionKeys', TType.LIST, 8)
oprot.writeListBegin(TType.STRUCT, len(self.partitionKeys))
- for iter181 in self.partitionKeys:
- iter181.write(oprot)
+ for iter188 in self.partitionKeys:
+ iter188.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.parameters is not None:
oprot.writeFieldBegin('parameters', TType.MAP, 9)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.parameters))
- for kiter182,viter183 in self.parameters.items():
- oprot.writeString(kiter182)
- oprot.writeString(viter183)
+ for kiter189,viter190 in self.parameters.items():
+ oprot.writeString(kiter189)
+ oprot.writeString(viter190)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.viewOriginalText is not None:
@@ -4151,6 +4689,10 @@ class Table:
oprot.writeFieldBegin('creationMetadata', TType.STRUCT, 16)
self.creationMetadata.write(oprot)
oprot.writeFieldEnd()
+ if self.catName is not None:
+ oprot.writeFieldBegin('catName', TType.STRING, 17)
+ oprot.writeString(self.catName)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -4176,6 +4718,7 @@ class Table:
value = (value * 31) ^ hash(self.temporary)
value = (value * 31) ^ hash(self.rewriteEnabled)
value = (value * 31) ^ hash(self.creationMetadata)
+ value = (value * 31) ^ hash(self.catName)
return value
def __repr__(self):
@@ -4200,6 +4743,7 @@ class Partition:
- sd
- parameters
- privileges
+ - catName
"""
thrift_spec = (
@@ -4212,9 +4756,10 @@ class Partition:
(6, TType.STRUCT, 'sd', (StorageDescriptor, StorageDescriptor.thrift_spec), None, ), # 6
(7, TType.MAP, 'parameters', (TType.STRING,None,TType.STRING,None), None, ), # 7
(8, TType.STRUCT, 'privileges', (PrincipalPrivilegeSet, PrincipalPrivilegeSet.thrift_spec), None, ), # 8
+ (9, TType.STRING, 'catName', None, None, ), # 9
)
- def __init__(self, values=None, dbName=None, tableName=None, createTime=None, lastAccessTime=None, sd=None, parameters=None, privileges=None,):
+ def __init__(self, values=None, dbName=None, tableName=None, createTime=None, lastAccessTime=None, sd=None, parameters=None, privileges=None, catName=None,):
self.values = values
self.dbName = dbName
self.tableName = tableName
@@ -4223,6 +4768,7 @@ class Partition:
self.sd = sd
self.parameters = parameters
self.privileges = privileges
+ 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:
@@ -4236,10 +4782,10 @@ class Partition:
if fid == 1:
if ftype == TType.LIST:
self.values = []
- (_etype187, _size184) = iprot.readListBegin()
- for _i188 in xrange(_size184):
- _elem189 = iprot.readString()
- self.values.append(_elem189)
+ (_etype194, _size191) = iprot.readListBegin()
+ for _i195 in xrange(_size191):
+ _elem196 = iprot.readString()
+ self.values.append(_elem196)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -4272,11 +4818,11 @@ class Partition:
elif fid == 7:
if ftype == TType.MAP:
self.parameters = {}
- (_ktype191, _vtype192, _size190 ) = iprot.readMapBegin()
- for _i194 in xrange(_size190):
- _key195 = iprot.readString()
- _val196 = iprot.readString()
- self.parameters[_key195] = _val196
+ (_ktype198, _vtype199, _size197 ) = iprot.readMapBegin()
+ for _i201 in xrange(_size197):
+ _key202 = iprot.readString()
+ _val203 = iprot.readString()
+ self.parameters[_key202] = _val203
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -4286,6 +4832,11 @@ class Partition:
self.privileges.read(iprot)
else:
iprot.skip(ftype)
+ elif fid == 9:
+ if ftype == TType.STRING:
+ self.catName = iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -4299,8 +4850,8 @@ class Partition:
if self.values is not None:
oprot.writeFieldBegin('values', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.values))
- for iter197 in self.values:
- oprot.writeString(iter197)
+ for iter204 in self.values:
+ oprot.writeString(iter204)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.dbName is not None:
@@ -4326,15 +4877,19 @@ class Partition:
if self.parameters is not None:
oprot.writeFieldBegin('parameters', TType.MAP, 7)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.parameters))
- for kiter198,viter199 in self.parameters.items():
- oprot.writeString(kiter198)
- oprot.writeString(viter199)
+ for kiter205,viter206 in self.parameters.items():
+ oprot.writeString(kiter205)
+ oprot.writeString(viter206)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.privileges is not None:
oprot.writeFieldBegin('privileges', TType.STRUCT, 8)
self.privileges.write(oprot)
oprot.writeFieldEnd()
+ if self.catName is not None:
+ oprot.writeFieldBegin('catName', TType.STRING, 9)
+ oprot.writeString(self.catName)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -4352,6 +4907,7 @@ class Partition:
value = (value * 31) ^ hash(self.sd)
value = (value * 31) ^ hash(self.parameters)
value = (value * 31) ^ hash(self.privileges)
+ value = (value * 31) ^ hash(self.catName)
return value
def __repr__(self):
@@ -4406,10 +4962,10 @@ class PartitionWithoutSD:
if fid == 1:
if ftype == TType.LIST:
self.values = []
- (_etype203, _size200) = iprot.readListBegin()
- for _i204 in xrange(_size200):
- _elem205 = iprot.readString()
- self.values.append(_elem205)
+ (_etype210, _size207) = iprot.readListBegin()
+ for _i211 in xrange(_size207):
+ _elem212 = iprot.readString()
+ self.values.append(_elem212)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -4431,11 +4987,11 @@ class PartitionWithoutSD:
elif fid == 5:
if ftype == TType.MAP:
self.parameters = {}
- (_ktype207, _vtype208, _size206 ) = iprot.readMapBegin()
- for _i210 in xrange(_size206):
- _key211 = iprot.readString()
- _val212 = iprot.readString()
- self.parameters[_key211] = _val212
+ (_ktype214, _vtype215, _size213 ) = iprot.readMapBegin()
+ for _i217 in xrange(_size213):
+ _key218 = iprot.readString()
+ _val219 = iprot.readString()
+ self.parameters[_key218] = _val219
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -4458,8 +5014,8 @@ class PartitionWithoutSD:
if self.values is not None:
oprot.writeFieldBegin('values', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.values))
- for iter213 in self.values:
- oprot.writeString(iter213)
+ for iter220 in self.values:
+ oprot.writeString(iter220)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.createTime is not None:
@@ -4477,9 +5033,9 @@ class PartitionWithoutSD:
if self.parameters is not None:
oprot.writeFieldBegin('parameters', TType.MAP, 5)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.parameters))
- for kiter214,viter215 in self.parameters.items():
- oprot.writeString(kiter214)
- oprot.writeString(viter215)
+ for kiter221,viter222 in self.parameters.items():
+ oprot.writeString(kiter221)
+ oprot.writeString(viter222)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.privileges is not None:
@@ -4543,11 +5099,11 @@ class PartitionSpecWithSharedSD:
if fid == 1:
if ftype == TType.LIST:
self.partitions = []
- (_etype219, _size216) = iprot.readListBegin()
- for _i220 in xrange(_size216):
- _elem221 = PartitionWithoutSD()
- _elem221.read(iprot)
- self.partitions.append(_elem221)
+ (_etype226, _size223) = iprot.readListBegin()
+ for _i227 in xrange(_size223):
+ _elem228 = PartitionWithoutSD()
+ _elem228.read(iprot)
+ self.partitions.append(_elem228)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -4570,8 +5126,8 @@ class PartitionSpecWithSharedSD:
if self.partitions is not None:
oprot.writeFieldBegin('partitions', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.partitions))
- for iter222 in self.partitions:
- iter222.write(oprot)
+ for iter229 in self.partitions:
+ iter229.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.sd is not None:
@@ -4628,11 +5184,11 @@ class PartitionListComposingSpec:
if fid == 1:
if ftype == TType.LIST:
self.partitions = []
- (_etype226, _size223) = iprot.readListBegin()
- for _i227 in xrange(_size223):
- _elem228 = Partition()
- _elem228.read(iprot)
- self.partitions.append(_elem228)
+ (_etype233, _size230) = iprot.readListBegin()
+ for _i234 in xrange(_size230):
+ _elem235 = Partition()
+ _elem235.read(iprot)
+ self.partitions.append(_elem235)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -4649,8 +5205,8 @@ class PartitionListComposingSpec:
if self.partitions is not None:
oprot.writeFieldBegin('partitions', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.partitions))
- for iter229 in self.partitions:
- iter229.write(oprot)
+ for iter236 in self.partitions:
+ iter236.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -4684,6 +5240,7 @@ class PartitionSpec:
- rootPath
- sharedSDPartitionSpec
- partitionList
+ - catName
"""
thrift_spec = (
@@ -4693,14 +5250,16 @@ class PartitionSpec:
(3, TType.STRING, 'rootPath', None, None, ), # 3
(4, TType.STRUCT, 'sharedSDPartitionSpec', (PartitionSpecWithSharedSD, PartitionSpecWithSharedSD.thrift_spec), None, ), # 4
(5, TType.STRUCT, 'partitionList', (PartitionListComposingSpec, PartitionListComposingSpec.thrift_spec), None, ), # 5
+ (6, TType.STRING, 'catName', None, None, ), # 6
)
- def __init__(self, dbName=None, tableName=None, rootPath=None, sharedSDPartitionSpec=None, partitionList=None,):
+ def __init__(self, dbName=None, tableName=None, rootPath=None, sharedSDPartitionSpec=None, partitionList=None, catName=None,):
self.dbName = dbName
self.tableName = tableName
self.rootPath = rootPath
self.sharedSDPartitionSpec = sharedSDPartitionSpec
self.partitionList = partitionList
+ 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:
@@ -4738,6 +5297,11 @@ class PartitionSpec:
self.partitionList.read(iprot)
else:
iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.STRING:
+ self.catName = iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -4768,6 +5332,10 @@ class PartitionSpec:
oprot.writeFieldBegin('partitionList', TType.STRUCT, 5)
self.partitionList.write(oprot)
oprot.writeFieldEnd()
+ if self.catName is not None:
+ oprot.writeFieldBegin('catName', TType.STRING, 6)
+ oprot.writeString(self.catName)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -4782,6 +5350,7 @@ class PartitionSpec:
value = (value * 31) ^ hash(self.rootPath)
value = (value * 31) ^ hash(self.sharedSDPartitionSpec)
value = (value * 31) ^ hash(self.partitionList)
+ value = (value * 31) ^ hash(self.catName)
return value
def __repr__(self):
@@ -6034,6 +6603,7 @@ class ColumnStatisticsDesc:
- tableName
- partName
- lastAnalyzed
+ - catName
"""
thrift_spec = (
@@ -6043,14 +6613,16 @@ class ColumnStatisticsDesc:
(3, TType.STRING, 'tableName', None, None, ), # 3
(4, TType.STRING, 'partName', None, None, ), # 4
(5, TType.I64, 'lastAnalyzed', None, None, ), # 5
+ (6, TType.STRING, 'catName', None, None, ), # 6
)
- def __init__(self, isTblLevel=None, dbName=None, tableName=None, partName=None, lastAnalyzed=None,):
+ def __init__(self, isTblLevel=None, dbName=None, tableName=None, partName=None, lastAnalyzed=None, catName=None,):
self.isTblLevel = isTblLevel
self.dbName = dbName
self.tableName = tableName
self.partName = partName
self.lastAnalyzed = lastAnalyzed
+ 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:
@@ -6086,6 +6658,11 @@ class ColumnStatisticsDesc:
self.lastAnalyzed = iprot.readI64()
else:
iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.STRING:
+ self.catName = iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -6116,6 +6693,10 @@ class ColumnStatisticsDesc:
oprot.writeFieldBegin('lastAnalyzed', TType.I64, 5)
oprot.writeI64(self.lastAnalyzed)
oprot.writeFieldEnd()
+ if self.catName is not None:
+ oprot.writeFieldBegin('catName', TType.STRING, 6)
+ oprot.writeString(self.catName)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -6136,6 +6717,7 @@ class ColumnStatisticsDesc:
value = (value * 31) ^ hash(self.tableName)
value = (value * 31) ^ hash(self.partName)
value = (value * 31) ^ hash(self.lastAnalyzed)
+ value = (value * 31) ^ hash(self.catName)
return value
def __repr__(self):
@@ -6184,11 +6766,11 @@ class ColumnStatistics:
elif fid == 2:
if ftype == TType.LIST:
self.statsObj = []
- (_etype233, _size230) = iprot.readListBegin()
- for _i234 in xrange(_size230):
- _elem235 = ColumnStatisticsObj()
- _elem235.read(iprot)
- self.statsObj.append(_elem235)
+ (_etype240, _size237) = iprot.readListBegin()
+ for _i241 in xrange(_size237):
+ _elem242 = ColumnStatisticsObj()
+ _elem242.read(iprot)
+ self.statsObj.append(_elem242)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -6209,8 +6791,8 @@ class ColumnStatistics:
if self.statsObj is not None:
oprot.writeFieldBegin('statsObj', TType.LIST, 2)
oprot.writeListBegin(TType.STRUCT, len(self.statsObj))
- for iter236 in self.statsObj:
- iter236.write(oprot)
+ for iter243 in self.statsObj:
+ iter243.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -6270,11 +6852,11 @@ class AggrStats:
if fid == 1:
if ftype == TType.LIST:
self.colStats = []
- (_etype240, _size237) = iprot.readListBegin()
- for _i241 in xrange(_size237):
- _elem242 = ColumnStatisticsObj()
- _elem242.read(iprot)
- self.colStats.append(_elem242)
+ (_etype247, _size244) = iprot.readListBegin()
+ for _i248 in xrange(_size244):
+ _elem249 = ColumnStatisticsObj()
+ _elem249.read(iprot)
+ self.colStats.append(_elem249)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -6296,8 +6878,8 @@ class AggrStats:
if self.colStats is not None:
oprot.writeFieldBegin('colStats', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.colStats))
- for iter243 in self.colStats:
- iter243.write(oprot)
+ for iter250 in self.colStats:
+ iter250.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.partsFound is not None:
@@ -6361,11 +6943,11 @@ class SetPartitionsStatsRequest:
if fid == 1:
if ftype == TType.LIST:
self.colStats = []
- (_etype247, _size244) = iprot.readListBegin()
- for _i248 in xrange(_size244):
- _elem249 = ColumnStatistics()
- _elem249.read(iprot)
- self.colStats.append(_elem249)
+ (_etype254, _size251) = iprot.readListBegin()
+ for _i255 in xrange(_size251):
+ _elem256 = ColumnStatistics()
+ _elem256.read(iprot)
+ self.colStats.append(_elem256)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -6387,8 +6969,8 @@ class SetPartitionsStatsRequest:
if self.colStats is not None:
oprot.writeFieldBegin('colStats', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.colStats))
- for iter250 in self.colStats:
- iter250.write(oprot)
+ for iter257 in self.colStats:
+ iter257.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.needMerge is not None:
@@ -6450,22 +7032,22 @@ class Schema:
if fid == 1:
if ftype == TType.LIST:
self.fieldSchemas = []
- (_etype254, _size251) = iprot.readListBegin()
- for _i255 in xrange(_size251):
- _elem256 = FieldSchema()
- _elem256.read(iprot)
- self.fieldSchemas.append(_elem256)
+ (_etype261, _size258) = iprot.readListBegin()
+ for _i262 in xrange(_size258):
+ _elem263 = FieldSchema()
+ _elem263.read(iprot)
+ self.fieldSchemas.append(_elem263)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.MAP:
self.properties = {}
- (_ktype258, _vtype259, _size257 ) = iprot.readMapBegin()
- for _i261 in xrange(_size257):
- _key262 = iprot.readString()
- _val263 = iprot.readString()
- self.properties[_key262] = _val263
+ (_ktype265, _vtype266, _size264 ) = iprot.readMapBegin()
+ for _i268 in xrange(_size264):
+ _key269 = iprot.readString()
+ _val270 = iprot.readString()
+ self.properties[_key269] = _val270
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -6482,16 +7064,16 @@ class Schema:
if self.fieldSchemas is not None:
oprot.writeFieldBegin('fieldSchemas', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.fieldSchemas))
- for iter264 in self.fieldSchemas:
- iter264.write(oprot)
+ for iter271 in self.fieldSchemas:
+ iter271.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.properties is not None:
oprot.writeFieldBegin('properties', TType.MAP, 2)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.properties))
- for kiter265,viter266 in self.properties.items():
- oprot.writeString(kiter265)
- oprot.writeString(viter266)
+ for kiter272,viter273 in self.properties.items():
+ oprot.writeString(kiter272)
+ oprot.writeString(viter273)
oprot.writeMapEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -6544,11 +7126,11 @@ class EnvironmentContext:
if fid == 1:
if ftype == TType.MAP:
self.properties = {}
- (_ktype268, _vtype269, _size267 ) = iprot.readMapBegin()
- for _i271 in xrange(_size267):
- _key272 = iprot.readString()
- _val273 = iprot.readString()
- self.properties[_key272] = _val273
+ (_ktype275, _vtype276, _size274 ) = iprot.readMapBegin()
+ for _i278 in xrange(_size274):
+ _key279 = iprot.readString()
+ _val280 = iprot.readString()
+ self.properties[_key279] = _val280
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -6565,9 +7147,9 @@ class EnvironmentContext:
if self.properties is not None:
oprot.writeFieldBegin('properties', TType.MAP, 1)
oprot.writeMapBegin(
<TRUNCATED>