http://git-wip-us.apache.org/repos/asf/hive/blob/4db8b1c6/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp ---------------------------------------------------------------------- diff --cc standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp index da14ac1,7f06b3b..8980258 --- a/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp +++ b/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp @@@ -17286,6 -16635,26 +17291,26 @@@ uint32_t CommitTxnRequest::read(::apach xfer += iprot->skip(ftype); } break; + case 3: + if (ftype == ::apache::thrift::protocol::T_LIST) { + { + this->writeEventInfos.clear(); - uint32_t _size673; - ::apache::thrift::protocol::TType _etype676; - xfer += iprot->readListBegin(_etype676, _size673); - this->writeEventInfos.resize(_size673); - uint32_t _i677; - for (_i677 = 0; _i677 < _size673; ++_i677) ++ uint32_t _size681; ++ ::apache::thrift::protocol::TType _etype684; ++ xfer += iprot->readListBegin(_etype684, _size681); ++ this->writeEventInfos.resize(_size681); ++ uint32_t _i685; ++ for (_i685 = 0; _i685 < _size681; ++_i685) + { - xfer += this->writeEventInfos[_i677].read(iprot); ++ xfer += this->writeEventInfos[_i685].read(iprot); + } + xfer += iprot->readListEnd(); + } + this->__isset.writeEventInfos = true; + } else { + xfer += iprot->skip(ftype); + } + break; default: xfer += iprot->skip(ftype); break; @@@ -17314,6 -16683,19 +17339,19 @@@ uint32_t CommitTxnRequest::write(::apac xfer += oprot->writeString(this->replPolicy); xfer += oprot->writeFieldEnd(); } + if (this->__isset.writeEventInfos) { + xfer += oprot->writeFieldBegin("writeEventInfos", ::apache::thrift::protocol::T_LIST, 3); + { + xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->writeEventInfos.size())); - std::vector<WriteEventInfo> ::const_iterator _iter678; - for (_iter678 = this->writeEventInfos.begin(); _iter678 != this->writeEventInfos.end(); ++_iter678) ++ std::vector<WriteEventInfo> ::const_iterator _iter686; ++ for (_iter686 = this->writeEventInfos.begin(); _iter686 != this->writeEventInfos.end(); ++_iter686) + { - xfer += (*_iter678).write(oprot); ++ xfer += (*_iter686).write(oprot); + } + xfer += oprot->writeListEnd(); + } + xfer += oprot->writeFieldEnd(); + } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; @@@ -17326,15 -16709,17 +17365,17 @@@ void swap(CommitTxnRequest &a, CommitTx swap(a.__isset, b.__isset); } - CommitTxnRequest::CommitTxnRequest(const CommitTxnRequest& other681) { - txnid = other681.txnid; - replPolicy = other681.replPolicy; - __isset = other681.__isset; -CommitTxnRequest::CommitTxnRequest(const CommitTxnRequest& other679) { - txnid = other679.txnid; - replPolicy = other679.replPolicy; - writeEventInfos = other679.writeEventInfos; - __isset = other679.__isset; ++CommitTxnRequest::CommitTxnRequest(const CommitTxnRequest& other687) { ++ txnid = other687.txnid; ++ replPolicy = other687.replPolicy; ++ writeEventInfos = other687.writeEventInfos; ++ __isset = other687.__isset; } - CommitTxnRequest& CommitTxnRequest::operator=(const CommitTxnRequest& other682) { - txnid = other682.txnid; - replPolicy = other682.replPolicy; - __isset = other682.__isset; -CommitTxnRequest& CommitTxnRequest::operator=(const CommitTxnRequest& other680) { - txnid = other680.txnid; - replPolicy = other680.replPolicy; - writeEventInfos = other680.writeEventInfos; - __isset = other680.__isset; ++CommitTxnRequest& CommitTxnRequest::operator=(const CommitTxnRequest& other688) { ++ txnid = other688.txnid; ++ replPolicy = other688.replPolicy; ++ writeEventInfos = other688.writeEventInfos; ++ __isset = other688.__isset; return *this; } void CommitTxnRequest::printTo(std::ostream& out) const { @@@ -17342,6 -16727,231 +17383,231 @@@ out << "CommitTxnRequest("; out << "txnid=" << to_string(txnid); out << ", " << "replPolicy="; (__isset.replPolicy ? (out << to_string(replPolicy)) : (out << "<null>")); + out << ", " << "writeEventInfos="; (__isset.writeEventInfos ? (out << to_string(writeEventInfos)) : (out << "<null>")); + out << ")"; + } + + + WriteEventInfo::~WriteEventInfo() throw() { + } + + + void WriteEventInfo::__set_writeId(const int64_t val) { + this->writeId = val; + } + + void WriteEventInfo::__set_database(const std::string& val) { + this->database = val; + } + + void WriteEventInfo::__set_table(const std::string& val) { + this->table = val; + } + + void WriteEventInfo::__set_files(const std::string& val) { + this->files = val; + } + + void WriteEventInfo::__set_partition(const std::string& val) { + this->partition = val; + __isset.partition = true; + } + + void WriteEventInfo::__set_tableObj(const std::string& val) { + this->tableObj = val; + __isset.tableObj = true; + } + + void WriteEventInfo::__set_partitionObj(const std::string& val) { + this->partitionObj = val; + __isset.partitionObj = true; + } + + uint32_t WriteEventInfo::read(::apache::thrift::protocol::TProtocol* iprot) { + + apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); + uint32_t xfer = 0; + std::string fname; + ::apache::thrift::protocol::TType ftype; + int16_t fid; + + xfer += iprot->readStructBegin(fname); + + using ::apache::thrift::protocol::TProtocolException; + + bool isset_writeId = false; + bool isset_database = false; + bool isset_table = false; + bool isset_files = false; + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == ::apache::thrift::protocol::T_I64) { + xfer += iprot->readI64(this->writeId); + isset_writeId = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 2: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->database); + isset_database = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 3: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->table); + isset_table = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 4: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->files); + isset_files = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 5: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->partition); + this->__isset.partition = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 6: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->tableObj); + this->__isset.tableObj = true; + } else { + xfer += iprot->skip(ftype); + } + break; + case 7: + if (ftype == ::apache::thrift::protocol::T_STRING) { + xfer += iprot->readString(this->partitionObj); + this->__isset.partitionObj = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + if (!isset_writeId) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_database) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_table) + throw TProtocolException(TProtocolException::INVALID_DATA); + if (!isset_files) + throw TProtocolException(TProtocolException::INVALID_DATA); + return xfer; + } + + uint32_t WriteEventInfo::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; + apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + xfer += oprot->writeStructBegin("WriteEventInfo"); + + xfer += oprot->writeFieldBegin("writeId", ::apache::thrift::protocol::T_I64, 1); + xfer += oprot->writeI64(this->writeId); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("database", ::apache::thrift::protocol::T_STRING, 2); + xfer += oprot->writeString(this->database); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("table", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString(this->table); + xfer += oprot->writeFieldEnd(); + + xfer += oprot->writeFieldBegin("files", ::apache::thrift::protocol::T_STRING, 4); + xfer += oprot->writeString(this->files); + xfer += oprot->writeFieldEnd(); + + if (this->__isset.partition) { + xfer += oprot->writeFieldBegin("partition", ::apache::thrift::protocol::T_STRING, 5); + xfer += oprot->writeString(this->partition); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.tableObj) { + xfer += oprot->writeFieldBegin("tableObj", ::apache::thrift::protocol::T_STRING, 6); + xfer += oprot->writeString(this->tableObj); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.partitionObj) { + xfer += oprot->writeFieldBegin("partitionObj", ::apache::thrift::protocol::T_STRING, 7); + xfer += oprot->writeString(this->partitionObj); + xfer += oprot->writeFieldEnd(); + } + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; + } + + void swap(WriteEventInfo &a, WriteEventInfo &b) { + using ::std::swap; + swap(a.writeId, b.writeId); + swap(a.database, b.database); + swap(a.table, b.table); + swap(a.files, b.files); + swap(a.partition, b.partition); + swap(a.tableObj, b.tableObj); + swap(a.partitionObj, b.partitionObj); + swap(a.__isset, b.__isset); + } + -WriteEventInfo::WriteEventInfo(const WriteEventInfo& other681) { - writeId = other681.writeId; - database = other681.database; - table = other681.table; - files = other681.files; - partition = other681.partition; - tableObj = other681.tableObj; - partitionObj = other681.partitionObj; - __isset = other681.__isset; -} -WriteEventInfo& WriteEventInfo::operator=(const WriteEventInfo& other682) { - writeId = other682.writeId; - database = other682.database; - table = other682.table; - files = other682.files; - partition = other682.partition; - tableObj = other682.tableObj; - partitionObj = other682.partitionObj; - __isset = other682.__isset; ++WriteEventInfo::WriteEventInfo(const WriteEventInfo& other689) { ++ writeId = other689.writeId; ++ database = other689.database; ++ table = other689.table; ++ files = other689.files; ++ partition = other689.partition; ++ tableObj = other689.tableObj; ++ partitionObj = other689.partitionObj; ++ __isset = other689.__isset; ++} ++WriteEventInfo& WriteEventInfo::operator=(const WriteEventInfo& other690) { ++ writeId = other690.writeId; ++ database = other690.database; ++ table = other690.table; ++ files = other690.files; ++ partition = other690.partition; ++ tableObj = other690.tableObj; ++ partitionObj = other690.partitionObj; ++ __isset = other690.__isset; + return *this; + } + void WriteEventInfo::printTo(std::ostream& out) const { + using ::apache::thrift::to_string; + out << "WriteEventInfo("; + out << "writeId=" << to_string(writeId); + out << ", " << "database=" << to_string(database); + out << ", " << "table=" << to_string(table); + out << ", " << "files=" << to_string(files); + out << ", " << "partition="; (__isset.partition ? (out << to_string(partition)) : (out << "<null>")); + out << ", " << "tableObj="; (__isset.tableObj ? (out << to_string(tableObj)) : (out << "<null>")); + out << ", " << "partitionObj="; (__isset.partitionObj ? (out << to_string(partitionObj)) : (out << "<null>")); out << ")"; } @@@ -17445,14 -17055,14 +17711,14 @@@ uint32_t ReplTblWriteIdStateRequest::re if (ftype == ::apache::thrift::protocol::T_LIST) { { this->partNames.clear(); -- uint32_t _size683; -- ::apache::thrift::protocol::TType _etype686; -- xfer += iprot->readListBegin(_etype686, _size683); -- this->partNames.resize(_size683); -- uint32_t _i687; -- for (_i687 = 0; _i687 < _size683; ++_i687) ++ uint32_t _size691; ++ ::apache::thrift::protocol::TType _etype694; ++ xfer += iprot->readListBegin(_etype694, _size691); ++ this->partNames.resize(_size691); ++ uint32_t _i695; ++ for (_i695 = 0; _i695 < _size691; ++_i695) { -- xfer += iprot->readString(this->partNames[_i687]); ++ xfer += iprot->readString(this->partNames[_i695]); } xfer += iprot->readListEnd(); } @@@ -17512,10 -17122,10 +17778,10 @@@ uint32_t ReplTblWriteIdStateRequest::wr xfer += oprot->writeFieldBegin("partNames", ::apache::thrift::protocol::T_LIST, 6); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->partNames.size())); -- std::vector<std::string> ::const_iterator _iter688; -- for (_iter688 = this->partNames.begin(); _iter688 != this->partNames.end(); ++_iter688) ++ std::vector<std::string> ::const_iterator _iter696; ++ for (_iter696 = this->partNames.begin(); _iter696 != this->partNames.end(); ++_iter696) { -- xfer += oprot->writeString((*_iter688)); ++ xfer += oprot->writeString((*_iter696)); } xfer += oprot->writeListEnd(); } @@@ -17537,23 -17147,23 +17803,23 @@@ void swap(ReplTblWriteIdStateRequest &a swap(a.__isset, b.__isset); } --ReplTblWriteIdStateRequest::ReplTblWriteIdStateRequest(const ReplTblWriteIdStateRequest& other689) { -- validWriteIdlist = other689.validWriteIdlist; -- user = other689.user; -- hostName = other689.hostName; -- dbName = other689.dbName; -- tableName = other689.tableName; -- partNames = other689.partNames; -- __isset = other689.__isset; --} --ReplTblWriteIdStateRequest& ReplTblWriteIdStateRequest::operator=(const ReplTblWriteIdStateRequest& other690) { -- validWriteIdlist = other690.validWriteIdlist; -- user = other690.user; -- hostName = other690.hostName; -- dbName = other690.dbName; -- tableName = other690.tableName; -- partNames = other690.partNames; -- __isset = other690.__isset; ++ReplTblWriteIdStateRequest::ReplTblWriteIdStateRequest(const ReplTblWriteIdStateRequest& other697) { ++ validWriteIdlist = other697.validWriteIdlist; ++ user = other697.user; ++ hostName = other697.hostName; ++ dbName = other697.dbName; ++ tableName = other697.tableName; ++ partNames = other697.partNames; ++ __isset = other697.__isset; ++} ++ReplTblWriteIdStateRequest& ReplTblWriteIdStateRequest::operator=(const ReplTblWriteIdStateRequest& other698) { ++ validWriteIdlist = other698.validWriteIdlist; ++ user = other698.user; ++ hostName = other698.hostName; ++ dbName = other698.dbName; ++ tableName = other698.tableName; ++ partNames = other698.partNames; ++ __isset = other698.__isset; return *this; } void ReplTblWriteIdStateRequest::printTo(std::ostream& out) const { @@@ -17608,14 -17218,14 +17874,14 @@@ uint32_t GetValidWriteIdsRequest::read( if (ftype == ::apache::thrift::protocol::T_LIST) { { this->fullTableNames.clear(); -- uint32_t _size691; -- ::apache::thrift::protocol::TType _etype694; -- xfer += iprot->readListBegin(_etype694, _size691); -- this->fullTableNames.resize(_size691); -- uint32_t _i695; -- for (_i695 = 0; _i695 < _size691; ++_i695) ++ uint32_t _size699; ++ ::apache::thrift::protocol::TType _etype702; ++ xfer += iprot->readListBegin(_etype702, _size699); ++ this->fullTableNames.resize(_size699); ++ uint32_t _i703; ++ for (_i703 = 0; _i703 < _size699; ++_i703) { -- xfer += iprot->readString(this->fullTableNames[_i695]); ++ xfer += iprot->readString(this->fullTableNames[_i703]); } xfer += iprot->readListEnd(); } @@@ -17656,10 -17266,10 +17922,10 @@@ uint32_t GetValidWriteIdsRequest::write xfer += oprot->writeFieldBegin("fullTableNames", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->fullTableNames.size())); -- std::vector<std::string> ::const_iterator _iter696; -- for (_iter696 = this->fullTableNames.begin(); _iter696 != this->fullTableNames.end(); ++_iter696) ++ std::vector<std::string> ::const_iterator _iter704; ++ for (_iter704 = this->fullTableNames.begin(); _iter704 != this->fullTableNames.end(); ++_iter704) { -- xfer += oprot->writeString((*_iter696)); ++ xfer += oprot->writeString((*_iter704)); } xfer += oprot->writeListEnd(); } @@@ -17680,13 -17290,13 +17946,13 @@@ void swap(GetValidWriteIdsRequest &a, G swap(a.validTxnList, b.validTxnList); } --GetValidWriteIdsRequest::GetValidWriteIdsRequest(const GetValidWriteIdsRequest& other697) { -- fullTableNames = other697.fullTableNames; -- validTxnList = other697.validTxnList; ++GetValidWriteIdsRequest::GetValidWriteIdsRequest(const GetValidWriteIdsRequest& other705) { ++ fullTableNames = other705.fullTableNames; ++ validTxnList = other705.validTxnList; } --GetValidWriteIdsRequest& GetValidWriteIdsRequest::operator=(const GetValidWriteIdsRequest& other698) { -- fullTableNames = other698.fullTableNames; -- validTxnList = other698.validTxnList; ++GetValidWriteIdsRequest& GetValidWriteIdsRequest::operator=(const GetValidWriteIdsRequest& other706) { ++ fullTableNames = other706.fullTableNames; ++ validTxnList = other706.validTxnList; return *this; } void GetValidWriteIdsRequest::printTo(std::ostream& out) const { @@@ -17768,14 -17378,14 +18034,14 @@@ uint32_t TableValidWriteIds::read(::apa if (ftype == ::apache::thrift::protocol::T_LIST) { { this->invalidWriteIds.clear(); -- uint32_t _size699; -- ::apache::thrift::protocol::TType _etype702; -- xfer += iprot->readListBegin(_etype702, _size699); -- this->invalidWriteIds.resize(_size699); -- uint32_t _i703; -- for (_i703 = 0; _i703 < _size699; ++_i703) ++ uint32_t _size707; ++ ::apache::thrift::protocol::TType _etype710; ++ xfer += iprot->readListBegin(_etype710, _size707); ++ this->invalidWriteIds.resize(_size707); ++ uint32_t _i711; ++ for (_i711 = 0; _i711 < _size707; ++_i711) { -- xfer += iprot->readI64(this->invalidWriteIds[_i703]); ++ xfer += iprot->readI64(this->invalidWriteIds[_i711]); } xfer += iprot->readListEnd(); } @@@ -17836,10 -17446,10 +18102,10 @@@ uint32_t TableValidWriteIds::write(::ap xfer += oprot->writeFieldBegin("invalidWriteIds", ::apache::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_I64, static_cast<uint32_t>(this->invalidWriteIds.size())); -- std::vector<int64_t> ::const_iterator _iter704; -- for (_iter704 = this->invalidWriteIds.begin(); _iter704 != this->invalidWriteIds.end(); ++_iter704) ++ std::vector<int64_t> ::const_iterator _iter712; ++ for (_iter712 = this->invalidWriteIds.begin(); _iter712 != this->invalidWriteIds.end(); ++_iter712) { -- xfer += oprot->writeI64((*_iter704)); ++ xfer += oprot->writeI64((*_iter712)); } xfer += oprot->writeListEnd(); } @@@ -17869,21 -17479,21 +18135,21 @@@ void swap(TableValidWriteIds &a, TableV swap(a.__isset, b.__isset); } --TableValidWriteIds::TableValidWriteIds(const TableValidWriteIds& other705) { -- fullTableName = other705.fullTableName; -- writeIdHighWaterMark = other705.writeIdHighWaterMark; -- invalidWriteIds = other705.invalidWriteIds; -- minOpenWriteId = other705.minOpenWriteId; -- abortedBits = other705.abortedBits; -- __isset = other705.__isset; --} --TableValidWriteIds& TableValidWriteIds::operator=(const TableValidWriteIds& other706) { -- fullTableName = other706.fullTableName; -- writeIdHighWaterMark = other706.writeIdHighWaterMark; -- invalidWriteIds = other706.invalidWriteIds; -- minOpenWriteId = other706.minOpenWriteId; -- abortedBits = other706.abortedBits; -- __isset = other706.__isset; ++TableValidWriteIds::TableValidWriteIds(const TableValidWriteIds& other713) { ++ fullTableName = other713.fullTableName; ++ writeIdHighWaterMark = other713.writeIdHighWaterMark; ++ invalidWriteIds = other713.invalidWriteIds; ++ minOpenWriteId = other713.minOpenWriteId; ++ abortedBits = other713.abortedBits; ++ __isset = other713.__isset; ++} ++TableValidWriteIds& TableValidWriteIds::operator=(const TableValidWriteIds& other714) { ++ fullTableName = other714.fullTableName; ++ writeIdHighWaterMark = other714.writeIdHighWaterMark; ++ invalidWriteIds = other714.invalidWriteIds; ++ minOpenWriteId = other714.minOpenWriteId; ++ abortedBits = other714.abortedBits; ++ __isset = other714.__isset; return *this; } void TableValidWriteIds::printTo(std::ostream& out) const { @@@ -17932,14 -17542,14 +18198,14 @@@ uint32_t GetValidWriteIdsResponse::read if (ftype == ::apache::thrift::protocol::T_LIST) { { this->tblValidWriteIds.clear(); -- uint32_t _size707; -- ::apache::thrift::protocol::TType _etype710; -- xfer += iprot->readListBegin(_etype710, _size707); -- this->tblValidWriteIds.resize(_size707); -- uint32_t _i711; -- for (_i711 = 0; _i711 < _size707; ++_i711) ++ uint32_t _size715; ++ ::apache::thrift::protocol::TType _etype718; ++ xfer += iprot->readListBegin(_etype718, _size715); ++ this->tblValidWriteIds.resize(_size715); ++ uint32_t _i719; ++ for (_i719 = 0; _i719 < _size715; ++_i719) { -- xfer += this->tblValidWriteIds[_i711].read(iprot); ++ xfer += this->tblValidWriteIds[_i719].read(iprot); } xfer += iprot->readListEnd(); } @@@ -17970,10 -17580,10 +18236,10 @@@ uint32_t GetValidWriteIdsResponse::writ xfer += oprot->writeFieldBegin("tblValidWriteIds", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->tblValidWriteIds.size())); -- std::vector<TableValidWriteIds> ::const_iterator _iter712; -- for (_iter712 = this->tblValidWriteIds.begin(); _iter712 != this->tblValidWriteIds.end(); ++_iter712) ++ std::vector<TableValidWriteIds> ::const_iterator _iter720; ++ for (_iter720 = this->tblValidWriteIds.begin(); _iter720 != this->tblValidWriteIds.end(); ++_iter720) { -- xfer += (*_iter712).write(oprot); ++ xfer += (*_iter720).write(oprot); } xfer += oprot->writeListEnd(); } @@@ -17989,11 -17599,11 +18255,11 @@@ void swap(GetValidWriteIdsResponse &a, swap(a.tblValidWriteIds, b.tblValidWriteIds); } --GetValidWriteIdsResponse::GetValidWriteIdsResponse(const GetValidWriteIdsResponse& other713) { -- tblValidWriteIds = other713.tblValidWriteIds; ++GetValidWriteIdsResponse::GetValidWriteIdsResponse(const GetValidWriteIdsResponse& other721) { ++ tblValidWriteIds = other721.tblValidWriteIds; } --GetValidWriteIdsResponse& GetValidWriteIdsResponse::operator=(const GetValidWriteIdsResponse& other714) { -- tblValidWriteIds = other714.tblValidWriteIds; ++GetValidWriteIdsResponse& GetValidWriteIdsResponse::operator=(const GetValidWriteIdsResponse& other722) { ++ tblValidWriteIds = other722.tblValidWriteIds; return *this; } void GetValidWriteIdsResponse::printTo(std::ostream& out) const { @@@ -18074,14 -17684,14 +18340,14 @@@ uint32_t AllocateTableWriteIdsRequest:: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->txnIds.clear(); -- uint32_t _size715; -- ::apache::thrift::protocol::TType _etype718; -- xfer += iprot->readListBegin(_etype718, _size715); -- this->txnIds.resize(_size715); -- uint32_t _i719; -- for (_i719 = 0; _i719 < _size715; ++_i719) ++ uint32_t _size723; ++ ::apache::thrift::protocol::TType _etype726; ++ xfer += iprot->readListBegin(_etype726, _size723); ++ this->txnIds.resize(_size723); ++ uint32_t _i727; ++ for (_i727 = 0; _i727 < _size723; ++_i727) { -- xfer += iprot->readI64(this->txnIds[_i719]); ++ xfer += iprot->readI64(this->txnIds[_i727]); } xfer += iprot->readListEnd(); } @@@ -18102,14 -17712,14 +18368,14 @@@ if (ftype == ::apache::thrift::protocol::T_LIST) { { this->srcTxnToWriteIdList.clear(); -- uint32_t _size720; -- ::apache::thrift::protocol::TType _etype723; -- xfer += iprot->readListBegin(_etype723, _size720); -- this->srcTxnToWriteIdList.resize(_size720); -- uint32_t _i724; -- for (_i724 = 0; _i724 < _size720; ++_i724) ++ uint32_t _size728; ++ ::apache::thrift::protocol::TType _etype731; ++ xfer += iprot->readListBegin(_etype731, _size728); ++ this->srcTxnToWriteIdList.resize(_size728); ++ uint32_t _i732; ++ for (_i732 = 0; _i732 < _size728; ++_i732) { -- xfer += this->srcTxnToWriteIdList[_i724].read(iprot); ++ xfer += this->srcTxnToWriteIdList[_i732].read(iprot); } xfer += iprot->readListEnd(); } @@@ -18151,10 -17761,10 +18417,10 @@@ uint32_t AllocateTableWriteIdsRequest:: xfer += oprot->writeFieldBegin("txnIds", ::apache::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_I64, static_cast<uint32_t>(this->txnIds.size())); -- std::vector<int64_t> ::const_iterator _iter725; -- for (_iter725 = this->txnIds.begin(); _iter725 != this->txnIds.end(); ++_iter725) ++ std::vector<int64_t> ::const_iterator _iter733; ++ for (_iter733 = this->txnIds.begin(); _iter733 != this->txnIds.end(); ++_iter733) { -- xfer += oprot->writeI64((*_iter725)); ++ xfer += oprot->writeI64((*_iter733)); } xfer += oprot->writeListEnd(); } @@@ -18169,10 -17779,10 +18435,10 @@@ xfer += oprot->writeFieldBegin("srcTxnToWriteIdList", ::apache::thrift::protocol::T_LIST, 5); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->srcTxnToWriteIdList.size())); -- std::vector<TxnToWriteId> ::const_iterator _iter726; -- for (_iter726 = this->srcTxnToWriteIdList.begin(); _iter726 != this->srcTxnToWriteIdList.end(); ++_iter726) ++ std::vector<TxnToWriteId> ::const_iterator _iter734; ++ for (_iter734 = this->srcTxnToWriteIdList.begin(); _iter734 != this->srcTxnToWriteIdList.end(); ++_iter734) { -- xfer += (*_iter726).write(oprot); ++ xfer += (*_iter734).write(oprot); } xfer += oprot->writeListEnd(); } @@@ -18193,21 -17803,21 +18459,21 @@@ void swap(AllocateTableWriteIdsRequest swap(a.__isset, b.__isset); } --AllocateTableWriteIdsRequest::AllocateTableWriteIdsRequest(const AllocateTableWriteIdsRequest& other727) { -- dbName = other727.dbName; -- tableName = other727.tableName; -- txnIds = other727.txnIds; -- replPolicy = other727.replPolicy; -- srcTxnToWriteIdList = other727.srcTxnToWriteIdList; -- __isset = other727.__isset; --} --AllocateTableWriteIdsRequest& AllocateTableWriteIdsRequest::operator=(const AllocateTableWriteIdsRequest& other728) { -- dbName = other728.dbName; -- tableName = other728.tableName; -- txnIds = other728.txnIds; -- replPolicy = other728.replPolicy; -- srcTxnToWriteIdList = other728.srcTxnToWriteIdList; -- __isset = other728.__isset; ++AllocateTableWriteIdsRequest::AllocateTableWriteIdsRequest(const AllocateTableWriteIdsRequest& other735) { ++ dbName = other735.dbName; ++ tableName = other735.tableName; ++ txnIds = other735.txnIds; ++ replPolicy = other735.replPolicy; ++ srcTxnToWriteIdList = other735.srcTxnToWriteIdList; ++ __isset = other735.__isset; ++} ++AllocateTableWriteIdsRequest& AllocateTableWriteIdsRequest::operator=(const AllocateTableWriteIdsRequest& other736) { ++ dbName = other736.dbName; ++ tableName = other736.tableName; ++ txnIds = other736.txnIds; ++ replPolicy = other736.replPolicy; ++ srcTxnToWriteIdList = other736.srcTxnToWriteIdList; ++ __isset = other736.__isset; return *this; } void AllocateTableWriteIdsRequest::printTo(std::ostream& out) const { @@@ -18313,13 -17923,13 +18579,13 @@@ void swap(TxnToWriteId &a, TxnToWriteI swap(a.writeId, b.writeId); } --TxnToWriteId::TxnToWriteId(const TxnToWriteId& other729) { -- txnId = other729.txnId; -- writeId = other729.writeId; ++TxnToWriteId::TxnToWriteId(const TxnToWriteId& other737) { ++ txnId = other737.txnId; ++ writeId = other737.writeId; } --TxnToWriteId& TxnToWriteId::operator=(const TxnToWriteId& other730) { -- txnId = other730.txnId; -- writeId = other730.writeId; ++TxnToWriteId& TxnToWriteId::operator=(const TxnToWriteId& other738) { ++ txnId = other738.txnId; ++ writeId = other738.writeId; return *this; } void TxnToWriteId::printTo(std::ostream& out) const { @@@ -18365,14 -17975,14 +18631,14 @@@ uint32_t AllocateTableWriteIdsResponse: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->txnToWriteIds.clear(); -- uint32_t _size731; -- ::apache::thrift::protocol::TType _etype734; -- xfer += iprot->readListBegin(_etype734, _size731); -- this->txnToWriteIds.resize(_size731); -- uint32_t _i735; -- for (_i735 = 0; _i735 < _size731; ++_i735) ++ uint32_t _size739; ++ ::apache::thrift::protocol::TType _etype742; ++ xfer += iprot->readListBegin(_etype742, _size739); ++ this->txnToWriteIds.resize(_size739); ++ uint32_t _i743; ++ for (_i743 = 0; _i743 < _size739; ++_i743) { -- xfer += this->txnToWriteIds[_i735].read(iprot); ++ xfer += this->txnToWriteIds[_i743].read(iprot); } xfer += iprot->readListEnd(); } @@@ -18403,10 -18013,10 +18669,10 @@@ uint32_t AllocateTableWriteIdsResponse: xfer += oprot->writeFieldBegin("txnToWriteIds", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->txnToWriteIds.size())); -- std::vector<TxnToWriteId> ::const_iterator _iter736; -- for (_iter736 = this->txnToWriteIds.begin(); _iter736 != this->txnToWriteIds.end(); ++_iter736) ++ std::vector<TxnToWriteId> ::const_iterator _iter744; ++ for (_iter744 = this->txnToWriteIds.begin(); _iter744 != this->txnToWriteIds.end(); ++_iter744) { -- xfer += (*_iter736).write(oprot); ++ xfer += (*_iter744).write(oprot); } xfer += oprot->writeListEnd(); } @@@ -18422,11 -18032,11 +18688,11 @@@ void swap(AllocateTableWriteIdsRespons swap(a.txnToWriteIds, b.txnToWriteIds); } --AllocateTableWriteIdsResponse::AllocateTableWriteIdsResponse(const AllocateTableWriteIdsResponse& other737) { -- txnToWriteIds = other737.txnToWriteIds; ++AllocateTableWriteIdsResponse::AllocateTableWriteIdsResponse(const AllocateTableWriteIdsResponse& other745) { ++ txnToWriteIds = other745.txnToWriteIds; } --AllocateTableWriteIdsResponse& AllocateTableWriteIdsResponse::operator=(const AllocateTableWriteIdsResponse& other738) { -- txnToWriteIds = other738.txnToWriteIds; ++AllocateTableWriteIdsResponse& AllocateTableWriteIdsResponse::operator=(const AllocateTableWriteIdsResponse& other746) { ++ txnToWriteIds = other746.txnToWriteIds; return *this; } void AllocateTableWriteIdsResponse::printTo(std::ostream& out) const { @@@ -18504,9 -18114,9 +18770,9 @@@ uint32_t LockComponent::read(::apache:: { case 1: if (ftype == ::apache::thrift::protocol::T_I32) { -- int32_t ecast739; -- xfer += iprot->readI32(ecast739); -- this->type = (LockType::type)ecast739; ++ int32_t ecast747; ++ xfer += iprot->readI32(ecast747); ++ this->type = (LockType::type)ecast747; isset_type = true; } else { xfer += iprot->skip(ftype); @@@ -18514,9 -18124,9 +18780,9 @@@ break; case 2: if (ftype == ::apache::thrift::protocol::T_I32) { -- int32_t ecast740; -- xfer += iprot->readI32(ecast740); -- this->level = (LockLevel::type)ecast740; ++ int32_t ecast748; ++ xfer += iprot->readI32(ecast748); ++ this->level = (LockLevel::type)ecast748; isset_level = true; } else { xfer += iprot->skip(ftype); @@@ -18548,9 -18158,9 +18814,9 @@@ break; case 6: if (ftype == ::apache::thrift::protocol::T_I32) { -- int32_t ecast741; -- xfer += iprot->readI32(ecast741); -- this->operationType = (DataOperationType::type)ecast741; ++ int32_t ecast749; ++ xfer += iprot->readI32(ecast749); ++ this->operationType = (DataOperationType::type)ecast749; this->__isset.operationType = true; } else { xfer += iprot->skip(ftype); @@@ -18650,27 -18260,27 +18916,27 @@@ void swap(LockComponent &a, LockCompone swap(a.__isset, b.__isset); } --LockComponent::LockComponent(const LockComponent& other742) { -- type = other742.type; -- level = other742.level; -- dbname = other742.dbname; -- tablename = other742.tablename; -- partitionname = other742.partitionname; -- operationType = other742.operationType; -- isTransactional = other742.isTransactional; -- isDynamicPartitionWrite = other742.isDynamicPartitionWrite; -- __isset = other742.__isset; --} --LockComponent& LockComponent::operator=(const LockComponent& other743) { -- type = other743.type; -- level = other743.level; -- dbname = other743.dbname; -- tablename = other743.tablename; -- partitionname = other743.partitionname; -- operationType = other743.operationType; -- isTransactional = other743.isTransactional; -- isDynamicPartitionWrite = other743.isDynamicPartitionWrite; -- __isset = other743.__isset; ++LockComponent::LockComponent(const LockComponent& other750) { ++ type = other750.type; ++ level = other750.level; ++ dbname = other750.dbname; ++ tablename = other750.tablename; ++ partitionname = other750.partitionname; ++ operationType = other750.operationType; ++ isTransactional = other750.isTransactional; ++ isDynamicPartitionWrite = other750.isDynamicPartitionWrite; ++ __isset = other750.__isset; ++} ++LockComponent& LockComponent::operator=(const LockComponent& other751) { ++ type = other751.type; ++ level = other751.level; ++ dbname = other751.dbname; ++ tablename = other751.tablename; ++ partitionname = other751.partitionname; ++ operationType = other751.operationType; ++ isTransactional = other751.isTransactional; ++ isDynamicPartitionWrite = other751.isDynamicPartitionWrite; ++ __isset = other751.__isset; return *this; } void LockComponent::printTo(std::ostream& out) const { @@@ -18742,14 -18352,14 +19008,14 @@@ uint32_t LockRequest::read(::apache::th if (ftype == ::apache::thrift::protocol::T_LIST) { { this->component.clear(); -- uint32_t _size744; -- ::apache::thrift::protocol::TType _etype747; -- xfer += iprot->readListBegin(_etype747, _size744); -- this->component.resize(_size744); -- uint32_t _i748; -- for (_i748 = 0; _i748 < _size744; ++_i748) ++ uint32_t _size752; ++ ::apache::thrift::protocol::TType _etype755; ++ xfer += iprot->readListBegin(_etype755, _size752); ++ this->component.resize(_size752); ++ uint32_t _i756; ++ for (_i756 = 0; _i756 < _size752; ++_i756) { -- xfer += this->component[_i748].read(iprot); ++ xfer += this->component[_i756].read(iprot); } xfer += iprot->readListEnd(); } @@@ -18816,10 -18426,10 +19082,10 @@@ uint32_t LockRequest::write(::apache::t xfer += oprot->writeFieldBegin("component", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->component.size())); -- std::vector<LockComponent> ::const_iterator _iter749; -- for (_iter749 = this->component.begin(); _iter749 != this->component.end(); ++_iter749) ++ std::vector<LockComponent> ::const_iterator _iter757; ++ for (_iter757 = this->component.begin(); _iter757 != this->component.end(); ++_iter757) { -- xfer += (*_iter749).write(oprot); ++ xfer += (*_iter757).write(oprot); } xfer += oprot->writeListEnd(); } @@@ -18858,21 -18468,21 +19124,21 @@@ void swap(LockRequest &a, LockRequest & swap(a.__isset, b.__isset); } --LockRequest::LockRequest(const LockRequest& other750) { -- component = other750.component; -- txnid = other750.txnid; -- user = other750.user; -- hostname = other750.hostname; -- agentInfo = other750.agentInfo; -- __isset = other750.__isset; --} --LockRequest& LockRequest::operator=(const LockRequest& other751) { -- component = other751.component; -- txnid = other751.txnid; -- user = other751.user; -- hostname = other751.hostname; -- agentInfo = other751.agentInfo; -- __isset = other751.__isset; ++LockRequest::LockRequest(const LockRequest& other758) { ++ component = other758.component; ++ txnid = other758.txnid; ++ user = other758.user; ++ hostname = other758.hostname; ++ agentInfo = other758.agentInfo; ++ __isset = other758.__isset; ++} ++LockRequest& LockRequest::operator=(const LockRequest& other759) { ++ component = other759.component; ++ txnid = other759.txnid; ++ user = other759.user; ++ hostname = other759.hostname; ++ agentInfo = other759.agentInfo; ++ __isset = other759.__isset; return *this; } void LockRequest::printTo(std::ostream& out) const { @@@ -18932,9 -18542,9 +19198,9 @@@ uint32_t LockResponse::read(::apache::t break; case 2: if (ftype == ::apache::thrift::protocol::T_I32) { -- int32_t ecast752; -- xfer += iprot->readI32(ecast752); -- this->state = (LockState::type)ecast752; ++ int32_t ecast760; ++ xfer += iprot->readI32(ecast760); ++ this->state = (LockState::type)ecast760; isset_state = true; } else { xfer += iprot->skip(ftype); @@@ -18980,13 -18590,13 +19246,13 @@@ void swap(LockResponse &a, LockRespons swap(a.state, b.state); } --LockResponse::LockResponse(const LockResponse& other753) { -- lockid = other753.lockid; -- state = other753.state; ++LockResponse::LockResponse(const LockResponse& other761) { ++ lockid = other761.lockid; ++ state = other761.state; } --LockResponse& LockResponse::operator=(const LockResponse& other754) { -- lockid = other754.lockid; -- state = other754.state; ++LockResponse& LockResponse::operator=(const LockResponse& other762) { ++ lockid = other762.lockid; ++ state = other762.state; return *this; } void LockResponse::printTo(std::ostream& out) const { @@@ -19108,17 -18718,17 +19374,17 @@@ void swap(CheckLockRequest &a, CheckLoc swap(a.__isset, b.__isset); } --CheckLockRequest::CheckLockRequest(const CheckLockRequest& other755) { -- lockid = other755.lockid; -- txnid = other755.txnid; -- elapsed_ms = other755.elapsed_ms; -- __isset = other755.__isset; ++CheckLockRequest::CheckLockRequest(const CheckLockRequest& other763) { ++ lockid = other763.lockid; ++ txnid = other763.txnid; ++ elapsed_ms = other763.elapsed_ms; ++ __isset = other763.__isset; } --CheckLockRequest& CheckLockRequest::operator=(const CheckLockRequest& other756) { -- lockid = other756.lockid; -- txnid = other756.txnid; -- elapsed_ms = other756.elapsed_ms; -- __isset = other756.__isset; ++CheckLockRequest& CheckLockRequest::operator=(const CheckLockRequest& other764) { ++ lockid = other764.lockid; ++ txnid = other764.txnid; ++ elapsed_ms = other764.elapsed_ms; ++ __isset = other764.__isset; return *this; } void CheckLockRequest::printTo(std::ostream& out) const { @@@ -19202,11 -18812,11 +19468,11 @@@ void swap(UnlockRequest &a, UnlockReque swap(a.lockid, b.lockid); } --UnlockRequest::UnlockRequest(const UnlockRequest& other757) { -- lockid = other757.lockid; ++UnlockRequest::UnlockRequest(const UnlockRequest& other765) { ++ lockid = other765.lockid; } --UnlockRequest& UnlockRequest::operator=(const UnlockRequest& other758) { -- lockid = other758.lockid; ++UnlockRequest& UnlockRequest::operator=(const UnlockRequest& other766) { ++ lockid = other766.lockid; return *this; } void UnlockRequest::printTo(std::ostream& out) const { @@@ -19345,19 -18955,19 +19611,19 @@@ void swap(ShowLocksRequest &a, ShowLock swap(a.__isset, b.__isset); } --ShowLocksRequest::ShowLocksRequest(const ShowLocksRequest& other759) { -- dbname = other759.dbname; -- tablename = other759.tablename; -- partname = other759.partname; -- isExtended = other759.isExtended; -- __isset = other759.__isset; ++ShowLocksRequest::ShowLocksRequest(const ShowLocksRequest& other767) { ++ dbname = other767.dbname; ++ tablename = other767.tablename; ++ partname = other767.partname; ++ isExtended = other767.isExtended; ++ __isset = other767.__isset; } --ShowLocksRequest& ShowLocksRequest::operator=(const ShowLocksRequest& other760) { -- dbname = other760.dbname; -- tablename = other760.tablename; -- partname = other760.partname; -- isExtended = other760.isExtended; -- __isset = other760.__isset; ++ShowLocksRequest& ShowLocksRequest::operator=(const ShowLocksRequest& other768) { ++ dbname = other768.dbname; ++ tablename = other768.tablename; ++ partname = other768.partname; ++ isExtended = other768.isExtended; ++ __isset = other768.__isset; return *this; } void ShowLocksRequest::printTo(std::ostream& out) const { @@@ -19510,9 -19120,9 +19776,9 @@@ uint32_t ShowLocksResponseElement::read break; case 5: if (ftype == ::apache::thrift::protocol::T_I32) { -- int32_t ecast761; -- xfer += iprot->readI32(ecast761); -- this->state = (LockState::type)ecast761; ++ int32_t ecast769; ++ xfer += iprot->readI32(ecast769); ++ this->state = (LockState::type)ecast769; isset_state = true; } else { xfer += iprot->skip(ftype); @@@ -19520,9 -19130,9 +19786,9 @@@ break; case 6: if (ftype == ::apache::thrift::protocol::T_I32) { -- int32_t ecast762; -- xfer += iprot->readI32(ecast762); -- this->type = (LockType::type)ecast762; ++ int32_t ecast770; ++ xfer += iprot->readI32(ecast770); ++ this->type = (LockType::type)ecast770; isset_type = true; } else { xfer += iprot->skip(ftype); @@@ -19738,43 -19348,43 +20004,43 @@@ void swap(ShowLocksResponseElement &a, swap(a.__isset, b.__isset); } --ShowLocksResponseElement::ShowLocksResponseElement(const ShowLocksResponseElement& other763) { -- lockid = other763.lockid; -- dbname = other763.dbname; -- tablename = other763.tablename; -- partname = other763.partname; -- state = other763.state; -- type = other763.type; -- txnid = other763.txnid; -- lastheartbeat = other763.lastheartbeat; -- acquiredat = other763.acquiredat; -- user = other763.user; -- hostname = other763.hostname; -- heartbeatCount = other763.heartbeatCount; -- agentInfo = other763.agentInfo; -- blockedByExtId = other763.blockedByExtId; -- blockedByIntId = other763.blockedByIntId; -- lockIdInternal = other763.lockIdInternal; -- __isset = other763.__isset; ++ShowLocksResponseElement::ShowLocksResponseElement(const ShowLocksResponseElement& other771) { ++ lockid = other771.lockid; ++ dbname = other771.dbname; ++ tablename = other771.tablename; ++ partname = other771.partname; ++ state = other771.state; ++ type = other771.type; ++ txnid = other771.txnid; ++ lastheartbeat = other771.lastheartbeat; ++ acquiredat = other771.acquiredat; ++ user = other771.user; ++ hostname = other771.hostname; ++ heartbeatCount = other771.heartbeatCount; ++ agentInfo = other771.agentInfo; ++ blockedByExtId = other771.blockedByExtId; ++ blockedByIntId = other771.blockedByIntId; ++ lockIdInternal = other771.lockIdInternal; ++ __isset = other771.__isset; } --ShowLocksResponseElement& ShowLocksResponseElement::operator=(const ShowLocksResponseElement& other764) { -- lockid = other764.lockid; -- dbname = other764.dbname; -- tablename = other764.tablename; -- partname = other764.partname; -- state = other764.state; -- type = other764.type; -- txnid = other764.txnid; -- lastheartbeat = other764.lastheartbeat; -- acquiredat = other764.acquiredat; -- user = other764.user; -- hostname = other764.hostname; -- heartbeatCount = other764.heartbeatCount; -- agentInfo = other764.agentInfo; -- blockedByExtId = other764.blockedByExtId; -- blockedByIntId = other764.blockedByIntId; -- lockIdInternal = other764.lockIdInternal; -- __isset = other764.__isset; ++ShowLocksResponseElement& ShowLocksResponseElement::operator=(const ShowLocksResponseElement& other772) { ++ lockid = other772.lockid; ++ dbname = other772.dbname; ++ tablename = other772.tablename; ++ partname = other772.partname; ++ state = other772.state; ++ type = other772.type; ++ txnid = other772.txnid; ++ lastheartbeat = other772.lastheartbeat; ++ acquiredat = other772.acquiredat; ++ user = other772.user; ++ hostname = other772.hostname; ++ heartbeatCount = other772.heartbeatCount; ++ agentInfo = other772.agentInfo; ++ blockedByExtId = other772.blockedByExtId; ++ blockedByIntId = other772.blockedByIntId; ++ lockIdInternal = other772.lockIdInternal; ++ __isset = other772.__isset; return *this; } void ShowLocksResponseElement::printTo(std::ostream& out) const { @@@ -19833,14 -19443,14 +20099,14 @@@ uint32_t ShowLocksResponse::read(::apac if (ftype == ::apache::thrift::protocol::T_LIST) { { this->locks.clear(); -- uint32_t _size765; -- ::apache::thrift::protocol::TType _etype768; -- xfer += iprot->readListBegin(_etype768, _size765); -- this->locks.resize(_size765); -- uint32_t _i769; -- for (_i769 = 0; _i769 < _size765; ++_i769) ++ uint32_t _size773; ++ ::apache::thrift::protocol::TType _etype776; ++ xfer += iprot->readListBegin(_etype776, _size773); ++ this->locks.resize(_size773); ++ uint32_t _i777; ++ for (_i777 = 0; _i777 < _size773; ++_i777) { -- xfer += this->locks[_i769].read(iprot); ++ xfer += this->locks[_i777].read(iprot); } xfer += iprot->readListEnd(); } @@@ -19869,10 -19479,10 +20135,10 @@@ uint32_t ShowLocksResponse::write(::apa xfer += oprot->writeFieldBegin("locks", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->locks.size())); -- std::vector<ShowLocksResponseElement> ::const_iterator _iter770; -- for (_iter770 = this->locks.begin(); _iter770 != this->locks.end(); ++_iter770) ++ std::vector<ShowLocksResponseElement> ::const_iterator _iter778; ++ for (_iter778 = this->locks.begin(); _iter778 != this->locks.end(); ++_iter778) { -- xfer += (*_iter770).write(oprot); ++ xfer += (*_iter778).write(oprot); } xfer += oprot->writeListEnd(); } @@@ -19889,13 -19499,13 +20155,13 @@@ void swap(ShowLocksResponse &a, ShowLoc swap(a.__isset, b.__isset); } --ShowLocksResponse::ShowLocksResponse(const ShowLocksResponse& other771) { -- locks = other771.locks; -- __isset = other771.__isset; ++ShowLocksResponse::ShowLocksResponse(const ShowLocksResponse& other779) { ++ locks = other779.locks; ++ __isset = other779.__isset; } --ShowLocksResponse& ShowLocksResponse::operator=(const ShowLocksResponse& other772) { -- locks = other772.locks; -- __isset = other772.__isset; ++ShowLocksResponse& ShowLocksResponse::operator=(const ShowLocksResponse& other780) { ++ locks = other780.locks; ++ __isset = other780.__isset; return *this; } void ShowLocksResponse::printTo(std::ostream& out) const { @@@ -19996,15 -19606,15 +20262,15 @@@ void swap(HeartbeatRequest &a, Heartbea swap(a.__isset, b.__isset); } --HeartbeatRequest::HeartbeatRequest(const HeartbeatRequest& other773) { -- lockid = other773.lockid; -- txnid = other773.txnid; -- __isset = other773.__isset; ++HeartbeatRequest::HeartbeatRequest(const HeartbeatRequest& other781) { ++ lockid = other781.lockid; ++ txnid = other781.txnid; ++ __isset = other781.__isset; } --HeartbeatRequest& HeartbeatRequest::operator=(const HeartbeatRequest& other774) { -- lockid = other774.lockid; -- txnid = other774.txnid; -- __isset = other774.__isset; ++HeartbeatRequest& HeartbeatRequest::operator=(const HeartbeatRequest& other782) { ++ lockid = other782.lockid; ++ txnid = other782.txnid; ++ __isset = other782.__isset; return *this; } void HeartbeatRequest::printTo(std::ostream& out) const { @@@ -20107,13 -19717,13 +20373,13 @@@ void swap(HeartbeatTxnRangeRequest &a, swap(a.max, b.max); } --HeartbeatTxnRangeRequest::HeartbeatTxnRangeRequest(const HeartbeatTxnRangeRequest& other775) { -- min = other775.min; -- max = other775.max; ++HeartbeatTxnRangeRequest::HeartbeatTxnRangeRequest(const HeartbeatTxnRangeRequest& other783) { ++ min = other783.min; ++ max = other783.max; } --HeartbeatTxnRangeRequest& HeartbeatTxnRangeRequest::operator=(const HeartbeatTxnRangeRequest& other776) { -- min = other776.min; -- max = other776.max; ++HeartbeatTxnRangeRequest& HeartbeatTxnRangeRequest::operator=(const HeartbeatTxnRangeRequest& other784) { ++ min = other784.min; ++ max = other784.max; return *this; } void HeartbeatTxnRangeRequest::printTo(std::ostream& out) const { @@@ -20164,15 -19774,15 +20430,15 @@@ uint32_t HeartbeatTxnRangeResponse::rea if (ftype == ::apache::thrift::protocol::T_SET) { { this->aborted.clear(); -- uint32_t _size777; -- ::apache::thrift::protocol::TType _etype780; -- xfer += iprot->readSetBegin(_etype780, _size777); -- uint32_t _i781; -- for (_i781 = 0; _i781 < _size777; ++_i781) ++ uint32_t _size785; ++ ::apache::thrift::protocol::TType _etype788; ++ xfer += iprot->readSetBegin(_etype788, _size785); ++ uint32_t _i789; ++ for (_i789 = 0; _i789 < _size785; ++_i789) { -- int64_t _elem782; -- xfer += iprot->readI64(_elem782); -- this->aborted.insert(_elem782); ++ int64_t _elem790; ++ xfer += iprot->readI64(_elem790); ++ this->aborted.insert(_elem790); } xfer += iprot->readSetEnd(); } @@@ -20185,15 -19795,15 +20451,15 @@@ if (ftype == ::apache::thrift::protocol::T_SET) { { this->nosuch.clear(); -- uint32_t _size783; -- ::apache::thrift::protocol::TType _etype786; -- xfer += iprot->readSetBegin(_etype786, _size783); -- uint32_t _i787; -- for (_i787 = 0; _i787 < _size783; ++_i787) ++ uint32_t _size791; ++ ::apache::thrift::protocol::TType _etype794; ++ xfer += iprot->readSetBegin(_etype794, _size791); ++ uint32_t _i795; ++ for (_i795 = 0; _i795 < _size791; ++_i795) { -- int64_t _elem788; -- xfer += iprot->readI64(_elem788); -- this->nosuch.insert(_elem788); ++ int64_t _elem796; ++ xfer += iprot->readI64(_elem796); ++ this->nosuch.insert(_elem796); } xfer += iprot->readSetEnd(); } @@@ -20226,10 -19836,10 +20492,10 @@@ uint32_t HeartbeatTxnRangeResponse::wri xfer += oprot->writeFieldBegin("aborted", ::apache::thrift::protocol::T_SET, 1); { xfer += oprot->writeSetBegin(::apache::thrift::protocol::T_I64, static_cast<uint32_t>(this->aborted.size())); -- std::set<int64_t> ::const_iterator _iter789; -- for (_iter789 = this->aborted.begin(); _iter789 != this->aborted.end(); ++_iter789) ++ std::set<int64_t> ::const_iterator _iter797; ++ for (_iter797 = this->aborted.begin(); _iter797 != this->aborted.end(); ++_iter797) { -- xfer += oprot->writeI64((*_iter789)); ++ xfer += oprot->writeI64((*_iter797)); } xfer += oprot->writeSetEnd(); } @@@ -20238,10 -19848,10 +20504,10 @@@ xfer += oprot->writeFieldBegin("nosuch", ::apache::thrift::protocol::T_SET, 2); { xfer += oprot->writeSetBegin(::apache::thrift::protocol::T_I64, static_cast<uint32_t>(this->nosuch.size())); -- std::set<int64_t> ::const_iterator _iter790; -- for (_iter790 = this->nosuch.begin(); _iter790 != this->nosuch.end(); ++_iter790) ++ std::set<int64_t> ::const_iterator _iter798; ++ for (_iter798 = this->nosuch.begin(); _iter798 != this->nosuch.end(); ++_iter798) { -- xfer += oprot->writeI64((*_iter790)); ++ xfer += oprot->writeI64((*_iter798)); } xfer += oprot->writeSetEnd(); } @@@ -20258,13 -19868,13 +20524,13 @@@ void swap(HeartbeatTxnRangeResponse &a swap(a.nosuch, b.nosuch); } --HeartbeatTxnRangeResponse::HeartbeatTxnRangeResponse(const HeartbeatTxnRangeResponse& other791) { -- aborted = other791.aborted; -- nosuch = other791.nosuch; ++HeartbeatTxnRangeResponse::HeartbeatTxnRangeResponse(const HeartbeatTxnRangeResponse& other799) { ++ aborted = other799.aborted; ++ nosuch = other799.nosuch; } --HeartbeatTxnRangeResponse& HeartbeatTxnRangeResponse::operator=(const HeartbeatTxnRangeResponse& other792) { -- aborted = other792.aborted; -- nosuch = other792.nosuch; ++HeartbeatTxnRangeResponse& HeartbeatTxnRangeResponse::operator=(const HeartbeatTxnRangeResponse& other800) { ++ aborted = other800.aborted; ++ nosuch = other800.nosuch; return *this; } void HeartbeatTxnRangeResponse::printTo(std::ostream& out) const { @@@ -20357,9 -19967,9 +20623,9 @@@ uint32_t CompactionRequest::read(::apac break; case 4: if (ftype == ::apache::thrift::protocol::T_I32) { -- int32_t ecast793; -- xfer += iprot->readI32(ecast793); -- this->type = (CompactionType::type)ecast793; ++ int32_t ecast801; ++ xfer += iprot->readI32(ecast801); ++ this->type = (CompactionType::type)ecast801; isset_type = true; } else { xfer += iprot->skip(ftype); @@@ -20377,17 -19987,17 +20643,17 @@@ if (ftype == ::apache::thrift::protocol::T_MAP) { { this->properties.clear(); -- uint32_t _size794; -- ::apache::thrift::protocol::TType _ktype795; -- ::apache::thrift::protocol::TType _vtype796; -- xfer += iprot->readMapBegin(_ktype795, _vtype796, _size794); -- uint32_t _i798; -- for (_i798 = 0; _i798 < _size794; ++_i798) ++ uint32_t _size802; ++ ::apache::thrift::protocol::TType _ktype803; ++ ::apache::thrift::protocol::TType _vtype804; ++ xfer += iprot->readMapBegin(_ktype803, _vtype804, _size802); ++ uint32_t _i806; ++ for (_i806 = 0; _i806 < _size802; ++_i806) { -- std::string _key799; -- xfer += iprot->readString(_key799); -- std::string& _val800 = this->properties[_key799]; -- xfer += iprot->readString(_val800); ++ std::string _key807; ++ xfer += iprot->readString(_key807); ++ std::string& _val808 = this->properties[_key807]; ++ xfer += iprot->readString(_val808); } xfer += iprot->readMapEnd(); } @@@ -20445,11 -20055,11 +20711,11 @@@ uint32_t CompactionRequest::write(::apa xfer += oprot->writeFieldBegin("properties", ::apache::thrift::protocol::T_MAP, 6); { xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->properties.size())); -- std::map<std::string, std::string> ::const_iterator _iter801; -- for (_iter801 = this->properties.begin(); _iter801 != this->properties.end(); ++_iter801) ++ std::map<std::string, std::string> ::const_iterator _iter809; ++ for (_iter809 = this->properties.begin(); _iter809 != this->properties.end(); ++_iter809) { -- xfer += oprot->writeString(_iter801->first); -- xfer += oprot->writeString(_iter801->second); ++ xfer += oprot->writeString(_iter809->first); ++ xfer += oprot->writeString(_iter809->second); } xfer += oprot->writeMapEnd(); } @@@ -20471,23 -20081,23 +20737,23 @@@ void swap(CompactionRequest &a, Compact swap(a.__isset, b.__isset); } --CompactionRequest::CompactionRequest(const CompactionRequest& other802) { -- dbname = other802.dbname; -- tablename = other802.tablename; -- partitionname = other802.partitionname; -- type = other802.type; -- runas = other802.runas; -- properties = other802.properties; -- __isset = other802.__isset; --} --CompactionRequest& CompactionRequest::operator=(const CompactionRequest& other803) { -- dbname = other803.dbname; -- tablename = other803.tablename; -- partitionname = other803.partitionname; -- type = other803.type; -- runas = other803.runas; -- properties = other803.properties; -- __isset = other803.__isset; ++CompactionRequest::CompactionRequest(const CompactionRequest& other810) { ++ dbname = other810.dbname; ++ tablename = other810.tablename; ++ partitionname = other810.partitionname; ++ type = other810.type; ++ runas = other810.runas; ++ properties = other810.properties; ++ __isset = other810.__isset; ++} ++CompactionRequest& CompactionRequest::operator=(const CompactionRequest& other811) { ++ dbname = other811.dbname; ++ tablename = other811.tablename; ++ partitionname = other811.partitionname; ++ type = other811.type; ++ runas = other811.runas; ++ properties = other811.properties; ++ __isset = other811.__isset; return *this; } void CompactionRequest::printTo(std::ostream& out) const { @@@ -20614,15 -20224,15 +20880,15 @@@ void swap(CompactionResponse &a, Compac swap(a.accepted, b.accepted); } --CompactionResponse::CompactionResponse(const CompactionResponse& other804) { -- id = other804.id; -- state = other804.state; -- accepted = other804.accepted; ++CompactionResponse::CompactionResponse(const CompactionResponse& other812) { ++ id = other812.id; ++ state = other812.state; ++ accepted = other812.accepted; } --CompactionResponse& CompactionResponse::operator=(const CompactionResponse& other805) { -- id = other805.id; -- state = other805.state; -- accepted = other805.accepted; ++CompactionResponse& CompactionResponse::operator=(const CompactionResponse& other813) { ++ id = other813.id; ++ state = other813.state; ++ accepted = other813.accepted; return *this; } void CompactionResponse::printTo(std::ostream& out) const { @@@ -20683,11 -20293,11 +20949,11 @@@ void swap(ShowCompactRequest &a, ShowCo (void) b; } --ShowCompactRequest::ShowCompactRequest(const ShowCompactRequest& other806) { -- (void) other806; ++ShowCompactRequest::ShowCompactRequest(const ShowCompactRequest& other814) { ++ (void) other814; } --ShowCompactRequest& ShowCompactRequest::operator=(const ShowCompactRequest& other807) { -- (void) other807; ++ShowCompactRequest& ShowCompactRequest::operator=(const ShowCompactRequest& other815) { ++ (void) other815; return *this; } void ShowCompactRequest::printTo(std::ostream& out) const { @@@ -20813,9 -20423,9 +21079,9 @@@ uint32_t ShowCompactResponseElement::re break; case 4: if (ftype == ::apache::thrift::protocol::T_I32) { -- int32_t ecast808; -- xfer += iprot->readI32(ecast808); -- this->type = (CompactionType::type)ecast808; ++ int32_t ecast816; ++ xfer += iprot->readI32(ecast816); ++ this->type = (CompactionType::type)ecast816; isset_type = true; } else { xfer += iprot->skip(ftype); @@@ -21002,37 -20612,37 +21268,37 @@@ void swap(ShowCompactResponseElement &a swap(a.__isset, b.__isset); } --ShowCompactResponseElement::ShowCompactResponseElement(const ShowCompactResponseElement& other809) { -- dbname = other809.dbname; -- tablename = other809.tablename; -- partitionname = other809.partitionname; -- type = other809.type; -- state = other809.state; -- workerid = other809.workerid; -- start = other809.start; -- runAs = other809.runAs; -- hightestTxnId = other809.hightestTxnId; -- metaInfo = other809.metaInfo; -- endTime = other809.endTime; -- hadoopJobId = other809.hadoopJobId; -- id = other809.id; -- __isset = other809.__isset; --} --ShowCompactResponseElement& ShowCompactResponseElement::operator=(const ShowCompactResponseElement& other810) { -- dbname = other810.dbname; -- tablename = other810.tablename; -- partitionname = other810.partitionname; -- type = other810.type; -- state = other810.state; -- workerid = other810.workerid; -- start = other810.start; -- runAs = other810.runAs; -- hightestTxnId = other810.hightestTxnId; -- metaInfo = other810.metaInfo; -- endTime = other810.endTime; -- hadoopJobId = other810.hadoopJobId; -- id = other810.id; -- __isset = other810.__isset; ++ShowCompactResponseElement::ShowCompactResponseElement(const ShowCompactResponseElement& other817) { ++ dbname = other817.dbname; ++ tablename = other817.tablename; ++ partitionname = other817.partitionname; ++ type = other817.type; ++ state = other817.state; ++ workerid = other817.workerid; ++ start = other817.start; ++ runAs = other817.runAs; ++ hightestTxnId = other817.hightestTxnId; ++ metaInfo = other817.metaInfo; ++ endTime = other817.endTime; ++ hadoopJobId = other817.hadoopJobId; ++ id = other817.id; ++ __isset = other817.__isset; ++} ++ShowCompactResponseElement& ShowCompactResponseElement::operator=(const ShowCompactResponseElement& other818) { ++ dbname = other818.dbname; ++ tablename = other818.tablename; ++ partitionname = other818.partitionname; ++ type = other818.type; ++ state = other818.state; ++ workerid = other818.workerid; ++ start = other818.start; ++ runAs = other818.runAs; ++ hightestTxnId = other818.hightestTxnId; ++ metaInfo = other818.metaInfo; ++ endTime = other818.endTime; ++ hadoopJobId = other818.hadoopJobId; ++ id = other818.id; ++ __isset = other818.__isset; return *this; } void ShowCompactResponseElement::printTo(std::ostream& out) const { @@@ -21089,14 -20699,14 +21355,14 @@@ uint32_t ShowCompactResponse::read(::ap if (ftype == ::apache::thrift::protocol::T_LIST) { { this->compacts.clear(); -- uint32_t _size811; -- ::apache::thrift::protocol::TType _etype814; -- xfer += iprot->readListBegin(_etype814, _size811); -- this->compacts.resize(_size811); -- uint32_t _i815; -- for (_i815 = 0; _i815 < _size811; ++_i815) ++ uint32_t _size819; ++ ::apache::thrift::protocol::TType _etype822; ++ xfer += iprot->readListBegin(_etype822, _size819); ++ this->compacts.resize(_size819); ++ uint32_t _i823; ++ for (_i823 = 0; _i823 < _size819; ++_i823) { -- xfer += this->compacts[_i815].read(iprot); ++ xfer += this->compacts[_i823].read(iprot); } xfer += iprot->readListEnd(); } @@@ -21127,10 -20737,10 +21393,10 @@@ uint32_t ShowCompactResponse::write(::a xfer += oprot->writeFieldBegin("compacts", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->compacts.size())); -- std::vector<ShowCompactResponseElement> ::const_iterator _iter816; -- for (_iter816 = this->compacts.begin(); _iter816 != this->compacts.end(); ++_iter816) ++ std::vector<ShowCompactResponseElement> ::const_iterator _iter824; ++ for (_iter824 = this->compacts.begin(); _iter824 != this->compacts.end(); ++_iter824) { -- xfer += (*_iter816).write(oprot); ++ xfer += (*_iter824).write(oprot); } xfer += oprot->writeListEnd(); } @@@ -21146,11 -20756,11 +21412,11 @@@ void swap(ShowCompactResponse &a, ShowC swap(a.compacts, b.compacts); } --ShowCompactResponse::ShowCompactResponse(const ShowCompactResponse& other817) { -- compacts = other817.compacts; ++ShowCompactResponse::ShowCompactResponse(const ShowCompactResponse& other825) { ++ compacts = other825.compacts; } --ShowCompactResponse& ShowCompactResponse::operator=(const ShowCompactResponse& other818) { -- compacts = other818.compacts; ++ShowCompactResponse& ShowCompactResponse::operator=(const ShowCompactResponse& other826) { ++ compacts = other826.compacts; return *this; } void ShowCompactResponse::printTo(std::ostream& out) const { @@@ -21252,14 -20862,14 +21518,14 @@@ uint32_t AddDynamicPartitions::read(::a if (ftype == ::apache::thrift::protocol::T_LIST) { { this->partitionnames.clear(); -- uint32_t _size819; -- ::apache::thrift::protocol::TType _etype822; -- xfer += iprot->readListBegin(_etype822, _size819); -- this->partitionnames.resize(_size819); -- uint32_t _i823; -- for (_i823 = 0; _i823 < _size819; ++_i823) ++ uint32_t _size827; ++ ::apache::thrift::protocol::TType _etype830; ++ xfer += iprot->readListBegin(_etype830, _size827); ++ this->partitionnames.resize(_size827); ++ uint32_t _i831; ++ for (_i831 = 0; _i831 < _size827; ++_i831) { -- xfer += iprot->readString(this->partitionnames[_i823]); ++ xfer += iprot->readString(this->partitionnames[_i831]); } xfer += iprot->readListEnd(); } @@@ -21270,9 -20880,9 +21536,9 @@@ break; case 6: if (ftype == ::apache::thrift::protocol::T_I32) { -- int32_t ecast824; -- xfer += iprot->readI32(ecast824); -- this->operationType = (DataOperationType::type)ecast824; ++ int32_t ecast832; ++ xfer += iprot->readI32(ecast832); ++ this->operationType = (DataOperationType::type)ecast832; this->__isset.operationType = true; } else { xfer += iprot->skip(ftype); @@@ -21324,10 -20934,10 +21590,10 @@@ uint32_t AddDynamicPartitions::write(:: xfer += oprot->writeFieldBegin("partitionnames", ::apache::thrift::protocol::T_LIST, 5); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->partitionnames.size())); -- std::vector<std::string> ::const_iterator _iter825; -- for (_iter825 = this->partitionnames.begin(); _iter825 != this->partitionnames.end(); ++_iter825) ++ std::vector<std::string> ::const_iterator _iter833; ++ for (_iter833 = this->partitionnames.begin(); _iter833 != this->partitionnames.end(); ++_iter833) { -- xfer += oprot->writeString((*_iter825)); ++ xfer += oprot->writeString((*_iter833)); } xfer += oprot->writeListEnd(); } @@@ -21354,23 -20964,23 +21620,23 @@@ void swap(AddDynamicPartitions &a, AddD swap(a.__isset, b.__isset); } --AddDynamicPartitions::AddDynamicPartitions(const AddDynamicPartitions& other826) { -- txnid = other826.txnid; -- writeid = other826.writeid; -- dbname = other826.dbname; -- tablename = other826.tablename; -- partitionnames = other826.partitionnames; -- operationType = other826.operationType; -- __isset = other826.__isset; --} --AddDynamicPartitions& AddDynamicPartitions::operator=(const AddDynamicPartitions& other827) { -- txnid = other827.txnid; -- writeid = other827.writeid; -- dbname = other827.dbname; -- tablename = other827.tablename; -- partitionnames = other827.partitionnames; -- operationType = other827.operationType; -- __isset = other827.__isset; ++AddDynamicPartitions::AddDynamicPartitions(const AddDynamicPartitions& other834) { ++ txnid = other834.txnid; ++ writeid = other834.writeid; ++ dbname = other834.dbname; ++ tablename = other834.tablename; ++ partitionnames = other834.partitionnames; ++ operationType = other834.operationType; ++ __isset = other834.__isset; ++} ++AddDynamicPartitions& AddDynamicPartitions::operator=(const AddDynamicPartitions& other835) { ++ txnid = other835.txnid; ++ writeid = other835.writeid; ++ dbname = other835.dbname; ++ tablename = other835.tablename; ++ partitionnames = other835.partitionnames; ++ operationType = other835.operationType; ++ __isset = other835.__isset; return *this; } void AddDynamicPartitions::printTo(std::ostream& out) const { @@@ -21553,23 -21163,23 +21819,23 @@@ void swap(BasicTxnInfo &a, BasicTxnInf swap(a.__isset, b.__isset); } --BasicTxnInfo::BasicTxnInfo(const BasicTxnInfo& other828) { -- isnull = other828.isnull; -- time = other828.time; -- txnid = other828.txnid; -- dbname = other828.dbname; -- tablename = other828.tablename; -- partitionname = other828.partitionname; -- __isset = other828.__isset; --} --BasicTxnInfo& BasicTxnInfo::operator=(const BasicTxnInfo& other829) { -- isnull = other829.isnull; -- time = other829.time; -- txnid = other829.txnid; -- dbname = other829.dbname; -- tablename = other829.tablename; -- partitionname = other829.partitionname; -- __isset = other829.__isset; ++BasicTxnInfo::BasicTxnInfo(const BasicTxnInfo& other836) { ++ isnull = other836.isnull; ++ time = other836.time; ++ txnid = other836.txnid; ++ dbname = other836.dbname; ++ tablename = other836.tablename; ++ partitionname = other836.partitionname; ++ __isset = other836.__isset; ++} ++BasicTxnInfo& BasicTxnInfo::operator=(const BasicTxnInfo& other837) { ++ isnull = other837.isnull; ++ time = other837.time; ++ txnid = other837.txnid; ++ dbname = other837.dbname; ++ tablename = other837.tablename; ++ partitionname = other837.partitionname; ++ __isset = other837.__isset; return *this; } void BasicTxnInfo::printTo(std::ostream& out) const { @@@ -21663,15 -21273,15 +21929,15 @@@ uint32_t CreationMetadata::read(::apach if (ftype == ::apache::thrift::protocol::T_SET) { { this->tablesUsed.clear(); -- uint32_t _size830; -- ::apache::thrift::protocol::TType _etype833; -- xfer += iprot->readSetBegin(_etype833, _size830); -- uint32_t _i834; -- for (_i834 = 0; _i834 < _size830; ++_i834) ++ uint32_t _size838; ++ ::apache::thrift::protocol::TType _etype841; ++ xfer += iprot->readSetBegin(_etype841, _size838); ++ uint32_t _i842; ++ for (_i842 = 0; _i842 < _size838; ++_i842) { -- std::string _elem835; -- xfer += iprot->readString(_elem835); -- this->tablesUsed.insert(_elem835); ++ std::string _elem843; ++ xfer += iprot->readString(_elem843); ++ this->tablesUsed.insert(_elem843); } xfer += iprot->readSetEnd(); } @@@ -21728,10 -21338,10 +21994,10 @@@ uint32_t CreationMetadata::write(::apac xfer += oprot->writeFieldBegin("tablesUsed", ::apache::thrift::protocol::T_SET, 4); { xfer += oprot->writeSetBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->tablesUsed.size())); -- std::set<std::string> ::const_iterator _iter836; -- for (_iter836 = this->tablesUsed.begin(); _iter836 != this->tablesUsed.end(); ++_iter836) ++ std::set<std::string> ::const_iterator _iter844; ++ for (_iter844 = this->tablesUsed.begin(); _iter844 != this->tablesUsed.end(); ++_iter844) { -- xfer += oprot->writeString((*_iter836)); ++ xfer += oprot->writeString((*_iter844)); } xfer += oprot->writeSetEnd(); } @@@ -21757,21 -21367,21 +22023,21 @@@ void swap(CreationMetadata &a, Creation swap(a.__isset, b.__isset); } --CreationMetadata::CreationMetadata(const CreationMetadata& other837) { -- catName = other837.catName; -- dbName = other837.dbName; -- tblName = other837.tblName; -- tablesUsed = other837.tablesUsed; -- validTxnList = other837.validTxnList; -- __isset = other837.__isset; --} --CreationMetadata& CreationMetadata::operator=(const CreationMetadata& other838) { -- catName = other838.catName; -- dbName = other838.dbName; -- tblName = other838.tblName; -- tablesUsed = other838.tablesUsed; -- validTxnList = other838.validTxnList; -- __isset = other838.__isset; ++CreationMetadata::CreationMetadata(const CreationMetadata& other845) { ++ catName = other845.catName; ++ dbName = other845.dbName; ++ tblName = other845.tblName; ++ tablesUsed = other845.tablesUsed; ++ validTxnList = other845.validTxnList; ++ __isset = other845.__isset; ++} ++CreationMetadata& CreationMetadata::operator=(const CreationMetadata& other846) { ++ catName = other846.catName; ++ dbName = other846.dbName; ++ tblName = other846.tblName; ++ tablesUsed = other846.tablesUsed; ++ validTxnList = other846.validTxnList; ++ __isset = other846.__isset; return *this; } void CreationMetadata::printTo(std::ostream& out) const { @@@ -21877,15 -21487,15 +22143,15 @@@ void swap(NotificationEventRequest &a, swap(a.__isset, b.__isset); } --NotificationEventRequest::NotificationEventRequest(const NotificationEventRequest& other839) { -- lastEvent = other839.lastEvent; -- maxEvents = other839.maxEvents; -- __isset = other839.__isset; ++NotificationEventRequest::NotificationEventRequest(const NotificationEventRequest& other847) { ++ lastEvent = other847.lastEvent; ++ maxEvents = other847.maxEvents; ++ __isset = other847.__isset; } --NotificationEventRequest& NotificationEventRequest::operator=(const NotificationEventRequest& other840) { -- lastEvent = other840.lastEvent; -- maxEvents = other840.maxEvents; -- __isset = other840.__isset; ++NotificationEventRequest& NotificationEventRequest::operator=(const NotificationEventRequest& other848) { ++ lastEvent = other848.lastEvent; ++ maxEvents = other848.maxEvents; ++ __isset = other848.__isset; return *this; } void NotificationEventRequest::printTo(std::ostream& out) const { @@@ -22105,27 -21715,27 +22371,27 @@@ void swap(NotificationEvent &a, Notific swap(a.__isset, b.__isset); } --NotificationEvent::NotificationEvent(const NotificationEvent& other841) { -- eventId = other841.eventId; -- eventTime = other841.eventTime; -- eventType = other841.eventType; -- dbName = other841.dbName; -- tableName = other841.tableName; -- message = other841.message; -- messageFormat = other841.messageFormat; -- catName = other841.catName; -- __isset = other841.__isset; --} --NotificationEvent& NotificationEvent::operator=(const NotificationEvent& other842) { -- eventId = other842.eventId; -- eventTime = other842.eventTime; -- eventType = other842.eventType; -- dbName = other842.dbName; -- tableName = other842.tableName; -- message = other842.message; -- messageFormat = other842.messageFormat; -- catName = other842.catName; -- __isset = other842.__isset; ++NotificationEvent::NotificationEvent(const NotificationEvent& other849) { ++ eventId = other849.eventId; ++ eventTime = other849.eventTime; ++ eventType = other849.eventType; ++ dbName = other849.dbName; ++ tableName = other849.tableName; ++ message = other849.message; ++ messageFormat = other849.messageFormat; ++ catName = other849.catName; ++ __isset = other849.__isset; ++} ++NotificationEvent& NotificationEvent::operator=(const NotificationEvent& other850) { ++ eventId = other850.eventId; ++ eventTime = other850.eventTime; ++ eventType = other850.eventType; ++ dbName = other850.dbName; ++ tableName = other850.tableName; ++ message = other850.message; ++ messageFormat = other850.messageFormat; ++ catName = other850.catName; ++ __isset = other850.__isset; return *this; } void NotificationEvent::printTo(std::ostream& out) const { @@@ -22177,14 -21787,14 +22443,14 @@@ uint32_t NotificationEventResponse::rea if (ftype == ::apache::thrift::protocol::T_LIST) { { this->events.clear(); -- uint32_t _size843; -- ::apache::thrift::protocol::TType _etype846; -- xfer += iprot->readListBegin(_etype846, _size843); -- this->events.resize(_size843); -- uint32_t _i847; -- for (_i847 = 0; _i847 < _size843; ++_i847) ++ uint32_t _size851; ++ ::apache::thrift::protocol::TType _etype854; ++ xfer += iprot->readListBegin(_etype854, _size851); ++ this->events.resize(_size851); ++ uint32_t _i855; ++ for (_i855 = 0; _i855 < _size851; ++_i855) { -- xfer += this->events[_i847].read(iprot); ++ xfer += this->events[_i855].read(iprot); } xfer += iprot->readListEnd(); } @@@ -22215,10 -21825,10 +22481,10 @@@ uint32_t NotificationEventResponse::wri xfer += oprot->writeFieldBegin("events", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->events.size())); -- std::vector<NotificationEvent> ::const_iterator _iter848; -- for (_iter848 = this->events.begin(); _iter848 != this->events.end(); ++_iter848) ++ std::vector<NotificationEvent> ::const_iterator _iter856; ++ for (_iter856 = this->events.begin(); _iter856 != this->events.end(); ++_iter856) { -- xfer += (*_iter848).write(oprot); ++ xfer += (*_iter856).write(oprot); } xfer += oprot->writeListEnd(); } @@@ -22234,11 -21844,11 +22500,11 @@@ void swap(NotificationEventResponse &a swap(a.events, b.events); } --NotificationEventResponse::NotificationEventResponse(const NotificationEventResponse& other849) { -- events = other849.events; ++NotificationEventResponse::NotificationEventResponse(const NotificationEventResponse& other857) { ++ events = other857.events; } --NotificationEventResponse& NotificationEventResponse::operator=(const NotificationEventResponse& other850) { -- events = other850.events; ++NotificationEventResponse& NotificationEventResponse::operator=(const NotificationEventResponse& other858) { ++ events = other858.events; return *this; } void NotificationEventResponse::printTo(std::ostream& out) const { @@@ -22320,11 -21930,11 +22586,11 @@@ void swap(CurrentNotificationEventId &a swap(a.eventId, b.eventId); } --CurrentNotificationEventId::CurrentNotificationEventId(const CurrentNotificationEventId& other851) { -- eventId = other851.eventId; ++CurrentNotificationEventId::CurrentNotificationEventId(const CurrentNotificationEventId& other859) { ++ eventId = other859.eventId; } --CurrentNotificationEventId& CurrentNotificationEventId::operator=(const CurrentNotificationEventId& other852) { -- eventId = other852.eventId; ++CurrentNotificationEventId& CurrentNotificationEventId::operator=(const CurrentNotificationEventId& other860) { ++ eventId = other860.eventId; return *this; } void CurrentNotificationEventId::printTo(std::ostream& out) const { @@@ -22446,17 -22056,17 +22712,17 @@@ void swap(NotificationEventsCountReques swap(a.__isset, b.__isset); } --NotificationEventsCountRequest::NotificationEventsCountRequest(const NotificationEventsCountRequest& other853) { -- fromEventId = other853.fromEventId; -- dbName = other853.dbName; -- catName = other853.catName; -- __isset = other853.__isset; ++NotificationEventsCountRequest::NotificationEventsCountRequest(const NotificationEventsCountRequest& other861) { ++ fromEventId = other861.fromEventId; ++ dbName = other861.dbName; ++ catName = other861.catName; ++ __isset = other861.__isset; } --NotificationEventsCountRequest& NotificationEventsCountRequest::operator=(const NotificationEventsCountRequest& other854) { -- fromEventId = other854.fromEventId; -- dbName = other854.dbName; -- catName = other854.catName; -- __isset = other854.__isset; ++NotificationEventsCountRequest& NotificationEventsCountRequest::operator=(const NotificationEventsCountRequest& other862) { ++ fromEventId = other862.fromEventId; ++ dbName = other862.dbName; ++ catName = other862.catName; ++ __isset = other862.__isset; return *this; } void NotificationEventsCountRequest::printTo(std::ostream& out) const { @@@ -22540,11 -22150,11 +22806,11 @@@ void swap(NotificationEventsCountRespon swap(a.eventsCount, b.eventsCount); } --NotificationEventsCountResponse::NotificationEventsCountResponse(const NotificationEventsCountResponse& other855) { -- eventsCount = other855.eventsCount; ++NotificationEventsCountResponse::NotificationEventsCountResponse(const NotificationEventsCountResponse& other863) { ++ eventsCount = other863.eventsCount; } --NotificationEventsCountResponse& NotificationEventsCountResponse::operator=(const NotificationEventsCountResponse& other856) { -- eventsCount = other856.eventsCount; ++NotificationEventsCountResponse& NotificationEventsCountResponse::operator=(const NotificationEventsCountResponse& other864) { ++ eventsCount = other864.eventsCount; return *this; } void NotificationEventsCountResponse::printTo(std::ostream& out) const { @@@ -22607,14 -22222,14 +22878,14 @@@ uint32_t InsertEventRequestData::read(: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->filesAdded.clear(); -- uint32_t _size857; -- ::apache::thrift::protocol::TType _etype860; -- xfer += iprot->readListBegin(_etype860, _size857); -- this->filesAdded.resize(_size857); -- uint32_t _i861; -- for (_i861 = 0; _i861 < _size857; ++_i861) ++ uint32_t _size865; ++ ::apache::thrift::protocol::TType _etype868; ++ xfer += iprot->readListBegin(_etype868, _size865); ++ this->filesAdded.resize(_size865); ++ uint32_t _i869; ++ for (_i869 = 0; _i869 < _size865; ++_i869) { -- xfer += iprot->readString(this->filesAdded[_i861]); ++ xfer += iprot->readString(this->filesAdded[_i869]); } xfer += iprot->readListEnd(); } @@@ -22627,14 -22242,14 +22898,14 @@@ if (ftype == ::apache::thrift::protocol::T_LIST) { { this->filesAddedChecksum.clear(); -- uint32_t _size862; -- ::apache::thrift::protocol::TType _etype865; -- xfer += iprot->readListBegin(_etype865, _size862); -- this->filesAddedChecksum.resize(_size862); -- uint32_t _i866; -- for (_i866 = 0; _i866 < _size862; ++_i866) ++ uint32_t _size870; ++ ::apache::thrift::protocol::TType _etype873; ++ xfer += iprot->readListBegin(_etype873, _size870); ++ this->filesAddedChecksum.resize(_size870); ++ uint32_t _i874; ++ for (_i874 = 0; _i874 < _size870; ++_i874) { -- xfer += iprot->readString(this->filesAddedChecksum[_i866]); ++ xfer += iprot->readString(this->filesAddedChecksum[_i874]); } xfer += iprot->readListEnd(); } @@@ -22643,6 -22258,26 +22914,26 @@@ xfer += iprot->skip(ftype); } break; + case 4: + if (ftype == ::apache::thrift::protocol::T_LIST) { + { + this->subDirectoryList.clear(); - uint32_t _size867; - ::apache::thrift::protocol::TType _etype870; - xfer += iprot->readListBegin(_etype870, _size867); - this->subDirectoryList.resize(_size867); - uint32_t _i871; - for (_i871 = 0; _i871 < _size867; ++_i871) ++ uint32_t _size875; ++ ::apache::thrift::protocol::TType _etype878; ++ xfer += iprot->readListBegin(_etype878, _size875); ++ this->subDirectoryList.resize(_size875); ++ uint32_t _i879; ++ for (_i879 = 0; _i879 < _size875; ++_i879) + { - xfer += iprot->readString(this->subDirectoryList[_i871]); ++ xfer += iprot->readString(this->subDirectoryList[_i879]); + } + xfer += iprot->readListEnd(); + } + this->__isset.subDirectoryList = true; + } else { + xfer += iprot->skip(ftype); + } + break; default: xfer += iprot->skip(ftype); break; @@@ -22670,10 -22305,10 +22961,10 @@@ uint32_t InsertEventRequestData::write( xfer += oprot->writeFieldBegin("filesAdded", ::apache::thrift::protocol::T_LIST, 2); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->filesAdded.size())); - std::vector<std::string> ::const_iterator _iter867; - for (_iter867 = this->filesAdded.begin(); _iter867 != this->filesAdded.end(); ++_iter867) - std::vector<std::string> ::const_iterator _iter872; - for (_iter872 = this->filesAdded.begin(); _iter872 != this->filesAdded.end(); ++_iter872) ++ std::vector<std::string> ::const_iterator _iter880; ++ for (_iter880 = this->filesAdded.begin(); _iter880 != this->filesAdded.end(); ++_iter880) { - xfer += oprot->writeString((*_iter867)); - xfer += oprot->writeString((*_iter872)); ++ xfer += oprot->writeString((*_iter880)); } xfer += oprot->writeListEnd(); } @@@ -22683,10 -22318,23 +22974,23 @@@ xfer += oprot->writeFieldBegin("filesAddedChecksum", ::apache::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->filesAddedChecksum.size())); - std::vector<std::string> ::const_iterator _iter868; - for (_iter868 = this->filesAddedChecksum.begin(); _iter868 != this->filesAddedChecksum.end(); ++_iter868) - std::vector<std::string> ::const_iterator _iter873; - for (_iter873 = this->filesAddedChecksum.begin(); _iter873 != this->filesAddedChecksum.end(); ++_iter873) ++ std::vector<std::string> ::const_iterator _iter881; ++ for (_iter881 = this->filesAddedChecksum.begin(); _iter881 != this->filesAddedChecksum.end(); ++_iter881) + { - xfer += oprot->writeString((*_iter873)); ++ xfer += oprot->writeString((*_iter881)); + } + xfer += oprot->writeListEnd(); + } + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.subDirectoryList) { + xfer += oprot->writeFieldBegin("subDirectoryList", ::apache::thrift::protocol::T_LIST, 4); + { + xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->subDirectoryList.size())); - std:
<TRUNCATED> http://git-wip-us.apache.org/repos/asf/hive/blob/4db8b1c6/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h ----------------------------------------------------------------------
