You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2012/11/08 10:44:29 UTC
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...
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);
+ }
+ }
+ }
+
}