hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hashut...@apache.org
Subject svn commit: r1406984 [26/29] - in /hive/trunk: contrib/src/java/org/apache/hadoop/hive/contrib/genericudf/example/ contrib/src/java/org/apache/hadoop/hive/contrib/serde2/ contrib/src/java/org/apache/hadoop/hive/contrib/util/typedbytes/ contrib/src/test...
Date Thu, 08 Nov 2012 09:44:29 GMT
Modified: hive/trunk/service/src/gen/thrift/gen-cpp/ThriftHive.cpp
URL: http://svn.apache.org/viewvc/hive/trunk/service/src/gen/thrift/gen-cpp/ThriftHive.cpp?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/service/src/gen/thrift/gen-cpp/ThriftHive.cpp (original)
+++ hive/trunk/service/src/gen/thrift/gen-cpp/ThriftHive.cpp Thu Nov  8 09:44:19 2012
@@ -1,7 +1,8 @@
 /**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *  @generated
  */
 #include "ThriftHive.h"
 
@@ -50,9 +51,11 @@ uint32_t ThriftHive_execute_args::read(:
 uint32_t ThriftHive_execute_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("ThriftHive_execute_args");
+
   xfer += oprot->writeFieldBegin("query", ::apache::thrift::protocol::T_STRING, 1);
   xfer += oprot->writeString(this->query);
   xfer += oprot->writeFieldEnd();
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
@@ -61,9 +64,11 @@ uint32_t ThriftHive_execute_args::write(
 uint32_t ThriftHive_execute_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("ThriftHive_execute_pargs");
+
   xfer += oprot->writeFieldBegin("query", ::apache::thrift::protocol::T_STRING, 1);
   xfer += oprot->writeString((*(this->query)));
   xfer += oprot->writeFieldEnd();
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
@@ -183,12 +188,7 @@ uint32_t ThriftHive_fetchOne_args::read(
     if (ftype == ::apache::thrift::protocol::T_STOP) {
       break;
     }
-    switch (fid)
-    {
-      default:
-        xfer += iprot->skip(ftype);
-        break;
-    }
+    xfer += iprot->skip(ftype);
     xfer += iprot->readFieldEnd();
   }
 
@@ -200,6 +200,7 @@ uint32_t ThriftHive_fetchOne_args::read(
 uint32_t ThriftHive_fetchOne_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("ThriftHive_fetchOne_args");
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
@@ -208,6 +209,7 @@ uint32_t ThriftHive_fetchOne_args::write
 uint32_t ThriftHive_fetchOne_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("ThriftHive_fetchOne_pargs");
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
@@ -372,9 +374,11 @@ uint32_t ThriftHive_fetchN_args::read(::
 uint32_t ThriftHive_fetchN_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("ThriftHive_fetchN_args");
+
   xfer += oprot->writeFieldBegin("numRows", ::apache::thrift::protocol::T_I32, 1);
   xfer += oprot->writeI32(this->numRows);
   xfer += oprot->writeFieldEnd();
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
@@ -383,9 +387,11 @@ uint32_t ThriftHive_fetchN_args::write(:
 uint32_t ThriftHive_fetchN_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("ThriftHive_fetchN_pargs");
+
   xfer += oprot->writeFieldBegin("numRows", ::apache::thrift::protocol::T_I32, 1);
   xfer += oprot->writeI32((*(this->numRows)));
   xfer += oprot->writeFieldEnd();
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
@@ -417,14 +423,14 @@ uint32_t ThriftHive_fetchN_result::read(
             this->success.clear();
             uint32_t _size1;
             ::apache::thrift::protocol::TType _etype4;
-            iprot->readListBegin(_etype4, _size1);
+            xfer += iprot->readListBegin(_etype4, _size1);
             this->success.resize(_size1);
             uint32_t _i5;
             for (_i5 = 0; _i5 < _size1; ++_i5)
             {
               xfer += iprot->readString(this->success[_i5]);
             }
-            iprot->readListEnd();
+            xfer += iprot->readListEnd();
           }
           this->__isset.success = true;
         } else {
@@ -505,14 +511,14 @@ uint32_t ThriftHive_fetchN_presult::read
             (*(this->success)).clear();
             uint32_t _size7;
             ::apache::thrift::protocol::TType _etype10;
-            iprot->readListBegin(_etype10, _size7);
+            xfer += iprot->readListBegin(_etype10, _size7);
             (*(this->success)).resize(_size7);
             uint32_t _i11;
             for (_i11 = 0; _i11 < _size7; ++_i11)
             {
               xfer += iprot->readString((*(this->success))[_i11]);
             }
-            iprot->readListEnd();
+            xfer += iprot->readListEnd();
           }
           this->__isset.success = true;
         } else {
@@ -557,12 +563,7 @@ uint32_t ThriftHive_fetchAll_args::read(
     if (ftype == ::apache::thrift::protocol::T_STOP) {
       break;
     }
-    switch (fid)
-    {
-      default:
-        xfer += iprot->skip(ftype);
-        break;
-    }
+    xfer += iprot->skip(ftype);
     xfer += iprot->readFieldEnd();
   }
 
@@ -574,6 +575,7 @@ uint32_t ThriftHive_fetchAll_args::read(
 uint32_t ThriftHive_fetchAll_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("ThriftHive_fetchAll_args");
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
@@ -582,6 +584,7 @@ uint32_t ThriftHive_fetchAll_args::write
 uint32_t ThriftHive_fetchAll_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("ThriftHive_fetchAll_pargs");
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
@@ -613,14 +616,14 @@ uint32_t ThriftHive_fetchAll_result::rea
             this->success.clear();
             uint32_t _size12;
             ::apache::thrift::protocol::TType _etype15;
-            iprot->readListBegin(_etype15, _size12);
+            xfer += iprot->readListBegin(_etype15, _size12);
             this->success.resize(_size12);
             uint32_t _i16;
             for (_i16 = 0; _i16 < _size12; ++_i16)
             {
               xfer += iprot->readString(this->success[_i16]);
             }
-            iprot->readListEnd();
+            xfer += iprot->readListEnd();
           }
           this->__isset.success = true;
         } else {
@@ -701,14 +704,14 @@ uint32_t ThriftHive_fetchAll_presult::re
             (*(this->success)).clear();
             uint32_t _size18;
             ::apache::thrift::protocol::TType _etype21;
-            iprot->readListBegin(_etype21, _size18);
+            xfer += iprot->readListBegin(_etype21, _size18);
             (*(this->success)).resize(_size18);
             uint32_t _i22;
             for (_i22 = 0; _i22 < _size18; ++_i22)
             {
               xfer += iprot->readString((*(this->success))[_i22]);
             }
-            iprot->readListEnd();
+            xfer += iprot->readListEnd();
           }
           this->__isset.success = true;
         } else {
@@ -753,12 +756,7 @@ uint32_t ThriftHive_getSchema_args::read
     if (ftype == ::apache::thrift::protocol::T_STOP) {
       break;
     }
-    switch (fid)
-    {
-      default:
-        xfer += iprot->skip(ftype);
-        break;
-    }
+    xfer += iprot->skip(ftype);
     xfer += iprot->readFieldEnd();
   }
 
@@ -770,6 +768,7 @@ uint32_t ThriftHive_getSchema_args::read
 uint32_t ThriftHive_getSchema_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("ThriftHive_getSchema_args");
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
@@ -778,6 +777,7 @@ uint32_t ThriftHive_getSchema_args::writ
 uint32_t ThriftHive_getSchema_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("ThriftHive_getSchema_pargs");
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
@@ -917,12 +917,7 @@ uint32_t ThriftHive_getThriftSchema_args
     if (ftype == ::apache::thrift::protocol::T_STOP) {
       break;
     }
-    switch (fid)
-    {
-      default:
-        xfer += iprot->skip(ftype);
-        break;
-    }
+    xfer += iprot->skip(ftype);
     xfer += iprot->readFieldEnd();
   }
 
@@ -934,6 +929,7 @@ uint32_t ThriftHive_getThriftSchema_args
 uint32_t ThriftHive_getThriftSchema_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("ThriftHive_getThriftSchema_args");
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
@@ -942,6 +938,7 @@ uint32_t ThriftHive_getThriftSchema_args
 uint32_t ThriftHive_getThriftSchema_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("ThriftHive_getThriftSchema_pargs");
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
@@ -1081,12 +1078,7 @@ uint32_t ThriftHive_getClusterStatus_arg
     if (ftype == ::apache::thrift::protocol::T_STOP) {
       break;
     }
-    switch (fid)
-    {
-      default:
-        xfer += iprot->skip(ftype);
-        break;
-    }
+    xfer += iprot->skip(ftype);
     xfer += iprot->readFieldEnd();
   }
 
@@ -1098,6 +1090,7 @@ uint32_t ThriftHive_getClusterStatus_arg
 uint32_t ThriftHive_getClusterStatus_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("ThriftHive_getClusterStatus_args");
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
@@ -1106,6 +1099,7 @@ uint32_t ThriftHive_getClusterStatus_arg
 uint32_t ThriftHive_getClusterStatus_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("ThriftHive_getClusterStatus_pargs");
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
@@ -1245,12 +1239,7 @@ uint32_t ThriftHive_getQueryPlan_args::r
     if (ftype == ::apache::thrift::protocol::T_STOP) {
       break;
     }
-    switch (fid)
-    {
-      default:
-        xfer += iprot->skip(ftype);
-        break;
-    }
+    xfer += iprot->skip(ftype);
     xfer += iprot->readFieldEnd();
   }
 
@@ -1262,6 +1251,7 @@ uint32_t ThriftHive_getQueryPlan_args::r
 uint32_t ThriftHive_getQueryPlan_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("ThriftHive_getQueryPlan_args");
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
@@ -1270,6 +1260,7 @@ uint32_t ThriftHive_getQueryPlan_args::w
 uint32_t ThriftHive_getQueryPlan_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("ThriftHive_getQueryPlan_pargs");
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
@@ -1409,12 +1400,7 @@ uint32_t ThriftHive_clean_args::read(::a
     if (ftype == ::apache::thrift::protocol::T_STOP) {
       break;
     }
-    switch (fid)
-    {
-      default:
-        xfer += iprot->skip(ftype);
-        break;
-    }
+    xfer += iprot->skip(ftype);
     xfer += iprot->readFieldEnd();
   }
 
@@ -1426,6 +1412,7 @@ uint32_t ThriftHive_clean_args::read(::a
 uint32_t ThriftHive_clean_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("ThriftHive_clean_args");
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
@@ -1434,6 +1421,7 @@ uint32_t ThriftHive_clean_args::write(::
 uint32_t ThriftHive_clean_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("ThriftHive_clean_pargs");
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
@@ -1457,12 +1445,7 @@ uint32_t ThriftHive_clean_result::read(:
     if (ftype == ::apache::thrift::protocol::T_STOP) {
       break;
     }
-    switch (fid)
-    {
-      default:
-        xfer += iprot->skip(ftype);
-        break;
-    }
+    xfer += iprot->skip(ftype);
     xfer += iprot->readFieldEnd();
   }
 
@@ -1500,12 +1483,7 @@ uint32_t ThriftHive_clean_presult::read(
     if (ftype == ::apache::thrift::protocol::T_STOP) {
       break;
     }
-    switch (fid)
-    {
-      default:
-        xfer += iprot->skip(ftype);
-        break;
-    }
+    xfer += iprot->skip(ftype);
     xfer += iprot->readFieldEnd();
   }
 
@@ -1751,7 +1729,7 @@ void ThriftHiveClient::recv_fetchAll(std
   throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "fetchAll failed: unknown result");
 }
 
-void ThriftHiveClient::getSchema(Apache::Hadoop::Hive::Schema& _return)
+void ThriftHiveClient::getSchema( ::Apache::Hadoop::Hive::Schema& _return)
 {
   send_getSchema();
   recv_getSchema(_return);
@@ -1770,7 +1748,7 @@ void ThriftHiveClient::send_getSchema()
   oprot_->getTransport()->flush();
 }
 
-void ThriftHiveClient::recv_getSchema(Apache::Hadoop::Hive::Schema& _return)
+void ThriftHiveClient::recv_getSchema( ::Apache::Hadoop::Hive::Schema& _return)
 {
 
   int32_t rseqid = 0;
@@ -1811,7 +1789,7 @@ void ThriftHiveClient::recv_getSchema(Ap
   throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getSchema failed: unknown result");
 }
 
-void ThriftHiveClient::getThriftSchema(Apache::Hadoop::Hive::Schema& _return)
+void ThriftHiveClient::getThriftSchema( ::Apache::Hadoop::Hive::Schema& _return)
 {
   send_getThriftSchema();
   recv_getThriftSchema(_return);
@@ -1830,7 +1808,7 @@ void ThriftHiveClient::send_getThriftSch
   oprot_->getTransport()->flush();
 }
 
-void ThriftHiveClient::recv_getThriftSchema(Apache::Hadoop::Hive::Schema& _return)
+void ThriftHiveClient::recv_getThriftSchema( ::Apache::Hadoop::Hive::Schema& _return)
 {
 
   int32_t rseqid = 0;
@@ -1931,7 +1909,7 @@ void ThriftHiveClient::recv_getClusterSt
   throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getClusterStatus failed: unknown result");
 }
 
-void ThriftHiveClient::getQueryPlan(Apache::Hadoop::Hive::QueryPlan& _return)
+void ThriftHiveClient::getQueryPlan( ::Apache::Hadoop::Hive::QueryPlan& _return)
 {
   send_getQueryPlan();
   recv_getQueryPlan(_return);
@@ -1950,7 +1928,7 @@ void ThriftHiveClient::send_getQueryPlan
   oprot_->getTransport()->flush();
 }
 
-void ThriftHiveClient::recv_getQueryPlan(Apache::Hadoop::Hive::QueryPlan& _return)
+void ThriftHiveClient::recv_getQueryPlan( ::Apache::Hadoop::Hive::QueryPlan& _return)
 {
 
   int32_t rseqid = 0;
@@ -2043,37 +2021,11 @@ void ThriftHiveClient::recv_clean()
   return;
 }
 
-bool ThriftHiveProcessor::process(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> piprot, boost::shared_ptr< ::apache::thrift::protocol::TProtocol> poprot, void* callContext) {
-
-  ::apache::thrift::protocol::TProtocol* iprot = piprot.get();
-  ::apache::thrift::protocol::TProtocol* oprot = poprot.get();
-  std::string fname;
-  ::apache::thrift::protocol::TMessageType mtype;
-  int32_t seqid;
-
-  iprot->readMessageBegin(fname, mtype, seqid);
-
-  if (mtype != ::apache::thrift::protocol::T_CALL && mtype != ::apache::thrift::protocol::T_ONEWAY) {
-    iprot->skip(::apache::thrift::protocol::T_STRUCT);
-    iprot->readMessageEnd();
-    iprot->getTransport()->readEnd();
-    ::apache::thrift::TApplicationException x(::apache::thrift::TApplicationException::INVALID_MESSAGE_TYPE);
-    oprot->writeMessageBegin(fname, ::apache::thrift::protocol::T_EXCEPTION, seqid);
-    x.write(oprot);
-    oprot->writeMessageEnd();
-    oprot->getTransport()->writeEnd();
-    oprot->getTransport()->flush();
-    return false;
-  }
-
-  return process_fn(iprot, oprot, fname, seqid, callContext);
-}
-
-bool ThriftHiveProcessor::process_fn(::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, std::string& fname, int32_t seqid, void* callContext) {
-  std::map<std::string, void (ThriftHiveProcessor::*)(int32_t, ::apache::thrift::protocol::TProtocol*, ::apache::thrift::protocol::TProtocol*, void*)>::iterator pfn;
+bool ThriftHiveProcessor::dispatchCall(::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, const std::string& fname, int32_t seqid, void* callContext) {
+  ProcessMap::iterator pfn;
   pfn = processMap_.find(fname);
   if (pfn == processMap_.end()) {
-    return Apache::Hadoop::Hive::ThriftHiveMetastoreProcessor::process_fn(iprot, oprot, fname, seqid, callContext);
+    return  ::Apache::Hadoop::Hive::ThriftHiveMetastoreProcessor::dispatchCall(iprot, oprot, fname, seqid, callContext);
   }
   (this->*(pfn->second))(seqid, iprot, oprot, callContext);
   return true;
@@ -2082,13 +2034,13 @@ bool ThriftHiveProcessor::process_fn(::a
 void ThriftHiveProcessor::process_execute(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext)
 {
   void* ctx = NULL;
-  if (eventHandler_.get() != NULL) {
-    ctx = eventHandler_->getContext("ThriftHive.execute", callContext);
+  if (this->eventHandler_.get() != NULL) {
+    ctx = this->eventHandler_->getContext("ThriftHive.execute", callContext);
   }
-  ::apache::thrift::TProcessorContextFreer freer(eventHandler_.get(), ctx, "ThriftHive.execute");
+  ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "ThriftHive.execute");
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->preRead(ctx, "ThriftHive.execute");
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->preRead(ctx, "ThriftHive.execute");
   }
 
   ThriftHive_execute_args args;
@@ -2096,8 +2048,8 @@ void ThriftHiveProcessor::process_execut
   iprot->readMessageEnd();
   uint32_t bytes = iprot->getTransport()->readEnd();
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->postRead(ctx, "ThriftHive.execute", bytes);
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->postRead(ctx, "ThriftHive.execute", bytes);
   }
 
   ThriftHive_execute_result result;
@@ -2107,8 +2059,8 @@ void ThriftHiveProcessor::process_execut
     result.ex = ex;
     result.__isset.ex = true;
   } catch (const std::exception& e) {
-    if (eventHandler_.get() != NULL) {
-      eventHandler_->handlerError(ctx, "ThriftHive.execute");
+    if (this->eventHandler_.get() != NULL) {
+      this->eventHandler_->handlerError(ctx, "ThriftHive.execute");
     }
 
     ::apache::thrift::TApplicationException x(e.what());
@@ -2120,8 +2072,8 @@ void ThriftHiveProcessor::process_execut
     return;
   }
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->preWrite(ctx, "ThriftHive.execute");
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->preWrite(ctx, "ThriftHive.execute");
   }
 
   oprot->writeMessageBegin("execute", ::apache::thrift::protocol::T_REPLY, seqid);
@@ -2130,21 +2082,21 @@ void ThriftHiveProcessor::process_execut
   bytes = oprot->getTransport()->writeEnd();
   oprot->getTransport()->flush();
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->postWrite(ctx, "ThriftHive.execute", bytes);
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->postWrite(ctx, "ThriftHive.execute", bytes);
   }
 }
 
 void ThriftHiveProcessor::process_fetchOne(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext)
 {
   void* ctx = NULL;
-  if (eventHandler_.get() != NULL) {
-    ctx = eventHandler_->getContext("ThriftHive.fetchOne", callContext);
+  if (this->eventHandler_.get() != NULL) {
+    ctx = this->eventHandler_->getContext("ThriftHive.fetchOne", callContext);
   }
-  ::apache::thrift::TProcessorContextFreer freer(eventHandler_.get(), ctx, "ThriftHive.fetchOne");
+  ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "ThriftHive.fetchOne");
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->preRead(ctx, "ThriftHive.fetchOne");
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->preRead(ctx, "ThriftHive.fetchOne");
   }
 
   ThriftHive_fetchOne_args args;
@@ -2152,8 +2104,8 @@ void ThriftHiveProcessor::process_fetchO
   iprot->readMessageEnd();
   uint32_t bytes = iprot->getTransport()->readEnd();
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->postRead(ctx, "ThriftHive.fetchOne", bytes);
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->postRead(ctx, "ThriftHive.fetchOne", bytes);
   }
 
   ThriftHive_fetchOne_result result;
@@ -2164,8 +2116,8 @@ void ThriftHiveProcessor::process_fetchO
     result.ex = ex;
     result.__isset.ex = true;
   } catch (const std::exception& e) {
-    if (eventHandler_.get() != NULL) {
-      eventHandler_->handlerError(ctx, "ThriftHive.fetchOne");
+    if (this->eventHandler_.get() != NULL) {
+      this->eventHandler_->handlerError(ctx, "ThriftHive.fetchOne");
     }
 
     ::apache::thrift::TApplicationException x(e.what());
@@ -2177,8 +2129,8 @@ void ThriftHiveProcessor::process_fetchO
     return;
   }
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->preWrite(ctx, "ThriftHive.fetchOne");
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->preWrite(ctx, "ThriftHive.fetchOne");
   }
 
   oprot->writeMessageBegin("fetchOne", ::apache::thrift::protocol::T_REPLY, seqid);
@@ -2187,21 +2139,21 @@ void ThriftHiveProcessor::process_fetchO
   bytes = oprot->getTransport()->writeEnd();
   oprot->getTransport()->flush();
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->postWrite(ctx, "ThriftHive.fetchOne", bytes);
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->postWrite(ctx, "ThriftHive.fetchOne", bytes);
   }
 }
 
 void ThriftHiveProcessor::process_fetchN(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext)
 {
   void* ctx = NULL;
-  if (eventHandler_.get() != NULL) {
-    ctx = eventHandler_->getContext("ThriftHive.fetchN", callContext);
+  if (this->eventHandler_.get() != NULL) {
+    ctx = this->eventHandler_->getContext("ThriftHive.fetchN", callContext);
   }
-  ::apache::thrift::TProcessorContextFreer freer(eventHandler_.get(), ctx, "ThriftHive.fetchN");
+  ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "ThriftHive.fetchN");
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->preRead(ctx, "ThriftHive.fetchN");
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->preRead(ctx, "ThriftHive.fetchN");
   }
 
   ThriftHive_fetchN_args args;
@@ -2209,8 +2161,8 @@ void ThriftHiveProcessor::process_fetchN
   iprot->readMessageEnd();
   uint32_t bytes = iprot->getTransport()->readEnd();
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->postRead(ctx, "ThriftHive.fetchN", bytes);
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->postRead(ctx, "ThriftHive.fetchN", bytes);
   }
 
   ThriftHive_fetchN_result result;
@@ -2221,8 +2173,8 @@ void ThriftHiveProcessor::process_fetchN
     result.ex = ex;
     result.__isset.ex = true;
   } catch (const std::exception& e) {
-    if (eventHandler_.get() != NULL) {
-      eventHandler_->handlerError(ctx, "ThriftHive.fetchN");
+    if (this->eventHandler_.get() != NULL) {
+      this->eventHandler_->handlerError(ctx, "ThriftHive.fetchN");
     }
 
     ::apache::thrift::TApplicationException x(e.what());
@@ -2234,8 +2186,8 @@ void ThriftHiveProcessor::process_fetchN
     return;
   }
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->preWrite(ctx, "ThriftHive.fetchN");
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->preWrite(ctx, "ThriftHive.fetchN");
   }
 
   oprot->writeMessageBegin("fetchN", ::apache::thrift::protocol::T_REPLY, seqid);
@@ -2244,21 +2196,21 @@ void ThriftHiveProcessor::process_fetchN
   bytes = oprot->getTransport()->writeEnd();
   oprot->getTransport()->flush();
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->postWrite(ctx, "ThriftHive.fetchN", bytes);
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->postWrite(ctx, "ThriftHive.fetchN", bytes);
   }
 }
 
 void ThriftHiveProcessor::process_fetchAll(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext)
 {
   void* ctx = NULL;
-  if (eventHandler_.get() != NULL) {
-    ctx = eventHandler_->getContext("ThriftHive.fetchAll", callContext);
+  if (this->eventHandler_.get() != NULL) {
+    ctx = this->eventHandler_->getContext("ThriftHive.fetchAll", callContext);
   }
-  ::apache::thrift::TProcessorContextFreer freer(eventHandler_.get(), ctx, "ThriftHive.fetchAll");
+  ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "ThriftHive.fetchAll");
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->preRead(ctx, "ThriftHive.fetchAll");
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->preRead(ctx, "ThriftHive.fetchAll");
   }
 
   ThriftHive_fetchAll_args args;
@@ -2266,8 +2218,8 @@ void ThriftHiveProcessor::process_fetchA
   iprot->readMessageEnd();
   uint32_t bytes = iprot->getTransport()->readEnd();
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->postRead(ctx, "ThriftHive.fetchAll", bytes);
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->postRead(ctx, "ThriftHive.fetchAll", bytes);
   }
 
   ThriftHive_fetchAll_result result;
@@ -2278,8 +2230,8 @@ void ThriftHiveProcessor::process_fetchA
     result.ex = ex;
     result.__isset.ex = true;
   } catch (const std::exception& e) {
-    if (eventHandler_.get() != NULL) {
-      eventHandler_->handlerError(ctx, "ThriftHive.fetchAll");
+    if (this->eventHandler_.get() != NULL) {
+      this->eventHandler_->handlerError(ctx, "ThriftHive.fetchAll");
     }
 
     ::apache::thrift::TApplicationException x(e.what());
@@ -2291,8 +2243,8 @@ void ThriftHiveProcessor::process_fetchA
     return;
   }
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->preWrite(ctx, "ThriftHive.fetchAll");
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->preWrite(ctx, "ThriftHive.fetchAll");
   }
 
   oprot->writeMessageBegin("fetchAll", ::apache::thrift::protocol::T_REPLY, seqid);
@@ -2301,21 +2253,21 @@ void ThriftHiveProcessor::process_fetchA
   bytes = oprot->getTransport()->writeEnd();
   oprot->getTransport()->flush();
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->postWrite(ctx, "ThriftHive.fetchAll", bytes);
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->postWrite(ctx, "ThriftHive.fetchAll", bytes);
   }
 }
 
 void ThriftHiveProcessor::process_getSchema(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext)
 {
   void* ctx = NULL;
-  if (eventHandler_.get() != NULL) {
-    ctx = eventHandler_->getContext("ThriftHive.getSchema", callContext);
+  if (this->eventHandler_.get() != NULL) {
+    ctx = this->eventHandler_->getContext("ThriftHive.getSchema", callContext);
   }
-  ::apache::thrift::TProcessorContextFreer freer(eventHandler_.get(), ctx, "ThriftHive.getSchema");
+  ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "ThriftHive.getSchema");
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->preRead(ctx, "ThriftHive.getSchema");
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->preRead(ctx, "ThriftHive.getSchema");
   }
 
   ThriftHive_getSchema_args args;
@@ -2323,8 +2275,8 @@ void ThriftHiveProcessor::process_getSch
   iprot->readMessageEnd();
   uint32_t bytes = iprot->getTransport()->readEnd();
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->postRead(ctx, "ThriftHive.getSchema", bytes);
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->postRead(ctx, "ThriftHive.getSchema", bytes);
   }
 
   ThriftHive_getSchema_result result;
@@ -2335,8 +2287,8 @@ void ThriftHiveProcessor::process_getSch
     result.ex = ex;
     result.__isset.ex = true;
   } catch (const std::exception& e) {
-    if (eventHandler_.get() != NULL) {
-      eventHandler_->handlerError(ctx, "ThriftHive.getSchema");
+    if (this->eventHandler_.get() != NULL) {
+      this->eventHandler_->handlerError(ctx, "ThriftHive.getSchema");
     }
 
     ::apache::thrift::TApplicationException x(e.what());
@@ -2348,8 +2300,8 @@ void ThriftHiveProcessor::process_getSch
     return;
   }
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->preWrite(ctx, "ThriftHive.getSchema");
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->preWrite(ctx, "ThriftHive.getSchema");
   }
 
   oprot->writeMessageBegin("getSchema", ::apache::thrift::protocol::T_REPLY, seqid);
@@ -2358,21 +2310,21 @@ void ThriftHiveProcessor::process_getSch
   bytes = oprot->getTransport()->writeEnd();
   oprot->getTransport()->flush();
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->postWrite(ctx, "ThriftHive.getSchema", bytes);
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->postWrite(ctx, "ThriftHive.getSchema", bytes);
   }
 }
 
 void ThriftHiveProcessor::process_getThriftSchema(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext)
 {
   void* ctx = NULL;
-  if (eventHandler_.get() != NULL) {
-    ctx = eventHandler_->getContext("ThriftHive.getThriftSchema", callContext);
+  if (this->eventHandler_.get() != NULL) {
+    ctx = this->eventHandler_->getContext("ThriftHive.getThriftSchema", callContext);
   }
-  ::apache::thrift::TProcessorContextFreer freer(eventHandler_.get(), ctx, "ThriftHive.getThriftSchema");
+  ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "ThriftHive.getThriftSchema");
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->preRead(ctx, "ThriftHive.getThriftSchema");
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->preRead(ctx, "ThriftHive.getThriftSchema");
   }
 
   ThriftHive_getThriftSchema_args args;
@@ -2380,8 +2332,8 @@ void ThriftHiveProcessor::process_getThr
   iprot->readMessageEnd();
   uint32_t bytes = iprot->getTransport()->readEnd();
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->postRead(ctx, "ThriftHive.getThriftSchema", bytes);
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->postRead(ctx, "ThriftHive.getThriftSchema", bytes);
   }
 
   ThriftHive_getThriftSchema_result result;
@@ -2392,8 +2344,8 @@ void ThriftHiveProcessor::process_getThr
     result.ex = ex;
     result.__isset.ex = true;
   } catch (const std::exception& e) {
-    if (eventHandler_.get() != NULL) {
-      eventHandler_->handlerError(ctx, "ThriftHive.getThriftSchema");
+    if (this->eventHandler_.get() != NULL) {
+      this->eventHandler_->handlerError(ctx, "ThriftHive.getThriftSchema");
     }
 
     ::apache::thrift::TApplicationException x(e.what());
@@ -2405,8 +2357,8 @@ void ThriftHiveProcessor::process_getThr
     return;
   }
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->preWrite(ctx, "ThriftHive.getThriftSchema");
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->preWrite(ctx, "ThriftHive.getThriftSchema");
   }
 
   oprot->writeMessageBegin("getThriftSchema", ::apache::thrift::protocol::T_REPLY, seqid);
@@ -2415,21 +2367,21 @@ void ThriftHiveProcessor::process_getThr
   bytes = oprot->getTransport()->writeEnd();
   oprot->getTransport()->flush();
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->postWrite(ctx, "ThriftHive.getThriftSchema", bytes);
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->postWrite(ctx, "ThriftHive.getThriftSchema", bytes);
   }
 }
 
 void ThriftHiveProcessor::process_getClusterStatus(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext)
 {
   void* ctx = NULL;
-  if (eventHandler_.get() != NULL) {
-    ctx = eventHandler_->getContext("ThriftHive.getClusterStatus", callContext);
+  if (this->eventHandler_.get() != NULL) {
+    ctx = this->eventHandler_->getContext("ThriftHive.getClusterStatus", callContext);
   }
-  ::apache::thrift::TProcessorContextFreer freer(eventHandler_.get(), ctx, "ThriftHive.getClusterStatus");
+  ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "ThriftHive.getClusterStatus");
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->preRead(ctx, "ThriftHive.getClusterStatus");
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->preRead(ctx, "ThriftHive.getClusterStatus");
   }
 
   ThriftHive_getClusterStatus_args args;
@@ -2437,8 +2389,8 @@ void ThriftHiveProcessor::process_getClu
   iprot->readMessageEnd();
   uint32_t bytes = iprot->getTransport()->readEnd();
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->postRead(ctx, "ThriftHive.getClusterStatus", bytes);
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->postRead(ctx, "ThriftHive.getClusterStatus", bytes);
   }
 
   ThriftHive_getClusterStatus_result result;
@@ -2449,8 +2401,8 @@ void ThriftHiveProcessor::process_getClu
     result.ex = ex;
     result.__isset.ex = true;
   } catch (const std::exception& e) {
-    if (eventHandler_.get() != NULL) {
-      eventHandler_->handlerError(ctx, "ThriftHive.getClusterStatus");
+    if (this->eventHandler_.get() != NULL) {
+      this->eventHandler_->handlerError(ctx, "ThriftHive.getClusterStatus");
     }
 
     ::apache::thrift::TApplicationException x(e.what());
@@ -2462,8 +2414,8 @@ void ThriftHiveProcessor::process_getClu
     return;
   }
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->preWrite(ctx, "ThriftHive.getClusterStatus");
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->preWrite(ctx, "ThriftHive.getClusterStatus");
   }
 
   oprot->writeMessageBegin("getClusterStatus", ::apache::thrift::protocol::T_REPLY, seqid);
@@ -2472,21 +2424,21 @@ void ThriftHiveProcessor::process_getClu
   bytes = oprot->getTransport()->writeEnd();
   oprot->getTransport()->flush();
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->postWrite(ctx, "ThriftHive.getClusterStatus", bytes);
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->postWrite(ctx, "ThriftHive.getClusterStatus", bytes);
   }
 }
 
 void ThriftHiveProcessor::process_getQueryPlan(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext)
 {
   void* ctx = NULL;
-  if (eventHandler_.get() != NULL) {
-    ctx = eventHandler_->getContext("ThriftHive.getQueryPlan", callContext);
+  if (this->eventHandler_.get() != NULL) {
+    ctx = this->eventHandler_->getContext("ThriftHive.getQueryPlan", callContext);
   }
-  ::apache::thrift::TProcessorContextFreer freer(eventHandler_.get(), ctx, "ThriftHive.getQueryPlan");
+  ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "ThriftHive.getQueryPlan");
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->preRead(ctx, "ThriftHive.getQueryPlan");
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->preRead(ctx, "ThriftHive.getQueryPlan");
   }
 
   ThriftHive_getQueryPlan_args args;
@@ -2494,8 +2446,8 @@ void ThriftHiveProcessor::process_getQue
   iprot->readMessageEnd();
   uint32_t bytes = iprot->getTransport()->readEnd();
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->postRead(ctx, "ThriftHive.getQueryPlan", bytes);
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->postRead(ctx, "ThriftHive.getQueryPlan", bytes);
   }
 
   ThriftHive_getQueryPlan_result result;
@@ -2506,8 +2458,8 @@ void ThriftHiveProcessor::process_getQue
     result.ex = ex;
     result.__isset.ex = true;
   } catch (const std::exception& e) {
-    if (eventHandler_.get() != NULL) {
-      eventHandler_->handlerError(ctx, "ThriftHive.getQueryPlan");
+    if (this->eventHandler_.get() != NULL) {
+      this->eventHandler_->handlerError(ctx, "ThriftHive.getQueryPlan");
     }
 
     ::apache::thrift::TApplicationException x(e.what());
@@ -2519,8 +2471,8 @@ void ThriftHiveProcessor::process_getQue
     return;
   }
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->preWrite(ctx, "ThriftHive.getQueryPlan");
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->preWrite(ctx, "ThriftHive.getQueryPlan");
   }
 
   oprot->writeMessageBegin("getQueryPlan", ::apache::thrift::protocol::T_REPLY, seqid);
@@ -2529,21 +2481,21 @@ void ThriftHiveProcessor::process_getQue
   bytes = oprot->getTransport()->writeEnd();
   oprot->getTransport()->flush();
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->postWrite(ctx, "ThriftHive.getQueryPlan", bytes);
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->postWrite(ctx, "ThriftHive.getQueryPlan", bytes);
   }
 }
 
 void ThriftHiveProcessor::process_clean(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext)
 {
   void* ctx = NULL;
-  if (eventHandler_.get() != NULL) {
-    ctx = eventHandler_->getContext("ThriftHive.clean", callContext);
+  if (this->eventHandler_.get() != NULL) {
+    ctx = this->eventHandler_->getContext("ThriftHive.clean", callContext);
   }
-  ::apache::thrift::TProcessorContextFreer freer(eventHandler_.get(), ctx, "ThriftHive.clean");
+  ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "ThriftHive.clean");
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->preRead(ctx, "ThriftHive.clean");
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->preRead(ctx, "ThriftHive.clean");
   }
 
   ThriftHive_clean_args args;
@@ -2551,16 +2503,16 @@ void ThriftHiveProcessor::process_clean(
   iprot->readMessageEnd();
   uint32_t bytes = iprot->getTransport()->readEnd();
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->postRead(ctx, "ThriftHive.clean", bytes);
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->postRead(ctx, "ThriftHive.clean", bytes);
   }
 
   ThriftHive_clean_result result;
   try {
     iface_->clean();
   } catch (const std::exception& e) {
-    if (eventHandler_.get() != NULL) {
-      eventHandler_->handlerError(ctx, "ThriftHive.clean");
+    if (this->eventHandler_.get() != NULL) {
+      this->eventHandler_->handlerError(ctx, "ThriftHive.clean");
     }
 
     ::apache::thrift::TApplicationException x(e.what());
@@ -2572,8 +2524,8 @@ void ThriftHiveProcessor::process_clean(
     return;
   }
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->preWrite(ctx, "ThriftHive.clean");
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->preWrite(ctx, "ThriftHive.clean");
   }
 
   oprot->writeMessageBegin("clean", ::apache::thrift::protocol::T_REPLY, seqid);
@@ -2582,10 +2534,16 @@ void ThriftHiveProcessor::process_clean(
   bytes = oprot->getTransport()->writeEnd();
   oprot->getTransport()->flush();
 
-  if (eventHandler_.get() != NULL) {
-    eventHandler_->postWrite(ctx, "ThriftHive.clean", bytes);
+  if (this->eventHandler_.get() != NULL) {
+    this->eventHandler_->postWrite(ctx, "ThriftHive.clean", bytes);
   }
 }
 
+::boost::shared_ptr< ::apache::thrift::TProcessor > ThriftHiveProcessorFactory::getProcessor(const ::apache::thrift::TConnectionInfo& connInfo) {
+  ::apache::thrift::ReleaseHandler< ThriftHiveIfFactory > cleanup(handlerFactory_);
+  ::boost::shared_ptr< ThriftHiveIf > handler(handlerFactory_->getHandler(connInfo), cleanup);
+  ::boost::shared_ptr< ::apache::thrift::TProcessor > processor(new ThriftHiveProcessor(handler));
+  return processor;
+}
 }}} // namespace
 

Modified: hive/trunk/service/src/gen/thrift/gen-cpp/ThriftHive.h
URL: http://svn.apache.org/viewvc/hive/trunk/service/src/gen/thrift/gen-cpp/ThriftHive.h?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/service/src/gen/thrift/gen-cpp/ThriftHive.h (original)
+++ hive/trunk/service/src/gen/thrift/gen-cpp/ThriftHive.h Thu Nov  8 09:44:19 2012
@@ -1,32 +1,57 @@
 /**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *  @generated
  */
 #ifndef ThriftHive_H
 #define ThriftHive_H
 
-#include <TProcessor.h>
+#include <thrift/TDispatchProcessor.h>
 #include "hive_service_types.h"
 #include "ThriftHiveMetastore.h"
 
 namespace Apache { namespace Hadoop { namespace Hive {
 
-class ThriftHiveIf : virtual public Apache::Hadoop::Hive::ThriftHiveMetastoreIf {
+class ThriftHiveIf : virtual public  ::Apache::Hadoop::Hive::ThriftHiveMetastoreIf {
  public:
   virtual ~ThriftHiveIf() {}
   virtual void execute(const std::string& query) = 0;
   virtual void fetchOne(std::string& _return) = 0;
   virtual void fetchN(std::vector<std::string> & _return, const int32_t numRows) = 0;
   virtual void fetchAll(std::vector<std::string> & _return) = 0;
-  virtual void getSchema(Apache::Hadoop::Hive::Schema& _return) = 0;
-  virtual void getThriftSchema(Apache::Hadoop::Hive::Schema& _return) = 0;
+  virtual void getSchema( ::Apache::Hadoop::Hive::Schema& _return) = 0;
+  virtual void getThriftSchema( ::Apache::Hadoop::Hive::Schema& _return) = 0;
   virtual void getClusterStatus(HiveClusterStatus& _return) = 0;
-  virtual void getQueryPlan(Apache::Hadoop::Hive::QueryPlan& _return) = 0;
+  virtual void getQueryPlan( ::Apache::Hadoop::Hive::QueryPlan& _return) = 0;
   virtual void clean() = 0;
 };
 
-class ThriftHiveNull : virtual public ThriftHiveIf , virtual public Apache::Hadoop::Hive::ThriftHiveMetastoreNull {
+class ThriftHiveIfFactory : virtual public  ::Apache::Hadoop::Hive::ThriftHiveMetastoreIfFactory {
+ public:
+  typedef ThriftHiveIf Handler;
+
+  virtual ~ThriftHiveIfFactory() {}
+
+  virtual ThriftHiveIf* getHandler(const ::apache::thrift::TConnectionInfo& connInfo) = 0;
+  virtual void releaseHandler( ::facebook::fb303::FacebookServiceIf* /* handler */) = 0;
+};
+
+class ThriftHiveIfSingletonFactory : virtual public ThriftHiveIfFactory {
+ public:
+  ThriftHiveIfSingletonFactory(const boost::shared_ptr<ThriftHiveIf>& iface) : iface_(iface) {}
+  virtual ~ThriftHiveIfSingletonFactory() {}
+
+  virtual ThriftHiveIf* getHandler(const ::apache::thrift::TConnectionInfo&) {
+    return iface_.get();
+  }
+  virtual void releaseHandler( ::facebook::fb303::FacebookServiceIf* /* handler */) {}
+
+ protected:
+  boost::shared_ptr<ThriftHiveIf> iface_;
+};
+
+class ThriftHiveNull : virtual public ThriftHiveIf , virtual public  ::Apache::Hadoop::Hive::ThriftHiveMetastoreNull {
  public:
   virtual ~ThriftHiveNull() {}
   void execute(const std::string& /* query */) {
@@ -41,16 +66,16 @@ class ThriftHiveNull : virtual public Th
   void fetchAll(std::vector<std::string> & /* _return */) {
     return;
   }
-  void getSchema(Apache::Hadoop::Hive::Schema& /* _return */) {
+  void getSchema( ::Apache::Hadoop::Hive::Schema& /* _return */) {
     return;
   }
-  void getThriftSchema(Apache::Hadoop::Hive::Schema& /* _return */) {
+  void getThriftSchema( ::Apache::Hadoop::Hive::Schema& /* _return */) {
     return;
   }
   void getClusterStatus(HiveClusterStatus& /* _return */) {
     return;
   }
-  void getQueryPlan(Apache::Hadoop::Hive::QueryPlan& /* _return */) {
+  void getQueryPlan( ::Apache::Hadoop::Hive::QueryPlan& /* _return */) {
     return;
   }
   void clean() {
@@ -66,7 +91,7 @@ typedef struct _ThriftHive_execute_args_
 class ThriftHive_execute_args {
  public:
 
-  ThriftHive_execute_args() : query("") {
+  ThriftHive_execute_args() : query() {
   }
 
   virtual ~ThriftHive_execute_args() throw() {}
@@ -212,7 +237,7 @@ typedef struct _ThriftHive_fetchOne_resu
 class ThriftHive_fetchOne_result {
  public:
 
-  ThriftHive_fetchOne_result() : success("") {
+  ThriftHive_fetchOne_result() : success() {
   }
 
   virtual ~ThriftHive_fetchOne_result() throw() {}
@@ -543,12 +568,12 @@ class ThriftHive_getSchema_result {
 
   virtual ~ThriftHive_getSchema_result() throw() {}
 
-  Apache::Hadoop::Hive::Schema success;
+   ::Apache::Hadoop::Hive::Schema success;
   HiveServerException ex;
 
   _ThriftHive_getSchema_result__isset __isset;
 
-  void __set_success(const Apache::Hadoop::Hive::Schema& val) {
+  void __set_success(const  ::Apache::Hadoop::Hive::Schema& val) {
     success = val;
   }
 
@@ -587,7 +612,7 @@ class ThriftHive_getSchema_presult {
 
   virtual ~ThriftHive_getSchema_presult() throw() {}
 
-  Apache::Hadoop::Hive::Schema* success;
+   ::Apache::Hadoop::Hive::Schema* success;
   HiveServerException ex;
 
   _ThriftHive_getSchema_presult__isset __isset;
@@ -647,12 +672,12 @@ class ThriftHive_getThriftSchema_result 
 
   virtual ~ThriftHive_getThriftSchema_result() throw() {}
 
-  Apache::Hadoop::Hive::Schema success;
+   ::Apache::Hadoop::Hive::Schema success;
   HiveServerException ex;
 
   _ThriftHive_getThriftSchema_result__isset __isset;
 
-  void __set_success(const Apache::Hadoop::Hive::Schema& val) {
+  void __set_success(const  ::Apache::Hadoop::Hive::Schema& val) {
     success = val;
   }
 
@@ -691,7 +716,7 @@ class ThriftHive_getThriftSchema_presult
 
   virtual ~ThriftHive_getThriftSchema_presult() throw() {}
 
-  Apache::Hadoop::Hive::Schema* success;
+   ::Apache::Hadoop::Hive::Schema* success;
   HiveServerException ex;
 
   _ThriftHive_getThriftSchema_presult__isset __isset;
@@ -855,12 +880,12 @@ class ThriftHive_getQueryPlan_result {
 
   virtual ~ThriftHive_getQueryPlan_result() throw() {}
 
-  Apache::Hadoop::Hive::QueryPlan success;
+   ::Apache::Hadoop::Hive::QueryPlan success;
   HiveServerException ex;
 
   _ThriftHive_getQueryPlan_result__isset __isset;
 
-  void __set_success(const Apache::Hadoop::Hive::QueryPlan& val) {
+  void __set_success(const  ::Apache::Hadoop::Hive::QueryPlan& val) {
     success = val;
   }
 
@@ -899,7 +924,7 @@ class ThriftHive_getQueryPlan_presult {
 
   virtual ~ThriftHive_getQueryPlan_presult() throw() {}
 
-  Apache::Hadoop::Hive::QueryPlan* success;
+   ::Apache::Hadoop::Hive::QueryPlan* success;
   HiveServerException ex;
 
   _ThriftHive_getQueryPlan_presult__isset __isset;
@@ -982,12 +1007,12 @@ class ThriftHive_clean_presult {
 
 };
 
-class ThriftHiveClient : virtual public ThriftHiveIf, public Apache::Hadoop::Hive::ThriftHiveMetastoreClient {
+class ThriftHiveClient : virtual public ThriftHiveIf, public  ::Apache::Hadoop::Hive::ThriftHiveMetastoreClient {
  public:
   ThriftHiveClient(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> prot) :
-    Apache::Hadoop::Hive::ThriftHiveMetastoreClient(prot, prot) {}
+     ::Apache::Hadoop::Hive::ThriftHiveMetastoreClient(prot, prot) {}
   ThriftHiveClient(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> iprot, boost::shared_ptr< ::apache::thrift::protocol::TProtocol> oprot) :
-    Apache::Hadoop::Hive::ThriftHiveMetastoreClient(iprot, oprot) {}
+     ::Apache::Hadoop::Hive::ThriftHiveMetastoreClient(iprot, oprot) {}
   boost::shared_ptr< ::apache::thrift::protocol::TProtocol> getInputProtocol() {
     return piprot_;
   }
@@ -1006,29 +1031,31 @@ class ThriftHiveClient : virtual public 
   void fetchAll(std::vector<std::string> & _return);
   void send_fetchAll();
   void recv_fetchAll(std::vector<std::string> & _return);
-  void getSchema(Apache::Hadoop::Hive::Schema& _return);
+  void getSchema( ::Apache::Hadoop::Hive::Schema& _return);
   void send_getSchema();
-  void recv_getSchema(Apache::Hadoop::Hive::Schema& _return);
-  void getThriftSchema(Apache::Hadoop::Hive::Schema& _return);
+  void recv_getSchema( ::Apache::Hadoop::Hive::Schema& _return);
+  void getThriftSchema( ::Apache::Hadoop::Hive::Schema& _return);
   void send_getThriftSchema();
-  void recv_getThriftSchema(Apache::Hadoop::Hive::Schema& _return);
+  void recv_getThriftSchema( ::Apache::Hadoop::Hive::Schema& _return);
   void getClusterStatus(HiveClusterStatus& _return);
   void send_getClusterStatus();
   void recv_getClusterStatus(HiveClusterStatus& _return);
-  void getQueryPlan(Apache::Hadoop::Hive::QueryPlan& _return);
+  void getQueryPlan( ::Apache::Hadoop::Hive::QueryPlan& _return);
   void send_getQueryPlan();
-  void recv_getQueryPlan(Apache::Hadoop::Hive::QueryPlan& _return);
+  void recv_getQueryPlan( ::Apache::Hadoop::Hive::QueryPlan& _return);
   void clean();
   void send_clean();
   void recv_clean();
 };
 
-class ThriftHiveProcessor : virtual public ::apache::thrift::TProcessor, public Apache::Hadoop::Hive::ThriftHiveMetastoreProcessor {
+class ThriftHiveProcessor : public  ::Apache::Hadoop::Hive::ThriftHiveMetastoreProcessor {
  protected:
   boost::shared_ptr<ThriftHiveIf> iface_;
-  virtual bool process_fn(::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, std::string& fname, int32_t seqid, void* callContext);
+  virtual bool dispatchCall(::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, const std::string& fname, int32_t seqid, void* callContext);
  private:
-  std::map<std::string, void (ThriftHiveProcessor::*)(int32_t, ::apache::thrift::protocol::TProtocol*, ::apache::thrift::protocol::TProtocol*, void*)> processMap_;
+  typedef  void (ThriftHiveProcessor::*ProcessFunction)(int32_t, ::apache::thrift::protocol::TProtocol*, ::apache::thrift::protocol::TProtocol*, void*);
+  typedef std::map<std::string, ProcessFunction> ProcessMap;
+  ProcessMap processMap_;
   void process_execute(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
   void process_fetchOne(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
   void process_fetchN(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
@@ -1040,7 +1067,7 @@ class ThriftHiveProcessor : virtual publ
   void process_clean(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
  public:
   ThriftHiveProcessor(boost::shared_ptr<ThriftHiveIf> iface) :
-    Apache::Hadoop::Hive::ThriftHiveMetastoreProcessor(iface),
+     ::Apache::Hadoop::Hive::ThriftHiveMetastoreProcessor(iface),
     iface_(iface) {
     processMap_["execute"] = &ThriftHiveProcessor::process_execute;
     processMap_["fetchOne"] = &ThriftHiveProcessor::process_fetchOne;
@@ -1053,16 +1080,26 @@ class ThriftHiveProcessor : virtual publ
     processMap_["clean"] = &ThriftHiveProcessor::process_clean;
   }
 
-  virtual bool process(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> piprot, boost::shared_ptr< ::apache::thrift::protocol::TProtocol> poprot, void* callContext);
   virtual ~ThriftHiveProcessor() {}
 };
 
-class ThriftHiveMultiface : virtual public ThriftHiveIf, public Apache::Hadoop::Hive::ThriftHiveMetastoreMultiface {
+class ThriftHiveProcessorFactory : public ::apache::thrift::TProcessorFactory {
+ public:
+  ThriftHiveProcessorFactory(const ::boost::shared_ptr< ThriftHiveIfFactory >& handlerFactory) :
+      handlerFactory_(handlerFactory) {}
+
+  ::boost::shared_ptr< ::apache::thrift::TProcessor > getProcessor(const ::apache::thrift::TConnectionInfo& connInfo);
+
+ protected:
+  ::boost::shared_ptr< ThriftHiveIfFactory > handlerFactory_;
+};
+
+class ThriftHiveMultiface : virtual public ThriftHiveIf, public  ::Apache::Hadoop::Hive::ThriftHiveMetastoreMultiface {
  public:
   ThriftHiveMultiface(std::vector<boost::shared_ptr<ThriftHiveIf> >& ifaces) : ifaces_(ifaces) {
     std::vector<boost::shared_ptr<ThriftHiveIf> >::iterator iter;
     for (iter = ifaces.begin(); iter != ifaces.end(); ++iter) {
-      Apache::Hadoop::Hive::ThriftHiveMetastoreMultiface::add(*iter);
+       ::Apache::Hadoop::Hive::ThriftHiveMetastoreMultiface::add(*iter);
     }
   }
   virtual ~ThriftHiveMultiface() {}
@@ -1070,106 +1107,96 @@ class ThriftHiveMultiface : virtual publ
   std::vector<boost::shared_ptr<ThriftHiveIf> > ifaces_;
   ThriftHiveMultiface() {}
   void add(boost::shared_ptr<ThriftHiveIf> iface) {
-    Apache::Hadoop::Hive::ThriftHiveMetastoreMultiface::add(iface);
+     ::Apache::Hadoop::Hive::ThriftHiveMetastoreMultiface::add(iface);
     ifaces_.push_back(iface);
   }
  public:
   void execute(const std::string& query) {
     size_t sz = ifaces_.size();
-    for (size_t i = 0; i < sz; ++i) {
+    size_t i = 0;
+    for (; i < (sz - 1); ++i) {
       ifaces_[i]->execute(query);
     }
+    ifaces_[i]->execute(query);
   }
 
   void fetchOne(std::string& _return) {
     size_t sz = ifaces_.size();
-    for (size_t i = 0; i < sz; ++i) {
-      if (i == sz - 1) {
-        ifaces_[i]->fetchOne(_return);
-        return;
-      } else {
-        ifaces_[i]->fetchOne(_return);
-      }
+    size_t i = 0;
+    for (; i < (sz - 1); ++i) {
+      ifaces_[i]->fetchOne(_return);
     }
+    ifaces_[i]->fetchOne(_return);
+    return;
   }
 
   void fetchN(std::vector<std::string> & _return, const int32_t numRows) {
     size_t sz = ifaces_.size();
-    for (size_t i = 0; i < sz; ++i) {
-      if (i == sz - 1) {
-        ifaces_[i]->fetchN(_return, numRows);
-        return;
-      } else {
-        ifaces_[i]->fetchN(_return, numRows);
-      }
+    size_t i = 0;
+    for (; i < (sz - 1); ++i) {
+      ifaces_[i]->fetchN(_return, numRows);
     }
+    ifaces_[i]->fetchN(_return, numRows);
+    return;
   }
 
   void fetchAll(std::vector<std::string> & _return) {
     size_t sz = ifaces_.size();
-    for (size_t i = 0; i < sz; ++i) {
-      if (i == sz - 1) {
-        ifaces_[i]->fetchAll(_return);
-        return;
-      } else {
-        ifaces_[i]->fetchAll(_return);
-      }
+    size_t i = 0;
+    for (; i < (sz - 1); ++i) {
+      ifaces_[i]->fetchAll(_return);
     }
+    ifaces_[i]->fetchAll(_return);
+    return;
   }
 
-  void getSchema(Apache::Hadoop::Hive::Schema& _return) {
+  void getSchema( ::Apache::Hadoop::Hive::Schema& _return) {
     size_t sz = ifaces_.size();
-    for (size_t i = 0; i < sz; ++i) {
-      if (i == sz - 1) {
-        ifaces_[i]->getSchema(_return);
-        return;
-      } else {
-        ifaces_[i]->getSchema(_return);
-      }
+    size_t i = 0;
+    for (; i < (sz - 1); ++i) {
+      ifaces_[i]->getSchema(_return);
     }
+    ifaces_[i]->getSchema(_return);
+    return;
   }
 
-  void getThriftSchema(Apache::Hadoop::Hive::Schema& _return) {
+  void getThriftSchema( ::Apache::Hadoop::Hive::Schema& _return) {
     size_t sz = ifaces_.size();
-    for (size_t i = 0; i < sz; ++i) {
-      if (i == sz - 1) {
-        ifaces_[i]->getThriftSchema(_return);
-        return;
-      } else {
-        ifaces_[i]->getThriftSchema(_return);
-      }
+    size_t i = 0;
+    for (; i < (sz - 1); ++i) {
+      ifaces_[i]->getThriftSchema(_return);
     }
+    ifaces_[i]->getThriftSchema(_return);
+    return;
   }
 
   void getClusterStatus(HiveClusterStatus& _return) {
     size_t sz = ifaces_.size();
-    for (size_t i = 0; i < sz; ++i) {
-      if (i == sz - 1) {
-        ifaces_[i]->getClusterStatus(_return);
-        return;
-      } else {
-        ifaces_[i]->getClusterStatus(_return);
-      }
+    size_t i = 0;
+    for (; i < (sz - 1); ++i) {
+      ifaces_[i]->getClusterStatus(_return);
     }
+    ifaces_[i]->getClusterStatus(_return);
+    return;
   }
 
-  void getQueryPlan(Apache::Hadoop::Hive::QueryPlan& _return) {
+  void getQueryPlan( ::Apache::Hadoop::Hive::QueryPlan& _return) {
     size_t sz = ifaces_.size();
-    for (size_t i = 0; i < sz; ++i) {
-      if (i == sz - 1) {
-        ifaces_[i]->getQueryPlan(_return);
-        return;
-      } else {
-        ifaces_[i]->getQueryPlan(_return);
-      }
+    size_t i = 0;
+    for (; i < (sz - 1); ++i) {
+      ifaces_[i]->getQueryPlan(_return);
     }
+    ifaces_[i]->getQueryPlan(_return);
+    return;
   }
 
   void clean() {
     size_t sz = ifaces_.size();
-    for (size_t i = 0; i < sz; ++i) {
+    size_t i = 0;
+    for (; i < (sz - 1); ++i) {
       ifaces_[i]->clean();
     }
+    ifaces_[i]->clean();
   }
 
 };

Modified: hive/trunk/service/src/gen/thrift/gen-cpp/ThriftHive_server.skeleton.cpp
URL: http://svn.apache.org/viewvc/hive/trunk/service/src/gen/thrift/gen-cpp/ThriftHive_server.skeleton.cpp?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/service/src/gen/thrift/gen-cpp/ThriftHive_server.skeleton.cpp (original)
+++ hive/trunk/service/src/gen/thrift/gen-cpp/ThriftHive_server.skeleton.cpp Thu Nov  8 09:44:19 2012
@@ -2,10 +2,10 @@
 // You should copy it to another filename to avoid overwriting it.
 
 #include "ThriftHive.h"
-#include <protocol/TBinaryProtocol.h>
-#include <server/TSimpleServer.h>
-#include <transport/TServerSocket.h>
-#include <transport/TBufferTransports.h>
+#include <thrift/protocol/TBinaryProtocol.h>
+#include <thrift/server/TSimpleServer.h>
+#include <thrift/transport/TServerSocket.h>
+#include <thrift/transport/TBufferTransports.h>
 
 using namespace ::apache::thrift;
 using namespace ::apache::thrift::protocol;
@@ -14,7 +14,7 @@ using namespace ::apache::thrift::server
 
 using boost::shared_ptr;
 
-using namespace Apache::Hadoop::Hive;
+using namespace  ::Apache::Hadoop::Hive;
 
 class ThriftHiveHandler : virtual public ThriftHiveIf {
  public:
@@ -42,12 +42,12 @@ class ThriftHiveHandler : virtual public
     printf("fetchAll\n");
   }
 
-  void getSchema(Apache::Hadoop::Hive::Schema& _return) {
+  void getSchema( ::Apache::Hadoop::Hive::Schema& _return) {
     // Your implementation goes here
     printf("getSchema\n");
   }
 
-  void getThriftSchema(Apache::Hadoop::Hive::Schema& _return) {
+  void getThriftSchema( ::Apache::Hadoop::Hive::Schema& _return) {
     // Your implementation goes here
     printf("getThriftSchema\n");
   }
@@ -57,7 +57,7 @@ class ThriftHiveHandler : virtual public
     printf("getClusterStatus\n");
   }
 
-  void getQueryPlan(Apache::Hadoop::Hive::QueryPlan& _return) {
+  void getQueryPlan( ::Apache::Hadoop::Hive::QueryPlan& _return) {
     // Your implementation goes here
     printf("getQueryPlan\n");
   }

Modified: hive/trunk/service/src/gen/thrift/gen-cpp/hive_service_constants.cpp
URL: http://svn.apache.org/viewvc/hive/trunk/service/src/gen/thrift/gen-cpp/hive_service_constants.cpp?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/service/src/gen/thrift/gen-cpp/hive_service_constants.cpp (original)
+++ hive/trunk/service/src/gen/thrift/gen-cpp/hive_service_constants.cpp Thu Nov  8 09:44:19 2012
@@ -1,7 +1,8 @@
 /**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *  @generated
  */
 #include "hive_service_constants.h"
 

Modified: hive/trunk/service/src/gen/thrift/gen-cpp/hive_service_constants.h
URL: http://svn.apache.org/viewvc/hive/trunk/service/src/gen/thrift/gen-cpp/hive_service_constants.h?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/service/src/gen/thrift/gen-cpp/hive_service_constants.h (original)
+++ hive/trunk/service/src/gen/thrift/gen-cpp/hive_service_constants.h Thu Nov  8 09:44:19 2012
@@ -1,7 +1,8 @@
 /**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *  @generated
  */
 #ifndef hive_service_CONSTANTS_H
 #define hive_service_CONSTANTS_H

Modified: hive/trunk/service/src/gen/thrift/gen-cpp/hive_service_types.cpp
URL: http://svn.apache.org/viewvc/hive/trunk/service/src/gen/thrift/gen-cpp/hive_service_types.cpp?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/service/src/gen/thrift/gen-cpp/hive_service_types.cpp (original)
+++ hive/trunk/service/src/gen/thrift/gen-cpp/hive_service_types.cpp Thu Nov  8 09:44:19 2012
@@ -1,10 +1,13 @@
 /**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *  @generated
  */
 #include "hive_service_types.h"
 
+#include <algorithm>
+
 namespace Apache { namespace Hadoop { namespace Hive {
 
 int _kJobTrackerStateValues[] = {
@@ -105,29 +108,47 @@ uint32_t HiveClusterStatus::read(::apach
 uint32_t HiveClusterStatus::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("HiveClusterStatus");
+
   xfer += oprot->writeFieldBegin("taskTrackers", ::apache::thrift::protocol::T_I32, 1);
   xfer += oprot->writeI32(this->taskTrackers);
   xfer += oprot->writeFieldEnd();
+
   xfer += oprot->writeFieldBegin("mapTasks", ::apache::thrift::protocol::T_I32, 2);
   xfer += oprot->writeI32(this->mapTasks);
   xfer += oprot->writeFieldEnd();
+
   xfer += oprot->writeFieldBegin("reduceTasks", ::apache::thrift::protocol::T_I32, 3);
   xfer += oprot->writeI32(this->reduceTasks);
   xfer += oprot->writeFieldEnd();
+
   xfer += oprot->writeFieldBegin("maxMapTasks", ::apache::thrift::protocol::T_I32, 4);
   xfer += oprot->writeI32(this->maxMapTasks);
   xfer += oprot->writeFieldEnd();
+
   xfer += oprot->writeFieldBegin("maxReduceTasks", ::apache::thrift::protocol::T_I32, 5);
   xfer += oprot->writeI32(this->maxReduceTasks);
   xfer += oprot->writeFieldEnd();
+
   xfer += oprot->writeFieldBegin("state", ::apache::thrift::protocol::T_I32, 6);
   xfer += oprot->writeI32((int32_t)this->state);
   xfer += oprot->writeFieldEnd();
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
 }
 
+void swap(HiveClusterStatus &a, HiveClusterStatus &b) {
+  using ::std::swap;
+  swap(a.taskTrackers, b.taskTrackers);
+  swap(a.mapTasks, b.mapTasks);
+  swap(a.reduceTasks, b.reduceTasks);
+  swap(a.maxMapTasks, b.maxMapTasks);
+  swap(a.maxReduceTasks, b.maxReduceTasks);
+  swap(a.state, b.state);
+  swap(a.__isset, b.__isset);
+}
+
 const char* HiveServerException::ascii_fingerprint = "70563A0628F75DF9555F4D24690B1E26";
 const uint8_t HiveServerException::binary_fingerprint[16] = {0x70,0x56,0x3A,0x06,0x28,0xF7,0x5D,0xF9,0x55,0x5F,0x4D,0x24,0x69,0x0B,0x1E,0x26};
 
@@ -190,18 +211,30 @@ uint32_t HiveServerException::read(::apa
 uint32_t HiveServerException::write(::apache::thrift::protocol::TProtocol* oprot) const {
   uint32_t xfer = 0;
   xfer += oprot->writeStructBegin("HiveServerException");
+
   xfer += oprot->writeFieldBegin("message", ::apache::thrift::protocol::T_STRING, 1);
   xfer += oprot->writeString(this->message);
   xfer += oprot->writeFieldEnd();
+
   xfer += oprot->writeFieldBegin("errorCode", ::apache::thrift::protocol::T_I32, 2);
   xfer += oprot->writeI32(this->errorCode);
   xfer += oprot->writeFieldEnd();
+
   xfer += oprot->writeFieldBegin("SQLState", ::apache::thrift::protocol::T_STRING, 3);
   xfer += oprot->writeString(this->SQLState);
   xfer += oprot->writeFieldEnd();
+
   xfer += oprot->writeFieldStop();
   xfer += oprot->writeStructEnd();
   return xfer;
 }
 
+void swap(HiveServerException &a, HiveServerException &b) {
+  using ::std::swap;
+  swap(a.message, b.message);
+  swap(a.errorCode, b.errorCode);
+  swap(a.SQLState, b.SQLState);
+  swap(a.__isset, b.__isset);
+}
+
 }}} // namespace

Modified: hive/trunk/service/src/gen/thrift/gen-cpp/hive_service_types.h
URL: http://svn.apache.org/viewvc/hive/trunk/service/src/gen/thrift/gen-cpp/hive_service_types.h?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/service/src/gen/thrift/gen-cpp/hive_service_types.h (original)
+++ hive/trunk/service/src/gen/thrift/gen-cpp/hive_service_types.h Thu Nov  8 09:44:19 2012
@@ -1,15 +1,16 @@
 /**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *  @generated
  */
 #ifndef hive_service_TYPES_H
 #define hive_service_TYPES_H
 
-#include <Thrift.h>
-#include <TApplicationException.h>
-#include <protocol/TProtocol.h>
-#include <transport/TTransport.h>
+#include <thrift/Thrift.h>
+#include <thrift/TApplicationException.h>
+#include <thrift/protocol/TProtocol.h>
+#include <thrift/transport/TTransport.h>
 
 #include "fb303_types.h"
 #include "hive_metastore_types.h"
@@ -43,7 +44,7 @@ class HiveClusterStatus {
   static const char* ascii_fingerprint; // = "D514EDCFFC86F64A2E924DCD16D4FAD8";
   static const uint8_t binary_fingerprint[16]; // = {0xD5,0x14,0xED,0xCF,0xFC,0x86,0xF6,0x4A,0x2E,0x92,0x4D,0xCD,0x16,0xD4,0xFA,0xD8};
 
-  HiveClusterStatus() : taskTrackers(0), mapTasks(0), reduceTasks(0), maxMapTasks(0), maxReduceTasks(0) {
+  HiveClusterStatus() : taskTrackers(0), mapTasks(0), reduceTasks(0), maxMapTasks(0), maxReduceTasks(0), state((JobTrackerState::type)0) {
   }
 
   virtual ~HiveClusterStatus() throw() {}
@@ -108,6 +109,8 @@ class HiveClusterStatus {
 
 };
 
+void swap(HiveClusterStatus &a, HiveClusterStatus &b);
+
 typedef struct _HiveServerException__isset {
   _HiveServerException__isset() : message(false), errorCode(false), SQLState(false) {}
   bool message;
@@ -121,7 +124,7 @@ class HiveServerException : public ::apa
   static const char* ascii_fingerprint; // = "70563A0628F75DF9555F4D24690B1E26";
   static const uint8_t binary_fingerprint[16]; // = {0x70,0x56,0x3A,0x06,0x28,0xF7,0x5D,0xF9,0x55,0x5F,0x4D,0x24,0x69,0x0B,0x1E,0x26};
 
-  HiveServerException() : message(""), errorCode(0), SQLState("") {
+  HiveServerException() : message(), errorCode(0), SQLState() {
   }
 
   virtual ~HiveServerException() throw() {}
@@ -165,6 +168,8 @@ class HiveServerException : public ::apa
 
 };
 
+void swap(HiveServerException &a, HiveServerException &b);
+
 }}} // namespace
 
 #endif

Modified: hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/HiveClusterStatus.java
URL: http://svn.apache.org/viewvc/hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/HiveClusterStatus.java?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/HiveClusterStatus.java (original)
+++ hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/HiveClusterStatus.java Thu Nov  8 09:44:19 2012
@@ -1,11 +1,21 @@
 /**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *  @generated
  */
 package org.apache.hadoop.hive.service;
 
 import org.apache.commons.lang.builder.HashCodeBuilder;
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
 import java.util.List;
 import java.util.ArrayList;
 import java.util.Map;
@@ -31,6 +41,12 @@ public class HiveClusterStatus implement
   private static final org.apache.thrift.protocol.TField MAX_REDUCE_TASKS_FIELD_DESC = new org.apache.thrift.protocol.TField("maxReduceTasks", org.apache.thrift.protocol.TType.I32, (short)5);
   private static final org.apache.thrift.protocol.TField STATE_FIELD_DESC = new org.apache.thrift.protocol.TField("state", org.apache.thrift.protocol.TType.I32, (short)6);
 
+  private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+  static {
+    schemes.put(StandardScheme.class, new HiveClusterStatusStandardSchemeFactory());
+    schemes.put(TupleScheme.class, new HiveClusterStatusTupleSchemeFactory());
+  }
+
   private int taskTrackers; // required
   private int mapTasks; // required
   private int reduceTasks; // required
@@ -121,8 +137,7 @@ public class HiveClusterStatus implement
   private static final int __REDUCETASKS_ISSET_ID = 2;
   private static final int __MAXMAPTASKS_ISSET_ID = 3;
   private static final int __MAXREDUCETASKS_ISSET_ID = 4;
-  private BitSet __isset_bit_vector = new BitSet(5);
-
+  private byte __isset_bitfield = 0;
   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);
@@ -171,8 +186,7 @@ public class HiveClusterStatus implement
    * Performs a deep copy on <i>other</i>.
    */
   public HiveClusterStatus(HiveClusterStatus other) {
-    __isset_bit_vector.clear();
-    __isset_bit_vector.or(other.__isset_bit_vector);
+    __isset_bitfield = other.__isset_bitfield;
     this.taskTrackers = other.taskTrackers;
     this.mapTasks = other.mapTasks;
     this.reduceTasks = other.reduceTasks;
@@ -212,16 +226,16 @@ public class HiveClusterStatus implement
   }
 
   public void unsetTaskTrackers() {
-    __isset_bit_vector.clear(__TASKTRACKERS_ISSET_ID);
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TASKTRACKERS_ISSET_ID);
   }
 
   /** Returns true if field taskTrackers is set (has been assigned a value) and false otherwise */
   public boolean isSetTaskTrackers() {
-    return __isset_bit_vector.get(__TASKTRACKERS_ISSET_ID);
+    return EncodingUtils.testBit(__isset_bitfield, __TASKTRACKERS_ISSET_ID);
   }
 
   public void setTaskTrackersIsSet(boolean value) {
-    __isset_bit_vector.set(__TASKTRACKERS_ISSET_ID, value);
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TASKTRACKERS_ISSET_ID, value);
   }
 
   public int getMapTasks() {
@@ -234,16 +248,16 @@ public class HiveClusterStatus implement
   }
 
   public void unsetMapTasks() {
-    __isset_bit_vector.clear(__MAPTASKS_ISSET_ID);
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MAPTASKS_ISSET_ID);
   }
 
   /** Returns true if field mapTasks is set (has been assigned a value) and false otherwise */
   public boolean isSetMapTasks() {
-    return __isset_bit_vector.get(__MAPTASKS_ISSET_ID);
+    return EncodingUtils.testBit(__isset_bitfield, __MAPTASKS_ISSET_ID);
   }
 
   public void setMapTasksIsSet(boolean value) {
-    __isset_bit_vector.set(__MAPTASKS_ISSET_ID, value);
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MAPTASKS_ISSET_ID, value);
   }
 
   public int getReduceTasks() {
@@ -256,16 +270,16 @@ public class HiveClusterStatus implement
   }
 
   public void unsetReduceTasks() {
-    __isset_bit_vector.clear(__REDUCETASKS_ISSET_ID);
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __REDUCETASKS_ISSET_ID);
   }
 
   /** Returns true if field reduceTasks is set (has been assigned a value) and false otherwise */
   public boolean isSetReduceTasks() {
-    return __isset_bit_vector.get(__REDUCETASKS_ISSET_ID);
+    return EncodingUtils.testBit(__isset_bitfield, __REDUCETASKS_ISSET_ID);
   }
 
   public void setReduceTasksIsSet(boolean value) {
-    __isset_bit_vector.set(__REDUCETASKS_ISSET_ID, value);
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __REDUCETASKS_ISSET_ID, value);
   }
 
   public int getMaxMapTasks() {
@@ -278,16 +292,16 @@ public class HiveClusterStatus implement
   }
 
   public void unsetMaxMapTasks() {
-    __isset_bit_vector.clear(__MAXMAPTASKS_ISSET_ID);
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MAXMAPTASKS_ISSET_ID);
   }
 
   /** Returns true if field maxMapTasks is set (has been assigned a value) and false otherwise */
   public boolean isSetMaxMapTasks() {
-    return __isset_bit_vector.get(__MAXMAPTASKS_ISSET_ID);
+    return EncodingUtils.testBit(__isset_bitfield, __MAXMAPTASKS_ISSET_ID);
   }
 
   public void setMaxMapTasksIsSet(boolean value) {
-    __isset_bit_vector.set(__MAXMAPTASKS_ISSET_ID, value);
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MAXMAPTASKS_ISSET_ID, value);
   }
 
   public int getMaxReduceTasks() {
@@ -300,16 +314,16 @@ public class HiveClusterStatus implement
   }
 
   public void unsetMaxReduceTasks() {
-    __isset_bit_vector.clear(__MAXREDUCETASKS_ISSET_ID);
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MAXREDUCETASKS_ISSET_ID);
   }
 
   /** Returns true if field maxReduceTasks is set (has been assigned a value) and false otherwise */
   public boolean isSetMaxReduceTasks() {
-    return __isset_bit_vector.get(__MAXREDUCETASKS_ISSET_ID);
+    return EncodingUtils.testBit(__isset_bitfield, __MAXREDUCETASKS_ISSET_ID);
   }
 
   public void setMaxReduceTasksIsSet(boolean value) {
-    __isset_bit_vector.set(__MAXREDUCETASKS_ISSET_ID, value);
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MAXREDUCETASKS_ISSET_ID, value);
   }
 
   /**
@@ -626,97 +640,11 @@ public class HiveClusterStatus implement
   }
 
   public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
-    org.apache.thrift.protocol.TField field;
-    iprot.readStructBegin();
-    while (true)
-    {
-      field = iprot.readFieldBegin();
-      if (field.type == org.apache.thrift.protocol.TType.STOP) { 
-        break;
-      }
-      switch (field.id) {
-        case 1: // TASK_TRACKERS
-          if (field.type == org.apache.thrift.protocol.TType.I32) {
-            this.taskTrackers = iprot.readI32();
-            setTaskTrackersIsSet(true);
-          } else { 
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-          }
-          break;
-        case 2: // MAP_TASKS
-          if (field.type == org.apache.thrift.protocol.TType.I32) {
-            this.mapTasks = iprot.readI32();
-            setMapTasksIsSet(true);
-          } else { 
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-          }
-          break;
-        case 3: // REDUCE_TASKS
-          if (field.type == org.apache.thrift.protocol.TType.I32) {
-            this.reduceTasks = iprot.readI32();
-            setReduceTasksIsSet(true);
-          } else { 
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-          }
-          break;
-        case 4: // MAX_MAP_TASKS
-          if (field.type == org.apache.thrift.protocol.TType.I32) {
-            this.maxMapTasks = iprot.readI32();
-            setMaxMapTasksIsSet(true);
-          } else { 
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-          }
-          break;
-        case 5: // MAX_REDUCE_TASKS
-          if (field.type == org.apache.thrift.protocol.TType.I32) {
-            this.maxReduceTasks = iprot.readI32();
-            setMaxReduceTasksIsSet(true);
-          } else { 
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-          }
-          break;
-        case 6: // STATE
-          if (field.type == org.apache.thrift.protocol.TType.I32) {
-            this.state = JobTrackerState.findByValue(iprot.readI32());
-          } else { 
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-          }
-          break;
-        default:
-          org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-      }
-      iprot.readFieldEnd();
-    }
-    iprot.readStructEnd();
-    validate();
+    schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
   }
 
   public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
-    validate();
-
-    oprot.writeStructBegin(STRUCT_DESC);
-    oprot.writeFieldBegin(TASK_TRACKERS_FIELD_DESC);
-    oprot.writeI32(this.taskTrackers);
-    oprot.writeFieldEnd();
-    oprot.writeFieldBegin(MAP_TASKS_FIELD_DESC);
-    oprot.writeI32(this.mapTasks);
-    oprot.writeFieldEnd();
-    oprot.writeFieldBegin(REDUCE_TASKS_FIELD_DESC);
-    oprot.writeI32(this.reduceTasks);
-    oprot.writeFieldEnd();
-    oprot.writeFieldBegin(MAX_MAP_TASKS_FIELD_DESC);
-    oprot.writeI32(this.maxMapTasks);
-    oprot.writeFieldEnd();
-    oprot.writeFieldBegin(MAX_REDUCE_TASKS_FIELD_DESC);
-    oprot.writeI32(this.maxReduceTasks);
-    oprot.writeFieldEnd();
-    if (this.state != null) {
-      oprot.writeFieldBegin(STATE_FIELD_DESC);
-      oprot.writeI32(this.state.getValue());
-      oprot.writeFieldEnd();
-    }
-    oprot.writeFieldStop();
-    oprot.writeStructEnd();
+    schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
   }
 
   @Override
@@ -757,6 +685,7 @@ public class HiveClusterStatus implement
 
   public void validate() throws org.apache.thrift.TException {
     // check for required fields
+    // check for sub-struct validity
   }
 
   private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -770,12 +699,199 @@ public class HiveClusterStatus implement
   private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
     try {
       // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
-      __isset_bit_vector = new BitSet(1);
+      __isset_bitfield = 0;
       read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
     } catch (org.apache.thrift.TException te) {
       throw new java.io.IOException(te);
     }
   }
 
+  private static class HiveClusterStatusStandardSchemeFactory implements SchemeFactory {
+    public HiveClusterStatusStandardScheme getScheme() {
+      return new HiveClusterStatusStandardScheme();
+    }
+  }
+
+  private static class HiveClusterStatusStandardScheme extends StandardScheme<HiveClusterStatus> {
+
+    public void read(org.apache.thrift.protocol.TProtocol iprot, HiveClusterStatus struct) throws org.apache.thrift.TException {
+      org.apache.thrift.protocol.TField schemeField;
+      iprot.readStructBegin();
+      while (true)
+      {
+        schemeField = iprot.readFieldBegin();
+        if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
+          break;
+        }
+        switch (schemeField.id) {
+          case 1: // TASK_TRACKERS
+            if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+              struct.taskTrackers = iprot.readI32();
+              struct.setTaskTrackersIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 2: // MAP_TASKS
+            if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+              struct.mapTasks = iprot.readI32();
+              struct.setMapTasksIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 3: // REDUCE_TASKS
+            if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+              struct.reduceTasks = iprot.readI32();
+              struct.setReduceTasksIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 4: // MAX_MAP_TASKS
+            if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+              struct.maxMapTasks = iprot.readI32();
+              struct.setMaxMapTasksIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 5: // MAX_REDUCE_TASKS
+            if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+              struct.maxReduceTasks = iprot.readI32();
+              struct.setMaxReduceTasksIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 6: // STATE
+            if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+              struct.state = JobTrackerState.findByValue(iprot.readI32());
+              struct.setStateIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          default:
+            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+        }
+        iprot.readFieldEnd();
+      }
+      iprot.readStructEnd();
+      struct.validate();
+    }
+
+    public void write(org.apache.thrift.protocol.TProtocol oprot, HiveClusterStatus struct) throws org.apache.thrift.TException {
+      struct.validate();
+
+      oprot.writeStructBegin(STRUCT_DESC);
+      oprot.writeFieldBegin(TASK_TRACKERS_FIELD_DESC);
+      oprot.writeI32(struct.taskTrackers);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(MAP_TASKS_FIELD_DESC);
+      oprot.writeI32(struct.mapTasks);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(REDUCE_TASKS_FIELD_DESC);
+      oprot.writeI32(struct.reduceTasks);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(MAX_MAP_TASKS_FIELD_DESC);
+      oprot.writeI32(struct.maxMapTasks);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(MAX_REDUCE_TASKS_FIELD_DESC);
+      oprot.writeI32(struct.maxReduceTasks);
+      oprot.writeFieldEnd();
+      if (struct.state != null) {
+        oprot.writeFieldBegin(STATE_FIELD_DESC);
+        oprot.writeI32(struct.state.getValue());
+        oprot.writeFieldEnd();
+      }
+      oprot.writeFieldStop();
+      oprot.writeStructEnd();
+    }
+
+  }
+
+  private static class HiveClusterStatusTupleSchemeFactory implements SchemeFactory {
+    public HiveClusterStatusTupleScheme getScheme() {
+      return new HiveClusterStatusTupleScheme();
+    }
+  }
+
+  private static class HiveClusterStatusTupleScheme extends TupleScheme<HiveClusterStatus> {
+
+    @Override
+    public void write(org.apache.thrift.protocol.TProtocol prot, HiveClusterStatus struct) throws org.apache.thrift.TException {
+      TTupleProtocol oprot = (TTupleProtocol) prot;
+      BitSet optionals = new BitSet();
+      if (struct.isSetTaskTrackers()) {
+        optionals.set(0);
+      }
+      if (struct.isSetMapTasks()) {
+        optionals.set(1);
+      }
+      if (struct.isSetReduceTasks()) {
+        optionals.set(2);
+      }
+      if (struct.isSetMaxMapTasks()) {
+        optionals.set(3);
+      }
+      if (struct.isSetMaxReduceTasks()) {
+        optionals.set(4);
+      }
+      if (struct.isSetState()) {
+        optionals.set(5);
+      }
+      oprot.writeBitSet(optionals, 6);
+      if (struct.isSetTaskTrackers()) {
+        oprot.writeI32(struct.taskTrackers);
+      }
+      if (struct.isSetMapTasks()) {
+        oprot.writeI32(struct.mapTasks);
+      }
+      if (struct.isSetReduceTasks()) {
+        oprot.writeI32(struct.reduceTasks);
+      }
+      if (struct.isSetMaxMapTasks()) {
+        oprot.writeI32(struct.maxMapTasks);
+      }
+      if (struct.isSetMaxReduceTasks()) {
+        oprot.writeI32(struct.maxReduceTasks);
+      }
+      if (struct.isSetState()) {
+        oprot.writeI32(struct.state.getValue());
+      }
+    }
+
+    @Override
+    public void read(org.apache.thrift.protocol.TProtocol prot, HiveClusterStatus struct) throws org.apache.thrift.TException {
+      TTupleProtocol iprot = (TTupleProtocol) prot;
+      BitSet incoming = iprot.readBitSet(6);
+      if (incoming.get(0)) {
+        struct.taskTrackers = iprot.readI32();
+        struct.setTaskTrackersIsSet(true);
+      }
+      if (incoming.get(1)) {
+        struct.mapTasks = iprot.readI32();
+        struct.setMapTasksIsSet(true);
+      }
+      if (incoming.get(2)) {
+        struct.reduceTasks = iprot.readI32();
+        struct.setReduceTasksIsSet(true);
+      }
+      if (incoming.get(3)) {
+        struct.maxMapTasks = iprot.readI32();
+        struct.setMaxMapTasksIsSet(true);
+      }
+      if (incoming.get(4)) {
+        struct.maxReduceTasks = iprot.readI32();
+        struct.setMaxReduceTasksIsSet(true);
+      }
+      if (incoming.get(5)) {
+        struct.state = JobTrackerState.findByValue(iprot.readI32());
+        struct.setStateIsSet(true);
+      }
+    }
+  }
+
 }
 



Mime
View raw message