http://git-wip-us.apache.org/repos/asf/hive/blob/77511070/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp b/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp index cfa2e49..fd2bdde 100644 --- a/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp +++ b/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp @@ -4486,16 +4486,6 @@ void Table::__set_rewriteEnabled(const bool val) { __isset.rewriteEnabled = true; } -void Table::__set_mmNextWriteId(const int64_t val) { - this->mmNextWriteId = val; -__isset.mmNextWriteId = true; -} - -void Table::__set_mmWatermarkWriteId(const int64_t val) { - this->mmWatermarkWriteId = val; -__isset.mmWatermarkWriteId = true; -} - uint32_t Table::read(::apache::thrift::protocol::TProtocol* iprot) { apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); @@ -4664,22 +4654,6 @@ uint32_t Table::read(::apache::thrift::protocol::TProtocol* iprot) { xfer += iprot->skip(ftype); } break; - case 16: - if (ftype == ::apache::thrift::protocol::T_I64) { - xfer += iprot->readI64(this->mmNextWriteId); - this->__isset.mmNextWriteId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 17: - if (ftype == ::apache::thrift::protocol::T_I64) { - xfer += iprot->readI64(this->mmWatermarkWriteId); - this->__isset.mmWatermarkWriteId = true; - } else { - xfer += iprot->skip(ftype); - } - break; default: xfer += iprot->skip(ftype); break; @@ -4777,16 +4751,6 @@ uint32_t Table::write(::apache::thrift::protocol::TProtocol* oprot) const { xfer += oprot->writeBool(this->rewriteEnabled); xfer += oprot->writeFieldEnd(); } - if (this->__isset.mmNextWriteId) { - xfer += oprot->writeFieldBegin("mmNextWriteId", ::apache::thrift::protocol::T_I64, 16); - xfer += oprot->writeI64(this->mmNextWriteId); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.mmWatermarkWriteId) { - xfer += oprot->writeFieldBegin("mmWatermarkWriteId", ::apache::thrift::protocol::T_I64, 17); - xfer += oprot->writeI64(this->mmWatermarkWriteId); - xfer += oprot->writeFieldEnd(); - } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; @@ -4809,8 +4773,6 @@ void swap(Table &a, Table &b) { swap(a.privileges, b.privileges); swap(a.temporary, b.temporary); swap(a.rewriteEnabled, b.rewriteEnabled); - swap(a.mmNextWriteId, b.mmNextWriteId); - swap(a.mmWatermarkWriteId, b.mmWatermarkWriteId); swap(a.__isset, b.__isset); } @@ -4830,8 +4792,6 @@ Table::Table(const Table& other221) { privileges = other221.privileges; temporary = other221.temporary; rewriteEnabled = other221.rewriteEnabled; - mmNextWriteId = other221.mmNextWriteId; - mmWatermarkWriteId = other221.mmWatermarkWriteId; __isset = other221.__isset; } Table& Table::operator=(const Table& other222) { @@ -4850,8 +4810,6 @@ Table& Table::operator=(const Table& other222) { privileges = other222.privileges; temporary = other222.temporary; rewriteEnabled = other222.rewriteEnabled; - mmNextWriteId = other222.mmNextWriteId; - mmWatermarkWriteId = other222.mmWatermarkWriteId; __isset = other222.__isset; return *this; } @@ -4873,8 +4831,6 @@ void Table::printTo(std::ostream& out) const { out << ", " << "privileges="; (__isset.privileges ? (out << to_string(privileges)) : (out << "<null>")); out << ", " << "temporary="; (__isset.temporary ? (out << to_string(temporary)) : (out << "<null>")); out << ", " << "rewriteEnabled="; (__isset.rewriteEnabled ? (out << to_string(rewriteEnabled)) : (out << "<null>")); - out << ", " << "mmNextWriteId="; (__isset.mmNextWriteId ? (out << to_string(mmNextWriteId)) : (out << "<null>")); - out << ", " << "mmWatermarkWriteId="; (__isset.mmWatermarkWriteId ? (out << to_string(mmWatermarkWriteId)) : (out << "<null>")); out << ")"; } @@ -18017,19 +17973,16 @@ void CacheFileMetadataRequest::printTo(std::ostream& out) const { } -GetNextWriteIdRequest::~GetNextWriteIdRequest() throw() { +GetAllFunctionsResponse::~GetAllFunctionsResponse() throw() { } -void GetNextWriteIdRequest::__set_dbName(const std::string& val) { - this->dbName = val; -} - -void GetNextWriteIdRequest::__set_tblName(const std::string& val) { - this->tblName = val; +void GetAllFunctionsResponse::__set_functions(const std::vector<Function> & val) { + this->functions = val; +__isset.functions = true; } -uint32_t GetNextWriteIdRequest::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t GetAllFunctionsResponse::read(::apache::thrift::protocol::TProtocol* iprot) { apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; @@ -18041,8 +17994,6 @@ uint32_t GetNextWriteIdRequest::read(::apache::thrift::protocol::TProtocol* ipro using ::apache::thrift::protocol::TProtocolException; - bool isset_dbName = false; - bool isset_tblName = false; while (true) { @@ -18053,17 +18004,21 @@ uint32_t GetNextWriteIdRequest::read(::apache::thrift::protocol::TProtocol* ipro switch (fid) { case 1: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->dbName); - isset_dbName = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->tblName); - isset_tblName = true; + if (ftype == ::apache::thrift::protocol::T_LIST) { + { + this->functions.clear(); + uint32_t _size746; + ::apache::thrift::protocol::TType _etype749; + xfer += iprot->readListBegin(_etype749, _size746); + this->functions.resize(_size746); + uint32_t _i750; + for (_i750 = 0; _i750 < _size746; ++_i750) + { + xfer += this->functions[_i750].read(iprot); + } + xfer += iprot->readListEnd(); + } + this->__isset.functions = true; } else { xfer += iprot->skip(ftype); } @@ -18077,64 +18032,64 @@ uint32_t GetNextWriteIdRequest::read(::apache::thrift::protocol::TProtocol* ipro xfer += iprot->readStructEnd(); - if (!isset_dbName) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_tblName) - throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t GetNextWriteIdRequest::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t GetAllFunctionsResponse::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("GetNextWriteIdRequest"); - - xfer += oprot->writeFieldBegin("dbName", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->dbName); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("tblName", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->tblName); - xfer += oprot->writeFieldEnd(); + xfer += oprot->writeStructBegin("GetAllFunctionsResponse"); + if (this->__isset.functions) { + xfer += oprot->writeFieldBegin("functions", ::apache::thrift::protocol::T_LIST, 1); + { + xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->functions.size())); + std::vector<Function> ::const_iterator _iter751; + for (_iter751 = this->functions.begin(); _iter751 != this->functions.end(); ++_iter751) + { + xfer += (*_iter751).write(oprot); + } + xfer += oprot->writeListEnd(); + } + xfer += oprot->writeFieldEnd(); + } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } -void swap(GetNextWriteIdRequest &a, GetNextWriteIdRequest &b) { +void swap(GetAllFunctionsResponse &a, GetAllFunctionsResponse &b) { using ::std::swap; - swap(a.dbName, b.dbName); - swap(a.tblName, b.tblName); + swap(a.functions, b.functions); + swap(a.__isset, b.__isset); } -GetNextWriteIdRequest::GetNextWriteIdRequest(const GetNextWriteIdRequest& other746) { - dbName = other746.dbName; - tblName = other746.tblName; +GetAllFunctionsResponse::GetAllFunctionsResponse(const GetAllFunctionsResponse& other752) { + functions = other752.functions; + __isset = other752.__isset; } -GetNextWriteIdRequest& GetNextWriteIdRequest::operator=(const GetNextWriteIdRequest& other747) { - dbName = other747.dbName; - tblName = other747.tblName; +GetAllFunctionsResponse& GetAllFunctionsResponse::operator=(const GetAllFunctionsResponse& other753) { + functions = other753.functions; + __isset = other753.__isset; return *this; } -void GetNextWriteIdRequest::printTo(std::ostream& out) const { +void GetAllFunctionsResponse::printTo(std::ostream& out) const { using ::apache::thrift::to_string; - out << "GetNextWriteIdRequest("; - out << "dbName=" << to_string(dbName); - out << ", " << "tblName=" << to_string(tblName); + out << "GetAllFunctionsResponse("; + out << "functions="; (__isset.functions ? (out << to_string(functions)) : (out << "<null>")); out << ")"; } -GetNextWriteIdResult::~GetNextWriteIdResult() throw() { +ClientCapabilities::~ClientCapabilities() throw() { } -void GetNextWriteIdResult::__set_writeId(const int64_t val) { - this->writeId = val; +void ClientCapabilities::__set_values(const std::vector<ClientCapability::type> & val) { + this->values = val; } -uint32_t GetNextWriteIdResult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t ClientCapabilities::read(::apache::thrift::protocol::TProtocol* iprot) { apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; @@ -18146,7 +18101,7 @@ uint32_t GetNextWriteIdResult::read(::apache::thrift::protocol::TProtocol* iprot using ::apache::thrift::protocol::TProtocolException; - bool isset_writeId = false; + bool isset_values = false; while (true) { @@ -18157,9 +18112,23 @@ uint32_t GetNextWriteIdResult::read(::apache::thrift::protocol::TProtocol* iprot switch (fid) { case 1: - if (ftype == ::apache::thrift::protocol::T_I64) { - xfer += iprot->readI64(this->writeId); - isset_writeId = true; + if (ftype == ::apache::thrift::protocol::T_LIST) { + { + this->values.clear(); + uint32_t _size754; + ::apache::thrift::protocol::TType _etype757; + xfer += iprot->readListBegin(_etype757, _size754); + this->values.resize(_size754); + uint32_t _i758; + for (_i758 = 0; _i758 < _size754; ++_i758) + { + int32_t ecast759; + xfer += iprot->readI32(ecast759); + this->values[_i758] = (ClientCapability::type)ecast759; + } + xfer += iprot->readListEnd(); + } + isset_values = true; } else { xfer += iprot->skip(ftype); } @@ -18173,18 +18142,26 @@ uint32_t GetNextWriteIdResult::read(::apache::thrift::protocol::TProtocol* iprot xfer += iprot->readStructEnd(); - if (!isset_writeId) + if (!isset_values) throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t GetNextWriteIdResult::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t ClientCapabilities::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("GetNextWriteIdResult"); + xfer += oprot->writeStructBegin("ClientCapabilities"); - xfer += oprot->writeFieldBegin("writeId", ::apache::thrift::protocol::T_I64, 1); - xfer += oprot->writeI64(this->writeId); + xfer += oprot->writeFieldBegin("values", ::apache::thrift::protocol::T_LIST, 1); + { + xfer += oprot->writeListBegin(::apache::thrift::protocol::T_I32, static_cast<uint32_t>(this->values.size())); + std::vector<ClientCapability::type> ::const_iterator _iter760; + for (_iter760 = this->values.begin(); _iter760 != this->values.end(); ++_iter760) + { + xfer += oprot->writeI32((int32_t)(*_iter760)); + } + xfer += oprot->writeListEnd(); + } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); @@ -18192,47 +18169,44 @@ uint32_t GetNextWriteIdResult::write(::apache::thrift::protocol::TProtocol* opro return xfer; } -void swap(GetNextWriteIdResult &a, GetNextWriteIdResult &b) { +void swap(ClientCapabilities &a, ClientCapabilities &b) { using ::std::swap; - swap(a.writeId, b.writeId); + swap(a.values, b.values); } -GetNextWriteIdResult::GetNextWriteIdResult(const GetNextWriteIdResult& other748) { - writeId = other748.writeId; +ClientCapabilities::ClientCapabilities(const ClientCapabilities& other761) { + values = other761.values; } -GetNextWriteIdResult& GetNextWriteIdResult::operator=(const GetNextWriteIdResult& other749) { - writeId = other749.writeId; +ClientCapabilities& ClientCapabilities::operator=(const ClientCapabilities& other762) { + values = other762.values; return *this; } -void GetNextWriteIdResult::printTo(std::ostream& out) const { +void ClientCapabilities::printTo(std::ostream& out) const { using ::apache::thrift::to_string; - out << "GetNextWriteIdResult("; - out << "writeId=" << to_string(writeId); + out << "ClientCapabilities("; + out << "values=" << to_string(values); out << ")"; } -FinalizeWriteIdRequest::~FinalizeWriteIdRequest() throw() { +GetTableRequest::~GetTableRequest() throw() { } -void FinalizeWriteIdRequest::__set_dbName(const std::string& val) { +void GetTableRequest::__set_dbName(const std::string& val) { this->dbName = val; } -void FinalizeWriteIdRequest::__set_tblName(const std::string& val) { +void GetTableRequest::__set_tblName(const std::string& val) { this->tblName = val; } -void FinalizeWriteIdRequest::__set_writeId(const int64_t val) { - this->writeId = val; -} - -void FinalizeWriteIdRequest::__set_commit(const bool val) { - this->commit = val; +void GetTableRequest::__set_capabilities(const ClientCapabilities& val) { + this->capabilities = val; +__isset.capabilities = true; } -uint32_t FinalizeWriteIdRequest::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t GetTableRequest::read(::apache::thrift::protocol::TProtocol* iprot) { apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; @@ -18246,8 +18220,6 @@ uint32_t FinalizeWriteIdRequest::read(::apache::thrift::protocol::TProtocol* ipr bool isset_dbName = false; bool isset_tblName = false; - bool isset_writeId = false; - bool isset_commit = false; while (true) { @@ -18274,17 +18246,9 @@ uint32_t FinalizeWriteIdRequest::read(::apache::thrift::protocol::TProtocol* ipr } break; case 3: - if (ftype == ::apache::thrift::protocol::T_I64) { - xfer += iprot->readI64(this->writeId); - isset_writeId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 4: - if (ftype == ::apache::thrift::protocol::T_BOOL) { - xfer += iprot->readBool(this->commit); - isset_commit = true; + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->capabilities.read(iprot); + this->__isset.capabilities = true; } else { xfer += iprot->skip(ftype); } @@ -18302,17 +18266,13 @@ uint32_t FinalizeWriteIdRequest::read(::apache::thrift::protocol::TProtocol* ipr throw TProtocolException(TProtocolException::INVALID_DATA); if (!isset_tblName) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_writeId) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_commit) - throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t FinalizeWriteIdRequest::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t GetTableRequest::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("FinalizeWriteIdRequest"); + xfer += oprot->writeStructBegin("GetTableRequest"); xfer += oprot->writeFieldBegin("dbName", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString(this->dbName); @@ -18322,56 +18282,56 @@ uint32_t FinalizeWriteIdRequest::write(::apache::thrift::protocol::TProtocol* op xfer += oprot->writeString(this->tblName); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("writeId", ::apache::thrift::protocol::T_I64, 3); - xfer += oprot->writeI64(this->writeId); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("commit", ::apache::thrift::protocol::T_BOOL, 4); - xfer += oprot->writeBool(this->commit); - xfer += oprot->writeFieldEnd(); - + if (this->__isset.capabilities) { + xfer += oprot->writeFieldBegin("capabilities", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->capabilities.write(oprot); + xfer += oprot->writeFieldEnd(); + } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } -void swap(FinalizeWriteIdRequest &a, FinalizeWriteIdRequest &b) { +void swap(GetTableRequest &a, GetTableRequest &b) { using ::std::swap; swap(a.dbName, b.dbName); swap(a.tblName, b.tblName); - swap(a.writeId, b.writeId); - swap(a.commit, b.commit); + swap(a.capabilities, b.capabilities); + swap(a.__isset, b.__isset); } -FinalizeWriteIdRequest::FinalizeWriteIdRequest(const FinalizeWriteIdRequest& other750) { - dbName = other750.dbName; - tblName = other750.tblName; - writeId = other750.writeId; - commit = other750.commit; +GetTableRequest::GetTableRequest(const GetTableRequest& other763) { + dbName = other763.dbName; + tblName = other763.tblName; + capabilities = other763.capabilities; + __isset = other763.__isset; } -FinalizeWriteIdRequest& FinalizeWriteIdRequest::operator=(const FinalizeWriteIdRequest& other751) { - dbName = other751.dbName; - tblName = other751.tblName; - writeId = other751.writeId; - commit = other751.commit; +GetTableRequest& GetTableRequest::operator=(const GetTableRequest& other764) { + dbName = other764.dbName; + tblName = other764.tblName; + capabilities = other764.capabilities; + __isset = other764.__isset; return *this; } -void FinalizeWriteIdRequest::printTo(std::ostream& out) const { +void GetTableRequest::printTo(std::ostream& out) const { using ::apache::thrift::to_string; - out << "FinalizeWriteIdRequest("; + out << "GetTableRequest("; out << "dbName=" << to_string(dbName); out << ", " << "tblName=" << to_string(tblName); - out << ", " << "writeId=" << to_string(writeId); - out << ", " << "commit=" << to_string(commit); + out << ", " << "capabilities="; (__isset.capabilities ? (out << to_string(capabilities)) : (out << "<null>")); out << ")"; } -FinalizeWriteIdResult::~FinalizeWriteIdResult() throw() { +GetTableResult::~GetTableResult() throw() { } -uint32_t FinalizeWriteIdResult::read(::apache::thrift::protocol::TProtocol* iprot) { +void GetTableResult::__set_table(const Table& val) { + this->table = val; +} + +uint32_t GetTableResult::read(::apache::thrift::protocol::TProtocol* iprot) { apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; @@ -18383,6 +18343,7 @@ uint32_t FinalizeWriteIdResult::read(::apache::thrift::protocol::TProtocol* ipro using ::apache::thrift::protocol::TProtocolException; + bool isset_table = false; while (true) { @@ -18390,62 +18351,83 @@ uint32_t FinalizeWriteIdResult::read(::apache::thrift::protocol::TProtocol* ipro if (ftype == ::apache::thrift::protocol::T_STOP) { break; } - xfer += iprot->skip(ftype); + switch (fid) + { + case 1: + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->table.read(iprot); + isset_table = true; + } else { + xfer += iprot->skip(ftype); + } + break; + default: + xfer += iprot->skip(ftype); + break; + } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); + if (!isset_table) + throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t FinalizeWriteIdResult::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t GetTableResult::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("FinalizeWriteIdResult"); + xfer += oprot->writeStructBegin("GetTableResult"); + + xfer += oprot->writeFieldBegin("table", ::apache::thrift::protocol::T_STRUCT, 1); + xfer += this->table.write(oprot); + xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } -void swap(FinalizeWriteIdResult &a, FinalizeWriteIdResult &b) { +void swap(GetTableResult &a, GetTableResult &b) { using ::std::swap; - (void) a; - (void) b; + swap(a.table, b.table); } -FinalizeWriteIdResult::FinalizeWriteIdResult(const FinalizeWriteIdResult& other752) { - (void) other752; +GetTableResult::GetTableResult(const GetTableResult& other765) { + table = other765.table; } -FinalizeWriteIdResult& FinalizeWriteIdResult::operator=(const FinalizeWriteIdResult& other753) { - (void) other753; +GetTableResult& GetTableResult::operator=(const GetTableResult& other766) { + table = other766.table; return *this; } -void FinalizeWriteIdResult::printTo(std::ostream& out) const { +void GetTableResult::printTo(std::ostream& out) const { using ::apache::thrift::to_string; - out << "FinalizeWriteIdResult("; + out << "GetTableResult("; + out << "table=" << to_string(table); out << ")"; } -HeartbeatWriteIdRequest::~HeartbeatWriteIdRequest() throw() { +GetTablesRequest::~GetTablesRequest() throw() { } -void HeartbeatWriteIdRequest::__set_dbName(const std::string& val) { +void GetTablesRequest::__set_dbName(const std::string& val) { this->dbName = val; } -void HeartbeatWriteIdRequest::__set_tblName(const std::string& val) { - this->tblName = val; +void GetTablesRequest::__set_tblNames(const std::vector<std::string> & val) { + this->tblNames = val; +__isset.tblNames = true; } -void HeartbeatWriteIdRequest::__set_writeId(const int64_t val) { - this->writeId = val; +void GetTablesRequest::__set_capabilities(const ClientCapabilities& val) { + this->capabilities = val; +__isset.capabilities = true; } -uint32_t HeartbeatWriteIdRequest::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t GetTablesRequest::read(::apache::thrift::protocol::TProtocol* iprot) { apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; @@ -18458,8 +18440,6 @@ uint32_t HeartbeatWriteIdRequest::read(::apache::thrift::protocol::TProtocol* ip using ::apache::thrift::protocol::TProtocolException; bool isset_dbName = false; - bool isset_tblName = false; - bool isset_writeId = false; while (true) { @@ -18478,17 +18458,29 @@ uint32_t HeartbeatWriteIdRequest::read(::apache::thrift::protocol::TProtocol* ip } break; case 2: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->tblName); - isset_tblName = true; + if (ftype == ::apache::thrift::protocol::T_LIST) { + { + this->tblNames.clear(); + uint32_t _size767; + ::apache::thrift::protocol::TType _etype770; + xfer += iprot->readListBegin(_etype770, _size767); + this->tblNames.resize(_size767); + uint32_t _i771; + for (_i771 = 0; _i771 < _size767; ++_i771) + { + xfer += iprot->readString(this->tblNames[_i771]); + } + xfer += iprot->readListEnd(); + } + this->__isset.tblNames = true; } else { xfer += iprot->skip(ftype); } break; case 3: - if (ftype == ::apache::thrift::protocol::T_I64) { - xfer += iprot->readI64(this->writeId); - isset_writeId = true; + if (ftype == ::apache::thrift::protocol::T_STRUCT) { + xfer += this->capabilities.read(iprot); + this->__isset.capabilities = true; } else { xfer += iprot->skip(ftype); } @@ -18504,1008 +18496,81 @@ uint32_t HeartbeatWriteIdRequest::read(::apache::thrift::protocol::TProtocol* ip if (!isset_dbName) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_tblName) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_writeId) - throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } -uint32_t HeartbeatWriteIdRequest::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t GetTablesRequest::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("HeartbeatWriteIdRequest"); + xfer += oprot->writeStructBegin("GetTablesRequest"); xfer += oprot->writeFieldBegin("dbName", ::apache::thrift::protocol::T_STRING, 1); xfer += oprot->writeString(this->dbName); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("tblName", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->tblName); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("writeId", ::apache::thrift::protocol::T_I64, 3); - xfer += oprot->writeI64(this->writeId); - xfer += oprot->writeFieldEnd(); - + if (this->__isset.tblNames) { + xfer += oprot->writeFieldBegin("tblNames", ::apache::thrift::protocol::T_LIST, 2); + { + xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->tblNames.size())); + std::vector<std::string> ::const_iterator _iter772; + for (_iter772 = this->tblNames.begin(); _iter772 != this->tblNames.end(); ++_iter772) + { + xfer += oprot->writeString((*_iter772)); + } + xfer += oprot->writeListEnd(); + } + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.capabilities) { + xfer += oprot->writeFieldBegin("capabilities", ::apache::thrift::protocol::T_STRUCT, 3); + xfer += this->capabilities.write(oprot); + xfer += oprot->writeFieldEnd(); + } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } -void swap(HeartbeatWriteIdRequest &a, HeartbeatWriteIdRequest &b) { +void swap(GetTablesRequest &a, GetTablesRequest &b) { using ::std::swap; swap(a.dbName, b.dbName); - swap(a.tblName, b.tblName); - swap(a.writeId, b.writeId); + swap(a.tblNames, b.tblNames); + swap(a.capabilities, b.capabilities); + swap(a.__isset, b.__isset); } -HeartbeatWriteIdRequest::HeartbeatWriteIdRequest(const HeartbeatWriteIdRequest& other754) { - dbName = other754.dbName; - tblName = other754.tblName; - writeId = other754.writeId; +GetTablesRequest::GetTablesRequest(const GetTablesRequest& other773) { + dbName = other773.dbName; + tblNames = other773.tblNames; + capabilities = other773.capabilities; + __isset = other773.__isset; } -HeartbeatWriteIdRequest& HeartbeatWriteIdRequest::operator=(const HeartbeatWriteIdRequest& other755) { - dbName = other755.dbName; - tblName = other755.tblName; - writeId = other755.writeId; +GetTablesRequest& GetTablesRequest::operator=(const GetTablesRequest& other774) { + dbName = other774.dbName; + tblNames = other774.tblNames; + capabilities = other774.capabilities; + __isset = other774.__isset; return *this; } -void HeartbeatWriteIdRequest::printTo(std::ostream& out) const { +void GetTablesRequest::printTo(std::ostream& out) const { using ::apache::thrift::to_string; - out << "HeartbeatWriteIdRequest("; + out << "GetTablesRequest("; out << "dbName=" << to_string(dbName); - out << ", " << "tblName=" << to_string(tblName); - out << ", " << "writeId=" << to_string(writeId); + out << ", " << "tblNames="; (__isset.tblNames ? (out << to_string(tblNames)) : (out << "<null>")); + out << ", " << "capabilities="; (__isset.capabilities ? (out << to_string(capabilities)) : (out << "<null>")); out << ")"; } -HeartbeatWriteIdResult::~HeartbeatWriteIdResult() throw() { +GetTablesResult::~GetTablesResult() throw() { } -uint32_t HeartbeatWriteIdResult::read(::apache::thrift::protocol::TProtocol* iprot) { - - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - xfer += iprot->skip(ftype); - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - return xfer; -} - -uint32_t HeartbeatWriteIdResult::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("HeartbeatWriteIdResult"); - - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(HeartbeatWriteIdResult &a, HeartbeatWriteIdResult &b) { - using ::std::swap; - (void) a; - (void) b; -} - -HeartbeatWriteIdResult::HeartbeatWriteIdResult(const HeartbeatWriteIdResult& other756) { - (void) other756; -} -HeartbeatWriteIdResult& HeartbeatWriteIdResult::operator=(const HeartbeatWriteIdResult& other757) { - (void) other757; - return *this; -} -void HeartbeatWriteIdResult::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "HeartbeatWriteIdResult("; - out << ")"; -} - - -GetValidWriteIdsRequest::~GetValidWriteIdsRequest() throw() { -} - - -void GetValidWriteIdsRequest::__set_dbName(const std::string& val) { - this->dbName = val; -} - -void GetValidWriteIdsRequest::__set_tblName(const std::string& val) { - this->tblName = val; -} - -uint32_t GetValidWriteIdsRequest::read(::apache::thrift::protocol::TProtocol* iprot) { - - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - bool isset_dbName = false; - bool isset_tblName = false; - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 1: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->dbName); - isset_dbName = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->tblName); - isset_tblName = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_dbName) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_tblName) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t GetValidWriteIdsRequest::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("GetValidWriteIdsRequest"); - - xfer += oprot->writeFieldBegin("dbName", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->dbName); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("tblName", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->tblName); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(GetValidWriteIdsRequest &a, GetValidWriteIdsRequest &b) { - using ::std::swap; - swap(a.dbName, b.dbName); - swap(a.tblName, b.tblName); -} - -GetValidWriteIdsRequest::GetValidWriteIdsRequest(const GetValidWriteIdsRequest& other758) { - dbName = other758.dbName; - tblName = other758.tblName; -} -GetValidWriteIdsRequest& GetValidWriteIdsRequest::operator=(const GetValidWriteIdsRequest& other759) { - dbName = other759.dbName; - tblName = other759.tblName; - return *this; -} -void GetValidWriteIdsRequest::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "GetValidWriteIdsRequest("; - out << "dbName=" << to_string(dbName); - out << ", " << "tblName=" << to_string(tblName); - out << ")"; -} - - -GetValidWriteIdsResult::~GetValidWriteIdsResult() throw() { -} - - -void GetValidWriteIdsResult::__set_lowWatermarkId(const int64_t val) { - this->lowWatermarkId = val; -} - -void GetValidWriteIdsResult::__set_highWatermarkId(const int64_t val) { - this->highWatermarkId = val; -} - -void GetValidWriteIdsResult::__set_areIdsValid(const bool val) { - this->areIdsValid = val; -__isset.areIdsValid = true; -} - -void GetValidWriteIdsResult::__set_ids(const std::vector<int64_t> & val) { - this->ids = val; -__isset.ids = true; -} - -uint32_t GetValidWriteIdsResult::read(::apache::thrift::protocol::TProtocol* iprot) { - - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - bool isset_lowWatermarkId = false; - bool isset_highWatermarkId = false; - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 1: - if (ftype == ::apache::thrift::protocol::T_I64) { - xfer += iprot->readI64(this->lowWatermarkId); - isset_lowWatermarkId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_I64) { - xfer += iprot->readI64(this->highWatermarkId); - isset_highWatermarkId = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: - if (ftype == ::apache::thrift::protocol::T_BOOL) { - xfer += iprot->readBool(this->areIdsValid); - this->__isset.areIdsValid = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 4: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->ids.clear(); - uint32_t _size760; - ::apache::thrift::protocol::TType _etype763; - xfer += iprot->readListBegin(_etype763, _size760); - this->ids.resize(_size760); - uint32_t _i764; - for (_i764 = 0; _i764 < _size760; ++_i764) - { - xfer += iprot->readI64(this->ids[_i764]); - } - xfer += iprot->readListEnd(); - } - this->__isset.ids = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_lowWatermarkId) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_highWatermarkId) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t GetValidWriteIdsResult::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("GetValidWriteIdsResult"); - - xfer += oprot->writeFieldBegin("lowWatermarkId", ::apache::thrift::protocol::T_I64, 1); - xfer += oprot->writeI64(this->lowWatermarkId); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("highWatermarkId", ::apache::thrift::protocol::T_I64, 2); - xfer += oprot->writeI64(this->highWatermarkId); - xfer += oprot->writeFieldEnd(); - - if (this->__isset.areIdsValid) { - xfer += oprot->writeFieldBegin("areIdsValid", ::apache::thrift::protocol::T_BOOL, 3); - xfer += oprot->writeBool(this->areIdsValid); - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.ids) { - xfer += oprot->writeFieldBegin("ids", ::apache::thrift::protocol::T_LIST, 4); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_I64, static_cast<uint32_t>(this->ids.size())); - std::vector<int64_t> ::const_iterator _iter765; - for (_iter765 = this->ids.begin(); _iter765 != this->ids.end(); ++_iter765) - { - xfer += oprot->writeI64((*_iter765)); - } - xfer += oprot->writeListEnd(); - } - xfer += oprot->writeFieldEnd(); - } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(GetValidWriteIdsResult &a, GetValidWriteIdsResult &b) { - using ::std::swap; - swap(a.lowWatermarkId, b.lowWatermarkId); - swap(a.highWatermarkId, b.highWatermarkId); - swap(a.areIdsValid, b.areIdsValid); - swap(a.ids, b.ids); - swap(a.__isset, b.__isset); -} - -GetValidWriteIdsResult::GetValidWriteIdsResult(const GetValidWriteIdsResult& other766) { - lowWatermarkId = other766.lowWatermarkId; - highWatermarkId = other766.highWatermarkId; - areIdsValid = other766.areIdsValid; - ids = other766.ids; - __isset = other766.__isset; -} -GetValidWriteIdsResult& GetValidWriteIdsResult::operator=(const GetValidWriteIdsResult& other767) { - lowWatermarkId = other767.lowWatermarkId; - highWatermarkId = other767.highWatermarkId; - areIdsValid = other767.areIdsValid; - ids = other767.ids; - __isset = other767.__isset; - return *this; -} -void GetValidWriteIdsResult::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "GetValidWriteIdsResult("; - out << "lowWatermarkId=" << to_string(lowWatermarkId); - out << ", " << "highWatermarkId=" << to_string(highWatermarkId); - out << ", " << "areIdsValid="; (__isset.areIdsValid ? (out << to_string(areIdsValid)) : (out << "<null>")); - out << ", " << "ids="; (__isset.ids ? (out << to_string(ids)) : (out << "<null>")); - out << ")"; -} - - -GetAllFunctionsResponse::~GetAllFunctionsResponse() throw() { -} - - -void GetAllFunctionsResponse::__set_functions(const std::vector<Function> & val) { - this->functions = val; -__isset.functions = true; -} - -uint32_t GetAllFunctionsResponse::read(::apache::thrift::protocol::TProtocol* iprot) { - - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 1: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->functions.clear(); - uint32_t _size768; - ::apache::thrift::protocol::TType _etype771; - xfer += iprot->readListBegin(_etype771, _size768); - this->functions.resize(_size768); - uint32_t _i772; - for (_i772 = 0; _i772 < _size768; ++_i772) - { - xfer += this->functions[_i772].read(iprot); - } - xfer += iprot->readListEnd(); - } - this->__isset.functions = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - return xfer; -} - -uint32_t GetAllFunctionsResponse::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("GetAllFunctionsResponse"); - - if (this->__isset.functions) { - xfer += oprot->writeFieldBegin("functions", ::apache::thrift::protocol::T_LIST, 1); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->functions.size())); - std::vector<Function> ::const_iterator _iter773; - for (_iter773 = this->functions.begin(); _iter773 != this->functions.end(); ++_iter773) - { - xfer += (*_iter773).write(oprot); - } - xfer += oprot->writeListEnd(); - } - xfer += oprot->writeFieldEnd(); - } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(GetAllFunctionsResponse &a, GetAllFunctionsResponse &b) { - using ::std::swap; - swap(a.functions, b.functions); - swap(a.__isset, b.__isset); -} - -GetAllFunctionsResponse::GetAllFunctionsResponse(const GetAllFunctionsResponse& other774) { - functions = other774.functions; - __isset = other774.__isset; -} -GetAllFunctionsResponse& GetAllFunctionsResponse::operator=(const GetAllFunctionsResponse& other775) { - functions = other775.functions; - __isset = other775.__isset; - return *this; -} -void GetAllFunctionsResponse::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "GetAllFunctionsResponse("; - out << "functions="; (__isset.functions ? (out << to_string(functions)) : (out << "<null>")); - out << ")"; -} - - -ClientCapabilities::~ClientCapabilities() throw() { -} - - -void ClientCapabilities::__set_values(const std::vector<ClientCapability::type> & val) { - this->values = val; -} - -uint32_t ClientCapabilities::read(::apache::thrift::protocol::TProtocol* iprot) { - - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - bool isset_values = false; - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 1: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->values.clear(); - uint32_t _size776; - ::apache::thrift::protocol::TType _etype779; - xfer += iprot->readListBegin(_etype779, _size776); - this->values.resize(_size776); - uint32_t _i780; - for (_i780 = 0; _i780 < _size776; ++_i780) - { - int32_t ecast781; - xfer += iprot->readI32(ecast781); - this->values[_i780] = (ClientCapability::type)ecast781; - } - xfer += iprot->readListEnd(); - } - isset_values = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_values) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t ClientCapabilities::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("ClientCapabilities"); - - xfer += oprot->writeFieldBegin("values", ::apache::thrift::protocol::T_LIST, 1); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_I32, static_cast<uint32_t>(this->values.size())); - std::vector<ClientCapability::type> ::const_iterator _iter782; - for (_iter782 = this->values.begin(); _iter782 != this->values.end(); ++_iter782) - { - xfer += oprot->writeI32((int32_t)(*_iter782)); - } - xfer += oprot->writeListEnd(); - } - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(ClientCapabilities &a, ClientCapabilities &b) { - using ::std::swap; - swap(a.values, b.values); -} - -ClientCapabilities::ClientCapabilities(const ClientCapabilities& other783) { - values = other783.values; -} -ClientCapabilities& ClientCapabilities::operator=(const ClientCapabilities& other784) { - values = other784.values; - return *this; -} -void ClientCapabilities::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "ClientCapabilities("; - out << "values=" << to_string(values); - out << ")"; -} - - -GetTableRequest::~GetTableRequest() throw() { -} - - -void GetTableRequest::__set_dbName(const std::string& val) { - this->dbName = val; -} - -void GetTableRequest::__set_tblName(const std::string& val) { - this->tblName = val; -} - -void GetTableRequest::__set_capabilities(const ClientCapabilities& val) { - this->capabilities = val; -__isset.capabilities = true; -} - -uint32_t GetTableRequest::read(::apache::thrift::protocol::TProtocol* iprot) { - - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - bool isset_dbName = false; - bool isset_tblName = false; - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 1: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->dbName); - isset_dbName = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->tblName); - isset_tblName = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: - if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->capabilities.read(iprot); - this->__isset.capabilities = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_dbName) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_tblName) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t GetTableRequest::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("GetTableRequest"); - - xfer += oprot->writeFieldBegin("dbName", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->dbName); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("tblName", ::apache::thrift::protocol::T_STRING, 2); - xfer += oprot->writeString(this->tblName); - xfer += oprot->writeFieldEnd(); - - if (this->__isset.capabilities) { - xfer += oprot->writeFieldBegin("capabilities", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += this->capabilities.write(oprot); - xfer += oprot->writeFieldEnd(); - } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(GetTableRequest &a, GetTableRequest &b) { - using ::std::swap; - swap(a.dbName, b.dbName); - swap(a.tblName, b.tblName); - swap(a.capabilities, b.capabilities); - swap(a.__isset, b.__isset); -} - -GetTableRequest::GetTableRequest(const GetTableRequest& other785) { - dbName = other785.dbName; - tblName = other785.tblName; - capabilities = other785.capabilities; - __isset = other785.__isset; -} -GetTableRequest& GetTableRequest::operator=(const GetTableRequest& other786) { - dbName = other786.dbName; - tblName = other786.tblName; - capabilities = other786.capabilities; - __isset = other786.__isset; - return *this; -} -void GetTableRequest::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "GetTableRequest("; - out << "dbName=" << to_string(dbName); - out << ", " << "tblName=" << to_string(tblName); - out << ", " << "capabilities="; (__isset.capabilities ? (out << to_string(capabilities)) : (out << "<null>")); - out << ")"; -} - - -GetTableResult::~GetTableResult() throw() { -} - - -void GetTableResult::__set_table(const Table& val) { - this->table = val; -} - -uint32_t GetTableResult::read(::apache::thrift::protocol::TProtocol* iprot) { - - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - bool isset_table = false; - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 1: - if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->table.read(iprot); - isset_table = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_table) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t GetTableResult::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("GetTableResult"); - - xfer += oprot->writeFieldBegin("table", ::apache::thrift::protocol::T_STRUCT, 1); - xfer += this->table.write(oprot); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(GetTableResult &a, GetTableResult &b) { - using ::std::swap; - swap(a.table, b.table); -} - -GetTableResult::GetTableResult(const GetTableResult& other787) { - table = other787.table; -} -GetTableResult& GetTableResult::operator=(const GetTableResult& other788) { - table = other788.table; - return *this; -} -void GetTableResult::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "GetTableResult("; - out << "table=" << to_string(table); - out << ")"; -} - - -GetTablesRequest::~GetTablesRequest() throw() { -} - - -void GetTablesRequest::__set_dbName(const std::string& val) { - this->dbName = val; -} - -void GetTablesRequest::__set_tblNames(const std::vector<std::string> & val) { - this->tblNames = val; -__isset.tblNames = true; -} - -void GetTablesRequest::__set_capabilities(const ClientCapabilities& val) { - this->capabilities = val; -__isset.capabilities = true; -} - -uint32_t GetTablesRequest::read(::apache::thrift::protocol::TProtocol* iprot) { - - apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - bool isset_dbName = false; - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 1: - if (ftype == ::apache::thrift::protocol::T_STRING) { - xfer += iprot->readString(this->dbName); - isset_dbName = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->tblNames.clear(); - uint32_t _size789; - ::apache::thrift::protocol::TType _etype792; - xfer += iprot->readListBegin(_etype792, _size789); - this->tblNames.resize(_size789); - uint32_t _i793; - for (_i793 = 0; _i793 < _size789; ++_i793) - { - xfer += iprot->readString(this->tblNames[_i793]); - } - xfer += iprot->readListEnd(); - } - this->__isset.tblNames = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: - if (ftype == ::apache::thrift::protocol::T_STRUCT) { - xfer += this->capabilities.read(iprot); - this->__isset.capabilities = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - if (!isset_dbName) - throw TProtocolException(TProtocolException::INVALID_DATA); - return xfer; -} - -uint32_t GetTablesRequest::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); - xfer += oprot->writeStructBegin("GetTablesRequest"); - - xfer += oprot->writeFieldBegin("dbName", ::apache::thrift::protocol::T_STRING, 1); - xfer += oprot->writeString(this->dbName); - xfer += oprot->writeFieldEnd(); - - if (this->__isset.tblNames) { - xfer += oprot->writeFieldBegin("tblNames", ::apache::thrift::protocol::T_LIST, 2); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->tblNames.size())); - std::vector<std::string> ::const_iterator _iter794; - for (_iter794 = this->tblNames.begin(); _iter794 != this->tblNames.end(); ++_iter794) - { - xfer += oprot->writeString((*_iter794)); - } - xfer += oprot->writeListEnd(); - } - xfer += oprot->writeFieldEnd(); - } - if (this->__isset.capabilities) { - xfer += oprot->writeFieldBegin("capabilities", ::apache::thrift::protocol::T_STRUCT, 3); - xfer += this->capabilities.write(oprot); - xfer += oprot->writeFieldEnd(); - } - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(GetTablesRequest &a, GetTablesRequest &b) { - using ::std::swap; - swap(a.dbName, b.dbName); - swap(a.tblNames, b.tblNames); - swap(a.capabilities, b.capabilities); - swap(a.__isset, b.__isset); -} - -GetTablesRequest::GetTablesRequest(const GetTablesRequest& other795) { - dbName = other795.dbName; - tblNames = other795.tblNames; - capabilities = other795.capabilities; - __isset = other795.__isset; -} -GetTablesRequest& GetTablesRequest::operator=(const GetTablesRequest& other796) { - dbName = other796.dbName; - tblNames = other796.tblNames; - capabilities = other796.capabilities; - __isset = other796.__isset; - return *this; -} -void GetTablesRequest::printTo(std::ostream& out) const { - using ::apache::thrift::to_string; - out << "GetTablesRequest("; - out << "dbName=" << to_string(dbName); - out << ", " << "tblNames="; (__isset.tblNames ? (out << to_string(tblNames)) : (out << "<null>")); - out << ", " << "capabilities="; (__isset.capabilities ? (out << to_string(capabilities)) : (out << "<null>")); - out << ")"; -} - - -GetTablesResult::~GetTablesResult() throw() { -} - - -void GetTablesResult::__set_tables(const std::vector<Table> & val) { - this->tables = val; -} - -uint32_t GetTablesResult::read(::apache::thrift::protocol::TProtocol* iprot) { +void GetTablesResult::__set_tables(const std::vector<Table> & val) { + this->tables = val; +} + +uint32_t GetTablesResult::read(::apache::thrift::protocol::TProtocol* iprot) { apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; @@ -19531,14 +18596,14 @@ uint32_t GetTablesResult::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->tables.clear(); - uint32_t _size797; - ::apache::thrift::protocol::TType _etype800; - xfer += iprot->readListBegin(_etype800, _size797); - this->tables.resize(_size797); - uint32_t _i801; - for (_i801 = 0; _i801 < _size797; ++_i801) + uint32_t _size775; + ::apache::thrift::protocol::TType _etype778; + xfer += iprot->readListBegin(_etype778, _size775); + this->tables.resize(_size775); + uint32_t _i779; + for (_i779 = 0; _i779 < _size775; ++_i779) { - xfer += this->tables[_i801].read(iprot); + xfer += this->tables[_i779].read(iprot); } xfer += iprot->readListEnd(); } @@ -19569,10 +18634,10 @@ uint32_t GetTablesResult::write(::apache::thrift::protocol::TProtocol* oprot) co xfer += oprot->writeFieldBegin("tables", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->tables.size())); - std::vector<Table> ::const_iterator _iter802; - for (_iter802 = this->tables.begin(); _iter802 != this->tables.end(); ++_iter802) + std::vector<Table> ::const_iterator _iter780; + for (_iter780 = this->tables.begin(); _iter780 != this->tables.end(); ++_iter780) { - xfer += (*_iter802).write(oprot); + xfer += (*_iter780).write(oprot); } xfer += oprot->writeListEnd(); } @@ -19588,11 +18653,11 @@ void swap(GetTablesResult &a, GetTablesResult &b) { swap(a.tables, b.tables); } -GetTablesResult::GetTablesResult(const GetTablesResult& other803) { - tables = other803.tables; +GetTablesResult::GetTablesResult(const GetTablesResult& other781) { + tables = other781.tables; } -GetTablesResult& GetTablesResult::operator=(const GetTablesResult& other804) { - tables = other804.tables; +GetTablesResult& GetTablesResult::operator=(const GetTablesResult& other782) { + tables = other782.tables; return *this; } void GetTablesResult::printTo(std::ostream& out) const { @@ -19734,19 +18799,19 @@ void swap(TableMeta &a, TableMeta &b) { swap(a.__isset, b.__isset); } -TableMeta::TableMeta(const TableMeta& other805) { - dbName = other805.dbName; - tableName = other805.tableName; - tableType = other805.tableType; - comments = other805.comments; - __isset = other805.__isset; +TableMeta::TableMeta(const TableMeta& other783) { + dbName = other783.dbName; + tableName = other783.tableName; + tableType = other783.tableType; + comments = other783.comments; + __isset = other783.__isset; } -TableMeta& TableMeta::operator=(const TableMeta& other806) { - dbName = other806.dbName; - tableName = other806.tableName; - tableType = other806.tableType; - comments = other806.comments; - __isset = other806.__isset; +TableMeta& TableMeta::operator=(const TableMeta& other784) { + dbName = other784.dbName; + tableName = other784.tableName; + tableType = other784.tableType; + comments = other784.comments; + __isset = other784.__isset; return *this; } void TableMeta::printTo(std::ostream& out) const { @@ -19829,13 +18894,13 @@ void swap(MetaException &a, MetaException &b) { swap(a.__isset, b.__isset); } -MetaException::MetaException(const MetaException& other807) : TException() { - message = other807.message; - __isset = other807.__isset; +MetaException::MetaException(const MetaException& other785) : TException() { + message = other785.message; + __isset = other785.__isset; } -MetaException& MetaException::operator=(const MetaException& other808) { - message = other808.message; - __isset = other808.__isset; +MetaException& MetaException::operator=(const MetaException& other786) { + message = other786.message; + __isset = other786.__isset; return *this; } void MetaException::printTo(std::ostream& out) const { @@ -19926,13 +18991,13 @@ void swap(UnknownTableException &a, UnknownTableException &b) { swap(a.__isset, b.__isset); } -UnknownTableException::UnknownTableException(const UnknownTableException& other809) : TException() { - message = other809.message; - __isset = other809.__isset; +UnknownTableException::UnknownTableException(const UnknownTableException& other787) : TException() { + message = other787.message; + __isset = other787.__isset; } -UnknownTableException& UnknownTableException::operator=(const UnknownTableException& other810) { - message = other810.message; - __isset = other810.__isset; +UnknownTableException& UnknownTableException::operator=(const UnknownTableException& other788) { + message = other788.message; + __isset = other788.__isset; return *this; } void UnknownTableException::printTo(std::ostream& out) const { @@ -20023,13 +19088,13 @@ void swap(UnknownDBException &a, UnknownDBException &b) { swap(a.__isset, b.__isset); } -UnknownDBException::UnknownDBException(const UnknownDBException& other811) : TException() { - message = other811.message; - __isset = other811.__isset; +UnknownDBException::UnknownDBException(const UnknownDBException& other789) : TException() { + message = other789.message; + __isset = other789.__isset; } -UnknownDBException& UnknownDBException::operator=(const UnknownDBException& other812) { - message = other812.message; - __isset = other812.__isset; +UnknownDBException& UnknownDBException::operator=(const UnknownDBException& other790) { + message = other790.message; + __isset = other790.__isset; return *this; } void UnknownDBException::printTo(std::ostream& out) const { @@ -20120,13 +19185,13 @@ void swap(AlreadyExistsException &a, AlreadyExistsException &b) { swap(a.__isset, b.__isset); } -AlreadyExistsException::AlreadyExistsException(const AlreadyExistsException& other813) : TException() { - message = other813.message; - __isset = other813.__isset; +AlreadyExistsException::AlreadyExistsException(const AlreadyExistsException& other791) : TException() { + message = other791.message; + __isset = other791.__isset; } -AlreadyExistsException& AlreadyExistsException::operator=(const AlreadyExistsException& other814) { - message = other814.message; - __isset = other814.__isset; +AlreadyExistsException& AlreadyExistsException::operator=(const AlreadyExistsException& other792) { + message = other792.message; + __isset = other792.__isset; return *this; } void AlreadyExistsException::printTo(std::ostream& out) const { @@ -20217,13 +19282,13 @@ void swap(InvalidPartitionException &a, InvalidPartitionException &b) { swap(a.__isset, b.__isset); } -InvalidPartitionException::InvalidPartitionException(const InvalidPartitionException& other815) : TException() { - message = other815.message; - __isset = other815.__isset; +InvalidPartitionException::InvalidPartitionException(const InvalidPartitionException& other793) : TException() { + message = other793.message; + __isset = other793.__isset; } -InvalidPartitionException& InvalidPartitionException::operator=(const InvalidPartitionException& other816) { - message = other816.message; - __isset = other816.__isset; +InvalidPartitionException& InvalidPartitionException::operator=(const InvalidPartitionException& other794) { + message = other794.message; + __isset = other794.__isset; return *this; } void InvalidPartitionException::printTo(std::ostream& out) const { @@ -20314,13 +19379,13 @@ void swap(UnknownPartitionException &a, UnknownPartitionException &b) { swap(a.__isset, b.__isset); } -UnknownPartitionException::UnknownPartitionException(const UnknownPartitionException& other817) : TException() { - message = other817.message; - __isset = other817.__isset; +UnknownPartitionException::UnknownPartitionException(const UnknownPartitionException& other795) : TException() { + message = other795.message; + __isset = other795.__isset; } -UnknownPartitionException& UnknownPartitionException::operator=(const UnknownPartitionException& other818) { - message = other818.message; - __isset = other818.__isset; +UnknownPartitionException& UnknownPartitionException::operator=(const UnknownPartitionException& other796) { + message = other796.message; + __isset = other796.__isset; return *this; } void UnknownPartitionException::printTo(std::ostream& out) const { @@ -20411,13 +19476,13 @@ void swap(InvalidObjectException &a, InvalidObjectException &b) { swap(a.__isset, b.__isset); } -InvalidObjectException::InvalidObjectException(const InvalidObjectException& other819) : TException() { - message = other819.message; - __isset = other819.__isset; +InvalidObjectException::InvalidObjectException(const InvalidObjectException& other797) : TException() { + message = other797.message; + __isset = other797.__isset; } -InvalidObjectException& InvalidObjectException::operator=(const InvalidObjectException& other820) { - message = other820.message; - __isset = other820.__isset; +InvalidObjectException& InvalidObjectException::operator=(const InvalidObjectException& other798) { + message = other798.message; + __isset = other798.__isset; return *this; } void InvalidObjectException::printTo(std::ostream& out) const { @@ -20508,13 +19573,13 @@ void swap(NoSuchObjectException &a, NoSuchObjectException &b) { swap(a.__isset, b.__isset); } -NoSuchObjectException::NoSuchObjectException(const NoSuchObjectException& other821) : TException() { - message = other821.message; - __isset = other821.__isset; +NoSuchObjectException::NoSuchObjectException(const NoSuchObjectException& other799) : TException() { + message = other799.message; + __isset = other799.__isset; } -NoSuchObjectException& NoSuchObjectException::operator=(const NoSuchObjectException& other822) { - message = other822.message; - __isset = other822.__isset; +NoSuchObjectException& NoSuchObjectException::operator=(const NoSuchObjectException& other800) { + message = other800.message; + __isset = other800.__isset; return *this; } void NoSuchObjectException::printTo(std::ostream& out) const { @@ -20605,13 +19670,13 @@ void swap(IndexAlreadyExistsException &a, IndexAlreadyExistsException &b) { swap(a.__isset, b.__isset); } -IndexAlreadyExistsException::IndexAlreadyExistsException(const IndexAlreadyExistsException& other823) : TException() { - message = other823.message; - __isset = other823.__isset; +IndexAlreadyExistsException::IndexAlreadyExistsException(const IndexAlreadyExistsException& other801) : TException() { + message = other801.message; + __isset = other801.__isset; } -IndexAlreadyExistsException& IndexAlreadyExistsException::operator=(const IndexAlreadyExistsException& other824) { - message = other824.message; - __isset = other824.__isset; +IndexAlreadyExistsException& IndexAlreadyExistsException::operator=(const IndexAlreadyExistsException& other802) { + message = other802.message; + __isset = other802.__isset; return *this; } void IndexAlreadyExistsException::printTo(std::ostream& out) const { @@ -20702,13 +19767,13 @@ void swap(InvalidOperationException &a, InvalidOperationException &b) { swap(a.__isset, b.__isset); } -InvalidOperationException::InvalidOperationException(const InvalidOperationException& other825) : TException() { - message = other825.message; - __isset = other825.__isset; +InvalidOperationException::InvalidOperationException(const InvalidOperationException& other803) : TException() { + message = other803.message; + __isset = other803.__isset; } -InvalidOperationException& InvalidOperationException::operator=(const InvalidOperationException& other826) { - message = other826.message; - __isset = other826.__isset; +InvalidOperationException& InvalidOperationException::operator=(const InvalidOperationException& other804) { + message = other804.message; + __isset = other804.__isset; return *this; } void InvalidOperationException::printTo(std::ostream& out) const { @@ -20799,13 +19864,13 @@ void swap(ConfigValSecurityException &a, ConfigValSecurityException &b) { swap(a.__isset, b.__isset); } -ConfigValSecurityException::ConfigValSecurityException(const ConfigValSecurityException& other827) : TException() { - message = other827.message; - __isset = other827.__isset; +ConfigValSecurityException::ConfigValSecurityException(const ConfigValSecurityException& other805) : TException() { + message = other805.message; + __isset = other805.__isset; } -ConfigValSecurityException& ConfigValSecurityException::operator=(const ConfigValSecurityException& other828) { - message = other828.message; - __isset = other828.__isset; +ConfigValSecurityException& ConfigValSecurityException::operator=(const ConfigValSecurityException& other806) { + message = other806.message; + __isset = other806.__isset; return *this; } void ConfigValSecurityException::printTo(std::ostream& out) const { @@ -20896,13 +19961,13 @@ void swap(InvalidInputException &a, InvalidInputException &b) { swap(a.__isset, b.__isset); } -InvalidInputException::InvalidInputException(const InvalidInputException& other829) : TException() { - message = other829.message; - __isset = other829.__isset; +InvalidInputException::InvalidInputException(const InvalidInputException& other807) : TException() { + message = other807.message; + __isset = other807.__isset; } -InvalidInputException& InvalidInputException::operator=(const InvalidInputException& other830) { - message = other830.message; - __isset = other830.__isset; +InvalidInputException& InvalidInputException::operator=(const InvalidInputException& other808) { + message = other808.message; + __isset = other808.__isset; return *this; } void InvalidInputException::printTo(std::ostream& out) const { @@ -20993,13 +20058,13 @@ void swap(NoSuchTxnException &a, NoSuchTxnException &b) { swap(a.__isset, b.__isset); } -NoSuchTxnException::NoSuchTxnException(const NoSuchTxnException& other831) : TException() { - message = other831.message; - __isset = other831.__isset; +NoSuchTxnException::NoSuchTxnException(const NoSuchTxnException& other809) : TException() { + message = other809.message; + __isset = other809.__isset; } -NoSuchTxnException& NoSuchTxnException::operator=(const NoSuchTxnException& other832) { - message = other832.message; - __isset = other832.__isset; +NoSuchTxnException& NoSuchTxnException::operator=(const NoSuchTxnException& other810) { + message = other810.message; + __isset = other810.__isset; return *this; } void NoSuchTxnException::printTo(std::ostream& out) const { @@ -21090,13 +20155,13 @@ void swap(TxnAbortedException &a, TxnAbortedException &b) { swap(a.__isset, b.__isset); } -TxnAbortedException::TxnAbortedException(const TxnAbortedException& other833) : TException() { - message = other833.message; - __isset = other833.__isset; +TxnAbortedException::TxnAbortedException(const TxnAbortedException& other811) : TException() { + message = other811.message; + __isset = other811.__isset; } -TxnAbortedException& TxnAbortedException::operator=(const TxnAbortedException& other834) { - message = other834.message; - __isset = other834.__isset; +TxnAbortedException& TxnAbortedException::operator=(const TxnAbortedException& other812) { + message = other812.message; + __isset = other812.__isset; return *this; } void TxnAbortedException::printTo(std::ostream& out) const { @@ -21187,13 +20252,13 @@ void swap(TxnOpenException &a, TxnOpenException &b) { swap(a.__isset, b.__isset); } -TxnOpenException::TxnOpenException(const TxnOpenException& other835) : TException() { - message = other835.message; - __isset = other835.__isset; +TxnOpenException::TxnOpenException(const TxnOpenException& other813) : TException() { + message = other813.message; + __isset = other813.__isset; } -TxnOpenException& TxnOpenException::operator=(const TxnOpenException& other836) { - message = other836.message; - __isset = other836.__isset; +TxnOpenException& TxnOpenException::operator=(const TxnOpenException& other814) { + message = other814.message; + __isset = other814.__isset; return *this; } void TxnOpenException::printTo(std::ostream& out) const { @@ -21284,13 +20349,13 @@ void swap(NoSuchLockException &a, NoSuchLockException &b) { swap(a.__isset, b.__isset); } -NoSuchLockException::NoSuchLockException(const NoSuchLockException& other837) : TException() { - message = other837.message; - __isset = other837.__isset; +NoSuchLockException::NoSuchLockException(const NoSuchLockException& other815) : TException() { + message = other815.message; + __isset = other815.__isset; } -NoSuchLockException& NoSuchLockException::operator=(const NoSuchLockException& other838) { - message = other838.message; - __isset = other838.__isset; +NoSuchLockException& NoSuchLockException::operator=(const NoSuchLockException& other816) { + message = other816.message; + __isset = other816.__isset; return *this; } void NoSuchLockException::printTo(std::ostream& out) const {
http://git-wip-us.apache.org/repos/asf/hive/blob/77511070/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h b/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h index d6a90cc..5f83781 100644 --- a/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h +++ b/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h @@ -395,22 +395,6 @@ class CacheFileMetadataResult; class CacheFileMetadataRequest; -class GetNextWriteIdRequest; - -class GetNextWriteIdResult; - -class FinalizeWriteIdRequest; - -class FinalizeWriteIdResult; - -class HeartbeatWriteIdRequest; - -class HeartbeatWriteIdResult; - -class GetValidWriteIdsRequest; - -class GetValidWriteIdsResult; - class GetAllFunctionsResponse; class ClientCapabilities; @@ -2079,7 +2063,7 @@ inline std::ostream& operator<<(std::ostream& out, const StorageDescriptor& obj) } typedef struct _Table__isset { - _Table__isset() : tableName(false), dbName(false), owner(false), createTime(false), lastAccessTime(false), retention(false), sd(false), partitionKeys(false), parameters(false), viewOriginalText(false), viewExpandedText(false), tableType(false), privileges(false), temporary(true), rewriteEnabled(false), mmNextWriteId(false), mmWatermarkWriteId(false) {} + _Table__isset() : tableName(false), dbName(false), owner(false), createTime(false), lastAccessTime(false), retention(false), sd(false), partitionKeys(false), parameters(false), viewOriginalText(false), viewExpandedText(false), tableType(false), privileges(false), temporary(true), rewriteEnabled(false) {} bool tableName :1; bool dbName :1; bool owner :1; @@ -2095,8 +2079,6 @@ typedef struct _Table__isset { bool privileges :1; bool temporary :1; bool rewriteEnabled :1; - bool mmNextWriteId :1; - bool mmWatermarkWriteId :1; } _Table__isset; class Table { @@ -2104,7 +2086,7 @@ class Table { Table(const Table&); Table& operator=(const Table&); - Table() : tableName(), dbName(), owner(), createTime(0), lastAccessTime(0), retention(0), viewOriginalText(), viewExpandedText(), tableType(), temporary(false), rewriteEnabled(0), mmNextWriteId(0), mmWatermarkWriteId(0) { + Table() : tableName(), dbName(), owner(), createTime(0), lastAccessTime(0), retention(0), viewOriginalText(), viewExpandedText(), tableType(), temporary(false), rewriteEnabled(0) { } virtual ~Table() throw(); @@ -2123,8 +2105,6 @@ class Table { PrincipalPrivilegeSet privileges; bool temporary; bool rewriteEnabled; - int64_t mmNextWriteId; - int64_t mmWatermarkWriteId; _Table__isset __isset; @@ -2158,10 +2138,6 @@ class Table { void __set_rewriteEnabled(const bool val); - void __set_mmNextWriteId(const int64_t val); - - void __set_mmWatermarkWriteId(const int64_t val); - bool operator == (const Table & rhs) const { if (!(tableName == rhs.tableName)) @@ -2200,14 +2176,6 @@ class Table { return false; else if (__isset.rewriteEnabled && !(rewriteEnabled == rhs.rewriteEnabled)) return false; - if (__isset.mmNextWriteId != rhs.__isset.mmNextWriteId) - return false; - else if (__isset.mmNextWriteId && !(mmNextWriteId == rhs.mmNextWriteId)) - return false; - if (__isset.mmWatermarkWriteId != rhs.__isset.mmWatermarkWriteId) - return false; - else if (__isset.mmWatermarkWriteId && !(mmWatermarkWriteId == rhs.mmWatermarkWriteId)) - return false; return true; } bool operator != (const Table &rhs) const { @@ -7334,377 +7302,6 @@ inline std::ostream& operator<<(std::ostream& out, const CacheFileMetadataReques return out; } - -class GetNextWriteIdRequest { - public: - - GetNextWriteIdRequest(const GetNextWriteIdRequest&); - GetNextWriteIdRequest& operator=(const GetNextWriteIdRequest&); - GetNextWriteIdRequest() : dbName(), tblName() { - } - - virtual ~GetNextWriteIdRequest() throw(); - std::string dbName; - std::string tblName; - - void __set_dbName(const std::string& val); - - void __set_tblName(const std::string& val); - - bool operator == (const GetNextWriteIdRequest & rhs) const - { - if (!(dbName == rhs.dbName)) - return false; - if (!(tblName == rhs.tblName)) - return false; - return true; - } - bool operator != (const GetNextWriteIdRequest &rhs) const { - return !(*this == rhs); - } - - bool operator < (const GetNextWriteIdRequest & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(GetNextWriteIdRequest &a, GetNextWriteIdRequest &b); - -inline std::ostream& operator<<(std::ostream& out, const GetNextWriteIdRequest& obj) -{ - obj.printTo(out); - return out; -} - - -class GetNextWriteIdResult { - public: - - GetNextWriteIdResult(const GetNextWriteIdResult&); - GetNextWriteIdResult& operator=(const GetNextWriteIdResult&); - GetNextWriteIdResult() : writeId(0) { - } - - virtual ~GetNextWriteIdResult() throw(); - int64_t writeId; - - void __set_writeId(const int64_t val); - - bool operator == (const GetNextWriteIdResult & rhs) const - { - if (!(writeId == rhs.writeId)) - return false; - return true; - } - bool operator != (const GetNextWriteIdResult &rhs) const { - return !(*this == rhs); - } - - bool operator < (const GetNextWriteIdResult & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(GetNextWriteIdResult &a, GetNextWriteIdResult &b); - -inline std::ostream& operator<<(std::ostream& out, const GetNextWriteIdResult& obj) -{ - obj.printTo(out); - return out; -} - - -class FinalizeWriteIdRequest { - public: - - FinalizeWriteIdRequest(const FinalizeWriteIdRequest&); - FinalizeWriteIdRequest& operator=(const FinalizeWriteIdRequest&); - FinalizeWriteIdRequest() : dbName(), tblName(), writeId(0), commit(0) { - } - - virtual ~FinalizeWriteIdRequest() throw(); - std::string dbName; - std::string tblName; - int64_t writeId; - bool commit; - - void __set_dbName(const std::string& val); - - void __set_tblName(const std::string& val); - - void __set_writeId(const int64_t val); - - void __set_commit(const bool val); - - bool operator == (const FinalizeWriteIdRequest & rhs) const - { - if (!(dbName == rhs.dbName)) - return false; - if (!(tblName == rhs.tblName)) - return false; - if (!(writeId == rhs.writeId)) - return false; - if (!(commit == rhs.commit)) - return false; - return true; - } - bool operator != (const FinalizeWriteIdRequest &rhs) const { - return !(*this == rhs); - } - - bool operator < (const FinalizeWriteIdRequest & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(FinalizeWriteIdRequest &a, FinalizeWriteIdRequest &b); - -inline std::ostream& operator<<(std::ostream& out, const FinalizeWriteIdRequest& obj) -{ - obj.printTo(out); - return out; -} - - -class FinalizeWriteIdResult { - public: - - FinalizeWriteIdResult(const FinalizeWriteIdResult&); - FinalizeWriteIdResult& operator=(const FinalizeWriteIdResult&); - FinalizeWriteIdResult() { - } - - virtual ~FinalizeWriteIdResult() throw(); - - bool operator == (const FinalizeWriteIdResult & /* rhs */) const - { - return true; - } - bool operator != (const FinalizeWriteIdResult &rhs) const { - return !(*this == rhs); - } - - bool operator < (const FinalizeWriteIdResult & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(FinalizeWriteIdResult &a, FinalizeWriteIdResult &b); - -inline std::ostream& operator<<(std::ostream& out, const FinalizeWriteIdResult& obj) -{ - obj.printTo(out); - return out; -} - - -class HeartbeatWriteIdRequest { - public: - - HeartbeatWriteIdRequest(const HeartbeatWriteIdRequest&); - HeartbeatWriteIdRequest& operator=(const HeartbeatWriteIdRequest&); - HeartbeatWriteIdRequest() : dbName(), tblName(), writeId(0) { - } - - virtual ~HeartbeatWriteIdRequest() throw(); - std::string dbName; - std::string tblName; - int64_t writeId; - - void __set_dbName(const std::string& val); - - void __set_tblName(const std::string& val); - - void __set_writeId(const int64_t val); - - bool operator == (const HeartbeatWriteIdRequest & rhs) const - { - if (!(dbName == rhs.dbName)) - return false; - if (!(tblName == rhs.tblName)) - return false; - if (!(writeId == rhs.writeId)) - return false; - return true; - } - bool operator != (const HeartbeatWriteIdRequest &rhs) const { - return !(*this == rhs); - } - - bool operator < (const HeartbeatWriteIdRequest & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(HeartbeatWriteIdRequest &a, HeartbeatWriteIdRequest &b); - -inline std::ostream& operator<<(std::ostream& out, const HeartbeatWriteIdRequest& obj) -{ - obj.printTo(out); - return out; -} - - -class HeartbeatWriteIdResult { - public: - - HeartbeatWriteIdResult(const HeartbeatWriteIdResult&); - HeartbeatWriteIdResult& operator=(const HeartbeatWriteIdResult&); - HeartbeatWriteIdResult() { - } - - virtual ~HeartbeatWriteIdResult() throw(); - - bool operator == (const HeartbeatWriteIdResult & /* rhs */) const - { - return true; - } - bool operator != (const HeartbeatWriteIdResult &rhs) const { - return !(*this == rhs); - } - - bool operator < (const HeartbeatWriteIdResult & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(HeartbeatWriteIdResult &a, HeartbeatWriteIdResult &b); - -inline std::ostream& operator<<(std::ostream& out, const HeartbeatWriteIdResult& obj) -{ - obj.printTo(out); - return out; -} - - -class GetValidWriteIdsRequest { - public: - - GetValidWriteIdsRequest(const GetValidWriteIdsRequest&); - GetValidWriteIdsRequest& operator=(const GetValidWriteIdsRequest&); - GetValidWriteIdsRequest() : dbName(), tblName() { - } - - virtual ~GetValidWriteIdsRequest() throw(); - std::string dbName; - std::string tblName; - - void __set_dbName(const std::string& val); - - void __set_tblName(const std::string& val); - - bool operator == (const GetValidWriteIdsRequest & rhs) const - { - if (!(dbName == rhs.dbName)) - return false; - if (!(tblName == rhs.tblName)) - return false; - return true; - } - bool operator != (const GetValidWriteIdsRequest &rhs) const { - return !(*this == rhs); - } - - bool operator < (const GetValidWriteIdsRequest & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(GetValidWriteIdsRequest &a, GetValidWriteIdsRequest &b); - -inline std::ostream& operator<<(std::ostream& out, const GetValidWriteIdsRequest& obj) -{ - obj.printTo(out); - return out; -} - -typedef struct _GetValidWriteIdsResult__isset { - _GetValidWriteIdsResult__isset() : areIdsValid(false), ids(false) {} - bool areIdsValid :1; - bool ids :1; -} _GetValidWriteIdsResult__isset; - -class GetValidWriteIdsResult { - public: - - GetValidWriteIdsResult(const GetValidWriteIdsResult&); - GetValidWriteIdsResult& operator=(const GetValidWriteIdsResult&); - GetValidWriteIdsResult() : lowWatermarkId(0), highWatermarkId(0), areIdsValid(0) { - } - - virtual ~GetValidWriteIdsResult() throw(); - int64_t lowWatermarkId; - int64_t highWatermarkId; - bool areIdsValid; - std::vector<int64_t> ids; - - _GetValidWriteIdsResult__isset __isset; - - void __set_lowWatermarkId(const int64_t val); - - void __set_highWatermarkId(const int64_t val); - - void __set_areIdsValid(const bool val); - - void __set_ids(const std::vector<int64_t> & val); - - bool operator == (const GetValidWriteIdsResult & rhs) const - { - if (!(lowWatermarkId == rhs.lowWatermarkId)) - return false; - if (!(highWatermarkId == rhs.highWatermarkId)) - return false; - if (__isset.areIdsValid != rhs.__isset.areIdsValid) - return false; - else if (__isset.areIdsValid && !(areIdsValid == rhs.areIdsValid)) - return false; - if (__isset.ids != rhs.__isset.ids) - return false; - else if (__isset.ids && !(ids == rhs.ids)) - return false; - return true; - } - bool operator != (const GetValidWriteIdsResult &rhs) const { - return !(*this == rhs); - } - - bool operator < (const GetValidWriteIdsResult & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - - virtual void printTo(std::ostream& out) const; -}; - -void swap(GetValidWriteIdsResult &a, GetValidWriteIdsResult &b); - -inline std::ostream& operator<<(std::ostream& out, const GetValidWriteIdsResult& obj) -{ - obj.printTo(out); - return out; -} - typedef struct _GetAllFunctionsResponse__isset { _GetAllFunctionsResponse__isset() : functions(false) {} bool functions :1;