http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/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 06938b4..dee644c 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 @@ -5142,6 +5142,7 @@ class Partition: - catName - writeId - isStatsCompliant + - colStats """ thrift_spec = ( @@ -5157,9 +5158,10 @@ class Partition: (9, TType.STRING, 'catName', None, None, ), # 9 (10, TType.I64, 'writeId', None, -1, ), # 10 (11, TType.BOOL, 'isStatsCompliant', None, None, ), # 11 + (12, TType.STRUCT, 'colStats', (ColumnStatistics, ColumnStatistics.thrift_spec), None, ), # 12 ) - def __init__(self, values=None, dbName=None, tableName=None, createTime=None, lastAccessTime=None, sd=None, parameters=None, privileges=None, catName=None, writeId=thrift_spec[10][4], isStatsCompliant=None,): + def __init__(self, values=None, dbName=None, tableName=None, createTime=None, lastAccessTime=None, sd=None, parameters=None, privileges=None, catName=None, writeId=thrift_spec[10][4], isStatsCompliant=None, colStats=None,): self.values = values self.dbName = dbName self.tableName = tableName @@ -5171,6 +5173,7 @@ class Partition: self.catName = catName self.writeId = writeId self.isStatsCompliant = isStatsCompliant + self.colStats = colStats 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: @@ -5249,6 +5252,12 @@ class Partition: self.isStatsCompliant = iprot.readBool() else: iprot.skip(ftype) + elif fid == 12: + if ftype == TType.STRUCT: + self.colStats = ColumnStatistics() + self.colStats.read(iprot) + else: + iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() @@ -5310,6 +5319,10 @@ class Partition: oprot.writeFieldBegin('isStatsCompliant', TType.BOOL, 11) oprot.writeBool(self.isStatsCompliant) oprot.writeFieldEnd() + if self.colStats is not None: + oprot.writeFieldBegin('colStats', TType.STRUCT, 12) + self.colStats.write(oprot) + oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -5330,6 +5343,7 @@ class Partition: value = (value * 31) ^ hash(self.catName) value = (value * 31) ^ hash(self.writeId) value = (value * 31) ^ hash(self.isStatsCompliant) + value = (value * 31) ^ hash(self.colStats) return value def __repr__(self): @@ -11081,6 +11095,198 @@ class PartitionValuesResponse: def __ne__(self, other): return not (self == other) +class GetPartitionsByNamesRequest: + """ + Attributes: + - db_name + - tbl_name + - names + - get_col_stats + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'db_name', None, None, ), # 1 + (2, TType.STRING, 'tbl_name', None, None, ), # 2 + (3, TType.LIST, 'names', (TType.STRING,None), None, ), # 3 + (4, TType.BOOL, 'get_col_stats', None, None, ), # 4 + ) + + def __init__(self, db_name=None, tbl_name=None, names=None, get_col_stats=None,): + self.db_name = db_name + self.tbl_name = tbl_name + self.names = names + self.get_col_stats = get_col_stats + + 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.tbl_name = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.LIST: + self.names = [] + (_etype491, _size488) = iprot.readListBegin() + for _i492 in xrange(_size488): + _elem493 = iprot.readString() + self.names.append(_elem493) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.BOOL: + self.get_col_stats = 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('GetPartitionsByNamesRequest') + if self.db_name is not None: + oprot.writeFieldBegin('db_name', TType.STRING, 1) + oprot.writeString(self.db_name) + oprot.writeFieldEnd() + if self.tbl_name is not None: + oprot.writeFieldBegin('tbl_name', TType.STRING, 2) + oprot.writeString(self.tbl_name) + oprot.writeFieldEnd() + if self.names is not None: + oprot.writeFieldBegin('names', TType.LIST, 3) + oprot.writeListBegin(TType.STRING, len(self.names)) + for iter494 in self.names: + oprot.writeString(iter494) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.get_col_stats is not None: + oprot.writeFieldBegin('get_col_stats', TType.BOOL, 4) + oprot.writeBool(self.get_col_stats) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.db_name is None: + raise TProtocol.TProtocolException(message='Required field db_name is unset!') + if self.tbl_name is None: + raise TProtocol.TProtocolException(message='Required field tbl_name is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.db_name) + value = (value * 31) ^ hash(self.tbl_name) + value = (value * 31) ^ hash(self.names) + value = (value * 31) ^ hash(self.get_col_stats) + 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 GetPartitionsByNamesResult: + """ + Attributes: + - partitions + """ + + thrift_spec = ( + None, # 0 + (1, TType.LIST, 'partitions', (TType.STRUCT,(Partition, Partition.thrift_spec)), None, ), # 1 + ) + + def __init__(self, partitions=None,): + self.partitions = partitions + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.LIST: + self.partitions = [] + (_etype498, _size495) = iprot.readListBegin() + for _i499 in xrange(_size495): + _elem500 = Partition() + _elem500.read(iprot) + self.partitions.append(_elem500) + iprot.readListEnd() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('GetPartitionsByNamesResult') + if self.partitions is not None: + oprot.writeFieldBegin('partitions', TType.LIST, 1) + oprot.writeListBegin(TType.STRUCT, len(self.partitions)) + for iter501 in self.partitions: + iter501.write(oprot) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.partitions is None: + raise TProtocol.TProtocolException(message='Required field partitions is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.partitions) + 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 ResourceUri: """ Attributes: @@ -11244,11 +11450,11 @@ class Function: elif fid == 8: if ftype == TType.LIST: self.resourceUris = [] - (_etype491, _size488) = iprot.readListBegin() - for _i492 in xrange(_size488): - _elem493 = ResourceUri() - _elem493.read(iprot) - self.resourceUris.append(_elem493) + (_etype505, _size502) = iprot.readListBegin() + for _i506 in xrange(_size502): + _elem507 = ResourceUri() + _elem507.read(iprot) + self.resourceUris.append(_elem507) iprot.readListEnd() else: iprot.skip(ftype) @@ -11298,8 +11504,8 @@ class Function: if self.resourceUris is not None: oprot.writeFieldBegin('resourceUris', TType.LIST, 8) oprot.writeListBegin(TType.STRUCT, len(self.resourceUris)) - for iter494 in self.resourceUris: - iter494.write(oprot) + for iter508 in self.resourceUris: + iter508.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.catName is not None: @@ -11548,11 +11754,11 @@ class GetOpenTxnsInfoResponse: elif fid == 2: if ftype == TType.LIST: self.open_txns = [] - (_etype498, _size495) = iprot.readListBegin() - for _i499 in xrange(_size495): - _elem500 = TxnInfo() - _elem500.read(iprot) - self.open_txns.append(_elem500) + (_etype512, _size509) = iprot.readListBegin() + for _i513 in xrange(_size509): + _elem514 = TxnInfo() + _elem514.read(iprot) + self.open_txns.append(_elem514) iprot.readListEnd() else: iprot.skip(ftype) @@ -11573,8 +11779,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 iter501 in self.open_txns: - iter501.write(oprot) + for iter515 in self.open_txns: + iter515.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -11645,10 +11851,10 @@ class GetOpenTxnsResponse: elif fid == 2: if ftype == TType.LIST: self.open_txns = [] - (_etype505, _size502) = iprot.readListBegin() - for _i506 in xrange(_size502): - _elem507 = iprot.readI64() - self.open_txns.append(_elem507) + (_etype519, _size516) = iprot.readListBegin() + for _i520 in xrange(_size516): + _elem521 = iprot.readI64() + self.open_txns.append(_elem521) iprot.readListEnd() else: iprot.skip(ftype) @@ -11679,8 +11885,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 iter508 in self.open_txns: - oprot.writeI64(iter508) + for iter522 in self.open_txns: + oprot.writeI64(iter522) oprot.writeListEnd() oprot.writeFieldEnd() if self.min_open_txn is not None: @@ -11792,10 +11998,10 @@ class OpenTxnRequest: elif fid == 6: if ftype == TType.LIST: self.replSrcTxnIds = [] - (_etype512, _size509) = iprot.readListBegin() - for _i513 in xrange(_size509): - _elem514 = iprot.readI64() - self.replSrcTxnIds.append(_elem514) + (_etype526, _size523) = iprot.readListBegin() + for _i527 in xrange(_size523): + _elem528 = iprot.readI64() + self.replSrcTxnIds.append(_elem528) iprot.readListEnd() else: iprot.skip(ftype) @@ -11837,8 +12043,8 @@ class OpenTxnRequest: if self.replSrcTxnIds is not None: oprot.writeFieldBegin('replSrcTxnIds', TType.LIST, 6) oprot.writeListBegin(TType.I64, len(self.replSrcTxnIds)) - for iter515 in self.replSrcTxnIds: - oprot.writeI64(iter515) + for iter529 in self.replSrcTxnIds: + oprot.writeI64(iter529) oprot.writeListEnd() oprot.writeFieldEnd() if self.txn_type is not None: @@ -11906,10 +12112,10 @@ class OpenTxnsResponse: 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) + (_etype533, _size530) = iprot.readListBegin() + for _i534 in xrange(_size530): + _elem535 = iprot.readI64() + self.txn_ids.append(_elem535) iprot.readListEnd() else: iprot.skip(ftype) @@ -11926,8 +12132,8 @@ 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 iter522 in self.txn_ids: - oprot.writeI64(iter522) + for iter536 in self.txn_ids: + oprot.writeI64(iter536) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -12061,10 +12267,10 @@ class AbortTxnsRequest: if fid == 1: if ftype == TType.LIST: self.txn_ids = [] - (_etype526, _size523) = iprot.readListBegin() - for _i527 in xrange(_size523): - _elem528 = iprot.readI64() - self.txn_ids.append(_elem528) + (_etype540, _size537) = iprot.readListBegin() + for _i541 in xrange(_size537): + _elem542 = iprot.readI64() + self.txn_ids.append(_elem542) iprot.readListEnd() else: iprot.skip(ftype) @@ -12081,8 +12287,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 iter529 in self.txn_ids: - oprot.writeI64(iter529) + for iter543 in self.txn_ids: + oprot.writeI64(iter543) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -12255,11 +12461,11 @@ class CommitTxnRequest: elif fid == 3: if ftype == TType.LIST: self.writeEventInfos = [] - (_etype533, _size530) = iprot.readListBegin() - for _i534 in xrange(_size530): - _elem535 = WriteEventInfo() - _elem535.read(iprot) - self.writeEventInfos.append(_elem535) + (_etype547, _size544) = iprot.readListBegin() + for _i548 in xrange(_size544): + _elem549 = WriteEventInfo() + _elem549.read(iprot) + self.writeEventInfos.append(_elem549) iprot.readListEnd() else: iprot.skip(ftype) @@ -12296,8 +12502,8 @@ class CommitTxnRequest: if self.writeEventInfos is not None: oprot.writeFieldBegin('writeEventInfos', TType.LIST, 3) oprot.writeListBegin(TType.STRUCT, len(self.writeEventInfos)) - for iter536 in self.writeEventInfos: - iter536.write(oprot) + for iter550 in self.writeEventInfos: + iter550.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.keyValue is not None: @@ -12398,10 +12604,10 @@ class ReplLastIdInfo: elif fid == 5: if ftype == TType.LIST: self.partitionList = [] - (_etype540, _size537) = iprot.readListBegin() - for _i541 in xrange(_size537): - _elem542 = iprot.readString() - self.partitionList.append(_elem542) + (_etype554, _size551) = iprot.readListBegin() + for _i555 in xrange(_size551): + _elem556 = iprot.readString() + self.partitionList.append(_elem556) iprot.readListEnd() else: iprot.skip(ftype) @@ -12439,8 +12645,8 @@ class ReplLastIdInfo: if self.partitionList is not None: oprot.writeFieldBegin('partitionList', TType.LIST, 5) oprot.writeListBegin(TType.STRING, len(self.partitionList)) - for iter543 in self.partitionList: - oprot.writeString(iter543) + for iter557 in self.partitionList: + oprot.writeString(iter557) oprot.writeListEnd() oprot.writeFieldEnd() if self.needUpdateDBReplId is not None: @@ -12696,10 +12902,10 @@ class ReplTblWriteIdStateRequest: elif fid == 6: if ftype == TType.LIST: self.partNames = [] - (_etype547, _size544) = iprot.readListBegin() - for _i548 in xrange(_size544): - _elem549 = iprot.readString() - self.partNames.append(_elem549) + (_etype561, _size558) = iprot.readListBegin() + for _i562 in xrange(_size558): + _elem563 = iprot.readString() + self.partNames.append(_elem563) iprot.readListEnd() else: iprot.skip(ftype) @@ -12736,8 +12942,8 @@ class ReplTblWriteIdStateRequest: if self.partNames is not None: oprot.writeFieldBegin('partNames', TType.LIST, 6) oprot.writeListBegin(TType.STRING, len(self.partNames)) - for iter550 in self.partNames: - oprot.writeString(iter550) + for iter564 in self.partNames: + oprot.writeString(iter564) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -12810,10 +13016,10 @@ class GetValidWriteIdsRequest: if fid == 1: if ftype == TType.LIST: self.fullTableNames = [] - (_etype554, _size551) = iprot.readListBegin() - for _i555 in xrange(_size551): - _elem556 = iprot.readString() - self.fullTableNames.append(_elem556) + (_etype568, _size565) = iprot.readListBegin() + for _i569 in xrange(_size565): + _elem570 = iprot.readString() + self.fullTableNames.append(_elem570) iprot.readListEnd() else: iprot.skip(ftype) @@ -12840,8 +13046,8 @@ class GetValidWriteIdsRequest: if self.fullTableNames is not None: oprot.writeFieldBegin('fullTableNames', TType.LIST, 1) oprot.writeListBegin(TType.STRING, len(self.fullTableNames)) - for iter557 in self.fullTableNames: - oprot.writeString(iter557) + for iter571 in self.fullTableNames: + oprot.writeString(iter571) oprot.writeListEnd() oprot.writeFieldEnd() if self.validTxnList is not None: @@ -12927,10 +13133,10 @@ class TableValidWriteIds: elif fid == 3: if ftype == TType.LIST: self.invalidWriteIds = [] - (_etype561, _size558) = iprot.readListBegin() - for _i562 in xrange(_size558): - _elem563 = iprot.readI64() - self.invalidWriteIds.append(_elem563) + (_etype575, _size572) = iprot.readListBegin() + for _i576 in xrange(_size572): + _elem577 = iprot.readI64() + self.invalidWriteIds.append(_elem577) iprot.readListEnd() else: iprot.skip(ftype) @@ -12965,8 +13171,8 @@ class TableValidWriteIds: if self.invalidWriteIds is not None: oprot.writeFieldBegin('invalidWriteIds', TType.LIST, 3) oprot.writeListBegin(TType.I64, len(self.invalidWriteIds)) - for iter564 in self.invalidWriteIds: - oprot.writeI64(iter564) + for iter578 in self.invalidWriteIds: + oprot.writeI64(iter578) oprot.writeListEnd() oprot.writeFieldEnd() if self.minOpenWriteId is not None: @@ -13038,11 +13244,11 @@ class GetValidWriteIdsResponse: if fid == 1: if ftype == TType.LIST: self.tblValidWriteIds = [] - (_etype568, _size565) = iprot.readListBegin() - for _i569 in xrange(_size565): - _elem570 = TableValidWriteIds() - _elem570.read(iprot) - self.tblValidWriteIds.append(_elem570) + (_etype582, _size579) = iprot.readListBegin() + for _i583 in xrange(_size579): + _elem584 = TableValidWriteIds() + _elem584.read(iprot) + self.tblValidWriteIds.append(_elem584) iprot.readListEnd() else: iprot.skip(ftype) @@ -13059,8 +13265,8 @@ class GetValidWriteIdsResponse: if self.tblValidWriteIds is not None: oprot.writeFieldBegin('tblValidWriteIds', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.tblValidWriteIds)) - for iter571 in self.tblValidWriteIds: - iter571.write(oprot) + for iter585 in self.tblValidWriteIds: + iter585.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -13136,10 +13342,10 @@ class AllocateTableWriteIdsRequest: elif fid == 3: if ftype == TType.LIST: self.txnIds = [] - (_etype575, _size572) = iprot.readListBegin() - for _i576 in xrange(_size572): - _elem577 = iprot.readI64() - self.txnIds.append(_elem577) + (_etype589, _size586) = iprot.readListBegin() + for _i590 in xrange(_size586): + _elem591 = iprot.readI64() + self.txnIds.append(_elem591) iprot.readListEnd() else: iprot.skip(ftype) @@ -13151,11 +13357,11 @@ class AllocateTableWriteIdsRequest: elif fid == 5: if ftype == TType.LIST: self.srcTxnToWriteIdList = [] - (_etype581, _size578) = iprot.readListBegin() - for _i582 in xrange(_size578): - _elem583 = TxnToWriteId() - _elem583.read(iprot) - self.srcTxnToWriteIdList.append(_elem583) + (_etype595, _size592) = iprot.readListBegin() + for _i596 in xrange(_size592): + _elem597 = TxnToWriteId() + _elem597.read(iprot) + self.srcTxnToWriteIdList.append(_elem597) iprot.readListEnd() else: iprot.skip(ftype) @@ -13180,8 +13386,8 @@ class AllocateTableWriteIdsRequest: if self.txnIds is not None: oprot.writeFieldBegin('txnIds', TType.LIST, 3) oprot.writeListBegin(TType.I64, len(self.txnIds)) - for iter584 in self.txnIds: - oprot.writeI64(iter584) + for iter598 in self.txnIds: + oprot.writeI64(iter598) oprot.writeListEnd() oprot.writeFieldEnd() if self.replPolicy is not None: @@ -13191,8 +13397,8 @@ class AllocateTableWriteIdsRequest: if self.srcTxnToWriteIdList is not None: oprot.writeFieldBegin('srcTxnToWriteIdList', TType.LIST, 5) oprot.writeListBegin(TType.STRUCT, len(self.srcTxnToWriteIdList)) - for iter585 in self.srcTxnToWriteIdList: - iter585.write(oprot) + for iter599 in self.srcTxnToWriteIdList: + iter599.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -13334,11 +13540,11 @@ class AllocateTableWriteIdsResponse: if fid == 1: if ftype == TType.LIST: self.txnToWriteIds = [] - (_etype589, _size586) = iprot.readListBegin() - for _i590 in xrange(_size586): - _elem591 = TxnToWriteId() - _elem591.read(iprot) - self.txnToWriteIds.append(_elem591) + (_etype603, _size600) = iprot.readListBegin() + for _i604 in xrange(_size600): + _elem605 = TxnToWriteId() + _elem605.read(iprot) + self.txnToWriteIds.append(_elem605) iprot.readListEnd() else: iprot.skip(ftype) @@ -13355,8 +13561,8 @@ class AllocateTableWriteIdsResponse: if self.txnToWriteIds is not None: oprot.writeFieldBegin('txnToWriteIds', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.txnToWriteIds)) - for iter592 in self.txnToWriteIds: - iter592.write(oprot) + for iter606 in self.txnToWriteIds: + iter606.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -13584,11 +13790,11 @@ class LockRequest: if fid == 1: if ftype == TType.LIST: self.component = [] - (_etype596, _size593) = iprot.readListBegin() - for _i597 in xrange(_size593): - _elem598 = LockComponent() - _elem598.read(iprot) - self.component.append(_elem598) + (_etype610, _size607) = iprot.readListBegin() + for _i611 in xrange(_size607): + _elem612 = LockComponent() + _elem612.read(iprot) + self.component.append(_elem612) iprot.readListEnd() else: iprot.skip(ftype) @@ -13625,8 +13831,8 @@ class LockRequest: if self.component is not None: oprot.writeFieldBegin('component', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.component)) - for iter599 in self.component: - iter599.write(oprot) + for iter613 in self.component: + iter613.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.txnid is not None: @@ -14324,11 +14530,11 @@ class ShowLocksResponse: if fid == 1: if ftype == TType.LIST: self.locks = [] - (_etype603, _size600) = iprot.readListBegin() - for _i604 in xrange(_size600): - _elem605 = ShowLocksResponseElement() - _elem605.read(iprot) - self.locks.append(_elem605) + (_etype617, _size614) = iprot.readListBegin() + for _i618 in xrange(_size614): + _elem619 = ShowLocksResponseElement() + _elem619.read(iprot) + self.locks.append(_elem619) iprot.readListEnd() else: iprot.skip(ftype) @@ -14345,8 +14551,8 @@ class ShowLocksResponse: if self.locks is not None: oprot.writeFieldBegin('locks', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.locks)) - for iter606 in self.locks: - iter606.write(oprot) + for iter620 in self.locks: + iter620.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -14561,20 +14767,20 @@ class HeartbeatTxnRangeResponse: if fid == 1: if ftype == TType.SET: self.aborted = set() - (_etype610, _size607) = iprot.readSetBegin() - for _i611 in xrange(_size607): - _elem612 = iprot.readI64() - self.aborted.add(_elem612) + (_etype624, _size621) = iprot.readSetBegin() + for _i625 in xrange(_size621): + _elem626 = iprot.readI64() + self.aborted.add(_elem626) iprot.readSetEnd() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.SET: self.nosuch = set() - (_etype616, _size613) = iprot.readSetBegin() - for _i617 in xrange(_size613): - _elem618 = iprot.readI64() - self.nosuch.add(_elem618) + (_etype630, _size627) = iprot.readSetBegin() + for _i631 in xrange(_size627): + _elem632 = iprot.readI64() + self.nosuch.add(_elem632) iprot.readSetEnd() else: iprot.skip(ftype) @@ -14591,15 +14797,15 @@ class HeartbeatTxnRangeResponse: if self.aborted is not None: oprot.writeFieldBegin('aborted', TType.SET, 1) oprot.writeSetBegin(TType.I64, len(self.aborted)) - for iter619 in self.aborted: - oprot.writeI64(iter619) + for iter633 in self.aborted: + oprot.writeI64(iter633) oprot.writeSetEnd() oprot.writeFieldEnd() if self.nosuch is not None: oprot.writeFieldBegin('nosuch', TType.SET, 2) oprot.writeSetBegin(TType.I64, len(self.nosuch)) - for iter620 in self.nosuch: - oprot.writeI64(iter620) + for iter634 in self.nosuch: + oprot.writeI64(iter634) oprot.writeSetEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -14696,11 +14902,11 @@ class CompactionRequest: elif fid == 6: if ftype == TType.MAP: self.properties = {} - (_ktype622, _vtype623, _size621 ) = iprot.readMapBegin() - for _i625 in xrange(_size621): - _key626 = iprot.readString() - _val627 = iprot.readString() - self.properties[_key626] = _val627 + (_ktype636, _vtype637, _size635 ) = iprot.readMapBegin() + for _i639 in xrange(_size635): + _key640 = iprot.readString() + _val641 = iprot.readString() + self.properties[_key640] = _val641 iprot.readMapEnd() else: iprot.skip(ftype) @@ -14737,9 +14943,9 @@ class CompactionRequest: if self.properties is not None: oprot.writeFieldBegin('properties', TType.MAP, 6) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.properties)) - for kiter628,viter629 in self.properties.items(): - oprot.writeString(kiter628) - oprot.writeString(viter629) + for kiter642,viter643 in self.properties.items(): + oprot.writeString(kiter642) + oprot.writeString(viter643) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -15456,11 +15662,11 @@ class ShowCompactResponse: if fid == 1: if ftype == TType.LIST: self.compacts = [] - (_etype633, _size630) = iprot.readListBegin() - for _i634 in xrange(_size630): - _elem635 = ShowCompactResponseElement() - _elem635.read(iprot) - self.compacts.append(_elem635) + (_etype647, _size644) = iprot.readListBegin() + for _i648 in xrange(_size644): + _elem649 = ShowCompactResponseElement() + _elem649.read(iprot) + self.compacts.append(_elem649) iprot.readListEnd() else: iprot.skip(ftype) @@ -15477,8 +15683,8 @@ class ShowCompactResponse: if self.compacts is not None: oprot.writeFieldBegin('compacts', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.compacts)) - for iter636 in self.compacts: - iter636.write(oprot) + for iter650 in self.compacts: + iter650.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -15567,10 +15773,10 @@ class AddDynamicPartitions: elif fid == 5: if ftype == TType.LIST: self.partitionnames = [] - (_etype640, _size637) = iprot.readListBegin() - for _i641 in xrange(_size637): - _elem642 = iprot.readString() - self.partitionnames.append(_elem642) + (_etype654, _size651) = iprot.readListBegin() + for _i655 in xrange(_size651): + _elem656 = iprot.readString() + self.partitionnames.append(_elem656) iprot.readListEnd() else: iprot.skip(ftype) @@ -15608,8 +15814,8 @@ class AddDynamicPartitions: if self.partitionnames is not None: oprot.writeFieldBegin('partitionnames', TType.LIST, 5) oprot.writeListBegin(TType.STRING, len(self.partitionnames)) - for iter643 in self.partitionnames: - oprot.writeString(iter643) + for iter657 in self.partitionnames: + oprot.writeString(iter657) oprot.writeListEnd() oprot.writeFieldEnd() if self.operationType is not None: @@ -15842,10 +16048,10 @@ class CreationMetadata: elif fid == 4: if ftype == TType.SET: self.tablesUsed = set() - (_etype647, _size644) = iprot.readSetBegin() - for _i648 in xrange(_size644): - _elem649 = iprot.readString() - self.tablesUsed.add(_elem649) + (_etype661, _size658) = iprot.readSetBegin() + for _i662 in xrange(_size658): + _elem663 = iprot.readString() + self.tablesUsed.add(_elem663) iprot.readSetEnd() else: iprot.skip(ftype) @@ -15884,8 +16090,8 @@ class CreationMetadata: if self.tablesUsed is not None: oprot.writeFieldBegin('tablesUsed', TType.SET, 4) oprot.writeSetBegin(TType.STRING, len(self.tablesUsed)) - for iter650 in self.tablesUsed: - oprot.writeString(iter650) + for iter664 in self.tablesUsed: + oprot.writeString(iter664) oprot.writeSetEnd() oprot.writeFieldEnd() if self.validTxnList is not None: @@ -15974,10 +16180,10 @@ class NotificationEventRequest: elif fid == 3: if ftype == TType.LIST: self.eventTypeSkipList = [] - (_etype654, _size651) = iprot.readListBegin() - for _i655 in xrange(_size651): - _elem656 = iprot.readString() - self.eventTypeSkipList.append(_elem656) + (_etype668, _size665) = iprot.readListBegin() + for _i669 in xrange(_size665): + _elem670 = iprot.readString() + self.eventTypeSkipList.append(_elem670) iprot.readListEnd() else: iprot.skip(ftype) @@ -16002,8 +16208,8 @@ class NotificationEventRequest: if self.eventTypeSkipList is not None: oprot.writeFieldBegin('eventTypeSkipList', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.eventTypeSkipList)) - for iter657 in self.eventTypeSkipList: - oprot.writeString(iter657) + for iter671 in self.eventTypeSkipList: + oprot.writeString(iter671) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -16223,11 +16429,11 @@ class NotificationEventResponse: if fid == 1: if ftype == TType.LIST: self.events = [] - (_etype661, _size658) = iprot.readListBegin() - for _i662 in xrange(_size658): - _elem663 = NotificationEvent() - _elem663.read(iprot) - self.events.append(_elem663) + (_etype675, _size672) = iprot.readListBegin() + for _i676 in xrange(_size672): + _elem677 = NotificationEvent() + _elem677.read(iprot) + self.events.append(_elem677) iprot.readListEnd() else: iprot.skip(ftype) @@ -16244,8 +16450,8 @@ class NotificationEventResponse: if self.events is not None: oprot.writeFieldBegin('events', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.events)) - for iter664 in self.events: - iter664.write(oprot) + for iter678 in self.events: + iter678.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -16568,30 +16774,30 @@ class InsertEventRequestData: elif fid == 2: if ftype == TType.LIST: self.filesAdded = [] - (_etype668, _size665) = iprot.readListBegin() - for _i669 in xrange(_size665): - _elem670 = iprot.readString() - self.filesAdded.append(_elem670) + (_etype682, _size679) = iprot.readListBegin() + for _i683 in xrange(_size679): + _elem684 = iprot.readString() + self.filesAdded.append(_elem684) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.LIST: self.filesAddedChecksum = [] - (_etype674, _size671) = iprot.readListBegin() - for _i675 in xrange(_size671): - _elem676 = iprot.readString() - self.filesAddedChecksum.append(_elem676) + (_etype688, _size685) = iprot.readListBegin() + for _i689 in xrange(_size685): + _elem690 = iprot.readString() + self.filesAddedChecksum.append(_elem690) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.LIST: self.subDirectoryList = [] - (_etype680, _size677) = iprot.readListBegin() - for _i681 in xrange(_size677): - _elem682 = iprot.readString() - self.subDirectoryList.append(_elem682) + (_etype694, _size691) = iprot.readListBegin() + for _i695 in xrange(_size691): + _elem696 = iprot.readString() + self.subDirectoryList.append(_elem696) iprot.readListEnd() else: iprot.skip(ftype) @@ -16612,22 +16818,22 @@ class InsertEventRequestData: if self.filesAdded is not None: oprot.writeFieldBegin('filesAdded', TType.LIST, 2) oprot.writeListBegin(TType.STRING, len(self.filesAdded)) - for iter683 in self.filesAdded: - oprot.writeString(iter683) + for iter697 in self.filesAdded: + oprot.writeString(iter697) oprot.writeListEnd() oprot.writeFieldEnd() if self.filesAddedChecksum is not None: oprot.writeFieldBegin('filesAddedChecksum', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.filesAddedChecksum)) - for iter684 in self.filesAddedChecksum: - oprot.writeString(iter684) + for iter698 in self.filesAddedChecksum: + oprot.writeString(iter698) oprot.writeListEnd() oprot.writeFieldEnd() if self.subDirectoryList is not None: oprot.writeFieldBegin('subDirectoryList', TType.LIST, 4) oprot.writeListBegin(TType.STRING, len(self.subDirectoryList)) - for iter685 in self.subDirectoryList: - oprot.writeString(iter685) + for iter699 in self.subDirectoryList: + oprot.writeString(iter699) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -16786,10 +16992,10 @@ class FireEventRequest: elif fid == 5: if ftype == TType.LIST: self.partitionVals = [] - (_etype689, _size686) = iprot.readListBegin() - for _i690 in xrange(_size686): - _elem691 = iprot.readString() - self.partitionVals.append(_elem691) + (_etype703, _size700) = iprot.readListBegin() + for _i704 in xrange(_size700): + _elem705 = iprot.readString() + self.partitionVals.append(_elem705) iprot.readListEnd() else: iprot.skip(ftype) @@ -16827,8 +17033,8 @@ class FireEventRequest: if self.partitionVals is not None: oprot.writeFieldBegin('partitionVals', TType.LIST, 5) oprot.writeListBegin(TType.STRING, len(self.partitionVals)) - for iter692 in self.partitionVals: - oprot.writeString(iter692) + for iter706 in self.partitionVals: + oprot.writeString(iter706) oprot.writeListEnd() oprot.writeFieldEnd() if self.catName is not None: @@ -16980,10 +17186,10 @@ class WriteNotificationLogRequest: elif fid == 6: if ftype == TType.LIST: self.partitionVals = [] - (_etype696, _size693) = iprot.readListBegin() - for _i697 in xrange(_size693): - _elem698 = iprot.readString() - self.partitionVals.append(_elem698) + (_etype710, _size707) = iprot.readListBegin() + for _i711 in xrange(_size707): + _elem712 = iprot.readString() + self.partitionVals.append(_elem712) iprot.readListEnd() else: iprot.skip(ftype) @@ -17020,8 +17226,8 @@ class WriteNotificationLogRequest: if self.partitionVals is not None: oprot.writeFieldBegin('partitionVals', TType.LIST, 6) oprot.writeListBegin(TType.STRING, len(self.partitionVals)) - for iter699 in self.partitionVals: - oprot.writeString(iter699) + for iter713 in self.partitionVals: + oprot.writeString(iter713) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17215,12 +17421,12 @@ class GetFileMetadataByExprResult: if fid == 1: if ftype == TType.MAP: self.metadata = {} - (_ktype701, _vtype702, _size700 ) = iprot.readMapBegin() - for _i704 in xrange(_size700): - _key705 = iprot.readI64() - _val706 = MetadataPpdResult() - _val706.read(iprot) - self.metadata[_key705] = _val706 + (_ktype715, _vtype716, _size714 ) = iprot.readMapBegin() + for _i718 in xrange(_size714): + _key719 = iprot.readI64() + _val720 = MetadataPpdResult() + _val720.read(iprot) + self.metadata[_key719] = _val720 iprot.readMapEnd() else: iprot.skip(ftype) @@ -17242,9 +17448,9 @@ class GetFileMetadataByExprResult: if self.metadata is not None: oprot.writeFieldBegin('metadata', TType.MAP, 1) oprot.writeMapBegin(TType.I64, TType.STRUCT, len(self.metadata)) - for kiter707,viter708 in self.metadata.items(): - oprot.writeI64(kiter707) - viter708.write(oprot) + for kiter721,viter722 in self.metadata.items(): + oprot.writeI64(kiter721) + viter722.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.isSupported is not None: @@ -17314,10 +17520,10 @@ class GetFileMetadataByExprRequest: if fid == 1: if ftype == TType.LIST: self.fileIds = [] - (_etype712, _size709) = iprot.readListBegin() - for _i713 in xrange(_size709): - _elem714 = iprot.readI64() - self.fileIds.append(_elem714) + (_etype726, _size723) = iprot.readListBegin() + for _i727 in xrange(_size723): + _elem728 = iprot.readI64() + self.fileIds.append(_elem728) iprot.readListEnd() else: iprot.skip(ftype) @@ -17349,8 +17555,8 @@ class GetFileMetadataByExprRequest: if self.fileIds is not None: oprot.writeFieldBegin('fileIds', TType.LIST, 1) oprot.writeListBegin(TType.I64, len(self.fileIds)) - for iter715 in self.fileIds: - oprot.writeI64(iter715) + for iter729 in self.fileIds: + oprot.writeI64(iter729) oprot.writeListEnd() oprot.writeFieldEnd() if self.expr is not None: @@ -17424,11 +17630,11 @@ class GetFileMetadataResult: if fid == 1: if ftype == TType.MAP: self.metadata = {} - (_ktype717, _vtype718, _size716 ) = iprot.readMapBegin() - for _i720 in xrange(_size716): - _key721 = iprot.readI64() - _val722 = iprot.readString() - self.metadata[_key721] = _val722 + (_ktype731, _vtype732, _size730 ) = iprot.readMapBegin() + for _i734 in xrange(_size730): + _key735 = iprot.readI64() + _val736 = iprot.readString() + self.metadata[_key735] = _val736 iprot.readMapEnd() else: iprot.skip(ftype) @@ -17450,9 +17656,9 @@ class GetFileMetadataResult: if self.metadata is not None: oprot.writeFieldBegin('metadata', TType.MAP, 1) oprot.writeMapBegin(TType.I64, TType.STRING, len(self.metadata)) - for kiter723,viter724 in self.metadata.items(): - oprot.writeI64(kiter723) - oprot.writeString(viter724) + for kiter737,viter738 in self.metadata.items(): + oprot.writeI64(kiter737) + oprot.writeString(viter738) oprot.writeMapEnd() oprot.writeFieldEnd() if self.isSupported is not None: @@ -17513,10 +17719,10 @@ class GetFileMetadataRequest: if fid == 1: if ftype == TType.LIST: self.fileIds = [] - (_etype728, _size725) = iprot.readListBegin() - for _i729 in xrange(_size725): - _elem730 = iprot.readI64() - self.fileIds.append(_elem730) + (_etype742, _size739) = iprot.readListBegin() + for _i743 in xrange(_size739): + _elem744 = iprot.readI64() + self.fileIds.append(_elem744) iprot.readListEnd() else: iprot.skip(ftype) @@ -17533,8 +17739,8 @@ class GetFileMetadataRequest: if self.fileIds is not None: oprot.writeFieldBegin('fileIds', TType.LIST, 1) oprot.writeListBegin(TType.I64, len(self.fileIds)) - for iter731 in self.fileIds: - oprot.writeI64(iter731) + for iter745 in self.fileIds: + oprot.writeI64(iter745) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17640,20 +17846,20 @@ class PutFileMetadataRequest: if fid == 1: if ftype == TType.LIST: self.fileIds = [] - (_etype735, _size732) = iprot.readListBegin() - for _i736 in xrange(_size732): - _elem737 = iprot.readI64() - self.fileIds.append(_elem737) + (_etype749, _size746) = iprot.readListBegin() + for _i750 in xrange(_size746): + _elem751 = iprot.readI64() + self.fileIds.append(_elem751) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.LIST: self.metadata = [] - (_etype741, _size738) = iprot.readListBegin() - for _i742 in xrange(_size738): - _elem743 = iprot.readString() - self.metadata.append(_elem743) + (_etype755, _size752) = iprot.readListBegin() + for _i756 in xrange(_size752): + _elem757 = iprot.readString() + self.metadata.append(_elem757) iprot.readListEnd() else: iprot.skip(ftype) @@ -17675,15 +17881,15 @@ class PutFileMetadataRequest: if self.fileIds is not None: oprot.writeFieldBegin('fileIds', TType.LIST, 1) oprot.writeListBegin(TType.I64, len(self.fileIds)) - for iter744 in self.fileIds: - oprot.writeI64(iter744) + for iter758 in self.fileIds: + oprot.writeI64(iter758) oprot.writeListEnd() oprot.writeFieldEnd() if self.metadata is not None: oprot.writeFieldBegin('metadata', TType.LIST, 2) oprot.writeListBegin(TType.STRING, len(self.metadata)) - for iter745 in self.metadata: - oprot.writeString(iter745) + for iter759 in self.metadata: + oprot.writeString(iter759) oprot.writeListEnd() oprot.writeFieldEnd() if self.type is not None: @@ -17791,10 +17997,10 @@ class ClearFileMetadataRequest: if fid == 1: if ftype == TType.LIST: self.fileIds = [] - (_etype749, _size746) = iprot.readListBegin() - for _i750 in xrange(_size746): - _elem751 = iprot.readI64() - self.fileIds.append(_elem751) + (_etype763, _size760) = iprot.readListBegin() + for _i764 in xrange(_size760): + _elem765 = iprot.readI64() + self.fileIds.append(_elem765) iprot.readListEnd() else: iprot.skip(ftype) @@ -17811,8 +18017,8 @@ class ClearFileMetadataRequest: if self.fileIds is not None: oprot.writeFieldBegin('fileIds', TType.LIST, 1) oprot.writeListBegin(TType.I64, len(self.fileIds)) - for iter752 in self.fileIds: - oprot.writeI64(iter752) + for iter766 in self.fileIds: + oprot.writeI64(iter766) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -18041,11 +18247,11 @@ class GetAllFunctionsResponse: if fid == 1: if ftype == TType.LIST: self.functions = [] - (_etype756, _size753) = iprot.readListBegin() - for _i757 in xrange(_size753): - _elem758 = Function() - _elem758.read(iprot) - self.functions.append(_elem758) + (_etype770, _size767) = iprot.readListBegin() + for _i771 in xrange(_size767): + _elem772 = Function() + _elem772.read(iprot) + self.functions.append(_elem772) iprot.readListEnd() else: iprot.skip(ftype) @@ -18062,8 +18268,8 @@ class GetAllFunctionsResponse: if self.functions is not None: oprot.writeFieldBegin('functions', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.functions)) - for iter759 in self.functions: - iter759.write(oprot) + for iter773 in self.functions: + iter773.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -18115,10 +18321,10 @@ class ClientCapabilities: if fid == 1: if ftype == TType.LIST: self.values = [] - (_etype763, _size760) = iprot.readListBegin() - for _i764 in xrange(_size760): - _elem765 = iprot.readI32() - self.values.append(_elem765) + (_etype777, _size774) = iprot.readListBegin() + for _i778 in xrange(_size774): + _elem779 = iprot.readI32() + self.values.append(_elem779) iprot.readListEnd() else: iprot.skip(ftype) @@ -18135,8 +18341,8 @@ class ClientCapabilities: if self.values is not None: oprot.writeFieldBegin('values', TType.LIST, 1) oprot.writeListBegin(TType.I32, len(self.values)) - for iter766 in self.values: - oprot.writeI32(iter766) + for iter780 in self.values: + oprot.writeI32(iter780) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -18421,10 +18627,10 @@ class GetTablesRequest: elif fid == 2: if ftype == TType.LIST: self.tblNames = [] - (_etype770, _size767) = iprot.readListBegin() - for _i771 in xrange(_size767): - _elem772 = iprot.readString() - self.tblNames.append(_elem772) + (_etype784, _size781) = iprot.readListBegin() + for _i785 in xrange(_size781): + _elem786 = iprot.readString() + self.tblNames.append(_elem786) iprot.readListEnd() else: iprot.skip(ftype) @@ -18456,8 +18662,8 @@ class GetTablesRequest: if self.tblNames is not None: oprot.writeFieldBegin('tblNames', TType.LIST, 2) oprot.writeListBegin(TType.STRING, len(self.tblNames)) - for iter773 in self.tblNames: - oprot.writeString(iter773) + for iter787 in self.tblNames: + oprot.writeString(iter787) oprot.writeListEnd() oprot.writeFieldEnd() if self.capabilities is not None: @@ -18522,11 +18728,11 @@ class GetTablesResult: if fid == 1: if ftype == TType.LIST: self.tables = [] - (_etype777, _size774) = iprot.readListBegin() - for _i778 in xrange(_size774): - _elem779 = Table() - _elem779.read(iprot) - self.tables.append(_elem779) + (_etype791, _size788) = iprot.readListBegin() + for _i792 in xrange(_size788): + _elem793 = Table() + _elem793.read(iprot) + self.tables.append(_elem793) iprot.readListEnd() else: iprot.skip(ftype) @@ -18543,8 +18749,8 @@ class GetTablesResult: if self.tables is not None: oprot.writeFieldBegin('tables', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.tables)) - for iter780 in self.tables: - iter780.write(oprot) + for iter794 in self.tables: + iter794.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -19843,44 +20049,44 @@ class WMFullResourcePlan: elif fid == 2: if ftype == TType.LIST: self.pools = [] - (_etype784, _size781) = iprot.readListBegin() - for _i785 in xrange(_size781): - _elem786 = WMPool() - _elem786.read(iprot) - self.pools.append(_elem786) + (_etype798, _size795) = iprot.readListBegin() + for _i799 in xrange(_size795): + _elem800 = WMPool() + _elem800.read(iprot) + self.pools.append(_elem800) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.LIST: self.mappings = [] - (_etype790, _size787) = iprot.readListBegin() - for _i791 in xrange(_size787): - _elem792 = WMMapping() - _elem792.read(iprot) - self.mappings.append(_elem792) + (_etype804, _size801) = iprot.readListBegin() + for _i805 in xrange(_size801): + _elem806 = WMMapping() + _elem806.read(iprot) + self.mappings.append(_elem806) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.LIST: self.triggers = [] - (_etype796, _size793) = iprot.readListBegin() - for _i797 in xrange(_size793): - _elem798 = WMTrigger() - _elem798.read(iprot) - self.triggers.append(_elem798) + (_etype810, _size807) = iprot.readListBegin() + for _i811 in xrange(_size807): + _elem812 = WMTrigger() + _elem812.read(iprot) + self.triggers.append(_elem812) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.LIST: self.poolTriggers = [] - (_etype802, _size799) = iprot.readListBegin() - for _i803 in xrange(_size799): - _elem804 = WMPoolTrigger() - _elem804.read(iprot) - self.poolTriggers.append(_elem804) + (_etype816, _size813) = iprot.readListBegin() + for _i817 in xrange(_size813): + _elem818 = WMPoolTrigger() + _elem818.read(iprot) + self.poolTriggers.append(_elem818) iprot.readListEnd() else: iprot.skip(ftype) @@ -19901,29 +20107,29 @@ class WMFullResourcePlan: if self.pools is not None: oprot.writeFieldBegin('pools', TType.LIST, 2) oprot.writeListBegin(TType.STRUCT, len(self.pools)) - for iter805 in self.pools: - iter805.write(oprot) + for iter819 in self.pools: + iter819.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.mappings is not None: oprot.writeFieldBegin('mappings', TType.LIST, 3) oprot.writeListBegin(TType.STRUCT, len(self.mappings)) - for iter806 in self.mappings: - iter806.write(oprot) + for iter820 in self.mappings: + iter820.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.triggers is not None: oprot.writeFieldBegin('triggers', TType.LIST, 4) oprot.writeListBegin(TType.STRUCT, len(self.triggers)) - for iter807 in self.triggers: - iter807.write(oprot) + for iter821 in self.triggers: + iter821.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.poolTriggers is not None: oprot.writeFieldBegin('poolTriggers', TType.LIST, 5) oprot.writeListBegin(TType.STRUCT, len(self.poolTriggers)) - for iter808 in self.poolTriggers: - iter808.write(oprot) + for iter822 in self.poolTriggers: + iter822.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -20448,11 +20654,11 @@ class WMGetAllResourcePlanResponse: if fid == 1: if ftype == TType.LIST: self.resourcePlans = [] - (_etype812, _size809) = iprot.readListBegin() - for _i813 in xrange(_size809): - _elem814 = WMResourcePlan() - _elem814.read(iprot) - self.resourcePlans.append(_elem814) + (_etype826, _size823) = iprot.readListBegin() + for _i827 in xrange(_size823): + _elem828 = WMResourcePlan() + _elem828.read(iprot) + self.resourcePlans.append(_elem828) iprot.readListEnd() else: iprot.skip(ftype) @@ -20469,8 +20675,8 @@ class WMGetAllResourcePlanResponse: if self.resourcePlans is not None: oprot.writeFieldBegin('resourcePlans', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.resourcePlans)) - for iter815 in self.resourcePlans: - iter815.write(oprot) + for iter829 in self.resourcePlans: + iter829.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -20800,20 +21006,20 @@ class WMValidateResourcePlanResponse: if fid == 1: if ftype == TType.LIST: self.errors = [] - (_etype819, _size816) = iprot.readListBegin() - for _i820 in xrange(_size816): - _elem821 = iprot.readString() - self.errors.append(_elem821) + (_etype833, _size830) = iprot.readListBegin() + for _i834 in xrange(_size830): + _elem835 = iprot.readString() + self.errors.append(_elem835) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.LIST: self.warnings = [] - (_etype825, _size822) = iprot.readListBegin() - for _i826 in xrange(_size822): - _elem827 = iprot.readString() - self.warnings.append(_elem827) + (_etype839, _size836) = iprot.readListBegin() + for _i840 in xrange(_size836): + _elem841 = iprot.readString() + self.warnings.append(_elem841) iprot.readListEnd() else: iprot.skip(ftype) @@ -20830,15 +21036,15 @@ class WMValidateResourcePlanResponse: if self.errors is not None: oprot.writeFieldBegin('errors', TType.LIST, 1) oprot.writeListBegin(TType.STRING, len(self.errors)) - for iter828 in self.errors: - oprot.writeString(iter828) + for iter842 in self.errors: + oprot.writeString(iter842) oprot.writeListEnd() oprot.writeFieldEnd() if self.warnings is not None: oprot.writeFieldBegin('warnings', TType.LIST, 2) oprot.writeListBegin(TType.STRING, len(self.warnings)) - for iter829 in self.warnings: - oprot.writeString(iter829) + for iter843 in self.warnings: + oprot.writeString(iter843) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -21454,11 +21660,11 @@ class WMGetTriggersForResourePlanResponse: if fid == 1: if ftype == TType.LIST: self.triggers = [] - (_etype833, _size830) = iprot.readListBegin() - for _i834 in xrange(_size830): - _elem835 = WMTrigger() - _elem835.read(iprot) - self.triggers.append(_elem835) + (_etype847, _size844) = iprot.readListBegin() + for _i848 in xrange(_size844): + _elem849 = WMTrigger() + _elem849.read(iprot) + self.triggers.append(_elem849) iprot.readListEnd() else: iprot.skip(ftype) @@ -21475,8 +21681,8 @@ class WMGetTriggersForResourePlanResponse: if self.triggers is not None: oprot.writeFieldBegin('triggers', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.triggers)) - for iter836 in self.triggers: - iter836.write(oprot) + for iter850 in self.triggers: + iter850.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -22686,11 +22892,11 @@ class SchemaVersion: elif fid == 4: if ftype == TType.LIST: self.cols = [] - (_etype840, _size837) = iprot.readListBegin() - for _i841 in xrange(_size837): - _elem842 = FieldSchema() - _elem842.read(iprot) - self.cols.append(_elem842) + (_etype854, _size851) = iprot.readListBegin() + for _i855 in xrange(_size851): + _elem856 = FieldSchema() + _elem856.read(iprot) + self.cols.append(_elem856) iprot.readListEnd() else: iprot.skip(ftype) @@ -22750,8 +22956,8 @@ class SchemaVersion: if self.cols is not None: oprot.writeFieldBegin('cols', TType.LIST, 4) oprot.writeListBegin(TType.STRUCT, len(self.cols)) - for iter843 in self.cols: - iter843.write(oprot) + for iter857 in self.cols: + iter857.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.state is not None: @@ -23006,11 +23212,11 @@ class FindSchemasByColsResp: if fid == 1: if ftype == TType.LIST: self.schemaVersions = [] - (_etype847, _size844) = iprot.readListBegin() - for _i848 in xrange(_size844): - _elem849 = SchemaVersionDescriptor() - _elem849.read(iprot) - self.schemaVersions.append(_elem849) + (_etype861, _size858) = iprot.readListBegin() + for _i862 in xrange(_size858): + _elem863 = SchemaVersionDescriptor() + _elem863.read(iprot) + self.schemaVersions.append(_elem863) iprot.readListEnd() else: iprot.skip(ftype) @@ -23027,8 +23233,8 @@ class FindSchemasByColsResp: if self.schemaVersions is not None: oprot.writeFieldBegin('schemaVersions', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.schemaVersions)) - for iter850 in self.schemaVersions: - iter850.write(oprot) + for iter864 in self.schemaVersions: + iter864.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -23513,11 +23719,11 @@ class AlterPartitionsRequest: elif fid == 4: if ftype == TType.LIST: self.partitions = [] - (_etype854, _size851) = iprot.readListBegin() - for _i855 in xrange(_size851): - _elem856 = Partition() - _elem856.read(iprot) - self.partitions.append(_elem856) + (_etype868, _size865) = iprot.readListBegin() + for _i869 in xrange(_size865): + _elem870 = Partition() + _elem870.read(iprot) + self.partitions.append(_elem870) iprot.readListEnd() else: iprot.skip(ftype) @@ -23562,8 +23768,8 @@ class AlterPartitionsRequest: if self.partitions is not None: oprot.writeFieldBegin('partitions', TType.LIST, 4) oprot.writeListBegin(TType.STRUCT, len(self.partitions)) - for iter857 in self.partitions: - iter857.write(oprot) + for iter871 in self.partitions: + iter871.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.environmentContext is not None: @@ -23715,10 +23921,10 @@ class RenamePartitionRequest: elif fid == 4: if ftype == TType.LIST: self.partVals = [] - (_etype861, _size858) = iprot.readListBegin() - for _i862 in xrange(_size858): - _elem863 = iprot.readString() - self.partVals.append(_elem863) + (_etype875, _size872) = iprot.readListBegin() + for _i876 in xrange(_size872): + _elem877 = iprot.readString() + self.partVals.append(_elem877) iprot.readListEnd() else: iprot.skip(ftype) @@ -23758,8 +23964,8 @@ class RenamePartitionRequest: if self.partVals is not None: oprot.writeFieldBegin('partVals', TType.LIST, 4) oprot.writeListBegin(TType.STRING, len(self.partVals)) - for iter864 in self.partVals: - oprot.writeString(iter864) + for iter878 in self.partVals: + oprot.writeString(iter878) oprot.writeListEnd() oprot.writeFieldEnd() if self.newPart is not None: @@ -24081,10 +24287,10 @@ class GetPartitionsProjectionSpec: if fid == 1: if ftype == TType.LIST: self.fieldList = [] - (_etype868, _size865) = iprot.readListBegin() - for _i869 in xrange(_size865): - _elem870 = iprot.readString() - self.fieldList.append(_elem870) + (_etype882, _size879) = iprot.readListBegin() + for _i883 in xrange(_size879): + _elem884 = iprot.readString() + self.fieldList.append(_elem884) iprot.readListEnd() else: iprot.skip(ftype) @@ -24111,8 +24317,8 @@ class GetPartitionsProjectionSpec: if self.fieldList is not None: oprot.writeFieldBegin('fieldList', TType.LIST, 1) oprot.writeListBegin(TType.STRING, len(self.fieldList)) - for iter871 in self.fieldList: - oprot.writeString(iter871) + for iter885 in self.fieldList: + oprot.writeString(iter885) oprot.writeListEnd() oprot.writeFieldEnd() if self.includeParamKeyPattern is not None: @@ -24188,10 +24394,10 @@ class GetPartitionsFilterSpec: elif fid == 8: if ftype == TType.LIST: self.filters = [] - (_etype875, _size872) = iprot.readListBegin() - for _i876 in xrange(_size872): - _elem877 = iprot.readString() - self.filters.append(_elem877) + (_etype889, _size886) = iprot.readListBegin() + for _i890 in xrange(_size886): + _elem891 = iprot.readString() + self.filters.append(_elem891) iprot.readListEnd() else: iprot.skip(ftype) @@ -24212,8 +24418,8 @@ class GetPartitionsFilterSpec: if self.filters is not None: oprot.writeFieldBegin('filters', TType.LIST, 8) oprot.writeListBegin(TType.STRING, len(self.filters)) - for iter878 in self.filters: - oprot.writeString(iter878) + for iter892 in self.filters: + oprot.writeString(iter892) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -24266,11 +24472,11 @@ class GetPartitionsResponse: if fid == 1: if ftype == TType.LIST: self.partitionSpec = [] - (_etype882, _size879) = iprot.readListBegin() - for _i883 in xrange(_size879): - _elem884 = PartitionSpec() - _elem884.read(iprot) - self.partitionSpec.append(_elem884) + (_etype896, _size893) = iprot.readListBegin() + for _i897 in xrange(_size893): + _elem898 = PartitionSpec() + _elem898.read(iprot) + self.partitionSpec.append(_elem898) iprot.readListEnd() else: iprot.skip(ftype) @@ -24287,8 +24493,8 @@ class GetPartitionsResponse: if self.partitionSpec is not None: oprot.writeFieldBegin('partitionSpec', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.partitionSpec)) - for iter885 in self.partitionSpec: - iter885.write(oprot) + for iter899 in self.partitionSpec: + iter899.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -24386,10 +24592,10 @@ class GetPartitionsRequest: elif fid == 6: if ftype == TType.LIST: self.groupNames = [] - (_etype889, _size886) = iprot.readListBegin() - for _i890 in xrange(_size886): - _elem891 = iprot.readString() - self.groupNames.append(_elem891) + (_etype903, _size900) = iprot.readListBegin() + for _i904 in xrange(_size900): + _elem905 = iprot.readString() + self.groupNames.append(_elem905) iprot.readListEnd() else: iprot.skip(ftype) @@ -24438,8 +24644,8 @@ class GetPartitionsRequest: if self.groupNames is not None: oprot.writeFieldBegin('groupNames', TType.LIST, 6) oprot.writeListBegin(TType.STRING, len(self.groupNames)) - for iter892 in self.groupNames: - oprot.writeString(iter892) + for iter906 in self.groupNames: + oprot.writeString(iter906) oprot.writeListEnd() oprot.writeFieldEnd() if self.projectionSpec is not None:
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-rb/hive_metastore_types.rb ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-rb/hive_metastore_types.rb b/standalone-metastore/metastore-common/src/gen/thrift/gen-rb/hive_metastore_types.rb index e885194..ac95307 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-rb/hive_metastore_types.rb +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-rb/hive_metastore_types.rb @@ -1178,6 +1178,7 @@ class Partition CATNAME = 9 WRITEID = 10 ISSTATSCOMPLIANT = 11 + COLSTATS = 12 FIELDS = { VALUES => {:type => ::Thrift::Types::LIST, :name => 'values', :element => {:type => ::Thrift::Types::STRING}}, @@ -1190,7 +1191,8 @@ class Partition PRIVILEGES => {:type => ::Thrift::Types::STRUCT, :name => 'privileges', :class => ::PrincipalPrivilegeSet, :optional => true}, CATNAME => {:type => ::Thrift::Types::STRING, :name => 'catName', :optional => true}, WRITEID => {:type => ::Thrift::Types::I64, :name => 'writeId', :default => -1, :optional => true}, - ISSTATSCOMPLIANT => {:type => ::Thrift::Types::BOOL, :name => 'isStatsCompliant', :optional => true} + ISSTATSCOMPLIANT => {:type => ::Thrift::Types::BOOL, :name => 'isStatsCompliant', :optional => true}, + COLSTATS => {:type => ::Thrift::Types::STRUCT, :name => 'colStats', :class => ::ColumnStatistics, :optional => true} } def struct_fields; FIELDS; end @@ -2468,6 +2470,47 @@ class PartitionValuesResponse ::Thrift::Struct.generate_accessors self end +class GetPartitionsByNamesRequest + include ::Thrift::Struct, ::Thrift::Struct_Union + DB_NAME = 1 + TBL_NAME = 2 + NAMES = 3 + GET_COL_STATS = 4 + + FIELDS = { + DB_NAME => {:type => ::Thrift::Types::STRING, :name => 'db_name'}, + TBL_NAME => {:type => ::Thrift::Types::STRING, :name => 'tbl_name'}, + NAMES => {:type => ::Thrift::Types::LIST, :name => 'names', :element => {:type => ::Thrift::Types::STRING}, :optional => true}, + GET_COL_STATS => {:type => ::Thrift::Types::BOOL, :name => 'get_col_stats', :optional => true} + } + + def struct_fields; FIELDS; end + + def validate + raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field db_name is unset!') unless @db_name + raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tbl_name is unset!') unless @tbl_name + end + + ::Thrift::Struct.generate_accessors self +end + +class GetPartitionsByNamesResult + include ::Thrift::Struct, ::Thrift::Struct_Union + PARTITIONS = 1 + + FIELDS = { + PARTITIONS => {:type => ::Thrift::Types::LIST, :name => 'partitions', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Partition}} + } + + def struct_fields; FIELDS; end + + def validate + raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field partitions is unset!') unless @partitions + end + + ::Thrift::Struct.generate_accessors self +end + class ResourceUri include ::Thrift::Struct, ::Thrift::Struct_Union RESOURCETYPE = 1 http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-rb/thrift_hive_metastore.rb ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-rb/thrift_hive_metastore.rb b/standalone-metastore/metastore-common/src/gen/thrift/gen-rb/thrift_hive_metastore.rb index 35e1693..39c671a 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-rb/thrift_hive_metastore.rb +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-rb/thrift_hive_metastore.rb @@ -1417,6 +1417,23 @@ module ThriftHiveMetastore raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_partitions_by_names failed: unknown result') end + def get_partitions_by_names_req(req) + send_get_partitions_by_names_req(req) + return recv_get_partitions_by_names_req() + end + + def send_get_partitions_by_names_req(req) + send_message('get_partitions_by_names_req', Get_partitions_by_names_req_args, :req => req) + end + + def recv_get_partitions_by_names_req() + result = receive_message(Get_partitions_by_names_req_result) + return result.success unless result.success.nil? + raise result.o1 unless result.o1.nil? + raise result.o2 unless result.o2.nil? + raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_partitions_by_names_req failed: unknown result') + end + def alter_partition(db_name, tbl_name, new_part) send_alter_partition(db_name, tbl_name, new_part) recv_alter_partition() @@ -4814,6 +4831,19 @@ module ThriftHiveMetastore write_result(result, oprot, 'get_partitions_by_names', seqid) end + def process_get_partitions_by_names_req(seqid, iprot, oprot) + args = read_args(iprot, Get_partitions_by_names_req_args) + result = Get_partitions_by_names_req_result.new() + begin + result.success = @handler.get_partitions_by_names_req(args.req) + rescue ::MetaException => o1 + result.o1 = o1 + rescue ::NoSuchObjectException => o2 + result.o2 = o2 + end + write_result(result, oprot, 'get_partitions_by_names_req', seqid) + end + def process_alter_partition(seqid, iprot, oprot) args = read_args(iprot, Alter_partition_args) result = Alter_partition_result.new() @@ -9671,6 +9701,42 @@ module ThriftHiveMetastore ::Thrift::Struct.generate_accessors self end + class Get_partitions_by_names_req_args + include ::Thrift::Struct, ::Thrift::Struct_Union + REQ = 1 + + FIELDS = { + REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::GetPartitionsByNamesRequest} + } + + def struct_fields; FIELDS; end + + def validate + end + + ::Thrift::Struct.generate_accessors self + end + + class Get_partitions_by_names_req_result + include ::Thrift::Struct, ::Thrift::Struct_Union + SUCCESS = 0 + O1 = 1 + O2 = 2 + + FIELDS = { + SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::GetPartitionsByNamesResult}, + O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => ::MetaException}, + O2 => {:type => ::Thrift::Types::STRUCT, :name => 'o2', :class => ::NoSuchObjectException} + } + + def struct_fields; FIELDS; end + + def validate + end + + ::Thrift::Struct.generate_accessors self + end + class Alter_partition_args include ::Thrift::Struct, ::Thrift::Struct_Union DB_NAME = 1 http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java b/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java index 59b5bcf..a1826fa 100644 --- a/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java +++ b/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java @@ -1831,11 +1831,28 @@ public class HiveMetaStoreClient implements IMetaStoreClient, AutoCloseable { } @Override + public List<Partition> getPartitionsByNames(String db_name, String tbl_name, + List<String> part_names, boolean getColStats) + throws TException { + return getPartitionsByNames(getDefaultCatalog(conf), db_name, tbl_name, part_names, getColStats); + } + + @Override public List<Partition> getPartitionsByNames(String catName, String db_name, String tbl_name, List<String> part_names) throws TException { + return getPartitionsByNames(catName, db_name, tbl_name, part_names, false); + } + + @Override + public List<Partition> getPartitionsByNames(String catName, String db_name, String tbl_name, + List<String> part_names, boolean getColStats) throws TException { checkDbAndTableFilters(catName, db_name, tbl_name); - List<Partition> parts = - client.get_partitions_by_names(prependCatalogToDbName(catName, db_name, conf), tbl_name, part_names); + GetPartitionsByNamesRequest gpbnr = + new GetPartitionsByNamesRequest(prependCatalogToDbName(catName, db_name, conf), + tbl_name); + gpbnr.setNames(part_names); + gpbnr.setGet_col_stats(getColStats); + List<Partition> parts = client.get_partitions_by_names_req(gpbnr).getPartitions(); return deepCopyPartitions(FilterUtils.filterPartitionsIfEnabled(isClientFilterEnabled, filterHook, parts)); } http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java b/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java index e10cc8c..f67761e 100644 --- a/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java +++ b/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java @@ -1478,6 +1478,20 @@ public interface IMetaStoreClient { /** * Get partitions by a list of partition names. + * @param db_name database name + * @param tbl_name table name + * @param part_names list of partition names + * @param getColStats if true include statistics in the Partition object + * @return list of Partition objects + * @throws NoSuchObjectException No such partitions + * @throws MetaException error accessing the RDBMS. + * @throws TException thrift transport error + */ + List<Partition> getPartitionsByNames(String db_name, String tbl_name, List<String> part_names, + boolean getColStats) throws NoSuchObjectException, MetaException, TException; + + /** + * Get partitions by a list of partition names. * @param catName catalog name * @param db_name database name * @param tbl_name table name @@ -1491,6 +1505,22 @@ public interface IMetaStoreClient { List<String> part_names) throws NoSuchObjectException, MetaException, TException; + /** + * Get partitions by a list of partition names. + * @param catName catalog name + * @param db_name database name + * @param tbl_name table name + * @param part_names list of partition names + * @param getColStats if true, column statistics is added to the Partition objects + * @return list of Partition objects + * @throws NoSuchObjectException No such partitions + * @throws MetaException error accessing the RDBMS. + * @throws TException thrift transport error + */ + List<Partition> getPartitionsByNames(String catName, String db_name, String tbl_name, + List<String> part_names, boolean getColStats) + throws NoSuchObjectException, MetaException, TException; + /** * List partitions along with privilege information for a user or groups * @param dbName database name http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/main/thrift/hive_metastore.thrift ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/main/thrift/hive_metastore.thrift b/standalone-metastore/metastore-common/src/main/thrift/hive_metastore.thrift index c58015d..19bc713 100644 --- a/standalone-metastore/metastore-common/src/main/thrift/hive_metastore.thrift +++ b/standalone-metastore/metastore-common/src/main/thrift/hive_metastore.thrift @@ -462,7 +462,8 @@ struct Partition { 8: optional PrincipalPrivilegeSet privileges, 9: optional string catName, 10: optional i64 writeId=-1, - 11: optional bool isStatsCompliant + 11: optional bool isStatsCompliant, + 12: optional ColumnStatistics colStats // column statistics for partition } struct PartitionWithoutSD { @@ -826,6 +827,17 @@ struct PartitionValuesResponse { 1: required list<PartitionValuesRow> partitionValues; } +struct GetPartitionsByNamesRequest { + 1: required string db_name, + 2: required string tbl_name, + 3: optional list<string> names, + 4: optional bool get_col_stats +} + +struct GetPartitionsByNamesResult { + 1: required list<Partition> partitions +} + enum FunctionType { JAVA = 1, } @@ -2103,6 +2115,8 @@ service ThriftHiveMetastore extends fb303.FacebookService // get partitions give a list of partition names list<Partition> get_partitions_by_names(1:string db_name 2:string tbl_name 3:list<string> names) throws(1:MetaException o1, 2:NoSuchObjectException o2) + GetPartitionsByNamesResult get_partitions_by_names_req(1:GetPartitionsByNamesRequest req) + throws(1:MetaException o1, 2:NoSuchObjectException o2) // changes the partition to the new partition object. partition is identified from the part values // in the new_part
