You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by we...@apache.org on 2017/05/16 22:53:20 UTC
[15/18] hive git commit: HIVE-14879 : integrate MM tables into ACID:
replace MM metastore calls and structures with ACID ones (Wei Zheng)
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;