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>
