http://git-wip-us.apache.org/repos/asf/hive/blob/6e0504d9/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 9e2e883..f2a715a 100644 --- a/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp +++ b/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp @@ -12834,6 +12834,11 @@ void CompactionRequest::__set_runas(const std::string& val) { __isset.runas = true; } +void CompactionRequest::__set_properties(const std::map<std::string, std::string> & val) { + this->properties = val; +__isset.properties = true; +} + uint32_t CompactionRequest::read(::apache::thrift::protocol::TProtocol* iprot) { apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); @@ -12900,6 +12905,29 @@ uint32_t CompactionRequest::read(::apache::thrift::protocol::TProtocol* iprot) { xfer += iprot->skip(ftype); } break; + case 6: + if (ftype == ::apache::thrift::protocol::T_MAP) { + { + this->properties.clear(); + uint32_t _size561; + ::apache::thrift::protocol::TType _ktype562; + ::apache::thrift::protocol::TType _vtype563; + xfer += iprot->readMapBegin(_ktype562, _vtype563, _size561); + uint32_t _i565; + for (_i565 = 0; _i565 < _size561; ++_i565) + { + std::string _key566; + xfer += iprot->readString(_key566); + std::string& _val567 = this->properties[_key566]; + xfer += iprot->readString(_val567); + } + xfer += iprot->readMapEnd(); + } + this->__isset.properties = true; + } else { + xfer += iprot->skip(ftype); + } + break; default: xfer += iprot->skip(ftype); break; @@ -12945,6 +12973,20 @@ uint32_t CompactionRequest::write(::apache::thrift::protocol::TProtocol* oprot) xfer += oprot->writeString(this->runas); xfer += oprot->writeFieldEnd(); } + if (this->__isset.properties) { + 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 _iter568; + for (_iter568 = this->properties.begin(); _iter568 != this->properties.end(); ++_iter568) + { + xfer += oprot->writeString(_iter568->first); + xfer += oprot->writeString(_iter568->second); + } + xfer += oprot->writeMapEnd(); + } + xfer += oprot->writeFieldEnd(); + } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; @@ -12957,24 +12999,27 @@ void swap(CompactionRequest &a, CompactionRequest &b) { swap(a.partitionname, b.partitionname); swap(a.type, b.type); swap(a.runas, b.runas); + swap(a.properties, b.properties); swap(a.__isset, b.__isset); } -CompactionRequest::CompactionRequest(const CompactionRequest& other561) { - dbname = other561.dbname; - tablename = other561.tablename; - partitionname = other561.partitionname; - type = other561.type; - runas = other561.runas; - __isset = other561.__isset; -} -CompactionRequest& CompactionRequest::operator=(const CompactionRequest& other562) { - dbname = other562.dbname; - tablename = other562.tablename; - partitionname = other562.partitionname; - type = other562.type; - runas = other562.runas; - __isset = other562.__isset; +CompactionRequest::CompactionRequest(const CompactionRequest& other569) { + dbname = other569.dbname; + tablename = other569.tablename; + partitionname = other569.partitionname; + type = other569.type; + runas = other569.runas; + properties = other569.properties; + __isset = other569.__isset; +} +CompactionRequest& CompactionRequest::operator=(const CompactionRequest& other570) { + dbname = other570.dbname; + tablename = other570.tablename; + partitionname = other570.partitionname; + type = other570.type; + runas = other570.runas; + properties = other570.properties; + __isset = other570.__isset; return *this; } void CompactionRequest::printTo(std::ostream& out) const { @@ -12985,6 +13030,7 @@ void CompactionRequest::printTo(std::ostream& out) const { out << ", " << "partitionname="; (__isset.partitionname ? (out << to_string(partitionname)) : (out << "<null>")); out << ", " << "type=" << to_string(type); out << ", " << "runas="; (__isset.runas ? (out << to_string(runas)) : (out << "<null>")); + out << ", " << "properties="; (__isset.properties ? (out << to_string(properties)) : (out << "<null>")); out << ")"; } @@ -13037,11 +13083,11 @@ void swap(ShowCompactRequest &a, ShowCompactRequest &b) { (void) b; } -ShowCompactRequest::ShowCompactRequest(const ShowCompactRequest& other563) { - (void) other563; +ShowCompactRequest::ShowCompactRequest(const ShowCompactRequest& other571) { + (void) other571; } -ShowCompactRequest& ShowCompactRequest::operator=(const ShowCompactRequest& other564) { - (void) other564; +ShowCompactRequest& ShowCompactRequest::operator=(const ShowCompactRequest& other572) { + (void) other572; return *this; } void ShowCompactRequest::printTo(std::ostream& out) const { @@ -13162,9 +13208,9 @@ uint32_t ShowCompactResponseElement::read(::apache::thrift::protocol::TProtocol* break; case 4: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast565; - xfer += iprot->readI32(ecast565); - this->type = (CompactionType::type)ecast565; + int32_t ecast573; + xfer += iprot->readI32(ecast573); + this->type = (CompactionType::type)ecast573; isset_type = true; } else { xfer += iprot->skip(ftype); @@ -13337,35 +13383,35 @@ void swap(ShowCompactResponseElement &a, ShowCompactResponseElement &b) { swap(a.__isset, b.__isset); } -ShowCompactResponseElement::ShowCompactResponseElement(const ShowCompactResponseElement& other566) { - dbname = other566.dbname; - tablename = other566.tablename; - partitionname = other566.partitionname; - type = other566.type; - state = other566.state; - workerid = other566.workerid; - start = other566.start; - runAs = other566.runAs; - hightestTxnId = other566.hightestTxnId; - metaInfo = other566.metaInfo; - endTime = other566.endTime; - hadoopJobId = other566.hadoopJobId; - __isset = other566.__isset; -} -ShowCompactResponseElement& ShowCompactResponseElement::operator=(const ShowCompactResponseElement& other567) { - dbname = other567.dbname; - tablename = other567.tablename; - partitionname = other567.partitionname; - type = other567.type; - state = other567.state; - workerid = other567.workerid; - start = other567.start; - runAs = other567.runAs; - hightestTxnId = other567.hightestTxnId; - metaInfo = other567.metaInfo; - endTime = other567.endTime; - hadoopJobId = other567.hadoopJobId; - __isset = other567.__isset; +ShowCompactResponseElement::ShowCompactResponseElement(const ShowCompactResponseElement& other574) { + dbname = other574.dbname; + tablename = other574.tablename; + partitionname = other574.partitionname; + type = other574.type; + state = other574.state; + workerid = other574.workerid; + start = other574.start; + runAs = other574.runAs; + hightestTxnId = other574.hightestTxnId; + metaInfo = other574.metaInfo; + endTime = other574.endTime; + hadoopJobId = other574.hadoopJobId; + __isset = other574.__isset; +} +ShowCompactResponseElement& ShowCompactResponseElement::operator=(const ShowCompactResponseElement& other575) { + dbname = other575.dbname; + tablename = other575.tablename; + partitionname = other575.partitionname; + type = other575.type; + state = other575.state; + workerid = other575.workerid; + start = other575.start; + runAs = other575.runAs; + hightestTxnId = other575.hightestTxnId; + metaInfo = other575.metaInfo; + endTime = other575.endTime; + hadoopJobId = other575.hadoopJobId; + __isset = other575.__isset; return *this; } void ShowCompactResponseElement::printTo(std::ostream& out) const { @@ -13421,14 +13467,14 @@ uint32_t ShowCompactResponse::read(::apache::thrift::protocol::TProtocol* iprot) if (ftype == ::apache::thrift::protocol::T_LIST) { { this->compacts.clear(); - uint32_t _size568; - ::apache::thrift::protocol::TType _etype571; - xfer += iprot->readListBegin(_etype571, _size568); - this->compacts.resize(_size568); - uint32_t _i572; - for (_i572 = 0; _i572 < _size568; ++_i572) + uint32_t _size576; + ::apache::thrift::protocol::TType _etype579; + xfer += iprot->readListBegin(_etype579, _size576); + this->compacts.resize(_size576); + uint32_t _i580; + for (_i580 = 0; _i580 < _size576; ++_i580) { - xfer += this->compacts[_i572].read(iprot); + xfer += this->compacts[_i580].read(iprot); } xfer += iprot->readListEnd(); } @@ -13459,10 +13505,10 @@ uint32_t ShowCompactResponse::write(::apache::thrift::protocol::TProtocol* oprot 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 _iter573; - for (_iter573 = this->compacts.begin(); _iter573 != this->compacts.end(); ++_iter573) + std::vector<ShowCompactResponseElement> ::const_iterator _iter581; + for (_iter581 = this->compacts.begin(); _iter581 != this->compacts.end(); ++_iter581) { - xfer += (*_iter573).write(oprot); + xfer += (*_iter581).write(oprot); } xfer += oprot->writeListEnd(); } @@ -13478,11 +13524,11 @@ void swap(ShowCompactResponse &a, ShowCompactResponse &b) { swap(a.compacts, b.compacts); } -ShowCompactResponse::ShowCompactResponse(const ShowCompactResponse& other574) { - compacts = other574.compacts; +ShowCompactResponse::ShowCompactResponse(const ShowCompactResponse& other582) { + compacts = other582.compacts; } -ShowCompactResponse& ShowCompactResponse::operator=(const ShowCompactResponse& other575) { - compacts = other575.compacts; +ShowCompactResponse& ShowCompactResponse::operator=(const ShowCompactResponse& other583) { + compacts = other583.compacts; return *this; } void ShowCompactResponse::printTo(std::ostream& out) const { @@ -13571,14 +13617,14 @@ uint32_t AddDynamicPartitions::read(::apache::thrift::protocol::TProtocol* iprot if (ftype == ::apache::thrift::protocol::T_LIST) { { this->partitionnames.clear(); - uint32_t _size576; - ::apache::thrift::protocol::TType _etype579; - xfer += iprot->readListBegin(_etype579, _size576); - this->partitionnames.resize(_size576); - uint32_t _i580; - for (_i580 = 0; _i580 < _size576; ++_i580) + uint32_t _size584; + ::apache::thrift::protocol::TType _etype587; + xfer += iprot->readListBegin(_etype587, _size584); + this->partitionnames.resize(_size584); + uint32_t _i588; + for (_i588 = 0; _i588 < _size584; ++_i588) { - xfer += iprot->readString(this->partitionnames[_i580]); + xfer += iprot->readString(this->partitionnames[_i588]); } xfer += iprot->readListEnd(); } @@ -13589,9 +13635,9 @@ uint32_t AddDynamicPartitions::read(::apache::thrift::protocol::TProtocol* iprot break; case 5: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast581; - xfer += iprot->readI32(ecast581); - this->operationType = (DataOperationType::type)ecast581; + int32_t ecast589; + xfer += iprot->readI32(ecast589); + this->operationType = (DataOperationType::type)ecast589; this->__isset.operationType = true; } else { xfer += iprot->skip(ftype); @@ -13637,10 +13683,10 @@ uint32_t AddDynamicPartitions::write(::apache::thrift::protocol::TProtocol* opro xfer += oprot->writeFieldBegin("partitionnames", ::apache::thrift::protocol::T_LIST, 4); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->partitionnames.size())); - std::vector<std::string> ::const_iterator _iter582; - for (_iter582 = this->partitionnames.begin(); _iter582 != this->partitionnames.end(); ++_iter582) + std::vector<std::string> ::const_iterator _iter590; + for (_iter590 = this->partitionnames.begin(); _iter590 != this->partitionnames.end(); ++_iter590) { - xfer += oprot->writeString((*_iter582)); + xfer += oprot->writeString((*_iter590)); } xfer += oprot->writeListEnd(); } @@ -13666,21 +13712,21 @@ void swap(AddDynamicPartitions &a, AddDynamicPartitions &b) { swap(a.__isset, b.__isset); } -AddDynamicPartitions::AddDynamicPartitions(const AddDynamicPartitions& other583) { - txnid = other583.txnid; - dbname = other583.dbname; - tablename = other583.tablename; - partitionnames = other583.partitionnames; - operationType = other583.operationType; - __isset = other583.__isset; -} -AddDynamicPartitions& AddDynamicPartitions::operator=(const AddDynamicPartitions& other584) { - txnid = other584.txnid; - dbname = other584.dbname; - tablename = other584.tablename; - partitionnames = other584.partitionnames; - operationType = other584.operationType; - __isset = other584.__isset; +AddDynamicPartitions::AddDynamicPartitions(const AddDynamicPartitions& other591) { + txnid = other591.txnid; + dbname = other591.dbname; + tablename = other591.tablename; + partitionnames = other591.partitionnames; + operationType = other591.operationType; + __isset = other591.__isset; +} +AddDynamicPartitions& AddDynamicPartitions::operator=(const AddDynamicPartitions& other592) { + txnid = other592.txnid; + dbname = other592.dbname; + tablename = other592.tablename; + partitionnames = other592.partitionnames; + operationType = other592.operationType; + __isset = other592.__isset; return *this; } void AddDynamicPartitions::printTo(std::ostream& out) const { @@ -13786,15 +13832,15 @@ void swap(NotificationEventRequest &a, NotificationEventRequest &b) { swap(a.__isset, b.__isset); } -NotificationEventRequest::NotificationEventRequest(const NotificationEventRequest& other585) { - lastEvent = other585.lastEvent; - maxEvents = other585.maxEvents; - __isset = other585.__isset; +NotificationEventRequest::NotificationEventRequest(const NotificationEventRequest& other593) { + lastEvent = other593.lastEvent; + maxEvents = other593.maxEvents; + __isset = other593.__isset; } -NotificationEventRequest& NotificationEventRequest::operator=(const NotificationEventRequest& other586) { - lastEvent = other586.lastEvent; - maxEvents = other586.maxEvents; - __isset = other586.__isset; +NotificationEventRequest& NotificationEventRequest::operator=(const NotificationEventRequest& other594) { + lastEvent = other594.lastEvent; + maxEvents = other594.maxEvents; + __isset = other594.__isset; return *this; } void NotificationEventRequest::printTo(std::ostream& out) const { @@ -13976,23 +14022,23 @@ void swap(NotificationEvent &a, NotificationEvent &b) { swap(a.__isset, b.__isset); } -NotificationEvent::NotificationEvent(const NotificationEvent& other587) { - eventId = other587.eventId; - eventTime = other587.eventTime; - eventType = other587.eventType; - dbName = other587.dbName; - tableName = other587.tableName; - message = other587.message; - __isset = other587.__isset; -} -NotificationEvent& NotificationEvent::operator=(const NotificationEvent& other588) { - eventId = other588.eventId; - eventTime = other588.eventTime; - eventType = other588.eventType; - dbName = other588.dbName; - tableName = other588.tableName; - message = other588.message; - __isset = other588.__isset; +NotificationEvent::NotificationEvent(const NotificationEvent& other595) { + eventId = other595.eventId; + eventTime = other595.eventTime; + eventType = other595.eventType; + dbName = other595.dbName; + tableName = other595.tableName; + message = other595.message; + __isset = other595.__isset; +} +NotificationEvent& NotificationEvent::operator=(const NotificationEvent& other596) { + eventId = other596.eventId; + eventTime = other596.eventTime; + eventType = other596.eventType; + dbName = other596.dbName; + tableName = other596.tableName; + message = other596.message; + __isset = other596.__isset; return *this; } void NotificationEvent::printTo(std::ostream& out) const { @@ -14042,14 +14088,14 @@ uint32_t NotificationEventResponse::read(::apache::thrift::protocol::TProtocol* if (ftype == ::apache::thrift::protocol::T_LIST) { { this->events.clear(); - uint32_t _size589; - ::apache::thrift::protocol::TType _etype592; - xfer += iprot->readListBegin(_etype592, _size589); - this->events.resize(_size589); - uint32_t _i593; - for (_i593 = 0; _i593 < _size589; ++_i593) + uint32_t _size597; + ::apache::thrift::protocol::TType _etype600; + xfer += iprot->readListBegin(_etype600, _size597); + this->events.resize(_size597); + uint32_t _i601; + for (_i601 = 0; _i601 < _size597; ++_i601) { - xfer += this->events[_i593].read(iprot); + xfer += this->events[_i601].read(iprot); } xfer += iprot->readListEnd(); } @@ -14080,10 +14126,10 @@ uint32_t NotificationEventResponse::write(::apache::thrift::protocol::TProtocol* 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 _iter594; - for (_iter594 = this->events.begin(); _iter594 != this->events.end(); ++_iter594) + std::vector<NotificationEvent> ::const_iterator _iter602; + for (_iter602 = this->events.begin(); _iter602 != this->events.end(); ++_iter602) { - xfer += (*_iter594).write(oprot); + xfer += (*_iter602).write(oprot); } xfer += oprot->writeListEnd(); } @@ -14099,11 +14145,11 @@ void swap(NotificationEventResponse &a, NotificationEventResponse &b) { swap(a.events, b.events); } -NotificationEventResponse::NotificationEventResponse(const NotificationEventResponse& other595) { - events = other595.events; +NotificationEventResponse::NotificationEventResponse(const NotificationEventResponse& other603) { + events = other603.events; } -NotificationEventResponse& NotificationEventResponse::operator=(const NotificationEventResponse& other596) { - events = other596.events; +NotificationEventResponse& NotificationEventResponse::operator=(const NotificationEventResponse& other604) { + events = other604.events; return *this; } void NotificationEventResponse::printTo(std::ostream& out) const { @@ -14185,11 +14231,11 @@ void swap(CurrentNotificationEventId &a, CurrentNotificationEventId &b) { swap(a.eventId, b.eventId); } -CurrentNotificationEventId::CurrentNotificationEventId(const CurrentNotificationEventId& other597) { - eventId = other597.eventId; +CurrentNotificationEventId::CurrentNotificationEventId(const CurrentNotificationEventId& other605) { + eventId = other605.eventId; } -CurrentNotificationEventId& CurrentNotificationEventId::operator=(const CurrentNotificationEventId& other598) { - eventId = other598.eventId; +CurrentNotificationEventId& CurrentNotificationEventId::operator=(const CurrentNotificationEventId& other606) { + eventId = other606.eventId; return *this; } void CurrentNotificationEventId::printTo(std::ostream& out) const { @@ -14234,14 +14280,14 @@ uint32_t InsertEventRequestData::read(::apache::thrift::protocol::TProtocol* ipr if (ftype == ::apache::thrift::protocol::T_LIST) { { this->filesAdded.clear(); - uint32_t _size599; - ::apache::thrift::protocol::TType _etype602; - xfer += iprot->readListBegin(_etype602, _size599); - this->filesAdded.resize(_size599); - uint32_t _i603; - for (_i603 = 0; _i603 < _size599; ++_i603) + uint32_t _size607; + ::apache::thrift::protocol::TType _etype610; + xfer += iprot->readListBegin(_etype610, _size607); + this->filesAdded.resize(_size607); + uint32_t _i611; + for (_i611 = 0; _i611 < _size607; ++_i611) { - xfer += iprot->readString(this->filesAdded[_i603]); + xfer += iprot->readString(this->filesAdded[_i611]); } xfer += iprot->readListEnd(); } @@ -14272,10 +14318,10 @@ 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 _iter604; - for (_iter604 = this->filesAdded.begin(); _iter604 != this->filesAdded.end(); ++_iter604) + std::vector<std::string> ::const_iterator _iter612; + for (_iter612 = this->filesAdded.begin(); _iter612 != this->filesAdded.end(); ++_iter612) { - xfer += oprot->writeString((*_iter604)); + xfer += oprot->writeString((*_iter612)); } xfer += oprot->writeListEnd(); } @@ -14291,11 +14337,11 @@ void swap(InsertEventRequestData &a, InsertEventRequestData &b) { swap(a.filesAdded, b.filesAdded); } -InsertEventRequestData::InsertEventRequestData(const InsertEventRequestData& other605) { - filesAdded = other605.filesAdded; +InsertEventRequestData::InsertEventRequestData(const InsertEventRequestData& other613) { + filesAdded = other613.filesAdded; } -InsertEventRequestData& InsertEventRequestData::operator=(const InsertEventRequestData& other606) { - filesAdded = other606.filesAdded; +InsertEventRequestData& InsertEventRequestData::operator=(const InsertEventRequestData& other614) { + filesAdded = other614.filesAdded; return *this; } void InsertEventRequestData::printTo(std::ostream& out) const { @@ -14375,13 +14421,13 @@ void swap(FireEventRequestData &a, FireEventRequestData &b) { swap(a.__isset, b.__isset); } -FireEventRequestData::FireEventRequestData(const FireEventRequestData& other607) { - insertData = other607.insertData; - __isset = other607.__isset; +FireEventRequestData::FireEventRequestData(const FireEventRequestData& other615) { + insertData = other615.insertData; + __isset = other615.__isset; } -FireEventRequestData& FireEventRequestData::operator=(const FireEventRequestData& other608) { - insertData = other608.insertData; - __isset = other608.__isset; +FireEventRequestData& FireEventRequestData::operator=(const FireEventRequestData& other616) { + insertData = other616.insertData; + __isset = other616.__isset; return *this; } void FireEventRequestData::printTo(std::ostream& out) const { @@ -14478,14 +14524,14 @@ uint32_t FireEventRequest::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->partitionVals.clear(); - uint32_t _size609; - ::apache::thrift::protocol::TType _etype612; - xfer += iprot->readListBegin(_etype612, _size609); - this->partitionVals.resize(_size609); - uint32_t _i613; - for (_i613 = 0; _i613 < _size609; ++_i613) + uint32_t _size617; + ::apache::thrift::protocol::TType _etype620; + xfer += iprot->readListBegin(_etype620, _size617); + this->partitionVals.resize(_size617); + uint32_t _i621; + for (_i621 = 0; _i621 < _size617; ++_i621) { - xfer += iprot->readString(this->partitionVals[_i613]); + xfer += iprot->readString(this->partitionVals[_i621]); } xfer += iprot->readListEnd(); } @@ -14537,10 +14583,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 _iter614; - for (_iter614 = this->partitionVals.begin(); _iter614 != this->partitionVals.end(); ++_iter614) + std::vector<std::string> ::const_iterator _iter622; + for (_iter622 = this->partitionVals.begin(); _iter622 != this->partitionVals.end(); ++_iter622) { - xfer += oprot->writeString((*_iter614)); + xfer += oprot->writeString((*_iter622)); } xfer += oprot->writeListEnd(); } @@ -14561,21 +14607,21 @@ void swap(FireEventRequest &a, FireEventRequest &b) { swap(a.__isset, b.__isset); } -FireEventRequest::FireEventRequest(const FireEventRequest& other615) { - successful = other615.successful; - data = other615.data; - dbName = other615.dbName; - tableName = other615.tableName; - partitionVals = other615.partitionVals; - __isset = other615.__isset; -} -FireEventRequest& FireEventRequest::operator=(const FireEventRequest& other616) { - successful = other616.successful; - data = other616.data; - dbName = other616.dbName; - tableName = other616.tableName; - partitionVals = other616.partitionVals; - __isset = other616.__isset; +FireEventRequest::FireEventRequest(const FireEventRequest& other623) { + successful = other623.successful; + data = other623.data; + dbName = other623.dbName; + tableName = other623.tableName; + partitionVals = other623.partitionVals; + __isset = other623.__isset; +} +FireEventRequest& FireEventRequest::operator=(const FireEventRequest& other624) { + successful = other624.successful; + data = other624.data; + dbName = other624.dbName; + tableName = other624.tableName; + partitionVals = other624.partitionVals; + __isset = other624.__isset; return *this; } void FireEventRequest::printTo(std::ostream& out) const { @@ -14638,11 +14684,11 @@ void swap(FireEventResponse &a, FireEventResponse &b) { (void) b; } -FireEventResponse::FireEventResponse(const FireEventResponse& other617) { - (void) other617; +FireEventResponse::FireEventResponse(const FireEventResponse& other625) { + (void) other625; } -FireEventResponse& FireEventResponse::operator=(const FireEventResponse& other618) { - (void) other618; +FireEventResponse& FireEventResponse::operator=(const FireEventResponse& other626) { + (void) other626; return *this; } void FireEventResponse::printTo(std::ostream& out) const { @@ -14686,14 +14732,14 @@ uint32_t GetAllFunctionsResponse::read(::apache::thrift::protocol::TProtocol* ip if (ftype == ::apache::thrift::protocol::T_LIST) { { this->functions.clear(); - uint32_t _size619; - ::apache::thrift::protocol::TType _etype622; - xfer += iprot->readListBegin(_etype622, _size619); - this->functions.resize(_size619); - uint32_t _i623; - for (_i623 = 0; _i623 < _size619; ++_i623) + uint32_t _size627; + ::apache::thrift::protocol::TType _etype630; + xfer += iprot->readListBegin(_etype630, _size627); + this->functions.resize(_size627); + uint32_t _i631; + for (_i631 = 0; _i631 < _size627; ++_i631) { - xfer += this->functions[_i623].read(iprot); + xfer += this->functions[_i631].read(iprot); } xfer += iprot->readListEnd(); } @@ -14723,10 +14769,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 _iter624; - for (_iter624 = this->functions.begin(); _iter624 != this->functions.end(); ++_iter624) + std::vector<Function> ::const_iterator _iter632; + for (_iter632 = this->functions.begin(); _iter632 != this->functions.end(); ++_iter632) { - xfer += (*_iter624).write(oprot); + xfer += (*_iter632).write(oprot); } xfer += oprot->writeListEnd(); } @@ -14743,13 +14789,13 @@ void swap(GetAllFunctionsResponse &a, GetAllFunctionsResponse &b) { swap(a.__isset, b.__isset); } -GetAllFunctionsResponse::GetAllFunctionsResponse(const GetAllFunctionsResponse& other625) { - functions = other625.functions; - __isset = other625.__isset; +GetAllFunctionsResponse::GetAllFunctionsResponse(const GetAllFunctionsResponse& other633) { + functions = other633.functions; + __isset = other633.__isset; } -GetAllFunctionsResponse& GetAllFunctionsResponse::operator=(const GetAllFunctionsResponse& other626) { - functions = other626.functions; - __isset = other626.__isset; +GetAllFunctionsResponse& GetAllFunctionsResponse::operator=(const GetAllFunctionsResponse& other634) { + functions = other634.functions; + __isset = other634.__isset; return *this; } void GetAllFunctionsResponse::printTo(std::ostream& out) const { @@ -14829,13 +14875,13 @@ void swap(MetaException &a, MetaException &b) { swap(a.__isset, b.__isset); } -MetaException::MetaException(const MetaException& other627) : TException() { - message = other627.message; - __isset = other627.__isset; +MetaException::MetaException(const MetaException& other635) : TException() { + message = other635.message; + __isset = other635.__isset; } -MetaException& MetaException::operator=(const MetaException& other628) { - message = other628.message; - __isset = other628.__isset; +MetaException& MetaException::operator=(const MetaException& other636) { + message = other636.message; + __isset = other636.__isset; return *this; } void MetaException::printTo(std::ostream& out) const { @@ -14926,13 +14972,13 @@ void swap(UnknownTableException &a, UnknownTableException &b) { swap(a.__isset, b.__isset); } -UnknownTableException::UnknownTableException(const UnknownTableException& other629) : TException() { - message = other629.message; - __isset = other629.__isset; +UnknownTableException::UnknownTableException(const UnknownTableException& other637) : TException() { + message = other637.message; + __isset = other637.__isset; } -UnknownTableException& UnknownTableException::operator=(const UnknownTableException& other630) { - message = other630.message; - __isset = other630.__isset; +UnknownTableException& UnknownTableException::operator=(const UnknownTableException& other638) { + message = other638.message; + __isset = other638.__isset; return *this; } void UnknownTableException::printTo(std::ostream& out) const { @@ -15023,13 +15069,13 @@ void swap(UnknownDBException &a, UnknownDBException &b) { swap(a.__isset, b.__isset); } -UnknownDBException::UnknownDBException(const UnknownDBException& other631) : TException() { - message = other631.message; - __isset = other631.__isset; +UnknownDBException::UnknownDBException(const UnknownDBException& other639) : TException() { + message = other639.message; + __isset = other639.__isset; } -UnknownDBException& UnknownDBException::operator=(const UnknownDBException& other632) { - message = other632.message; - __isset = other632.__isset; +UnknownDBException& UnknownDBException::operator=(const UnknownDBException& other640) { + message = other640.message; + __isset = other640.__isset; return *this; } void UnknownDBException::printTo(std::ostream& out) const { @@ -15120,13 +15166,13 @@ void swap(AlreadyExistsException &a, AlreadyExistsException &b) { swap(a.__isset, b.__isset); } -AlreadyExistsException::AlreadyExistsException(const AlreadyExistsException& other633) : TException() { - message = other633.message; - __isset = other633.__isset; +AlreadyExistsException::AlreadyExistsException(const AlreadyExistsException& other641) : TException() { + message = other641.message; + __isset = other641.__isset; } -AlreadyExistsException& AlreadyExistsException::operator=(const AlreadyExistsException& other634) { - message = other634.message; - __isset = other634.__isset; +AlreadyExistsException& AlreadyExistsException::operator=(const AlreadyExistsException& other642) { + message = other642.message; + __isset = other642.__isset; return *this; } void AlreadyExistsException::printTo(std::ostream& out) const { @@ -15217,13 +15263,13 @@ void swap(InvalidPartitionException &a, InvalidPartitionException &b) { swap(a.__isset, b.__isset); } -InvalidPartitionException::InvalidPartitionException(const InvalidPartitionException& other635) : TException() { - message = other635.message; - __isset = other635.__isset; +InvalidPartitionException::InvalidPartitionException(const InvalidPartitionException& other643) : TException() { + message = other643.message; + __isset = other643.__isset; } -InvalidPartitionException& InvalidPartitionException::operator=(const InvalidPartitionException& other636) { - message = other636.message; - __isset = other636.__isset; +InvalidPartitionException& InvalidPartitionException::operator=(const InvalidPartitionException& other644) { + message = other644.message; + __isset = other644.__isset; return *this; } void InvalidPartitionException::printTo(std::ostream& out) const { @@ -15314,13 +15360,13 @@ void swap(UnknownPartitionException &a, UnknownPartitionException &b) { swap(a.__isset, b.__isset); } -UnknownPartitionException::UnknownPartitionException(const UnknownPartitionException& other637) : TException() { - message = other637.message; - __isset = other637.__isset; +UnknownPartitionException::UnknownPartitionException(const UnknownPartitionException& other645) : TException() { + message = other645.message; + __isset = other645.__isset; } -UnknownPartitionException& UnknownPartitionException::operator=(const UnknownPartitionException& other638) { - message = other638.message; - __isset = other638.__isset; +UnknownPartitionException& UnknownPartitionException::operator=(const UnknownPartitionException& other646) { + message = other646.message; + __isset = other646.__isset; return *this; } void UnknownPartitionException::printTo(std::ostream& out) const { @@ -15411,13 +15457,13 @@ void swap(InvalidObjectException &a, InvalidObjectException &b) { swap(a.__isset, b.__isset); } -InvalidObjectException::InvalidObjectException(const InvalidObjectException& other639) : TException() { - message = other639.message; - __isset = other639.__isset; +InvalidObjectException::InvalidObjectException(const InvalidObjectException& other647) : TException() { + message = other647.message; + __isset = other647.__isset; } -InvalidObjectException& InvalidObjectException::operator=(const InvalidObjectException& other640) { - message = other640.message; - __isset = other640.__isset; +InvalidObjectException& InvalidObjectException::operator=(const InvalidObjectException& other648) { + message = other648.message; + __isset = other648.__isset; return *this; } void InvalidObjectException::printTo(std::ostream& out) const { @@ -15508,13 +15554,13 @@ void swap(NoSuchObjectException &a, NoSuchObjectException &b) { swap(a.__isset, b.__isset); } -NoSuchObjectException::NoSuchObjectException(const NoSuchObjectException& other641) : TException() { - message = other641.message; - __isset = other641.__isset; +NoSuchObjectException::NoSuchObjectException(const NoSuchObjectException& other649) : TException() { + message = other649.message; + __isset = other649.__isset; } -NoSuchObjectException& NoSuchObjectException::operator=(const NoSuchObjectException& other642) { - message = other642.message; - __isset = other642.__isset; +NoSuchObjectException& NoSuchObjectException::operator=(const NoSuchObjectException& other650) { + message = other650.message; + __isset = other650.__isset; return *this; } void NoSuchObjectException::printTo(std::ostream& out) const { @@ -15605,13 +15651,13 @@ void swap(IndexAlreadyExistsException &a, IndexAlreadyExistsException &b) { swap(a.__isset, b.__isset); } -IndexAlreadyExistsException::IndexAlreadyExistsException(const IndexAlreadyExistsException& other643) : TException() { - message = other643.message; - __isset = other643.__isset; +IndexAlreadyExistsException::IndexAlreadyExistsException(const IndexAlreadyExistsException& other651) : TException() { + message = other651.message; + __isset = other651.__isset; } -IndexAlreadyExistsException& IndexAlreadyExistsException::operator=(const IndexAlreadyExistsException& other644) { - message = other644.message; - __isset = other644.__isset; +IndexAlreadyExistsException& IndexAlreadyExistsException::operator=(const IndexAlreadyExistsException& other652) { + message = other652.message; + __isset = other652.__isset; return *this; } void IndexAlreadyExistsException::printTo(std::ostream& out) const { @@ -15702,13 +15748,13 @@ void swap(InvalidOperationException &a, InvalidOperationException &b) { swap(a.__isset, b.__isset); } -InvalidOperationException::InvalidOperationException(const InvalidOperationException& other645) : TException() { - message = other645.message; - __isset = other645.__isset; +InvalidOperationException::InvalidOperationException(const InvalidOperationException& other653) : TException() { + message = other653.message; + __isset = other653.__isset; } -InvalidOperationException& InvalidOperationException::operator=(const InvalidOperationException& other646) { - message = other646.message; - __isset = other646.__isset; +InvalidOperationException& InvalidOperationException::operator=(const InvalidOperationException& other654) { + message = other654.message; + __isset = other654.__isset; return *this; } void InvalidOperationException::printTo(std::ostream& out) const { @@ -15799,13 +15845,13 @@ void swap(ConfigValSecurityException &a, ConfigValSecurityException &b) { swap(a.__isset, b.__isset); } -ConfigValSecurityException::ConfigValSecurityException(const ConfigValSecurityException& other647) : TException() { - message = other647.message; - __isset = other647.__isset; +ConfigValSecurityException::ConfigValSecurityException(const ConfigValSecurityException& other655) : TException() { + message = other655.message; + __isset = other655.__isset; } -ConfigValSecurityException& ConfigValSecurityException::operator=(const ConfigValSecurityException& other648) { - message = other648.message; - __isset = other648.__isset; +ConfigValSecurityException& ConfigValSecurityException::operator=(const ConfigValSecurityException& other656) { + message = other656.message; + __isset = other656.__isset; return *this; } void ConfigValSecurityException::printTo(std::ostream& out) const { @@ -15896,13 +15942,13 @@ void swap(InvalidInputException &a, InvalidInputException &b) { swap(a.__isset, b.__isset); } -InvalidInputException::InvalidInputException(const InvalidInputException& other649) : TException() { - message = other649.message; - __isset = other649.__isset; +InvalidInputException::InvalidInputException(const InvalidInputException& other657) : TException() { + message = other657.message; + __isset = other657.__isset; } -InvalidInputException& InvalidInputException::operator=(const InvalidInputException& other650) { - message = other650.message; - __isset = other650.__isset; +InvalidInputException& InvalidInputException::operator=(const InvalidInputException& other658) { + message = other658.message; + __isset = other658.__isset; return *this; } void InvalidInputException::printTo(std::ostream& out) const { @@ -15993,13 +16039,13 @@ void swap(NoSuchTxnException &a, NoSuchTxnException &b) { swap(a.__isset, b.__isset); } -NoSuchTxnException::NoSuchTxnException(const NoSuchTxnException& other651) : TException() { - message = other651.message; - __isset = other651.__isset; +NoSuchTxnException::NoSuchTxnException(const NoSuchTxnException& other659) : TException() { + message = other659.message; + __isset = other659.__isset; } -NoSuchTxnException& NoSuchTxnException::operator=(const NoSuchTxnException& other652) { - message = other652.message; - __isset = other652.__isset; +NoSuchTxnException& NoSuchTxnException::operator=(const NoSuchTxnException& other660) { + message = other660.message; + __isset = other660.__isset; return *this; } void NoSuchTxnException::printTo(std::ostream& out) const { @@ -16090,13 +16136,13 @@ void swap(TxnAbortedException &a, TxnAbortedException &b) { swap(a.__isset, b.__isset); } -TxnAbortedException::TxnAbortedException(const TxnAbortedException& other653) : TException() { - message = other653.message; - __isset = other653.__isset; +TxnAbortedException::TxnAbortedException(const TxnAbortedException& other661) : TException() { + message = other661.message; + __isset = other661.__isset; } -TxnAbortedException& TxnAbortedException::operator=(const TxnAbortedException& other654) { - message = other654.message; - __isset = other654.__isset; +TxnAbortedException& TxnAbortedException::operator=(const TxnAbortedException& other662) { + message = other662.message; + __isset = other662.__isset; return *this; } void TxnAbortedException::printTo(std::ostream& out) const { @@ -16187,13 +16233,13 @@ void swap(TxnOpenException &a, TxnOpenException &b) { swap(a.__isset, b.__isset); } -TxnOpenException::TxnOpenException(const TxnOpenException& other655) : TException() { - message = other655.message; - __isset = other655.__isset; +TxnOpenException::TxnOpenException(const TxnOpenException& other663) : TException() { + message = other663.message; + __isset = other663.__isset; } -TxnOpenException& TxnOpenException::operator=(const TxnOpenException& other656) { - message = other656.message; - __isset = other656.__isset; +TxnOpenException& TxnOpenException::operator=(const TxnOpenException& other664) { + message = other664.message; + __isset = other664.__isset; return *this; } void TxnOpenException::printTo(std::ostream& out) const { @@ -16284,13 +16330,13 @@ void swap(NoSuchLockException &a, NoSuchLockException &b) { swap(a.__isset, b.__isset); } -NoSuchLockException::NoSuchLockException(const NoSuchLockException& other657) : TException() { - message = other657.message; - __isset = other657.__isset; +NoSuchLockException::NoSuchLockException(const NoSuchLockException& other665) : TException() { + message = other665.message; + __isset = other665.__isset; } -NoSuchLockException& NoSuchLockException::operator=(const NoSuchLockException& other658) { - message = other658.message; - __isset = other658.__isset; +NoSuchLockException& NoSuchLockException::operator=(const NoSuchLockException& other666) { + message = other666.message; + __isset = other666.__isset; return *this; } void NoSuchLockException::printTo(std::ostream& out) const {
http://git-wip-us.apache.org/repos/asf/hive/blob/6e0504d9/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 390db33..4574214 100644 --- a/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h +++ b/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h @@ -5202,9 +5202,10 @@ inline std::ostream& operator<<(std::ostream& out, const HeartbeatTxnRangeRespon } typedef struct _CompactionRequest__isset { - _CompactionRequest__isset() : partitionname(false), runas(false) {} + _CompactionRequest__isset() : partitionname(false), runas(false), properties(false) {} bool partitionname :1; bool runas :1; + bool properties :1; } _CompactionRequest__isset; class CompactionRequest { @@ -5221,6 +5222,7 @@ class CompactionRequest { std::string partitionname; CompactionType::type type; std::string runas; + std::map<std::string, std::string> properties; _CompactionRequest__isset __isset; @@ -5234,6 +5236,8 @@ class CompactionRequest { void __set_runas(const std::string& val); + void __set_properties(const std::map<std::string, std::string> & val); + bool operator == (const CompactionRequest & rhs) const { if (!(dbname == rhs.dbname)) @@ -5250,6 +5254,10 @@ class CompactionRequest { return false; else if (__isset.runas && !(runas == rhs.runas)) return false; + if (__isset.properties != rhs.__isset.properties) + return false; + else if (__isset.properties && !(properties == rhs.properties)) + return false; return true; } bool operator != (const CompactionRequest &rhs) const { http://git-wip-us.apache.org/repos/asf/hive/blob/6e0504d9/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java index 7543ef4..9350b2d 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java @@ -727,13 +727,13 @@ public class AddDynamicPartitions implements org.apache.thrift.TBase<AddDynamicP case 4: // PARTITIONNAMES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list500 = iprot.readListBegin(); - struct.partitionnames = new ArrayList<String>(_list500.size); - String _elem501; - for (int _i502 = 0; _i502 < _list500.size; ++_i502) + org.apache.thrift.protocol.TList _list510 = iprot.readListBegin(); + struct.partitionnames = new ArrayList<String>(_list510.size); + String _elem511; + for (int _i512 = 0; _i512 < _list510.size; ++_i512) { - _elem501 = iprot.readString(); - struct.partitionnames.add(_elem501); + _elem511 = iprot.readString(); + struct.partitionnames.add(_elem511); } iprot.readListEnd(); } @@ -780,9 +780,9 @@ public class AddDynamicPartitions implements org.apache.thrift.TBase<AddDynamicP oprot.writeFieldBegin(PARTITIONNAMES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partitionnames.size())); - for (String _iter503 : struct.partitionnames) + for (String _iter513 : struct.partitionnames) { - oprot.writeString(_iter503); + oprot.writeString(_iter513); } oprot.writeListEnd(); } @@ -817,9 +817,9 @@ public class AddDynamicPartitions implements org.apache.thrift.TBase<AddDynamicP oprot.writeString(struct.tablename); { oprot.writeI32(struct.partitionnames.size()); - for (String _iter504 : struct.partitionnames) + for (String _iter514 : struct.partitionnames) { - oprot.writeString(_iter504); + oprot.writeString(_iter514); } } BitSet optionals = new BitSet(); @@ -842,13 +842,13 @@ public class AddDynamicPartitions implements org.apache.thrift.TBase<AddDynamicP struct.tablename = iprot.readString(); struct.setTablenameIsSet(true); { - org.apache.thrift.protocol.TList _list505 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.partitionnames = new ArrayList<String>(_list505.size); - String _elem506; - for (int _i507 = 0; _i507 < _list505.size; ++_i507) + org.apache.thrift.protocol.TList _list515 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.partitionnames = new ArrayList<String>(_list515.size); + String _elem516; + for (int _i517 = 0; _i517 < _list515.size; ++_i517) { - _elem506 = iprot.readString(); - struct.partitionnames.add(_elem506); + _elem516 = iprot.readString(); + struct.partitionnames.add(_elem516); } } struct.setPartitionnamesIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6e0504d9/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java index e028ecb..638ba73 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java @@ -43,6 +43,7 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ private static final org.apache.thrift.protocol.TField PARTITIONNAME_FIELD_DESC = new org.apache.thrift.protocol.TField("partitionname", org.apache.thrift.protocol.TType.STRING, (short)3); private static final org.apache.thrift.protocol.TField TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("type", org.apache.thrift.protocol.TType.I32, (short)4); private static final org.apache.thrift.protocol.TField RUNAS_FIELD_DESC = new org.apache.thrift.protocol.TField("runas", org.apache.thrift.protocol.TType.STRING, (short)5); + private static final org.apache.thrift.protocol.TField PROPERTIES_FIELD_DESC = new org.apache.thrift.protocol.TField("properties", org.apache.thrift.protocol.TType.MAP, (short)6); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -55,6 +56,7 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ private String partitionname; // optional private CompactionType type; // required private String runas; // optional + private Map<String,String> properties; // optional /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { @@ -66,7 +68,8 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ * @see CompactionType */ TYPE((short)4, "type"), - RUNAS((short)5, "runas"); + RUNAS((short)5, "runas"), + PROPERTIES((short)6, "properties"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -91,6 +94,8 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ return TYPE; case 5: // RUNAS return RUNAS; + case 6: // PROPERTIES + return PROPERTIES; default: return null; } @@ -131,7 +136,7 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ } // isset id assignments - private static final _Fields optionals[] = {_Fields.PARTITIONNAME,_Fields.RUNAS}; + private static final _Fields optionals[] = {_Fields.PARTITIONNAME,_Fields.RUNAS,_Fields.PROPERTIES}; public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; static { Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); @@ -145,6 +150,10 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, CompactionType.class))); tmpMap.put(_Fields.RUNAS, new org.apache.thrift.meta_data.FieldMetaData("runas", org.apache.thrift.TFieldRequirementType.OPTIONAL, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.PROPERTIES, new org.apache.thrift.meta_data.FieldMetaData("properties", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING), + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))); metaDataMap = Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(CompactionRequest.class, metaDataMap); } @@ -182,6 +191,10 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ if (other.isSetRunas()) { this.runas = other.runas; } + if (other.isSetProperties()) { + Map<String,String> __this__properties = new HashMap<String,String>(other.properties); + this.properties = __this__properties; + } } public CompactionRequest deepCopy() { @@ -195,6 +208,7 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ this.partitionname = null; this.type = null; this.runas = null; + this.properties = null; } public String getDbname() { @@ -320,6 +334,40 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ } } + public int getPropertiesSize() { + return (this.properties == null) ? 0 : this.properties.size(); + } + + public void putToProperties(String key, String val) { + if (this.properties == null) { + this.properties = new HashMap<String,String>(); + } + this.properties.put(key, val); + } + + public Map<String,String> getProperties() { + return this.properties; + } + + public void setProperties(Map<String,String> properties) { + this.properties = properties; + } + + public void unsetProperties() { + this.properties = null; + } + + /** Returns true if field properties is set (has been assigned a value) and false otherwise */ + public boolean isSetProperties() { + return this.properties != null; + } + + public void setPropertiesIsSet(boolean value) { + if (!value) { + this.properties = null; + } + } + public void setFieldValue(_Fields field, Object value) { switch (field) { case DBNAME: @@ -362,6 +410,14 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ } break; + case PROPERTIES: + if (value == null) { + unsetProperties(); + } else { + setProperties((Map<String,String>)value); + } + break; + } } @@ -382,6 +438,9 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ case RUNAS: return getRunas(); + case PROPERTIES: + return getProperties(); + } throw new IllegalStateException(); } @@ -403,6 +462,8 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ return isSetType(); case RUNAS: return isSetRunas(); + case PROPERTIES: + return isSetProperties(); } throw new IllegalStateException(); } @@ -465,6 +526,15 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ return false; } + boolean this_present_properties = true && this.isSetProperties(); + boolean that_present_properties = true && that.isSetProperties(); + if (this_present_properties || that_present_properties) { + if (!(this_present_properties && that_present_properties)) + return false; + if (!this.properties.equals(that.properties)) + return false; + } + return true; } @@ -497,6 +567,11 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ if (present_runas) list.add(runas); + boolean present_properties = true && (isSetProperties()); + list.add(present_properties); + if (present_properties) + list.add(properties); + return list.hashCode(); } @@ -558,6 +633,16 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ return lastComparison; } } + lastComparison = Boolean.valueOf(isSetProperties()).compareTo(other.isSetProperties()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetProperties()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.properties, other.properties); + if (lastComparison != 0) { + return lastComparison; + } + } return 0; } @@ -621,6 +706,16 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ } first = false; } + if (isSetProperties()) { + if (!first) sb.append(", "); + sb.append("properties:"); + if (this.properties == null) { + sb.append("null"); + } else { + sb.append(this.properties); + } + first = false; + } sb.append(")"); return sb.toString(); } @@ -716,6 +811,26 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; + case 6: // PROPERTIES + if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { + { + org.apache.thrift.protocol.TMap _map492 = iprot.readMapBegin(); + struct.properties = new HashMap<String,String>(2*_map492.size); + String _key493; + String _val494; + for (int _i495 = 0; _i495 < _map492.size; ++_i495) + { + _key493 = iprot.readString(); + _val494 = iprot.readString(); + struct.properties.put(_key493, _val494); + } + iprot.readMapEnd(); + } + struct.setPropertiesIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -758,6 +873,21 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ oprot.writeFieldEnd(); } } + if (struct.properties != null) { + if (struct.isSetProperties()) { + oprot.writeFieldBegin(PROPERTIES_FIELD_DESC); + { + oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.properties.size())); + for (Map.Entry<String, String> _iter496 : struct.properties.entrySet()) + { + oprot.writeString(_iter496.getKey()); + oprot.writeString(_iter496.getValue()); + } + oprot.writeMapEnd(); + } + oprot.writeFieldEnd(); + } + } oprot.writeFieldStop(); oprot.writeStructEnd(); } @@ -785,13 +915,26 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ if (struct.isSetRunas()) { optionals.set(1); } - oprot.writeBitSet(optionals, 2); + if (struct.isSetProperties()) { + optionals.set(2); + } + oprot.writeBitSet(optionals, 3); if (struct.isSetPartitionname()) { oprot.writeString(struct.partitionname); } if (struct.isSetRunas()) { oprot.writeString(struct.runas); } + if (struct.isSetProperties()) { + { + oprot.writeI32(struct.properties.size()); + for (Map.Entry<String, String> _iter497 : struct.properties.entrySet()) + { + oprot.writeString(_iter497.getKey()); + oprot.writeString(_iter497.getValue()); + } + } + } } @Override @@ -803,7 +946,7 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ struct.setTablenameIsSet(true); struct.type = org.apache.hadoop.hive.metastore.api.CompactionType.findByValue(iprot.readI32()); struct.setTypeIsSet(true); - BitSet incoming = iprot.readBitSet(2); + BitSet incoming = iprot.readBitSet(3); if (incoming.get(0)) { struct.partitionname = iprot.readString(); struct.setPartitionnameIsSet(true); @@ -812,6 +955,21 @@ public class CompactionRequest implements org.apache.thrift.TBase<CompactionRequ struct.runas = iprot.readString(); struct.setRunasIsSet(true); } + if (incoming.get(2)) { + { + org.apache.thrift.protocol.TMap _map498 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.properties = new HashMap<String,String>(2*_map498.size); + String _key499; + String _val500; + for (int _i501 = 0; _i501 < _map498.size; ++_i501) + { + _key499 = iprot.readString(); + _val500 = iprot.readString(); + struct.properties.put(_key499, _val500); + } + } + struct.setPropertiesIsSet(true); + } } } http://git-wip-us.apache.org/repos/asf/hive/blob/6e0504d9/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 551c46a..a3a6171 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 _list524 = iprot.readListBegin(); - struct.partitionVals = new ArrayList<String>(_list524.size); - String _elem525; - for (int _i526 = 0; _i526 < _list524.size; ++_i526) + org.apache.thrift.protocol.TList _list534 = iprot.readListBegin(); + struct.partitionVals = new ArrayList<String>(_list534.size); + String _elem535; + for (int _i536 = 0; _i536 < _list534.size; ++_i536) { - _elem525 = iprot.readString(); - struct.partitionVals.add(_elem525); + _elem535 = iprot.readString(); + struct.partitionVals.add(_elem535); } 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 _iter527 : struct.partitionVals) + for (String _iter537 : struct.partitionVals) { - oprot.writeString(_iter527); + oprot.writeString(_iter537); } 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 _iter528 : struct.partitionVals) + for (String _iter538 : struct.partitionVals) { - oprot.writeString(_iter528); + oprot.writeString(_iter538); } } } @@ -843,13 +843,13 @@ public class FireEventRequest implements org.apache.thrift.TBase<FireEventReques } if (incoming.get(2)) { { - org.apache.thrift.protocol.TList _list529 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.partitionVals = new ArrayList<String>(_list529.size); - String _elem530; - for (int _i531 = 0; _i531 < _list529.size; ++_i531) + org.apache.thrift.protocol.TList _list539 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.partitionVals = new ArrayList<String>(_list539.size); + String _elem540; + for (int _i541 = 0; _i541 < _list539.size; ++_i541) { - _elem530 = iprot.readString(); - struct.partitionVals.add(_elem530); + _elem540 = iprot.readString(); + struct.partitionVals.add(_elem540); } } struct.setPartitionValsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6e0504d9/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 f23c8e5..9728f5e 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 _list532 = iprot.readListBegin(); - struct.functions = new ArrayList<Function>(_list532.size); - Function _elem533; - for (int _i534 = 0; _i534 < _list532.size; ++_i534) + org.apache.thrift.protocol.TList _list542 = iprot.readListBegin(); + struct.functions = new ArrayList<Function>(_list542.size); + Function _elem543; + for (int _i544 = 0; _i544 < _list542.size; ++_i544) { - _elem533 = new Function(); - _elem533.read(iprot); - struct.functions.add(_elem533); + _elem543 = new Function(); + _elem543.read(iprot); + struct.functions.add(_elem543); } 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 _iter535 : struct.functions) + for (Function _iter545 : struct.functions) { - _iter535.write(oprot); + _iter545.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 _iter536 : struct.functions) + for (Function _iter546 : struct.functions) { - _iter536.write(oprot); + _iter546.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 _list537 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.functions = new ArrayList<Function>(_list537.size); - Function _elem538; - for (int _i539 = 0; _i539 < _list537.size; ++_i539) + org.apache.thrift.protocol.TList _list547 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.functions = new ArrayList<Function>(_list547.size); + Function _elem548; + for (int _i549 = 0; _i549 < _list547.size; ++_i549) { - _elem538 = new Function(); - _elem538.read(iprot); - struct.functions.add(_elem538); + _elem548 = new Function(); + _elem548.read(iprot); + struct.functions.add(_elem548); } } struct.setFunctionsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6e0504d9/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java index 8a799c8..594c28e 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java @@ -351,13 +351,13 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve case 1: // FILES_ADDED if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list516 = iprot.readListBegin(); - struct.filesAdded = new ArrayList<String>(_list516.size); - String _elem517; - for (int _i518 = 0; _i518 < _list516.size; ++_i518) + org.apache.thrift.protocol.TList _list526 = iprot.readListBegin(); + struct.filesAdded = new ArrayList<String>(_list526.size); + String _elem527; + for (int _i528 = 0; _i528 < _list526.size; ++_i528) { - _elem517 = iprot.readString(); - struct.filesAdded.add(_elem517); + _elem527 = iprot.readString(); + struct.filesAdded.add(_elem527); } iprot.readListEnd(); } @@ -383,9 +383,9 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve oprot.writeFieldBegin(FILES_ADDED_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.filesAdded.size())); - for (String _iter519 : struct.filesAdded) + for (String _iter529 : struct.filesAdded) { - oprot.writeString(_iter519); + oprot.writeString(_iter529); } oprot.writeListEnd(); } @@ -410,9 +410,9 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.filesAdded.size()); - for (String _iter520 : struct.filesAdded) + for (String _iter530 : struct.filesAdded) { - oprot.writeString(_iter520); + oprot.writeString(_iter530); } } } @@ -421,13 +421,13 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve public void read(org.apache.thrift.protocol.TProtocol prot, InsertEventRequestData struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list521 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.filesAdded = new ArrayList<String>(_list521.size); - String _elem522; - for (int _i523 = 0; _i523 < _list521.size; ++_i523) + org.apache.thrift.protocol.TList _list531 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.filesAdded = new ArrayList<String>(_list531.size); + String _elem532; + for (int _i533 = 0; _i533 < _list531.size; ++_i533) { - _elem522 = iprot.readString(); - struct.filesAdded.add(_elem522); + _elem532 = iprot.readString(); + struct.filesAdded.add(_elem532); } } struct.setFilesAddedIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6e0504d9/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java index f6671d5..fbc19b7 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java @@ -354,14 +354,14 @@ public class NotificationEventResponse implements org.apache.thrift.TBase<Notifi case 1: // EVENTS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list508 = iprot.readListBegin(); - struct.events = new ArrayList<NotificationEvent>(_list508.size); - NotificationEvent _elem509; - for (int _i510 = 0; _i510 < _list508.size; ++_i510) + org.apache.thrift.protocol.TList _list518 = iprot.readListBegin(); + struct.events = new ArrayList<NotificationEvent>(_list518.size); + NotificationEvent _elem519; + for (int _i520 = 0; _i520 < _list518.size; ++_i520) { - _elem509 = new NotificationEvent(); - _elem509.read(iprot); - struct.events.add(_elem509); + _elem519 = new NotificationEvent(); + _elem519.read(iprot); + struct.events.add(_elem519); } iprot.readListEnd(); } @@ -387,9 +387,9 @@ public class NotificationEventResponse implements org.apache.thrift.TBase<Notifi oprot.writeFieldBegin(EVENTS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.events.size())); - for (NotificationEvent _iter511 : struct.events) + for (NotificationEvent _iter521 : struct.events) { - _iter511.write(oprot); + _iter521.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ public class NotificationEventResponse implements org.apache.thrift.TBase<Notifi TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.events.size()); - for (NotificationEvent _iter512 : struct.events) + for (NotificationEvent _iter522 : struct.events) { - _iter512.write(oprot); + _iter522.write(oprot); } } } @@ -425,14 +425,14 @@ public class NotificationEventResponse implements org.apache.thrift.TBase<Notifi public void read(org.apache.thrift.protocol.TProtocol prot, NotificationEventResponse struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list513 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.events = new ArrayList<NotificationEvent>(_list513.size); - NotificationEvent _elem514; - for (int _i515 = 0; _i515 < _list513.size; ++_i515) + org.apache.thrift.protocol.TList _list523 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.events = new ArrayList<NotificationEvent>(_list523.size); + NotificationEvent _elem524; + for (int _i525 = 0; _i525 < _list523.size; ++_i525) { - _elem514 = new NotificationEvent(); - _elem514.read(iprot); - struct.events.add(_elem514); + _elem524 = new NotificationEvent(); + _elem524.read(iprot); + struct.events.add(_elem524); } } struct.setEventsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6e0504d9/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java index 1cb446d..6ee26ad 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java @@ -354,14 +354,14 @@ public class ShowCompactResponse implements org.apache.thrift.TBase<ShowCompactR case 1: // COMPACTS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list492 = iprot.readListBegin(); - struct.compacts = new ArrayList<ShowCompactResponseElement>(_list492.size); - ShowCompactResponseElement _elem493; - for (int _i494 = 0; _i494 < _list492.size; ++_i494) + org.apache.thrift.protocol.TList _list502 = iprot.readListBegin(); + struct.compacts = new ArrayList<ShowCompactResponseElement>(_list502.size); + ShowCompactResponseElement _elem503; + for (int _i504 = 0; _i504 < _list502.size; ++_i504) { - _elem493 = new ShowCompactResponseElement(); - _elem493.read(iprot); - struct.compacts.add(_elem493); + _elem503 = new ShowCompactResponseElement(); + _elem503.read(iprot); + struct.compacts.add(_elem503); } iprot.readListEnd(); } @@ -387,9 +387,9 @@ public class ShowCompactResponse implements org.apache.thrift.TBase<ShowCompactR oprot.writeFieldBegin(COMPACTS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.compacts.size())); - for (ShowCompactResponseElement _iter495 : struct.compacts) + for (ShowCompactResponseElement _iter505 : struct.compacts) { - _iter495.write(oprot); + _iter505.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ public class ShowCompactResponse implements org.apache.thrift.TBase<ShowCompactR TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.compacts.size()); - for (ShowCompactResponseElement _iter496 : struct.compacts) + for (ShowCompactResponseElement _iter506 : struct.compacts) { - _iter496.write(oprot); + _iter506.write(oprot); } } } @@ -425,14 +425,14 @@ public class ShowCompactResponse implements org.apache.thrift.TBase<ShowCompactR public void read(org.apache.thrift.protocol.TProtocol prot, ShowCompactResponse struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list497 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.compacts = new ArrayList<ShowCompactResponseElement>(_list497.size); - ShowCompactResponseElement _elem498; - for (int _i499 = 0; _i499 < _list497.size; ++_i499) + org.apache.thrift.protocol.TList _list507 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.compacts = new ArrayList<ShowCompactResponseElement>(_list507.size); + ShowCompactResponseElement _elem508; + for (int _i509 = 0; _i509 < _list507.size; ++_i509) { - _elem498 = new ShowCompactResponseElement(); - _elem498.read(iprot); - struct.compacts.add(_elem498); + _elem508 = new ShowCompactResponseElement(); + _elem508.read(iprot); + struct.compacts.add(_elem508); } } struct.setCompactsIsSet(true);