http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/service/src/gen/thrift/gen-cpp/ThriftHive.cpp ---------------------------------------------------------------------- diff --git a/service/src/gen/thrift/gen-cpp/ThriftHive.cpp b/service/src/gen/thrift/gen-cpp/ThriftHive.cpp index a5448f0..8935c04 100644 --- a/service/src/gen/thrift/gen-cpp/ThriftHive.cpp +++ b/service/src/gen/thrift/gen-cpp/ThriftHive.cpp @@ -1,5 +1,5 @@ /** - * Autogenerated by Thrift Compiler (0.9.3) + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -15,7 +15,6 @@ ThriftHive_execute_args::~ThriftHive_execute_args() throw() { uint32_t ThriftHive_execute_args::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -56,7 +55,7 @@ uint32_t ThriftHive_execute_args::read(::apache::thrift::protocol::TProtocol* ip uint32_t ThriftHive_execute_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_execute_args"); xfer += oprot->writeFieldBegin("query", ::apache::thrift::protocol::T_STRING, 1); @@ -65,6 +64,7 @@ uint32_t ThriftHive_execute_args::write(::apache::thrift::protocol::TProtocol* o xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -75,7 +75,7 @@ ThriftHive_execute_pargs::~ThriftHive_execute_pargs() throw() { uint32_t ThriftHive_execute_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_execute_pargs"); xfer += oprot->writeFieldBegin("query", ::apache::thrift::protocol::T_STRING, 1); @@ -84,6 +84,7 @@ uint32_t ThriftHive_execute_pargs::write(::apache::thrift::protocol::TProtocol* xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -94,7 +95,6 @@ ThriftHive_execute_result::~ThriftHive_execute_result() throw() { uint32_t ThriftHive_execute_result::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -156,7 +156,6 @@ ThriftHive_execute_presult::~ThriftHive_execute_presult() throw() { uint32_t ThriftHive_execute_presult::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -202,7 +201,6 @@ ThriftHive_fetchOne_args::~ThriftHive_fetchOne_args() throw() { uint32_t ThriftHive_fetchOne_args::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -230,11 +228,12 @@ uint32_t ThriftHive_fetchOne_args::read(::apache::thrift::protocol::TProtocol* i uint32_t ThriftHive_fetchOne_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_fetchOne_args"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -245,11 +244,12 @@ ThriftHive_fetchOne_pargs::~ThriftHive_fetchOne_pargs() throw() { uint32_t ThriftHive_fetchOne_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_fetchOne_pargs"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -260,7 +260,6 @@ ThriftHive_fetchOne_result::~ThriftHive_fetchOne_result() throw() { uint32_t ThriftHive_fetchOne_result::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -334,7 +333,6 @@ ThriftHive_fetchOne_presult::~ThriftHive_fetchOne_presult() throw() { uint32_t ThriftHive_fetchOne_presult::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -388,7 +386,6 @@ ThriftHive_fetchN_args::~ThriftHive_fetchN_args() throw() { uint32_t ThriftHive_fetchN_args::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -429,7 +426,7 @@ uint32_t ThriftHive_fetchN_args::read(::apache::thrift::protocol::TProtocol* ipr uint32_t ThriftHive_fetchN_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_fetchN_args"); xfer += oprot->writeFieldBegin("numRows", ::apache::thrift::protocol::T_I32, 1); @@ -438,6 +435,7 @@ uint32_t ThriftHive_fetchN_args::write(::apache::thrift::protocol::TProtocol* op xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -448,7 +446,7 @@ ThriftHive_fetchN_pargs::~ThriftHive_fetchN_pargs() throw() { uint32_t ThriftHive_fetchN_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_fetchN_pargs"); xfer += oprot->writeFieldBegin("numRows", ::apache::thrift::protocol::T_I32, 1); @@ -457,6 +455,7 @@ uint32_t ThriftHive_fetchN_pargs::write(::apache::thrift::protocol::TProtocol* o xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -467,7 +466,6 @@ ThriftHive_fetchN_result::~ThriftHive_fetchN_result() throw() { uint32_t ThriftHive_fetchN_result::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -561,7 +559,6 @@ ThriftHive_fetchN_presult::~ThriftHive_fetchN_presult() throw() { uint32_t ThriftHive_fetchN_presult::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -627,7 +624,6 @@ ThriftHive_fetchAll_args::~ThriftHive_fetchAll_args() throw() { uint32_t ThriftHive_fetchAll_args::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -655,11 +651,12 @@ uint32_t ThriftHive_fetchAll_args::read(::apache::thrift::protocol::TProtocol* i uint32_t ThriftHive_fetchAll_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_fetchAll_args"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -670,11 +667,12 @@ ThriftHive_fetchAll_pargs::~ThriftHive_fetchAll_pargs() throw() { uint32_t ThriftHive_fetchAll_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_fetchAll_pargs"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -685,7 +683,6 @@ ThriftHive_fetchAll_result::~ThriftHive_fetchAll_result() throw() { uint32_t ThriftHive_fetchAll_result::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -779,7 +776,6 @@ ThriftHive_fetchAll_presult::~ThriftHive_fetchAll_presult() throw() { uint32_t ThriftHive_fetchAll_presult::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -845,7 +841,6 @@ ThriftHive_getSchema_args::~ThriftHive_getSchema_args() throw() { uint32_t ThriftHive_getSchema_args::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -873,11 +868,12 @@ uint32_t ThriftHive_getSchema_args::read(::apache::thrift::protocol::TProtocol* uint32_t ThriftHive_getSchema_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_getSchema_args"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -888,11 +884,12 @@ ThriftHive_getSchema_pargs::~ThriftHive_getSchema_pargs() throw() { uint32_t ThriftHive_getSchema_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_getSchema_pargs"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -903,7 +900,6 @@ ThriftHive_getSchema_result::~ThriftHive_getSchema_result() throw() { uint32_t ThriftHive_getSchema_result::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -977,7 +973,6 @@ ThriftHive_getSchema_presult::~ThriftHive_getSchema_presult() throw() { uint32_t ThriftHive_getSchema_presult::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -1031,7 +1026,6 @@ ThriftHive_getThriftSchema_args::~ThriftHive_getThriftSchema_args() throw() { uint32_t ThriftHive_getThriftSchema_args::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -1059,11 +1053,12 @@ uint32_t ThriftHive_getThriftSchema_args::read(::apache::thrift::protocol::TProt uint32_t ThriftHive_getThriftSchema_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_getThriftSchema_args"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -1074,11 +1069,12 @@ ThriftHive_getThriftSchema_pargs::~ThriftHive_getThriftSchema_pargs() throw() { uint32_t ThriftHive_getThriftSchema_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_getThriftSchema_pargs"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -1089,7 +1085,6 @@ ThriftHive_getThriftSchema_result::~ThriftHive_getThriftSchema_result() throw() uint32_t ThriftHive_getThriftSchema_result::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -1163,7 +1158,6 @@ ThriftHive_getThriftSchema_presult::~ThriftHive_getThriftSchema_presult() throw( uint32_t ThriftHive_getThriftSchema_presult::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -1217,7 +1211,6 @@ ThriftHive_getClusterStatus_args::~ThriftHive_getClusterStatus_args() throw() { uint32_t ThriftHive_getClusterStatus_args::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -1245,11 +1238,12 @@ uint32_t ThriftHive_getClusterStatus_args::read(::apache::thrift::protocol::TPro uint32_t ThriftHive_getClusterStatus_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_getClusterStatus_args"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -1260,11 +1254,12 @@ ThriftHive_getClusterStatus_pargs::~ThriftHive_getClusterStatus_pargs() throw() uint32_t ThriftHive_getClusterStatus_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_getClusterStatus_pargs"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -1275,7 +1270,6 @@ ThriftHive_getClusterStatus_result::~ThriftHive_getClusterStatus_result() throw( uint32_t ThriftHive_getClusterStatus_result::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -1349,7 +1343,6 @@ ThriftHive_getClusterStatus_presult::~ThriftHive_getClusterStatus_presult() thro uint32_t ThriftHive_getClusterStatus_presult::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -1403,7 +1396,6 @@ ThriftHive_getQueryPlan_args::~ThriftHive_getQueryPlan_args() throw() { uint32_t ThriftHive_getQueryPlan_args::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -1431,11 +1423,12 @@ uint32_t ThriftHive_getQueryPlan_args::read(::apache::thrift::protocol::TProtoco uint32_t ThriftHive_getQueryPlan_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_getQueryPlan_args"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -1446,11 +1439,12 @@ ThriftHive_getQueryPlan_pargs::~ThriftHive_getQueryPlan_pargs() throw() { uint32_t ThriftHive_getQueryPlan_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_getQueryPlan_pargs"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -1461,7 +1455,6 @@ ThriftHive_getQueryPlan_result::~ThriftHive_getQueryPlan_result() throw() { uint32_t ThriftHive_getQueryPlan_result::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -1535,7 +1528,6 @@ ThriftHive_getQueryPlan_presult::~ThriftHive_getQueryPlan_presult() throw() { uint32_t ThriftHive_getQueryPlan_presult::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -1589,7 +1581,6 @@ ThriftHive_clean_args::~ThriftHive_clean_args() throw() { uint32_t ThriftHive_clean_args::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -1617,11 +1608,12 @@ uint32_t ThriftHive_clean_args::read(::apache::thrift::protocol::TProtocol* ipro uint32_t ThriftHive_clean_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_clean_args"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -1632,11 +1624,12 @@ ThriftHive_clean_pargs::~ThriftHive_clean_pargs() throw() { uint32_t ThriftHive_clean_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_clean_pargs"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -1647,7 +1640,6 @@ ThriftHive_clean_result::~ThriftHive_clean_result() throw() { uint32_t ThriftHive_clean_result::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -1691,7 +1683,6 @@ ThriftHive_clean_presult::~ThriftHive_clean_presult() throw() { uint32_t ThriftHive_clean_presult::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -2770,775 +2761,5 @@ void ThriftHiveProcessor::process_clean(int32_t seqid, ::apache::thrift::protoco ::boost::shared_ptr< ::apache::thrift::TProcessor > processor(new ThriftHiveProcessor(handler)); return processor; } - -void ThriftHiveConcurrentClient::execute(const std::string& query) -{ - int32_t seqid = send_execute(query); - recv_execute(seqid); -} - -int32_t ThriftHiveConcurrentClient::send_execute(const std::string& query) -{ - int32_t cseqid = this->sync_.generateSeqId(); - ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); - oprot_->writeMessageBegin("execute", ::apache::thrift::protocol::T_CALL, cseqid); - - ThriftHive_execute_pargs args; - args.query = &query; - args.write(oprot_); - - oprot_->writeMessageEnd(); - oprot_->getTransport()->writeEnd(); - oprot_->getTransport()->flush(); - - sentry.commit(); - return cseqid; -} - -void ThriftHiveConcurrentClient::recv_execute(const int32_t seqid) -{ - - int32_t rseqid = 0; - std::string fname; - ::apache::thrift::protocol::TMessageType mtype; - - // the read mutex gets dropped and reacquired as part of waitForWork() - // The destructor of this sentry wakes up other clients - ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); - - while(true) { - if(!this->sync_.getPending(fname, mtype, rseqid)) { - iprot_->readMessageBegin(fname, mtype, rseqid); - } - if(seqid == rseqid) { - if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { - ::apache::thrift::TApplicationException x; - x.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - sentry.commit(); - throw x; - } - if (mtype != ::apache::thrift::protocol::T_REPLY) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - } - if (fname.compare("execute") != 0) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - - // in a bad state, don't commit - using ::apache::thrift::protocol::TProtocolException; - throw TProtocolException(TProtocolException::INVALID_DATA); - } - ThriftHive_execute_presult result; - result.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - - if (result.__isset.ex) { - sentry.commit(); - throw result.ex; - } - sentry.commit(); - return; - } - // seqid != rseqid - this->sync_.updatePending(fname, mtype, rseqid); - - // this will temporarily unlock the readMutex, and let other clients get work done - this->sync_.waitForWork(seqid); - } // end while(true) -} - -void ThriftHiveConcurrentClient::fetchOne(std::string& _return) -{ - int32_t seqid = send_fetchOne(); - recv_fetchOne(_return, seqid); -} - -int32_t ThriftHiveConcurrentClient::send_fetchOne() -{ - int32_t cseqid = this->sync_.generateSeqId(); - ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); - oprot_->writeMessageBegin("fetchOne", ::apache::thrift::protocol::T_CALL, cseqid); - - ThriftHive_fetchOne_pargs args; - args.write(oprot_); - - oprot_->writeMessageEnd(); - oprot_->getTransport()->writeEnd(); - oprot_->getTransport()->flush(); - - sentry.commit(); - return cseqid; -} - -void ThriftHiveConcurrentClient::recv_fetchOne(std::string& _return, const int32_t seqid) -{ - - int32_t rseqid = 0; - std::string fname; - ::apache::thrift::protocol::TMessageType mtype; - - // the read mutex gets dropped and reacquired as part of waitForWork() - // The destructor of this sentry wakes up other clients - ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); - - while(true) { - if(!this->sync_.getPending(fname, mtype, rseqid)) { - iprot_->readMessageBegin(fname, mtype, rseqid); - } - if(seqid == rseqid) { - if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { - ::apache::thrift::TApplicationException x; - x.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - sentry.commit(); - throw x; - } - if (mtype != ::apache::thrift::protocol::T_REPLY) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - } - if (fname.compare("fetchOne") != 0) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - - // in a bad state, don't commit - using ::apache::thrift::protocol::TProtocolException; - throw TProtocolException(TProtocolException::INVALID_DATA); - } - ThriftHive_fetchOne_presult result; - result.success = &_return; - result.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - - if (result.__isset.success) { - // _return pointer has now been filled - sentry.commit(); - return; - } - if (result.__isset.ex) { - sentry.commit(); - throw result.ex; - } - // in a bad state, don't commit - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "fetchOne failed: unknown result"); - } - // seqid != rseqid - this->sync_.updatePending(fname, mtype, rseqid); - - // this will temporarily unlock the readMutex, and let other clients get work done - this->sync_.waitForWork(seqid); - } // end while(true) -} - -void ThriftHiveConcurrentClient::fetchN(std::vector<std::string> & _return, const int32_t numRows) -{ - int32_t seqid = send_fetchN(numRows); - recv_fetchN(_return, seqid); -} - -int32_t ThriftHiveConcurrentClient::send_fetchN(const int32_t numRows) -{ - int32_t cseqid = this->sync_.generateSeqId(); - ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); - oprot_->writeMessageBegin("fetchN", ::apache::thrift::protocol::T_CALL, cseqid); - - ThriftHive_fetchN_pargs args; - args.numRows = &numRows; - args.write(oprot_); - - oprot_->writeMessageEnd(); - oprot_->getTransport()->writeEnd(); - oprot_->getTransport()->flush(); - - sentry.commit(); - return cseqid; -} - -void ThriftHiveConcurrentClient::recv_fetchN(std::vector<std::string> & _return, const int32_t seqid) -{ - - int32_t rseqid = 0; - std::string fname; - ::apache::thrift::protocol::TMessageType mtype; - - // the read mutex gets dropped and reacquired as part of waitForWork() - // The destructor of this sentry wakes up other clients - ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); - - while(true) { - if(!this->sync_.getPending(fname, mtype, rseqid)) { - iprot_->readMessageBegin(fname, mtype, rseqid); - } - if(seqid == rseqid) { - if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { - ::apache::thrift::TApplicationException x; - x.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - sentry.commit(); - throw x; - } - if (mtype != ::apache::thrift::protocol::T_REPLY) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - } - if (fname.compare("fetchN") != 0) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - - // in a bad state, don't commit - using ::apache::thrift::protocol::TProtocolException; - throw TProtocolException(TProtocolException::INVALID_DATA); - } - ThriftHive_fetchN_presult result; - result.success = &_return; - result.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - - if (result.__isset.success) { - // _return pointer has now been filled - sentry.commit(); - return; - } - if (result.__isset.ex) { - sentry.commit(); - throw result.ex; - } - // in a bad state, don't commit - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "fetchN failed: unknown result"); - } - // seqid != rseqid - this->sync_.updatePending(fname, mtype, rseqid); - - // this will temporarily unlock the readMutex, and let other clients get work done - this->sync_.waitForWork(seqid); - } // end while(true) -} - -void ThriftHiveConcurrentClient::fetchAll(std::vector<std::string> & _return) -{ - int32_t seqid = send_fetchAll(); - recv_fetchAll(_return, seqid); -} - -int32_t ThriftHiveConcurrentClient::send_fetchAll() -{ - int32_t cseqid = this->sync_.generateSeqId(); - ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); - oprot_->writeMessageBegin("fetchAll", ::apache::thrift::protocol::T_CALL, cseqid); - - ThriftHive_fetchAll_pargs args; - args.write(oprot_); - - oprot_->writeMessageEnd(); - oprot_->getTransport()->writeEnd(); - oprot_->getTransport()->flush(); - - sentry.commit(); - return cseqid; -} - -void ThriftHiveConcurrentClient::recv_fetchAll(std::vector<std::string> & _return, const int32_t seqid) -{ - - int32_t rseqid = 0; - std::string fname; - ::apache::thrift::protocol::TMessageType mtype; - - // the read mutex gets dropped and reacquired as part of waitForWork() - // The destructor of this sentry wakes up other clients - ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); - - while(true) { - if(!this->sync_.getPending(fname, mtype, rseqid)) { - iprot_->readMessageBegin(fname, mtype, rseqid); - } - if(seqid == rseqid) { - if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { - ::apache::thrift::TApplicationException x; - x.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - sentry.commit(); - throw x; - } - if (mtype != ::apache::thrift::protocol::T_REPLY) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - } - if (fname.compare("fetchAll") != 0) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - - // in a bad state, don't commit - using ::apache::thrift::protocol::TProtocolException; - throw TProtocolException(TProtocolException::INVALID_DATA); - } - ThriftHive_fetchAll_presult result; - result.success = &_return; - result.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - - if (result.__isset.success) { - // _return pointer has now been filled - sentry.commit(); - return; - } - if (result.__isset.ex) { - sentry.commit(); - throw result.ex; - } - // in a bad state, don't commit - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "fetchAll failed: unknown result"); - } - // seqid != rseqid - this->sync_.updatePending(fname, mtype, rseqid); - - // this will temporarily unlock the readMutex, and let other clients get work done - this->sync_.waitForWork(seqid); - } // end while(true) -} - -void ThriftHiveConcurrentClient::getSchema( ::Apache::Hadoop::Hive::Schema& _return) -{ - int32_t seqid = send_getSchema(); - recv_getSchema(_return, seqid); -} - -int32_t ThriftHiveConcurrentClient::send_getSchema() -{ - int32_t cseqid = this->sync_.generateSeqId(); - ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); - oprot_->writeMessageBegin("getSchema", ::apache::thrift::protocol::T_CALL, cseqid); - - ThriftHive_getSchema_pargs args; - args.write(oprot_); - - oprot_->writeMessageEnd(); - oprot_->getTransport()->writeEnd(); - oprot_->getTransport()->flush(); - - sentry.commit(); - return cseqid; -} - -void ThriftHiveConcurrentClient::recv_getSchema( ::Apache::Hadoop::Hive::Schema& _return, const int32_t seqid) -{ - - int32_t rseqid = 0; - std::string fname; - ::apache::thrift::protocol::TMessageType mtype; - - // the read mutex gets dropped and reacquired as part of waitForWork() - // The destructor of this sentry wakes up other clients - ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); - - while(true) { - if(!this->sync_.getPending(fname, mtype, rseqid)) { - iprot_->readMessageBegin(fname, mtype, rseqid); - } - if(seqid == rseqid) { - if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { - ::apache::thrift::TApplicationException x; - x.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - sentry.commit(); - throw x; - } - if (mtype != ::apache::thrift::protocol::T_REPLY) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - } - if (fname.compare("getSchema") != 0) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - - // in a bad state, don't commit - using ::apache::thrift::protocol::TProtocolException; - throw TProtocolException(TProtocolException::INVALID_DATA); - } - ThriftHive_getSchema_presult result; - result.success = &_return; - result.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - - if (result.__isset.success) { - // _return pointer has now been filled - sentry.commit(); - return; - } - if (result.__isset.ex) { - sentry.commit(); - throw result.ex; - } - // in a bad state, don't commit - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getSchema failed: unknown result"); - } - // seqid != rseqid - this->sync_.updatePending(fname, mtype, rseqid); - - // this will temporarily unlock the readMutex, and let other clients get work done - this->sync_.waitForWork(seqid); - } // end while(true) -} - -void ThriftHiveConcurrentClient::getThriftSchema( ::Apache::Hadoop::Hive::Schema& _return) -{ - int32_t seqid = send_getThriftSchema(); - recv_getThriftSchema(_return, seqid); -} - -int32_t ThriftHiveConcurrentClient::send_getThriftSchema() -{ - int32_t cseqid = this->sync_.generateSeqId(); - ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); - oprot_->writeMessageBegin("getThriftSchema", ::apache::thrift::protocol::T_CALL, cseqid); - - ThriftHive_getThriftSchema_pargs args; - args.write(oprot_); - - oprot_->writeMessageEnd(); - oprot_->getTransport()->writeEnd(); - oprot_->getTransport()->flush(); - - sentry.commit(); - return cseqid; -} - -void ThriftHiveConcurrentClient::recv_getThriftSchema( ::Apache::Hadoop::Hive::Schema& _return, const int32_t seqid) -{ - - int32_t rseqid = 0; - std::string fname; - ::apache::thrift::protocol::TMessageType mtype; - - // the read mutex gets dropped and reacquired as part of waitForWork() - // The destructor of this sentry wakes up other clients - ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); - - while(true) { - if(!this->sync_.getPending(fname, mtype, rseqid)) { - iprot_->readMessageBegin(fname, mtype, rseqid); - } - if(seqid == rseqid) { - if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { - ::apache::thrift::TApplicationException x; - x.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - sentry.commit(); - throw x; - } - if (mtype != ::apache::thrift::protocol::T_REPLY) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - } - if (fname.compare("getThriftSchema") != 0) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - - // in a bad state, don't commit - using ::apache::thrift::protocol::TProtocolException; - throw TProtocolException(TProtocolException::INVALID_DATA); - } - ThriftHive_getThriftSchema_presult result; - result.success = &_return; - result.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - - if (result.__isset.success) { - // _return pointer has now been filled - sentry.commit(); - return; - } - if (result.__isset.ex) { - sentry.commit(); - throw result.ex; - } - // in a bad state, don't commit - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getThriftSchema failed: unknown result"); - } - // seqid != rseqid - this->sync_.updatePending(fname, mtype, rseqid); - - // this will temporarily unlock the readMutex, and let other clients get work done - this->sync_.waitForWork(seqid); - } // end while(true) -} - -void ThriftHiveConcurrentClient::getClusterStatus(HiveClusterStatus& _return) -{ - int32_t seqid = send_getClusterStatus(); - recv_getClusterStatus(_return, seqid); -} - -int32_t ThriftHiveConcurrentClient::send_getClusterStatus() -{ - int32_t cseqid = this->sync_.generateSeqId(); - ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); - oprot_->writeMessageBegin("getClusterStatus", ::apache::thrift::protocol::T_CALL, cseqid); - - ThriftHive_getClusterStatus_pargs args; - args.write(oprot_); - - oprot_->writeMessageEnd(); - oprot_->getTransport()->writeEnd(); - oprot_->getTransport()->flush(); - - sentry.commit(); - return cseqid; -} - -void ThriftHiveConcurrentClient::recv_getClusterStatus(HiveClusterStatus& _return, const int32_t seqid) -{ - - int32_t rseqid = 0; - std::string fname; - ::apache::thrift::protocol::TMessageType mtype; - - // the read mutex gets dropped and reacquired as part of waitForWork() - // The destructor of this sentry wakes up other clients - ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); - - while(true) { - if(!this->sync_.getPending(fname, mtype, rseqid)) { - iprot_->readMessageBegin(fname, mtype, rseqid); - } - if(seqid == rseqid) { - if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { - ::apache::thrift::TApplicationException x; - x.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - sentry.commit(); - throw x; - } - if (mtype != ::apache::thrift::protocol::T_REPLY) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - } - if (fname.compare("getClusterStatus") != 0) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - - // in a bad state, don't commit - using ::apache::thrift::protocol::TProtocolException; - throw TProtocolException(TProtocolException::INVALID_DATA); - } - ThriftHive_getClusterStatus_presult result; - result.success = &_return; - result.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - - if (result.__isset.success) { - // _return pointer has now been filled - sentry.commit(); - return; - } - if (result.__isset.ex) { - sentry.commit(); - throw result.ex; - } - // in a bad state, don't commit - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getClusterStatus failed: unknown result"); - } - // seqid != rseqid - this->sync_.updatePending(fname, mtype, rseqid); - - // this will temporarily unlock the readMutex, and let other clients get work done - this->sync_.waitForWork(seqid); - } // end while(true) -} - -void ThriftHiveConcurrentClient::getQueryPlan( ::Apache::Hadoop::Hive::QueryPlan& _return) -{ - int32_t seqid = send_getQueryPlan(); - recv_getQueryPlan(_return, seqid); -} - -int32_t ThriftHiveConcurrentClient::send_getQueryPlan() -{ - int32_t cseqid = this->sync_.generateSeqId(); - ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); - oprot_->writeMessageBegin("getQueryPlan", ::apache::thrift::protocol::T_CALL, cseqid); - - ThriftHive_getQueryPlan_pargs args; - args.write(oprot_); - - oprot_->writeMessageEnd(); - oprot_->getTransport()->writeEnd(); - oprot_->getTransport()->flush(); - - sentry.commit(); - return cseqid; -} - -void ThriftHiveConcurrentClient::recv_getQueryPlan( ::Apache::Hadoop::Hive::QueryPlan& _return, const int32_t seqid) -{ - - int32_t rseqid = 0; - std::string fname; - ::apache::thrift::protocol::TMessageType mtype; - - // the read mutex gets dropped and reacquired as part of waitForWork() - // The destructor of this sentry wakes up other clients - ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); - - while(true) { - if(!this->sync_.getPending(fname, mtype, rseqid)) { - iprot_->readMessageBegin(fname, mtype, rseqid); - } - if(seqid == rseqid) { - if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { - ::apache::thrift::TApplicationException x; - x.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - sentry.commit(); - throw x; - } - if (mtype != ::apache::thrift::protocol::T_REPLY) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - } - if (fname.compare("getQueryPlan") != 0) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - - // in a bad state, don't commit - using ::apache::thrift::protocol::TProtocolException; - throw TProtocolException(TProtocolException::INVALID_DATA); - } - ThriftHive_getQueryPlan_presult result; - result.success = &_return; - result.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - - if (result.__isset.success) { - // _return pointer has now been filled - sentry.commit(); - return; - } - if (result.__isset.ex) { - sentry.commit(); - throw result.ex; - } - // in a bad state, don't commit - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getQueryPlan failed: unknown result"); - } - // seqid != rseqid - this->sync_.updatePending(fname, mtype, rseqid); - - // this will temporarily unlock the readMutex, and let other clients get work done - this->sync_.waitForWork(seqid); - } // end while(true) -} - -void ThriftHiveConcurrentClient::clean() -{ - int32_t seqid = send_clean(); - recv_clean(seqid); -} - -int32_t ThriftHiveConcurrentClient::send_clean() -{ - int32_t cseqid = this->sync_.generateSeqId(); - ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); - oprot_->writeMessageBegin("clean", ::apache::thrift::protocol::T_CALL, cseqid); - - ThriftHive_clean_pargs args; - args.write(oprot_); - - oprot_->writeMessageEnd(); - oprot_->getTransport()->writeEnd(); - oprot_->getTransport()->flush(); - - sentry.commit(); - return cseqid; -} - -void ThriftHiveConcurrentClient::recv_clean(const int32_t seqid) -{ - - int32_t rseqid = 0; - std::string fname; - ::apache::thrift::protocol::TMessageType mtype; - - // the read mutex gets dropped and reacquired as part of waitForWork() - // The destructor of this sentry wakes up other clients - ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); - - while(true) { - if(!this->sync_.getPending(fname, mtype, rseqid)) { - iprot_->readMessageBegin(fname, mtype, rseqid); - } - if(seqid == rseqid) { - if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { - ::apache::thrift::TApplicationException x; - x.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - sentry.commit(); - throw x; - } - if (mtype != ::apache::thrift::protocol::T_REPLY) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - } - if (fname.compare("clean") != 0) { - iprot_->skip(::apache::thrift::protocol::T_STRUCT); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - - // in a bad state, don't commit - using ::apache::thrift::protocol::TProtocolException; - throw TProtocolException(TProtocolException::INVALID_DATA); - } - ThriftHive_clean_presult result; - result.read(iprot_); - iprot_->readMessageEnd(); - iprot_->getTransport()->readEnd(); - - sentry.commit(); - return; - } - // seqid != rseqid - this->sync_.updatePending(fname, mtype, rseqid); - - // this will temporarily unlock the readMutex, and let other clients get work done - this->sync_.waitForWork(seqid); - } // end while(true) -} - }}} // namespace
http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/service/src/gen/thrift/gen-cpp/ThriftHive.h ---------------------------------------------------------------------- diff --git a/service/src/gen/thrift/gen-cpp/ThriftHive.h b/service/src/gen/thrift/gen-cpp/ThriftHive.h index 902bd4b..e610e50 100644 --- a/service/src/gen/thrift/gen-cpp/ThriftHive.h +++ b/service/src/gen/thrift/gen-cpp/ThriftHive.h @@ -1,5 +1,5 @@ /** - * Autogenerated by Thrift Compiler (0.9.3) + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -8,17 +8,11 @@ #define ThriftHive_H #include <thrift/TDispatchProcessor.h> -#include <thrift/async/TConcurrentClientSyncInfo.h> #include "hive_service_types.h" #include "ThriftHiveMetastore.h" namespace Apache { namespace Hadoop { namespace Hive { -#ifdef _WIN32 - #pragma warning( push ) - #pragma warning (disable : 4250 ) //inheriting methods via dominance -#endif - class ThriftHiveIf : virtual public ::Apache::Hadoop::Hive::ThriftHiveMetastoreIf { public: virtual ~ThriftHiveIf() {} @@ -97,6 +91,9 @@ typedef struct _ThriftHive_execute_args__isset { class ThriftHive_execute_args { public: + static const char* ascii_fingerprint; // = "EFB929595D312AC8F305D5A794CFEDA1"; + static const uint8_t binary_fingerprint[16]; // = {0xEF,0xB9,0x29,0x59,0x5D,0x31,0x2A,0xC8,0xF3,0x05,0xD5,0xA7,0x94,0xCF,0xED,0xA1}; + ThriftHive_execute_args(const ThriftHive_execute_args&); ThriftHive_execute_args& operator=(const ThriftHive_execute_args&); ThriftHive_execute_args() : query() { @@ -124,18 +121,23 @@ class ThriftHive_execute_args { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_execute_args& obj); }; class ThriftHive_execute_pargs { public: + static const char* ascii_fingerprint; // = "EFB929595D312AC8F305D5A794CFEDA1"; + static const uint8_t binary_fingerprint[16]; // = {0xEF,0xB9,0x29,0x59,0x5D,0x31,0x2A,0xC8,0xF3,0x05,0xD5,0xA7,0x94,0xCF,0xED,0xA1}; + virtual ~ThriftHive_execute_pargs() throw(); const std::string* query; uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_execute_pargs& obj); }; typedef struct _ThriftHive_execute_result__isset { @@ -146,6 +148,9 @@ typedef struct _ThriftHive_execute_result__isset { class ThriftHive_execute_result { public: + static const char* ascii_fingerprint; // = "6AC6FD61CA5E3524E0174B0B96D6F9C0"; + static const uint8_t binary_fingerprint[16]; // = {0x6A,0xC6,0xFD,0x61,0xCA,0x5E,0x35,0x24,0xE0,0x17,0x4B,0x0B,0x96,0xD6,0xF9,0xC0}; + ThriftHive_execute_result(const ThriftHive_execute_result&); ThriftHive_execute_result& operator=(const ThriftHive_execute_result&); ThriftHive_execute_result() { @@ -173,6 +178,7 @@ class ThriftHive_execute_result { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_execute_result& obj); }; typedef struct _ThriftHive_execute_presult__isset { @@ -183,6 +189,9 @@ typedef struct _ThriftHive_execute_presult__isset { class ThriftHive_execute_presult { public: + static const char* ascii_fingerprint; // = "6AC6FD61CA5E3524E0174B0B96D6F9C0"; + static const uint8_t binary_fingerprint[16]; // = {0x6A,0xC6,0xFD,0x61,0xCA,0x5E,0x35,0x24,0xE0,0x17,0x4B,0x0B,0x96,0xD6,0xF9,0xC0}; + virtual ~ThriftHive_execute_presult() throw(); HiveServerException ex; @@ -191,12 +200,16 @@ class ThriftHive_execute_presult { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_execute_presult& obj); }; class ThriftHive_fetchOne_args { public: + static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; + static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; + ThriftHive_fetchOne_args(const ThriftHive_fetchOne_args&); ThriftHive_fetchOne_args& operator=(const ThriftHive_fetchOne_args&); ThriftHive_fetchOne_args() { @@ -217,17 +230,22 @@ class ThriftHive_fetchOne_args { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_fetchOne_args& obj); }; class ThriftHive_fetchOne_pargs { public: + static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; + static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; + virtual ~ThriftHive_fetchOne_pargs() throw(); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_fetchOne_pargs& obj); }; typedef struct _ThriftHive_fetchOne_result__isset { @@ -239,6 +257,9 @@ typedef struct _ThriftHive_fetchOne_result__isset { class ThriftHive_fetchOne_result { public: + static const char* ascii_fingerprint; // = "BD5C3537D3AE5C0248BD3B45C053AE32"; + static const uint8_t binary_fingerprint[16]; // = {0xBD,0x5C,0x35,0x37,0xD3,0xAE,0x5C,0x02,0x48,0xBD,0x3B,0x45,0xC0,0x53,0xAE,0x32}; + ThriftHive_fetchOne_result(const ThriftHive_fetchOne_result&); ThriftHive_fetchOne_result& operator=(const ThriftHive_fetchOne_result&); ThriftHive_fetchOne_result() : success() { @@ -271,6 +292,7 @@ class ThriftHive_fetchOne_result { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_fetchOne_result& obj); }; typedef struct _ThriftHive_fetchOne_presult__isset { @@ -282,6 +304,9 @@ typedef struct _ThriftHive_fetchOne_presult__isset { class ThriftHive_fetchOne_presult { public: + static const char* ascii_fingerprint; // = "BD5C3537D3AE5C0248BD3B45C053AE32"; + static const uint8_t binary_fingerprint[16]; // = {0xBD,0x5C,0x35,0x37,0xD3,0xAE,0x5C,0x02,0x48,0xBD,0x3B,0x45,0xC0,0x53,0xAE,0x32}; + virtual ~ThriftHive_fetchOne_presult() throw(); std::string* success; @@ -291,6 +316,7 @@ class ThriftHive_fetchOne_presult { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_fetchOne_presult& obj); }; typedef struct _ThriftHive_fetchN_args__isset { @@ -301,6 +327,9 @@ typedef struct _ThriftHive_fetchN_args__isset { class ThriftHive_fetchN_args { public: + static const char* ascii_fingerprint; // = "E86CACEB22240450EDCBEFC3A83970E4"; + static const uint8_t binary_fingerprint[16]; // = {0xE8,0x6C,0xAC,0xEB,0x22,0x24,0x04,0x50,0xED,0xCB,0xEF,0xC3,0xA8,0x39,0x70,0xE4}; + ThriftHive_fetchN_args(const ThriftHive_fetchN_args&); ThriftHive_fetchN_args& operator=(const ThriftHive_fetchN_args&); ThriftHive_fetchN_args() : numRows(0) { @@ -328,18 +357,23 @@ class ThriftHive_fetchN_args { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_fetchN_args& obj); }; class ThriftHive_fetchN_pargs { public: + static const char* ascii_fingerprint; // = "E86CACEB22240450EDCBEFC3A83970E4"; + static const uint8_t binary_fingerprint[16]; // = {0xE8,0x6C,0xAC,0xEB,0x22,0x24,0x04,0x50,0xED,0xCB,0xEF,0xC3,0xA8,0x39,0x70,0xE4}; + virtual ~ThriftHive_fetchN_pargs() throw(); const int32_t* numRows; uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_fetchN_pargs& obj); }; typedef struct _ThriftHive_fetchN_result__isset { @@ -351,6 +385,9 @@ typedef struct _ThriftHive_fetchN_result__isset { class ThriftHive_fetchN_result { public: + static const char* ascii_fingerprint; // = "EB142A6BE66D8EE6065D07106EABD55D"; + static const uint8_t binary_fingerprint[16]; // = {0xEB,0x14,0x2A,0x6B,0xE6,0x6D,0x8E,0xE6,0x06,0x5D,0x07,0x10,0x6E,0xAB,0xD5,0x5D}; + ThriftHive_fetchN_result(const ThriftHive_fetchN_result&); ThriftHive_fetchN_result& operator=(const ThriftHive_fetchN_result&); ThriftHive_fetchN_result() { @@ -383,6 +420,7 @@ class ThriftHive_fetchN_result { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_fetchN_result& obj); }; typedef struct _ThriftHive_fetchN_presult__isset { @@ -394,6 +432,9 @@ typedef struct _ThriftHive_fetchN_presult__isset { class ThriftHive_fetchN_presult { public: + static const char* ascii_fingerprint; // = "EB142A6BE66D8EE6065D07106EABD55D"; + static const uint8_t binary_fingerprint[16]; // = {0xEB,0x14,0x2A,0x6B,0xE6,0x6D,0x8E,0xE6,0x06,0x5D,0x07,0x10,0x6E,0xAB,0xD5,0x5D}; + virtual ~ThriftHive_fetchN_presult() throw(); std::vector<std::string> * success; @@ -403,12 +444,16 @@ class ThriftHive_fetchN_presult { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_fetchN_presult& obj); }; class ThriftHive_fetchAll_args { public: + static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; + static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; + ThriftHive_fetchAll_args(const ThriftHive_fetchAll_args&); ThriftHive_fetchAll_args& operator=(const ThriftHive_fetchAll_args&); ThriftHive_fetchAll_args() { @@ -429,17 +474,22 @@ class ThriftHive_fetchAll_args { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_fetchAll_args& obj); }; class ThriftHive_fetchAll_pargs { public: + static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; + static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; + virtual ~ThriftHive_fetchAll_pargs() throw(); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_fetchAll_pargs& obj); }; typedef struct _ThriftHive_fetchAll_result__isset { @@ -451,6 +501,9 @@ typedef struct _ThriftHive_fetchAll_result__isset { class ThriftHive_fetchAll_result { public: + static const char* ascii_fingerprint; // = "EB142A6BE66D8EE6065D07106EABD55D"; + static const uint8_t binary_fingerprint[16]; // = {0xEB,0x14,0x2A,0x6B,0xE6,0x6D,0x8E,0xE6,0x06,0x5D,0x07,0x10,0x6E,0xAB,0xD5,0x5D}; + ThriftHive_fetchAll_result(const ThriftHive_fetchAll_result&); ThriftHive_fetchAll_result& operator=(const ThriftHive_fetchAll_result&); ThriftHive_fetchAll_result() { @@ -483,6 +536,7 @@ class ThriftHive_fetchAll_result { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_fetchAll_result& obj); }; typedef struct _ThriftHive_fetchAll_presult__isset { @@ -494,6 +548,9 @@ typedef struct _ThriftHive_fetchAll_presult__isset { class ThriftHive_fetchAll_presult { public: + static const char* ascii_fingerprint; // = "EB142A6BE66D8EE6065D07106EABD55D"; + static const uint8_t binary_fingerprint[16]; // = {0xEB,0x14,0x2A,0x6B,0xE6,0x6D,0x8E,0xE6,0x06,0x5D,0x07,0x10,0x6E,0xAB,0xD5,0x5D}; + virtual ~ThriftHive_fetchAll_presult() throw(); std::vector<std::string> * success; @@ -503,12 +560,16 @@ class ThriftHive_fetchAll_presult { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_fetchAll_presult& obj); }; class ThriftHive_getSchema_args { public: + static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; + static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; + ThriftHive_getSchema_args(const ThriftHive_getSchema_args&); ThriftHive_getSchema_args& operator=(const ThriftHive_getSchema_args&); ThriftHive_getSchema_args() { @@ -529,17 +590,22 @@ class ThriftHive_getSchema_args { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_getSchema_args& obj); }; class ThriftHive_getSchema_pargs { public: + static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; + static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; + virtual ~ThriftHive_getSchema_pargs() throw(); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_getSchema_pargs& obj); }; typedef struct _ThriftHive_getSchema_result__isset { @@ -551,6 +617,9 @@ typedef struct _ThriftHive_getSchema_result__isset { class ThriftHive_getSchema_result { public: + static const char* ascii_fingerprint; // = "FCFAE75CC7093F1A3926C2AD58A6FFD1"; + static const uint8_t binary_fingerprint[16]; // = {0xFC,0xFA,0xE7,0x5C,0xC7,0x09,0x3F,0x1A,0x39,0x26,0xC2,0xAD,0x58,0xA6,0xFF,0xD1}; + ThriftHive_getSchema_result(const ThriftHive_getSchema_result&); ThriftHive_getSchema_result& operator=(const ThriftHive_getSchema_result&); ThriftHive_getSchema_result() { @@ -583,6 +652,7 @@ class ThriftHive_getSchema_result { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_getSchema_result& obj); }; typedef struct _ThriftHive_getSchema_presult__isset { @@ -594,6 +664,9 @@ typedef struct _ThriftHive_getSchema_presult__isset { class ThriftHive_getSchema_presult { public: + static const char* ascii_fingerprint; // = "FCFAE75CC7093F1A3926C2AD58A6FFD1"; + static const uint8_t binary_fingerprint[16]; // = {0xFC,0xFA,0xE7,0x5C,0xC7,0x09,0x3F,0x1A,0x39,0x26,0xC2,0xAD,0x58,0xA6,0xFF,0xD1}; + virtual ~ThriftHive_getSchema_presult() throw(); ::Apache::Hadoop::Hive::Schema* success; @@ -603,12 +676,16 @@ class ThriftHive_getSchema_presult { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_getSchema_presult& obj); }; class ThriftHive_getThriftSchema_args { public: + static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; + static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; + ThriftHive_getThriftSchema_args(const ThriftHive_getThriftSchema_args&); ThriftHive_getThriftSchema_args& operator=(const ThriftHive_getThriftSchema_args&); ThriftHive_getThriftSchema_args() { @@ -629,17 +706,22 @@ class ThriftHive_getThriftSchema_args { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_getThriftSchema_args& obj); }; class ThriftHive_getThriftSchema_pargs { public: + static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; + static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; + virtual ~ThriftHive_getThriftSchema_pargs() throw(); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_getThriftSchema_pargs& obj); }; typedef struct _ThriftHive_getThriftSchema_result__isset { @@ -651,6 +733,9 @@ typedef struct _ThriftHive_getThriftSchema_result__isset { class ThriftHive_getThriftSchema_result { public: + static const char* ascii_fingerprint; // = "FCFAE75CC7093F1A3926C2AD58A6FFD1"; + static const uint8_t binary_fingerprint[16]; // = {0xFC,0xFA,0xE7,0x5C,0xC7,0x09,0x3F,0x1A,0x39,0x26,0xC2,0xAD,0x58,0xA6,0xFF,0xD1}; + ThriftHive_getThriftSchema_result(const ThriftHive_getThriftSchema_result&); ThriftHive_getThriftSchema_result& operator=(const ThriftHive_getThriftSchema_result&); ThriftHive_getThriftSchema_result() { @@ -683,6 +768,7 @@ class ThriftHive_getThriftSchema_result { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_getThriftSchema_result& obj); }; typedef struct _ThriftHive_getThriftSchema_presult__isset { @@ -694,6 +780,9 @@ typedef struct _ThriftHive_getThriftSchema_presult__isset { class ThriftHive_getThriftSchema_presult { public: + static const char* ascii_fingerprint; // = "FCFAE75CC7093F1A3926C2AD58A6FFD1"; + static const uint8_t binary_fingerprint[16]; // = {0xFC,0xFA,0xE7,0x5C,0xC7,0x09,0x3F,0x1A,0x39,0x26,0xC2,0xAD,0x58,0xA6,0xFF,0xD1}; + virtual ~ThriftHive_getThriftSchema_presult() throw(); ::Apache::Hadoop::Hive::Schema* success; @@ -703,12 +792,16 @@ class ThriftHive_getThriftSchema_presult { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_getThriftSchema_presult& obj); }; class ThriftHive_getClusterStatus_args { public: + static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; + static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; + ThriftHive_getClusterStatus_args(const ThriftHive_getClusterStatus_args&); ThriftHive_getClusterStatus_args& operator=(const ThriftHive_getClusterStatus_args&); ThriftHive_getClusterStatus_args() { @@ -729,17 +822,22 @@ class ThriftHive_getClusterStatus_args { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_getClusterStatus_args& obj); }; class ThriftHive_getClusterStatus_pargs { public: + static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; + static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; + virtual ~ThriftHive_getClusterStatus_pargs() throw(); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_getClusterStatus_pargs& obj); }; typedef struct _ThriftHive_getClusterStatus_result__isset { @@ -751,6 +849,9 @@ typedef struct _ThriftHive_getClusterStatus_result__isset { class ThriftHive_getClusterStatus_result { public: + static const char* ascii_fingerprint; // = "F486E00F8F0F2B6A17A0371997BB7B87"; + static const uint8_t binary_fingerprint[16]; // = {0xF4,0x86,0xE0,0x0F,0x8F,0x0F,0x2B,0x6A,0x17,0xA0,0x37,0x19,0x97,0xBB,0x7B,0x87}; + ThriftHive_getClusterStatus_result(const ThriftHive_getClusterStatus_result&); ThriftHive_getClusterStatus_result& operator=(const ThriftHive_getClusterStatus_result&); ThriftHive_getClusterStatus_result() { @@ -783,6 +884,7 @@ class ThriftHive_getClusterStatus_result { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_getClusterStatus_result& obj); }; typedef struct _ThriftHive_getClusterStatus_presult__isset { @@ -794,6 +896,9 @@ typedef struct _ThriftHive_getClusterStatus_presult__isset { class ThriftHive_getClusterStatus_presult { public: + static const char* ascii_fingerprint; // = "F486E00F8F0F2B6A17A0371997BB7B87"; + static const uint8_t binary_fingerprint[16]; // = {0xF4,0x86,0xE0,0x0F,0x8F,0x0F,0x2B,0x6A,0x17,0xA0,0x37,0x19,0x97,0xBB,0x7B,0x87}; + virtual ~ThriftHive_getClusterStatus_presult() throw(); HiveClusterStatus* success; @@ -803,12 +908,16 @@ class ThriftHive_getClusterStatus_presult { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_getClusterStatus_presult& obj); }; class ThriftHive_getQueryPlan_args { public: + static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; + static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; + ThriftHive_getQueryPlan_args(const ThriftHive_getQueryPlan_args&); ThriftHive_getQueryPlan_args& operator=(const ThriftHive_getQueryPlan_args&); ThriftHive_getQueryPlan_args() { @@ -829,17 +938,22 @@ class ThriftHive_getQueryPlan_args { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_getQueryPlan_args& obj); }; class ThriftHive_getQueryPlan_pargs { public: + static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; + static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; + virtual ~ThriftHive_getQueryPlan_pargs() throw(); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_getQueryPlan_pargs& obj); }; typedef struct _ThriftHive_getQueryPlan_result__isset { @@ -851,6 +965,9 @@ typedef struct _ThriftHive_getQueryPlan_result__isset { class ThriftHive_getQueryPlan_result { public: + static const char* ascii_fingerprint; // = "0263544CFF7194CEE7DC6128DD5941ED"; + static const uint8_t binary_fingerprint[16]; // = {0x02,0x63,0x54,0x4C,0xFF,0x71,0x94,0xCE,0xE7,0xDC,0x61,0x28,0xDD,0x59,0x41,0xED}; + ThriftHive_getQueryPlan_result(const ThriftHive_getQueryPlan_result&); ThriftHive_getQueryPlan_result& operator=(const ThriftHive_getQueryPlan_result&); ThriftHive_getQueryPlan_result() { @@ -883,6 +1000,7 @@ class ThriftHive_getQueryPlan_result { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_getQueryPlan_result& obj); }; typedef struct _ThriftHive_getQueryPlan_presult__isset { @@ -894,6 +1012,9 @@ typedef struct _ThriftHive_getQueryPlan_presult__isset { class ThriftHive_getQueryPlan_presult { public: + static const char* ascii_fingerprint; // = "0263544CFF7194CEE7DC6128DD5941ED"; + static const uint8_t binary_fingerprint[16]; // = {0x02,0x63,0x54,0x4C,0xFF,0x71,0x94,0xCE,0xE7,0xDC,0x61,0x28,0xDD,0x59,0x41,0xED}; + virtual ~ThriftHive_getQueryPlan_presult() throw(); ::Apache::Hadoop::Hive::QueryPlan* success; @@ -903,12 +1024,16 @@ class ThriftHive_getQueryPlan_presult { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_getQueryPlan_presult& obj); }; class ThriftHive_clean_args { public: + static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; + static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; + ThriftHive_clean_args(const ThriftHive_clean_args&); ThriftHive_clean_args& operator=(const ThriftHive_clean_args&); ThriftHive_clean_args() { @@ -929,23 +1054,31 @@ class ThriftHive_clean_args { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_clean_args& obj); }; class ThriftHive_clean_pargs { public: + static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; + static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; + virtual ~ThriftHive_clean_pargs() throw(); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_clean_pargs& obj); }; class ThriftHive_clean_result { public: + static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; + static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; + ThriftHive_clean_result(const ThriftHive_clean_result&); ThriftHive_clean_result& operator=(const ThriftHive_clean_result&); ThriftHive_clean_result() { @@ -966,17 +1099,22 @@ class ThriftHive_clean_result { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_clean_result& obj); }; class ThriftHive_clean_presult { public: + static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; + static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; + virtual ~ThriftHive_clean_presult() throw(); uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + friend std::ostream& operator<<(std::ostream& out, const ThriftHive_clean_presult& obj); }; class ThriftHiveClient : virtual public ThriftHiveIf, public ::Apache::Hadoop::Hive::ThriftHiveMetastoreClient { @@ -1172,53 +1310,6 @@ class ThriftHiveMultiface : virtual public ThriftHiveIf, public ::Apache::Hadoo }; -// The 'concurrent' client is a thread safe client that correctly handles -// out of order responses. It is slower than the regular client, so should -// only be used when you need to share a connection among multiple threads -class ThriftHiveConcurrentClient : virtual public ThriftHiveIf, public ::Apache::Hadoop::Hive::ThriftHiveMetastoreConcurrentClient { - public: - ThriftHiveConcurrentClient(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> prot) : - ::Apache::Hadoop::Hive::ThriftHiveMetastoreConcurrentClient(prot, prot) {} - ThriftHiveConcurrentClient(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> iprot, boost::shared_ptr< ::apache::thrift::protocol::TProtocol> oprot) : ::Apache::Hadoop::Hive::ThriftHiveMetastoreConcurrentClient(iprot, oprot) {} - boost::shared_ptr< ::apache::thrift::protocol::TProtocol> getInputProtocol() { - return piprot_; - } - boost::shared_ptr< ::apache::thrift::protocol::TProtocol> getOutputProtocol() { - return poprot_; - } - void execute(const std::string& query); - int32_t send_execute(const std::string& query); - void recv_execute(const int32_t seqid); - void fetchOne(std::string& _return); - int32_t send_fetchOne(); - void recv_fetchOne(std::string& _return, const int32_t seqid); - void fetchN(std::vector<std::string> & _return, const int32_t numRows); - int32_t send_fetchN(const int32_t numRows); - void recv_fetchN(std::vector<std::string> & _return, const int32_t seqid); - void fetchAll(std::vector<std::string> & _return); - int32_t send_fetchAll(); - void recv_fetchAll(std::vector<std::string> & _return, const int32_t seqid); - void getSchema( ::Apache::Hadoop::Hive::Schema& _return); - int32_t send_getSchema(); - void recv_getSchema( ::Apache::Hadoop::Hive::Schema& _return, const int32_t seqid); - void getThriftSchema( ::Apache::Hadoop::Hive::Schema& _return); - int32_t send_getThriftSchema(); - void recv_getThriftSchema( ::Apache::Hadoop::Hive::Schema& _return, const int32_t seqid); - void getClusterStatus(HiveClusterStatus& _return); - int32_t send_getClusterStatus(); - void recv_getClusterStatus(HiveClusterStatus& _return, const int32_t seqid); - void getQueryPlan( ::Apache::Hadoop::Hive::QueryPlan& _return); - int32_t send_getQueryPlan(); - void recv_getQueryPlan( ::Apache::Hadoop::Hive::QueryPlan& _return, const int32_t seqid); - void clean(); - int32_t send_clean(); - void recv_clean(const int32_t seqid); -}; - -#ifdef _WIN32 - #pragma warning( pop ) -#endif - }}} // namespace #endif http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/service/src/gen/thrift/gen-cpp/hive_service_constants.cpp ---------------------------------------------------------------------- diff --git a/service/src/gen/thrift/gen-cpp/hive_service_constants.cpp b/service/src/gen/thrift/gen-cpp/hive_service_constants.cpp index e2bbe71..c3c8482 100644 --- a/service/src/gen/thrift/gen-cpp/hive_service_constants.cpp +++ b/service/src/gen/thrift/gen-cpp/hive_service_constants.cpp @@ -1,5 +1,5 @@ /** - * Autogenerated by Thrift Compiler (0.9.3) + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/service/src/gen/thrift/gen-cpp/hive_service_constants.h ---------------------------------------------------------------------- diff --git a/service/src/gen/thrift/gen-cpp/hive_service_constants.h b/service/src/gen/thrift/gen-cpp/hive_service_constants.h index e0887f4..5878dbe 100644 --- a/service/src/gen/thrift/gen-cpp/hive_service_constants.h +++ b/service/src/gen/thrift/gen-cpp/hive_service_constants.h @@ -1,5 +1,5 @@ /** - * Autogenerated by Thrift Compiler (0.9.3) + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/service/src/gen/thrift/gen-cpp/hive_service_types.cpp ---------------------------------------------------------------------- diff --git a/service/src/gen/thrift/gen-cpp/hive_service_types.cpp b/service/src/gen/thrift/gen-cpp/hive_service_types.cpp index 9ddf7c1..4d6cf01 100644 --- a/service/src/gen/thrift/gen-cpp/hive_service_types.cpp +++ b/service/src/gen/thrift/gen-cpp/hive_service_types.cpp @@ -1,5 +1,5 @@ /** - * Autogenerated by Thrift Compiler (0.9.3) + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -52,9 +52,11 @@ void HiveClusterStatus::__set_state(const JobTrackerState::type val) { this->state = val; } +const char* HiveClusterStatus::ascii_fingerprint = "D514EDCFFC86F64A2E924DCD16D4FAD8"; +const uint8_t HiveClusterStatus::binary_fingerprint[16] = {0xD5,0x14,0xED,0xCF,0xFC,0x86,0xF6,0x4A,0x2E,0x92,0x4D,0xCD,0x16,0xD4,0xFA,0xD8}; + uint32_t HiveClusterStatus::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -137,7 +139,7 @@ uint32_t HiveClusterStatus::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t HiveClusterStatus::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("HiveClusterStatus"); xfer += oprot->writeFieldBegin("taskTrackers", ::apache::thrift::protocol::T_I32, 1); @@ -166,6 +168,7 @@ uint32_t HiveClusterStatus::write(::apache::thrift::protocol::TProtocol* oprot) xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -199,16 +202,17 @@ HiveClusterStatus& HiveClusterStatus::operator=(const HiveClusterStatus& other2) __isset = other2.__isset; return *this; } -void HiveClusterStatus::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; +std::ostream& operator<<(std::ostream& out, const HiveClusterStatus& obj) { + using apache::thrift::to_string; out << "HiveClusterStatus("; - out << "taskTrackers=" << to_string(taskTrackers); - out << ", " << "mapTasks=" << to_string(mapTasks); - out << ", " << "reduceTasks=" << to_string(reduceTasks); - out << ", " << "maxMapTasks=" << to_string(maxMapTasks); - out << ", " << "maxReduceTasks=" << to_string(maxReduceTasks); - out << ", " << "state=" << to_string(state); + out << "taskTrackers=" << to_string(obj.taskTrackers); + out << ", " << "mapTasks=" << to_string(obj.mapTasks); + out << ", " << "reduceTasks=" << to_string(obj.reduceTasks); + out << ", " << "maxMapTasks=" << to_string(obj.maxMapTasks); + out << ", " << "maxReduceTasks=" << to_string(obj.maxReduceTasks); + out << ", " << "state=" << to_string(obj.state); out << ")"; + return out; } @@ -228,9 +232,11 @@ void HiveServerException::__set_SQLState(const std::string& val) { this->SQLState = val; } +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}; + uint32_t HiveServerException::read(::apache::thrift::protocol::TProtocol* iprot) { - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; @@ -287,7 +293,7 @@ uint32_t HiveServerException::read(::apache::thrift::protocol::TProtocol* iprot) uint32_t HiveServerException::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("HiveServerException"); xfer += oprot->writeFieldBegin("message", ::apache::thrift::protocol::T_STRING, 1); @@ -304,6 +310,7 @@ uint32_t HiveServerException::write(::apache::thrift::protocol::TProtocol* oprot xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -328,24 +335,14 @@ HiveServerException& HiveServerException::operator=(const HiveServerException& o __isset = other4.__isset; return *this; } -void HiveServerException::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; +std::ostream& operator<<(std::ostream& out, const HiveServerException& obj) { + using apache::thrift::to_string; out << "HiveServerException("; - out << "message=" << to_string(message); - out << ", " << "errorCode=" << to_string(errorCode); - out << ", " << "SQLState=" << to_string(SQLState); + out << "message=" << to_string(obj.message); + out << ", " << "errorCode=" << to_string(obj.errorCode); + out << ", " << "SQLState=" << to_string(obj.SQLState); out << ")"; -} - -const char* HiveServerException::what() const throw() { - try { - std::stringstream ss; - ss << "TException - service has thrown: " << *this; - this->thriftTExceptionMessageHolder_ = ss.str(); - return this->thriftTExceptionMessageHolder_.c_str(); - } catch (const std::exception&) { - return "TException - service has thrown: HiveServerException"; - } + return out; } }}} // namespace http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/service/src/gen/thrift/gen-cpp/hive_service_types.h ---------------------------------------------------------------------- diff --git a/service/src/gen/thrift/gen-cpp/hive_service_types.h b/service/src/gen/thrift/gen-cpp/hive_service_types.h index 266f8ea..7fea88c 100644 --- a/service/src/gen/thrift/gen-cpp/hive_service_types.h +++ b/service/src/gen/thrift/gen-cpp/hive_service_types.h @@ -1,5 +1,5 @@ /** - * Autogenerated by Thrift Compiler (0.9.3) + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -48,6 +48,9 @@ typedef struct _HiveClusterStatus__isset { class HiveClusterStatus { public: + 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(const HiveClusterStatus&); HiveClusterStatus& operator=(const HiveClusterStatus&); HiveClusterStatus() : taskTrackers(0), mapTasks(0), reduceTasks(0), maxMapTasks(0), maxReduceTasks(0), state((JobTrackerState::type)0) { @@ -100,17 +103,11 @@ class HiveClusterStatus { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - virtual void printTo(std::ostream& out) const; + friend std::ostream& operator<<(std::ostream& out, const HiveClusterStatus& obj); }; void swap(HiveClusterStatus &a, HiveClusterStatus &b); -inline std::ostream& operator<<(std::ostream& out, const HiveClusterStatus& obj) -{ - obj.printTo(out); - return out; -} - typedef struct _HiveServerException__isset { _HiveServerException__isset() : message(false), errorCode(false), SQLState(false) {} bool message :1; @@ -121,6 +118,9 @@ typedef struct _HiveServerException__isset { class HiveServerException : public ::apache::thrift::TException { public: + 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(const HiveServerException&); HiveServerException& operator=(const HiveServerException&); HiveServerException() : message(), errorCode(0), SQLState() { @@ -158,19 +158,11 @@ class HiveServerException : public ::apache::thrift::TException { uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - virtual void printTo(std::ostream& out) const; - mutable std::string thriftTExceptionMessageHolder_; - const char* what() const throw(); + friend std::ostream& operator<<(std::ostream& out, const HiveServerException& obj); }; void swap(HiveServerException &a, HiveServerException &b); -inline std::ostream& operator<<(std::ostream& out, const HiveServerException& obj) -{ - obj.printTo(out); - return out; -} - }}} // namespace #endif http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/HiveClusterStatus.java ---------------------------------------------------------------------- diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/HiveClusterStatus.java b/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/HiveClusterStatus.java index ad89867..9dbfbe4 100644 --- a/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/HiveClusterStatus.java +++ b/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/HiveClusterStatus.java @@ -1,5 +1,5 @@ /** - * Autogenerated by Thrift Compiler (0.9.3) + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") public class HiveClusterStatus implements org.apache.thrift.TBase<HiveClusterStatus, HiveClusterStatus._Fields>, java.io.Serializable, Cloneable, Comparable<HiveClusterStatus> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("HiveClusterStatus"); @@ -417,19 +417,19 @@ public class HiveClusterStatus implements org.apache.thrift.TBase<HiveClusterSta public Object getFieldValue(_Fields field) { switch (field) { case TASK_TRACKERS: - return getTaskTrackers(); + return Integer.valueOf(getTaskTrackers()); case MAP_TASKS: - return getMapTasks(); + return Integer.valueOf(getMapTasks()); case REDUCE_TASKS: - return getReduceTasks(); + return Integer.valueOf(getReduceTasks()); case MAX_MAP_TASKS: - return getMaxMapTasks(); + return Integer.valueOf(getMaxMapTasks()); case MAX_REDUCE_TASKS: - return getMaxReduceTasks(); + return Integer.valueOf(getMaxReduceTasks()); case STATE: return getState(); http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/HiveServerException.java ---------------------------------------------------------------------- diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/HiveServerException.java b/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/HiveServerException.java index 97b1219..d1c2f3f 100644 --- a/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/HiveServerException.java +++ b/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/HiveServerException.java @@ -1,5 +1,5 @@ /** - * Autogenerated by Thrift Compiler (0.9.3) + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") public class HiveServerException extends TException implements org.apache.thrift.TBase<HiveServerException, HiveServerException._Fields>, java.io.Serializable, Cloneable, Comparable<HiveServerException> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("HiveServerException"); @@ -276,7 +276,7 @@ public class HiveServerException extends TException implements org.apache.thrift return getMessage(); case ERROR_CODE: - return getErrorCode(); + return Integer.valueOf(getErrorCode()); case SQLSTATE: return getSQLState();
