Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 2A7AF200B35 for ; Sat, 28 May 2016 00:16:18 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 28D43160A38; Fri, 27 May 2016 22:16:18 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id D4C61160A3D for ; Sat, 28 May 2016 00:16:15 +0200 (CEST) Received: (qmail 75330 invoked by uid 500); 27 May 2016 22:16:14 -0000 Mailing-List: contact commits-help@hive.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: hive-dev@hive.apache.org Delivered-To: mailing list commits@hive.apache.org Received: (qmail 74520 invoked by uid 99); 27 May 2016 22:16:14 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 27 May 2016 22:16:14 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 3BC0EE7E30; Fri, 27 May 2016 22:16:14 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: weiz@apache.org To: commits@hive.apache.org Date: Fri, 27 May 2016 22:16:19 -0000 Message-Id: <51707085773148ffb1f192a008640f6d@git.apache.org> In-Reply-To: <45ef26a43ae94f50961a7ea89619b123@git.apache.org> References: <45ef26a43ae94f50961a7ea89619b123@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [6/8] hive git commit: HIVE-13354 : Add ability to specify Compaction options per table and per request (Wei Zheng, reviewed by Eugene Koifman) archived-at: Fri, 27 May 2016 22:16:18 -0000 http://git-wip-us.apache.org/repos/asf/hive/blob/e276929d/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 f8ca7cd..79460a8 100644 --- a/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp +++ b/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp @@ -14413,6 +14413,11 @@ void CompactionRequest::__set_runas(const std::string& val) { __isset.runas = true; } +void CompactionRequest::__set_properties(const std::map & val) { + this->properties = val; +__isset.properties = true; +} + uint32_t CompactionRequest::read(::apache::thrift::protocol::TProtocol* iprot) { apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); @@ -14479,6 +14484,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 _size603; + ::apache::thrift::protocol::TType _ktype604; + ::apache::thrift::protocol::TType _vtype605; + xfer += iprot->readMapBegin(_ktype604, _vtype605, _size603); + uint32_t _i607; + for (_i607 = 0; _i607 < _size603; ++_i607) + { + std::string _key608; + xfer += iprot->readString(_key608); + std::string& _val609 = this->properties[_key608]; + xfer += iprot->readString(_val609); + } + xfer += iprot->readMapEnd(); + } + this->__isset.properties = true; + } else { + xfer += iprot->skip(ftype); + } + break; default: xfer += iprot->skip(ftype); break; @@ -14524,6 +14552,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(this->properties.size())); + std::map ::const_iterator _iter610; + for (_iter610 = this->properties.begin(); _iter610 != this->properties.end(); ++_iter610) + { + xfer += oprot->writeString(_iter610->first); + xfer += oprot->writeString(_iter610->second); + } + xfer += oprot->writeMapEnd(); + } + xfer += oprot->writeFieldEnd(); + } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; @@ -14536,24 +14578,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& other603) { - dbname = other603.dbname; - tablename = other603.tablename; - partitionname = other603.partitionname; - type = other603.type; - runas = other603.runas; - __isset = other603.__isset; -} -CompactionRequest& CompactionRequest::operator=(const CompactionRequest& other604) { - dbname = other604.dbname; - tablename = other604.tablename; - partitionname = other604.partitionname; - type = other604.type; - runas = other604.runas; - __isset = other604.__isset; +CompactionRequest::CompactionRequest(const CompactionRequest& other611) { + dbname = other611.dbname; + tablename = other611.tablename; + partitionname = other611.partitionname; + type = other611.type; + runas = other611.runas; + properties = other611.properties; + __isset = other611.__isset; +} +CompactionRequest& CompactionRequest::operator=(const CompactionRequest& other612) { + dbname = other612.dbname; + tablename = other612.tablename; + partitionname = other612.partitionname; + type = other612.type; + runas = other612.runas; + properties = other612.properties; + __isset = other612.__isset; return *this; } void CompactionRequest::printTo(std::ostream& out) const { @@ -14564,6 +14609,7 @@ void CompactionRequest::printTo(std::ostream& out) const { out << ", " << "partitionname="; (__isset.partitionname ? (out << to_string(partitionname)) : (out << "")); out << ", " << "type=" << to_string(type); out << ", " << "runas="; (__isset.runas ? (out << to_string(runas)) : (out << "")); + out << ", " << "properties="; (__isset.properties ? (out << to_string(properties)) : (out << "")); out << ")"; } @@ -14616,11 +14662,11 @@ void swap(ShowCompactRequest &a, ShowCompactRequest &b) { (void) b; } -ShowCompactRequest::ShowCompactRequest(const ShowCompactRequest& other605) { - (void) other605; +ShowCompactRequest::ShowCompactRequest(const ShowCompactRequest& other613) { + (void) other613; } -ShowCompactRequest& ShowCompactRequest::operator=(const ShowCompactRequest& other606) { - (void) other606; +ShowCompactRequest& ShowCompactRequest::operator=(const ShowCompactRequest& other614) { + (void) other614; return *this; } void ShowCompactRequest::printTo(std::ostream& out) const { @@ -14741,9 +14787,9 @@ uint32_t ShowCompactResponseElement::read(::apache::thrift::protocol::TProtocol* break; case 4: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast607; - xfer += iprot->readI32(ecast607); - this->type = (CompactionType::type)ecast607; + int32_t ecast615; + xfer += iprot->readI32(ecast615); + this->type = (CompactionType::type)ecast615; isset_type = true; } else { xfer += iprot->skip(ftype); @@ -14916,35 +14962,35 @@ void swap(ShowCompactResponseElement &a, ShowCompactResponseElement &b) { swap(a.__isset, b.__isset); } -ShowCompactResponseElement::ShowCompactResponseElement(const ShowCompactResponseElement& other608) { - dbname = other608.dbname; - tablename = other608.tablename; - partitionname = other608.partitionname; - type = other608.type; - state = other608.state; - workerid = other608.workerid; - start = other608.start; - runAs = other608.runAs; - hightestTxnId = other608.hightestTxnId; - metaInfo = other608.metaInfo; - endTime = other608.endTime; - hadoopJobId = other608.hadoopJobId; - __isset = other608.__isset; -} -ShowCompactResponseElement& ShowCompactResponseElement::operator=(const ShowCompactResponseElement& other609) { - dbname = other609.dbname; - tablename = other609.tablename; - partitionname = other609.partitionname; - type = other609.type; - state = other609.state; - workerid = other609.workerid; - start = other609.start; - runAs = other609.runAs; - hightestTxnId = other609.hightestTxnId; - metaInfo = other609.metaInfo; - endTime = other609.endTime; - hadoopJobId = other609.hadoopJobId; - __isset = other609.__isset; +ShowCompactResponseElement::ShowCompactResponseElement(const ShowCompactResponseElement& other616) { + dbname = other616.dbname; + tablename = other616.tablename; + partitionname = other616.partitionname; + type = other616.type; + state = other616.state; + workerid = other616.workerid; + start = other616.start; + runAs = other616.runAs; + hightestTxnId = other616.hightestTxnId; + metaInfo = other616.metaInfo; + endTime = other616.endTime; + hadoopJobId = other616.hadoopJobId; + __isset = other616.__isset; +} +ShowCompactResponseElement& ShowCompactResponseElement::operator=(const ShowCompactResponseElement& other617) { + dbname = other617.dbname; + tablename = other617.tablename; + partitionname = other617.partitionname; + type = other617.type; + state = other617.state; + workerid = other617.workerid; + start = other617.start; + runAs = other617.runAs; + hightestTxnId = other617.hightestTxnId; + metaInfo = other617.metaInfo; + endTime = other617.endTime; + hadoopJobId = other617.hadoopJobId; + __isset = other617.__isset; return *this; } void ShowCompactResponseElement::printTo(std::ostream& out) const { @@ -15000,14 +15046,14 @@ uint32_t ShowCompactResponse::read(::apache::thrift::protocol::TProtocol* iprot) if (ftype == ::apache::thrift::protocol::T_LIST) { { this->compacts.clear(); - uint32_t _size610; - ::apache::thrift::protocol::TType _etype613; - xfer += iprot->readListBegin(_etype613, _size610); - this->compacts.resize(_size610); - uint32_t _i614; - for (_i614 = 0; _i614 < _size610; ++_i614) + uint32_t _size618; + ::apache::thrift::protocol::TType _etype621; + xfer += iprot->readListBegin(_etype621, _size618); + this->compacts.resize(_size618); + uint32_t _i622; + for (_i622 = 0; _i622 < _size618; ++_i622) { - xfer += this->compacts[_i614].read(iprot); + xfer += this->compacts[_i622].read(iprot); } xfer += iprot->readListEnd(); } @@ -15038,10 +15084,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(this->compacts.size())); - std::vector ::const_iterator _iter615; - for (_iter615 = this->compacts.begin(); _iter615 != this->compacts.end(); ++_iter615) + std::vector ::const_iterator _iter623; + for (_iter623 = this->compacts.begin(); _iter623 != this->compacts.end(); ++_iter623) { - xfer += (*_iter615).write(oprot); + xfer += (*_iter623).write(oprot); } xfer += oprot->writeListEnd(); } @@ -15057,11 +15103,11 @@ void swap(ShowCompactResponse &a, ShowCompactResponse &b) { swap(a.compacts, b.compacts); } -ShowCompactResponse::ShowCompactResponse(const ShowCompactResponse& other616) { - compacts = other616.compacts; +ShowCompactResponse::ShowCompactResponse(const ShowCompactResponse& other624) { + compacts = other624.compacts; } -ShowCompactResponse& ShowCompactResponse::operator=(const ShowCompactResponse& other617) { - compacts = other617.compacts; +ShowCompactResponse& ShowCompactResponse::operator=(const ShowCompactResponse& other625) { + compacts = other625.compacts; return *this; } void ShowCompactResponse::printTo(std::ostream& out) const { @@ -15150,14 +15196,14 @@ uint32_t AddDynamicPartitions::read(::apache::thrift::protocol::TProtocol* iprot if (ftype == ::apache::thrift::protocol::T_LIST) { { this->partitionnames.clear(); - uint32_t _size618; - ::apache::thrift::protocol::TType _etype621; - xfer += iprot->readListBegin(_etype621, _size618); - this->partitionnames.resize(_size618); - uint32_t _i622; - for (_i622 = 0; _i622 < _size618; ++_i622) + uint32_t _size626; + ::apache::thrift::protocol::TType _etype629; + xfer += iprot->readListBegin(_etype629, _size626); + this->partitionnames.resize(_size626); + uint32_t _i630; + for (_i630 = 0; _i630 < _size626; ++_i630) { - xfer += iprot->readString(this->partitionnames[_i622]); + xfer += iprot->readString(this->partitionnames[_i630]); } xfer += iprot->readListEnd(); } @@ -15168,9 +15214,9 @@ uint32_t AddDynamicPartitions::read(::apache::thrift::protocol::TProtocol* iprot break; case 5: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast623; - xfer += iprot->readI32(ecast623); - this->operationType = (DataOperationType::type)ecast623; + int32_t ecast631; + xfer += iprot->readI32(ecast631); + this->operationType = (DataOperationType::type)ecast631; this->__isset.operationType = true; } else { xfer += iprot->skip(ftype); @@ -15216,10 +15262,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(this->partitionnames.size())); - std::vector ::const_iterator _iter624; - for (_iter624 = this->partitionnames.begin(); _iter624 != this->partitionnames.end(); ++_iter624) + std::vector ::const_iterator _iter632; + for (_iter632 = this->partitionnames.begin(); _iter632 != this->partitionnames.end(); ++_iter632) { - xfer += oprot->writeString((*_iter624)); + xfer += oprot->writeString((*_iter632)); } xfer += oprot->writeListEnd(); } @@ -15245,21 +15291,21 @@ void swap(AddDynamicPartitions &a, AddDynamicPartitions &b) { swap(a.__isset, b.__isset); } -AddDynamicPartitions::AddDynamicPartitions(const AddDynamicPartitions& other625) { - txnid = other625.txnid; - dbname = other625.dbname; - tablename = other625.tablename; - partitionnames = other625.partitionnames; - operationType = other625.operationType; - __isset = other625.__isset; -} -AddDynamicPartitions& AddDynamicPartitions::operator=(const AddDynamicPartitions& other626) { - txnid = other626.txnid; - dbname = other626.dbname; - tablename = other626.tablename; - partitionnames = other626.partitionnames; - operationType = other626.operationType; - __isset = other626.__isset; +AddDynamicPartitions::AddDynamicPartitions(const AddDynamicPartitions& other633) { + txnid = other633.txnid; + dbname = other633.dbname; + tablename = other633.tablename; + partitionnames = other633.partitionnames; + operationType = other633.operationType; + __isset = other633.__isset; +} +AddDynamicPartitions& AddDynamicPartitions::operator=(const AddDynamicPartitions& other634) { + txnid = other634.txnid; + dbname = other634.dbname; + tablename = other634.tablename; + partitionnames = other634.partitionnames; + operationType = other634.operationType; + __isset = other634.__isset; return *this; } void AddDynamicPartitions::printTo(std::ostream& out) const { @@ -15365,15 +15411,15 @@ void swap(NotificationEventRequest &a, NotificationEventRequest &b) { swap(a.__isset, b.__isset); } -NotificationEventRequest::NotificationEventRequest(const NotificationEventRequest& other627) { - lastEvent = other627.lastEvent; - maxEvents = other627.maxEvents; - __isset = other627.__isset; +NotificationEventRequest::NotificationEventRequest(const NotificationEventRequest& other635) { + lastEvent = other635.lastEvent; + maxEvents = other635.maxEvents; + __isset = other635.__isset; } -NotificationEventRequest& NotificationEventRequest::operator=(const NotificationEventRequest& other628) { - lastEvent = other628.lastEvent; - maxEvents = other628.maxEvents; - __isset = other628.__isset; +NotificationEventRequest& NotificationEventRequest::operator=(const NotificationEventRequest& other636) { + lastEvent = other636.lastEvent; + maxEvents = other636.maxEvents; + __isset = other636.__isset; return *this; } void NotificationEventRequest::printTo(std::ostream& out) const { @@ -15555,23 +15601,23 @@ void swap(NotificationEvent &a, NotificationEvent &b) { swap(a.__isset, b.__isset); } -NotificationEvent::NotificationEvent(const NotificationEvent& other629) { - eventId = other629.eventId; - eventTime = other629.eventTime; - eventType = other629.eventType; - dbName = other629.dbName; - tableName = other629.tableName; - message = other629.message; - __isset = other629.__isset; -} -NotificationEvent& NotificationEvent::operator=(const NotificationEvent& other630) { - eventId = other630.eventId; - eventTime = other630.eventTime; - eventType = other630.eventType; - dbName = other630.dbName; - tableName = other630.tableName; - message = other630.message; - __isset = other630.__isset; +NotificationEvent::NotificationEvent(const NotificationEvent& other637) { + eventId = other637.eventId; + eventTime = other637.eventTime; + eventType = other637.eventType; + dbName = other637.dbName; + tableName = other637.tableName; + message = other637.message; + __isset = other637.__isset; +} +NotificationEvent& NotificationEvent::operator=(const NotificationEvent& other638) { + eventId = other638.eventId; + eventTime = other638.eventTime; + eventType = other638.eventType; + dbName = other638.dbName; + tableName = other638.tableName; + message = other638.message; + __isset = other638.__isset; return *this; } void NotificationEvent::printTo(std::ostream& out) const { @@ -15621,14 +15667,14 @@ uint32_t NotificationEventResponse::read(::apache::thrift::protocol::TProtocol* if (ftype == ::apache::thrift::protocol::T_LIST) { { this->events.clear(); - uint32_t _size631; - ::apache::thrift::protocol::TType _etype634; - xfer += iprot->readListBegin(_etype634, _size631); - this->events.resize(_size631); - uint32_t _i635; - for (_i635 = 0; _i635 < _size631; ++_i635) + uint32_t _size639; + ::apache::thrift::protocol::TType _etype642; + xfer += iprot->readListBegin(_etype642, _size639); + this->events.resize(_size639); + uint32_t _i643; + for (_i643 = 0; _i643 < _size639; ++_i643) { - xfer += this->events[_i635].read(iprot); + xfer += this->events[_i643].read(iprot); } xfer += iprot->readListEnd(); } @@ -15659,10 +15705,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(this->events.size())); - std::vector ::const_iterator _iter636; - for (_iter636 = this->events.begin(); _iter636 != this->events.end(); ++_iter636) + std::vector ::const_iterator _iter644; + for (_iter644 = this->events.begin(); _iter644 != this->events.end(); ++_iter644) { - xfer += (*_iter636).write(oprot); + xfer += (*_iter644).write(oprot); } xfer += oprot->writeListEnd(); } @@ -15678,11 +15724,11 @@ void swap(NotificationEventResponse &a, NotificationEventResponse &b) { swap(a.events, b.events); } -NotificationEventResponse::NotificationEventResponse(const NotificationEventResponse& other637) { - events = other637.events; +NotificationEventResponse::NotificationEventResponse(const NotificationEventResponse& other645) { + events = other645.events; } -NotificationEventResponse& NotificationEventResponse::operator=(const NotificationEventResponse& other638) { - events = other638.events; +NotificationEventResponse& NotificationEventResponse::operator=(const NotificationEventResponse& other646) { + events = other646.events; return *this; } void NotificationEventResponse::printTo(std::ostream& out) const { @@ -15764,11 +15810,11 @@ void swap(CurrentNotificationEventId &a, CurrentNotificationEventId &b) { swap(a.eventId, b.eventId); } -CurrentNotificationEventId::CurrentNotificationEventId(const CurrentNotificationEventId& other639) { - eventId = other639.eventId; +CurrentNotificationEventId::CurrentNotificationEventId(const CurrentNotificationEventId& other647) { + eventId = other647.eventId; } -CurrentNotificationEventId& CurrentNotificationEventId::operator=(const CurrentNotificationEventId& other640) { - eventId = other640.eventId; +CurrentNotificationEventId& CurrentNotificationEventId::operator=(const CurrentNotificationEventId& other648) { + eventId = other648.eventId; return *this; } void CurrentNotificationEventId::printTo(std::ostream& out) const { @@ -15813,14 +15859,14 @@ uint32_t InsertEventRequestData::read(::apache::thrift::protocol::TProtocol* ipr if (ftype == ::apache::thrift::protocol::T_LIST) { { this->filesAdded.clear(); - uint32_t _size641; - ::apache::thrift::protocol::TType _etype644; - xfer += iprot->readListBegin(_etype644, _size641); - this->filesAdded.resize(_size641); - uint32_t _i645; - for (_i645 = 0; _i645 < _size641; ++_i645) + uint32_t _size649; + ::apache::thrift::protocol::TType _etype652; + xfer += iprot->readListBegin(_etype652, _size649); + this->filesAdded.resize(_size649); + uint32_t _i653; + for (_i653 = 0; _i653 < _size649; ++_i653) { - xfer += iprot->readString(this->filesAdded[_i645]); + xfer += iprot->readString(this->filesAdded[_i653]); } xfer += iprot->readListEnd(); } @@ -15851,10 +15897,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(this->filesAdded.size())); - std::vector ::const_iterator _iter646; - for (_iter646 = this->filesAdded.begin(); _iter646 != this->filesAdded.end(); ++_iter646) + std::vector ::const_iterator _iter654; + for (_iter654 = this->filesAdded.begin(); _iter654 != this->filesAdded.end(); ++_iter654) { - xfer += oprot->writeString((*_iter646)); + xfer += oprot->writeString((*_iter654)); } xfer += oprot->writeListEnd(); } @@ -15870,11 +15916,11 @@ void swap(InsertEventRequestData &a, InsertEventRequestData &b) { swap(a.filesAdded, b.filesAdded); } -InsertEventRequestData::InsertEventRequestData(const InsertEventRequestData& other647) { - filesAdded = other647.filesAdded; +InsertEventRequestData::InsertEventRequestData(const InsertEventRequestData& other655) { + filesAdded = other655.filesAdded; } -InsertEventRequestData& InsertEventRequestData::operator=(const InsertEventRequestData& other648) { - filesAdded = other648.filesAdded; +InsertEventRequestData& InsertEventRequestData::operator=(const InsertEventRequestData& other656) { + filesAdded = other656.filesAdded; return *this; } void InsertEventRequestData::printTo(std::ostream& out) const { @@ -15954,13 +16000,13 @@ void swap(FireEventRequestData &a, FireEventRequestData &b) { swap(a.__isset, b.__isset); } -FireEventRequestData::FireEventRequestData(const FireEventRequestData& other649) { - insertData = other649.insertData; - __isset = other649.__isset; +FireEventRequestData::FireEventRequestData(const FireEventRequestData& other657) { + insertData = other657.insertData; + __isset = other657.__isset; } -FireEventRequestData& FireEventRequestData::operator=(const FireEventRequestData& other650) { - insertData = other650.insertData; - __isset = other650.__isset; +FireEventRequestData& FireEventRequestData::operator=(const FireEventRequestData& other658) { + insertData = other658.insertData; + __isset = other658.__isset; return *this; } void FireEventRequestData::printTo(std::ostream& out) const { @@ -16057,14 +16103,14 @@ uint32_t FireEventRequest::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->partitionVals.clear(); - uint32_t _size651; - ::apache::thrift::protocol::TType _etype654; - xfer += iprot->readListBegin(_etype654, _size651); - this->partitionVals.resize(_size651); - uint32_t _i655; - for (_i655 = 0; _i655 < _size651; ++_i655) + uint32_t _size659; + ::apache::thrift::protocol::TType _etype662; + xfer += iprot->readListBegin(_etype662, _size659); + this->partitionVals.resize(_size659); + uint32_t _i663; + for (_i663 = 0; _i663 < _size659; ++_i663) { - xfer += iprot->readString(this->partitionVals[_i655]); + xfer += iprot->readString(this->partitionVals[_i663]); } xfer += iprot->readListEnd(); } @@ -16116,10 +16162,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(this->partitionVals.size())); - std::vector ::const_iterator _iter656; - for (_iter656 = this->partitionVals.begin(); _iter656 != this->partitionVals.end(); ++_iter656) + std::vector ::const_iterator _iter664; + for (_iter664 = this->partitionVals.begin(); _iter664 != this->partitionVals.end(); ++_iter664) { - xfer += oprot->writeString((*_iter656)); + xfer += oprot->writeString((*_iter664)); } xfer += oprot->writeListEnd(); } @@ -16140,21 +16186,21 @@ void swap(FireEventRequest &a, FireEventRequest &b) { swap(a.__isset, b.__isset); } -FireEventRequest::FireEventRequest(const FireEventRequest& other657) { - successful = other657.successful; - data = other657.data; - dbName = other657.dbName; - tableName = other657.tableName; - partitionVals = other657.partitionVals; - __isset = other657.__isset; -} -FireEventRequest& FireEventRequest::operator=(const FireEventRequest& other658) { - successful = other658.successful; - data = other658.data; - dbName = other658.dbName; - tableName = other658.tableName; - partitionVals = other658.partitionVals; - __isset = other658.__isset; +FireEventRequest::FireEventRequest(const FireEventRequest& other665) { + successful = other665.successful; + data = other665.data; + dbName = other665.dbName; + tableName = other665.tableName; + partitionVals = other665.partitionVals; + __isset = other665.__isset; +} +FireEventRequest& FireEventRequest::operator=(const FireEventRequest& other666) { + successful = other666.successful; + data = other666.data; + dbName = other666.dbName; + tableName = other666.tableName; + partitionVals = other666.partitionVals; + __isset = other666.__isset; return *this; } void FireEventRequest::printTo(std::ostream& out) const { @@ -16217,11 +16263,11 @@ void swap(FireEventResponse &a, FireEventResponse &b) { (void) b; } -FireEventResponse::FireEventResponse(const FireEventResponse& other659) { - (void) other659; +FireEventResponse::FireEventResponse(const FireEventResponse& other667) { + (void) other667; } -FireEventResponse& FireEventResponse::operator=(const FireEventResponse& other660) { - (void) other660; +FireEventResponse& FireEventResponse::operator=(const FireEventResponse& other668) { + (void) other668; return *this; } void FireEventResponse::printTo(std::ostream& out) const { @@ -16321,15 +16367,15 @@ void swap(MetadataPpdResult &a, MetadataPpdResult &b) { swap(a.__isset, b.__isset); } -MetadataPpdResult::MetadataPpdResult(const MetadataPpdResult& other661) { - metadata = other661.metadata; - includeBitset = other661.includeBitset; - __isset = other661.__isset; +MetadataPpdResult::MetadataPpdResult(const MetadataPpdResult& other669) { + metadata = other669.metadata; + includeBitset = other669.includeBitset; + __isset = other669.__isset; } -MetadataPpdResult& MetadataPpdResult::operator=(const MetadataPpdResult& other662) { - metadata = other662.metadata; - includeBitset = other662.includeBitset; - __isset = other662.__isset; +MetadataPpdResult& MetadataPpdResult::operator=(const MetadataPpdResult& other670) { + metadata = other670.metadata; + includeBitset = other670.includeBitset; + __isset = other670.__isset; return *this; } void MetadataPpdResult::printTo(std::ostream& out) const { @@ -16380,17 +16426,17 @@ uint32_t GetFileMetadataByExprResult::read(::apache::thrift::protocol::TProtocol if (ftype == ::apache::thrift::protocol::T_MAP) { { this->metadata.clear(); - uint32_t _size663; - ::apache::thrift::protocol::TType _ktype664; - ::apache::thrift::protocol::TType _vtype665; - xfer += iprot->readMapBegin(_ktype664, _vtype665, _size663); - uint32_t _i667; - for (_i667 = 0; _i667 < _size663; ++_i667) + uint32_t _size671; + ::apache::thrift::protocol::TType _ktype672; + ::apache::thrift::protocol::TType _vtype673; + xfer += iprot->readMapBegin(_ktype672, _vtype673, _size671); + uint32_t _i675; + for (_i675 = 0; _i675 < _size671; ++_i675) { - int64_t _key668; - xfer += iprot->readI64(_key668); - MetadataPpdResult& _val669 = this->metadata[_key668]; - xfer += _val669.read(iprot); + int64_t _key676; + xfer += iprot->readI64(_key676); + MetadataPpdResult& _val677 = this->metadata[_key676]; + xfer += _val677.read(iprot); } xfer += iprot->readMapEnd(); } @@ -16431,11 +16477,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(this->metadata.size())); - std::map ::const_iterator _iter670; - for (_iter670 = this->metadata.begin(); _iter670 != this->metadata.end(); ++_iter670) + std::map ::const_iterator _iter678; + for (_iter678 = this->metadata.begin(); _iter678 != this->metadata.end(); ++_iter678) { - xfer += oprot->writeI64(_iter670->first); - xfer += _iter670->second.write(oprot); + xfer += oprot->writeI64(_iter678->first); + xfer += _iter678->second.write(oprot); } xfer += oprot->writeMapEnd(); } @@ -16456,13 +16502,13 @@ void swap(GetFileMetadataByExprResult &a, GetFileMetadataByExprResult &b) { swap(a.isSupported, b.isSupported); } -GetFileMetadataByExprResult::GetFileMetadataByExprResult(const GetFileMetadataByExprResult& other671) { - metadata = other671.metadata; - isSupported = other671.isSupported; +GetFileMetadataByExprResult::GetFileMetadataByExprResult(const GetFileMetadataByExprResult& other679) { + metadata = other679.metadata; + isSupported = other679.isSupported; } -GetFileMetadataByExprResult& GetFileMetadataByExprResult::operator=(const GetFileMetadataByExprResult& other672) { - metadata = other672.metadata; - isSupported = other672.isSupported; +GetFileMetadataByExprResult& GetFileMetadataByExprResult::operator=(const GetFileMetadataByExprResult& other680) { + metadata = other680.metadata; + isSupported = other680.isSupported; return *this; } void GetFileMetadataByExprResult::printTo(std::ostream& out) const { @@ -16523,14 +16569,14 @@ uint32_t GetFileMetadataByExprRequest::read(::apache::thrift::protocol::TProtoco if (ftype == ::apache::thrift::protocol::T_LIST) { { this->fileIds.clear(); - uint32_t _size673; - ::apache::thrift::protocol::TType _etype676; - xfer += iprot->readListBegin(_etype676, _size673); - this->fileIds.resize(_size673); - uint32_t _i677; - for (_i677 = 0; _i677 < _size673; ++_i677) + uint32_t _size681; + ::apache::thrift::protocol::TType _etype684; + xfer += iprot->readListBegin(_etype684, _size681); + this->fileIds.resize(_size681); + uint32_t _i685; + for (_i685 = 0; _i685 < _size681; ++_i685) { - xfer += iprot->readI64(this->fileIds[_i677]); + xfer += iprot->readI64(this->fileIds[_i685]); } xfer += iprot->readListEnd(); } @@ -16557,9 +16603,9 @@ uint32_t GetFileMetadataByExprRequest::read(::apache::thrift::protocol::TProtoco break; case 4: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast678; - xfer += iprot->readI32(ecast678); - this->type = (FileMetadataExprType::type)ecast678; + int32_t ecast686; + xfer += iprot->readI32(ecast686); + this->type = (FileMetadataExprType::type)ecast686; this->__isset.type = true; } else { xfer += iprot->skip(ftype); @@ -16589,10 +16635,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(this->fileIds.size())); - std::vector ::const_iterator _iter679; - for (_iter679 = this->fileIds.begin(); _iter679 != this->fileIds.end(); ++_iter679) + std::vector ::const_iterator _iter687; + for (_iter687 = this->fileIds.begin(); _iter687 != this->fileIds.end(); ++_iter687) { - xfer += oprot->writeI64((*_iter679)); + xfer += oprot->writeI64((*_iter687)); } xfer += oprot->writeListEnd(); } @@ -16626,19 +16672,19 @@ void swap(GetFileMetadataByExprRequest &a, GetFileMetadataByExprRequest &b) { swap(a.__isset, b.__isset); } -GetFileMetadataByExprRequest::GetFileMetadataByExprRequest(const GetFileMetadataByExprRequest& other680) { - fileIds = other680.fileIds; - expr = other680.expr; - doGetFooters = other680.doGetFooters; - type = other680.type; - __isset = other680.__isset; +GetFileMetadataByExprRequest::GetFileMetadataByExprRequest(const GetFileMetadataByExprRequest& other688) { + fileIds = other688.fileIds; + expr = other688.expr; + doGetFooters = other688.doGetFooters; + type = other688.type; + __isset = other688.__isset; } -GetFileMetadataByExprRequest& GetFileMetadataByExprRequest::operator=(const GetFileMetadataByExprRequest& other681) { - fileIds = other681.fileIds; - expr = other681.expr; - doGetFooters = other681.doGetFooters; - type = other681.type; - __isset = other681.__isset; +GetFileMetadataByExprRequest& GetFileMetadataByExprRequest::operator=(const GetFileMetadataByExprRequest& other689) { + fileIds = other689.fileIds; + expr = other689.expr; + doGetFooters = other689.doGetFooters; + type = other689.type; + __isset = other689.__isset; return *this; } void GetFileMetadataByExprRequest::printTo(std::ostream& out) const { @@ -16691,17 +16737,17 @@ uint32_t GetFileMetadataResult::read(::apache::thrift::protocol::TProtocol* ipro if (ftype == ::apache::thrift::protocol::T_MAP) { { this->metadata.clear(); - uint32_t _size682; - ::apache::thrift::protocol::TType _ktype683; - ::apache::thrift::protocol::TType _vtype684; - xfer += iprot->readMapBegin(_ktype683, _vtype684, _size682); - uint32_t _i686; - for (_i686 = 0; _i686 < _size682; ++_i686) + uint32_t _size690; + ::apache::thrift::protocol::TType _ktype691; + ::apache::thrift::protocol::TType _vtype692; + xfer += iprot->readMapBegin(_ktype691, _vtype692, _size690); + uint32_t _i694; + for (_i694 = 0; _i694 < _size690; ++_i694) { - int64_t _key687; - xfer += iprot->readI64(_key687); - std::string& _val688 = this->metadata[_key687]; - xfer += iprot->readBinary(_val688); + int64_t _key695; + xfer += iprot->readI64(_key695); + std::string& _val696 = this->metadata[_key695]; + xfer += iprot->readBinary(_val696); } xfer += iprot->readMapEnd(); } @@ -16742,11 +16788,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(this->metadata.size())); - std::map ::const_iterator _iter689; - for (_iter689 = this->metadata.begin(); _iter689 != this->metadata.end(); ++_iter689) + std::map ::const_iterator _iter697; + for (_iter697 = this->metadata.begin(); _iter697 != this->metadata.end(); ++_iter697) { - xfer += oprot->writeI64(_iter689->first); - xfer += oprot->writeBinary(_iter689->second); + xfer += oprot->writeI64(_iter697->first); + xfer += oprot->writeBinary(_iter697->second); } xfer += oprot->writeMapEnd(); } @@ -16767,13 +16813,13 @@ void swap(GetFileMetadataResult &a, GetFileMetadataResult &b) { swap(a.isSupported, b.isSupported); } -GetFileMetadataResult::GetFileMetadataResult(const GetFileMetadataResult& other690) { - metadata = other690.metadata; - isSupported = other690.isSupported; +GetFileMetadataResult::GetFileMetadataResult(const GetFileMetadataResult& other698) { + metadata = other698.metadata; + isSupported = other698.isSupported; } -GetFileMetadataResult& GetFileMetadataResult::operator=(const GetFileMetadataResult& other691) { - metadata = other691.metadata; - isSupported = other691.isSupported; +GetFileMetadataResult& GetFileMetadataResult::operator=(const GetFileMetadataResult& other699) { + metadata = other699.metadata; + isSupported = other699.isSupported; return *this; } void GetFileMetadataResult::printTo(std::ostream& out) const { @@ -16819,14 +16865,14 @@ uint32_t GetFileMetadataRequest::read(::apache::thrift::protocol::TProtocol* ipr if (ftype == ::apache::thrift::protocol::T_LIST) { { this->fileIds.clear(); - uint32_t _size692; - ::apache::thrift::protocol::TType _etype695; - xfer += iprot->readListBegin(_etype695, _size692); - this->fileIds.resize(_size692); - uint32_t _i696; - for (_i696 = 0; _i696 < _size692; ++_i696) + uint32_t _size700; + ::apache::thrift::protocol::TType _etype703; + xfer += iprot->readListBegin(_etype703, _size700); + this->fileIds.resize(_size700); + uint32_t _i704; + for (_i704 = 0; _i704 < _size700; ++_i704) { - xfer += iprot->readI64(this->fileIds[_i696]); + xfer += iprot->readI64(this->fileIds[_i704]); } xfer += iprot->readListEnd(); } @@ -16857,10 +16903,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(this->fileIds.size())); - std::vector ::const_iterator _iter697; - for (_iter697 = this->fileIds.begin(); _iter697 != this->fileIds.end(); ++_iter697) + std::vector ::const_iterator _iter705; + for (_iter705 = this->fileIds.begin(); _iter705 != this->fileIds.end(); ++_iter705) { - xfer += oprot->writeI64((*_iter697)); + xfer += oprot->writeI64((*_iter705)); } xfer += oprot->writeListEnd(); } @@ -16876,11 +16922,11 @@ void swap(GetFileMetadataRequest &a, GetFileMetadataRequest &b) { swap(a.fileIds, b.fileIds); } -GetFileMetadataRequest::GetFileMetadataRequest(const GetFileMetadataRequest& other698) { - fileIds = other698.fileIds; +GetFileMetadataRequest::GetFileMetadataRequest(const GetFileMetadataRequest& other706) { + fileIds = other706.fileIds; } -GetFileMetadataRequest& GetFileMetadataRequest::operator=(const GetFileMetadataRequest& other699) { - fileIds = other699.fileIds; +GetFileMetadataRequest& GetFileMetadataRequest::operator=(const GetFileMetadataRequest& other707) { + fileIds = other707.fileIds; return *this; } void GetFileMetadataRequest::printTo(std::ostream& out) const { @@ -16939,11 +16985,11 @@ void swap(PutFileMetadataResult &a, PutFileMetadataResult &b) { (void) b; } -PutFileMetadataResult::PutFileMetadataResult(const PutFileMetadataResult& other700) { - (void) other700; +PutFileMetadataResult::PutFileMetadataResult(const PutFileMetadataResult& other708) { + (void) other708; } -PutFileMetadataResult& PutFileMetadataResult::operator=(const PutFileMetadataResult& other701) { - (void) other701; +PutFileMetadataResult& PutFileMetadataResult::operator=(const PutFileMetadataResult& other709) { + (void) other709; return *this; } void PutFileMetadataResult::printTo(std::ostream& out) const { @@ -16997,14 +17043,14 @@ uint32_t PutFileMetadataRequest::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 _size710; + ::apache::thrift::protocol::TType _etype713; + xfer += iprot->readListBegin(_etype713, _size710); + this->fileIds.resize(_size710); + uint32_t _i714; + for (_i714 = 0; _i714 < _size710; ++_i714) { - xfer += iprot->readI64(this->fileIds[_i706]); + xfer += iprot->readI64(this->fileIds[_i714]); } xfer += iprot->readListEnd(); } @@ -17017,14 +17063,14 @@ uint32_t PutFileMetadataRequest::read(::apache::thrift::protocol::TProtocol* ipr if (ftype == ::apache::thrift::protocol::T_LIST) { { this->metadata.clear(); - uint32_t _size707; - ::apache::thrift::protocol::TType _etype710; - xfer += iprot->readListBegin(_etype710, _size707); - this->metadata.resize(_size707); - uint32_t _i711; - for (_i711 = 0; _i711 < _size707; ++_i711) + uint32_t _size715; + ::apache::thrift::protocol::TType _etype718; + xfer += iprot->readListBegin(_etype718, _size715); + this->metadata.resize(_size715); + uint32_t _i719; + for (_i719 = 0; _i719 < _size715; ++_i719) { - xfer += iprot->readBinary(this->metadata[_i711]); + xfer += iprot->readBinary(this->metadata[_i719]); } xfer += iprot->readListEnd(); } @@ -17035,9 +17081,9 @@ uint32_t PutFileMetadataRequest::read(::apache::thrift::protocol::TProtocol* ipr break; case 3: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast712; - xfer += iprot->readI32(ecast712); - this->type = (FileMetadataExprType::type)ecast712; + int32_t ecast720; + xfer += iprot->readI32(ecast720); + this->type = (FileMetadataExprType::type)ecast720; this->__isset.type = true; } else { xfer += iprot->skip(ftype); @@ -17067,10 +17113,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(this->fileIds.size())); - std::vector ::const_iterator _iter713; - for (_iter713 = this->fileIds.begin(); _iter713 != this->fileIds.end(); ++_iter713) + std::vector ::const_iterator _iter721; + for (_iter721 = this->fileIds.begin(); _iter721 != this->fileIds.end(); ++_iter721) { - xfer += oprot->writeI64((*_iter713)); + xfer += oprot->writeI64((*_iter721)); } xfer += oprot->writeListEnd(); } @@ -17079,10 +17125,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(this->metadata.size())); - std::vector ::const_iterator _iter714; - for (_iter714 = this->metadata.begin(); _iter714 != this->metadata.end(); ++_iter714) + std::vector ::const_iterator _iter722; + for (_iter722 = this->metadata.begin(); _iter722 != this->metadata.end(); ++_iter722) { - xfer += oprot->writeBinary((*_iter714)); + xfer += oprot->writeBinary((*_iter722)); } xfer += oprot->writeListEnd(); } @@ -17106,17 +17152,17 @@ void swap(PutFileMetadataRequest &a, PutFileMetadataRequest &b) { swap(a.__isset, b.__isset); } -PutFileMetadataRequest::PutFileMetadataRequest(const PutFileMetadataRequest& other715) { - fileIds = other715.fileIds; - metadata = other715.metadata; - type = other715.type; - __isset = other715.__isset; +PutFileMetadataRequest::PutFileMetadataRequest(const PutFileMetadataRequest& other723) { + fileIds = other723.fileIds; + metadata = other723.metadata; + type = other723.type; + __isset = other723.__isset; } -PutFileMetadataRequest& PutFileMetadataRequest::operator=(const PutFileMetadataRequest& other716) { - fileIds = other716.fileIds; - metadata = other716.metadata; - type = other716.type; - __isset = other716.__isset; +PutFileMetadataRequest& PutFileMetadataRequest::operator=(const PutFileMetadataRequest& other724) { + fileIds = other724.fileIds; + metadata = other724.metadata; + type = other724.type; + __isset = other724.__isset; return *this; } void PutFileMetadataRequest::printTo(std::ostream& out) const { @@ -17177,11 +17223,11 @@ void swap(ClearFileMetadataResult &a, ClearFileMetadataResult &b) { (void) b; } -ClearFileMetadataResult::ClearFileMetadataResult(const ClearFileMetadataResult& other717) { - (void) other717; +ClearFileMetadataResult::ClearFileMetadataResult(const ClearFileMetadataResult& other725) { + (void) other725; } -ClearFileMetadataResult& ClearFileMetadataResult::operator=(const ClearFileMetadataResult& other718) { - (void) other718; +ClearFileMetadataResult& ClearFileMetadataResult::operator=(const ClearFileMetadataResult& other726) { + (void) other726; return *this; } void ClearFileMetadataResult::printTo(std::ostream& out) const { @@ -17225,14 +17271,14 @@ uint32_t ClearFileMetadataRequest::read(::apache::thrift::protocol::TProtocol* i if (ftype == ::apache::thrift::protocol::T_LIST) { { this->fileIds.clear(); - uint32_t _size719; - ::apache::thrift::protocol::TType _etype722; - xfer += iprot->readListBegin(_etype722, _size719); - this->fileIds.resize(_size719); - uint32_t _i723; - for (_i723 = 0; _i723 < _size719; ++_i723) + uint32_t _size727; + ::apache::thrift::protocol::TType _etype730; + xfer += iprot->readListBegin(_etype730, _size727); + this->fileIds.resize(_size727); + uint32_t _i731; + for (_i731 = 0; _i731 < _size727; ++_i731) { - xfer += iprot->readI64(this->fileIds[_i723]); + xfer += iprot->readI64(this->fileIds[_i731]); } xfer += iprot->readListEnd(); } @@ -17263,10 +17309,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(this->fileIds.size())); - std::vector ::const_iterator _iter724; - for (_iter724 = this->fileIds.begin(); _iter724 != this->fileIds.end(); ++_iter724) + std::vector ::const_iterator _iter732; + for (_iter732 = this->fileIds.begin(); _iter732 != this->fileIds.end(); ++_iter732) { - xfer += oprot->writeI64((*_iter724)); + xfer += oprot->writeI64((*_iter732)); } xfer += oprot->writeListEnd(); } @@ -17282,11 +17328,11 @@ void swap(ClearFileMetadataRequest &a, ClearFileMetadataRequest &b) { swap(a.fileIds, b.fileIds); } -ClearFileMetadataRequest::ClearFileMetadataRequest(const ClearFileMetadataRequest& other725) { - fileIds = other725.fileIds; +ClearFileMetadataRequest::ClearFileMetadataRequest(const ClearFileMetadataRequest& other733) { + fileIds = other733.fileIds; } -ClearFileMetadataRequest& ClearFileMetadataRequest::operator=(const ClearFileMetadataRequest& other726) { - fileIds = other726.fileIds; +ClearFileMetadataRequest& ClearFileMetadataRequest::operator=(const ClearFileMetadataRequest& other734) { + fileIds = other734.fileIds; return *this; } void ClearFileMetadataRequest::printTo(std::ostream& out) const { @@ -17368,11 +17414,11 @@ void swap(CacheFileMetadataResult &a, CacheFileMetadataResult &b) { swap(a.isSupported, b.isSupported); } -CacheFileMetadataResult::CacheFileMetadataResult(const CacheFileMetadataResult& other727) { - isSupported = other727.isSupported; +CacheFileMetadataResult::CacheFileMetadataResult(const CacheFileMetadataResult& other735) { + isSupported = other735.isSupported; } -CacheFileMetadataResult& CacheFileMetadataResult::operator=(const CacheFileMetadataResult& other728) { - isSupported = other728.isSupported; +CacheFileMetadataResult& CacheFileMetadataResult::operator=(const CacheFileMetadataResult& other736) { + isSupported = other736.isSupported; return *this; } void CacheFileMetadataResult::printTo(std::ostream& out) const { @@ -17513,19 +17559,19 @@ void swap(CacheFileMetadataRequest &a, CacheFileMetadataRequest &b) { swap(a.__isset, b.__isset); } -CacheFileMetadataRequest::CacheFileMetadataRequest(const CacheFileMetadataRequest& other729) { - dbName = other729.dbName; - tblName = other729.tblName; - partName = other729.partName; - isAllParts = other729.isAllParts; - __isset = other729.__isset; +CacheFileMetadataRequest::CacheFileMetadataRequest(const CacheFileMetadataRequest& other737) { + dbName = other737.dbName; + tblName = other737.tblName; + partName = other737.partName; + isAllParts = other737.isAllParts; + __isset = other737.__isset; } -CacheFileMetadataRequest& CacheFileMetadataRequest::operator=(const CacheFileMetadataRequest& other730) { - dbName = other730.dbName; - tblName = other730.tblName; - partName = other730.partName; - isAllParts = other730.isAllParts; - __isset = other730.__isset; +CacheFileMetadataRequest& CacheFileMetadataRequest::operator=(const CacheFileMetadataRequest& other738) { + dbName = other738.dbName; + tblName = other738.tblName; + partName = other738.partName; + isAllParts = other738.isAllParts; + __isset = other738.__isset; return *this; } void CacheFileMetadataRequest::printTo(std::ostream& out) const { @@ -17573,14 +17619,14 @@ uint32_t GetAllFunctionsResponse::read(::apache::thrift::protocol::TProtocol* ip if (ftype == ::apache::thrift::protocol::T_LIST) { { this->functions.clear(); - uint32_t _size731; - ::apache::thrift::protocol::TType _etype734; - xfer += iprot->readListBegin(_etype734, _size731); - this->functions.resize(_size731); - uint32_t _i735; - for (_i735 = 0; _i735 < _size731; ++_i735) + uint32_t _size739; + ::apache::thrift::protocol::TType _etype742; + xfer += iprot->readListBegin(_etype742, _size739); + this->functions.resize(_size739); + uint32_t _i743; + for (_i743 = 0; _i743 < _size739; ++_i743) { - xfer += this->functions[_i735].read(iprot); + xfer += this->functions[_i743].read(iprot); } xfer += iprot->readListEnd(); } @@ -17610,10 +17656,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(this->functions.size())); - std::vector ::const_iterator _iter736; - for (_iter736 = this->functions.begin(); _iter736 != this->functions.end(); ++_iter736) + std::vector ::const_iterator _iter744; + for (_iter744 = this->functions.begin(); _iter744 != this->functions.end(); ++_iter744) { - xfer += (*_iter736).write(oprot); + xfer += (*_iter744).write(oprot); } xfer += oprot->writeListEnd(); } @@ -17630,13 +17676,13 @@ void swap(GetAllFunctionsResponse &a, GetAllFunctionsResponse &b) { swap(a.__isset, b.__isset); } -GetAllFunctionsResponse::GetAllFunctionsResponse(const GetAllFunctionsResponse& other737) { - functions = other737.functions; - __isset = other737.__isset; +GetAllFunctionsResponse::GetAllFunctionsResponse(const GetAllFunctionsResponse& other745) { + functions = other745.functions; + __isset = other745.__isset; } -GetAllFunctionsResponse& GetAllFunctionsResponse::operator=(const GetAllFunctionsResponse& other738) { - functions = other738.functions; - __isset = other738.__isset; +GetAllFunctionsResponse& GetAllFunctionsResponse::operator=(const GetAllFunctionsResponse& other746) { + functions = other746.functions; + __isset = other746.__isset; return *this; } void GetAllFunctionsResponse::printTo(std::ostream& out) const { @@ -17778,19 +17824,19 @@ void swap(TableMeta &a, TableMeta &b) { swap(a.__isset, b.__isset); } -TableMeta::TableMeta(const TableMeta& other739) { - dbName = other739.dbName; - tableName = other739.tableName; - tableType = other739.tableType; - comments = other739.comments; - __isset = other739.__isset; +TableMeta::TableMeta(const TableMeta& other747) { + dbName = other747.dbName; + tableName = other747.tableName; + tableType = other747.tableType; + comments = other747.comments; + __isset = other747.__isset; } -TableMeta& TableMeta::operator=(const TableMeta& other740) { - dbName = other740.dbName; - tableName = other740.tableName; - tableType = other740.tableType; - comments = other740.comments; - __isset = other740.__isset; +TableMeta& TableMeta::operator=(const TableMeta& other748) { + dbName = other748.dbName; + tableName = other748.tableName; + tableType = other748.tableType; + comments = other748.comments; + __isset = other748.__isset; return *this; } void TableMeta::printTo(std::ostream& out) const { @@ -17873,13 +17919,13 @@ void swap(MetaException &a, MetaException &b) { swap(a.__isset, b.__isset); } -MetaException::MetaException(const MetaException& other741) : TException() { - message = other741.message; - __isset = other741.__isset; +MetaException::MetaException(const MetaException& other749) : TException() { + message = other749.message; + __isset = other749.__isset; } -MetaException& MetaException::operator=(const MetaException& other742) { - message = other742.message; - __isset = other742.__isset; +MetaException& MetaException::operator=(const MetaException& other750) { + message = other750.message; + __isset = other750.__isset; return *this; } void MetaException::printTo(std::ostream& out) const { @@ -17970,13 +18016,13 @@ void swap(UnknownTableException &a, UnknownTableException &b) { swap(a.__isset, b.__isset); } -UnknownTableException::UnknownTableException(const UnknownTableException& other743) : TException() { - message = other743.message; - __isset = other743.__isset; +UnknownTableException::UnknownTableException(const UnknownTableException& other751) : TException() { + message = other751.message; + __isset = other751.__isset; } -UnknownTableException& UnknownTableException::operator=(const UnknownTableException& other744) { - message = other744.message; - __isset = other744.__isset; +UnknownTableException& UnknownTableException::operator=(const UnknownTableException& other752) { + message = other752.message; + __isset = other752.__isset; return *this; } void UnknownTableException::printTo(std::ostream& out) const { @@ -18067,13 +18113,13 @@ void swap(UnknownDBException &a, UnknownDBException &b) { swap(a.__isset, b.__isset); } -UnknownDBException::UnknownDBException(const UnknownDBException& other745) : TException() { - message = other745.message; - __isset = other745.__isset; +UnknownDBException::UnknownDBException(const UnknownDBException& other753) : TException() { + message = other753.message; + __isset = other753.__isset; } -UnknownDBException& UnknownDBException::operator=(const UnknownDBException& other746) { - message = other746.message; - __isset = other746.__isset; +UnknownDBException& UnknownDBException::operator=(const UnknownDBException& other754) { + message = other754.message; + __isset = other754.__isset; return *this; } void UnknownDBException::printTo(std::ostream& out) const { @@ -18164,13 +18210,13 @@ void swap(AlreadyExistsException &a, AlreadyExistsException &b) { swap(a.__isset, b.__isset); } -AlreadyExistsException::AlreadyExistsException(const AlreadyExistsException& other747) : TException() { - message = other747.message; - __isset = other747.__isset; +AlreadyExistsException::AlreadyExistsException(const AlreadyExistsException& other755) : TException() { + message = other755.message; + __isset = other755.__isset; } -AlreadyExistsException& AlreadyExistsException::operator=(const AlreadyExistsException& other748) { - message = other748.message; - __isset = other748.__isset; +AlreadyExistsException& AlreadyExistsException::operator=(const AlreadyExistsException& other756) { + message = other756.message; + __isset = other756.__isset; return *this; } void AlreadyExistsException::printTo(std::ostream& out) const { @@ -18261,13 +18307,13 @@ void swap(InvalidPartitionException &a, InvalidPartitionException &b) { swap(a.__isset, b.__isset); } -InvalidPartitionException::InvalidPartitionException(const InvalidPartitionException& other749) : TException() { - message = other749.message; - __isset = other749.__isset; +InvalidPartitionException::InvalidPartitionException(const InvalidPartitionException& other757) : TException() { + message = other757.message; + __isset = other757.__isset; } -InvalidPartitionException& InvalidPartitionException::operator=(const InvalidPartitionException& other750) { - message = other750.message; - __isset = other750.__isset; +InvalidPartitionException& InvalidPartitionException::operator=(const InvalidPartitionException& other758) { + message = other758.message; + __isset = other758.__isset; return *this; } void InvalidPartitionException::printTo(std::ostream& out) const { @@ -18358,13 +18404,13 @@ void swap(UnknownPartitionException &a, UnknownPartitionException &b) { swap(a.__isset, b.__isset); } -UnknownPartitionException::UnknownPartitionException(const UnknownPartitionException& other751) : TException() { - message = other751.message; - __isset = other751.__isset; +UnknownPartitionException::UnknownPartitionException(const UnknownPartitionException& other759) : TException() { + message = other759.message; + __isset = other759.__isset; } -UnknownPartitionException& UnknownPartitionException::operator=(const UnknownPartitionException& other752) { - message = other752.message; - __isset = other752.__isset; +UnknownPartitionException& UnknownPartitionException::operator=(const UnknownPartitionException& other760) { + message = other760.message; + __isset = other760.__isset; return *this; } void UnknownPartitionException::printTo(std::ostream& out) const { @@ -18455,13 +18501,13 @@ void swap(InvalidObjectException &a, InvalidObjectException &b) { swap(a.__isset, b.__isset); } -InvalidObjectException::InvalidObjectException(const InvalidObjectException& other753) : TException() { - message = other753.message; - __isset = other753.__isset; +InvalidObjectException::InvalidObjectException(const InvalidObjectException& other761) : TException() { + message = other761.message; + __isset = other761.__isset; } -InvalidObjectException& InvalidObjectException::operator=(const InvalidObjectException& other754) { - message = other754.message; - __isset = other754.__isset; +InvalidObjectException& InvalidObjectException::operator=(const InvalidObjectException& other762) { + message = other762.message; + __isset = other762.__isset; return *this; } void InvalidObjectException::printTo(std::ostream& out) const { @@ -18552,13 +18598,13 @@ void swap(NoSuchObjectException &a, NoSuchObjectException &b) { swap(a.__isset, b.__isset); } -NoSuchObjectException::NoSuchObjectException(const NoSuchObjectException& other755) : TException() { - message = other755.message; - __isset = other755.__isset; +NoSuchObjectException::NoSuchObjectException(const NoSuchObjectException& other763) : TException() { + message = other763.message; + __isset = other763.__isset; } -NoSuchObjectException& NoSuchObjectException::operator=(const NoSuchObjectException& other756) { - message = other756.message; - __isset = other756.__isset; +NoSuchObjectException& NoSuchObjectException::operator=(const NoSuchObjectException& other764) { + message = other764.message; + __isset = other764.__isset; return *this; } void NoSuchObjectException::printTo(std::ostream& out) const { @@ -18649,13 +18695,13 @@ void swap(IndexAlreadyExistsException &a, IndexAlreadyExistsException &b) { swap(a.__isset, b.__isset); } -IndexAlreadyExistsException::IndexAlreadyExistsException(const IndexAlreadyExistsException& other757) : TException() { - message = other757.message; - __isset = other757.__isset; +IndexAlreadyExistsException::IndexAlreadyExistsException(const IndexAlreadyExistsException& other765) : TException() { + message = other765.message; + __isset = other765.__isset; } -IndexAlreadyExistsException& IndexAlreadyExistsException::operator=(const IndexAlreadyExistsException& other758) { - message = other758.message; - __isset = other758.__isset; +IndexAlreadyExistsException& IndexAlreadyExistsException::operator=(const IndexAlreadyExistsException& other766) { + message = other766.message; + __isset = other766.__isset; return *this; } void IndexAlreadyExistsException::printTo(std::ostream& out) const { @@ -18746,13 +18792,13 @@ void swap(InvalidOperationException &a, InvalidOperationException &b) { swap(a.__isset, b.__isset); } -InvalidOperationException::InvalidOperationException(const InvalidOperationException& other759) : TException() { - message = other759.message; - __isset = other759.__isset; +InvalidOperationException::InvalidOperationException(const InvalidOperationException& other767) : TException() { + message = other767.message; + __isset = other767.__isset; } -InvalidOperationException& InvalidOperationException::operator=(const InvalidOperationException& other760) { - message = other760.message; - __isset = other760.__isset; +InvalidOperationException& InvalidOperationException::operator=(const InvalidOperationException& other768) { + message = other768.message; + __isset = other768.__isset; return *this; } void InvalidOperationException::printTo(std::ostream& out) const { @@ -18843,13 +18889,13 @@ void swap(ConfigValSecurityException &a, ConfigValSecurityException &b) { swap(a.__isset, b.__isset); } -ConfigValSecurityException::ConfigValSecurityException(const ConfigValSecurityException& other761) : TException() { - message = other761.message; - __isset = other761.__isset; +ConfigValSecurityException::ConfigValSecurityException(const ConfigValSecurityException& other769) : TException() { + message = other769.message; + __isset = other769.__isset; } -ConfigValSecurityException& ConfigValSecurityException::operator=(const ConfigValSecurityException& other762) { - message = other762.message; - __isset = other762.__isset; +ConfigValSecurityException& ConfigValSecurityException::operator=(const ConfigValSecurityException& other770) { + message = other770.message; + __isset = other770.__isset; return *this; } void ConfigValSecurityException::printTo(std::ostream& out) const { @@ -18940,13 +18986,13 @@ void swap(InvalidInputException &a, InvalidInputException &b) { swap(a.__isset, b.__isset); } -InvalidInputException::InvalidInputException(const InvalidInputException& other763) : TException() { - message = other763.message; - __isset = other763.__isset; +InvalidInputException::InvalidInputException(const InvalidInputException& other771) : TException() { + message = other771.message; + __isset = other771.__isset; } -InvalidInputException& InvalidInputException::operator=(const InvalidInputException& other764) { - message = other764.message; - __isset = other764.__isset; +InvalidInputException& InvalidInputException::operator=(const InvalidInputException& other772) { + message = other772.message; + __isset = other772.__isset; return *this; } void InvalidInputException::printTo(std::ostream& out) const { @@ -19037,13 +19083,13 @@ void swap(NoSuchTxnException &a, NoSuchTxnException &b) { swap(a.__isset, b.__isset); } -NoSuchTxnException::NoSuchTxnException(const NoSuchTxnException& other765) : TException() { - message = other765.message; - __isset = other765.__isset; +NoSuchTxnException::NoSuchTxnException(const NoSuchTxnException& other773) : TException() { + message = other773.message; + __isset = other773.__isset; } -NoSuchTxnException& NoSuchTxnException::operator=(const NoSuchTxnException& other766) { - message = other766.message; - __isset = other766.__isset; +NoSuchTxnException& NoSuchTxnException::operator=(const NoSuchTxnException& other774) { + message = other774.message; + __isset = other774.__isset; return *this; } void NoSuchTxnException::printTo(std::ostream& out) const { @@ -19134,13 +19180,13 @@ void swap(TxnAbortedException &a, TxnAbortedException &b) { swap(a.__isset, b.__isset); } -TxnAbortedException::TxnAbortedException(const TxnAbortedException& other767) : TException() { - message = other767.message; - __isset = other767.__isset; +TxnAbortedException::TxnAbortedException(const TxnAbortedException& other775) : TException() { + message = other775.message; + __isset = other775.__isset; } -TxnAbortedException& TxnAbortedException::operator=(const TxnAbortedException& other768) { - message = other768.message; - __isset = other768.__isset; +TxnAbortedException& TxnAbortedException::operator=(const TxnAbortedException& other776) { + message = other776.message; + __isset = other776.__isset; return *this; } void TxnAbortedException::printTo(std::ostream& out) const { @@ -19231,13 +19277,13 @@ void swap(TxnOpenException &a, TxnOpenException &b) { swap(a.__isset, b.__isset); } -TxnOpenException::TxnOpenException(const TxnOpenException& other769) : TException() { - message = other769.message; - __isset = other769.__isset; +TxnOpenException::TxnOpenException(const TxnOpenException& other777) : TException() { + message = other777.message; + __isset = other777.__isset; } -TxnOpenException& TxnOpenException::operator=(const TxnOpenException& other770) { - message = other770.message; - __isset = other770.__isset; +TxnOpenException& TxnOpenException::operator=(const TxnOpenException& other778) { + message = other778.message; + __isset = other778.__isset; return *this; } void TxnOpenException::printTo(std::ostream& out) const { @@ -19328,13 +19374,13 @@ void swap(NoSuchLockException &a, NoSuchLockException &b) { swap(a.__isset, b.__isset); } -NoSuchLockException::NoSuchLockException(const NoSuchLockException& other771) : TException() { - message = other771.message; - __isset = other771.__isset; +NoSuchLockException::NoSuchLockException(const NoSuchLockException& other779) : TException() { + message = other779.message; + __isset = other779.__isset; } -NoSuchLockException& NoSuchLockException::operator=(const NoSuchLockException& other772) { - message = other772.message; - __isset = other772.__isset; +NoSuchLockException& NoSuchLockException::operator=(const NoSuchLockException& other780) { + message = other780.message; + __isset = other780.__isset; return *this; } void NoSuchLockException::printTo(std::ostream& out) const { http://git-wip-us.apache.org/repos/asf/hive/blob/e276929d/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 00f017b..ec81798 100644 --- a/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h +++ b/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h @@ -5867,9 +5867,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 { @@ -5886,6 +5887,7 @@ class CompactionRequest { std::string partitionname; CompactionType::type type; std::string runas; + std::map properties; _CompactionRequest__isset __isset; @@ -5899,6 +5901,8 @@ class CompactionRequest { void __set_runas(const std::string& val); + void __set_properties(const std::map & val); + bool operator == (const CompactionRequest & rhs) const { if (!(dbname == rhs.dbname)) @@ -5915,6 +5919,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/e276929d/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 734a6df..ba06a56 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(_list532.size); - String _elem533; - for (int _i534 = 0; _i534 < _list532.size; ++_i534) + org.apache.thrift.protocol.TList _list542 = iprot.readListBegin(); + struct.partitionnames = new ArrayList(_list542.size); + String _elem543; + for (int _i544 = 0; _i544 < _list542.size; ++_i544) { - _elem533 = iprot.readString(); - struct.partitionnames.add(_elem533); + _elem543 = iprot.readString(); + struct.partitionnames.add(_elem543); } iprot.readListEnd(); } @@ -780,9 +780,9 @@ public class AddDynamicPartitions implements org.apache.thrift.TBase(_list537.size); - String _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.STRING, iprot.readI32()); + struct.partitionnames = new ArrayList(_list547.size); + String _elem548; + for (int _i549 = 0; _i549 < _list547.size; ++_i549) { - _elem538 = iprot.readString(); - struct.partitionnames.add(_elem538); + _elem548 = iprot.readString(); + struct.partitionnames.add(_elem548); } } struct.setPartitionnamesIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/e276929d/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 f71a3ca..ca274e6 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(_list616.size); - long _elem617; - for (int _i618 = 0; _i618 < _list616.size; ++_i618) + org.apache.thrift.protocol.TList _list626 = iprot.readListBegin(); + struct.fileIds = new ArrayList(_list626.size); + long _elem627; + for (int _i628 = 0; _i628 < _list626.size; ++_i628) { - _elem617 = iprot.readI64(); - struct.fileIds.add(_elem617); + _elem627 = iprot.readI64(); + struct.fileIds.add(_elem627); } iprot.readListEnd(); } @@ -383,9 +383,9 @@ public class ClearFileMetadataRequest implements org.apache.thrift.TBase(_list621.size); - long _elem622; - for (int _i623 = 0; _i623 < _list621.size; ++_i623) + org.apache.thrift.protocol.TList _list631 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.fileIds = new ArrayList(_list631.size); + long _elem632; + for (int _i633 = 0; _i633 < _list631.size; ++_i633) { - _elem622 = iprot.readI64(); - struct.fileIds.add(_elem622); + _elem632 = iprot.readI64(); + struct.fileIds.add(_elem632); } } struct.setFileIdsIsSet(true);