http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py ---------------------------------------------------------------------- diff --cc metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py index 22c0cc6,10778f2..6f157d8 --- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py +++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py @@@ -14858,6 -14695,183 +14927,183 @@@ class get_tables_result def __ne__(self, other): return not (self == other) + class get_tables_by_type_args: + """ + Attributes: + - db_name + - pattern + - tableType + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'db_name', None, None, ), # 1 + (2, TType.STRING, 'pattern', None, None, ), # 2 + (3, TType.STRING, 'tableType', None, None, ), # 3 + ) + + def __init__(self, db_name=None, pattern=None, tableType=None,): + self.db_name = db_name + self.pattern = pattern + self.tableType = tableType + + 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.db_name = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.pattern = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.tableType = 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('get_tables_by_type_args') + if self.db_name is not None: + oprot.writeFieldBegin('db_name', TType.STRING, 1) + oprot.writeString(self.db_name) + oprot.writeFieldEnd() + if self.pattern is not None: + oprot.writeFieldBegin('pattern', TType.STRING, 2) + oprot.writeString(self.pattern) + oprot.writeFieldEnd() + if self.tableType is not None: + oprot.writeFieldBegin('tableType', TType.STRING, 3) + oprot.writeString(self.tableType) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.db_name) + value = (value * 31) ^ hash(self.pattern) + value = (value * 31) ^ hash(self.tableType) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + + class get_tables_by_type_result: + """ + Attributes: + - success + - o1 + """ + + thrift_spec = ( + (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0 + (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1 + ) + + def __init__(self, success=None, o1=None,): + self.success = success + self.o1 = o1 + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 0: + if ftype == TType.LIST: + self.success = [] - (_etype641, _size638) = iprot.readListBegin() - for _i642 in xrange(_size638): - _elem643 = iprot.readString() - self.success.append(_elem643) ++ (_etype648, _size645) = iprot.readListBegin() ++ for _i649 in xrange(_size645): ++ _elem650 = iprot.readString() ++ self.success.append(_elem650) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.o1 = MetaException() + self.o1.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('get_tables_by_type_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.LIST, 0) + oprot.writeListBegin(TType.STRING, len(self.success)) - for iter644 in self.success: - oprot.writeString(iter644) ++ for iter651 in self.success: ++ oprot.writeString(iter651) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.o1 is not None: + oprot.writeFieldBegin('o1', TType.STRUCT, 1) + self.o1.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + value = (value * 31) ^ hash(self.o1) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + class get_table_meta_args: """ Attributes: @@@ -14900,10 -14914,10 +15146,10 @@@ elif fid == 3: if ftype == TType.LIST: self.tbl_types = [] -- (_etype648, _size645) = iprot.readListBegin() -- for _i649 in xrange(_size645): -- _elem650 = iprot.readString() -- self.tbl_types.append(_elem650) ++ (_etype655, _size652) = iprot.readListBegin() ++ for _i656 in xrange(_size652): ++ _elem657 = iprot.readString() ++ self.tbl_types.append(_elem657) iprot.readListEnd() else: iprot.skip(ftype) @@@ -14928,8 -14942,8 +15174,8 @@@ if self.tbl_types is not None: oprot.writeFieldBegin('tbl_types', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.tbl_types)) -- for iter651 in self.tbl_types: -- oprot.writeString(iter651) ++ for iter658 in self.tbl_types: ++ oprot.writeString(iter658) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@@ -14985,11 -14999,11 +15231,11 @@@ class get_table_meta_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype655, _size652) = iprot.readListBegin() -- for _i656 in xrange(_size652): -- _elem657 = TableMeta() -- _elem657.read(iprot) -- self.success.append(_elem657) ++ (_etype662, _size659) = iprot.readListBegin() ++ for _i663 in xrange(_size659): ++ _elem664 = TableMeta() ++ _elem664.read(iprot) ++ self.success.append(_elem664) iprot.readListEnd() else: iprot.skip(ftype) @@@ -15012,8 -15026,8 +15258,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) -- for iter658 in self.success: -- iter658.write(oprot) ++ for iter665 in self.success: ++ iter665.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -15137,10 -15151,10 +15383,10 @@@ class get_all_tables_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype662, _size659) = iprot.readListBegin() -- for _i663 in xrange(_size659): -- _elem664 = iprot.readString() -- self.success.append(_elem664) ++ (_etype669, _size666) = iprot.readListBegin() ++ for _i670 in xrange(_size666): ++ _elem671 = iprot.readString() ++ self.success.append(_elem671) iprot.readListEnd() else: iprot.skip(ftype) @@@ -15163,8 -15177,8 +15409,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) -- for iter665 in self.success: -- oprot.writeString(iter665) ++ for iter672 in self.success: ++ oprot.writeString(iter672) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -15400,10 -15414,10 +15646,10 @@@ class get_table_objects_by_name_args elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] -- (_etype669, _size666) = iprot.readListBegin() -- for _i670 in xrange(_size666): -- _elem671 = iprot.readString() -- self.tbl_names.append(_elem671) ++ (_etype676, _size673) = iprot.readListBegin() ++ for _i677 in xrange(_size673): ++ _elem678 = iprot.readString() ++ self.tbl_names.append(_elem678) iprot.readListEnd() else: iprot.skip(ftype) @@@ -15424,8 -15438,8 +15670,8 @@@ if self.tbl_names is not None: oprot.writeFieldBegin('tbl_names', TType.LIST, 2) oprot.writeListBegin(TType.STRING, len(self.tbl_names)) -- for iter672 in self.tbl_names: -- oprot.writeString(iter672) ++ for iter679 in self.tbl_names: ++ oprot.writeString(iter679) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@@ -15486,11 -15500,11 +15732,11 @@@ class get_table_objects_by_name_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype676, _size673) = iprot.readListBegin() -- for _i677 in xrange(_size673): -- _elem678 = Table() -- _elem678.read(iprot) -- self.success.append(_elem678) ++ (_etype683, _size680) = iprot.readListBegin() ++ for _i684 in xrange(_size680): ++ _elem685 = Table() ++ _elem685.read(iprot) ++ self.success.append(_elem685) iprot.readListEnd() else: iprot.skip(ftype) @@@ -15525,8 -15539,8 +15771,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) -- for iter679 in self.success: -- iter679.write(oprot) ++ for iter686 in self.success: ++ iter686.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -15692,10 -15706,10 +15938,10 @@@ class get_table_names_by_filter_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype683, _size680) = iprot.readListBegin() -- for _i684 in xrange(_size680): -- _elem685 = iprot.readString() -- self.success.append(_elem685) ++ (_etype690, _size687) = iprot.readListBegin() ++ for _i691 in xrange(_size687): ++ _elem692 = iprot.readString() ++ self.success.append(_elem692) iprot.readListEnd() else: iprot.skip(ftype) @@@ -15730,8 -15744,8 +15976,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) -- for iter686 in self.success: -- oprot.writeString(iter686) ++ for iter693 in self.success: ++ oprot.writeString(iter693) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -16701,11 -16715,11 +16947,11 @@@ class add_partitions_args if fid == 1: if ftype == TType.LIST: self.new_parts = [] -- (_etype690, _size687) = iprot.readListBegin() -- for _i691 in xrange(_size687): -- _elem692 = Partition() -- _elem692.read(iprot) -- self.new_parts.append(_elem692) ++ (_etype697, _size694) = iprot.readListBegin() ++ for _i698 in xrange(_size694): ++ _elem699 = Partition() ++ _elem699.read(iprot) ++ self.new_parts.append(_elem699) iprot.readListEnd() else: iprot.skip(ftype) @@@ -16722,8 -16736,8 +16968,8 @@@ if self.new_parts is not None: oprot.writeFieldBegin('new_parts', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.new_parts)) -- for iter693 in self.new_parts: -- iter693.write(oprot) ++ for iter700 in self.new_parts: ++ iter700.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@@ -16881,11 -16895,11 +17127,11 @@@ class add_partitions_pspec_args if fid == 1: if ftype == TType.LIST: self.new_parts = [] -- (_etype697, _size694) = iprot.readListBegin() -- for _i698 in xrange(_size694): -- _elem699 = PartitionSpec() -- _elem699.read(iprot) -- self.new_parts.append(_elem699) ++ (_etype704, _size701) = iprot.readListBegin() ++ for _i705 in xrange(_size701): ++ _elem706 = PartitionSpec() ++ _elem706.read(iprot) ++ self.new_parts.append(_elem706) iprot.readListEnd() else: iprot.skip(ftype) @@@ -16902,8 -16916,8 +17148,8 @@@ if self.new_parts is not None: oprot.writeFieldBegin('new_parts', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.new_parts)) -- for iter700 in self.new_parts: -- iter700.write(oprot) ++ for iter707 in self.new_parts: ++ iter707.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@@ -17077,10 -17091,10 +17323,10 @@@ class append_partition_args elif fid == 3: if ftype == TType.LIST: self.part_vals = [] -- (_etype704, _size701) = iprot.readListBegin() -- for _i705 in xrange(_size701): -- _elem706 = iprot.readString() -- self.part_vals.append(_elem706) ++ (_etype711, _size708) = iprot.readListBegin() ++ for _i712 in xrange(_size708): ++ _elem713 = iprot.readString() ++ self.part_vals.append(_elem713) iprot.readListEnd() else: iprot.skip(ftype) @@@ -17105,8 -17119,8 +17351,8 @@@ if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) -- for iter707 in self.part_vals: -- oprot.writeString(iter707) ++ for iter714 in self.part_vals: ++ oprot.writeString(iter714) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@@ -17459,10 -17473,10 +17705,10 @@@ class append_partition_with_environment elif fid == 3: if ftype == TType.LIST: self.part_vals = [] -- (_etype711, _size708) = iprot.readListBegin() -- for _i712 in xrange(_size708): -- _elem713 = iprot.readString() -- self.part_vals.append(_elem713) ++ (_etype718, _size715) = iprot.readListBegin() ++ for _i719 in xrange(_size715): ++ _elem720 = iprot.readString() ++ self.part_vals.append(_elem720) iprot.readListEnd() else: iprot.skip(ftype) @@@ -17493,8 -17507,8 +17739,8 @@@ if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) -- for iter714 in self.part_vals: -- oprot.writeString(iter714) ++ for iter721 in self.part_vals: ++ oprot.writeString(iter721) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@@ -18089,10 -18103,10 +18335,10 @@@ class drop_partition_args elif fid == 3: if ftype == TType.LIST: self.part_vals = [] -- (_etype718, _size715) = iprot.readListBegin() -- for _i719 in xrange(_size715): -- _elem720 = iprot.readString() -- self.part_vals.append(_elem720) ++ (_etype725, _size722) = iprot.readListBegin() ++ for _i726 in xrange(_size722): ++ _elem727 = iprot.readString() ++ self.part_vals.append(_elem727) iprot.readListEnd() else: iprot.skip(ftype) @@@ -18122,8 -18136,8 +18368,8 @@@ if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) -- for iter721 in self.part_vals: -- oprot.writeString(iter721) ++ for iter728 in self.part_vals: ++ oprot.writeString(iter728) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@@ -18296,10 -18310,10 +18542,10 @@@ class drop_partition_with_environment_c elif fid == 3: if ftype == TType.LIST: self.part_vals = [] -- (_etype725, _size722) = iprot.readListBegin() -- for _i726 in xrange(_size722): -- _elem727 = iprot.readString() -- self.part_vals.append(_elem727) ++ (_etype732, _size729) = iprot.readListBegin() ++ for _i733 in xrange(_size729): ++ _elem734 = iprot.readString() ++ self.part_vals.append(_elem734) iprot.readListEnd() else: iprot.skip(ftype) @@@ -18335,8 -18349,8 +18581,8 @@@ if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) -- for iter728 in self.part_vals: -- oprot.writeString(iter728) ++ for iter735 in self.part_vals: ++ oprot.writeString(iter735) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@@ -19073,10 -19087,10 +19319,10 @@@ class get_partition_args elif fid == 3: if ftype == TType.LIST: self.part_vals = [] -- (_etype732, _size729) = iprot.readListBegin() -- for _i733 in xrange(_size729): -- _elem734 = iprot.readString() -- self.part_vals.append(_elem734) ++ (_etype739, _size736) = iprot.readListBegin() ++ for _i740 in xrange(_size736): ++ _elem741 = iprot.readString() ++ self.part_vals.append(_elem741) iprot.readListEnd() else: iprot.skip(ftype) @@@ -19101,8 -19115,8 +19347,8 @@@ if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) -- for iter735 in self.part_vals: -- oprot.writeString(iter735) ++ for iter742 in self.part_vals: ++ oprot.writeString(iter742) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@@ -19261,11 -19275,11 +19507,11 @@@ class exchange_partition_args if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} -- (_ktype737, _vtype738, _size736 ) = iprot.readMapBegin() -- for _i740 in xrange(_size736): -- _key741 = iprot.readString() -- _val742 = iprot.readString() -- self.partitionSpecs[_key741] = _val742 ++ (_ktype744, _vtype745, _size743 ) = iprot.readMapBegin() ++ for _i747 in xrange(_size743): ++ _key748 = iprot.readString() ++ _val749 = iprot.readString() ++ self.partitionSpecs[_key748] = _val749 iprot.readMapEnd() else: iprot.skip(ftype) @@@ -19302,9 -19316,9 +19548,9 @@@ if self.partitionSpecs is not None: oprot.writeFieldBegin('partitionSpecs', TType.MAP, 1) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.partitionSpecs)) -- for kiter743,viter744 in self.partitionSpecs.items(): -- oprot.writeString(kiter743) -- oprot.writeString(viter744) ++ for kiter750,viter751 in self.partitionSpecs.items(): ++ oprot.writeString(kiter750) ++ oprot.writeString(viter751) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@@ -19509,11 -19523,11 +19755,11 @@@ class exchange_partitions_args if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} -- (_ktype746, _vtype747, _size745 ) = iprot.readMapBegin() -- for _i749 in xrange(_size745): -- _key750 = iprot.readString() -- _val751 = iprot.readString() -- self.partitionSpecs[_key750] = _val751 ++ (_ktype753, _vtype754, _size752 ) = iprot.readMapBegin() ++ for _i756 in xrange(_size752): ++ _key757 = iprot.readString() ++ _val758 = iprot.readString() ++ self.partitionSpecs[_key757] = _val758 iprot.readMapEnd() else: iprot.skip(ftype) @@@ -19550,9 -19564,9 +19796,9 @@@ if self.partitionSpecs is not None: oprot.writeFieldBegin('partitionSpecs', TType.MAP, 1) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.partitionSpecs)) -- for kiter752,viter753 in self.partitionSpecs.items(): -- oprot.writeString(kiter752) -- oprot.writeString(viter753) ++ for kiter759,viter760 in self.partitionSpecs.items(): ++ oprot.writeString(kiter759) ++ oprot.writeString(viter760) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@@ -19635,11 -19649,11 +19881,11 @@@ class exchange_partitions_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype757, _size754) = iprot.readListBegin() -- for _i758 in xrange(_size754): -- _elem759 = Partition() -- _elem759.read(iprot) -- self.success.append(_elem759) ++ (_etype764, _size761) = iprot.readListBegin() ++ for _i765 in xrange(_size761): ++ _elem766 = Partition() ++ _elem766.read(iprot) ++ self.success.append(_elem766) iprot.readListEnd() else: iprot.skip(ftype) @@@ -19680,8 -19694,8 +19926,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) -- for iter760 in self.success: -- iter760.write(oprot) ++ for iter767 in self.success: ++ iter767.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -19775,10 -19789,10 +20021,10 @@@ class get_partition_with_auth_args elif fid == 3: if ftype == TType.LIST: self.part_vals = [] -- (_etype764, _size761) = iprot.readListBegin() -- for _i765 in xrange(_size761): -- _elem766 = iprot.readString() -- self.part_vals.append(_elem766) ++ (_etype771, _size768) = iprot.readListBegin() ++ for _i772 in xrange(_size768): ++ _elem773 = iprot.readString() ++ self.part_vals.append(_elem773) iprot.readListEnd() else: iprot.skip(ftype) @@@ -19790,10 -19804,10 +20036,10 @@@ elif fid == 5: if ftype == TType.LIST: self.group_names = [] -- (_etype770, _size767) = iprot.readListBegin() -- for _i771 in xrange(_size767): -- _elem772 = iprot.readString() -- self.group_names.append(_elem772) ++ (_etype777, _size774) = iprot.readListBegin() ++ for _i778 in xrange(_size774): ++ _elem779 = iprot.readString() ++ self.group_names.append(_elem779) iprot.readListEnd() else: iprot.skip(ftype) @@@ -19818,8 -19832,8 +20064,8 @@@ if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) -- for iter773 in self.part_vals: -- oprot.writeString(iter773) ++ for iter780 in self.part_vals: ++ oprot.writeString(iter780) oprot.writeListEnd() oprot.writeFieldEnd() if self.user_name is not None: @@@ -19829,8 -19843,8 +20075,8 @@@ if self.group_names is not None: oprot.writeFieldBegin('group_names', TType.LIST, 5) oprot.writeListBegin(TType.STRING, len(self.group_names)) -- for iter774 in self.group_names: -- oprot.writeString(iter774) ++ for iter781 in self.group_names: ++ oprot.writeString(iter781) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@@ -20259,11 -20273,11 +20505,11 @@@ class get_partitions_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype778, _size775) = iprot.readListBegin() -- for _i779 in xrange(_size775): -- _elem780 = Partition() -- _elem780.read(iprot) -- self.success.append(_elem780) ++ (_etype785, _size782) = iprot.readListBegin() ++ for _i786 in xrange(_size782): ++ _elem787 = Partition() ++ _elem787.read(iprot) ++ self.success.append(_elem787) iprot.readListEnd() else: iprot.skip(ftype) @@@ -20292,8 -20306,8 +20538,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) -- for iter781 in self.success: -- iter781.write(oprot) ++ for iter788 in self.success: ++ iter788.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -20387,10 -20401,10 +20633,10 @@@ class get_partitions_with_auth_args elif fid == 5: if ftype == TType.LIST: self.group_names = [] -- (_etype785, _size782) = iprot.readListBegin() -- for _i786 in xrange(_size782): -- _elem787 = iprot.readString() -- self.group_names.append(_elem787) ++ (_etype792, _size789) = iprot.readListBegin() ++ for _i793 in xrange(_size789): ++ _elem794 = iprot.readString() ++ self.group_names.append(_elem794) iprot.readListEnd() else: iprot.skip(ftype) @@@ -20423,8 -20437,8 +20669,8 @@@ if self.group_names is not None: oprot.writeFieldBegin('group_names', TType.LIST, 5) oprot.writeListBegin(TType.STRING, len(self.group_names)) -- for iter788 in self.group_names: -- oprot.writeString(iter788) ++ for iter795 in self.group_names: ++ oprot.writeString(iter795) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@@ -20485,11 -20499,11 +20731,11 @@@ class get_partitions_with_auth_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype792, _size789) = iprot.readListBegin() -- for _i793 in xrange(_size789): -- _elem794 = Partition() -- _elem794.read(iprot) -- self.success.append(_elem794) ++ (_etype799, _size796) = iprot.readListBegin() ++ for _i800 in xrange(_size796): ++ _elem801 = Partition() ++ _elem801.read(iprot) ++ self.success.append(_elem801) iprot.readListEnd() else: iprot.skip(ftype) @@@ -20518,8 -20532,8 +20764,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) -- for iter795 in self.success: -- iter795.write(oprot) ++ for iter802 in self.success: ++ iter802.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -20677,11 -20691,11 +20923,11 @@@ class get_partitions_pspec_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype799, _size796) = iprot.readListBegin() -- for _i800 in xrange(_size796): -- _elem801 = PartitionSpec() -- _elem801.read(iprot) -- self.success.append(_elem801) ++ (_etype806, _size803) = iprot.readListBegin() ++ for _i807 in xrange(_size803): ++ _elem808 = PartitionSpec() ++ _elem808.read(iprot) ++ self.success.append(_elem808) iprot.readListEnd() else: iprot.skip(ftype) @@@ -20710,8 -20724,8 +20956,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) -- for iter802 in self.success: -- iter802.write(oprot) ++ for iter809 in self.success: ++ iter809.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -20866,10 -20880,10 +21112,10 @@@ class get_partition_names_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype806, _size803) = iprot.readListBegin() -- for _i807 in xrange(_size803): -- _elem808 = iprot.readString() -- self.success.append(_elem808) ++ (_etype813, _size810) = iprot.readListBegin() ++ for _i814 in xrange(_size810): ++ _elem815 = iprot.readString() ++ self.success.append(_elem815) iprot.readListEnd() else: iprot.skip(ftype) @@@ -20892,8 -20906,8 +21138,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) -- for iter809 in self.success: -- oprot.writeString(iter809) ++ for iter816 in self.success: ++ oprot.writeString(iter816) oprot.writeListEnd() oprot.writeFieldEnd() if self.o2 is not None: @@@ -20969,10 -20983,10 +21215,10 @@@ class get_partitions_ps_args elif fid == 3: if ftype == TType.LIST: self.part_vals = [] -- (_etype813, _size810) = iprot.readListBegin() -- for _i814 in xrange(_size810): -- _elem815 = iprot.readString() -- self.part_vals.append(_elem815) ++ (_etype820, _size817) = iprot.readListBegin() ++ for _i821 in xrange(_size817): ++ _elem822 = iprot.readString() ++ self.part_vals.append(_elem822) iprot.readListEnd() else: iprot.skip(ftype) @@@ -21002,8 -21016,8 +21248,8 @@@ if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) -- for iter816 in self.part_vals: -- oprot.writeString(iter816) ++ for iter823 in self.part_vals: ++ oprot.writeString(iter823) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@@ -21067,11 -21081,11 +21313,11 @@@ class get_partitions_ps_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype820, _size817) = iprot.readListBegin() -- for _i821 in xrange(_size817): -- _elem822 = Partition() -- _elem822.read(iprot) -- self.success.append(_elem822) ++ (_etype827, _size824) = iprot.readListBegin() ++ for _i828 in xrange(_size824): ++ _elem829 = Partition() ++ _elem829.read(iprot) ++ self.success.append(_elem829) iprot.readListEnd() else: iprot.skip(ftype) @@@ -21100,8 -21114,8 +21346,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) -- for iter823 in self.success: -- iter823.write(oprot) ++ for iter830 in self.success: ++ iter830.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -21188,10 -21202,10 +21434,10 @@@ class get_partitions_ps_with_auth_args elif fid == 3: if ftype == TType.LIST: self.part_vals = [] -- (_etype827, _size824) = iprot.readListBegin() -- for _i828 in xrange(_size824): -- _elem829 = iprot.readString() -- self.part_vals.append(_elem829) ++ (_etype834, _size831) = iprot.readListBegin() ++ for _i835 in xrange(_size831): ++ _elem836 = iprot.readString() ++ self.part_vals.append(_elem836) iprot.readListEnd() else: iprot.skip(ftype) @@@ -21208,10 -21222,10 +21454,10 @@@ elif fid == 6: if ftype == TType.LIST: self.group_names = [] -- (_etype833, _size830) = iprot.readListBegin() -- for _i834 in xrange(_size830): -- _elem835 = iprot.readString() -- self.group_names.append(_elem835) ++ (_etype840, _size837) = iprot.readListBegin() ++ for _i841 in xrange(_size837): ++ _elem842 = iprot.readString() ++ self.group_names.append(_elem842) iprot.readListEnd() else: iprot.skip(ftype) @@@ -21236,8 -21250,8 +21482,8 @@@ if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) -- for iter836 in self.part_vals: -- oprot.writeString(iter836) ++ for iter843 in self.part_vals: ++ oprot.writeString(iter843) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@@ -21251,8 -21265,8 +21497,8 @@@ if self.group_names is not None: oprot.writeFieldBegin('group_names', TType.LIST, 6) oprot.writeListBegin(TType.STRING, len(self.group_names)) -- for iter837 in self.group_names: -- oprot.writeString(iter837) ++ for iter844 in self.group_names: ++ oprot.writeString(iter844) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@@ -21314,11 -21328,11 +21560,11 @@@ class get_partitions_ps_with_auth_resul if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype841, _size838) = iprot.readListBegin() -- for _i842 in xrange(_size838): -- _elem843 = Partition() -- _elem843.read(iprot) -- self.success.append(_elem843) ++ (_etype848, _size845) = iprot.readListBegin() ++ for _i849 in xrange(_size845): ++ _elem850 = Partition() ++ _elem850.read(iprot) ++ self.success.append(_elem850) iprot.readListEnd() else: iprot.skip(ftype) @@@ -21347,8 -21361,8 +21593,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) -- for iter844 in self.success: -- iter844.write(oprot) ++ for iter851 in self.success: ++ iter851.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -21429,10 -21443,10 +21675,10 @@@ class get_partition_names_ps_args elif fid == 3: if ftype == TType.LIST: self.part_vals = [] -- (_etype848, _size845) = iprot.readListBegin() -- for _i849 in xrange(_size845): -- _elem850 = iprot.readString() -- self.part_vals.append(_elem850) ++ (_etype855, _size852) = iprot.readListBegin() ++ for _i856 in xrange(_size852): ++ _elem857 = iprot.readString() ++ self.part_vals.append(_elem857) iprot.readListEnd() else: iprot.skip(ftype) @@@ -21462,8 -21476,8 +21708,8 @@@ if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) -- for iter851 in self.part_vals: -- oprot.writeString(iter851) ++ for iter858 in self.part_vals: ++ oprot.writeString(iter858) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@@ -21527,10 -21541,10 +21773,10 @@@ class get_partition_names_ps_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype855, _size852) = iprot.readListBegin() -- for _i856 in xrange(_size852): -- _elem857 = iprot.readString() -- self.success.append(_elem857) ++ (_etype862, _size859) = iprot.readListBegin() ++ for _i863 in xrange(_size859): ++ _elem864 = iprot.readString() ++ self.success.append(_elem864) iprot.readListEnd() else: iprot.skip(ftype) @@@ -21559,8 -21573,8 +21805,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) -- for iter858 in self.success: -- oprot.writeString(iter858) ++ for iter865 in self.success: ++ oprot.writeString(iter865) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -21731,11 -21745,11 +21977,11 @@@ class get_partitions_by_filter_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype862, _size859) = iprot.readListBegin() -- for _i863 in xrange(_size859): -- _elem864 = Partition() -- _elem864.read(iprot) -- self.success.append(_elem864) ++ (_etype869, _size866) = iprot.readListBegin() ++ for _i870 in xrange(_size866): ++ _elem871 = Partition() ++ _elem871.read(iprot) ++ self.success.append(_elem871) iprot.readListEnd() else: iprot.skip(ftype) @@@ -21764,8 -21778,8 +22010,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) -- for iter865 in self.success: -- iter865.write(oprot) ++ for iter872 in self.success: ++ iter872.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -21936,11 -21950,11 +22182,11 @@@ class get_part_specs_by_filter_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype869, _size866) = iprot.readListBegin() -- for _i870 in xrange(_size866): -- _elem871 = PartitionSpec() -- _elem871.read(iprot) -- self.success.append(_elem871) ++ (_etype876, _size873) = iprot.readListBegin() ++ for _i877 in xrange(_size873): ++ _elem878 = PartitionSpec() ++ _elem878.read(iprot) ++ self.success.append(_elem878) iprot.readListEnd() else: iprot.skip(ftype) @@@ -21969,8 -21983,8 +22215,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) -- for iter872 in self.success: -- iter872.write(oprot) ++ for iter879 in self.success: ++ iter879.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -22390,10 -22404,10 +22636,10 @@@ class get_partitions_by_names_args elif fid == 3: if ftype == TType.LIST: self.names = [] -- (_etype876, _size873) = iprot.readListBegin() -- for _i877 in xrange(_size873): -- _elem878 = iprot.readString() -- self.names.append(_elem878) ++ (_etype883, _size880) = iprot.readListBegin() ++ for _i884 in xrange(_size880): ++ _elem885 = iprot.readString() ++ self.names.append(_elem885) iprot.readListEnd() else: iprot.skip(ftype) @@@ -22418,8 -22432,8 +22664,8 @@@ if self.names is not None: oprot.writeFieldBegin('names', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.names)) -- for iter879 in self.names: -- oprot.writeString(iter879) ++ for iter886 in self.names: ++ oprot.writeString(iter886) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@@ -22478,11 -22492,11 +22724,11 @@@ class get_partitions_by_names_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype883, _size880) = iprot.readListBegin() -- for _i884 in xrange(_size880): -- _elem885 = Partition() -- _elem885.read(iprot) -- self.success.append(_elem885) ++ (_etype890, _size887) = iprot.readListBegin() ++ for _i891 in xrange(_size887): ++ _elem892 = Partition() ++ _elem892.read(iprot) ++ self.success.append(_elem892) iprot.readListEnd() else: iprot.skip(ftype) @@@ -22511,8 -22525,8 +22757,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) -- for iter886 in self.success: -- iter886.write(oprot) ++ for iter893 in self.success: ++ iter893.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -22762,11 -22776,11 +23008,11 @@@ class alter_partitions_args elif fid == 3: if ftype == TType.LIST: self.new_parts = [] -- (_etype890, _size887) = iprot.readListBegin() -- for _i891 in xrange(_size887): -- _elem892 = Partition() -- _elem892.read(iprot) -- self.new_parts.append(_elem892) ++ (_etype897, _size894) = iprot.readListBegin() ++ for _i898 in xrange(_size894): ++ _elem899 = Partition() ++ _elem899.read(iprot) ++ self.new_parts.append(_elem899) iprot.readListEnd() else: iprot.skip(ftype) @@@ -22791,8 -22805,8 +23037,8 @@@ if self.new_parts is not None: oprot.writeFieldBegin('new_parts', TType.LIST, 3) oprot.writeListBegin(TType.STRUCT, len(self.new_parts)) -- for iter893 in self.new_parts: -- iter893.write(oprot) ++ for iter900 in self.new_parts: ++ iter900.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@@ -22945,11 -22959,11 +23191,11 @@@ class alter_partitions_with_environment elif fid == 3: if ftype == TType.LIST: self.new_parts = [] -- (_etype897, _size894) = iprot.readListBegin() -- for _i898 in xrange(_size894): -- _elem899 = Partition() -- _elem899.read(iprot) -- self.new_parts.append(_elem899) ++ (_etype904, _size901) = iprot.readListBegin() ++ for _i905 in xrange(_size901): ++ _elem906 = Partition() ++ _elem906.read(iprot) ++ self.new_parts.append(_elem906) iprot.readListEnd() else: iprot.skip(ftype) @@@ -22980,8 -22994,8 +23226,8 @@@ if self.new_parts is not None: oprot.writeFieldBegin('new_parts', TType.LIST, 3) oprot.writeListBegin(TType.STRUCT, len(self.new_parts)) -- for iter900 in self.new_parts: -- iter900.write(oprot) ++ for iter907 in self.new_parts: ++ iter907.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@@ -23325,10 -23339,10 +23571,10 @@@ class rename_partition_args elif fid == 3: if ftype == TType.LIST: self.part_vals = [] -- (_etype904, _size901) = iprot.readListBegin() -- for _i905 in xrange(_size901): -- _elem906 = iprot.readString() -- self.part_vals.append(_elem906) ++ (_etype911, _size908) = iprot.readListBegin() ++ for _i912 in xrange(_size908): ++ _elem913 = iprot.readString() ++ self.part_vals.append(_elem913) iprot.readListEnd() else: iprot.skip(ftype) @@@ -23359,8 -23373,8 +23605,8 @@@ if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) -- for iter907 in self.part_vals: -- oprot.writeString(iter907) ++ for iter914 in self.part_vals: ++ oprot.writeString(iter914) oprot.writeListEnd() oprot.writeFieldEnd() if self.new_part is not None: @@@ -23502,10 -23516,10 +23748,10 @@@ class partition_name_has_valid_characte if fid == 1: if ftype == TType.LIST: self.part_vals = [] -- (_etype911, _size908) = iprot.readListBegin() -- for _i912 in xrange(_size908): -- _elem913 = iprot.readString() -- self.part_vals.append(_elem913) ++ (_etype918, _size915) = iprot.readListBegin() ++ for _i919 in xrange(_size915): ++ _elem920 = iprot.readString() ++ self.part_vals.append(_elem920) iprot.readListEnd() else: iprot.skip(ftype) @@@ -23527,8 -23541,8 +23773,8 @@@ if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 1) oprot.writeListBegin(TType.STRING, len(self.part_vals)) -- for iter914 in self.part_vals: -- oprot.writeString(iter914) ++ for iter921 in self.part_vals: ++ oprot.writeString(iter921) oprot.writeListEnd() oprot.writeFieldEnd() if self.throw_exception is not None: @@@ -23886,10 -23900,10 +24132,10 @@@ class partition_name_to_vals_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype918, _size915) = iprot.readListBegin() -- for _i919 in xrange(_size915): -- _elem920 = iprot.readString() -- self.success.append(_elem920) ++ (_etype925, _size922) = iprot.readListBegin() ++ for _i926 in xrange(_size922): ++ _elem927 = iprot.readString() ++ self.success.append(_elem927) iprot.readListEnd() else: iprot.skip(ftype) @@@ -23912,8 -23926,8 +24158,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) -- for iter921 in self.success: -- oprot.writeString(iter921) ++ for iter928 in self.success: ++ oprot.writeString(iter928) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -24037,11 -24051,11 +24283,11 @@@ class partition_name_to_spec_result if fid == 0: if ftype == TType.MAP: self.success = {} -- (_ktype923, _vtype924, _size922 ) = iprot.readMapBegin() -- for _i926 in xrange(_size922): -- _key927 = iprot.readString() -- _val928 = iprot.readString() -- self.success[_key927] = _val928 ++ (_ktype930, _vtype931, _size929 ) = iprot.readMapBegin() ++ for _i933 in xrange(_size929): ++ _key934 = iprot.readString() ++ _val935 = iprot.readString() ++ self.success[_key934] = _val935 iprot.readMapEnd() else: iprot.skip(ftype) @@@ -24064,9 -24078,9 +24310,9 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success)) -- for kiter929,viter930 in self.success.items(): -- oprot.writeString(kiter929) -- oprot.writeString(viter930) ++ for kiter936,viter937 in self.success.items(): ++ oprot.writeString(kiter936) ++ oprot.writeString(viter937) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -24142,11 -24156,11 +24388,11 @@@ class markPartitionForEvent_args elif fid == 3: if ftype == TType.MAP: self.part_vals = {} -- (_ktype932, _vtype933, _size931 ) = iprot.readMapBegin() -- for _i935 in xrange(_size931): -- _key936 = iprot.readString() -- _val937 = iprot.readString() -- self.part_vals[_key936] = _val937 ++ (_ktype939, _vtype940, _size938 ) = iprot.readMapBegin() ++ for _i942 in xrange(_size938): ++ _key943 = iprot.readString() ++ _val944 = iprot.readString() ++ self.part_vals[_key943] = _val944 iprot.readMapEnd() else: iprot.skip(ftype) @@@ -24176,9 -24190,9 +24422,9 @@@ if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.MAP, 3) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.part_vals)) -- for kiter938,viter939 in self.part_vals.items(): -- oprot.writeString(kiter938) -- oprot.writeString(viter939) ++ for kiter945,viter946 in self.part_vals.items(): ++ oprot.writeString(kiter945) ++ oprot.writeString(viter946) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@@ -24392,11 -24406,11 +24638,11 @@@ class isPartitionMarkedForEvent_args elif fid == 3: if ftype == TType.MAP: self.part_vals = {} -- (_ktype941, _vtype942, _size940 ) = iprot.readMapBegin() -- for _i944 in xrange(_size940): -- _key945 = iprot.readString() -- _val946 = iprot.readString() -- self.part_vals[_key945] = _val946 ++ (_ktype948, _vtype949, _size947 ) = iprot.readMapBegin() ++ for _i951 in xrange(_size947): ++ _key952 = iprot.readString() ++ _val953 = iprot.readString() ++ self.part_vals[_key952] = _val953 iprot.readMapEnd() else: iprot.skip(ftype) @@@ -24426,9 -24440,9 +24672,9 @@@ if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.MAP, 3) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.part_vals)) -- for kiter947,viter948 in self.part_vals.items(): -- oprot.writeString(kiter947) -- oprot.writeString(viter948) ++ for kiter954,viter955 in self.part_vals.items(): ++ oprot.writeString(kiter954) ++ oprot.writeString(viter955) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@@ -25483,11 -25497,11 +25729,11 @@@ class get_indexes_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype952, _size949) = iprot.readListBegin() -- for _i953 in xrange(_size949): -- _elem954 = Index() -- _elem954.read(iprot) -- self.success.append(_elem954) ++ (_etype959, _size956) = iprot.readListBegin() ++ for _i960 in xrange(_size956): ++ _elem961 = Index() ++ _elem961.read(iprot) ++ self.success.append(_elem961) iprot.readListEnd() else: iprot.skip(ftype) @@@ -25516,8 -25530,8 +25762,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) -- for iter955 in self.success: -- iter955.write(oprot) ++ for iter962 in self.success: ++ iter962.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -25672,10 -25686,10 +25918,10 @@@ class get_index_names_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype959, _size956) = iprot.readListBegin() -- for _i960 in xrange(_size956): -- _elem961 = iprot.readString() -- self.success.append(_elem961) ++ (_etype966, _size963) = iprot.readListBegin() ++ for _i967 in xrange(_size963): ++ _elem968 = iprot.readString() ++ self.success.append(_elem968) iprot.readListEnd() else: iprot.skip(ftype) @@@ -25698,8 -25712,8 +25944,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) -- for iter962 in self.success: -- oprot.writeString(iter962) ++ for iter969 in self.success: ++ oprot.writeString(iter969) oprot.writeListEnd() oprot.writeFieldEnd() if self.o2 is not None: @@@ -28565,10 -28579,10 +28811,10 @@@ class get_functions_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype966, _size963) = iprot.readListBegin() -- for _i967 in xrange(_size963): -- _elem968 = iprot.readString() -- self.success.append(_elem968) ++ (_etype973, _size970) = iprot.readListBegin() ++ for _i974 in xrange(_size970): ++ _elem975 = iprot.readString() ++ self.success.append(_elem975) iprot.readListEnd() else: iprot.skip(ftype) @@@ -28591,8 -28605,8 +28837,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) -- for iter969 in self.success: -- oprot.writeString(iter969) ++ for iter976 in self.success: ++ oprot.writeString(iter976) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -29280,10 -29294,10 +29526,10 @@@ class get_role_names_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype973, _size970) = iprot.readListBegin() -- for _i974 in xrange(_size970): -- _elem975 = iprot.readString() -- self.success.append(_elem975) ++ (_etype980, _size977) = iprot.readListBegin() ++ for _i981 in xrange(_size977): ++ _elem982 = iprot.readString() ++ self.success.append(_elem982) iprot.readListEnd() else: iprot.skip(ftype) @@@ -29306,8 -29320,8 +29552,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) -- for iter976 in self.success: -- oprot.writeString(iter976) ++ for iter983 in self.success: ++ oprot.writeString(iter983) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -29821,11 -29835,11 +30067,11 @@@ class list_roles_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype980, _size977) = iprot.readListBegin() -- for _i981 in xrange(_size977): -- _elem982 = Role() -- _elem982.read(iprot) -- self.success.append(_elem982) ++ (_etype987, _size984) = iprot.readListBegin() ++ for _i988 in xrange(_size984): ++ _elem989 = Role() ++ _elem989.read(iprot) ++ self.success.append(_elem989) iprot.readListEnd() else: iprot.skip(ftype) @@@ -29848,8 -29862,8 +30094,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) -- for iter983 in self.success: -- iter983.write(oprot) ++ for iter990 in self.success: ++ iter990.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -30358,10 -30372,10 +30604,10 @@@ class get_privilege_set_args elif fid == 3: if ftype == TType.LIST: self.group_names = [] -- (_etype987, _size984) = iprot.readListBegin() -- for _i988 in xrange(_size984): -- _elem989 = iprot.readString() -- self.group_names.append(_elem989) ++ (_etype994, _size991) = iprot.readListBegin() ++ for _i995 in xrange(_size991): ++ _elem996 = iprot.readString() ++ self.group_names.append(_elem996) iprot.readListEnd() else: iprot.skip(ftype) @@@ -30386,8 -30400,8 +30632,8 @@@ if self.group_names is not None: oprot.writeFieldBegin('group_names', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.group_names)) -- for iter990 in self.group_names: -- oprot.writeString(iter990) ++ for iter997 in self.group_names: ++ oprot.writeString(iter997) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@@ -30614,11 -30628,11 +30860,11 @@@ class list_privileges_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype994, _size991) = iprot.readListBegin() -- for _i995 in xrange(_size991): -- _elem996 = HiveObjectPrivilege() -- _elem996.read(iprot) -- self.success.append(_elem996) ++ (_etype1001, _size998) = iprot.readListBegin() ++ for _i1002 in xrange(_size998): ++ _elem1003 = HiveObjectPrivilege() ++ _elem1003.read(iprot) ++ self.success.append(_elem1003) iprot.readListEnd() else: iprot.skip(ftype) @@@ -30641,8 -30655,8 +30887,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) -- for iter997 in self.success: -- iter997.write(oprot) ++ for iter1004 in self.success: ++ iter1004.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -31140,10 -31154,10 +31386,10 @@@ class set_ugi_args elif fid == 2: if ftype == TType.LIST: self.group_names = [] -- (_etype1001, _size998) = iprot.readListBegin() -- for _i1002 in xrange(_size998): -- _elem1003 = iprot.readString() -- self.group_names.append(_elem1003) ++ (_etype1008, _size1005) = iprot.readListBegin() ++ for _i1009 in xrange(_size1005): ++ _elem1010 = iprot.readString() ++ self.group_names.append(_elem1010) iprot.readListEnd() else: iprot.skip(ftype) @@@ -31164,8 -31178,8 +31410,8 @@@ if self.group_names is not None: oprot.writeFieldBegin('group_names', TType.LIST, 2) oprot.writeListBegin(TType.STRING, len(self.group_names)) -- for iter1004 in self.group_names: -- oprot.writeString(iter1004) ++ for iter1011 in self.group_names: ++ oprot.writeString(iter1011) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@@ -31220,10 -31234,10 +31466,10 @@@ class set_ugi_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype1008, _size1005) = iprot.readListBegin() -- for _i1009 in xrange(_size1005): -- _elem1010 = iprot.readString() -- self.success.append(_elem1010) ++ (_etype1015, _size1012) = iprot.readListBegin() ++ for _i1016 in xrange(_size1012): ++ _elem1017 = iprot.readString() ++ self.success.append(_elem1017) iprot.readListEnd() else: iprot.skip(ftype) @@@ -31246,8 -31260,8 +31492,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) -- for iter1011 in self.success: -- oprot.writeString(iter1011) ++ for iter1018 in self.success: ++ oprot.writeString(iter1018) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@@ -32179,10 -32193,10 +32425,10 @@@ class get_all_token_identifiers_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype1015, _size1012) = iprot.readListBegin() -- for _i1016 in xrange(_size1012): -- _elem1017 = iprot.readString() -- self.success.append(_elem1017) ++ (_etype1022, _size1019) = iprot.readListBegin() ++ for _i1023 in xrange(_size1019): ++ _elem1024 = iprot.readString() ++ self.success.append(_elem1024) iprot.readListEnd() else: iprot.skip(ftype) @@@ -32199,8 -32213,8 +32445,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) -- for iter1018 in self.success: -- oprot.writeString(iter1018) ++ for iter1025 in self.success: ++ oprot.writeString(iter1025) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@@ -32727,10 -32741,10 +32973,10 @@@ class get_master_keys_result if fid == 0: if ftype == TType.LIST: self.success = [] -- (_etype1022, _size1019) = iprot.readListBegin() -- for _i1023 in xrange(_size1019): -- _elem1024 = iprot.readString() -- self.success.append(_elem1024) ++ (_etype1029, _size1026) = iprot.readListBegin() ++ for _i1030 in xrange(_size1026): ++ _elem1031 = iprot.readString() ++ self.success.append(_elem1031) iprot.readListEnd() else: iprot.skip(ftype) @@@ -32747,8 -32761,8 +32993,8 @@@ if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) -- for iter1025 in self.success: -- oprot.writeString(iter1025) ++ for iter1032 in self.success: ++ oprot.writeString(iter1032) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop()
http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java ---------------------------------------------------------------------- diff --cc metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java index 0e7bdf2,530d2f4..9f16eb2 --- a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java +++ b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java @@@ -47,7 -47,9 +47,8 @@@ import org.apache.hadoop.hive.common.me import org.apache.hadoop.hive.common.metrics.common.MetricsVariable; import org.apache.hadoop.hive.conf.HiveConf; import org.apache.hadoop.hive.conf.HiveConf.ConfVars; + import org.apache.hadoop.hive.metastore.TableType; import org.apache.hadoop.hive.metastore.api.*; -import org.apache.hadoop.hive.metastore.api.Table; import org.apache.hadoop.hive.metastore.events.AddIndexEvent; import org.apache.hadoop.hive.metastore.events.AddPartitionEvent; import org.apache.hadoop.hive.metastore.events.AlterIndexEvent; http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java ---------------------------------------------------------------------- diff --cc metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java index 0325854,c32486f..73e14c4 --- a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java +++ b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java @@@ -27,7 -27,105 +27,8 @@@ import org.apache.hadoop.hive.common.cl import org.apache.hadoop.hive.conf.HiveConf; import org.apache.hadoop.hive.conf.HiveConf.ConfVars; import org.apache.hadoop.hive.conf.HiveConfUtil; +import org.apache.hadoop.hive.metastore.api.*; + import org.apache.hadoop.hive.metastore.TableType; -import org.apache.hadoop.hive.metastore.api.AbortTxnRequest; -import org.apache.hadoop.hive.metastore.api.AbortTxnsRequest; -import org.apache.hadoop.hive.metastore.api.AddDynamicPartitions; -import org.apache.hadoop.hive.metastore.api.AddForeignKeyRequest; -import org.apache.hadoop.hive.metastore.api.AddPartitionsRequest; -import org.apache.hadoop.hive.metastore.api.AddPartitionsResult; -import org.apache.hadoop.hive.metastore.api.AddPrimaryKeyRequest; -import org.apache.hadoop.hive.metastore.api.AggrStats; -import org.apache.hadoop.hive.metastore.api.AlreadyExistsException; -import org.apache.hadoop.hive.metastore.api.CacheFileMetadataRequest; -import org.apache.hadoop.hive.metastore.api.CacheFileMetadataResult; -import org.apache.hadoop.hive.metastore.api.CheckLockRequest; -import org.apache.hadoop.hive.metastore.api.ClearFileMetadataRequest; -import org.apache.hadoop.hive.metastore.api.ColumnStatistics; -import org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj; -import org.apache.hadoop.hive.metastore.api.CommitTxnRequest; -import org.apache.hadoop.hive.metastore.api.CompactionRequest; -import org.apache.hadoop.hive.metastore.api.CompactionType; -import org.apache.hadoop.hive.metastore.api.ConfigValSecurityException; -import org.apache.hadoop.hive.metastore.api.CurrentNotificationEventId; -import org.apache.hadoop.hive.metastore.api.DataOperationType; -import org.apache.hadoop.hive.metastore.api.Database; -import org.apache.hadoop.hive.metastore.api.DropConstraintRequest; -import org.apache.hadoop.hive.metastore.api.DropPartitionsExpr; -import org.apache.hadoop.hive.metastore.api.DropPartitionsRequest; -import org.apache.hadoop.hive.metastore.api.EnvironmentContext; -import org.apache.hadoop.hive.metastore.api.FieldSchema; -import org.apache.hadoop.hive.metastore.api.FireEventRequest; -import org.apache.hadoop.hive.metastore.api.FireEventResponse; -import org.apache.hadoop.hive.metastore.api.ForeignKeysRequest; -import org.apache.hadoop.hive.metastore.api.Function; -import org.apache.hadoop.hive.metastore.api.GetAllFunctionsResponse; -import org.apache.hadoop.hive.metastore.api.GetFileMetadataByExprRequest; -import org.apache.hadoop.hive.metastore.api.GetFileMetadataByExprResult; -import org.apache.hadoop.hive.metastore.api.GetFileMetadataRequest; -import org.apache.hadoop.hive.metastore.api.GetFileMetadataResult; -import org.apache.hadoop.hive.metastore.api.GetOpenTxnsInfoResponse; -import org.apache.hadoop.hive.metastore.api.GetPrincipalsInRoleRequest; -import org.apache.hadoop.hive.metastore.api.GetPrincipalsInRoleResponse; -import org.apache.hadoop.hive.metastore.api.GetRoleGrantsForPrincipalRequest; -import org.apache.hadoop.hive.metastore.api.GetRoleGrantsForPrincipalResponse; -import org.apache.hadoop.hive.metastore.api.GrantRevokePrivilegeRequest; -import org.apache.hadoop.hive.metastore.api.GrantRevokePrivilegeResponse; -import org.apache.hadoop.hive.metastore.api.GrantRevokeRoleRequest; -import org.apache.hadoop.hive.metastore.api.GrantRevokeRoleResponse; -import org.apache.hadoop.hive.metastore.api.GrantRevokeType; -import org.apache.hadoop.hive.metastore.api.HeartbeatRequest; -import org.apache.hadoop.hive.metastore.api.HeartbeatTxnRangeRequest; -import org.apache.hadoop.hive.metastore.api.HeartbeatTxnRangeResponse; -import org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege; -import org.apache.hadoop.hive.metastore.api.HiveObjectRef; -import org.apache.hadoop.hive.metastore.api.Index; -import org.apache.hadoop.hive.metastore.api.InvalidInputException; -import org.apache.hadoop.hive.metastore.api.InvalidObjectException; -import org.apache.hadoop.hive.metastore.api.InvalidOperationException; -import org.apache.hadoop.hive.metastore.api.InvalidPartitionException; -import org.apache.hadoop.hive.metastore.api.LockRequest; -import org.apache.hadoop.hive.metastore.api.LockResponse; -import org.apache.hadoop.hive.metastore.api.MetaException; -import org.apache.hadoop.hive.metastore.api.MetadataPpdResult; -import org.apache.hadoop.hive.metastore.api.NoSuchLockException; -import org.apache.hadoop.hive.metastore.api.NoSuchObjectException; -import org.apache.hadoop.hive.metastore.api.NoSuchTxnException; -import org.apache.hadoop.hive.metastore.api.NotificationEvent; -import org.apache.hadoop.hive.metastore.api.NotificationEventRequest; -import org.apache.hadoop.hive.metastore.api.NotificationEventResponse; -import org.apache.hadoop.hive.metastore.api.OpenTxnRequest; -import org.apache.hadoop.hive.metastore.api.OpenTxnsResponse; -import org.apache.hadoop.hive.metastore.api.Partition; -import org.apache.hadoop.hive.metastore.api.PartitionEventType; -import org.apache.hadoop.hive.metastore.api.PartitionsByExprRequest; -import org.apache.hadoop.hive.metastore.api.PartitionsByExprResult; -import org.apache.hadoop.hive.metastore.api.PartitionsStatsRequest; -import org.apache.hadoop.hive.metastore.api.PrimaryKeysRequest; -import org.apache.hadoop.hive.metastore.api.PrincipalPrivilegeSet; -import org.apache.hadoop.hive.metastore.api.PrincipalType; -import org.apache.hadoop.hive.metastore.api.PrivilegeBag; -import org.apache.hadoop.hive.metastore.api.PutFileMetadataRequest; -import org.apache.hadoop.hive.metastore.api.RequestPartsSpec; -import org.apache.hadoop.hive.metastore.api.Role; -import org.apache.hadoop.hive.metastore.api.SQLForeignKey; -import org.apache.hadoop.hive.metastore.api.SQLPrimaryKey; -import org.apache.hadoop.hive.metastore.api.SetPartitionsStatsRequest; -import org.apache.hadoop.hive.metastore.api.ShowCompactRequest; -import org.apache.hadoop.hive.metastore.api.ShowCompactResponse; -import org.apache.hadoop.hive.metastore.api.ShowLocksRequest; -import org.apache.hadoop.hive.metastore.api.ShowLocksResponse; -import org.apache.hadoop.hive.metastore.api.Table; -import org.apache.hadoop.hive.metastore.api.TableMeta; -import org.apache.hadoop.hive.metastore.api.TableStatsRequest; -import org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore; -import org.apache.hadoop.hive.metastore.api.TxnAbortedException; -import org.apache.hadoop.hive.metastore.api.TxnOpenException; -import org.apache.hadoop.hive.metastore.api.Type; -import org.apache.hadoop.hive.metastore.api.UnknownDBException; -import org.apache.hadoop.hive.metastore.api.UnknownPartitionException; -import org.apache.hadoop.hive.metastore.api.UnknownTableException; -import org.apache.hadoop.hive.metastore.api.UnlockRequest; import org.apache.hadoop.hive.metastore.partition.spec.PartitionSpecProxy; import org.apache.hadoop.hive.metastore.txn.TxnUtils; import org.apache.hadoop.hive.shims.ShimLoader; http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/java/org/apache/hadoop/hive/metastore/RawStore.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/java/org/apache/hadoop/hive/metastore/hbase/HBaseStore.java ---------------------------------------------------------------------- diff --cc metastore/src/java/org/apache/hadoop/hive/metastore/hbase/HBaseStore.java index ddc5a62,f9fad4c..e5b469b --- a/metastore/src/java/org/apache/hadoop/hive/metastore/hbase/HBaseStore.java +++ b/metastore/src/java/org/apache/hadoop/hive/metastore/hbase/HBaseStore.java @@@ -33,8 -33,8 +33,9 @@@ import org.apache.hadoop.hive.metastore import org.apache.hadoop.hive.metastore.PartFilterExprUtil; import org.apache.hadoop.hive.metastore.PartitionExpressionProxy; import org.apache.hadoop.hive.metastore.RawStore; + import org.apache.hadoop.hive.metastore.TableType; import org.apache.hadoop.hive.metastore.Warehouse; +import org.apache.hadoop.hive.metastore.RawStore.CanNotRetry; import org.apache.hadoop.hive.metastore.api.AggrStats; import org.apache.hadoop.hive.metastore.api.ColumnStatistics; import org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj; http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreControlledCommit.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreForJdoConnection.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/754443e6/ql/src/java/org/apache/hadoop/hive/ql/parse/DDLSemanticAnalyzer.java ----------------------------------------------------------------------
