http://git-wip-us.apache.org/repos/asf/hive/blob/bbd99ed6/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp b/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp index a74e28b..1311b20 100644 --- a/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp +++ b/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp @@ -16108,6 +16108,11 @@ void InsertEventRequestData::__set_filesAdded(const std::vector<std::string> & v this->filesAdded = val; } +void InsertEventRequestData::__set_filesAddedChecksum(const std::vector<std::string> & val) { + this->filesAddedChecksum = val; +__isset.filesAddedChecksum = true; +} + uint32_t InsertEventRequestData::read(::apache::thrift::protocol::TProtocol* iprot) { apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); @@ -16150,6 +16155,26 @@ uint32_t InsertEventRequestData::read(::apache::thrift::protocol::TProtocol* ipr xfer += iprot->skip(ftype); } break; + case 2: + if (ftype == ::apache::thrift::protocol::T_LIST) { + { + this->filesAddedChecksum.clear(); + uint32_t _size656; + ::apache::thrift::protocol::TType _etype659; + xfer += iprot->readListBegin(_etype659, _size656); + this->filesAddedChecksum.resize(_size656); + uint32_t _i660; + for (_i660 = 0; _i660 < _size656; ++_i660) + { + xfer += iprot->readBinary(this->filesAddedChecksum[_i660]); + } + xfer += iprot->readListEnd(); + } + this->__isset.filesAddedChecksum = true; + } else { + xfer += iprot->skip(ftype); + } + break; default: xfer += iprot->skip(ftype); break; @@ -16172,15 +16197,28 @@ uint32_t InsertEventRequestData::write(::apache::thrift::protocol::TProtocol* op xfer += oprot->writeFieldBegin("filesAdded", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->filesAdded.size())); - std::vector<std::string> ::const_iterator _iter656; - for (_iter656 = this->filesAdded.begin(); _iter656 != this->filesAdded.end(); ++_iter656) + std::vector<std::string> ::const_iterator _iter661; + for (_iter661 = this->filesAdded.begin(); _iter661 != this->filesAdded.end(); ++_iter661) { - xfer += oprot->writeString((*_iter656)); + xfer += oprot->writeString((*_iter661)); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); + if (this->__isset.filesAddedChecksum) { + xfer += oprot->writeFieldBegin("filesAddedChecksum", ::apache::thrift::protocol::T_LIST, 2); + { + xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->filesAddedChecksum.size())); + std::vector<std::string> ::const_iterator _iter662; + for (_iter662 = this->filesAddedChecksum.begin(); _iter662 != this->filesAddedChecksum.end(); ++_iter662) + { + xfer += oprot->writeBinary((*_iter662)); + } + xfer += oprot->writeListEnd(); + } + xfer += oprot->writeFieldEnd(); + } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; @@ -16189,19 +16227,26 @@ uint32_t InsertEventRequestData::write(::apache::thrift::protocol::TProtocol* op void swap(InsertEventRequestData &a, InsertEventRequestData &b) { using ::std::swap; swap(a.filesAdded, b.filesAdded); + swap(a.filesAddedChecksum, b.filesAddedChecksum); + swap(a.__isset, b.__isset); } -InsertEventRequestData::InsertEventRequestData(const InsertEventRequestData& other657) { - filesAdded = other657.filesAdded; +InsertEventRequestData::InsertEventRequestData(const InsertEventRequestData& other663) { + filesAdded = other663.filesAdded; + filesAddedChecksum = other663.filesAddedChecksum; + __isset = other663.__isset; } -InsertEventRequestData& InsertEventRequestData::operator=(const InsertEventRequestData& other658) { - filesAdded = other658.filesAdded; +InsertEventRequestData& InsertEventRequestData::operator=(const InsertEventRequestData& other664) { + filesAdded = other664.filesAdded; + filesAddedChecksum = other664.filesAddedChecksum; + __isset = other664.__isset; return *this; } void InsertEventRequestData::printTo(std::ostream& out) const { using ::apache::thrift::to_string; out << "InsertEventRequestData("; out << "filesAdded=" << to_string(filesAdded); + out << ", " << "filesAddedChecksum="; (__isset.filesAddedChecksum ? (out << to_string(filesAddedChecksum)) : (out << "<null>")); out << ")"; } @@ -16275,13 +16320,13 @@ void swap(FireEventRequestData &a, FireEventRequestData &b) { swap(a.__isset, b.__isset); } -FireEventRequestData::FireEventRequestData(const FireEventRequestData& other659) { - insertData = other659.insertData; - __isset = other659.__isset; +FireEventRequestData::FireEventRequestData(const FireEventRequestData& other665) { + insertData = other665.insertData; + __isset = other665.__isset; } -FireEventRequestData& FireEventRequestData::operator=(const FireEventRequestData& other660) { - insertData = other660.insertData; - __isset = other660.__isset; +FireEventRequestData& FireEventRequestData::operator=(const FireEventRequestData& other666) { + insertData = other666.insertData; + __isset = other666.__isset; return *this; } void FireEventRequestData::printTo(std::ostream& out) const { @@ -16378,14 +16423,14 @@ uint32_t FireEventRequest::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->partitionVals.clear(); - uint32_t _size661; - ::apache::thrift::protocol::TType _etype664; - xfer += iprot->readListBegin(_etype664, _size661); - this->partitionVals.resize(_size661); - uint32_t _i665; - for (_i665 = 0; _i665 < _size661; ++_i665) + uint32_t _size667; + ::apache::thrift::protocol::TType _etype670; + xfer += iprot->readListBegin(_etype670, _size667); + this->partitionVals.resize(_size667); + uint32_t _i671; + for (_i671 = 0; _i671 < _size667; ++_i671) { - xfer += iprot->readString(this->partitionVals[_i665]); + xfer += iprot->readString(this->partitionVals[_i671]); } xfer += iprot->readListEnd(); } @@ -16437,10 +16482,10 @@ uint32_t FireEventRequest::write(::apache::thrift::protocol::TProtocol* oprot) c xfer += oprot->writeFieldBegin("partitionVals", ::apache::thrift::protocol::T_LIST, 5); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->partitionVals.size())); - std::vector<std::string> ::const_iterator _iter666; - for (_iter666 = this->partitionVals.begin(); _iter666 != this->partitionVals.end(); ++_iter666) + std::vector<std::string> ::const_iterator _iter672; + for (_iter672 = this->partitionVals.begin(); _iter672 != this->partitionVals.end(); ++_iter672) { - xfer += oprot->writeString((*_iter666)); + xfer += oprot->writeString((*_iter672)); } xfer += oprot->writeListEnd(); } @@ -16461,21 +16506,21 @@ void swap(FireEventRequest &a, FireEventRequest &b) { swap(a.__isset, b.__isset); } -FireEventRequest::FireEventRequest(const FireEventRequest& other667) { - successful = other667.successful; - data = other667.data; - dbName = other667.dbName; - tableName = other667.tableName; - partitionVals = other667.partitionVals; - __isset = other667.__isset; -} -FireEventRequest& FireEventRequest::operator=(const FireEventRequest& other668) { - successful = other668.successful; - data = other668.data; - dbName = other668.dbName; - tableName = other668.tableName; - partitionVals = other668.partitionVals; - __isset = other668.__isset; +FireEventRequest::FireEventRequest(const FireEventRequest& other673) { + successful = other673.successful; + data = other673.data; + dbName = other673.dbName; + tableName = other673.tableName; + partitionVals = other673.partitionVals; + __isset = other673.__isset; +} +FireEventRequest& FireEventRequest::operator=(const FireEventRequest& other674) { + successful = other674.successful; + data = other674.data; + dbName = other674.dbName; + tableName = other674.tableName; + partitionVals = other674.partitionVals; + __isset = other674.__isset; return *this; } void FireEventRequest::printTo(std::ostream& out) const { @@ -16538,11 +16583,11 @@ void swap(FireEventResponse &a, FireEventResponse &b) { (void) b; } -FireEventResponse::FireEventResponse(const FireEventResponse& other669) { - (void) other669; +FireEventResponse::FireEventResponse(const FireEventResponse& other675) { + (void) other675; } -FireEventResponse& FireEventResponse::operator=(const FireEventResponse& other670) { - (void) other670; +FireEventResponse& FireEventResponse::operator=(const FireEventResponse& other676) { + (void) other676; return *this; } void FireEventResponse::printTo(std::ostream& out) const { @@ -16642,15 +16687,15 @@ void swap(MetadataPpdResult &a, MetadataPpdResult &b) { swap(a.__isset, b.__isset); } -MetadataPpdResult::MetadataPpdResult(const MetadataPpdResult& other671) { - metadata = other671.metadata; - includeBitset = other671.includeBitset; - __isset = other671.__isset; +MetadataPpdResult::MetadataPpdResult(const MetadataPpdResult& other677) { + metadata = other677.metadata; + includeBitset = other677.includeBitset; + __isset = other677.__isset; } -MetadataPpdResult& MetadataPpdResult::operator=(const MetadataPpdResult& other672) { - metadata = other672.metadata; - includeBitset = other672.includeBitset; - __isset = other672.__isset; +MetadataPpdResult& MetadataPpdResult::operator=(const MetadataPpdResult& other678) { + metadata = other678.metadata; + includeBitset = other678.includeBitset; + __isset = other678.__isset; return *this; } void MetadataPpdResult::printTo(std::ostream& out) const { @@ -16701,17 +16746,17 @@ uint32_t GetFileMetadataByExprResult::read(::apache::thrift::protocol::TProtocol if (ftype == ::apache::thrift::protocol::T_MAP) { { this->metadata.clear(); - uint32_t _size673; - ::apache::thrift::protocol::TType _ktype674; - ::apache::thrift::protocol::TType _vtype675; - xfer += iprot->readMapBegin(_ktype674, _vtype675, _size673); - uint32_t _i677; - for (_i677 = 0; _i677 < _size673; ++_i677) + uint32_t _size679; + ::apache::thrift::protocol::TType _ktype680; + ::apache::thrift::protocol::TType _vtype681; + xfer += iprot->readMapBegin(_ktype680, _vtype681, _size679); + uint32_t _i683; + for (_i683 = 0; _i683 < _size679; ++_i683) { - int64_t _key678; - xfer += iprot->readI64(_key678); - MetadataPpdResult& _val679 = this->metadata[_key678]; - xfer += _val679.read(iprot); + int64_t _key684; + xfer += iprot->readI64(_key684); + MetadataPpdResult& _val685 = this->metadata[_key684]; + xfer += _val685.read(iprot); } xfer += iprot->readMapEnd(); } @@ -16752,11 +16797,11 @@ uint32_t GetFileMetadataByExprResult::write(::apache::thrift::protocol::TProtoco xfer += oprot->writeFieldBegin("metadata", ::apache::thrift::protocol::T_MAP, 1); { xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_I64, ::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->metadata.size())); - std::map<int64_t, MetadataPpdResult> ::const_iterator _iter680; - for (_iter680 = this->metadata.begin(); _iter680 != this->metadata.end(); ++_iter680) + std::map<int64_t, MetadataPpdResult> ::const_iterator _iter686; + for (_iter686 = this->metadata.begin(); _iter686 != this->metadata.end(); ++_iter686) { - xfer += oprot->writeI64(_iter680->first); - xfer += _iter680->second.write(oprot); + xfer += oprot->writeI64(_iter686->first); + xfer += _iter686->second.write(oprot); } xfer += oprot->writeMapEnd(); } @@ -16777,13 +16822,13 @@ void swap(GetFileMetadataByExprResult &a, GetFileMetadataByExprResult &b) { swap(a.isSupported, b.isSupported); } -GetFileMetadataByExprResult::GetFileMetadataByExprResult(const GetFileMetadataByExprResult& other681) { - metadata = other681.metadata; - isSupported = other681.isSupported; +GetFileMetadataByExprResult::GetFileMetadataByExprResult(const GetFileMetadataByExprResult& other687) { + metadata = other687.metadata; + isSupported = other687.isSupported; } -GetFileMetadataByExprResult& GetFileMetadataByExprResult::operator=(const GetFileMetadataByExprResult& other682) { - metadata = other682.metadata; - isSupported = other682.isSupported; +GetFileMetadataByExprResult& GetFileMetadataByExprResult::operator=(const GetFileMetadataByExprResult& other688) { + metadata = other688.metadata; + isSupported = other688.isSupported; return *this; } void GetFileMetadataByExprResult::printTo(std::ostream& out) const { @@ -16844,14 +16889,14 @@ uint32_t GetFileMetadataByExprRequest::read(::apache::thrift::protocol::TProtoco if (ftype == ::apache::thrift::protocol::T_LIST) { { this->fileIds.clear(); - uint32_t _size683; - ::apache::thrift::protocol::TType _etype686; - xfer += iprot->readListBegin(_etype686, _size683); - this->fileIds.resize(_size683); - uint32_t _i687; - for (_i687 = 0; _i687 < _size683; ++_i687) + uint32_t _size689; + ::apache::thrift::protocol::TType _etype692; + xfer += iprot->readListBegin(_etype692, _size689); + this->fileIds.resize(_size689); + uint32_t _i693; + for (_i693 = 0; _i693 < _size689; ++_i693) { - xfer += iprot->readI64(this->fileIds[_i687]); + xfer += iprot->readI64(this->fileIds[_i693]); } xfer += iprot->readListEnd(); } @@ -16878,9 +16923,9 @@ uint32_t GetFileMetadataByExprRequest::read(::apache::thrift::protocol::TProtoco break; case 4: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast688; - xfer += iprot->readI32(ecast688); - this->type = (FileMetadataExprType::type)ecast688; + int32_t ecast694; + xfer += iprot->readI32(ecast694); + this->type = (FileMetadataExprType::type)ecast694; this->__isset.type = true; } else { xfer += iprot->skip(ftype); @@ -16910,10 +16955,10 @@ uint32_t GetFileMetadataByExprRequest::write(::apache::thrift::protocol::TProtoc xfer += oprot->writeFieldBegin("fileIds", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_I64, static_cast<uint32_t>(this->fileIds.size())); - std::vector<int64_t> ::const_iterator _iter689; - for (_iter689 = this->fileIds.begin(); _iter689 != this->fileIds.end(); ++_iter689) + std::vector<int64_t> ::const_iterator _iter695; + for (_iter695 = this->fileIds.begin(); _iter695 != this->fileIds.end(); ++_iter695) { - xfer += oprot->writeI64((*_iter689)); + xfer += oprot->writeI64((*_iter695)); } xfer += oprot->writeListEnd(); } @@ -16947,19 +16992,19 @@ void swap(GetFileMetadataByExprRequest &a, GetFileMetadataByExprRequest &b) { swap(a.__isset, b.__isset); } -GetFileMetadataByExprRequest::GetFileMetadataByExprRequest(const GetFileMetadataByExprRequest& other690) { - fileIds = other690.fileIds; - expr = other690.expr; - doGetFooters = other690.doGetFooters; - type = other690.type; - __isset = other690.__isset; +GetFileMetadataByExprRequest::GetFileMetadataByExprRequest(const GetFileMetadataByExprRequest& other696) { + fileIds = other696.fileIds; + expr = other696.expr; + doGetFooters = other696.doGetFooters; + type = other696.type; + __isset = other696.__isset; } -GetFileMetadataByExprRequest& GetFileMetadataByExprRequest::operator=(const GetFileMetadataByExprRequest& other691) { - fileIds = other691.fileIds; - expr = other691.expr; - doGetFooters = other691.doGetFooters; - type = other691.type; - __isset = other691.__isset; +GetFileMetadataByExprRequest& GetFileMetadataByExprRequest::operator=(const GetFileMetadataByExprRequest& other697) { + fileIds = other697.fileIds; + expr = other697.expr; + doGetFooters = other697.doGetFooters; + type = other697.type; + __isset = other697.__isset; return *this; } void GetFileMetadataByExprRequest::printTo(std::ostream& out) const { @@ -17012,17 +17057,17 @@ uint32_t GetFileMetadataResult::read(::apache::thrift::protocol::TProtocol* ipro if (ftype == ::apache::thrift::protocol::T_MAP) { { this->metadata.clear(); - uint32_t _size692; - ::apache::thrift::protocol::TType _ktype693; - ::apache::thrift::protocol::TType _vtype694; - xfer += iprot->readMapBegin(_ktype693, _vtype694, _size692); - uint32_t _i696; - for (_i696 = 0; _i696 < _size692; ++_i696) + uint32_t _size698; + ::apache::thrift::protocol::TType _ktype699; + ::apache::thrift::protocol::TType _vtype700; + xfer += iprot->readMapBegin(_ktype699, _vtype700, _size698); + uint32_t _i702; + for (_i702 = 0; _i702 < _size698; ++_i702) { - int64_t _key697; - xfer += iprot->readI64(_key697); - std::string& _val698 = this->metadata[_key697]; - xfer += iprot->readBinary(_val698); + int64_t _key703; + xfer += iprot->readI64(_key703); + std::string& _val704 = this->metadata[_key703]; + xfer += iprot->readBinary(_val704); } xfer += iprot->readMapEnd(); } @@ -17063,11 +17108,11 @@ uint32_t GetFileMetadataResult::write(::apache::thrift::protocol::TProtocol* opr xfer += oprot->writeFieldBegin("metadata", ::apache::thrift::protocol::T_MAP, 1); { xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_I64, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->metadata.size())); - std::map<int64_t, std::string> ::const_iterator _iter699; - for (_iter699 = this->metadata.begin(); _iter699 != this->metadata.end(); ++_iter699) + std::map<int64_t, std::string> ::const_iterator _iter705; + for (_iter705 = this->metadata.begin(); _iter705 != this->metadata.end(); ++_iter705) { - xfer += oprot->writeI64(_iter699->first); - xfer += oprot->writeBinary(_iter699->second); + xfer += oprot->writeI64(_iter705->first); + xfer += oprot->writeBinary(_iter705->second); } xfer += oprot->writeMapEnd(); } @@ -17088,13 +17133,13 @@ void swap(GetFileMetadataResult &a, GetFileMetadataResult &b) { swap(a.isSupported, b.isSupported); } -GetFileMetadataResult::GetFileMetadataResult(const GetFileMetadataResult& other700) { - metadata = other700.metadata; - isSupported = other700.isSupported; +GetFileMetadataResult::GetFileMetadataResult(const GetFileMetadataResult& other706) { + metadata = other706.metadata; + isSupported = other706.isSupported; } -GetFileMetadataResult& GetFileMetadataResult::operator=(const GetFileMetadataResult& other701) { - metadata = other701.metadata; - isSupported = other701.isSupported; +GetFileMetadataResult& GetFileMetadataResult::operator=(const GetFileMetadataResult& other707) { + metadata = other707.metadata; + isSupported = other707.isSupported; return *this; } void GetFileMetadataResult::printTo(std::ostream& out) const { @@ -17140,14 +17185,14 @@ uint32_t GetFileMetadataRequest::read(::apache::thrift::protocol::TProtocol* ipr if (ftype == ::apache::thrift::protocol::T_LIST) { { this->fileIds.clear(); - uint32_t _size702; - ::apache::thrift::protocol::TType _etype705; - xfer += iprot->readListBegin(_etype705, _size702); - this->fileIds.resize(_size702); - uint32_t _i706; - for (_i706 = 0; _i706 < _size702; ++_i706) + uint32_t _size708; + ::apache::thrift::protocol::TType _etype711; + xfer += iprot->readListBegin(_etype711, _size708); + this->fileIds.resize(_size708); + uint32_t _i712; + for (_i712 = 0; _i712 < _size708; ++_i712) { - xfer += iprot->readI64(this->fileIds[_i706]); + xfer += iprot->readI64(this->fileIds[_i712]); } xfer += iprot->readListEnd(); } @@ -17178,10 +17223,10 @@ uint32_t GetFileMetadataRequest::write(::apache::thrift::protocol::TProtocol* op xfer += oprot->writeFieldBegin("fileIds", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_I64, static_cast<uint32_t>(this->fileIds.size())); - std::vector<int64_t> ::const_iterator _iter707; - for (_iter707 = this->fileIds.begin(); _iter707 != this->fileIds.end(); ++_iter707) + std::vector<int64_t> ::const_iterator _iter713; + for (_iter713 = this->fileIds.begin(); _iter713 != this->fileIds.end(); ++_iter713) { - xfer += oprot->writeI64((*_iter707)); + xfer += oprot->writeI64((*_iter713)); } xfer += oprot->writeListEnd(); } @@ -17197,11 +17242,11 @@ void swap(GetFileMetadataRequest &a, GetFileMetadataRequest &b) { swap(a.fileIds, b.fileIds); } -GetFileMetadataRequest::GetFileMetadataRequest(const GetFileMetadataRequest& other708) { - fileIds = other708.fileIds; +GetFileMetadataRequest::GetFileMetadataRequest(const GetFileMetadataRequest& other714) { + fileIds = other714.fileIds; } -GetFileMetadataRequest& GetFileMetadataRequest::operator=(const GetFileMetadataRequest& other709) { - fileIds = other709.fileIds; +GetFileMetadataRequest& GetFileMetadataRequest::operator=(const GetFileMetadataRequest& other715) { + fileIds = other715.fileIds; return *this; } void GetFileMetadataRequest::printTo(std::ostream& out) const { @@ -17260,11 +17305,11 @@ void swap(PutFileMetadataResult &a, PutFileMetadataResult &b) { (void) b; } -PutFileMetadataResult::PutFileMetadataResult(const PutFileMetadataResult& other710) { - (void) other710; +PutFileMetadataResult::PutFileMetadataResult(const PutFileMetadataResult& other716) { + (void) other716; } -PutFileMetadataResult& PutFileMetadataResult::operator=(const PutFileMetadataResult& other711) { - (void) other711; +PutFileMetadataResult& PutFileMetadataResult::operator=(const PutFileMetadataResult& other717) { + (void) other717; return *this; } void PutFileMetadataResult::printTo(std::ostream& out) const { @@ -17318,14 +17363,14 @@ uint32_t PutFileMetadataRequest::read(::apache::thrift::protocol::TProtocol* ipr if (ftype == ::apache::thrift::protocol::T_LIST) { { this->fileIds.clear(); - uint32_t _size712; - ::apache::thrift::protocol::TType _etype715; - xfer += iprot->readListBegin(_etype715, _size712); - this->fileIds.resize(_size712); - uint32_t _i716; - for (_i716 = 0; _i716 < _size712; ++_i716) + uint32_t _size718; + ::apache::thrift::protocol::TType _etype721; + xfer += iprot->readListBegin(_etype721, _size718); + this->fileIds.resize(_size718); + uint32_t _i722; + for (_i722 = 0; _i722 < _size718; ++_i722) { - xfer += iprot->readI64(this->fileIds[_i716]); + xfer += iprot->readI64(this->fileIds[_i722]); } xfer += iprot->readListEnd(); } @@ -17338,14 +17383,14 @@ uint32_t PutFileMetadataRequest::read(::apache::thrift::protocol::TProtocol* ipr if (ftype == ::apache::thrift::protocol::T_LIST) { { this->metadata.clear(); - uint32_t _size717; - ::apache::thrift::protocol::TType _etype720; - xfer += iprot->readListBegin(_etype720, _size717); - this->metadata.resize(_size717); - uint32_t _i721; - for (_i721 = 0; _i721 < _size717; ++_i721) + uint32_t _size723; + ::apache::thrift::protocol::TType _etype726; + xfer += iprot->readListBegin(_etype726, _size723); + this->metadata.resize(_size723); + uint32_t _i727; + for (_i727 = 0; _i727 < _size723; ++_i727) { - xfer += iprot->readBinary(this->metadata[_i721]); + xfer += iprot->readBinary(this->metadata[_i727]); } xfer += iprot->readListEnd(); } @@ -17356,9 +17401,9 @@ uint32_t PutFileMetadataRequest::read(::apache::thrift::protocol::TProtocol* ipr break; case 3: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast722; - xfer += iprot->readI32(ecast722); - this->type = (FileMetadataExprType::type)ecast722; + int32_t ecast728; + xfer += iprot->readI32(ecast728); + this->type = (FileMetadataExprType::type)ecast728; this->__isset.type = true; } else { xfer += iprot->skip(ftype); @@ -17388,10 +17433,10 @@ uint32_t PutFileMetadataRequest::write(::apache::thrift::protocol::TProtocol* op xfer += oprot->writeFieldBegin("fileIds", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_I64, static_cast<uint32_t>(this->fileIds.size())); - std::vector<int64_t> ::const_iterator _iter723; - for (_iter723 = this->fileIds.begin(); _iter723 != this->fileIds.end(); ++_iter723) + std::vector<int64_t> ::const_iterator _iter729; + for (_iter729 = this->fileIds.begin(); _iter729 != this->fileIds.end(); ++_iter729) { - xfer += oprot->writeI64((*_iter723)); + xfer += oprot->writeI64((*_iter729)); } xfer += oprot->writeListEnd(); } @@ -17400,10 +17445,10 @@ uint32_t PutFileMetadataRequest::write(::apache::thrift::protocol::TProtocol* op xfer += oprot->writeFieldBegin("metadata", ::apache::thrift::protocol::T_LIST, 2); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->metadata.size())); - std::vector<std::string> ::const_iterator _iter724; - for (_iter724 = this->metadata.begin(); _iter724 != this->metadata.end(); ++_iter724) + std::vector<std::string> ::const_iterator _iter730; + for (_iter730 = this->metadata.begin(); _iter730 != this->metadata.end(); ++_iter730) { - xfer += oprot->writeBinary((*_iter724)); + xfer += oprot->writeBinary((*_iter730)); } xfer += oprot->writeListEnd(); } @@ -17427,17 +17472,17 @@ void swap(PutFileMetadataRequest &a, PutFileMetadataRequest &b) { swap(a.__isset, b.__isset); } -PutFileMetadataRequest::PutFileMetadataRequest(const PutFileMetadataRequest& other725) { - fileIds = other725.fileIds; - metadata = other725.metadata; - type = other725.type; - __isset = other725.__isset; +PutFileMetadataRequest::PutFileMetadataRequest(const PutFileMetadataRequest& other731) { + fileIds = other731.fileIds; + metadata = other731.metadata; + type = other731.type; + __isset = other731.__isset; } -PutFileMetadataRequest& PutFileMetadataRequest::operator=(const PutFileMetadataRequest& other726) { - fileIds = other726.fileIds; - metadata = other726.metadata; - type = other726.type; - __isset = other726.__isset; +PutFileMetadataRequest& PutFileMetadataRequest::operator=(const PutFileMetadataRequest& other732) { + fileIds = other732.fileIds; + metadata = other732.metadata; + type = other732.type; + __isset = other732.__isset; return *this; } void PutFileMetadataRequest::printTo(std::ostream& out) const { @@ -17498,11 +17543,11 @@ void swap(ClearFileMetadataResult &a, ClearFileMetadataResult &b) { (void) b; } -ClearFileMetadataResult::ClearFileMetadataResult(const ClearFileMetadataResult& other727) { - (void) other727; +ClearFileMetadataResult::ClearFileMetadataResult(const ClearFileMetadataResult& other733) { + (void) other733; } -ClearFileMetadataResult& ClearFileMetadataResult::operator=(const ClearFileMetadataResult& other728) { - (void) other728; +ClearFileMetadataResult& ClearFileMetadataResult::operator=(const ClearFileMetadataResult& other734) { + (void) other734; return *this; } void ClearFileMetadataResult::printTo(std::ostream& out) const { @@ -17546,14 +17591,14 @@ uint32_t ClearFileMetadataRequest::read(::apache::thrift::protocol::TProtocol* i if (ftype == ::apache::thrift::protocol::T_LIST) { { this->fileIds.clear(); - uint32_t _size729; - ::apache::thrift::protocol::TType _etype732; - xfer += iprot->readListBegin(_etype732, _size729); - this->fileIds.resize(_size729); - uint32_t _i733; - for (_i733 = 0; _i733 < _size729; ++_i733) + uint32_t _size735; + ::apache::thrift::protocol::TType _etype738; + xfer += iprot->readListBegin(_etype738, _size735); + this->fileIds.resize(_size735); + uint32_t _i739; + for (_i739 = 0; _i739 < _size735; ++_i739) { - xfer += iprot->readI64(this->fileIds[_i733]); + xfer += iprot->readI64(this->fileIds[_i739]); } xfer += iprot->readListEnd(); } @@ -17584,10 +17629,10 @@ uint32_t ClearFileMetadataRequest::write(::apache::thrift::protocol::TProtocol* xfer += oprot->writeFieldBegin("fileIds", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_I64, static_cast<uint32_t>(this->fileIds.size())); - std::vector<int64_t> ::const_iterator _iter734; - for (_iter734 = this->fileIds.begin(); _iter734 != this->fileIds.end(); ++_iter734) + std::vector<int64_t> ::const_iterator _iter740; + for (_iter740 = this->fileIds.begin(); _iter740 != this->fileIds.end(); ++_iter740) { - xfer += oprot->writeI64((*_iter734)); + xfer += oprot->writeI64((*_iter740)); } xfer += oprot->writeListEnd(); } @@ -17603,11 +17648,11 @@ void swap(ClearFileMetadataRequest &a, ClearFileMetadataRequest &b) { swap(a.fileIds, b.fileIds); } -ClearFileMetadataRequest::ClearFileMetadataRequest(const ClearFileMetadataRequest& other735) { - fileIds = other735.fileIds; +ClearFileMetadataRequest::ClearFileMetadataRequest(const ClearFileMetadataRequest& other741) { + fileIds = other741.fileIds; } -ClearFileMetadataRequest& ClearFileMetadataRequest::operator=(const ClearFileMetadataRequest& other736) { - fileIds = other736.fileIds; +ClearFileMetadataRequest& ClearFileMetadataRequest::operator=(const ClearFileMetadataRequest& other742) { + fileIds = other742.fileIds; return *this; } void ClearFileMetadataRequest::printTo(std::ostream& out) const { @@ -17689,11 +17734,11 @@ void swap(CacheFileMetadataResult &a, CacheFileMetadataResult &b) { swap(a.isSupported, b.isSupported); } -CacheFileMetadataResult::CacheFileMetadataResult(const CacheFileMetadataResult& other737) { - isSupported = other737.isSupported; +CacheFileMetadataResult::CacheFileMetadataResult(const CacheFileMetadataResult& other743) { + isSupported = other743.isSupported; } -CacheFileMetadataResult& CacheFileMetadataResult::operator=(const CacheFileMetadataResult& other738) { - isSupported = other738.isSupported; +CacheFileMetadataResult& CacheFileMetadataResult::operator=(const CacheFileMetadataResult& other744) { + isSupported = other744.isSupported; return *this; } void CacheFileMetadataResult::printTo(std::ostream& out) const { @@ -17834,19 +17879,19 @@ void swap(CacheFileMetadataRequest &a, CacheFileMetadataRequest &b) { swap(a.__isset, b.__isset); } -CacheFileMetadataRequest::CacheFileMetadataRequest(const CacheFileMetadataRequest& other739) { - dbName = other739.dbName; - tblName = other739.tblName; - partName = other739.partName; - isAllParts = other739.isAllParts; - __isset = other739.__isset; +CacheFileMetadataRequest::CacheFileMetadataRequest(const CacheFileMetadataRequest& other745) { + dbName = other745.dbName; + tblName = other745.tblName; + partName = other745.partName; + isAllParts = other745.isAllParts; + __isset = other745.__isset; } -CacheFileMetadataRequest& CacheFileMetadataRequest::operator=(const CacheFileMetadataRequest& other740) { - dbName = other740.dbName; - tblName = other740.tblName; - partName = other740.partName; - isAllParts = other740.isAllParts; - __isset = other740.__isset; +CacheFileMetadataRequest& CacheFileMetadataRequest::operator=(const CacheFileMetadataRequest& other746) { + dbName = other746.dbName; + tblName = other746.tblName; + partName = other746.partName; + isAllParts = other746.isAllParts; + __isset = other746.__isset; return *this; } void CacheFileMetadataRequest::printTo(std::ostream& out) const { @@ -17894,14 +17939,14 @@ uint32_t GetAllFunctionsResponse::read(::apache::thrift::protocol::TProtocol* ip if (ftype == ::apache::thrift::protocol::T_LIST) { { this->functions.clear(); - uint32_t _size741; - ::apache::thrift::protocol::TType _etype744; - xfer += iprot->readListBegin(_etype744, _size741); - this->functions.resize(_size741); - uint32_t _i745; - for (_i745 = 0; _i745 < _size741; ++_i745) + uint32_t _size747; + ::apache::thrift::protocol::TType _etype750; + xfer += iprot->readListBegin(_etype750, _size747); + this->functions.resize(_size747); + uint32_t _i751; + for (_i751 = 0; _i751 < _size747; ++_i751) { - xfer += this->functions[_i745].read(iprot); + xfer += this->functions[_i751].read(iprot); } xfer += iprot->readListEnd(); } @@ -17931,10 +17976,10 @@ uint32_t GetAllFunctionsResponse::write(::apache::thrift::protocol::TProtocol* o xfer += oprot->writeFieldBegin("functions", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->functions.size())); - std::vector<Function> ::const_iterator _iter746; - for (_iter746 = this->functions.begin(); _iter746 != this->functions.end(); ++_iter746) + std::vector<Function> ::const_iterator _iter752; + for (_iter752 = this->functions.begin(); _iter752 != this->functions.end(); ++_iter752) { - xfer += (*_iter746).write(oprot); + xfer += (*_iter752).write(oprot); } xfer += oprot->writeListEnd(); } @@ -17951,13 +17996,13 @@ void swap(GetAllFunctionsResponse &a, GetAllFunctionsResponse &b) { swap(a.__isset, b.__isset); } -GetAllFunctionsResponse::GetAllFunctionsResponse(const GetAllFunctionsResponse& other747) { - functions = other747.functions; - __isset = other747.__isset; +GetAllFunctionsResponse::GetAllFunctionsResponse(const GetAllFunctionsResponse& other753) { + functions = other753.functions; + __isset = other753.__isset; } -GetAllFunctionsResponse& GetAllFunctionsResponse::operator=(const GetAllFunctionsResponse& other748) { - functions = other748.functions; - __isset = other748.__isset; +GetAllFunctionsResponse& GetAllFunctionsResponse::operator=(const GetAllFunctionsResponse& other754) { + functions = other754.functions; + __isset = other754.__isset; return *this; } void GetAllFunctionsResponse::printTo(std::ostream& out) const { @@ -18002,16 +18047,16 @@ uint32_t ClientCapabilities::read(::apache::thrift::protocol::TProtocol* iprot) if (ftype == ::apache::thrift::protocol::T_LIST) { { this->values.clear(); - uint32_t _size749; - ::apache::thrift::protocol::TType _etype752; - xfer += iprot->readListBegin(_etype752, _size749); - this->values.resize(_size749); - uint32_t _i753; - for (_i753 = 0; _i753 < _size749; ++_i753) + uint32_t _size755; + ::apache::thrift::protocol::TType _etype758; + xfer += iprot->readListBegin(_etype758, _size755); + this->values.resize(_size755); + uint32_t _i759; + for (_i759 = 0; _i759 < _size755; ++_i759) { - int32_t ecast754; - xfer += iprot->readI32(ecast754); - this->values[_i753] = (ClientCapability::type)ecast754; + int32_t ecast760; + xfer += iprot->readI32(ecast760); + this->values[_i759] = (ClientCapability::type)ecast760; } xfer += iprot->readListEnd(); } @@ -18042,10 +18087,10 @@ uint32_t ClientCapabilities::write(::apache::thrift::protocol::TProtocol* oprot) xfer += oprot->writeFieldBegin("values", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_I32, static_cast<uint32_t>(this->values.size())); - std::vector<ClientCapability::type> ::const_iterator _iter755; - for (_iter755 = this->values.begin(); _iter755 != this->values.end(); ++_iter755) + std::vector<ClientCapability::type> ::const_iterator _iter761; + for (_iter761 = this->values.begin(); _iter761 != this->values.end(); ++_iter761) { - xfer += oprot->writeI32((int32_t)(*_iter755)); + xfer += oprot->writeI32((int32_t)(*_iter761)); } xfer += oprot->writeListEnd(); } @@ -18061,11 +18106,11 @@ void swap(ClientCapabilities &a, ClientCapabilities &b) { swap(a.values, b.values); } -ClientCapabilities::ClientCapabilities(const ClientCapabilities& other756) { - values = other756.values; +ClientCapabilities::ClientCapabilities(const ClientCapabilities& other762) { + values = other762.values; } -ClientCapabilities& ClientCapabilities::operator=(const ClientCapabilities& other757) { - values = other757.values; +ClientCapabilities& ClientCapabilities::operator=(const ClientCapabilities& other763) { + values = other763.values; return *this; } void ClientCapabilities::printTo(std::ostream& out) const { @@ -18187,17 +18232,17 @@ void swap(GetTableRequest &a, GetTableRequest &b) { swap(a.__isset, b.__isset); } -GetTableRequest::GetTableRequest(const GetTableRequest& other758) { - dbName = other758.dbName; - tblName = other758.tblName; - capabilities = other758.capabilities; - __isset = other758.__isset; +GetTableRequest::GetTableRequest(const GetTableRequest& other764) { + dbName = other764.dbName; + tblName = other764.tblName; + capabilities = other764.capabilities; + __isset = other764.__isset; } -GetTableRequest& GetTableRequest::operator=(const GetTableRequest& other759) { - dbName = other759.dbName; - tblName = other759.tblName; - capabilities = other759.capabilities; - __isset = other759.__isset; +GetTableRequest& GetTableRequest::operator=(const GetTableRequest& other765) { + dbName = other765.dbName; + tblName = other765.tblName; + capabilities = other765.capabilities; + __isset = other765.__isset; return *this; } void GetTableRequest::printTo(std::ostream& out) const { @@ -18281,11 +18326,11 @@ void swap(GetTableResult &a, GetTableResult &b) { swap(a.table, b.table); } -GetTableResult::GetTableResult(const GetTableResult& other760) { - table = other760.table; +GetTableResult::GetTableResult(const GetTableResult& other766) { + table = other766.table; } -GetTableResult& GetTableResult::operator=(const GetTableResult& other761) { - table = other761.table; +GetTableResult& GetTableResult::operator=(const GetTableResult& other767) { + table = other767.table; return *this; } void GetTableResult::printTo(std::ostream& out) const { @@ -18348,14 +18393,14 @@ uint32_t GetTablesRequest::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->tblNames.clear(); - uint32_t _size762; - ::apache::thrift::protocol::TType _etype765; - xfer += iprot->readListBegin(_etype765, _size762); - this->tblNames.resize(_size762); - uint32_t _i766; - for (_i766 = 0; _i766 < _size762; ++_i766) + uint32_t _size768; + ::apache::thrift::protocol::TType _etype771; + xfer += iprot->readListBegin(_etype771, _size768); + this->tblNames.resize(_size768); + uint32_t _i772; + for (_i772 = 0; _i772 < _size768; ++_i772) { - xfer += iprot->readString(this->tblNames[_i766]); + xfer += iprot->readString(this->tblNames[_i772]); } xfer += iprot->readListEnd(); } @@ -18399,10 +18444,10 @@ uint32_t GetTablesRequest::write(::apache::thrift::protocol::TProtocol* oprot) c xfer += oprot->writeFieldBegin("tblNames", ::apache::thrift::protocol::T_LIST, 2); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->tblNames.size())); - std::vector<std::string> ::const_iterator _iter767; - for (_iter767 = this->tblNames.begin(); _iter767 != this->tblNames.end(); ++_iter767) + std::vector<std::string> ::const_iterator _iter773; + for (_iter773 = this->tblNames.begin(); _iter773 != this->tblNames.end(); ++_iter773) { - xfer += oprot->writeString((*_iter767)); + xfer += oprot->writeString((*_iter773)); } xfer += oprot->writeListEnd(); } @@ -18426,17 +18471,17 @@ void swap(GetTablesRequest &a, GetTablesRequest &b) { swap(a.__isset, b.__isset); } -GetTablesRequest::GetTablesRequest(const GetTablesRequest& other768) { - dbName = other768.dbName; - tblNames = other768.tblNames; - capabilities = other768.capabilities; - __isset = other768.__isset; +GetTablesRequest::GetTablesRequest(const GetTablesRequest& other774) { + dbName = other774.dbName; + tblNames = other774.tblNames; + capabilities = other774.capabilities; + __isset = other774.__isset; } -GetTablesRequest& GetTablesRequest::operator=(const GetTablesRequest& other769) { - dbName = other769.dbName; - tblNames = other769.tblNames; - capabilities = other769.capabilities; - __isset = other769.__isset; +GetTablesRequest& GetTablesRequest::operator=(const GetTablesRequest& other775) { + dbName = other775.dbName; + tblNames = other775.tblNames; + capabilities = other775.capabilities; + __isset = other775.__isset; return *this; } void GetTablesRequest::printTo(std::ostream& out) const { @@ -18483,14 +18528,14 @@ uint32_t GetTablesResult::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->tables.clear(); - uint32_t _size770; - ::apache::thrift::protocol::TType _etype773; - xfer += iprot->readListBegin(_etype773, _size770); - this->tables.resize(_size770); - uint32_t _i774; - for (_i774 = 0; _i774 < _size770; ++_i774) + uint32_t _size776; + ::apache::thrift::protocol::TType _etype779; + xfer += iprot->readListBegin(_etype779, _size776); + this->tables.resize(_size776); + uint32_t _i780; + for (_i780 = 0; _i780 < _size776; ++_i780) { - xfer += this->tables[_i774].read(iprot); + xfer += this->tables[_i780].read(iprot); } xfer += iprot->readListEnd(); } @@ -18521,10 +18566,10 @@ uint32_t GetTablesResult::write(::apache::thrift::protocol::TProtocol* oprot) co xfer += oprot->writeFieldBegin("tables", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->tables.size())); - std::vector<Table> ::const_iterator _iter775; - for (_iter775 = this->tables.begin(); _iter775 != this->tables.end(); ++_iter775) + std::vector<Table> ::const_iterator _iter781; + for (_iter781 = this->tables.begin(); _iter781 != this->tables.end(); ++_iter781) { - xfer += (*_iter775).write(oprot); + xfer += (*_iter781).write(oprot); } xfer += oprot->writeListEnd(); } @@ -18540,11 +18585,11 @@ void swap(GetTablesResult &a, GetTablesResult &b) { swap(a.tables, b.tables); } -GetTablesResult::GetTablesResult(const GetTablesResult& other776) { - tables = other776.tables; +GetTablesResult::GetTablesResult(const GetTablesResult& other782) { + tables = other782.tables; } -GetTablesResult& GetTablesResult::operator=(const GetTablesResult& other777) { - tables = other777.tables; +GetTablesResult& GetTablesResult::operator=(const GetTablesResult& other783) { + tables = other783.tables; return *this; } void GetTablesResult::printTo(std::ostream& out) const { @@ -18686,19 +18731,19 @@ void swap(TableMeta &a, TableMeta &b) { swap(a.__isset, b.__isset); } -TableMeta::TableMeta(const TableMeta& other778) { - dbName = other778.dbName; - tableName = other778.tableName; - tableType = other778.tableType; - comments = other778.comments; - __isset = other778.__isset; +TableMeta::TableMeta(const TableMeta& other784) { + dbName = other784.dbName; + tableName = other784.tableName; + tableType = other784.tableType; + comments = other784.comments; + __isset = other784.__isset; } -TableMeta& TableMeta::operator=(const TableMeta& other779) { - dbName = other779.dbName; - tableName = other779.tableName; - tableType = other779.tableType; - comments = other779.comments; - __isset = other779.__isset; +TableMeta& TableMeta::operator=(const TableMeta& other785) { + dbName = other785.dbName; + tableName = other785.tableName; + tableType = other785.tableType; + comments = other785.comments; + __isset = other785.__isset; return *this; } void TableMeta::printTo(std::ostream& out) const { @@ -18781,13 +18826,13 @@ void swap(MetaException &a, MetaException &b) { swap(a.__isset, b.__isset); } -MetaException::MetaException(const MetaException& other780) : TException() { - message = other780.message; - __isset = other780.__isset; +MetaException::MetaException(const MetaException& other786) : TException() { + message = other786.message; + __isset = other786.__isset; } -MetaException& MetaException::operator=(const MetaException& other781) { - message = other781.message; - __isset = other781.__isset; +MetaException& MetaException::operator=(const MetaException& other787) { + message = other787.message; + __isset = other787.__isset; return *this; } void MetaException::printTo(std::ostream& out) const { @@ -18878,13 +18923,13 @@ void swap(UnknownTableException &a, UnknownTableException &b) { swap(a.__isset, b.__isset); } -UnknownTableException::UnknownTableException(const UnknownTableException& other782) : TException() { - message = other782.message; - __isset = other782.__isset; +UnknownTableException::UnknownTableException(const UnknownTableException& other788) : TException() { + message = other788.message; + __isset = other788.__isset; } -UnknownTableException& UnknownTableException::operator=(const UnknownTableException& other783) { - message = other783.message; - __isset = other783.__isset; +UnknownTableException& UnknownTableException::operator=(const UnknownTableException& other789) { + message = other789.message; + __isset = other789.__isset; return *this; } void UnknownTableException::printTo(std::ostream& out) const { @@ -18975,13 +19020,13 @@ void swap(UnknownDBException &a, UnknownDBException &b) { swap(a.__isset, b.__isset); } -UnknownDBException::UnknownDBException(const UnknownDBException& other784) : TException() { - message = other784.message; - __isset = other784.__isset; +UnknownDBException::UnknownDBException(const UnknownDBException& other790) : TException() { + message = other790.message; + __isset = other790.__isset; } -UnknownDBException& UnknownDBException::operator=(const UnknownDBException& other785) { - message = other785.message; - __isset = other785.__isset; +UnknownDBException& UnknownDBException::operator=(const UnknownDBException& other791) { + message = other791.message; + __isset = other791.__isset; return *this; } void UnknownDBException::printTo(std::ostream& out) const { @@ -19072,13 +19117,13 @@ void swap(AlreadyExistsException &a, AlreadyExistsException &b) { swap(a.__isset, b.__isset); } -AlreadyExistsException::AlreadyExistsException(const AlreadyExistsException& other786) : TException() { - message = other786.message; - __isset = other786.__isset; +AlreadyExistsException::AlreadyExistsException(const AlreadyExistsException& other792) : TException() { + message = other792.message; + __isset = other792.__isset; } -AlreadyExistsException& AlreadyExistsException::operator=(const AlreadyExistsException& other787) { - message = other787.message; - __isset = other787.__isset; +AlreadyExistsException& AlreadyExistsException::operator=(const AlreadyExistsException& other793) { + message = other793.message; + __isset = other793.__isset; return *this; } void AlreadyExistsException::printTo(std::ostream& out) const { @@ -19169,13 +19214,13 @@ void swap(InvalidPartitionException &a, InvalidPartitionException &b) { swap(a.__isset, b.__isset); } -InvalidPartitionException::InvalidPartitionException(const InvalidPartitionException& other788) : TException() { - message = other788.message; - __isset = other788.__isset; +InvalidPartitionException::InvalidPartitionException(const InvalidPartitionException& other794) : TException() { + message = other794.message; + __isset = other794.__isset; } -InvalidPartitionException& InvalidPartitionException::operator=(const InvalidPartitionException& other789) { - message = other789.message; - __isset = other789.__isset; +InvalidPartitionException& InvalidPartitionException::operator=(const InvalidPartitionException& other795) { + message = other795.message; + __isset = other795.__isset; return *this; } void InvalidPartitionException::printTo(std::ostream& out) const { @@ -19266,13 +19311,13 @@ void swap(UnknownPartitionException &a, UnknownPartitionException &b) { swap(a.__isset, b.__isset); } -UnknownPartitionException::UnknownPartitionException(const UnknownPartitionException& other790) : TException() { - message = other790.message; - __isset = other790.__isset; +UnknownPartitionException::UnknownPartitionException(const UnknownPartitionException& other796) : TException() { + message = other796.message; + __isset = other796.__isset; } -UnknownPartitionException& UnknownPartitionException::operator=(const UnknownPartitionException& other791) { - message = other791.message; - __isset = other791.__isset; +UnknownPartitionException& UnknownPartitionException::operator=(const UnknownPartitionException& other797) { + message = other797.message; + __isset = other797.__isset; return *this; } void UnknownPartitionException::printTo(std::ostream& out) const { @@ -19363,13 +19408,13 @@ void swap(InvalidObjectException &a, InvalidObjectException &b) { swap(a.__isset, b.__isset); } -InvalidObjectException::InvalidObjectException(const InvalidObjectException& other792) : TException() { - message = other792.message; - __isset = other792.__isset; +InvalidObjectException::InvalidObjectException(const InvalidObjectException& other798) : TException() { + message = other798.message; + __isset = other798.__isset; } -InvalidObjectException& InvalidObjectException::operator=(const InvalidObjectException& other793) { - message = other793.message; - __isset = other793.__isset; +InvalidObjectException& InvalidObjectException::operator=(const InvalidObjectException& other799) { + message = other799.message; + __isset = other799.__isset; return *this; } void InvalidObjectException::printTo(std::ostream& out) const { @@ -19460,13 +19505,13 @@ void swap(NoSuchObjectException &a, NoSuchObjectException &b) { swap(a.__isset, b.__isset); } -NoSuchObjectException::NoSuchObjectException(const NoSuchObjectException& other794) : TException() { - message = other794.message; - __isset = other794.__isset; +NoSuchObjectException::NoSuchObjectException(const NoSuchObjectException& other800) : TException() { + message = other800.message; + __isset = other800.__isset; } -NoSuchObjectException& NoSuchObjectException::operator=(const NoSuchObjectException& other795) { - message = other795.message; - __isset = other795.__isset; +NoSuchObjectException& NoSuchObjectException::operator=(const NoSuchObjectException& other801) { + message = other801.message; + __isset = other801.__isset; return *this; } void NoSuchObjectException::printTo(std::ostream& out) const { @@ -19557,13 +19602,13 @@ void swap(IndexAlreadyExistsException &a, IndexAlreadyExistsException &b) { swap(a.__isset, b.__isset); } -IndexAlreadyExistsException::IndexAlreadyExistsException(const IndexAlreadyExistsException& other796) : TException() { - message = other796.message; - __isset = other796.__isset; +IndexAlreadyExistsException::IndexAlreadyExistsException(const IndexAlreadyExistsException& other802) : TException() { + message = other802.message; + __isset = other802.__isset; } -IndexAlreadyExistsException& IndexAlreadyExistsException::operator=(const IndexAlreadyExistsException& other797) { - message = other797.message; - __isset = other797.__isset; +IndexAlreadyExistsException& IndexAlreadyExistsException::operator=(const IndexAlreadyExistsException& other803) { + message = other803.message; + __isset = other803.__isset; return *this; } void IndexAlreadyExistsException::printTo(std::ostream& out) const { @@ -19654,13 +19699,13 @@ void swap(InvalidOperationException &a, InvalidOperationException &b) { swap(a.__isset, b.__isset); } -InvalidOperationException::InvalidOperationException(const InvalidOperationException& other798) : TException() { - message = other798.message; - __isset = other798.__isset; +InvalidOperationException::InvalidOperationException(const InvalidOperationException& other804) : TException() { + message = other804.message; + __isset = other804.__isset; } -InvalidOperationException& InvalidOperationException::operator=(const InvalidOperationException& other799) { - message = other799.message; - __isset = other799.__isset; +InvalidOperationException& InvalidOperationException::operator=(const InvalidOperationException& other805) { + message = other805.message; + __isset = other805.__isset; return *this; } void InvalidOperationException::printTo(std::ostream& out) const { @@ -19751,13 +19796,13 @@ void swap(ConfigValSecurityException &a, ConfigValSecurityException &b) { swap(a.__isset, b.__isset); } -ConfigValSecurityException::ConfigValSecurityException(const ConfigValSecurityException& other800) : TException() { - message = other800.message; - __isset = other800.__isset; +ConfigValSecurityException::ConfigValSecurityException(const ConfigValSecurityException& other806) : TException() { + message = other806.message; + __isset = other806.__isset; } -ConfigValSecurityException& ConfigValSecurityException::operator=(const ConfigValSecurityException& other801) { - message = other801.message; - __isset = other801.__isset; +ConfigValSecurityException& ConfigValSecurityException::operator=(const ConfigValSecurityException& other807) { + message = other807.message; + __isset = other807.__isset; return *this; } void ConfigValSecurityException::printTo(std::ostream& out) const { @@ -19848,13 +19893,13 @@ void swap(InvalidInputException &a, InvalidInputException &b) { swap(a.__isset, b.__isset); } -InvalidInputException::InvalidInputException(const InvalidInputException& other802) : TException() { - message = other802.message; - __isset = other802.__isset; +InvalidInputException::InvalidInputException(const InvalidInputException& other808) : TException() { + message = other808.message; + __isset = other808.__isset; } -InvalidInputException& InvalidInputException::operator=(const InvalidInputException& other803) { - message = other803.message; - __isset = other803.__isset; +InvalidInputException& InvalidInputException::operator=(const InvalidInputException& other809) { + message = other809.message; + __isset = other809.__isset; return *this; } void InvalidInputException::printTo(std::ostream& out) const { @@ -19945,13 +19990,13 @@ void swap(NoSuchTxnException &a, NoSuchTxnException &b) { swap(a.__isset, b.__isset); } -NoSuchTxnException::NoSuchTxnException(const NoSuchTxnException& other804) : TException() { - message = other804.message; - __isset = other804.__isset; +NoSuchTxnException::NoSuchTxnException(const NoSuchTxnException& other810) : TException() { + message = other810.message; + __isset = other810.__isset; } -NoSuchTxnException& NoSuchTxnException::operator=(const NoSuchTxnException& other805) { - message = other805.message; - __isset = other805.__isset; +NoSuchTxnException& NoSuchTxnException::operator=(const NoSuchTxnException& other811) { + message = other811.message; + __isset = other811.__isset; return *this; } void NoSuchTxnException::printTo(std::ostream& out) const { @@ -20042,13 +20087,13 @@ void swap(TxnAbortedException &a, TxnAbortedException &b) { swap(a.__isset, b.__isset); } -TxnAbortedException::TxnAbortedException(const TxnAbortedException& other806) : TException() { - message = other806.message; - __isset = other806.__isset; +TxnAbortedException::TxnAbortedException(const TxnAbortedException& other812) : TException() { + message = other812.message; + __isset = other812.__isset; } -TxnAbortedException& TxnAbortedException::operator=(const TxnAbortedException& other807) { - message = other807.message; - __isset = other807.__isset; +TxnAbortedException& TxnAbortedException::operator=(const TxnAbortedException& other813) { + message = other813.message; + __isset = other813.__isset; return *this; } void TxnAbortedException::printTo(std::ostream& out) const { @@ -20139,13 +20184,13 @@ void swap(TxnOpenException &a, TxnOpenException &b) { swap(a.__isset, b.__isset); } -TxnOpenException::TxnOpenException(const TxnOpenException& other808) : TException() { - message = other808.message; - __isset = other808.__isset; +TxnOpenException::TxnOpenException(const TxnOpenException& other814) : TException() { + message = other814.message; + __isset = other814.__isset; } -TxnOpenException& TxnOpenException::operator=(const TxnOpenException& other809) { - message = other809.message; - __isset = other809.__isset; +TxnOpenException& TxnOpenException::operator=(const TxnOpenException& other815) { + message = other815.message; + __isset = other815.__isset; return *this; } void TxnOpenException::printTo(std::ostream& out) const { @@ -20236,13 +20281,13 @@ void swap(NoSuchLockException &a, NoSuchLockException &b) { swap(a.__isset, b.__isset); } -NoSuchLockException::NoSuchLockException(const NoSuchLockException& other810) : TException() { - message = other810.message; - __isset = other810.__isset; +NoSuchLockException::NoSuchLockException(const NoSuchLockException& other816) : TException() { + message = other816.message; + __isset = other816.__isset; } -NoSuchLockException& NoSuchLockException::operator=(const NoSuchLockException& other811) { - message = other811.message; - __isset = other811.__isset; +NoSuchLockException& NoSuchLockException::operator=(const NoSuchLockException& other817) { + message = other817.message; + __isset = other817.__isset; return *this; } void NoSuchLockException::printTo(std::ostream& out) const {
http://git-wip-us.apache.org/repos/asf/hive/blob/bbd99ed6/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h b/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h index 0104f6e..4d5da71 100644 --- a/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h +++ b/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h @@ -6546,6 +6546,10 @@ inline std::ostream& operator<<(std::ostream& out, const CurrentNotificationEven return out; } +typedef struct _InsertEventRequestData__isset { + _InsertEventRequestData__isset() : filesAddedChecksum(false) {} + bool filesAddedChecksum :1; +} _InsertEventRequestData__isset; class InsertEventRequestData { public: @@ -6557,13 +6561,22 @@ class InsertEventRequestData { virtual ~InsertEventRequestData() throw(); std::vector<std::string> filesAdded; + std::vector<std::string> filesAddedChecksum; + + _InsertEventRequestData__isset __isset; void __set_filesAdded(const std::vector<std::string> & val); + void __set_filesAddedChecksum(const std::vector<std::string> & val); + bool operator == (const InsertEventRequestData & rhs) const { if (!(filesAdded == rhs.filesAdded)) return false; + if (__isset.filesAddedChecksum != rhs.__isset.filesAddedChecksum) + return false; + else if (__isset.filesAddedChecksum && !(filesAddedChecksum == rhs.filesAddedChecksum)) + return false; return true; } bool operator != (const InsertEventRequestData &rhs) const { http://git-wip-us.apache.org/repos/asf/hive/blob/bbd99ed6/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java index ca274e6..0da09bf 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java @@ -351,13 +351,13 @@ public class ClearFileMetadataRequest implements org.apache.thrift.TBase<ClearFi case 1: // FILE_IDS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list626 = iprot.readListBegin(); - struct.fileIds = new ArrayList<Long>(_list626.size); - long _elem627; - for (int _i628 = 0; _i628 < _list626.size; ++_i628) + org.apache.thrift.protocol.TList _list634 = iprot.readListBegin(); + struct.fileIds = new ArrayList<Long>(_list634.size); + long _elem635; + for (int _i636 = 0; _i636 < _list634.size; ++_i636) { - _elem627 = iprot.readI64(); - struct.fileIds.add(_elem627); + _elem635 = iprot.readI64(); + struct.fileIds.add(_elem635); } iprot.readListEnd(); } @@ -383,9 +383,9 @@ public class ClearFileMetadataRequest implements org.apache.thrift.TBase<ClearFi oprot.writeFieldBegin(FILE_IDS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.fileIds.size())); - for (long _iter629 : struct.fileIds) + for (long _iter637 : struct.fileIds) { - oprot.writeI64(_iter629); + oprot.writeI64(_iter637); } oprot.writeListEnd(); } @@ -410,9 +410,9 @@ public class ClearFileMetadataRequest implements org.apache.thrift.TBase<ClearFi TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.fileIds.size()); - for (long _iter630 : struct.fileIds) + for (long _iter638 : struct.fileIds) { - oprot.writeI64(_iter630); + oprot.writeI64(_iter638); } } } @@ -421,13 +421,13 @@ public class ClearFileMetadataRequest implements org.apache.thrift.TBase<ClearFi public void read(org.apache.thrift.protocol.TProtocol prot, ClearFileMetadataRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list631 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.fileIds = new ArrayList<Long>(_list631.size); - long _elem632; - for (int _i633 = 0; _i633 < _list631.size; ++_i633) + org.apache.thrift.protocol.TList _list639 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.fileIds = new ArrayList<Long>(_list639.size); + long _elem640; + for (int _i641 = 0; _i641 < _list639.size; ++_i641) { - _elem632 = iprot.readI64(); - struct.fileIds.add(_elem632); + _elem640 = iprot.readI64(); + struct.fileIds.add(_elem640); } } struct.setFileIdsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/bbd99ed6/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java index 5fc7d56..81534fe 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java @@ -354,13 +354,13 @@ public class ClientCapabilities implements org.apache.thrift.TBase<ClientCapabil case 1: // VALUES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list642 = iprot.readListBegin(); - struct.values = new ArrayList<ClientCapability>(_list642.size); - ClientCapability _elem643; - for (int _i644 = 0; _i644 < _list642.size; ++_i644) + org.apache.thrift.protocol.TList _list650 = iprot.readListBegin(); + struct.values = new ArrayList<ClientCapability>(_list650.size); + ClientCapability _elem651; + for (int _i652 = 0; _i652 < _list650.size; ++_i652) { - _elem643 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32()); - struct.values.add(_elem643); + _elem651 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32()); + struct.values.add(_elem651); } iprot.readListEnd(); } @@ -386,9 +386,9 @@ public class ClientCapabilities implements org.apache.thrift.TBase<ClientCapabil oprot.writeFieldBegin(VALUES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, struct.values.size())); - for (ClientCapability _iter645 : struct.values) + for (ClientCapability _iter653 : struct.values) { - oprot.writeI32(_iter645.getValue()); + oprot.writeI32(_iter653.getValue()); } oprot.writeListEnd(); } @@ -413,9 +413,9 @@ public class ClientCapabilities implements org.apache.thrift.TBase<ClientCapabil TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.values.size()); - for (ClientCapability _iter646 : struct.values) + for (ClientCapability _iter654 : struct.values) { - oprot.writeI32(_iter646.getValue()); + oprot.writeI32(_iter654.getValue()); } } } @@ -424,13 +424,13 @@ public class ClientCapabilities implements org.apache.thrift.TBase<ClientCapabil public void read(org.apache.thrift.protocol.TProtocol prot, ClientCapabilities struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list647 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32()); - struct.values = new ArrayList<ClientCapability>(_list647.size); - ClientCapability _elem648; - for (int _i649 = 0; _i649 < _list647.size; ++_i649) + org.apache.thrift.protocol.TList _list655 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32()); + struct.values = new ArrayList<ClientCapability>(_list655.size); + ClientCapability _elem656; + for (int _i657 = 0; _i657 < _list655.size; ++_i657) { - _elem648 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32()); - struct.values.add(_elem648); + _elem656 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32()); + struct.values.add(_elem656); } } struct.setValuesIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/bbd99ed6/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java index 6772338..7bb10b3 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java @@ -713,13 +713,13 @@ public class FireEventRequest implements org.apache.thrift.TBase<FireEventReques case 5: // PARTITION_VALS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list566 = iprot.readListBegin(); - struct.partitionVals = new ArrayList<String>(_list566.size); - String _elem567; - for (int _i568 = 0; _i568 < _list566.size; ++_i568) + org.apache.thrift.protocol.TList _list574 = iprot.readListBegin(); + struct.partitionVals = new ArrayList<String>(_list574.size); + String _elem575; + for (int _i576 = 0; _i576 < _list574.size; ++_i576) { - _elem567 = iprot.readString(); - struct.partitionVals.add(_elem567); + _elem575 = iprot.readString(); + struct.partitionVals.add(_elem575); } iprot.readListEnd(); } @@ -768,9 +768,9 @@ public class FireEventRequest implements org.apache.thrift.TBase<FireEventReques oprot.writeFieldBegin(PARTITION_VALS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partitionVals.size())); - for (String _iter569 : struct.partitionVals) + for (String _iter577 : struct.partitionVals) { - oprot.writeString(_iter569); + oprot.writeString(_iter577); } oprot.writeListEnd(); } @@ -816,9 +816,9 @@ public class FireEventRequest implements org.apache.thrift.TBase<FireEventReques if (struct.isSetPartitionVals()) { { oprot.writeI32(struct.partitionVals.size()); - for (String _iter570 : struct.partitionVals) + for (String _iter578 : struct.partitionVals) { - oprot.writeString(_iter570); + oprot.writeString(_iter578); } } } @@ -843,13 +843,13 @@ public class FireEventRequest implements org.apache.thrift.TBase<FireEventReques } if (incoming.get(2)) { { - org.apache.thrift.protocol.TList _list571 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.partitionVals = new ArrayList<String>(_list571.size); - String _elem572; - for (int _i573 = 0; _i573 < _list571.size; ++_i573) + org.apache.thrift.protocol.TList _list579 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.partitionVals = new ArrayList<String>(_list579.size); + String _elem580; + for (int _i581 = 0; _i581 < _list579.size; ++_i581) { - _elem572 = iprot.readString(); - struct.partitionVals.add(_elem572); + _elem580 = iprot.readString(); + struct.partitionVals.add(_elem580); } } struct.setPartitionValsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/bbd99ed6/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java index f427a3a..49a1be2 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java @@ -346,14 +346,14 @@ public class GetAllFunctionsResponse implements org.apache.thrift.TBase<GetAllFu case 1: // FUNCTIONS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list634 = iprot.readListBegin(); - struct.functions = new ArrayList<Function>(_list634.size); - Function _elem635; - for (int _i636 = 0; _i636 < _list634.size; ++_i636) + org.apache.thrift.protocol.TList _list642 = iprot.readListBegin(); + struct.functions = new ArrayList<Function>(_list642.size); + Function _elem643; + for (int _i644 = 0; _i644 < _list642.size; ++_i644) { - _elem635 = new Function(); - _elem635.read(iprot); - struct.functions.add(_elem635); + _elem643 = new Function(); + _elem643.read(iprot); + struct.functions.add(_elem643); } iprot.readListEnd(); } @@ -380,9 +380,9 @@ public class GetAllFunctionsResponse implements org.apache.thrift.TBase<GetAllFu oprot.writeFieldBegin(FUNCTIONS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.functions.size())); - for (Function _iter637 : struct.functions) + for (Function _iter645 : struct.functions) { - _iter637.write(oprot); + _iter645.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ public class GetAllFunctionsResponse implements org.apache.thrift.TBase<GetAllFu if (struct.isSetFunctions()) { { oprot.writeI32(struct.functions.size()); - for (Function _iter638 : struct.functions) + for (Function _iter646 : struct.functions) { - _iter638.write(oprot); + _iter646.write(oprot); } } } @@ -428,14 +428,14 @@ public class GetAllFunctionsResponse implements org.apache.thrift.TBase<GetAllFu BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list639 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.functions = new ArrayList<Function>(_list639.size); - Function _elem640; - for (int _i641 = 0; _i641 < _list639.size; ++_i641) + org.apache.thrift.protocol.TList _list647 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.functions = new ArrayList<Function>(_list647.size); + Function _elem648; + for (int _i649 = 0; _i649 < _list647.size; ++_i649) { - _elem640 = new Function(); - _elem640.read(iprot); - struct.functions.add(_elem640); + _elem648 = new Function(); + _elem648.read(iprot); + struct.functions.add(_elem648); } } struct.setFunctionsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/bbd99ed6/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java index 1ea90a0..20b82cf 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java @@ -619,13 +619,13 @@ public class GetFileMetadataByExprRequest implements org.apache.thrift.TBase<Get case 1: // FILE_IDS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list584 = iprot.readListBegin(); - struct.fileIds = new ArrayList<Long>(_list584.size); - long _elem585; - for (int _i586 = 0; _i586 < _list584.size; ++_i586) + org.apache.thrift.protocol.TList _list592 = iprot.readListBegin(); + struct.fileIds = new ArrayList<Long>(_list592.size); + long _elem593; + for (int _i594 = 0; _i594 < _list592.size; ++_i594) { - _elem585 = iprot.readI64(); - struct.fileIds.add(_elem585); + _elem593 = iprot.readI64(); + struct.fileIds.add(_elem593); } iprot.readListEnd(); } @@ -675,9 +675,9 @@ public class GetFileMetadataByExprRequest implements org.apache.thrift.TBase<Get oprot.writeFieldBegin(FILE_IDS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.fileIds.size())); - for (long _iter587 : struct.fileIds) + for (long _iter595 : struct.fileIds) { - oprot.writeI64(_iter587); + oprot.writeI64(_iter595); } oprot.writeListEnd(); } @@ -719,9 +719,9 @@ public class GetFileMetadataByExprRequest implements org.apache.thrift.TBase<Get TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.fileIds.size()); - for (long _iter588 : struct.fileIds) + for (long _iter596 : struct.fileIds) { - oprot.writeI64(_iter588); + oprot.writeI64(_iter596); } } oprot.writeBinary(struct.expr); @@ -745,13 +745,13 @@ public class GetFileMetadataByExprRequest implements org.apache.thrift.TBase<Get public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataByExprRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list589 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.fileIds = new ArrayList<Long>(_list589.size); - long _elem590; - for (int _i591 = 0; _i591 < _list589.size; ++_i591) + org.apache.thrift.protocol.TList _list597 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.fileIds = new ArrayList<Long>(_list597.size); + long _elem598; + for (int _i599 = 0; _i599 < _list597.size; ++_i599) { - _elem590 = iprot.readI64(); - struct.fileIds.add(_elem590); + _elem598 = iprot.readI64(); + struct.fileIds.add(_elem598); } } struct.setFileIdsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/bbd99ed6/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java index 609abc5..9975dfc 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java @@ -444,16 +444,16 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF case 1: // METADATA if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map574 = iprot.readMapBegin(); - struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map574.size); - long _key575; - MetadataPpdResult _val576; - for (int _i577 = 0; _i577 < _map574.size; ++_i577) + org.apache.thrift.protocol.TMap _map582 = iprot.readMapBegin(); + struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map582.size); + long _key583; + MetadataPpdResult _val584; + for (int _i585 = 0; _i585 < _map582.size; ++_i585) { - _key575 = iprot.readI64(); - _val576 = new MetadataPpdResult(); - _val576.read(iprot); - struct.metadata.put(_key575, _val576); + _key583 = iprot.readI64(); + _val584 = new MetadataPpdResult(); + _val584.read(iprot); + struct.metadata.put(_key583, _val584); } iprot.readMapEnd(); } @@ -487,10 +487,10 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF oprot.writeFieldBegin(METADATA_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRUCT, struct.metadata.size())); - for (Map.Entry<Long, MetadataPpdResult> _iter578 : struct.metadata.entrySet()) + for (Map.Entry<Long, MetadataPpdResult> _iter586 : struct.metadata.entrySet()) { - oprot.writeI64(_iter578.getKey()); - _iter578.getValue().write(oprot); + oprot.writeI64(_iter586.getKey()); + _iter586.getValue().write(oprot); } oprot.writeMapEnd(); } @@ -518,10 +518,10 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.metadata.size()); - for (Map.Entry<Long, MetadataPpdResult> _iter579 : struct.metadata.entrySet()) + for (Map.Entry<Long, MetadataPpdResult> _iter587 : struct.metadata.entrySet()) { - oprot.writeI64(_iter579.getKey()); - _iter579.getValue().write(oprot); + oprot.writeI64(_iter587.getKey()); + _iter587.getValue().write(oprot); } } oprot.writeBool(struct.isSupported); @@ -531,16 +531,16 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataByExprResult struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TMap _map580 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map580.size); - long _key581; - MetadataPpdResult _val582; - for (int _i583 = 0; _i583 < _map580.size; ++_i583) + org.apache.thrift.protocol.TMap _map588 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map588.size); + long _key589; + MetadataPpdResult _val590; + for (int _i591 = 0; _i591 < _map588.size; ++_i591) { - _key581 = iprot.readI64(); - _val582 = new MetadataPpdResult(); - _val582.read(iprot); - struct.metadata.put(_key581, _val582); + _key589 = iprot.readI64(); + _val590 = new MetadataPpdResult(); + _val590.read(iprot); + struct.metadata.put(_key589, _val590); } } struct.setMetadataIsSet(true);