http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/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 865db69..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.0) + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -8,6 +8,11 @@ namespace Apache { namespace Hadoop { namespace Hive { + +ThriftHive_execute_args::~ThriftHive_execute_args() throw() { +} + + uint32_t ThriftHive_execute_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -50,6 +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; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_execute_args"); xfer += oprot->writeFieldBegin("query", ::apache::thrift::protocol::T_STRING, 1); @@ -58,11 +64,18 @@ uint32_t ThriftHive_execute_args::write(::apache::thrift::protocol::TProtocol* o xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } + +ThriftHive_execute_pargs::~ThriftHive_execute_pargs() throw() { +} + + uint32_t ThriftHive_execute_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_execute_pargs"); xfer += oprot->writeFieldBegin("query", ::apache::thrift::protocol::T_STRING, 1); @@ -71,9 +84,15 @@ uint32_t ThriftHive_execute_pargs::write(::apache::thrift::protocol::TProtocol* xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } + +ThriftHive_execute_result::~ThriftHive_execute_result() throw() { +} + + uint32_t ThriftHive_execute_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -130,6 +149,11 @@ uint32_t ThriftHive_execute_result::write(::apache::thrift::protocol::TProtocol* return xfer; } + +ThriftHive_execute_presult::~ThriftHive_execute_presult() throw() { +} + + uint32_t ThriftHive_execute_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -170,6 +194,11 @@ uint32_t ThriftHive_execute_presult::read(::apache::thrift::protocol::TProtocol* return xfer; } + +ThriftHive_fetchOne_args::~ThriftHive_fetchOne_args() throw() { +} + + uint32_t ThriftHive_fetchOne_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -199,22 +228,36 @@ 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; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_fetchOne_args"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } + +ThriftHive_fetchOne_pargs::~ThriftHive_fetchOne_pargs() throw() { +} + + uint32_t ThriftHive_fetchOne_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_fetchOne_pargs"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } + +ThriftHive_fetchOne_result::~ThriftHive_fetchOne_result() throw() { +} + + uint32_t ThriftHive_fetchOne_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -283,6 +326,11 @@ uint32_t ThriftHive_fetchOne_result::write(::apache::thrift::protocol::TProtocol return xfer; } + +ThriftHive_fetchOne_presult::~ThriftHive_fetchOne_presult() throw() { +} + + uint32_t ThriftHive_fetchOne_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -331,6 +379,11 @@ uint32_t ThriftHive_fetchOne_presult::read(::apache::thrift::protocol::TProtocol return xfer; } + +ThriftHive_fetchN_args::~ThriftHive_fetchN_args() throw() { +} + + uint32_t ThriftHive_fetchN_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -373,6 +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; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_fetchN_args"); xfer += oprot->writeFieldBegin("numRows", ::apache::thrift::protocol::T_I32, 1); @@ -381,11 +435,18 @@ uint32_t ThriftHive_fetchN_args::write(::apache::thrift::protocol::TProtocol* op xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } + +ThriftHive_fetchN_pargs::~ThriftHive_fetchN_pargs() throw() { +} + + uint32_t ThriftHive_fetchN_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_fetchN_pargs"); xfer += oprot->writeFieldBegin("numRows", ::apache::thrift::protocol::T_I32, 1); @@ -394,9 +455,15 @@ uint32_t ThriftHive_fetchN_pargs::write(::apache::thrift::protocol::TProtocol* o xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } + +ThriftHive_fetchN_result::~ThriftHive_fetchN_result() throw() { +} + + uint32_t ThriftHive_fetchN_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -421,14 +488,14 @@ uint32_t ThriftHive_fetchN_result::read(::apache::thrift::protocol::TProtocol* i if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size1; - ::apache::thrift::protocol::TType _etype4; - xfer += iprot->readListBegin(_etype4, _size1); - this->success.resize(_size1); - uint32_t _i5; - for (_i5 = 0; _i5 < _size1; ++_i5) + uint32_t _size5; + ::apache::thrift::protocol::TType _etype8; + xfer += iprot->readListBegin(_etype8, _size5); + this->success.resize(_size5); + uint32_t _i9; + for (_i9 = 0; _i9 < _size5; ++_i9) { - xfer += iprot->readString(this->success[_i5]); + xfer += iprot->readString(this->success[_i9]); } xfer += iprot->readListEnd(); } @@ -467,10 +534,10 @@ uint32_t ThriftHive_fetchN_result::write(::apache::thrift::protocol::TProtocol* xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size())); - std::vector<std::string> ::const_iterator _iter6; - for (_iter6 = this->success.begin(); _iter6 != this->success.end(); ++_iter6) + std::vector<std::string> ::const_iterator _iter10; + for (_iter10 = this->success.begin(); _iter10 != this->success.end(); ++_iter10) { - xfer += oprot->writeString((*_iter6)); + xfer += oprot->writeString((*_iter10)); } xfer += oprot->writeListEnd(); } @@ -485,6 +552,11 @@ uint32_t ThriftHive_fetchN_result::write(::apache::thrift::protocol::TProtocol* return xfer; } + +ThriftHive_fetchN_presult::~ThriftHive_fetchN_presult() throw() { +} + + uint32_t ThriftHive_fetchN_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -509,14 +581,14 @@ uint32_t ThriftHive_fetchN_presult::read(::apache::thrift::protocol::TProtocol* if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size7; - ::apache::thrift::protocol::TType _etype10; - xfer += iprot->readListBegin(_etype10, _size7); - (*(this->success)).resize(_size7); - uint32_t _i11; - for (_i11 = 0; _i11 < _size7; ++_i11) + uint32_t _size11; + ::apache::thrift::protocol::TType _etype14; + xfer += iprot->readListBegin(_etype14, _size11); + (*(this->success)).resize(_size11); + uint32_t _i15; + for (_i15 = 0; _i15 < _size11; ++_i15) { - xfer += iprot->readString((*(this->success))[_i11]); + xfer += iprot->readString((*(this->success))[_i15]); } xfer += iprot->readListEnd(); } @@ -545,6 +617,11 @@ uint32_t ThriftHive_fetchN_presult::read(::apache::thrift::protocol::TProtocol* return xfer; } + +ThriftHive_fetchAll_args::~ThriftHive_fetchAll_args() throw() { +} + + uint32_t ThriftHive_fetchAll_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -574,22 +651,36 @@ 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; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_fetchAll_args"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } + +ThriftHive_fetchAll_pargs::~ThriftHive_fetchAll_pargs() throw() { +} + + uint32_t ThriftHive_fetchAll_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_fetchAll_pargs"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } + +ThriftHive_fetchAll_result::~ThriftHive_fetchAll_result() throw() { +} + + uint32_t ThriftHive_fetchAll_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -614,14 +705,14 @@ uint32_t ThriftHive_fetchAll_result::read(::apache::thrift::protocol::TProtocol* if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); - uint32_t _size12; - ::apache::thrift::protocol::TType _etype15; - xfer += iprot->readListBegin(_etype15, _size12); - this->success.resize(_size12); - uint32_t _i16; - for (_i16 = 0; _i16 < _size12; ++_i16) + uint32_t _size16; + ::apache::thrift::protocol::TType _etype19; + xfer += iprot->readListBegin(_etype19, _size16); + this->success.resize(_size16); + uint32_t _i20; + for (_i20 = 0; _i20 < _size16; ++_i20) { - xfer += iprot->readString(this->success[_i16]); + xfer += iprot->readString(this->success[_i20]); } xfer += iprot->readListEnd(); } @@ -660,10 +751,10 @@ uint32_t ThriftHive_fetchAll_result::write(::apache::thrift::protocol::TProtocol xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->success.size())); - std::vector<std::string> ::const_iterator _iter17; - for (_iter17 = this->success.begin(); _iter17 != this->success.end(); ++_iter17) + std::vector<std::string> ::const_iterator _iter21; + for (_iter21 = this->success.begin(); _iter21 != this->success.end(); ++_iter21) { - xfer += oprot->writeString((*_iter17)); + xfer += oprot->writeString((*_iter21)); } xfer += oprot->writeListEnd(); } @@ -678,6 +769,11 @@ uint32_t ThriftHive_fetchAll_result::write(::apache::thrift::protocol::TProtocol return xfer; } + +ThriftHive_fetchAll_presult::~ThriftHive_fetchAll_presult() throw() { +} + + uint32_t ThriftHive_fetchAll_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -702,14 +798,14 @@ uint32_t ThriftHive_fetchAll_presult::read(::apache::thrift::protocol::TProtocol if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); - uint32_t _size18; - ::apache::thrift::protocol::TType _etype21; - xfer += iprot->readListBegin(_etype21, _size18); - (*(this->success)).resize(_size18); - uint32_t _i22; - for (_i22 = 0; _i22 < _size18; ++_i22) + uint32_t _size22; + ::apache::thrift::protocol::TType _etype25; + xfer += iprot->readListBegin(_etype25, _size22); + (*(this->success)).resize(_size22); + uint32_t _i26; + for (_i26 = 0; _i26 < _size22; ++_i26) { - xfer += iprot->readString((*(this->success))[_i22]); + xfer += iprot->readString((*(this->success))[_i26]); } xfer += iprot->readListEnd(); } @@ -738,6 +834,11 @@ uint32_t ThriftHive_fetchAll_presult::read(::apache::thrift::protocol::TProtocol return xfer; } + +ThriftHive_getSchema_args::~ThriftHive_getSchema_args() throw() { +} + + uint32_t ThriftHive_getSchema_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -767,22 +868,36 @@ 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; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_getSchema_args"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } + +ThriftHive_getSchema_pargs::~ThriftHive_getSchema_pargs() throw() { +} + + uint32_t ThriftHive_getSchema_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_getSchema_pargs"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } + +ThriftHive_getSchema_result::~ThriftHive_getSchema_result() throw() { +} + + uint32_t ThriftHive_getSchema_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -851,6 +966,11 @@ uint32_t ThriftHive_getSchema_result::write(::apache::thrift::protocol::TProtoco return xfer; } + +ThriftHive_getSchema_presult::~ThriftHive_getSchema_presult() throw() { +} + + uint32_t ThriftHive_getSchema_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -899,6 +1019,11 @@ uint32_t ThriftHive_getSchema_presult::read(::apache::thrift::protocol::TProtoco return xfer; } + +ThriftHive_getThriftSchema_args::~ThriftHive_getThriftSchema_args() throw() { +} + + uint32_t ThriftHive_getThriftSchema_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -928,22 +1053,36 @@ 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; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_getThriftSchema_args"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } + +ThriftHive_getThriftSchema_pargs::~ThriftHive_getThriftSchema_pargs() throw() { +} + + uint32_t ThriftHive_getThriftSchema_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_getThriftSchema_pargs"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } + +ThriftHive_getThriftSchema_result::~ThriftHive_getThriftSchema_result() throw() { +} + + uint32_t ThriftHive_getThriftSchema_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -1012,6 +1151,11 @@ uint32_t ThriftHive_getThriftSchema_result::write(::apache::thrift::protocol::TP return xfer; } + +ThriftHive_getThriftSchema_presult::~ThriftHive_getThriftSchema_presult() throw() { +} + + uint32_t ThriftHive_getThriftSchema_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -1060,6 +1204,11 @@ uint32_t ThriftHive_getThriftSchema_presult::read(::apache::thrift::protocol::TP return xfer; } + +ThriftHive_getClusterStatus_args::~ThriftHive_getClusterStatus_args() throw() { +} + + uint32_t ThriftHive_getClusterStatus_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -1089,22 +1238,36 @@ 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; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_getClusterStatus_args"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } + +ThriftHive_getClusterStatus_pargs::~ThriftHive_getClusterStatus_pargs() throw() { +} + + uint32_t ThriftHive_getClusterStatus_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_getClusterStatus_pargs"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } + +ThriftHive_getClusterStatus_result::~ThriftHive_getClusterStatus_result() throw() { +} + + uint32_t ThriftHive_getClusterStatus_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -1173,6 +1336,11 @@ uint32_t ThriftHive_getClusterStatus_result::write(::apache::thrift::protocol::T return xfer; } + +ThriftHive_getClusterStatus_presult::~ThriftHive_getClusterStatus_presult() throw() { +} + + uint32_t ThriftHive_getClusterStatus_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -1221,6 +1389,11 @@ uint32_t ThriftHive_getClusterStatus_presult::read(::apache::thrift::protocol::T return xfer; } + +ThriftHive_getQueryPlan_args::~ThriftHive_getQueryPlan_args() throw() { +} + + uint32_t ThriftHive_getQueryPlan_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -1250,22 +1423,36 @@ 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; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_getQueryPlan_args"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } + +ThriftHive_getQueryPlan_pargs::~ThriftHive_getQueryPlan_pargs() throw() { +} + + uint32_t ThriftHive_getQueryPlan_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_getQueryPlan_pargs"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } + +ThriftHive_getQueryPlan_result::~ThriftHive_getQueryPlan_result() throw() { +} + + uint32_t ThriftHive_getQueryPlan_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -1334,6 +1521,11 @@ uint32_t ThriftHive_getQueryPlan_result::write(::apache::thrift::protocol::TProt return xfer; } + +ThriftHive_getQueryPlan_presult::~ThriftHive_getQueryPlan_presult() throw() { +} + + uint32_t ThriftHive_getQueryPlan_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -1382,6 +1574,11 @@ uint32_t ThriftHive_getQueryPlan_presult::read(::apache::thrift::protocol::TProt return xfer; } + +ThriftHive_clean_args::~ThriftHive_clean_args() throw() { +} + + uint32_t ThriftHive_clean_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -1411,22 +1608,36 @@ 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; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_clean_args"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } + +ThriftHive_clean_pargs::~ThriftHive_clean_pargs() throw() { +} + + uint32_t ThriftHive_clean_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("ThriftHive_clean_pargs"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } + +ThriftHive_clean_result::~ThriftHive_clean_result() throw() { +} + + uint32_t ThriftHive_clean_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; @@ -1465,6 +1676,11 @@ uint32_t ThriftHive_clean_result::write(::apache::thrift::protocol::TProtocol* o return xfer; } + +ThriftHive_clean_presult::~ThriftHive_clean_presult() throw() { +} + + uint32_t ThriftHive_clean_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0;
http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/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 b84362b..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.0) + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -85,24 +85,26 @@ class ThriftHiveNull : virtual public ThriftHiveIf , virtual public ::Apache::H typedef struct _ThriftHive_execute_args__isset { _ThriftHive_execute_args__isset() : query(false) {} - bool query; + bool query :1; } _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() { } - virtual ~ThriftHive_execute_args() throw() {} - + virtual ~ThriftHive_execute_args() throw(); std::string query; _ThriftHive_execute_args__isset __isset; - void __set_query(const std::string& val) { - query = val; - } + void __set_query(const std::string& val); bool operator == (const ThriftHive_execute_args & rhs) const { @@ -119,41 +121,47 @@ 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() {} + 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 { _ThriftHive_execute_result__isset() : ex(false) {} - bool ex; + bool ex :1; } _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() { } - virtual ~ThriftHive_execute_result() throw() {} - + virtual ~ThriftHive_execute_result() throw(); HiveServerException ex; _ThriftHive_execute_result__isset __isset; - void __set_ex(const HiveServerException& val) { - ex = val; - } + void __set_ex(const HiveServerException& val); bool operator == (const ThriftHive_execute_result & rhs) const { @@ -170,36 +178,44 @@ 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 { _ThriftHive_execute_presult__isset() : ex(false) {} - bool ex; + bool ex :1; } _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() {} + virtual ~ThriftHive_execute_presult() throw(); HiveServerException ex; _ThriftHive_execute_presult__isset __isset; 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() { } - virtual ~ThriftHive_fetchOne_args() throw() {} - + virtual ~ThriftHive_fetchOne_args() throw(); bool operator == (const ThriftHive_fetchOne_args & /* rhs */) const { @@ -214,46 +230,50 @@ 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() {} + 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 { _ThriftHive_fetchOne_result__isset() : success(false), ex(false) {} - bool success; - bool ex; + bool success :1; + bool ex :1; } _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() { } - virtual ~ThriftHive_fetchOne_result() throw() {} - + virtual ~ThriftHive_fetchOne_result() throw(); std::string success; HiveServerException ex; _ThriftHive_fetchOne_result__isset __isset; - void __set_success(const std::string& val) { - success = val; - } + void __set_success(const std::string& val); - void __set_ex(const HiveServerException& val) { - ex = val; - } + void __set_ex(const HiveServerException& val); bool operator == (const ThriftHive_fetchOne_result & rhs) const { @@ -272,20 +292,23 @@ 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 { _ThriftHive_fetchOne_presult__isset() : success(false), ex(false) {} - bool success; - bool ex; + bool success :1; + bool ex :1; } _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() {} + virtual ~ThriftHive_fetchOne_presult() throw(); std::string* success; HiveServerException ex; @@ -293,28 +316,31 @@ 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 { _ThriftHive_fetchN_args__isset() : numRows(false) {} - bool numRows; + bool numRows :1; } _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) { } - virtual ~ThriftHive_fetchN_args() throw() {} - + virtual ~ThriftHive_fetchN_args() throw(); int32_t numRows; _ThriftHive_fetchN_args__isset __isset; - void __set_numRows(const int32_t val) { - numRows = val; - } + void __set_numRows(const int32_t val); bool operator == (const ThriftHive_fetchN_args & rhs) const { @@ -331,47 +357,51 @@ 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() {} + 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 { _ThriftHive_fetchN_result__isset() : success(false), ex(false) {} - bool success; - bool ex; + bool success :1; + bool ex :1; } _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() { } - virtual ~ThriftHive_fetchN_result() throw() {} - + virtual ~ThriftHive_fetchN_result() throw(); std::vector<std::string> success; HiveServerException ex; _ThriftHive_fetchN_result__isset __isset; - void __set_success(const std::vector<std::string> & val) { - success = val; - } + void __set_success(const std::vector<std::string> & val); - void __set_ex(const HiveServerException& val) { - ex = val; - } + void __set_ex(const HiveServerException& val); bool operator == (const ThriftHive_fetchN_result & rhs) const { @@ -390,20 +420,23 @@ 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 { _ThriftHive_fetchN_presult__isset() : success(false), ex(false) {} - bool success; - bool ex; + bool success :1; + bool ex :1; } _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() {} + virtual ~ThriftHive_fetchN_presult() throw(); std::vector<std::string> * success; HiveServerException ex; @@ -411,17 +444,22 @@ 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() { } - virtual ~ThriftHive_fetchAll_args() throw() {} - + virtual ~ThriftHive_fetchAll_args() throw(); bool operator == (const ThriftHive_fetchAll_args & /* rhs */) const { @@ -436,46 +474,50 @@ 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() {} + 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 { _ThriftHive_fetchAll_result__isset() : success(false), ex(false) {} - bool success; - bool ex; + bool success :1; + bool ex :1; } _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() { } - virtual ~ThriftHive_fetchAll_result() throw() {} - + virtual ~ThriftHive_fetchAll_result() throw(); std::vector<std::string> success; HiveServerException ex; _ThriftHive_fetchAll_result__isset __isset; - void __set_success(const std::vector<std::string> & val) { - success = val; - } + void __set_success(const std::vector<std::string> & val); - void __set_ex(const HiveServerException& val) { - ex = val; - } + void __set_ex(const HiveServerException& val); bool operator == (const ThriftHive_fetchAll_result & rhs) const { @@ -494,20 +536,23 @@ 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 { _ThriftHive_fetchAll_presult__isset() : success(false), ex(false) {} - bool success; - bool ex; + bool success :1; + bool ex :1; } _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() {} + virtual ~ThriftHive_fetchAll_presult() throw(); std::vector<std::string> * success; HiveServerException ex; @@ -515,17 +560,22 @@ 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() { } - virtual ~ThriftHive_getSchema_args() throw() {} - + virtual ~ThriftHive_getSchema_args() throw(); bool operator == (const ThriftHive_getSchema_args & /* rhs */) const { @@ -540,46 +590,50 @@ 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() {} + 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 { _ThriftHive_getSchema_result__isset() : success(false), ex(false) {} - bool success; - bool ex; + bool success :1; + bool ex :1; } _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() { } - virtual ~ThriftHive_getSchema_result() throw() {} - + virtual ~ThriftHive_getSchema_result() throw(); ::Apache::Hadoop::Hive::Schema success; HiveServerException ex; _ThriftHive_getSchema_result__isset __isset; - void __set_success(const ::Apache::Hadoop::Hive::Schema& val) { - success = val; - } + void __set_success(const ::Apache::Hadoop::Hive::Schema& val); - void __set_ex(const HiveServerException& val) { - ex = val; - } + void __set_ex(const HiveServerException& val); bool operator == (const ThriftHive_getSchema_result & rhs) const { @@ -598,20 +652,23 @@ 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 { _ThriftHive_getSchema_presult__isset() : success(false), ex(false) {} - bool success; - bool ex; + bool success :1; + bool ex :1; } _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() {} + virtual ~ThriftHive_getSchema_presult() throw(); ::Apache::Hadoop::Hive::Schema* success; HiveServerException ex; @@ -619,17 +676,22 @@ 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() { } - virtual ~ThriftHive_getThriftSchema_args() throw() {} - + virtual ~ThriftHive_getThriftSchema_args() throw(); bool operator == (const ThriftHive_getThriftSchema_args & /* rhs */) const { @@ -644,46 +706,50 @@ 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() {} + 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 { _ThriftHive_getThriftSchema_result__isset() : success(false), ex(false) {} - bool success; - bool ex; + bool success :1; + bool ex :1; } _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() { } - virtual ~ThriftHive_getThriftSchema_result() throw() {} - + virtual ~ThriftHive_getThriftSchema_result() throw(); ::Apache::Hadoop::Hive::Schema success; HiveServerException ex; _ThriftHive_getThriftSchema_result__isset __isset; - void __set_success(const ::Apache::Hadoop::Hive::Schema& val) { - success = val; - } + void __set_success(const ::Apache::Hadoop::Hive::Schema& val); - void __set_ex(const HiveServerException& val) { - ex = val; - } + void __set_ex(const HiveServerException& val); bool operator == (const ThriftHive_getThriftSchema_result & rhs) const { @@ -702,20 +768,23 @@ 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 { _ThriftHive_getThriftSchema_presult__isset() : success(false), ex(false) {} - bool success; - bool ex; + bool success :1; + bool ex :1; } _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() {} + virtual ~ThriftHive_getThriftSchema_presult() throw(); ::Apache::Hadoop::Hive::Schema* success; HiveServerException ex; @@ -723,17 +792,22 @@ 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() { } - virtual ~ThriftHive_getClusterStatus_args() throw() {} - + virtual ~ThriftHive_getClusterStatus_args() throw(); bool operator == (const ThriftHive_getClusterStatus_args & /* rhs */) const { @@ -748,46 +822,50 @@ 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() {} + 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 { _ThriftHive_getClusterStatus_result__isset() : success(false), ex(false) {} - bool success; - bool ex; + bool success :1; + bool ex :1; } _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() { } - virtual ~ThriftHive_getClusterStatus_result() throw() {} - + virtual ~ThriftHive_getClusterStatus_result() throw(); HiveClusterStatus success; HiveServerException ex; _ThriftHive_getClusterStatus_result__isset __isset; - void __set_success(const HiveClusterStatus& val) { - success = val; - } + void __set_success(const HiveClusterStatus& val); - void __set_ex(const HiveServerException& val) { - ex = val; - } + void __set_ex(const HiveServerException& val); bool operator == (const ThriftHive_getClusterStatus_result & rhs) const { @@ -806,20 +884,23 @@ 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 { _ThriftHive_getClusterStatus_presult__isset() : success(false), ex(false) {} - bool success; - bool ex; + bool success :1; + bool ex :1; } _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() {} + virtual ~ThriftHive_getClusterStatus_presult() throw(); HiveClusterStatus* success; HiveServerException ex; @@ -827,17 +908,22 @@ 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() { } - virtual ~ThriftHive_getQueryPlan_args() throw() {} - + virtual ~ThriftHive_getQueryPlan_args() throw(); bool operator == (const ThriftHive_getQueryPlan_args & /* rhs */) const { @@ -852,46 +938,50 @@ 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() {} + 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 { _ThriftHive_getQueryPlan_result__isset() : success(false), ex(false) {} - bool success; - bool ex; + bool success :1; + bool ex :1; } _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() { } - virtual ~ThriftHive_getQueryPlan_result() throw() {} - + virtual ~ThriftHive_getQueryPlan_result() throw(); ::Apache::Hadoop::Hive::QueryPlan success; HiveServerException ex; _ThriftHive_getQueryPlan_result__isset __isset; - void __set_success(const ::Apache::Hadoop::Hive::QueryPlan& val) { - success = val; - } + void __set_success(const ::Apache::Hadoop::Hive::QueryPlan& val); - void __set_ex(const HiveServerException& val) { - ex = val; - } + void __set_ex(const HiveServerException& val); bool operator == (const ThriftHive_getQueryPlan_result & rhs) const { @@ -910,20 +1000,23 @@ 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 { _ThriftHive_getQueryPlan_presult__isset() : success(false), ex(false) {} - bool success; - bool ex; + bool success :1; + bool ex :1; } _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() {} + virtual ~ThriftHive_getQueryPlan_presult() throw(); ::Apache::Hadoop::Hive::QueryPlan* success; HiveServerException ex; @@ -931,17 +1024,22 @@ 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() { } - virtual ~ThriftHive_clean_args() throw() {} - + virtual ~ThriftHive_clean_args() throw(); bool operator == (const ThriftHive_clean_args & /* rhs */) const { @@ -956,29 +1054,37 @@ 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() {} + 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() { } - virtual ~ThriftHive_clean_result() throw() {} - + virtual ~ThriftHive_clean_result() throw(); bool operator == (const ThriftHive_clean_result & /* rhs */) const { @@ -993,26 +1099,29 @@ 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() {} + 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 { public: ThriftHiveClient(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> 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) {} + ThriftHiveClient(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> iprot, boost::shared_ptr< ::apache::thrift::protocol::TProtocol> oprot) : ::Apache::Hadoop::Hive::ThriftHiveMetastoreClient(iprot, oprot) {} boost::shared_ptr< ::apache::thrift::protocol::TProtocol> getInputProtocol() { return piprot_; } http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/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 3555b03..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.0) + * 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/42216997/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 e27273c..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.0) + * 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/42216997/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 255fb00..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.0) + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -7,6 +7,9 @@ #include "hive_service_types.h" #include <algorithm> +#include <ostream> + +#include <thrift/TToString.h> namespace Apache { namespace Hadoop { namespace Hive { @@ -20,6 +23,35 @@ const char* _kJobTrackerStateNames[] = { }; const std::map<int, const char*> _JobTrackerState_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(2, _kJobTrackerStateValues, _kJobTrackerStateNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL)); + +HiveClusterStatus::~HiveClusterStatus() throw() { +} + + +void HiveClusterStatus::__set_taskTrackers(const int32_t val) { + this->taskTrackers = val; +} + +void HiveClusterStatus::__set_mapTasks(const int32_t val) { + this->mapTasks = val; +} + +void HiveClusterStatus::__set_reduceTasks(const int32_t val) { + this->reduceTasks = val; +} + +void HiveClusterStatus::__set_maxMapTasks(const int32_t val) { + this->maxMapTasks = val; +} + +void HiveClusterStatus::__set_maxReduceTasks(const int32_t val) { + this->maxReduceTasks = val; +} + +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}; @@ -107,6 +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; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("HiveClusterStatus"); xfer += oprot->writeFieldBegin("taskTrackers", ::apache::thrift::protocol::T_I32, 1); @@ -135,6 +168,7 @@ uint32_t HiveClusterStatus::write(::apache::thrift::protocol::TProtocol* oprot) xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -149,6 +183,55 @@ void swap(HiveClusterStatus &a, HiveClusterStatus &b) { swap(a.__isset, b.__isset); } +HiveClusterStatus::HiveClusterStatus(const HiveClusterStatus& other1) { + taskTrackers = other1.taskTrackers; + mapTasks = other1.mapTasks; + reduceTasks = other1.reduceTasks; + maxMapTasks = other1.maxMapTasks; + maxReduceTasks = other1.maxReduceTasks; + state = other1.state; + __isset = other1.__isset; +} +HiveClusterStatus& HiveClusterStatus::operator=(const HiveClusterStatus& other2) { + taskTrackers = other2.taskTrackers; + mapTasks = other2.mapTasks; + reduceTasks = other2.reduceTasks; + maxMapTasks = other2.maxMapTasks; + maxReduceTasks = other2.maxReduceTasks; + state = other2.state; + __isset = other2.__isset; + return *this; +} +std::ostream& operator<<(std::ostream& out, const HiveClusterStatus& obj) { + using apache::thrift::to_string; + out << "HiveClusterStatus("; + 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; +} + + +HiveServerException::~HiveServerException() throw() { +} + + +void HiveServerException::__set_message(const std::string& val) { + this->message = val; +} + +void HiveServerException::__set_errorCode(const int32_t val) { + this->errorCode = val; +} + +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}; @@ -210,6 +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; + oprot->incrementRecursionDepth(); xfer += oprot->writeStructBegin("HiveServerException"); xfer += oprot->writeFieldBegin("message", ::apache::thrift::protocol::T_STRING, 1); @@ -226,6 +310,7 @@ uint32_t HiveServerException::write(::apache::thrift::protocol::TProtocol* oprot xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); + oprot->decrementRecursionDepth(); return xfer; } @@ -237,4 +322,27 @@ void swap(HiveServerException &a, HiveServerException &b) { swap(a.__isset, b.__isset); } +HiveServerException::HiveServerException(const HiveServerException& other3) : TException() { + message = other3.message; + errorCode = other3.errorCode; + SQLState = other3.SQLState; + __isset = other3.__isset; +} +HiveServerException& HiveServerException::operator=(const HiveServerException& other4) { + message = other4.message; + errorCode = other4.errorCode; + SQLState = other4.SQLState; + __isset = other4.__isset; + return *this; +} +std::ostream& operator<<(std::ostream& out, const HiveServerException& obj) { + using apache::thrift::to_string; + out << "HiveServerException("; + out << "message=" << to_string(obj.message); + out << ", " << "errorCode=" << to_string(obj.errorCode); + out << ", " << "SQLState=" << to_string(obj.SQLState); + out << ")"; + return out; +} + }}} // namespace http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/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 bc0e652..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.0) + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -7,11 +7,14 @@ #ifndef hive_service_TYPES_H #define hive_service_TYPES_H +#include <iosfwd> + #include <thrift/Thrift.h> #include <thrift/TApplicationException.h> #include <thrift/protocol/TProtocol.h> #include <thrift/transport/TTransport.h> +#include <thrift/cxxfunctional.h> #include "fb303_types.h" #include "hive_metastore_types.h" #include "queryplan_types.h" @@ -28,14 +31,18 @@ struct JobTrackerState { extern const std::map<int, const char*> _JobTrackerState_VALUES_TO_NAMES; +class HiveClusterStatus; + +class HiveServerException; + typedef struct _HiveClusterStatus__isset { _HiveClusterStatus__isset() : taskTrackers(false), mapTasks(false), reduceTasks(false), maxMapTasks(false), maxReduceTasks(false), state(false) {} - bool taskTrackers; - bool mapTasks; - bool reduceTasks; - bool maxMapTasks; - bool maxReduceTasks; - bool state; + bool taskTrackers :1; + bool mapTasks :1; + bool reduceTasks :1; + bool maxMapTasks :1; + bool maxReduceTasks :1; + bool state :1; } _HiveClusterStatus__isset; class HiveClusterStatus { @@ -44,11 +51,12 @@ 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(const HiveClusterStatus&); + HiveClusterStatus& operator=(const HiveClusterStatus&); HiveClusterStatus() : taskTrackers(0), mapTasks(0), reduceTasks(0), maxMapTasks(0), maxReduceTasks(0), state((JobTrackerState::type)0) { } - virtual ~HiveClusterStatus() throw() {} - + virtual ~HiveClusterStatus() throw(); int32_t taskTrackers; int32_t mapTasks; int32_t reduceTasks; @@ -58,29 +66,17 @@ class HiveClusterStatus { _HiveClusterStatus__isset __isset; - void __set_taskTrackers(const int32_t val) { - taskTrackers = val; - } + void __set_taskTrackers(const int32_t val); - void __set_mapTasks(const int32_t val) { - mapTasks = val; - } + void __set_mapTasks(const int32_t val); - void __set_reduceTasks(const int32_t val) { - reduceTasks = val; - } + void __set_reduceTasks(const int32_t val); - void __set_maxMapTasks(const int32_t val) { - maxMapTasks = val; - } + void __set_maxMapTasks(const int32_t val); - void __set_maxReduceTasks(const int32_t val) { - maxReduceTasks = val; - } + void __set_maxReduceTasks(const int32_t val); - void __set_state(const JobTrackerState::type val) { - state = val; - } + void __set_state(const JobTrackerState::type val); bool operator == (const HiveClusterStatus & rhs) const { @@ -107,15 +103,16 @@ class HiveClusterStatus { 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 HiveClusterStatus& obj); }; void swap(HiveClusterStatus &a, HiveClusterStatus &b); typedef struct _HiveServerException__isset { _HiveServerException__isset() : message(false), errorCode(false), SQLState(false) {} - bool message; - bool errorCode; - bool SQLState; + bool message :1; + bool errorCode :1; + bool SQLState :1; } _HiveServerException__isset; class HiveServerException : public ::apache::thrift::TException { @@ -124,28 +121,23 @@ class HiveServerException : public ::apache::thrift::TException { 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() { } - virtual ~HiveServerException() throw() {} - + virtual ~HiveServerException() throw(); std::string message; int32_t errorCode; std::string SQLState; _HiveServerException__isset __isset; - void __set_message(const std::string& val) { - message = val; - } + void __set_message(const std::string& val); - void __set_errorCode(const int32_t val) { - errorCode = val; - } + void __set_errorCode(const int32_t val); - void __set_SQLState(const std::string& val) { - SQLState = val; - } + void __set_SQLState(const std::string& val); bool operator == (const HiveServerException & rhs) const { @@ -166,6 +158,7 @@ class HiveServerException : public ::apache::thrift::TException { 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 HiveServerException& obj); }; void swap(HiveServerException &a, HiveServerException &b); http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/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 11566e5..9bfbea9 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,12 +1,11 @@ /** - * Autogenerated by Thrift Compiler (0.9.0) + * Autogenerated by Thrift Compiler (0.9.2) * * 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; @@ -16,6 +15,8 @@ import org.apache.thrift.protocol.TTupleProtocol; import org.apache.thrift.protocol.TProtocolException; import org.apache.thrift.EncodingUtils; import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; import java.util.List; import java.util.ArrayList; import java.util.Map; @@ -28,10 +29,13 @@ import java.util.Collections; import java.util.BitSet; import java.nio.ByteBuffer; import java.util.Arrays; +import javax.annotation.Generated; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class HiveClusterStatus implements org.apache.thrift.TBase<HiveClusterStatus, HiveClusterStatus._Fields>, java.io.Serializable, Cloneable { +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14") +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"); private static final org.apache.thrift.protocol.TField TASK_TRACKERS_FIELD_DESC = new org.apache.thrift.protocol.TField("taskTrackers", org.apache.thrift.protocol.TType.I32, (short)1); @@ -529,105 +533,105 @@ public class HiveClusterStatus implements org.apache.thrift.TBase<HiveClusterSta @Override public int hashCode() { - HashCodeBuilder builder = new HashCodeBuilder(); + List<Object> list = new ArrayList<Object>(); boolean present_taskTrackers = true; - builder.append(present_taskTrackers); + list.add(present_taskTrackers); if (present_taskTrackers) - builder.append(taskTrackers); + list.add(taskTrackers); boolean present_mapTasks = true; - builder.append(present_mapTasks); + list.add(present_mapTasks); if (present_mapTasks) - builder.append(mapTasks); + list.add(mapTasks); boolean present_reduceTasks = true; - builder.append(present_reduceTasks); + list.add(present_reduceTasks); if (present_reduceTasks) - builder.append(reduceTasks); + list.add(reduceTasks); boolean present_maxMapTasks = true; - builder.append(present_maxMapTasks); + list.add(present_maxMapTasks); if (present_maxMapTasks) - builder.append(maxMapTasks); + list.add(maxMapTasks); boolean present_maxReduceTasks = true; - builder.append(present_maxReduceTasks); + list.add(present_maxReduceTasks); if (present_maxReduceTasks) - builder.append(maxReduceTasks); + list.add(maxReduceTasks); boolean present_state = true && (isSetState()); - builder.append(present_state); + list.add(present_state); if (present_state) - builder.append(state.getValue()); + list.add(state.getValue()); - return builder.toHashCode(); + return list.hashCode(); } + @Override public int compareTo(HiveClusterStatus other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - HiveClusterStatus typedOther = (HiveClusterStatus)other; - lastComparison = Boolean.valueOf(isSetTaskTrackers()).compareTo(typedOther.isSetTaskTrackers()); + lastComparison = Boolean.valueOf(isSetTaskTrackers()).compareTo(other.isSetTaskTrackers()); if (lastComparison != 0) { return lastComparison; } if (isSetTaskTrackers()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.taskTrackers, typedOther.taskTrackers); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.taskTrackers, other.taskTrackers); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetMapTasks()).compareTo(typedOther.isSetMapTasks()); + lastComparison = Boolean.valueOf(isSetMapTasks()).compareTo(other.isSetMapTasks()); if (lastComparison != 0) { return lastComparison; } if (isSetMapTasks()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.mapTasks, typedOther.mapTasks); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.mapTasks, other.mapTasks); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetReduceTasks()).compareTo(typedOther.isSetReduceTasks()); + lastComparison = Boolean.valueOf(isSetReduceTasks()).compareTo(other.isSetReduceTasks()); if (lastComparison != 0) { return lastComparison; } if (isSetReduceTasks()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.reduceTasks, typedOther.reduceTasks); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.reduceTasks, other.reduceTasks); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetMaxMapTasks()).compareTo(typedOther.isSetMaxMapTasks()); + lastComparison = Boolean.valueOf(isSetMaxMapTasks()).compareTo(other.isSetMaxMapTasks()); if (lastComparison != 0) { return lastComparison; } if (isSetMaxMapTasks()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.maxMapTasks, typedOther.maxMapTasks); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.maxMapTasks, other.maxMapTasks); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetMaxReduceTasks()).compareTo(typedOther.isSetMaxReduceTasks()); + lastComparison = Boolean.valueOf(isSetMaxReduceTasks()).compareTo(other.isSetMaxReduceTasks()); if (lastComparison != 0) { return lastComparison; } if (isSetMaxReduceTasks()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.maxReduceTasks, typedOther.maxReduceTasks); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.maxReduceTasks, other.maxReduceTasks); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetState()).compareTo(typedOther.isSetState()); + lastComparison = Boolean.valueOf(isSetState()).compareTo(other.isSetState()); if (lastComparison != 0) { return lastComparison; } if (isSetState()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.state, typedOther.state); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.state, other.state); if (lastComparison != 0) { return lastComparison; } @@ -766,7 +770,7 @@ public class HiveClusterStatus implements org.apache.thrift.TBase<HiveClusterSta break; case 6: // STATE if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.state = JobTrackerState.findByValue(iprot.readI32()); + struct.state = org.apache.hadoop.hive.service.JobTrackerState.findByValue(iprot.readI32()); struct.setStateIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -887,7 +891,7 @@ public class HiveClusterStatus implements org.apache.thrift.TBase<HiveClusterSta struct.setMaxReduceTasksIsSet(true); } if (incoming.get(5)) { - struct.state = JobTrackerState.findByValue(iprot.readI32()); + struct.state = org.apache.hadoop.hive.service.JobTrackerState.findByValue(iprot.readI32()); struct.setStateIsSet(true); } } http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/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 353dc8a..da8d1bc 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,12 +1,11 @@ /** - * Autogenerated by Thrift Compiler (0.9.0) + * Autogenerated by Thrift Compiler (0.9.2) * * 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; @@ -16,6 +15,8 @@ import org.apache.thrift.protocol.TTupleProtocol; import org.apache.thrift.protocol.TProtocolException; import org.apache.thrift.EncodingUtils; import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; import java.util.List; import java.util.ArrayList; import java.util.Map; @@ -28,10 +29,13 @@ import java.util.Collections; import java.util.BitSet; import java.nio.ByteBuffer; import java.util.Arrays; +import javax.annotation.Generated; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class HiveServerException extends TException implements org.apache.thrift.TBase<HiveServerException, HiveServerException._Fields>, java.io.Serializable, Cloneable { +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14") +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"); private static final org.apache.thrift.protocol.TField MESSAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("message", org.apache.thrift.protocol.TType.STRING, (short)1); @@ -343,60 +347,60 @@ public class HiveServerException extends TException implements org.apache.thrift @Override public int hashCode() { - HashCodeBuilder builder = new HashCodeBuilder(); + List<Object> list = new ArrayList<Object>(); boolean present_message = true && (isSetMessage()); - builder.append(present_message); + list.add(present_message); if (present_message) - builder.append(message); + list.add(message); boolean present_errorCode = true; - builder.append(present_errorCode); + list.add(present_errorCode); if (present_errorCode) - builder.append(errorCode); + list.add(errorCode); boolean present_SQLState = true && (isSetSQLState()); - builder.append(present_SQLState); + list.add(present_SQLState); if (present_SQLState) - builder.append(SQLState); + list.add(SQLState); - return builder.toHashCode(); + return list.hashCode(); } + @Override public int compareTo(HiveServerException other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - HiveServerException typedOther = (HiveServerException)other; - lastComparison = Boolean.valueOf(isSetMessage()).compareTo(typedOther.isSetMessage()); + lastComparison = Boolean.valueOf(isSetMessage()).compareTo(other.isSetMessage()); if (lastComparison != 0) { return lastComparison; } if (isSetMessage()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.message, typedOther.message); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.message, other.message); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetErrorCode()).compareTo(typedOther.isSetErrorCode()); + lastComparison = Boolean.valueOf(isSetErrorCode()).compareTo(other.isSetErrorCode()); if (lastComparison != 0) { return lastComparison; } if (isSetErrorCode()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.errorCode, typedOther.errorCode); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.errorCode, other.errorCode); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetSQLState()).compareTo(typedOther.isSetSQLState()); + lastComparison = Boolean.valueOf(isSetSQLState()).compareTo(other.isSetSQLState()); if (lastComparison != 0) { return lastComparison; } if (isSetSQLState()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.SQLState, typedOther.SQLState); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.SQLState, other.SQLState); if (lastComparison != 0) { return lastComparison; } http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/JobTrackerState.java ---------------------------------------------------------------------- diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/JobTrackerState.java b/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/JobTrackerState.java index 5de66c5..ab48bf7 100644 --- a/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/JobTrackerState.java +++ b/service/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/service/JobTrackerState.java @@ -1,5 +1,5 @@ /** - * Autogenerated by Thrift Compiler (0.9.0) + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated
