hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From w...@apache.org
Subject [5/7] hive git commit: HIVE-13354 : Add ability to specify Compaction options per table and per request (Wei Zheng, reviewed by Eugene Koifman)
Date Fri, 27 May 2016 22:14:18 GMT
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);


Mime
View raw message