http://git-wip-us.apache.org/repos/asf/hive/blob/1c9947f3/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ttypes.py ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ttypes.py b/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ttypes.py index df3c586..489beed 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ttypes.py +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ttypes.py @@ -2504,6 +2504,194 @@ class GrantRevokePrivilegeResponse: def __ne__(self, other): return not (self == other) +class TruncateTableRequest: + """ + Attributes: + - dbName + - tableName + - partNames + - txnId + - writeId + - validWriteIdList + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'dbName', None, None, ), # 1 + (2, TType.STRING, 'tableName', None, None, ), # 2 + (3, TType.LIST, 'partNames', (TType.STRING,None), None, ), # 3 + (4, TType.I64, 'txnId', None, -1, ), # 4 + (5, TType.I64, 'writeId', None, -1, ), # 5 + (6, TType.STRING, 'validWriteIdList', None, None, ), # 6 + ) + + def __init__(self, dbName=None, tableName=None, partNames=None, txnId=thrift_spec[4][4], writeId=thrift_spec[5][4], validWriteIdList=None,): + self.dbName = dbName + self.tableName = tableName + self.partNames = partNames + self.txnId = txnId + self.writeId = writeId + self.validWriteIdList = validWriteIdList + + 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.dbName = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.tableName = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.LIST: + self.partNames = [] + (_etype72, _size69) = iprot.readListBegin() + for _i73 in xrange(_size69): + _elem74 = iprot.readString() + self.partNames.append(_elem74) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.I64: + self.txnId = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.I64: + self.writeId = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.STRING: + self.validWriteIdList = 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('TruncateTableRequest') + if self.dbName is not None: + oprot.writeFieldBegin('dbName', TType.STRING, 1) + oprot.writeString(self.dbName) + oprot.writeFieldEnd() + if self.tableName is not None: + oprot.writeFieldBegin('tableName', TType.STRING, 2) + oprot.writeString(self.tableName) + oprot.writeFieldEnd() + if self.partNames is not None: + oprot.writeFieldBegin('partNames', TType.LIST, 3) + oprot.writeListBegin(TType.STRING, len(self.partNames)) + for iter75 in self.partNames: + oprot.writeString(iter75) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.txnId is not None: + oprot.writeFieldBegin('txnId', TType.I64, 4) + oprot.writeI64(self.txnId) + oprot.writeFieldEnd() + if self.writeId is not None: + oprot.writeFieldBegin('writeId', TType.I64, 5) + oprot.writeI64(self.writeId) + oprot.writeFieldEnd() + if self.validWriteIdList is not None: + oprot.writeFieldBegin('validWriteIdList', TType.STRING, 6) + oprot.writeString(self.validWriteIdList) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.dbName is None: + raise TProtocol.TProtocolException(message='Required field dbName is unset!') + if self.tableName is None: + raise TProtocol.TProtocolException(message='Required field tableName is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.dbName) + value = (value * 31) ^ hash(self.tableName) + value = (value * 31) ^ hash(self.partNames) + value = (value * 31) ^ hash(self.txnId) + value = (value * 31) ^ hash(self.writeId) + value = (value * 31) ^ hash(self.validWriteIdList) + 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 TruncateTableResponse: + + thrift_spec = ( + ) + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('TruncateTableResponse') + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + class Role: """ Attributes: @@ -2846,11 +3034,11 @@ class GetRoleGrantsForPrincipalResponse: if fid == 1: if ftype == TType.LIST: self.principalGrants = [] - (_etype72, _size69) = iprot.readListBegin() - for _i73 in xrange(_size69): - _elem74 = RolePrincipalGrant() - _elem74.read(iprot) - self.principalGrants.append(_elem74) + (_etype79, _size76) = iprot.readListBegin() + for _i80 in xrange(_size76): + _elem81 = RolePrincipalGrant() + _elem81.read(iprot) + self.principalGrants.append(_elem81) iprot.readListEnd() else: iprot.skip(ftype) @@ -2867,8 +3055,8 @@ class GetRoleGrantsForPrincipalResponse: if self.principalGrants is not None: oprot.writeFieldBegin('principalGrants', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.principalGrants)) - for iter75 in self.principalGrants: - iter75.write(oprot) + for iter82 in self.principalGrants: + iter82.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -2989,11 +3177,11 @@ class GetPrincipalsInRoleResponse: if fid == 1: if ftype == TType.LIST: self.principalGrants = [] - (_etype79, _size76) = iprot.readListBegin() - for _i80 in xrange(_size76): - _elem81 = RolePrincipalGrant() - _elem81.read(iprot) - self.principalGrants.append(_elem81) + (_etype86, _size83) = iprot.readListBegin() + for _i87 in xrange(_size83): + _elem88 = RolePrincipalGrant() + _elem88.read(iprot) + self.principalGrants.append(_elem88) iprot.readListEnd() else: iprot.skip(ftype) @@ -3010,8 +3198,8 @@ class GetPrincipalsInRoleResponse: if self.principalGrants is not None: oprot.writeFieldBegin('principalGrants', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.principalGrants)) - for iter82 in self.principalGrants: - iter82.write(oprot) + for iter89 in self.principalGrants: + iter89.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -3640,10 +3828,10 @@ class GetCatalogsResponse: 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) + (_etype93, _size90) = iprot.readListBegin() + for _i94 in xrange(_size90): + _elem95 = iprot.readString() + self.names.append(_elem95) iprot.readListEnd() else: iprot.skip(ftype) @@ -3660,8 +3848,8 @@ class 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) + for iter96 in self.names: + oprot.writeString(iter96) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -3814,11 +4002,11 @@ class Database: 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 + (_ktype98, _vtype99, _size97 ) = iprot.readMapBegin() + for _i101 in xrange(_size97): + _key102 = iprot.readString() + _val103 = iprot.readString() + self.parameters[_key102] = _val103 iprot.readMapEnd() else: iprot.skip(ftype) @@ -3868,9 +4056,9 @@ class Database: 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) + for kiter104,viter105 in self.parameters.items(): + oprot.writeString(kiter104) + oprot.writeString(viter105) oprot.writeMapEnd() oprot.writeFieldEnd() if self.privileges is not None: @@ -3973,11 +4161,11 @@ class SerDeInfo: 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 + (_ktype107, _vtype108, _size106 ) = iprot.readMapBegin() + for _i110 in xrange(_size106): + _key111 = iprot.readString() + _val112 = iprot.readString() + self.parameters[_key111] = _val112 iprot.readMapEnd() else: iprot.skip(ftype) @@ -4022,9 +4210,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 kiter106,viter107 in self.parameters.items(): - oprot.writeString(kiter106) - oprot.writeString(viter107) + for kiter113,viter114 in self.parameters.items(): + oprot.writeString(kiter113) + oprot.writeString(viter114) oprot.writeMapEnd() oprot.writeFieldEnd() if self.description is not None: @@ -4182,41 +4370,41 @@ class SkewedInfo: if fid == 1: if ftype == TType.LIST: self.skewedColNames = [] - (_etype111, _size108) = iprot.readListBegin() - for _i112 in xrange(_size108): - _elem113 = iprot.readString() - self.skewedColNames.append(_elem113) + (_etype118, _size115) = iprot.readListBegin() + for _i119 in xrange(_size115): + _elem120 = iprot.readString() + self.skewedColNames.append(_elem120) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.LIST: self.skewedColValues = [] - (_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) + (_etype124, _size121) = iprot.readListBegin() + for _i125 in xrange(_size121): + _elem126 = [] + (_etype130, _size127) = iprot.readListBegin() + for _i131 in xrange(_size127): + _elem132 = iprot.readString() + _elem126.append(_elem132) iprot.readListEnd() - self.skewedColValues.append(_elem119) + self.skewedColValues.append(_elem126) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.MAP: self.skewedColValueLocationMaps = {} - (_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) + (_ktype134, _vtype135, _size133 ) = iprot.readMapBegin() + for _i137 in xrange(_size133): + _key138 = [] + (_etype143, _size140) = iprot.readListBegin() + for _i144 in xrange(_size140): + _elem145 = iprot.readString() + _key138.append(_elem145) iprot.readListEnd() - _val132 = iprot.readString() - self.skewedColValueLocationMaps[_key131] = _val132 + _val139 = iprot.readString() + self.skewedColValueLocationMaps[_key138] = _val139 iprot.readMapEnd() else: iprot.skip(ftype) @@ -4233,29 +4421,29 @@ class SkewedInfo: if self.skewedColNames is not None: oprot.writeFieldBegin('skewedColNames', TType.LIST, 1) oprot.writeListBegin(TType.STRING, len(self.skewedColNames)) - for iter139 in self.skewedColNames: - oprot.writeString(iter139) + for iter146 in self.skewedColNames: + oprot.writeString(iter146) oprot.writeListEnd() oprot.writeFieldEnd() if self.skewedColValues is not None: oprot.writeFieldBegin('skewedColValues', TType.LIST, 2) oprot.writeListBegin(TType.LIST, len(self.skewedColValues)) - for iter140 in self.skewedColValues: - oprot.writeListBegin(TType.STRING, len(iter140)) - for iter141 in iter140: - oprot.writeString(iter141) + for iter147 in self.skewedColValues: + oprot.writeListBegin(TType.STRING, len(iter147)) + for iter148 in iter147: + oprot.writeString(iter148) 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 kiter142,viter143 in self.skewedColValueLocationMaps.items(): - oprot.writeListBegin(TType.STRING, len(kiter142)) - for iter144 in kiter142: - oprot.writeString(iter144) + for kiter149,viter150 in self.skewedColValueLocationMaps.items(): + oprot.writeListBegin(TType.STRING, len(kiter149)) + for iter151 in kiter149: + oprot.writeString(iter151) oprot.writeListEnd() - oprot.writeString(viter143) + oprot.writeString(viter150) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -4342,11 +4530,11 @@ class StorageDescriptor: if fid == 1: if ftype == TType.LIST: self.cols = [] - (_etype148, _size145) = iprot.readListBegin() - for _i149 in xrange(_size145): - _elem150 = FieldSchema() - _elem150.read(iprot) - self.cols.append(_elem150) + (_etype155, _size152) = iprot.readListBegin() + for _i156 in xrange(_size152): + _elem157 = FieldSchema() + _elem157.read(iprot) + self.cols.append(_elem157) iprot.readListEnd() else: iprot.skip(ftype) @@ -4384,32 +4572,32 @@ class StorageDescriptor: elif fid == 8: if ftype == TType.LIST: self.bucketCols = [] - (_etype154, _size151) = iprot.readListBegin() - for _i155 in xrange(_size151): - _elem156 = iprot.readString() - self.bucketCols.append(_elem156) + (_etype161, _size158) = iprot.readListBegin() + for _i162 in xrange(_size158): + _elem163 = iprot.readString() + self.bucketCols.append(_elem163) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 9: if ftype == TType.LIST: self.sortCols = [] - (_etype160, _size157) = iprot.readListBegin() - for _i161 in xrange(_size157): - _elem162 = Order() - _elem162.read(iprot) - self.sortCols.append(_elem162) + (_etype167, _size164) = iprot.readListBegin() + for _i168 in xrange(_size164): + _elem169 = Order() + _elem169.read(iprot) + self.sortCols.append(_elem169) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 10: if ftype == TType.MAP: self.parameters = {} - (_ktype164, _vtype165, _size163 ) = iprot.readMapBegin() - for _i167 in xrange(_size163): - _key168 = iprot.readString() - _val169 = iprot.readString() - self.parameters[_key168] = _val169 + (_ktype171, _vtype172, _size170 ) = iprot.readMapBegin() + for _i174 in xrange(_size170): + _key175 = iprot.readString() + _val176 = iprot.readString() + self.parameters[_key175] = _val176 iprot.readMapEnd() else: iprot.skip(ftype) @@ -4437,8 +4625,8 @@ class StorageDescriptor: if self.cols is not None: oprot.writeFieldBegin('cols', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.cols)) - for iter170 in self.cols: - iter170.write(oprot) + for iter177 in self.cols: + iter177.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.location is not None: @@ -4468,23 +4656,23 @@ class StorageDescriptor: if self.bucketCols is not None: oprot.writeFieldBegin('bucketCols', TType.LIST, 8) oprot.writeListBegin(TType.STRING, len(self.bucketCols)) - for iter171 in self.bucketCols: - oprot.writeString(iter171) + for iter178 in self.bucketCols: + oprot.writeString(iter178) oprot.writeListEnd() oprot.writeFieldEnd() if self.sortCols is not None: oprot.writeFieldBegin('sortCols', TType.LIST, 9) oprot.writeListBegin(TType.STRUCT, len(self.sortCols)) - for iter172 in self.sortCols: - iter172.write(oprot) + for iter179 in self.sortCols: + iter179.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 kiter173,viter174 in self.parameters.items(): - oprot.writeString(kiter173) - oprot.writeString(viter174) + for kiter180,viter181 in self.parameters.items(): + oprot.writeString(kiter180) + oprot.writeString(viter181) oprot.writeMapEnd() oprot.writeFieldEnd() if self.skewedInfo is not None: @@ -4648,22 +4836,22 @@ class Table: elif fid == 8: if ftype == TType.LIST: self.partitionKeys = [] - (_etype178, _size175) = iprot.readListBegin() - for _i179 in xrange(_size175): - _elem180 = FieldSchema() - _elem180.read(iprot) - self.partitionKeys.append(_elem180) + (_etype185, _size182) = iprot.readListBegin() + for _i186 in xrange(_size182): + _elem187 = FieldSchema() + _elem187.read(iprot) + self.partitionKeys.append(_elem187) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 9: if ftype == TType.MAP: self.parameters = {} - (_ktype182, _vtype183, _size181 ) = iprot.readMapBegin() - for _i185 in xrange(_size181): - _key186 = iprot.readString() - _val187 = iprot.readString() - self.parameters[_key186] = _val187 + (_ktype189, _vtype190, _size188 ) = iprot.readMapBegin() + for _i192 in xrange(_size188): + _key193 = iprot.readString() + _val194 = iprot.readString() + self.parameters[_key193] = _val194 iprot.readMapEnd() else: iprot.skip(ftype) @@ -4765,16 +4953,16 @@ class Table: if self.partitionKeys is not None: oprot.writeFieldBegin('partitionKeys', TType.LIST, 8) oprot.writeListBegin(TType.STRUCT, len(self.partitionKeys)) - for iter188 in self.partitionKeys: - iter188.write(oprot) + for iter195 in self.partitionKeys: + iter195.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 kiter189,viter190 in self.parameters.items(): - oprot.writeString(kiter189) - oprot.writeString(viter190) + for kiter196,viter197 in self.parameters.items(): + oprot.writeString(kiter196) + oprot.writeString(viter197) oprot.writeMapEnd() oprot.writeFieldEnd() if self.viewOriginalText is not None: @@ -4919,10 +5107,10 @@ class Partition: if fid == 1: if ftype == TType.LIST: self.values = [] - (_etype194, _size191) = iprot.readListBegin() - for _i195 in xrange(_size191): - _elem196 = iprot.readString() - self.values.append(_elem196) + (_etype201, _size198) = iprot.readListBegin() + for _i202 in xrange(_size198): + _elem203 = iprot.readString() + self.values.append(_elem203) iprot.readListEnd() else: iprot.skip(ftype) @@ -4955,11 +5143,11 @@ class Partition: elif fid == 7: if ftype == TType.MAP: self.parameters = {} - (_ktype198, _vtype199, _size197 ) = iprot.readMapBegin() - for _i201 in xrange(_size197): - _key202 = iprot.readString() - _val203 = iprot.readString() - self.parameters[_key202] = _val203 + (_ktype205, _vtype206, _size204 ) = iprot.readMapBegin() + for _i208 in xrange(_size204): + _key209 = iprot.readString() + _val210 = iprot.readString() + self.parameters[_key209] = _val210 iprot.readMapEnd() else: iprot.skip(ftype) @@ -4997,8 +5185,8 @@ class Partition: if self.values is not None: oprot.writeFieldBegin('values', TType.LIST, 1) oprot.writeListBegin(TType.STRING, len(self.values)) - for iter204 in self.values: - oprot.writeString(iter204) + for iter211 in self.values: + oprot.writeString(iter211) oprot.writeListEnd() oprot.writeFieldEnd() if self.dbName is not None: @@ -5024,9 +5212,9 @@ class Partition: if self.parameters is not None: oprot.writeFieldBegin('parameters', TType.MAP, 7) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.parameters)) - for kiter205,viter206 in self.parameters.items(): - oprot.writeString(kiter205) - oprot.writeString(viter206) + for kiter212,viter213 in self.parameters.items(): + oprot.writeString(kiter212) + oprot.writeString(viter213) oprot.writeMapEnd() oprot.writeFieldEnd() if self.privileges is not None: @@ -5119,10 +5307,10 @@ class PartitionWithoutSD: if fid == 1: if ftype == TType.LIST: self.values = [] - (_etype210, _size207) = iprot.readListBegin() - for _i211 in xrange(_size207): - _elem212 = iprot.readString() - self.values.append(_elem212) + (_etype217, _size214) = iprot.readListBegin() + for _i218 in xrange(_size214): + _elem219 = iprot.readString() + self.values.append(_elem219) iprot.readListEnd() else: iprot.skip(ftype) @@ -5144,11 +5332,11 @@ class PartitionWithoutSD: elif fid == 5: if ftype == TType.MAP: self.parameters = {} - (_ktype214, _vtype215, _size213 ) = iprot.readMapBegin() - for _i217 in xrange(_size213): - _key218 = iprot.readString() - _val219 = iprot.readString() - self.parameters[_key218] = _val219 + (_ktype221, _vtype222, _size220 ) = iprot.readMapBegin() + for _i224 in xrange(_size220): + _key225 = iprot.readString() + _val226 = iprot.readString() + self.parameters[_key225] = _val226 iprot.readMapEnd() else: iprot.skip(ftype) @@ -5171,8 +5359,8 @@ class PartitionWithoutSD: if self.values is not None: oprot.writeFieldBegin('values', TType.LIST, 1) oprot.writeListBegin(TType.STRING, len(self.values)) - for iter220 in self.values: - oprot.writeString(iter220) + for iter227 in self.values: + oprot.writeString(iter227) oprot.writeListEnd() oprot.writeFieldEnd() if self.createTime is not None: @@ -5190,9 +5378,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 kiter221,viter222 in self.parameters.items(): - oprot.writeString(kiter221) - oprot.writeString(viter222) + for kiter228,viter229 in self.parameters.items(): + oprot.writeString(kiter228) + oprot.writeString(viter229) oprot.writeMapEnd() oprot.writeFieldEnd() if self.privileges is not None: @@ -5256,11 +5444,11 @@ class PartitionSpecWithSharedSD: if fid == 1: if ftype == TType.LIST: self.partitions = [] - (_etype226, _size223) = iprot.readListBegin() - for _i227 in xrange(_size223): - _elem228 = PartitionWithoutSD() - _elem228.read(iprot) - self.partitions.append(_elem228) + (_etype233, _size230) = iprot.readListBegin() + for _i234 in xrange(_size230): + _elem235 = PartitionWithoutSD() + _elem235.read(iprot) + self.partitions.append(_elem235) iprot.readListEnd() else: iprot.skip(ftype) @@ -5283,8 +5471,8 @@ class PartitionSpecWithSharedSD: 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() if self.sd is not None: @@ -5341,11 +5529,11 @@ class PartitionListComposingSpec: if fid == 1: if ftype == TType.LIST: self.partitions = [] - (_etype233, _size230) = iprot.readListBegin() - for _i234 in xrange(_size230): - _elem235 = Partition() - _elem235.read(iprot) - self.partitions.append(_elem235) + (_etype240, _size237) = iprot.readListBegin() + for _i241 in xrange(_size237): + _elem242 = Partition() + _elem242.read(iprot) + self.partitions.append(_elem242) iprot.readListEnd() else: iprot.skip(ftype) @@ -5362,8 +5550,8 @@ class PartitionListComposingSpec: if self.partitions is not None: oprot.writeFieldBegin('partitions', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.partitions)) - for iter236 in self.partitions: - iter236.write(oprot) + for iter243 in self.partitions: + iter243.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -6919,8 +7107,6 @@ class ColumnStatistics: Attributes: - statsDesc - statsObj - - txnId - - validWriteIdList - isStatsCompliant """ @@ -6928,16 +7114,12 @@ class ColumnStatistics: None, # 0 (1, TType.STRUCT, 'statsDesc', (ColumnStatisticsDesc, ColumnStatisticsDesc.thrift_spec), None, ), # 1 (2, TType.LIST, 'statsObj', (TType.STRUCT,(ColumnStatisticsObj, ColumnStatisticsObj.thrift_spec)), None, ), # 2 - (3, TType.I64, 'txnId', None, -1, ), # 3 - (4, TType.STRING, 'validWriteIdList', None, None, ), # 4 - (5, TType.BOOL, 'isStatsCompliant', None, None, ), # 5 + (3, TType.BOOL, 'isStatsCompliant', None, None, ), # 3 ) - def __init__(self, statsDesc=None, statsObj=None, txnId=thrift_spec[3][4], validWriteIdList=None, isStatsCompliant=None,): + def __init__(self, statsDesc=None, statsObj=None, isStatsCompliant=None,): self.statsDesc = statsDesc self.statsObj = statsObj - self.txnId = txnId - self.validWriteIdList = validWriteIdList self.isStatsCompliant = isStatsCompliant def read(self, iprot): @@ -6958,25 +7140,15 @@ class ColumnStatistics: elif fid == 2: if ftype == TType.LIST: self.statsObj = [] - (_etype240, _size237) = iprot.readListBegin() - for _i241 in xrange(_size237): - _elem242 = ColumnStatisticsObj() - _elem242.read(iprot) - self.statsObj.append(_elem242) + (_etype247, _size244) = iprot.readListBegin() + for _i248 in xrange(_size244): + _elem249 = ColumnStatisticsObj() + _elem249.read(iprot) + self.statsObj.append(_elem249) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 3: - if ftype == TType.I64: - self.txnId = iprot.readI64() - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.validWriteIdList = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 5: if ftype == TType.BOOL: self.isStatsCompliant = iprot.readBool() else: @@ -6998,20 +7170,12 @@ class ColumnStatistics: if self.statsObj is not None: oprot.writeFieldBegin('statsObj', TType.LIST, 2) oprot.writeListBegin(TType.STRUCT, len(self.statsObj)) - for iter243 in self.statsObj: - iter243.write(oprot) + for iter250 in self.statsObj: + iter250.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() - if self.txnId is not None: - oprot.writeFieldBegin('txnId', TType.I64, 3) - oprot.writeI64(self.txnId) - oprot.writeFieldEnd() - if self.validWriteIdList is not None: - oprot.writeFieldBegin('validWriteIdList', TType.STRING, 4) - oprot.writeString(self.validWriteIdList) - oprot.writeFieldEnd() if self.isStatsCompliant is not None: - oprot.writeFieldBegin('isStatsCompliant', TType.BOOL, 5) + oprot.writeFieldBegin('isStatsCompliant', TType.BOOL, 3) oprot.writeBool(self.isStatsCompliant) oprot.writeFieldEnd() oprot.writeFieldStop() @@ -7029,8 +7193,6 @@ class ColumnStatistics: value = 17 value = (value * 31) ^ hash(self.statsDesc) value = (value * 31) ^ hash(self.statsObj) - value = (value * 31) ^ hash(self.txnId) - value = (value * 31) ^ hash(self.validWriteIdList) value = (value * 31) ^ hash(self.isStatsCompliant) return value @@ -7077,11 +7239,11 @@ class AggrStats: if fid == 1: if ftype == TType.LIST: self.colStats = [] - (_etype247, _size244) = iprot.readListBegin() - for _i248 in xrange(_size244): - _elem249 = ColumnStatisticsObj() - _elem249.read(iprot) - self.colStats.append(_elem249) + (_etype254, _size251) = iprot.readListBegin() + for _i255 in xrange(_size251): + _elem256 = ColumnStatisticsObj() + _elem256.read(iprot) + self.colStats.append(_elem256) iprot.readListEnd() else: iprot.skip(ftype) @@ -7108,9 +7270,9 @@ class AggrStats: 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) - oprot.writeListEnd() + for iter257 in self.colStats: + iter257.write(oprot) + oprot.writeListEnd() oprot.writeFieldEnd() if self.partsFound is not None: oprot.writeFieldBegin('partsFound', TType.I64, 2) @@ -7187,11 +7349,11 @@ class SetPartitionsStatsRequest: if fid == 1: if ftype == TType.LIST: self.colStats = [] - (_etype254, _size251) = iprot.readListBegin() - for _i255 in xrange(_size251): - _elem256 = ColumnStatistics() - _elem256.read(iprot) - self.colStats.append(_elem256) + (_etype261, _size258) = iprot.readListBegin() + for _i262 in xrange(_size258): + _elem263 = ColumnStatistics() + _elem263.read(iprot) + self.colStats.append(_elem263) iprot.readListEnd() else: iprot.skip(ftype) @@ -7228,8 +7390,8 @@ class SetPartitionsStatsRequest: if self.colStats is not None: oprot.writeFieldBegin('colStats', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.colStats)) - for iter257 in self.colStats: - iter257.write(oprot) + for iter264 in self.colStats: + iter264.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.needMerge is not None: @@ -7277,6 +7439,73 @@ class SetPartitionsStatsRequest: def __ne__(self, other): return not (self == other) +class SetPartitionsStatsResponse: + """ + Attributes: + - result + """ + + thrift_spec = ( + None, # 0 + (1, TType.BOOL, 'result', None, None, ), # 1 + ) + + def __init__(self, result=None,): + self.result = result + + 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.BOOL: + self.result = iprot.readBool() + 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('SetPartitionsStatsResponse') + if self.result is not None: + oprot.writeFieldBegin('result', TType.BOOL, 1) + oprot.writeBool(self.result) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.result is None: + raise TProtocol.TProtocolException(message='Required field result is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.result) + 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 Schema: """ Attributes: @@ -7306,22 +7535,22 @@ class Schema: if fid == 1: if ftype == TType.LIST: self.fieldSchemas = [] - (_etype261, _size258) = iprot.readListBegin() - for _i262 in xrange(_size258): - _elem263 = FieldSchema() - _elem263.read(iprot) - self.fieldSchemas.append(_elem263) + (_etype268, _size265) = iprot.readListBegin() + for _i269 in xrange(_size265): + _elem270 = FieldSchema() + _elem270.read(iprot) + self.fieldSchemas.append(_elem270) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.MAP: self.properties = {} - (_ktype265, _vtype266, _size264 ) = iprot.readMapBegin() - for _i268 in xrange(_size264): - _key269 = iprot.readString() - _val270 = iprot.readString() - self.properties[_key269] = _val270 + (_ktype272, _vtype273, _size271 ) = iprot.readMapBegin() + for _i275 in xrange(_size271): + _key276 = iprot.readString() + _val277 = iprot.readString() + self.properties[_key276] = _val277 iprot.readMapEnd() else: iprot.skip(ftype) @@ -7338,16 +7567,16 @@ class Schema: if self.fieldSchemas is not None: oprot.writeFieldBegin('fieldSchemas', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.fieldSchemas)) - for iter271 in self.fieldSchemas: - iter271.write(oprot) + for iter278 in self.fieldSchemas: + iter278.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 kiter272,viter273 in self.properties.items(): - oprot.writeString(kiter272) - oprot.writeString(viter273) + for kiter279,viter280 in self.properties.items(): + oprot.writeString(kiter279) + oprot.writeString(viter280) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -7400,11 +7629,11 @@ class EnvironmentContext: if fid == 1: if ftype == TType.MAP: self.properties = {} - (_ktype275, _vtype276, _size274 ) = iprot.readMapBegin() - for _i278 in xrange(_size274): - _key279 = iprot.readString() - _val280 = iprot.readString() - self.properties[_key279] = _val280 + (_ktype282, _vtype283, _size281 ) = iprot.readMapBegin() + for _i285 in xrange(_size281): + _key286 = iprot.readString() + _val287 = iprot.readString() + self.properties[_key286] = _val287 iprot.readMapEnd() else: iprot.skip(ftype) @@ -7421,9 +7650,9 @@ class EnvironmentContext: if self.properties is not None: oprot.writeFieldBegin('properties', TType.MAP, 1) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.properties)) - for kiter281,viter282 in self.properties.items(): - oprot.writeString(kiter281) - oprot.writeString(viter282) + for kiter288,viter289 in self.properties.items(): + oprot.writeString(kiter288) + oprot.writeString(viter289) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -7570,11 +7799,11 @@ class PrimaryKeysResponse: if fid == 1: if ftype == TType.LIST: self.primaryKeys = [] - (_etype286, _size283) = iprot.readListBegin() - for _i287 in xrange(_size283): - _elem288 = SQLPrimaryKey() - _elem288.read(iprot) - self.primaryKeys.append(_elem288) + (_etype293, _size290) = iprot.readListBegin() + for _i294 in xrange(_size290): + _elem295 = SQLPrimaryKey() + _elem295.read(iprot) + self.primaryKeys.append(_elem295) iprot.readListEnd() else: iprot.skip(ftype) @@ -7591,8 +7820,8 @@ class PrimaryKeysResponse: if self.primaryKeys is not None: oprot.writeFieldBegin('primaryKeys', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.primaryKeys)) - for iter289 in self.primaryKeys: - iter289.write(oprot) + for iter296 in self.primaryKeys: + iter296.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -7763,11 +7992,11 @@ class ForeignKeysResponse: if fid == 1: if ftype == TType.LIST: self.foreignKeys = [] - (_etype293, _size290) = iprot.readListBegin() - for _i294 in xrange(_size290): - _elem295 = SQLForeignKey() - _elem295.read(iprot) - self.foreignKeys.append(_elem295) + (_etype300, _size297) = iprot.readListBegin() + for _i301 in xrange(_size297): + _elem302 = SQLForeignKey() + _elem302.read(iprot) + self.foreignKeys.append(_elem302) iprot.readListEnd() else: iprot.skip(ftype) @@ -7784,8 +8013,8 @@ class ForeignKeysResponse: if self.foreignKeys is not None: oprot.writeFieldBegin('foreignKeys', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.foreignKeys)) - for iter296 in self.foreignKeys: - iter296.write(oprot) + for iter303 in self.foreignKeys: + iter303.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -7936,11 +8165,11 @@ class UniqueConstraintsResponse: if fid == 1: if ftype == TType.LIST: self.uniqueConstraints = [] - (_etype300, _size297) = iprot.readListBegin() - for _i301 in xrange(_size297): - _elem302 = SQLUniqueConstraint() - _elem302.read(iprot) - self.uniqueConstraints.append(_elem302) + (_etype307, _size304) = iprot.readListBegin() + for _i308 in xrange(_size304): + _elem309 = SQLUniqueConstraint() + _elem309.read(iprot) + self.uniqueConstraints.append(_elem309) iprot.readListEnd() else: iprot.skip(ftype) @@ -7957,8 +8186,8 @@ class UniqueConstraintsResponse: if self.uniqueConstraints is not None: oprot.writeFieldBegin('uniqueConstraints', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.uniqueConstraints)) - for iter303 in self.uniqueConstraints: - iter303.write(oprot) + for iter310 in self.uniqueConstraints: + iter310.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -8109,11 +8338,11 @@ class NotNullConstraintsResponse: if fid == 1: if ftype == TType.LIST: self.notNullConstraints = [] - (_etype307, _size304) = iprot.readListBegin() - for _i308 in xrange(_size304): - _elem309 = SQLNotNullConstraint() - _elem309.read(iprot) - self.notNullConstraints.append(_elem309) + (_etype314, _size311) = iprot.readListBegin() + for _i315 in xrange(_size311): + _elem316 = SQLNotNullConstraint() + _elem316.read(iprot) + self.notNullConstraints.append(_elem316) iprot.readListEnd() else: iprot.skip(ftype) @@ -8130,8 +8359,8 @@ class NotNullConstraintsResponse: if self.notNullConstraints is not None: oprot.writeFieldBegin('notNullConstraints', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.notNullConstraints)) - for iter310 in self.notNullConstraints: - iter310.write(oprot) + for iter317 in self.notNullConstraints: + iter317.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -8282,11 +8511,11 @@ class DefaultConstraintsResponse: if fid == 1: if ftype == TType.LIST: self.defaultConstraints = [] - (_etype314, _size311) = iprot.readListBegin() - for _i315 in xrange(_size311): - _elem316 = SQLDefaultConstraint() - _elem316.read(iprot) - self.defaultConstraints.append(_elem316) + (_etype321, _size318) = iprot.readListBegin() + for _i322 in xrange(_size318): + _elem323 = SQLDefaultConstraint() + _elem323.read(iprot) + self.defaultConstraints.append(_elem323) iprot.readListEnd() else: iprot.skip(ftype) @@ -8303,8 +8532,8 @@ class DefaultConstraintsResponse: if self.defaultConstraints is not None: oprot.writeFieldBegin('defaultConstraints', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.defaultConstraints)) - for iter317 in self.defaultConstraints: - iter317.write(oprot) + for iter324 in self.defaultConstraints: + iter324.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -8455,11 +8684,11 @@ class CheckConstraintsResponse: if fid == 1: if ftype == TType.LIST: self.checkConstraints = [] - (_etype321, _size318) = iprot.readListBegin() - for _i322 in xrange(_size318): - _elem323 = SQLCheckConstraint() - _elem323.read(iprot) - self.checkConstraints.append(_elem323) + (_etype328, _size325) = iprot.readListBegin() + for _i329 in xrange(_size325): + _elem330 = SQLCheckConstraint() + _elem330.read(iprot) + self.checkConstraints.append(_elem330) iprot.readListEnd() else: iprot.skip(ftype) @@ -8476,8 +8705,8 @@ class CheckConstraintsResponse: if self.checkConstraints is not None: oprot.writeFieldBegin('checkConstraints', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.checkConstraints)) - for iter324 in self.checkConstraints: - iter324.write(oprot) + for iter331 in self.checkConstraints: + iter331.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -8641,11 +8870,11 @@ class AddPrimaryKeyRequest: if fid == 1: if ftype == TType.LIST: self.primaryKeyCols = [] - (_etype328, _size325) = iprot.readListBegin() - for _i329 in xrange(_size325): - _elem330 = SQLPrimaryKey() - _elem330.read(iprot) - self.primaryKeyCols.append(_elem330) + (_etype335, _size332) = iprot.readListBegin() + for _i336 in xrange(_size332): + _elem337 = SQLPrimaryKey() + _elem337.read(iprot) + self.primaryKeyCols.append(_elem337) iprot.readListEnd() else: iprot.skip(ftype) @@ -8662,8 +8891,8 @@ class AddPrimaryKeyRequest: if self.primaryKeyCols is not None: oprot.writeFieldBegin('primaryKeyCols', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.primaryKeyCols)) - for iter331 in self.primaryKeyCols: - iter331.write(oprot) + for iter338 in self.primaryKeyCols: + iter338.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -8717,11 +8946,11 @@ class AddForeignKeyRequest: if fid == 1: if ftype == TType.LIST: self.foreignKeyCols = [] - (_etype335, _size332) = iprot.readListBegin() - for _i336 in xrange(_size332): - _elem337 = SQLForeignKey() - _elem337.read(iprot) - self.foreignKeyCols.append(_elem337) + (_etype342, _size339) = iprot.readListBegin() + for _i343 in xrange(_size339): + _elem344 = SQLForeignKey() + _elem344.read(iprot) + self.foreignKeyCols.append(_elem344) iprot.readListEnd() else: iprot.skip(ftype) @@ -8738,8 +8967,8 @@ class AddForeignKeyRequest: if self.foreignKeyCols is not None: oprot.writeFieldBegin('foreignKeyCols', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.foreignKeyCols)) - for iter338 in self.foreignKeyCols: - iter338.write(oprot) + for iter345 in self.foreignKeyCols: + iter345.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -8793,11 +9022,11 @@ class AddUniqueConstraintRequest: if fid == 1: if ftype == TType.LIST: self.uniqueConstraintCols = [] - (_etype342, _size339) = iprot.readListBegin() - for _i343 in xrange(_size339): - _elem344 = SQLUniqueConstraint() - _elem344.read(iprot) - self.uniqueConstraintCols.append(_elem344) + (_etype349, _size346) = iprot.readListBegin() + for _i350 in xrange(_size346): + _elem351 = SQLUniqueConstraint() + _elem351.read(iprot) + self.uniqueConstraintCols.append(_elem351) iprot.readListEnd() else: iprot.skip(ftype) @@ -8814,8 +9043,8 @@ class AddUniqueConstraintRequest: if self.uniqueConstraintCols is not None: oprot.writeFieldBegin('uniqueConstraintCols', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.uniqueConstraintCols)) - for iter345 in self.uniqueConstraintCols: - iter345.write(oprot) + for iter352 in self.uniqueConstraintCols: + iter352.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -8869,11 +9098,11 @@ class AddNotNullConstraintRequest: if fid == 1: if ftype == TType.LIST: self.notNullConstraintCols = [] - (_etype349, _size346) = iprot.readListBegin() - for _i350 in xrange(_size346): - _elem351 = SQLNotNullConstraint() - _elem351.read(iprot) - self.notNullConstraintCols.append(_elem351) + (_etype356, _size353) = iprot.readListBegin() + for _i357 in xrange(_size353): + _elem358 = SQLNotNullConstraint() + _elem358.read(iprot) + self.notNullConstraintCols.append(_elem358) iprot.readListEnd() else: iprot.skip(ftype) @@ -8890,8 +9119,8 @@ class AddNotNullConstraintRequest: if self.notNullConstraintCols is not None: oprot.writeFieldBegin('notNullConstraintCols', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.notNullConstraintCols)) - for iter352 in self.notNullConstraintCols: - iter352.write(oprot) + for iter359 in self.notNullConstraintCols: + iter359.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -8945,11 +9174,11 @@ class AddDefaultConstraintRequest: if fid == 1: if ftype == TType.LIST: self.defaultConstraintCols = [] - (_etype356, _size353) = iprot.readListBegin() - for _i357 in xrange(_size353): - _elem358 = SQLDefaultConstraint() - _elem358.read(iprot) - self.defaultConstraintCols.append(_elem358) + (_etype363, _size360) = iprot.readListBegin() + for _i364 in xrange(_size360): + _elem365 = SQLDefaultConstraint() + _elem365.read(iprot) + self.defaultConstraintCols.append(_elem365) iprot.readListEnd() else: iprot.skip(ftype) @@ -8966,8 +9195,8 @@ class AddDefaultConstraintRequest: if self.defaultConstraintCols is not None: oprot.writeFieldBegin('defaultConstraintCols', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.defaultConstraintCols)) - for iter359 in self.defaultConstraintCols: - iter359.write(oprot) + for iter366 in self.defaultConstraintCols: + iter366.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -9021,11 +9250,11 @@ class AddCheckConstraintRequest: if fid == 1: if ftype == TType.LIST: self.checkConstraintCols = [] - (_etype363, _size360) = iprot.readListBegin() - for _i364 in xrange(_size360): - _elem365 = SQLCheckConstraint() - _elem365.read(iprot) - self.checkConstraintCols.append(_elem365) + (_etype370, _size367) = iprot.readListBegin() + for _i371 in xrange(_size367): + _elem372 = SQLCheckConstraint() + _elem372.read(iprot) + self.checkConstraintCols.append(_elem372) iprot.readListEnd() else: iprot.skip(ftype) @@ -9042,8 +9271,8 @@ class AddCheckConstraintRequest: if self.checkConstraintCols is not None: oprot.writeFieldBegin('checkConstraintCols', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.checkConstraintCols)) - for iter366 in self.checkConstraintCols: - iter366.write(oprot) + for iter373 in self.checkConstraintCols: + iter373.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -9100,11 +9329,11 @@ class PartitionsByExprResult: if fid == 1: if ftype == TType.LIST: self.partitions = [] - (_etype370, _size367) = iprot.readListBegin() - for _i371 in xrange(_size367): - _elem372 = Partition() - _elem372.read(iprot) - self.partitions.append(_elem372) + (_etype377, _size374) = iprot.readListBegin() + for _i378 in xrange(_size374): + _elem379 = Partition() + _elem379.read(iprot) + self.partitions.append(_elem379) iprot.readListEnd() else: iprot.skip(ftype) @@ -9126,8 +9355,8 @@ class PartitionsByExprResult: if self.partitions is not None: oprot.writeFieldBegin('partitions', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.partitions)) - for iter373 in self.partitions: - iter373.write(oprot) + for iter380 in self.partitions: + iter380.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.hasUnknownPartitions is not None: @@ -9327,11 +9556,11 @@ class TableStatsResult: if fid == 1: if ftype == TType.LIST: self.tableStats = [] - (_etype377, _size374) = iprot.readListBegin() - for _i378 in xrange(_size374): - _elem379 = ColumnStatisticsObj() - _elem379.read(iprot) - self.tableStats.append(_elem379) + (_etype384, _size381) = iprot.readListBegin() + for _i385 in xrange(_size381): + _elem386 = ColumnStatisticsObj() + _elem386.read(iprot) + self.tableStats.append(_elem386) iprot.readListEnd() else: iprot.skip(ftype) @@ -9353,8 +9582,8 @@ class TableStatsResult: if self.tableStats is not None: oprot.writeFieldBegin('tableStats', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.tableStats)) - for iter380 in self.tableStats: - iter380.write(oprot) + for iter387 in self.tableStats: + iter387.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.isStatsCompliant is not None: @@ -9416,17 +9645,17 @@ class PartitionsStatsResult: if fid == 1: if ftype == TType.MAP: self.partStats = {} - (_ktype382, _vtype383, _size381 ) = iprot.readMapBegin() - for _i385 in xrange(_size381): - _key386 = iprot.readString() - _val387 = [] - (_etype391, _size388) = iprot.readListBegin() - for _i392 in xrange(_size388): - _elem393 = ColumnStatisticsObj() - _elem393.read(iprot) - _val387.append(_elem393) + (_ktype389, _vtype390, _size388 ) = iprot.readMapBegin() + for _i392 in xrange(_size388): + _key393 = iprot.readString() + _val394 = [] + (_etype398, _size395) = iprot.readListBegin() + for _i399 in xrange(_size395): + _elem400 = ColumnStatisticsObj() + _elem400.read(iprot) + _val394.append(_elem400) iprot.readListEnd() - self.partStats[_key386] = _val387 + self.partStats[_key393] = _val394 iprot.readMapEnd() else: iprot.skip(ftype) @@ -9448,11 +9677,11 @@ class PartitionsStatsResult: if self.partStats is not None: oprot.writeFieldBegin('partStats', TType.MAP, 1) oprot.writeMapBegin(TType.STRING, TType.LIST, len(self.partStats)) - for kiter394,viter395 in self.partStats.items(): - oprot.writeString(kiter394) - oprot.writeListBegin(TType.STRUCT, len(viter395)) - for iter396 in viter395: - iter396.write(oprot) + for kiter401,viter402 in self.partStats.items(): + oprot.writeString(kiter401) + oprot.writeListBegin(TType.STRUCT, len(viter402)) + for iter403 in viter402: + iter403.write(oprot) oprot.writeListEnd() oprot.writeMapEnd() oprot.writeFieldEnd() @@ -9537,10 +9766,10 @@ class TableStatsRequest: elif fid == 3: if ftype == TType.LIST: self.colNames = [] - (_etype400, _size397) = iprot.readListBegin() - for _i401 in xrange(_size397): - _elem402 = iprot.readString() - self.colNames.append(_elem402) + (_etype407, _size404) = iprot.readListBegin() + for _i408 in xrange(_size404): + _elem409 = iprot.readString() + self.colNames.append(_elem409) iprot.readListEnd() else: iprot.skip(ftype) @@ -9580,8 +9809,8 @@ class TableStatsRequest: if self.colNames is not None: oprot.writeFieldBegin('colNames', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.colNames)) - for iter403 in self.colNames: - oprot.writeString(iter403) + for iter410 in self.colNames: + oprot.writeString(iter410) oprot.writeListEnd() oprot.writeFieldEnd() if self.catName is not None: @@ -9684,20 +9913,20 @@ class PartitionsStatsRequest: elif fid == 3: if ftype == TType.LIST: self.colNames = [] - (_etype407, _size404) = iprot.readListBegin() - for _i408 in xrange(_size404): - _elem409 = iprot.readString() - self.colNames.append(_elem409) + (_etype414, _size411) = iprot.readListBegin() + for _i415 in xrange(_size411): + _elem416 = iprot.readString() + self.colNames.append(_elem416) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.LIST: self.partNames = [] - (_etype413, _size410) = iprot.readListBegin() - for _i414 in xrange(_size410): - _elem415 = iprot.readString() - self.partNames.append(_elem415) + (_etype420, _size417) = iprot.readListBegin() + for _i421 in xrange(_size417): + _elem422 = iprot.readString() + self.partNames.append(_elem422) iprot.readListEnd() else: iprot.skip(ftype) @@ -9737,15 +9966,15 @@ class PartitionsStatsRequest: if self.colNames is not None: oprot.writeFieldBegin('colNames', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.colNames)) - for iter416 in self.colNames: - oprot.writeString(iter416) + for iter423 in self.colNames: + oprot.writeString(iter423) oprot.writeListEnd() oprot.writeFieldEnd() if self.partNames is not None: oprot.writeFieldBegin('partNames', TType.LIST, 4) oprot.writeListBegin(TType.STRING, len(self.partNames)) - for iter417 in self.partNames: - oprot.writeString(iter417) + for iter424 in self.partNames: + oprot.writeString(iter424) oprot.writeListEnd() oprot.writeFieldEnd() if self.catName is not None: @@ -9826,11 +10055,11 @@ class AddPartitionsResult: if fid == 1: if ftype == TType.LIST: self.partitions = [] - (_etype421, _size418) = iprot.readListBegin() - for _i422 in xrange(_size418): - _elem423 = Partition() - _elem423.read(iprot) - self.partitions.append(_elem423) + (_etype428, _size425) = iprot.readListBegin() + for _i429 in xrange(_size425): + _elem430 = Partition() + _elem430.read(iprot) + self.partitions.append(_elem430) iprot.readListEnd() else: iprot.skip(ftype) @@ -9852,8 +10081,8 @@ class AddPartitionsResult: if self.partitions is not None: oprot.writeFieldBegin('partitions', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.partitions)) - for iter424 in self.partitions: - iter424.write(oprot) + for iter431 in self.partitions: + iter431.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.isStatsCompliant is not None: @@ -9941,11 +10170,11 @@ class AddPartitionsRequest: elif fid == 3: if ftype == TType.LIST: self.parts = [] - (_etype428, _size425) = iprot.readListBegin() - for _i429 in xrange(_size425): - _elem430 = Partition() - _elem430.read(iprot) - self.parts.append(_elem430) + (_etype435, _size432) = iprot.readListBegin() + for _i436 in xrange(_size432): + _elem437 = Partition() + _elem437.read(iprot) + self.parts.append(_elem437) iprot.readListEnd() else: iprot.skip(ftype) @@ -9995,8 +10224,8 @@ class AddPartitionsRequest: if self.parts is not None: oprot.writeFieldBegin('parts', TType.LIST, 3) oprot.writeListBegin(TType.STRUCT, len(self.parts)) - for iter431 in self.parts: - iter431.write(oprot) + for iter438 in self.parts: + iter438.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ifNotExists is not None: @@ -10083,11 +10312,11 @@ class DropPartitionsResult: if fid == 1: if ftype == TType.LIST: self.partitions = [] - (_etype435, _size432) = iprot.readListBegin() - for _i436 in xrange(_size432): - _elem437 = Partition() - _elem437.read(iprot) - self.partitions.append(_elem437) + (_etype442, _size439) = iprot.readListBegin() + for _i443 in xrange(_size439): + _elem444 = Partition() + _elem444.read(iprot) + self.partitions.append(_elem444) iprot.readListEnd() else: iprot.skip(ftype) @@ -10104,8 +10333,8 @@ class DropPartitionsResult: if self.partitions is not None: oprot.writeFieldBegin('partitions', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.partitions)) - for iter438 in self.partitions: - iter438.write(oprot) + for iter445 in self.partitions: + iter445.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -10240,21 +10469,21 @@ class RequestPartsSpec: if fid == 1: if ftype == TType.LIST: self.names = [] - (_etype442, _size439) = iprot.readListBegin() - for _i443 in xrange(_size439): - _elem444 = iprot.readString() - self.names.append(_elem444) + (_etype449, _size446) = iprot.readListBegin() + for _i450 in xrange(_size446): + _elem451 = iprot.readString() + self.names.append(_elem451) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.LIST: self.exprs = [] - (_etype448, _size445) = iprot.readListBegin() - for _i449 in xrange(_size445): - _elem450 = DropPartitionsExpr() - _elem450.read(iprot) - self.exprs.append(_elem450) + (_etype455, _size452) = iprot.readListBegin() + for _i456 in xrange(_size452): + _elem457 = DropPartitionsExpr() + _elem457.read(iprot) + self.exprs.append(_elem457) iprot.readListEnd() else: iprot.skip(ftype) @@ -10271,15 +10500,15 @@ class RequestPartsSpec: if self.names is not None: oprot.writeFieldBegin('names', TType.LIST, 1) oprot.writeListBegin(TType.STRING, len(self.names)) - for iter451 in self.names: - oprot.writeString(iter451) + for iter458 in self.names: + oprot.writeString(iter458) oprot.writeListEnd() oprot.writeFieldEnd() if self.exprs is not None: oprot.writeFieldBegin('exprs', TType.LIST, 2) oprot.writeListBegin(TType.STRUCT, len(self.exprs)) - for iter452 in self.exprs: - iter452.write(oprot) + for iter459 in self.exprs: + iter459.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -10543,11 +10772,11 @@ class PartitionValuesRequest: elif fid == 3: if ftype == TType.LIST: self.partitionKeys = [] - (_etype456, _size453) = iprot.readListBegin() - for _i457 in xrange(_size453): - _elem458 = FieldSchema() - _elem458.read(iprot) - self.partitionKeys.append(_elem458) + (_etype463, _size460) = iprot.readListBegin() + for _i464 in xrange(_size460): + _elem465 = FieldSchema() + _elem465.read(iprot) + self.partitionKeys.append(_elem465) iprot.readListEnd() else: iprot.skip(ftype) @@ -10564,11 +10793,11 @@ class PartitionValuesRequest: elif fid == 6: if ftype == TType.LIST: self.partitionOrder = [] - (_etype462, _size459) = iprot.readListBegin() - for _i463 in xrange(_size459): - _elem464 = FieldSchema() - _elem464.read(iprot) - self.partitionOrder.append(_elem464) + (_etype469, _size466) = iprot.readListBegin() + for _i470 in xrange(_size466): + _elem471 = FieldSchema() + _elem471.read(iprot) + self.partitionOrder.append(_elem471) iprot.readListEnd() else: iprot.skip(ftype) @@ -10608,8 +10837,8 @@ class PartitionValuesRequest: if self.partitionKeys is not None: oprot.writeFieldBegin('partitionKeys', TType.LIST, 3) oprot.writeListBegin(TType.STRUCT, len(self.partitionKeys)) - for iter465 in self.partitionKeys: - iter465.write(oprot) + for iter472 in self.partitionKeys: + iter472.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.applyDistinct is not None: @@ -10623,8 +10852,8 @@ class PartitionValuesRequest: if self.partitionOrder is not None: oprot.writeFieldBegin('partitionOrder', TType.LIST, 6) oprot.writeListBegin(TType.STRUCT, len(self.partitionOrder)) - for iter466 in self.partitionOrder: - iter466.write(oprot) + for iter473 in self.partitionOrder: + iter473.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ascending is not None: @@ -10702,10 +10931,10 @@ class PartitionValuesRow: if fid == 1: if ftype == TType.LIST: self.row = [] - (_etype470, _size467) = iprot.readListBegin() - for _i471 in xrange(_size467): - _elem472 = iprot.readString() - self.row.append(_elem472) + (_etype477, _size474) = iprot.readListBegin() + for _i478 in xrange(_size474): + _elem479 = iprot.readString() + self.row.append(_elem479) iprot.readListEnd() else: iprot.skip(ftype) @@ -10722,8 +10951,8 @@ class PartitionValuesRow: if self.row is not None: oprot.writeFieldBegin('row', TType.LIST, 1) oprot.writeListBegin(TType.STRING, len(self.row)) - for iter473 in self.row: - oprot.writeString(iter473) + for iter480 in self.row: + oprot.writeString(iter480) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -10777,11 +11006,11 @@ class PartitionValuesResponse: if fid == 1: if ftype == TType.LIST: self.partitionValues = [] - (_etype477, _size474) = iprot.readListBegin() - for _i478 in xrange(_size474): - _elem479 = PartitionValuesRow() - _elem479.read(iprot) - self.partitionValues.append(_elem479) + (_etype484, _size481) = iprot.readListBegin() + for _i485 in xrange(_size481): + _elem486 = PartitionValuesRow() + _elem486.read(iprot) + self.partitionValues.append(_elem486) iprot.readListEnd() else: iprot.skip(ftype) @@ -10798,8 +11027,8 @@ class PartitionValuesResponse: if self.partitionValues is not None: oprot.writeFieldBegin('partitionValues', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.partitionValues)) - for iter480 in self.partitionValues: - iter480.write(oprot) + for iter487 in self.partitionValues: + iter487.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -10990,11 +11219,11 @@ class Function: elif fid == 8: if ftype == TType.LIST: self.resourceUris = [] - (_etype484, _size481) = iprot.readListBegin() - for _i485 in xrange(_size481): - _elem486 = ResourceUri() - _elem486.read(iprot) - self.resourceUris.append(_elem486) + (_etype491, _size488) = iprot.readListBegin() + for _i492 in xrange(_size488): + _elem493 = ResourceUri() + _elem493.read(iprot) + self.resourceUris.append(_elem493) iprot.readListEnd() else: iprot.skip(ftype) @@ -11044,8 +11273,8 @@ class Function: if self.resourceUris is not None: oprot.writeFieldBegin('resourceUris', TType.LIST, 8) oprot.writeListBegin(TType.STRUCT, len(self.resourceUris)) - for iter487 in self.resourceUris: - iter487.write(oprot) + for iter494 in self.resourceUris: + iter494.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.catName is not None: @@ -11294,11 +11523,11 @@ class GetOpenTxnsInfoResponse: elif fid == 2: if ftype == TType.LIST: self.open_txns = [] - (_etype491, _size488) = iprot.readListBegin() - for _i492 in xrange(_size488): - _elem493 = TxnInfo() - _elem493.read(iprot) - self.open_txns.append(_elem493) + (_etype498, _size495) = iprot.readListBegin() + for _i499 in xrange(_size495): + _elem500 = TxnInfo() + _elem500.read(iprot) + self.open_txns.append(_elem500) iprot.readListEnd() else: iprot.skip(ftype) @@ -11319,8 +11548,8 @@ class GetOpenTxnsInfoResponse: if self.open_txns is not None: oprot.writeFieldBegin('open_txns', TType.LIST, 2) oprot.writeListBegin(TType.STRUCT, len(self.open_txns)) - for iter494 in self.open_txns: - iter494.write(oprot) + for iter501 in self.open_txns: + iter501.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -11391,10 +11620,10 @@ class GetOpenTxnsResponse: elif fid == 2: if ftype == TType.LIST: self.open_txns = [] - (_etype498, _size495) = iprot.readListBegin() - for _i499 in xrange(_size495): - _elem500 = iprot.readI64() - self.open_txns.append(_elem500) + (_etype505, _size502) = iprot.readListBegin() + for _i506 in xrange(_size502): + _elem507 = iprot.readI64() + self.open_txns.append(_elem507) iprot.readListEnd() else: iprot.skip(ftype) @@ -11425,8 +11654,8 @@ class GetOpenTxnsResponse: if self.open_txns is not None: oprot.writeFieldBegin('open_txns', TType.LIST, 2) oprot.writeListBegin(TType.I64, len(self.open_txns)) - for iter501 in self.open_txns: - oprot.writeI64(iter501) + for iter508 in self.open_txns: + oprot.writeI64(iter508) oprot.writeListEnd() oprot.writeFieldEnd() if self.min_open_txn is not None: @@ -11535,10 +11764,10 @@ class OpenTxnRequest: elif fid == 6: if ftype == TType.LIST: self.replSrcTxnIds = [] - (_etype505, _size502) = iprot.readListBegin() - for _i506 in xrange(_size502): - _elem507 = iprot.readI64() - self.replSrcTxnIds.append(_elem507) + (_etype512, _size509) = iprot.readListBegin() + for _i513 in xrange(_size509): + _elem514 = iprot.readI64() + self.replSrcTxnIds.append(_elem514) iprot.readListEnd() else: iprot.skip(ftype) @@ -11575,8 +11804,8 @@ class OpenTxnRequest: if self.replSrcTxnIds is not None: oprot.writeFieldBegin('replSrcTxnIds', TType.LIST, 6) oprot.writeListBegin(TType.I64, len(self.replSrcTxnIds)) - for iter508 in self.replSrcTxnIds: - oprot.writeI64(iter508) + for iter515 in self.replSrcTxnIds: + oprot.writeI64(iter515) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -11639,10 +11868,10 @@ class OpenTxnsResponse: if fid == 1: if ftype == TType.LIST: self.txn_ids = [] - (_etype512, _size509) = iprot.readListBegin() - for _i513 in xrange(_size509): - _elem514 = iprot.readI64() - self.txn_ids.append(_elem514) + (_etype519, _size516) = iprot.readListBegin() + for _i520 in xrange(_size516): + _elem521 = iprot.readI64() + self.txn_ids.append(_elem521) iprot.readListEnd() else: iprot.skip(ftype) @@ -11659,9 +11888,9 @@ class OpenTxnsResponse: if self.txn_ids is not None: oprot.writeFieldBegin('txn_ids', TType.LIST, 1) oprot.writeListBegin(TType.I64, len(self.txn_ids)) - for iter515 in self.txn_ids: - oprot.writeI64(iter515) - oprot.writeListEnd() + for iter522 in self.txn_ids: + oprot.writeI64(iter522) + oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -11794,10 +12023,10 @@ class AbortTxnsRequest: if fid == 1: if ftype == TType.LIST: self.txn_ids = [] - (_etype519, _size516) = iprot.readListBegin() - for _i520 in xrange(_size516): - _elem521 = iprot.readI64() - self.txn_ids.append(_elem521) + (_etype526, _size523) = iprot.readListBegin() + for _i527 in xrange(_size523): + _elem528 = iprot.readI64() + self.txn_ids.append(_elem528) iprot.readListEnd() else: iprot.skip(ftype) @@ -11814,8 +12043,8 @@ class AbortTxnsRequest: if self.txn_ids is not None: oprot.writeFieldBegin('txn_ids', TType.LIST, 1) oprot.writeListBegin(TType.I64, len(self.txn_ids)) - for iter522 in self.txn_ids: - oprot.writeI64(iter522) + for iter529 in self.txn_ids: + oprot.writeI64(iter529) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -11885,11 +12114,11 @@ class CommitTxnRequest: elif fid == 3: if ftype == TType.LIST: self.writeEventInfos = [] - (_etype526, _size523) = iprot.readListBegin() - for _i527 in xrange(_size523): - _elem528 = WriteEventInfo() - _elem528.read(iprot) - self.writeEventInfos.append(_elem528) + (_etype533, _size530) = iprot.readListBegin() + for _i534 in xrange(_size530): + _elem535 = WriteEventInfo() + _elem535.read(iprot) + self.writeEventInfos.append(_elem535) iprot.readListEnd() else: iprot.skip(ftype) @@ -11914,8 +12143,8 @@ class CommitTxnRequest: if self.writeEventInfos is not None: oprot.writeFieldBegin('writeEventInfos', TType.LIST, 3) oprot.writeListBegin(TType.STRUCT, len(self.writeEventInfos)) - for iter529 in self.writeEventInfos: - iter529.write(oprot) + for iter536 in self.writeEventInfos: + iter536.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -12162,10 +12391,10 @@ class ReplTblWriteIdStateRequest: elif fid == 6: if ftype == TType.LIST: self.partNames = [] - (_etype533, _size530) = iprot.readListBegin() - for _i534 in xrange(_size530): - _elem535 = iprot.readString() - self.partNames.append(_elem535) + (_etype540, _size537) = iprot.readListBegin() + for _i541 in xrange(_size537): + _elem542 = iprot.readString() + self.partNames.append(_elem542) iprot.readListEnd() else: iprot.skip(ftype) @@ -12202,8 +12431,8 @@ class ReplTblWriteIdStateRequest: if self.partNames is not None: oprot.writeFieldBegin('partNames', TType.LIST, 6) oprot.writeListBegin(TType.STRING, len(self.partNames)) - for iter536 in self.partNames: - oprot.writeString(iter536) + for iter543 in self.partNames: + oprot.writeString(iter543) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -12273,10 +12502,10 @@ class GetValidWriteIdsRequest: if fid == 1: if ftype == TType.LIST: self.fullTableNames = [] - (_etype540, _size537) = iprot.readListBegin() - for _i541 in xrange(_size537): - _elem542 = iprot.readString() - self.fullTableNames.append(_elem542) + (_etype547, _size544) = iprot.readListBegin() + for _i548 in xrange(_size544): + _elem549 = iprot.readString() + self.fullTableNames.append(_elem549) iprot.readListEnd() else: iprot.skip(ftype) @@ -12298,8 +12527,8 @@ class GetValidWriteIdsRequest: if self.fullTableNames is not None: oprot.writeFieldBegin('fullTableNames', TType.LIST, 1) oprot.writeListBegin(TType.STRING, len(self.fullTableNames)) - for iter543 in self.fullTableNames: - oprot.writeString(iter543) + for iter550 in self.fullTableNames: + oprot.writeString(iter550) oprot.writeListEnd() oprot.writeFieldEnd() if self.validTxnList is not None: @@ -12382,10 +12611,10 @@ class TableValidWriteIds: elif fid == 3: if ftype == TType.LIST: self.invalidWriteIds = [] - (_etype547, _size544) = iprot.readListBegin() - for _i548 in xrange(_size544): - _elem549 = iprot.readI64() - self.invalidWriteIds.append(_elem549) + (_etype554, _size551) = iprot.readListBegin() + for _i555 in xrange(_size551): + _elem556 = iprot.readI64() + self.invalidWriteIds.append(_elem556) iprot.readListEnd() else: iprot.skip(ftype) @@ -12420,8 +12649,8 @@ class TableValidWriteIds: if self.invalidWriteIds is not None: oprot.writeFieldBegin('invalidWriteIds', TType.LIST, 3) oprot.writeListBegin(TType.I64, len(self.invalidWriteIds)) - for iter550 in self.invalidWriteIds: - oprot.writeI64(iter550) + for iter557 in self.invalidWriteIds: + oprot.writeI64(iter557) oprot.writeListEnd() oprot.writeFieldEnd() if self.minOpenWriteId is not None: @@ -12493,11 +12722,11 @@ class GetValidWriteIdsResponse: if fid == 1: if ftype == TType.LIST: self.tblValidWriteIds = [] - (_etype554, _size551) = iprot.readListBegin() - for _i555 in xrange(_size551): - _elem556 = TableValidWriteIds() - _elem556.read(iprot) - self.tblValidWriteIds.append(_elem556) + (_etype561, _size558) = iprot.readListBegin() + for _i562 in xrange(_size558): + _elem563 = TableValidWriteIds() + _elem563.read(iprot) + self.tblValidWriteIds.append(_elem563) iprot.readListEnd() else: iprot.skip(ftype) @@ -12514,8 +12743,8 @@ class GetValidWriteIdsResponse: if self.tblValidWriteIds is not None: oprot.writeFieldBegin('tblValidWriteIds', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.tblValidWriteIds)) - for iter557 in self.tblValidWriteIds: - iter557.write(oprot) + for iter564 in self.tblValidWriteIds: + iter564.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -12591,10 +12820,10 @@ class AllocateTableWriteIdsRequest: elif fid == 3: if ftype == TType.LIST: self.txnIds = [] - (_etype561, _size558) = iprot.readListBegin() - for _i562 in xrange(_size558): - _elem563 = iprot.readI64() - self.txnIds.append(_elem563) + (_etype568, _size565) = iprot.readListBegin() + for _i569 in xrange(_size565): + _elem570 = iprot.readI64() + self.txnIds.append(_elem570) iprot.readListEnd() else: iprot.skip(ftype) @@ -12606,11 +12835,11 @@ class AllocateTableWriteIdsRequest: elif fid == 5: if ftype == TType.LIST: self.srcTxnToWriteIdList = [] - (_etype567, _size564) = iprot.readListBegin() - for _i568 in xrange(_size564): - _elem569 = TxnToWriteId() - _elem569.read(iprot) - self.srcTxnToWriteIdList.append(_elem569) + (_etype574, _size571) = iprot.readListBegin() + for _i575 in xrange(_size571): + _elem576 = TxnToWriteId() + _elem576.read(iprot) + self.srcTxnToWriteIdList.append(_elem576) iprot.readListEnd() else: iprot.skip(ftype) @@ -12635,8 +12864,8 @@ class AllocateTableWriteIdsRequest: if self.txnIds is not None: oprot.writeFieldBegin('txnIds', TType.LIST, 3) oprot.writeListBegin(TType.I64, len(self.txnIds)) - for iter570 in self.txnIds: - oprot.writeI64(iter570) + for iter577 in self.txnIds: + oprot.writeI64(iter577) oprot.writeListEnd() oprot.writeFieldEnd() if self.replPolicy is not None: @@ -12646,8 +12875,8 @@ class AllocateTableWriteIdsRequest: if self.srcTxnToWriteIdList is not None: oprot.writeFieldBegin('srcTxnToWriteIdList', TType.LIST, 5) oprot.writeListBegin(TType.STRUCT, len(self.srcTxnToWriteIdList)) - for iter571 in self.srcTxnToWriteIdList: - iter571.write(oprot) + for iter578 in self.srcTxnToWriteIdList: + iter578.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -12789,11 +13018,11 @@ class AllocateTableWriteIdsResponse: if fid == 1: if ftype == TType.LIST: self.txnToWriteIds = [] - (_etype575, _size572) = iprot.readListBegin() - for _i576 in xrange(_size572): - _elem577 = TxnToWriteId() - _elem577.read(iprot) - self.txnToWriteIds.append(_elem577) + (_etype582, _size579) = iprot.readListBegin() + for _i583 in xrange(_size579): + _elem584 = TxnToWriteId() + _elem584.read(iprot) + self.txnToWriteIds.append(_elem584) iprot.readListEnd() else: iprot.skip(ftype) @@ -12810,8 +13039,8 @@ class AllocateTableWriteIdsResponse: if self.txnToWriteIds is not None: oprot.writeFieldBegin('txnToWriteIds', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.txnToWriteIds)) - for iter578 in self.txnToWriteIds: - iter578.write(oprot) + for iter585 in self.txnToWriteIds: + iter585.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -13039,11 +13268,11 @@ class LockRequest: if fid == 1: if ftype == TType.LIST: self.component = [] - (_etype582, _size579) = iprot.readListBegin() - for _i583 in xrange(_size579): - _elem584 = LockComponent() - _elem584.read(iprot) - self.component.append(_elem584) + (_etype589, _size586) = iprot.readListBegin() + for _i590 in xrange(_size586): + _elem591 = LockComponent() + _elem591.read(iprot) + self.component.append(_elem591) iprot.readListEnd() else: iprot.skip(ftype) @@ -13080,8 +13309,8 @@ class LockRequest: if self.component is not None: oprot.writeFieldBegin('component', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.component)) - for iter585 in self.component: - iter585.write(oprot) + for iter592 in self.component: + iter592.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.txnid is not None: @@ -13779,11 +14008,11 @@ class ShowLocksResponse: if fid == 1: if ftype == TType.LIST: self.locks = [] - (_etype589, _size586) = iprot.readListBegin() - for _i590 in xrange(_size586): - _elem591 = ShowLocksResponseElement() - _elem591.read(iprot) - self.locks.append(_elem591) + (_etype596, _size593) = iprot.readListBegin() + for _i597 in xrange(_size593): + _elem598 = ShowLocksResponseElement() + _elem598.read(iprot) + self.locks.append(_elem598) iprot.readListEnd() else: iprot.skip(ftype) @@ -13800,8 +14029,8 @@ class ShowLocksResponse: if self.locks is not None: oprot.writeFieldBegin('locks', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.locks)) - for iter592 in self.locks: - iter592.write(oprot) + for iter599 in self.locks: + iter599.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -14016,20 +14245,20 @@ class HeartbeatTxnRangeResponse: if fid == 1: if ftype == TType.SET: self.aborted = set() - (_etype596, _size593) = iprot.readSetBegin() - for _i597 in xrange(_si
<TRUNCATED>
