You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2018/07/03 18:00:31 UTC
[07/10] hive git commit: HIVE-19975 : Checking writeIdList per table
may not check the commit level of a partition on a partitioned table (Sergey
Shelukhin)
http://git-wip-us.apache.org/repos/asf/hive/blob/a47a80fe/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp b/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp
index 8980258..3b27199 100644
--- a/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp
+++ b/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp
@@ -215,18 +215,6 @@ const char* _kSchemaVersionStateNames[] = {
};
const std::map<int, const char*> _SchemaVersionState_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(8, _kSchemaVersionStateValues, _kSchemaVersionStateNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL));
-int _kIsolationLevelComplianceValues[] = {
- IsolationLevelCompliance::YES,
- IsolationLevelCompliance::NO,
- IsolationLevelCompliance::UNKNOWN
-};
-const char* _kIsolationLevelComplianceNames[] = {
- "YES",
- "NO",
- "UNKNOWN"
-};
-const std::map<int, const char*> _IsolationLevelCompliance_VALUES_TO_NAMES(::apache::thrift::TEnumIterator(3, _kIsolationLevelComplianceValues, _kIsolationLevelComplianceNames), ::apache::thrift::TEnumIterator(-1, NULL, NULL));
-
int _kFunctionTypeValues[] = {
FunctionType::JAVA
};
@@ -6447,22 +6435,12 @@ void Table::__set_ownerType(const PrincipalType::type val) {
__isset.ownerType = true;
}
-void Table::__set_txnId(const int64_t val) {
- this->txnId = val;
-__isset.txnId = true;
-}
-
void Table::__set_writeId(const int64_t val) {
this->writeId = val;
__isset.writeId = true;
}
-void Table::__set_validWriteIdList(const std::string& val) {
- this->validWriteIdList = val;
-__isset.validWriteIdList = true;
-}
-
-void Table::__set_isStatsCompliant(const IsolationLevelCompliance::type val) {
+void Table::__set_isStatsCompliant(const bool val) {
this->isStatsCompliant = val;
__isset.isStatsCompliant = true;
}
@@ -6663,33 +6641,15 @@ uint32_t Table::read(::apache::thrift::protocol::TProtocol* iprot) {
break;
case 19:
if (ftype == ::apache::thrift::protocol::T_I64) {
- xfer += iprot->readI64(this->txnId);
- this->__isset.txnId = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 20:
- if (ftype == ::apache::thrift::protocol::T_I64) {
xfer += iprot->readI64(this->writeId);
this->__isset.writeId = true;
} else {
xfer += iprot->skip(ftype);
}
break;
- case 21:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->validWriteIdList);
- this->__isset.validWriteIdList = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 22:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast249;
- xfer += iprot->readI32(ecast249);
- this->isStatsCompliant = (IsolationLevelCompliance::type)ecast249;
+ case 20:
+ if (ftype == ::apache::thrift::protocol::T_BOOL) {
+ xfer += iprot->readBool(this->isStatsCompliant);
this->__isset.isStatsCompliant = true;
} else {
xfer += iprot->skip(ftype);
@@ -6743,10 +6703,10 @@ uint32_t Table::write(::apache::thrift::protocol::TProtocol* oprot) const {
xfer += oprot->writeFieldBegin("partitionKeys", ::apache::thrift::protocol::T_LIST, 8);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->partitionKeys.size()));
- std::vector<FieldSchema> ::const_iterator _iter250;
- for (_iter250 = this->partitionKeys.begin(); _iter250 != this->partitionKeys.end(); ++_iter250)
+ std::vector<FieldSchema> ::const_iterator _iter249;
+ for (_iter249 = this->partitionKeys.begin(); _iter249 != this->partitionKeys.end(); ++_iter249)
{
- xfer += (*_iter250).write(oprot);
+ xfer += (*_iter249).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -6755,11 +6715,11 @@ uint32_t Table::write(::apache::thrift::protocol::TProtocol* oprot) const {
xfer += oprot->writeFieldBegin("parameters", ::apache::thrift::protocol::T_MAP, 9);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->parameters.size()));
- std::map<std::string, std::string> ::const_iterator _iter251;
- for (_iter251 = this->parameters.begin(); _iter251 != this->parameters.end(); ++_iter251)
+ std::map<std::string, std::string> ::const_iterator _iter250;
+ for (_iter250 = this->parameters.begin(); _iter250 != this->parameters.end(); ++_iter250)
{
- xfer += oprot->writeString(_iter251->first);
- xfer += oprot->writeString(_iter251->second);
+ xfer += oprot->writeString(_iter250->first);
+ xfer += oprot->writeString(_iter250->second);
}
xfer += oprot->writeMapEnd();
}
@@ -6807,24 +6767,14 @@ uint32_t Table::write(::apache::thrift::protocol::TProtocol* oprot) const {
xfer += oprot->writeI32((int32_t)this->ownerType);
xfer += oprot->writeFieldEnd();
}
- if (this->__isset.txnId) {
- xfer += oprot->writeFieldBegin("txnId", ::apache::thrift::protocol::T_I64, 19);
- xfer += oprot->writeI64(this->txnId);
- xfer += oprot->writeFieldEnd();
- }
if (this->__isset.writeId) {
- xfer += oprot->writeFieldBegin("writeId", ::apache::thrift::protocol::T_I64, 20);
+ xfer += oprot->writeFieldBegin("writeId", ::apache::thrift::protocol::T_I64, 19);
xfer += oprot->writeI64(this->writeId);
xfer += oprot->writeFieldEnd();
}
- if (this->__isset.validWriteIdList) {
- xfer += oprot->writeFieldBegin("validWriteIdList", ::apache::thrift::protocol::T_STRING, 21);
- xfer += oprot->writeString(this->validWriteIdList);
- xfer += oprot->writeFieldEnd();
- }
if (this->__isset.isStatsCompliant) {
- xfer += oprot->writeFieldBegin("isStatsCompliant", ::apache::thrift::protocol::T_I32, 22);
- xfer += oprot->writeI32((int32_t)this->isStatsCompliant);
+ xfer += oprot->writeFieldBegin("isStatsCompliant", ::apache::thrift::protocol::T_BOOL, 20);
+ xfer += oprot->writeBool(this->isStatsCompliant);
xfer += oprot->writeFieldEnd();
}
xfer += oprot->writeFieldStop();
@@ -6852,14 +6802,35 @@ void swap(Table &a, Table &b) {
swap(a.creationMetadata, b.creationMetadata);
swap(a.catName, b.catName);
swap(a.ownerType, b.ownerType);
- swap(a.txnId, b.txnId);
swap(a.writeId, b.writeId);
- swap(a.validWriteIdList, b.validWriteIdList);
swap(a.isStatsCompliant, b.isStatsCompliant);
swap(a.__isset, b.__isset);
}
-Table::Table(const Table& other252) {
+Table::Table(const Table& other251) {
+ tableName = other251.tableName;
+ dbName = other251.dbName;
+ owner = other251.owner;
+ createTime = other251.createTime;
+ lastAccessTime = other251.lastAccessTime;
+ retention = other251.retention;
+ sd = other251.sd;
+ partitionKeys = other251.partitionKeys;
+ parameters = other251.parameters;
+ viewOriginalText = other251.viewOriginalText;
+ viewExpandedText = other251.viewExpandedText;
+ tableType = other251.tableType;
+ privileges = other251.privileges;
+ temporary = other251.temporary;
+ rewriteEnabled = other251.rewriteEnabled;
+ creationMetadata = other251.creationMetadata;
+ catName = other251.catName;
+ ownerType = other251.ownerType;
+ writeId = other251.writeId;
+ isStatsCompliant = other251.isStatsCompliant;
+ __isset = other251.__isset;
+}
+Table& Table::operator=(const Table& other252) {
tableName = other252.tableName;
dbName = other252.dbName;
owner = other252.owner;
@@ -6878,36 +6849,9 @@ Table::Table(const Table& other252) {
creationMetadata = other252.creationMetadata;
catName = other252.catName;
ownerType = other252.ownerType;
- txnId = other252.txnId;
writeId = other252.writeId;
- validWriteIdList = other252.validWriteIdList;
isStatsCompliant = other252.isStatsCompliant;
__isset = other252.__isset;
-}
-Table& Table::operator=(const Table& other253) {
- tableName = other253.tableName;
- dbName = other253.dbName;
- owner = other253.owner;
- createTime = other253.createTime;
- lastAccessTime = other253.lastAccessTime;
- retention = other253.retention;
- sd = other253.sd;
- partitionKeys = other253.partitionKeys;
- parameters = other253.parameters;
- viewOriginalText = other253.viewOriginalText;
- viewExpandedText = other253.viewExpandedText;
- tableType = other253.tableType;
- privileges = other253.privileges;
- temporary = other253.temporary;
- rewriteEnabled = other253.rewriteEnabled;
- creationMetadata = other253.creationMetadata;
- catName = other253.catName;
- ownerType = other253.ownerType;
- txnId = other253.txnId;
- writeId = other253.writeId;
- validWriteIdList = other253.validWriteIdList;
- isStatsCompliant = other253.isStatsCompliant;
- __isset = other253.__isset;
return *this;
}
void Table::printTo(std::ostream& out) const {
@@ -6931,9 +6875,7 @@ void Table::printTo(std::ostream& out) const {
out << ", " << "creationMetadata="; (__isset.creationMetadata ? (out << to_string(creationMetadata)) : (out << "<null>"));
out << ", " << "catName="; (__isset.catName ? (out << to_string(catName)) : (out << "<null>"));
out << ", " << "ownerType="; (__isset.ownerType ? (out << to_string(ownerType)) : (out << "<null>"));
- out << ", " << "txnId="; (__isset.txnId ? (out << to_string(txnId)) : (out << "<null>"));
out << ", " << "writeId="; (__isset.writeId ? (out << to_string(writeId)) : (out << "<null>"));
- out << ", " << "validWriteIdList="; (__isset.validWriteIdList ? (out << to_string(validWriteIdList)) : (out << "<null>"));
out << ", " << "isStatsCompliant="; (__isset.isStatsCompliant ? (out << to_string(isStatsCompliant)) : (out << "<null>"));
out << ")";
}
@@ -6981,22 +6923,12 @@ void Partition::__set_catName(const std::string& val) {
__isset.catName = true;
}
-void Partition::__set_txnId(const int64_t val) {
- this->txnId = val;
-__isset.txnId = true;
-}
-
void Partition::__set_writeId(const int64_t val) {
this->writeId = val;
__isset.writeId = true;
}
-void Partition::__set_validWriteIdList(const std::string& val) {
- this->validWriteIdList = val;
-__isset.validWriteIdList = true;
-}
-
-void Partition::__set_isStatsCompliant(const IsolationLevelCompliance::type val) {
+void Partition::__set_isStatsCompliant(const bool val) {
this->isStatsCompliant = val;
__isset.isStatsCompliant = true;
}
@@ -7026,14 +6958,14 @@ uint32_t Partition::read(::apache::thrift::protocol::TProtocol* iprot) {
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->values.clear();
- uint32_t _size254;
- ::apache::thrift::protocol::TType _etype257;
- xfer += iprot->readListBegin(_etype257, _size254);
- this->values.resize(_size254);
- uint32_t _i258;
- for (_i258 = 0; _i258 < _size254; ++_i258)
+ uint32_t _size253;
+ ::apache::thrift::protocol::TType _etype256;
+ xfer += iprot->readListBegin(_etype256, _size253);
+ this->values.resize(_size253);
+ uint32_t _i257;
+ for (_i257 = 0; _i257 < _size253; ++_i257)
{
- xfer += iprot->readString(this->values[_i258]);
+ xfer += iprot->readString(this->values[_i257]);
}
xfer += iprot->readListEnd();
}
@@ -7086,17 +7018,17 @@ uint32_t Partition::read(::apache::thrift::protocol::TProtocol* iprot) {
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->parameters.clear();
- uint32_t _size259;
- ::apache::thrift::protocol::TType _ktype260;
- ::apache::thrift::protocol::TType _vtype261;
- xfer += iprot->readMapBegin(_ktype260, _vtype261, _size259);
- uint32_t _i263;
- for (_i263 = 0; _i263 < _size259; ++_i263)
+ uint32_t _size258;
+ ::apache::thrift::protocol::TType _ktype259;
+ ::apache::thrift::protocol::TType _vtype260;
+ xfer += iprot->readMapBegin(_ktype259, _vtype260, _size258);
+ uint32_t _i262;
+ for (_i262 = 0; _i262 < _size258; ++_i262)
{
- std::string _key264;
- xfer += iprot->readString(_key264);
- std::string& _val265 = this->parameters[_key264];
- xfer += iprot->readString(_val265);
+ std::string _key263;
+ xfer += iprot->readString(_key263);
+ std::string& _val264 = this->parameters[_key263];
+ xfer += iprot->readString(_val264);
}
xfer += iprot->readMapEnd();
}
@@ -7123,33 +7055,15 @@ uint32_t Partition::read(::apache::thrift::protocol::TProtocol* iprot) {
break;
case 10:
if (ftype == ::apache::thrift::protocol::T_I64) {
- xfer += iprot->readI64(this->txnId);
- this->__isset.txnId = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 11:
- if (ftype == ::apache::thrift::protocol::T_I64) {
xfer += iprot->readI64(this->writeId);
this->__isset.writeId = true;
} else {
xfer += iprot->skip(ftype);
}
break;
- case 12:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->validWriteIdList);
- this->__isset.validWriteIdList = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 13:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast266;
- xfer += iprot->readI32(ecast266);
- this->isStatsCompliant = (IsolationLevelCompliance::type)ecast266;
+ case 11:
+ if (ftype == ::apache::thrift::protocol::T_BOOL) {
+ xfer += iprot->readBool(this->isStatsCompliant);
this->__isset.isStatsCompliant = true;
} else {
xfer += iprot->skip(ftype);
@@ -7175,10 +7089,10 @@ uint32_t Partition::write(::apache::thrift::protocol::TProtocol* oprot) const {
xfer += oprot->writeFieldBegin("values", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->values.size()));
- std::vector<std::string> ::const_iterator _iter267;
- for (_iter267 = this->values.begin(); _iter267 != this->values.end(); ++_iter267)
+ std::vector<std::string> ::const_iterator _iter265;
+ for (_iter265 = this->values.begin(); _iter265 != this->values.end(); ++_iter265)
{
- xfer += oprot->writeString((*_iter267));
+ xfer += oprot->writeString((*_iter265));
}
xfer += oprot->writeListEnd();
}
@@ -7207,11 +7121,11 @@ uint32_t Partition::write(::apache::thrift::protocol::TProtocol* oprot) const {
xfer += oprot->writeFieldBegin("parameters", ::apache::thrift::protocol::T_MAP, 7);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->parameters.size()));
- std::map<std::string, std::string> ::const_iterator _iter268;
- for (_iter268 = this->parameters.begin(); _iter268 != this->parameters.end(); ++_iter268)
+ std::map<std::string, std::string> ::const_iterator _iter266;
+ for (_iter266 = this->parameters.begin(); _iter266 != this->parameters.end(); ++_iter266)
{
- xfer += oprot->writeString(_iter268->first);
- xfer += oprot->writeString(_iter268->second);
+ xfer += oprot->writeString(_iter266->first);
+ xfer += oprot->writeString(_iter266->second);
}
xfer += oprot->writeMapEnd();
}
@@ -7227,24 +7141,14 @@ uint32_t Partition::write(::apache::thrift::protocol::TProtocol* oprot) const {
xfer += oprot->writeString(this->catName);
xfer += oprot->writeFieldEnd();
}
- if (this->__isset.txnId) {
- xfer += oprot->writeFieldBegin("txnId", ::apache::thrift::protocol::T_I64, 10);
- xfer += oprot->writeI64(this->txnId);
- xfer += oprot->writeFieldEnd();
- }
if (this->__isset.writeId) {
- xfer += oprot->writeFieldBegin("writeId", ::apache::thrift::protocol::T_I64, 11);
+ xfer += oprot->writeFieldBegin("writeId", ::apache::thrift::protocol::T_I64, 10);
xfer += oprot->writeI64(this->writeId);
xfer += oprot->writeFieldEnd();
}
- if (this->__isset.validWriteIdList) {
- xfer += oprot->writeFieldBegin("validWriteIdList", ::apache::thrift::protocol::T_STRING, 12);
- xfer += oprot->writeString(this->validWriteIdList);
- xfer += oprot->writeFieldEnd();
- }
if (this->__isset.isStatsCompliant) {
- xfer += oprot->writeFieldBegin("isStatsCompliant", ::apache::thrift::protocol::T_I32, 13);
- xfer += oprot->writeI32((int32_t)this->isStatsCompliant);
+ xfer += oprot->writeFieldBegin("isStatsCompliant", ::apache::thrift::protocol::T_BOOL, 11);
+ xfer += oprot->writeBool(this->isStatsCompliant);
xfer += oprot->writeFieldEnd();
}
xfer += oprot->writeFieldStop();
@@ -7263,44 +7167,38 @@ void swap(Partition &a, Partition &b) {
swap(a.parameters, b.parameters);
swap(a.privileges, b.privileges);
swap(a.catName, b.catName);
- swap(a.txnId, b.txnId);
swap(a.writeId, b.writeId);
- swap(a.validWriteIdList, b.validWriteIdList);
swap(a.isStatsCompliant, b.isStatsCompliant);
swap(a.__isset, b.__isset);
}
-Partition::Partition(const Partition& other269) {
- values = other269.values;
- dbName = other269.dbName;
- tableName = other269.tableName;
- createTime = other269.createTime;
- lastAccessTime = other269.lastAccessTime;
- sd = other269.sd;
- parameters = other269.parameters;
- privileges = other269.privileges;
- catName = other269.catName;
- txnId = other269.txnId;
- writeId = other269.writeId;
- validWriteIdList = other269.validWriteIdList;
- isStatsCompliant = other269.isStatsCompliant;
- __isset = other269.__isset;
-}
-Partition& Partition::operator=(const Partition& other270) {
- values = other270.values;
- dbName = other270.dbName;
- tableName = other270.tableName;
- createTime = other270.createTime;
- lastAccessTime = other270.lastAccessTime;
- sd = other270.sd;
- parameters = other270.parameters;
- privileges = other270.privileges;
- catName = other270.catName;
- txnId = other270.txnId;
- writeId = other270.writeId;
- validWriteIdList = other270.validWriteIdList;
- isStatsCompliant = other270.isStatsCompliant;
- __isset = other270.__isset;
+Partition::Partition(const Partition& other267) {
+ values = other267.values;
+ dbName = other267.dbName;
+ tableName = other267.tableName;
+ createTime = other267.createTime;
+ lastAccessTime = other267.lastAccessTime;
+ sd = other267.sd;
+ parameters = other267.parameters;
+ privileges = other267.privileges;
+ catName = other267.catName;
+ writeId = other267.writeId;
+ isStatsCompliant = other267.isStatsCompliant;
+ __isset = other267.__isset;
+}
+Partition& Partition::operator=(const Partition& other268) {
+ values = other268.values;
+ dbName = other268.dbName;
+ tableName = other268.tableName;
+ createTime = other268.createTime;
+ lastAccessTime = other268.lastAccessTime;
+ sd = other268.sd;
+ parameters = other268.parameters;
+ privileges = other268.privileges;
+ catName = other268.catName;
+ writeId = other268.writeId;
+ isStatsCompliant = other268.isStatsCompliant;
+ __isset = other268.__isset;
return *this;
}
void Partition::printTo(std::ostream& out) const {
@@ -7315,9 +7213,7 @@ void Partition::printTo(std::ostream& out) const {
out << ", " << "parameters=" << to_string(parameters);
out << ", " << "privileges="; (__isset.privileges ? (out << to_string(privileges)) : (out << "<null>"));
out << ", " << "catName="; (__isset.catName ? (out << to_string(catName)) : (out << "<null>"));
- out << ", " << "txnId="; (__isset.txnId ? (out << to_string(txnId)) : (out << "<null>"));
out << ", " << "writeId="; (__isset.writeId ? (out << to_string(writeId)) : (out << "<null>"));
- out << ", " << "validWriteIdList="; (__isset.validWriteIdList ? (out << to_string(validWriteIdList)) : (out << "<null>"));
out << ", " << "isStatsCompliant="; (__isset.isStatsCompliant ? (out << to_string(isStatsCompliant)) : (out << "<null>"));
out << ")";
}
@@ -7377,14 +7273,14 @@ uint32_t PartitionWithoutSD::read(::apache::thrift::protocol::TProtocol* iprot)
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->values.clear();
- uint32_t _size271;
- ::apache::thrift::protocol::TType _etype274;
- xfer += iprot->readListBegin(_etype274, _size271);
- this->values.resize(_size271);
- uint32_t _i275;
- for (_i275 = 0; _i275 < _size271; ++_i275)
+ uint32_t _size269;
+ ::apache::thrift::protocol::TType _etype272;
+ xfer += iprot->readListBegin(_etype272, _size269);
+ this->values.resize(_size269);
+ uint32_t _i273;
+ for (_i273 = 0; _i273 < _size269; ++_i273)
{
- xfer += iprot->readString(this->values[_i275]);
+ xfer += iprot->readString(this->values[_i273]);
}
xfer += iprot->readListEnd();
}
@@ -7421,17 +7317,17 @@ uint32_t PartitionWithoutSD::read(::apache::thrift::protocol::TProtocol* iprot)
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->parameters.clear();
- uint32_t _size276;
- ::apache::thrift::protocol::TType _ktype277;
- ::apache::thrift::protocol::TType _vtype278;
- xfer += iprot->readMapBegin(_ktype277, _vtype278, _size276);
- uint32_t _i280;
- for (_i280 = 0; _i280 < _size276; ++_i280)
+ uint32_t _size274;
+ ::apache::thrift::protocol::TType _ktype275;
+ ::apache::thrift::protocol::TType _vtype276;
+ xfer += iprot->readMapBegin(_ktype275, _vtype276, _size274);
+ uint32_t _i278;
+ for (_i278 = 0; _i278 < _size274; ++_i278)
{
- std::string _key281;
- xfer += iprot->readString(_key281);
- std::string& _val282 = this->parameters[_key281];
- xfer += iprot->readString(_val282);
+ std::string _key279;
+ xfer += iprot->readString(_key279);
+ std::string& _val280 = this->parameters[_key279];
+ xfer += iprot->readString(_val280);
}
xfer += iprot->readMapEnd();
}
@@ -7468,10 +7364,10 @@ uint32_t PartitionWithoutSD::write(::apache::thrift::protocol::TProtocol* oprot)
xfer += oprot->writeFieldBegin("values", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->values.size()));
- std::vector<std::string> ::const_iterator _iter283;
- for (_iter283 = this->values.begin(); _iter283 != this->values.end(); ++_iter283)
+ std::vector<std::string> ::const_iterator _iter281;
+ for (_iter281 = this->values.begin(); _iter281 != this->values.end(); ++_iter281)
{
- xfer += oprot->writeString((*_iter283));
+ xfer += oprot->writeString((*_iter281));
}
xfer += oprot->writeListEnd();
}
@@ -7492,11 +7388,11 @@ uint32_t PartitionWithoutSD::write(::apache::thrift::protocol::TProtocol* oprot)
xfer += oprot->writeFieldBegin("parameters", ::apache::thrift::protocol::T_MAP, 5);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->parameters.size()));
- std::map<std::string, std::string> ::const_iterator _iter284;
- for (_iter284 = this->parameters.begin(); _iter284 != this->parameters.end(); ++_iter284)
+ std::map<std::string, std::string> ::const_iterator _iter282;
+ for (_iter282 = this->parameters.begin(); _iter282 != this->parameters.end(); ++_iter282)
{
- xfer += oprot->writeString(_iter284->first);
- xfer += oprot->writeString(_iter284->second);
+ xfer += oprot->writeString(_iter282->first);
+ xfer += oprot->writeString(_iter282->second);
}
xfer += oprot->writeMapEnd();
}
@@ -7523,23 +7419,23 @@ void swap(PartitionWithoutSD &a, PartitionWithoutSD &b) {
swap(a.__isset, b.__isset);
}
-PartitionWithoutSD::PartitionWithoutSD(const PartitionWithoutSD& other285) {
- values = other285.values;
- createTime = other285.createTime;
- lastAccessTime = other285.lastAccessTime;
- relativePath = other285.relativePath;
- parameters = other285.parameters;
- privileges = other285.privileges;
- __isset = other285.__isset;
-}
-PartitionWithoutSD& PartitionWithoutSD::operator=(const PartitionWithoutSD& other286) {
- values = other286.values;
- createTime = other286.createTime;
- lastAccessTime = other286.lastAccessTime;
- relativePath = other286.relativePath;
- parameters = other286.parameters;
- privileges = other286.privileges;
- __isset = other286.__isset;
+PartitionWithoutSD::PartitionWithoutSD(const PartitionWithoutSD& other283) {
+ values = other283.values;
+ createTime = other283.createTime;
+ lastAccessTime = other283.lastAccessTime;
+ relativePath = other283.relativePath;
+ parameters = other283.parameters;
+ privileges = other283.privileges;
+ __isset = other283.__isset;
+}
+PartitionWithoutSD& PartitionWithoutSD::operator=(const PartitionWithoutSD& other284) {
+ values = other284.values;
+ createTime = other284.createTime;
+ lastAccessTime = other284.lastAccessTime;
+ relativePath = other284.relativePath;
+ parameters = other284.parameters;
+ privileges = other284.privileges;
+ __isset = other284.__isset;
return *this;
}
void PartitionWithoutSD::printTo(std::ostream& out) const {
@@ -7592,14 +7488,14 @@ uint32_t PartitionSpecWithSharedSD::read(::apache::thrift::protocol::TProtocol*
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->partitions.clear();
- uint32_t _size287;
- ::apache::thrift::protocol::TType _etype290;
- xfer += iprot->readListBegin(_etype290, _size287);
- this->partitions.resize(_size287);
- uint32_t _i291;
- for (_i291 = 0; _i291 < _size287; ++_i291)
+ uint32_t _size285;
+ ::apache::thrift::protocol::TType _etype288;
+ xfer += iprot->readListBegin(_etype288, _size285);
+ this->partitions.resize(_size285);
+ uint32_t _i289;
+ for (_i289 = 0; _i289 < _size285; ++_i289)
{
- xfer += this->partitions[_i291].read(iprot);
+ xfer += this->partitions[_i289].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -7636,10 +7532,10 @@ uint32_t PartitionSpecWithSharedSD::write(::apache::thrift::protocol::TProtocol*
xfer += oprot->writeFieldBegin("partitions", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->partitions.size()));
- std::vector<PartitionWithoutSD> ::const_iterator _iter292;
- for (_iter292 = this->partitions.begin(); _iter292 != this->partitions.end(); ++_iter292)
+ std::vector<PartitionWithoutSD> ::const_iterator _iter290;
+ for (_iter290 = this->partitions.begin(); _iter290 != this->partitions.end(); ++_iter290)
{
- xfer += (*_iter292).write(oprot);
+ xfer += (*_iter290).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -7661,15 +7557,15 @@ void swap(PartitionSpecWithSharedSD &a, PartitionSpecWithSharedSD &b) {
swap(a.__isset, b.__isset);
}
-PartitionSpecWithSharedSD::PartitionSpecWithSharedSD(const PartitionSpecWithSharedSD& other293) {
- partitions = other293.partitions;
- sd = other293.sd;
- __isset = other293.__isset;
+PartitionSpecWithSharedSD::PartitionSpecWithSharedSD(const PartitionSpecWithSharedSD& other291) {
+ partitions = other291.partitions;
+ sd = other291.sd;
+ __isset = other291.__isset;
}
-PartitionSpecWithSharedSD& PartitionSpecWithSharedSD::operator=(const PartitionSpecWithSharedSD& other294) {
- partitions = other294.partitions;
- sd = other294.sd;
- __isset = other294.__isset;
+PartitionSpecWithSharedSD& PartitionSpecWithSharedSD::operator=(const PartitionSpecWithSharedSD& other292) {
+ partitions = other292.partitions;
+ sd = other292.sd;
+ __isset = other292.__isset;
return *this;
}
void PartitionSpecWithSharedSD::printTo(std::ostream& out) const {
@@ -7714,14 +7610,14 @@ uint32_t PartitionListComposingSpec::read(::apache::thrift::protocol::TProtocol*
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->partitions.clear();
- uint32_t _size295;
- ::apache::thrift::protocol::TType _etype298;
- xfer += iprot->readListBegin(_etype298, _size295);
- this->partitions.resize(_size295);
- uint32_t _i299;
- for (_i299 = 0; _i299 < _size295; ++_i299)
+ uint32_t _size293;
+ ::apache::thrift::protocol::TType _etype296;
+ xfer += iprot->readListBegin(_etype296, _size293);
+ this->partitions.resize(_size293);
+ uint32_t _i297;
+ for (_i297 = 0; _i297 < _size293; ++_i297)
{
- xfer += this->partitions[_i299].read(iprot);
+ xfer += this->partitions[_i297].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -7750,10 +7646,10 @@ uint32_t PartitionListComposingSpec::write(::apache::thrift::protocol::TProtocol
xfer += oprot->writeFieldBegin("partitions", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->partitions.size()));
- std::vector<Partition> ::const_iterator _iter300;
- for (_iter300 = this->partitions.begin(); _iter300 != this->partitions.end(); ++_iter300)
+ std::vector<Partition> ::const_iterator _iter298;
+ for (_iter298 = this->partitions.begin(); _iter298 != this->partitions.end(); ++_iter298)
{
- xfer += (*_iter300).write(oprot);
+ xfer += (*_iter298).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -7770,13 +7666,13 @@ void swap(PartitionListComposingSpec &a, PartitionListComposingSpec &b) {
swap(a.__isset, b.__isset);
}
-PartitionListComposingSpec::PartitionListComposingSpec(const PartitionListComposingSpec& other301) {
- partitions = other301.partitions;
- __isset = other301.__isset;
+PartitionListComposingSpec::PartitionListComposingSpec(const PartitionListComposingSpec& other299) {
+ partitions = other299.partitions;
+ __isset = other299.__isset;
}
-PartitionListComposingSpec& PartitionListComposingSpec::operator=(const PartitionListComposingSpec& other302) {
- partitions = other302.partitions;
- __isset = other302.__isset;
+PartitionListComposingSpec& PartitionListComposingSpec::operator=(const PartitionListComposingSpec& other300) {
+ partitions = other300.partitions;
+ __isset = other300.__isset;
return *this;
}
void PartitionListComposingSpec::printTo(std::ostream& out) const {
@@ -7818,22 +7714,12 @@ void PartitionSpec::__set_catName(const std::string& val) {
__isset.catName = true;
}
-void PartitionSpec::__set_txnId(const int64_t val) {
- this->txnId = val;
-__isset.txnId = true;
-}
-
void PartitionSpec::__set_writeId(const int64_t val) {
this->writeId = val;
__isset.writeId = true;
}
-void PartitionSpec::__set_validWriteIdList(const std::string& val) {
- this->validWriteIdList = val;
-__isset.validWriteIdList = true;
-}
-
-void PartitionSpec::__set_isStatsCompliant(const IsolationLevelCompliance::type val) {
+void PartitionSpec::__set_isStatsCompliant(const bool val) {
this->isStatsCompliant = val;
__isset.isStatsCompliant = true;
}
@@ -7909,33 +7795,15 @@ uint32_t PartitionSpec::read(::apache::thrift::protocol::TProtocol* iprot) {
break;
case 7:
if (ftype == ::apache::thrift::protocol::T_I64) {
- xfer += iprot->readI64(this->txnId);
- this->__isset.txnId = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 8:
- if (ftype == ::apache::thrift::protocol::T_I64) {
xfer += iprot->readI64(this->writeId);
this->__isset.writeId = true;
} else {
xfer += iprot->skip(ftype);
}
break;
- case 9:
- if (ftype == ::apache::thrift::protocol::T_STRING) {
- xfer += iprot->readString(this->validWriteIdList);
- this->__isset.validWriteIdList = true;
- } else {
- xfer += iprot->skip(ftype);
- }
- break;
- case 10:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast303;
- xfer += iprot->readI32(ecast303);
- this->isStatsCompliant = (IsolationLevelCompliance::type)ecast303;
+ case 8:
+ if (ftype == ::apache::thrift::protocol::T_BOOL) {
+ xfer += iprot->readBool(this->isStatsCompliant);
this->__isset.isStatsCompliant = true;
} else {
xfer += iprot->skip(ftype);
@@ -7985,24 +7853,14 @@ uint32_t PartitionSpec::write(::apache::thrift::protocol::TProtocol* oprot) cons
xfer += oprot->writeString(this->catName);
xfer += oprot->writeFieldEnd();
}
- if (this->__isset.txnId) {
- xfer += oprot->writeFieldBegin("txnId", ::apache::thrift::protocol::T_I64, 7);
- xfer += oprot->writeI64(this->txnId);
- xfer += oprot->writeFieldEnd();
- }
if (this->__isset.writeId) {
- xfer += oprot->writeFieldBegin("writeId", ::apache::thrift::protocol::T_I64, 8);
+ xfer += oprot->writeFieldBegin("writeId", ::apache::thrift::protocol::T_I64, 7);
xfer += oprot->writeI64(this->writeId);
xfer += oprot->writeFieldEnd();
}
- if (this->__isset.validWriteIdList) {
- xfer += oprot->writeFieldBegin("validWriteIdList", ::apache::thrift::protocol::T_STRING, 9);
- xfer += oprot->writeString(this->validWriteIdList);
- xfer += oprot->writeFieldEnd();
- }
if (this->__isset.isStatsCompliant) {
- xfer += oprot->writeFieldBegin("isStatsCompliant", ::apache::thrift::protocol::T_I32, 10);
- xfer += oprot->writeI32((int32_t)this->isStatsCompliant);
+ xfer += oprot->writeFieldBegin("isStatsCompliant", ::apache::thrift::protocol::T_BOOL, 8);
+ xfer += oprot->writeBool(this->isStatsCompliant);
xfer += oprot->writeFieldEnd();
}
xfer += oprot->writeFieldStop();
@@ -8018,38 +7876,32 @@ void swap(PartitionSpec &a, PartitionSpec &b) {
swap(a.sharedSDPartitionSpec, b.sharedSDPartitionSpec);
swap(a.partitionList, b.partitionList);
swap(a.catName, b.catName);
- swap(a.txnId, b.txnId);
swap(a.writeId, b.writeId);
- swap(a.validWriteIdList, b.validWriteIdList);
swap(a.isStatsCompliant, b.isStatsCompliant);
swap(a.__isset, b.__isset);
}
-PartitionSpec::PartitionSpec(const PartitionSpec& other304) {
- dbName = other304.dbName;
- tableName = other304.tableName;
- rootPath = other304.rootPath;
- sharedSDPartitionSpec = other304.sharedSDPartitionSpec;
- partitionList = other304.partitionList;
- catName = other304.catName;
- txnId = other304.txnId;
- writeId = other304.writeId;
- validWriteIdList = other304.validWriteIdList;
- isStatsCompliant = other304.isStatsCompliant;
- __isset = other304.__isset;
+PartitionSpec::PartitionSpec(const PartitionSpec& other301) {
+ dbName = other301.dbName;
+ tableName = other301.tableName;
+ rootPath = other301.rootPath;
+ sharedSDPartitionSpec = other301.sharedSDPartitionSpec;
+ partitionList = other301.partitionList;
+ catName = other301.catName;
+ writeId = other301.writeId;
+ isStatsCompliant = other301.isStatsCompliant;
+ __isset = other301.__isset;
}
-PartitionSpec& PartitionSpec::operator=(const PartitionSpec& other305) {
- dbName = other305.dbName;
- tableName = other305.tableName;
- rootPath = other305.rootPath;
- sharedSDPartitionSpec = other305.sharedSDPartitionSpec;
- partitionList = other305.partitionList;
- catName = other305.catName;
- txnId = other305.txnId;
- writeId = other305.writeId;
- validWriteIdList = other305.validWriteIdList;
- isStatsCompliant = other305.isStatsCompliant;
- __isset = other305.__isset;
+PartitionSpec& PartitionSpec::operator=(const PartitionSpec& other302) {
+ dbName = other302.dbName;
+ tableName = other302.tableName;
+ rootPath = other302.rootPath;
+ sharedSDPartitionSpec = other302.sharedSDPartitionSpec;
+ partitionList = other302.partitionList;
+ catName = other302.catName;
+ writeId = other302.writeId;
+ isStatsCompliant = other302.isStatsCompliant;
+ __isset = other302.__isset;
return *this;
}
void PartitionSpec::printTo(std::ostream& out) const {
@@ -8061,9 +7913,7 @@ void PartitionSpec::printTo(std::ostream& out) const {
out << ", " << "sharedSDPartitionSpec="; (__isset.sharedSDPartitionSpec ? (out << to_string(sharedSDPartitionSpec)) : (out << "<null>"));
out << ", " << "partitionList="; (__isset.partitionList ? (out << to_string(partitionList)) : (out << "<null>"));
out << ", " << "catName="; (__isset.catName ? (out << to_string(catName)) : (out << "<null>"));
- out << ", " << "txnId="; (__isset.txnId ? (out << to_string(txnId)) : (out << "<null>"));
out << ", " << "writeId="; (__isset.writeId ? (out << to_string(writeId)) : (out << "<null>"));
- out << ", " << "validWriteIdList="; (__isset.validWriteIdList ? (out << to_string(validWriteIdList)) : (out << "<null>"));
out << ", " << "isStatsCompliant="; (__isset.isStatsCompliant ? (out << to_string(isStatsCompliant)) : (out << "<null>"));
out << ")";
}
@@ -8200,19 +8050,19 @@ void swap(BooleanColumnStatsData &a, BooleanColumnStatsData &b) {
swap(a.__isset, b.__isset);
}
-BooleanColumnStatsData::BooleanColumnStatsData(const BooleanColumnStatsData& other306) {
- numTrues = other306.numTrues;
- numFalses = other306.numFalses;
- numNulls = other306.numNulls;
- bitVectors = other306.bitVectors;
- __isset = other306.__isset;
+BooleanColumnStatsData::BooleanColumnStatsData(const BooleanColumnStatsData& other303) {
+ numTrues = other303.numTrues;
+ numFalses = other303.numFalses;
+ numNulls = other303.numNulls;
+ bitVectors = other303.bitVectors;
+ __isset = other303.__isset;
}
-BooleanColumnStatsData& BooleanColumnStatsData::operator=(const BooleanColumnStatsData& other307) {
- numTrues = other307.numTrues;
- numFalses = other307.numFalses;
- numNulls = other307.numNulls;
- bitVectors = other307.bitVectors;
- __isset = other307.__isset;
+BooleanColumnStatsData& BooleanColumnStatsData::operator=(const BooleanColumnStatsData& other304) {
+ numTrues = other304.numTrues;
+ numFalses = other304.numFalses;
+ numNulls = other304.numNulls;
+ bitVectors = other304.bitVectors;
+ __isset = other304.__isset;
return *this;
}
void BooleanColumnStatsData::printTo(std::ostream& out) const {
@@ -8375,21 +8225,21 @@ void swap(DoubleColumnStatsData &a, DoubleColumnStatsData &b) {
swap(a.__isset, b.__isset);
}
-DoubleColumnStatsData::DoubleColumnStatsData(const DoubleColumnStatsData& other308) {
- lowValue = other308.lowValue;
- highValue = other308.highValue;
- numNulls = other308.numNulls;
- numDVs = other308.numDVs;
- bitVectors = other308.bitVectors;
- __isset = other308.__isset;
+DoubleColumnStatsData::DoubleColumnStatsData(const DoubleColumnStatsData& other305) {
+ lowValue = other305.lowValue;
+ highValue = other305.highValue;
+ numNulls = other305.numNulls;
+ numDVs = other305.numDVs;
+ bitVectors = other305.bitVectors;
+ __isset = other305.__isset;
}
-DoubleColumnStatsData& DoubleColumnStatsData::operator=(const DoubleColumnStatsData& other309) {
- lowValue = other309.lowValue;
- highValue = other309.highValue;
- numNulls = other309.numNulls;
- numDVs = other309.numDVs;
- bitVectors = other309.bitVectors;
- __isset = other309.__isset;
+DoubleColumnStatsData& DoubleColumnStatsData::operator=(const DoubleColumnStatsData& other306) {
+ lowValue = other306.lowValue;
+ highValue = other306.highValue;
+ numNulls = other306.numNulls;
+ numDVs = other306.numDVs;
+ bitVectors = other306.bitVectors;
+ __isset = other306.__isset;
return *this;
}
void DoubleColumnStatsData::printTo(std::ostream& out) const {
@@ -8553,21 +8403,21 @@ void swap(LongColumnStatsData &a, LongColumnStatsData &b) {
swap(a.__isset, b.__isset);
}
-LongColumnStatsData::LongColumnStatsData(const LongColumnStatsData& other310) {
- lowValue = other310.lowValue;
- highValue = other310.highValue;
- numNulls = other310.numNulls;
- numDVs = other310.numDVs;
- bitVectors = other310.bitVectors;
- __isset = other310.__isset;
+LongColumnStatsData::LongColumnStatsData(const LongColumnStatsData& other307) {
+ lowValue = other307.lowValue;
+ highValue = other307.highValue;
+ numNulls = other307.numNulls;
+ numDVs = other307.numDVs;
+ bitVectors = other307.bitVectors;
+ __isset = other307.__isset;
}
-LongColumnStatsData& LongColumnStatsData::operator=(const LongColumnStatsData& other311) {
- lowValue = other311.lowValue;
- highValue = other311.highValue;
- numNulls = other311.numNulls;
- numDVs = other311.numDVs;
- bitVectors = other311.bitVectors;
- __isset = other311.__isset;
+LongColumnStatsData& LongColumnStatsData::operator=(const LongColumnStatsData& other308) {
+ lowValue = other308.lowValue;
+ highValue = other308.highValue;
+ numNulls = other308.numNulls;
+ numDVs = other308.numDVs;
+ bitVectors = other308.bitVectors;
+ __isset = other308.__isset;
return *this;
}
void LongColumnStatsData::printTo(std::ostream& out) const {
@@ -8733,21 +8583,21 @@ void swap(StringColumnStatsData &a, StringColumnStatsData &b) {
swap(a.__isset, b.__isset);
}
-StringColumnStatsData::StringColumnStatsData(const StringColumnStatsData& other312) {
- maxColLen = other312.maxColLen;
- avgColLen = other312.avgColLen;
- numNulls = other312.numNulls;
- numDVs = other312.numDVs;
- bitVectors = other312.bitVectors;
- __isset = other312.__isset;
+StringColumnStatsData::StringColumnStatsData(const StringColumnStatsData& other309) {
+ maxColLen = other309.maxColLen;
+ avgColLen = other309.avgColLen;
+ numNulls = other309.numNulls;
+ numDVs = other309.numDVs;
+ bitVectors = other309.bitVectors;
+ __isset = other309.__isset;
}
-StringColumnStatsData& StringColumnStatsData::operator=(const StringColumnStatsData& other313) {
- maxColLen = other313.maxColLen;
- avgColLen = other313.avgColLen;
- numNulls = other313.numNulls;
- numDVs = other313.numDVs;
- bitVectors = other313.bitVectors;
- __isset = other313.__isset;
+StringColumnStatsData& StringColumnStatsData::operator=(const StringColumnStatsData& other310) {
+ maxColLen = other310.maxColLen;
+ avgColLen = other310.avgColLen;
+ numNulls = other310.numNulls;
+ numDVs = other310.numDVs;
+ bitVectors = other310.bitVectors;
+ __isset = other310.__isset;
return *this;
}
void StringColumnStatsData::printTo(std::ostream& out) const {
@@ -8893,19 +8743,19 @@ void swap(BinaryColumnStatsData &a, BinaryColumnStatsData &b) {
swap(a.__isset, b.__isset);
}
-BinaryColumnStatsData::BinaryColumnStatsData(const BinaryColumnStatsData& other314) {
- maxColLen = other314.maxColLen;
- avgColLen = other314.avgColLen;
- numNulls = other314.numNulls;
- bitVectors = other314.bitVectors;
- __isset = other314.__isset;
+BinaryColumnStatsData::BinaryColumnStatsData(const BinaryColumnStatsData& other311) {
+ maxColLen = other311.maxColLen;
+ avgColLen = other311.avgColLen;
+ numNulls = other311.numNulls;
+ bitVectors = other311.bitVectors;
+ __isset = other311.__isset;
}
-BinaryColumnStatsData& BinaryColumnStatsData::operator=(const BinaryColumnStatsData& other315) {
- maxColLen = other315.maxColLen;
- avgColLen = other315.avgColLen;
- numNulls = other315.numNulls;
- bitVectors = other315.bitVectors;
- __isset = other315.__isset;
+BinaryColumnStatsData& BinaryColumnStatsData::operator=(const BinaryColumnStatsData& other312) {
+ maxColLen = other312.maxColLen;
+ avgColLen = other312.avgColLen;
+ numNulls = other312.numNulls;
+ bitVectors = other312.bitVectors;
+ __isset = other312.__isset;
return *this;
}
void BinaryColumnStatsData::printTo(std::ostream& out) const {
@@ -9010,13 +8860,13 @@ void swap(Decimal &a, Decimal &b) {
swap(a.unscaled, b.unscaled);
}
-Decimal::Decimal(const Decimal& other316) {
- scale = other316.scale;
- unscaled = other316.unscaled;
+Decimal::Decimal(const Decimal& other313) {
+ scale = other313.scale;
+ unscaled = other313.unscaled;
}
-Decimal& Decimal::operator=(const Decimal& other317) {
- scale = other317.scale;
- unscaled = other317.unscaled;
+Decimal& Decimal::operator=(const Decimal& other314) {
+ scale = other314.scale;
+ unscaled = other314.unscaled;
return *this;
}
void Decimal::printTo(std::ostream& out) const {
@@ -9177,21 +9027,21 @@ void swap(DecimalColumnStatsData &a, DecimalColumnStatsData &b) {
swap(a.__isset, b.__isset);
}
-DecimalColumnStatsData::DecimalColumnStatsData(const DecimalColumnStatsData& other318) {
- lowValue = other318.lowValue;
- highValue = other318.highValue;
- numNulls = other318.numNulls;
- numDVs = other318.numDVs;
- bitVectors = other318.bitVectors;
- __isset = other318.__isset;
+DecimalColumnStatsData::DecimalColumnStatsData(const DecimalColumnStatsData& other315) {
+ lowValue = other315.lowValue;
+ highValue = other315.highValue;
+ numNulls = other315.numNulls;
+ numDVs = other315.numDVs;
+ bitVectors = other315.bitVectors;
+ __isset = other315.__isset;
}
-DecimalColumnStatsData& DecimalColumnStatsData::operator=(const DecimalColumnStatsData& other319) {
- lowValue = other319.lowValue;
- highValue = other319.highValue;
- numNulls = other319.numNulls;
- numDVs = other319.numDVs;
- bitVectors = other319.bitVectors;
- __isset = other319.__isset;
+DecimalColumnStatsData& DecimalColumnStatsData::operator=(const DecimalColumnStatsData& other316) {
+ lowValue = other316.lowValue;
+ highValue = other316.highValue;
+ numNulls = other316.numNulls;
+ numDVs = other316.numDVs;
+ bitVectors = other316.bitVectors;
+ __isset = other316.__isset;
return *this;
}
void DecimalColumnStatsData::printTo(std::ostream& out) const {
@@ -9277,11 +9127,11 @@ void swap(Date &a, Date &b) {
swap(a.daysSinceEpoch, b.daysSinceEpoch);
}
-Date::Date(const Date& other320) {
- daysSinceEpoch = other320.daysSinceEpoch;
+Date::Date(const Date& other317) {
+ daysSinceEpoch = other317.daysSinceEpoch;
}
-Date& Date::operator=(const Date& other321) {
- daysSinceEpoch = other321.daysSinceEpoch;
+Date& Date::operator=(const Date& other318) {
+ daysSinceEpoch = other318.daysSinceEpoch;
return *this;
}
void Date::printTo(std::ostream& out) const {
@@ -9441,21 +9291,21 @@ void swap(DateColumnStatsData &a, DateColumnStatsData &b) {
swap(a.__isset, b.__isset);
}
-DateColumnStatsData::DateColumnStatsData(const DateColumnStatsData& other322) {
- lowValue = other322.lowValue;
- highValue = other322.highValue;
- numNulls = other322.numNulls;
- numDVs = other322.numDVs;
- bitVectors = other322.bitVectors;
- __isset = other322.__isset;
+DateColumnStatsData::DateColumnStatsData(const DateColumnStatsData& other319) {
+ lowValue = other319.lowValue;
+ highValue = other319.highValue;
+ numNulls = other319.numNulls;
+ numDVs = other319.numDVs;
+ bitVectors = other319.bitVectors;
+ __isset = other319.__isset;
}
-DateColumnStatsData& DateColumnStatsData::operator=(const DateColumnStatsData& other323) {
- lowValue = other323.lowValue;
- highValue = other323.highValue;
- numNulls = other323.numNulls;
- numDVs = other323.numDVs;
- bitVectors = other323.bitVectors;
- __isset = other323.__isset;
+DateColumnStatsData& DateColumnStatsData::operator=(const DateColumnStatsData& other320) {
+ lowValue = other320.lowValue;
+ highValue = other320.highValue;
+ numNulls = other320.numNulls;
+ numDVs = other320.numDVs;
+ bitVectors = other320.bitVectors;
+ __isset = other320.__isset;
return *this;
}
void DateColumnStatsData::printTo(std::ostream& out) const {
@@ -9641,25 +9491,25 @@ void swap(ColumnStatisticsData &a, ColumnStatisticsData &b) {
swap(a.__isset, b.__isset);
}
-ColumnStatisticsData::ColumnStatisticsData(const ColumnStatisticsData& other324) {
- booleanStats = other324.booleanStats;
- longStats = other324.longStats;
- doubleStats = other324.doubleStats;
- stringStats = other324.stringStats;
- binaryStats = other324.binaryStats;
- decimalStats = other324.decimalStats;
- dateStats = other324.dateStats;
- __isset = other324.__isset;
-}
-ColumnStatisticsData& ColumnStatisticsData::operator=(const ColumnStatisticsData& other325) {
- booleanStats = other325.booleanStats;
- longStats = other325.longStats;
- doubleStats = other325.doubleStats;
- stringStats = other325.stringStats;
- binaryStats = other325.binaryStats;
- decimalStats = other325.decimalStats;
- dateStats = other325.dateStats;
- __isset = other325.__isset;
+ColumnStatisticsData::ColumnStatisticsData(const ColumnStatisticsData& other321) {
+ booleanStats = other321.booleanStats;
+ longStats = other321.longStats;
+ doubleStats = other321.doubleStats;
+ stringStats = other321.stringStats;
+ binaryStats = other321.binaryStats;
+ decimalStats = other321.decimalStats;
+ dateStats = other321.dateStats;
+ __isset = other321.__isset;
+}
+ColumnStatisticsData& ColumnStatisticsData::operator=(const ColumnStatisticsData& other322) {
+ booleanStats = other322.booleanStats;
+ longStats = other322.longStats;
+ doubleStats = other322.doubleStats;
+ stringStats = other322.stringStats;
+ binaryStats = other322.binaryStats;
+ decimalStats = other322.decimalStats;
+ dateStats = other322.dateStats;
+ __isset = other322.__isset;
return *this;
}
void ColumnStatisticsData::printTo(std::ostream& out) const {
@@ -9787,15 +9637,15 @@ void swap(ColumnStatisticsObj &a, ColumnStatisticsObj &b) {
swap(a.statsData, b.statsData);
}
-ColumnStatisticsObj::ColumnStatisticsObj(const ColumnStatisticsObj& other326) {
- colName = other326.colName;
- colType = other326.colType;
- statsData = other326.statsData;
+ColumnStatisticsObj::ColumnStatisticsObj(const ColumnStatisticsObj& other323) {
+ colName = other323.colName;
+ colType = other323.colType;
+ statsData = other323.statsData;
}
-ColumnStatisticsObj& ColumnStatisticsObj::operator=(const ColumnStatisticsObj& other327) {
- colName = other327.colName;
- colType = other327.colType;
- statsData = other327.statsData;
+ColumnStatisticsObj& ColumnStatisticsObj::operator=(const ColumnStatisticsObj& other324) {
+ colName = other324.colName;
+ colType = other324.colType;
+ statsData = other324.statsData;
return *this;
}
void ColumnStatisticsObj::printTo(std::ostream& out) const {
@@ -9977,23 +9827,23 @@ void swap(ColumnStatisticsDesc &a, ColumnStatisticsDesc &b) {
swap(a.__isset, b.__isset);
}
-ColumnStatisticsDesc::ColumnStatisticsDesc(const ColumnStatisticsDesc& other328) {
- isTblLevel = other328.isTblLevel;
- dbName = other328.dbName;
- tableName = other328.tableName;
- partName = other328.partName;
- lastAnalyzed = other328.lastAnalyzed;
- catName = other328.catName;
- __isset = other328.__isset;
-}
-ColumnStatisticsDesc& ColumnStatisticsDesc::operator=(const ColumnStatisticsDesc& other329) {
- isTblLevel = other329.isTblLevel;
- dbName = other329.dbName;
- tableName = other329.tableName;
- partName = other329.partName;
- lastAnalyzed = other329.lastAnalyzed;
- catName = other329.catName;
- __isset = other329.__isset;
+ColumnStatisticsDesc::ColumnStatisticsDesc(const ColumnStatisticsDesc& other325) {
+ isTblLevel = other325.isTblLevel;
+ dbName = other325.dbName;
+ tableName = other325.tableName;
+ partName = other325.partName;
+ lastAnalyzed = other325.lastAnalyzed;
+ catName = other325.catName;
+ __isset = other325.__isset;
+}
+ColumnStatisticsDesc& ColumnStatisticsDesc::operator=(const ColumnStatisticsDesc& other326) {
+ isTblLevel = other326.isTblLevel;
+ dbName = other326.dbName;
+ tableName = other326.tableName;
+ partName = other326.partName;
+ lastAnalyzed = other326.lastAnalyzed;
+ catName = other326.catName;
+ __isset = other326.__isset;
return *this;
}
void ColumnStatisticsDesc::printTo(std::ostream& out) const {
@@ -10031,7 +9881,7 @@ void ColumnStatistics::__set_validWriteIdList(const std::string& val) {
__isset.validWriteIdList = true;
}
-void ColumnStatistics::__set_isStatsCompliant(const IsolationLevelCompliance::type val) {
+void ColumnStatistics::__set_isStatsCompliant(const bool val) {
this->isStatsCompliant = val;
__isset.isStatsCompliant = true;
}
@@ -10071,14 +9921,14 @@ uint32_t ColumnStatistics::read(::apache::thrift::protocol::TProtocol* iprot) {
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->statsObj.clear();
- uint32_t _size330;
- ::apache::thrift::protocol::TType _etype333;
- xfer += iprot->readListBegin(_etype333, _size330);
- this->statsObj.resize(_size330);
- uint32_t _i334;
- for (_i334 = 0; _i334 < _size330; ++_i334)
+ uint32_t _size327;
+ ::apache::thrift::protocol::TType _etype330;
+ xfer += iprot->readListBegin(_etype330, _size327);
+ this->statsObj.resize(_size327);
+ uint32_t _i331;
+ for (_i331 = 0; _i331 < _size327; ++_i331)
{
- xfer += this->statsObj[_i334].read(iprot);
+ xfer += this->statsObj[_i331].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -10104,10 +9954,8 @@ uint32_t ColumnStatistics::read(::apache::thrift::protocol::TProtocol* iprot) {
}
break;
case 5:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast335;
- xfer += iprot->readI32(ecast335);
- this->isStatsCompliant = (IsolationLevelCompliance::type)ecast335;
+ if (ftype == ::apache::thrift::protocol::T_BOOL) {
+ xfer += iprot->readBool(this->isStatsCompliant);
this->__isset.isStatsCompliant = true;
} else {
xfer += iprot->skip(ftype);
@@ -10141,10 +9989,10 @@ uint32_t ColumnStatistics::write(::apache::thrift::protocol::TProtocol* oprot) c
xfer += oprot->writeFieldBegin("statsObj", ::apache::thrift::protocol::T_LIST, 2);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->statsObj.size()));
- std::vector<ColumnStatisticsObj> ::const_iterator _iter336;
- for (_iter336 = this->statsObj.begin(); _iter336 != this->statsObj.end(); ++_iter336)
+ std::vector<ColumnStatisticsObj> ::const_iterator _iter332;
+ for (_iter332 = this->statsObj.begin(); _iter332 != this->statsObj.end(); ++_iter332)
{
- xfer += (*_iter336).write(oprot);
+ xfer += (*_iter332).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -10161,8 +10009,8 @@ uint32_t ColumnStatistics::write(::apache::thrift::protocol::TProtocol* oprot) c
xfer += oprot->writeFieldEnd();
}
if (this->__isset.isStatsCompliant) {
- xfer += oprot->writeFieldBegin("isStatsCompliant", ::apache::thrift::protocol::T_I32, 5);
- xfer += oprot->writeI32((int32_t)this->isStatsCompliant);
+ xfer += oprot->writeFieldBegin("isStatsCompliant", ::apache::thrift::protocol::T_BOOL, 5);
+ xfer += oprot->writeBool(this->isStatsCompliant);
xfer += oprot->writeFieldEnd();
}
xfer += oprot->writeFieldStop();
@@ -10180,21 +10028,21 @@ void swap(ColumnStatistics &a, ColumnStatistics &b) {
swap(a.__isset, b.__isset);
}
-ColumnStatistics::ColumnStatistics(const ColumnStatistics& other337) {
- statsDesc = other337.statsDesc;
- statsObj = other337.statsObj;
- txnId = other337.txnId;
- validWriteIdList = other337.validWriteIdList;
- isStatsCompliant = other337.isStatsCompliant;
- __isset = other337.__isset;
-}
-ColumnStatistics& ColumnStatistics::operator=(const ColumnStatistics& other338) {
- statsDesc = other338.statsDesc;
- statsObj = other338.statsObj;
- txnId = other338.txnId;
- validWriteIdList = other338.validWriteIdList;
- isStatsCompliant = other338.isStatsCompliant;
- __isset = other338.__isset;
+ColumnStatistics::ColumnStatistics(const ColumnStatistics& other333) {
+ statsDesc = other333.statsDesc;
+ statsObj = other333.statsObj;
+ txnId = other333.txnId;
+ validWriteIdList = other333.validWriteIdList;
+ isStatsCompliant = other333.isStatsCompliant;
+ __isset = other333.__isset;
+}
+ColumnStatistics& ColumnStatistics::operator=(const ColumnStatistics& other334) {
+ statsDesc = other334.statsDesc;
+ statsObj = other334.statsObj;
+ txnId = other334.txnId;
+ validWriteIdList = other334.validWriteIdList;
+ isStatsCompliant = other334.isStatsCompliant;
+ __isset = other334.__isset;
return *this;
}
void ColumnStatistics::printTo(std::ostream& out) const {
@@ -10221,7 +10069,7 @@ void AggrStats::__set_partsFound(const int64_t val) {
this->partsFound = val;
}
-void AggrStats::__set_isStatsCompliant(const IsolationLevelCompliance::type val) {
+void AggrStats::__set_isStatsCompliant(const bool val) {
this->isStatsCompliant = val;
__isset.isStatsCompliant = true;
}
@@ -10253,14 +10101,14 @@ uint32_t AggrStats::read(::apache::thrift::protocol::TProtocol* iprot) {
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->colStats.clear();
- uint32_t _size339;
- ::apache::thrift::protocol::TType _etype342;
- xfer += iprot->readListBegin(_etype342, _size339);
- this->colStats.resize(_size339);
- uint32_t _i343;
- for (_i343 = 0; _i343 < _size339; ++_i343)
+ uint32_t _size335;
+ ::apache::thrift::protocol::TType _etype338;
+ xfer += iprot->readListBegin(_etype338, _size335);
+ this->colStats.resize(_size335);
+ uint32_t _i339;
+ for (_i339 = 0; _i339 < _size335; ++_i339)
{
- xfer += this->colStats[_i343].read(iprot);
+ xfer += this->colStats[_i339].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -10278,10 +10126,8 @@ uint32_t AggrStats::read(::apache::thrift::protocol::TProtocol* iprot) {
}
break;
case 3:
- if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast344;
- xfer += iprot->readI32(ecast344);
- this->isStatsCompliant = (IsolationLevelCompliance::type)ecast344;
+ if (ftype == ::apache::thrift::protocol::T_BOOL) {
+ xfer += iprot->readBool(this->isStatsCompliant);
this->__isset.isStatsCompliant = true;
} else {
xfer += iprot->skip(ftype);
@@ -10311,10 +10157,10 @@ uint32_t AggrStats::write(::apache::thrift::protocol::TProtocol* oprot) const {
xfer += oprot->writeFieldBegin("colStats", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->colStats.size()));
- std::vector<ColumnStatisticsObj> ::const_iterator _iter345;
- for (_iter345 = this->colStats.begin(); _iter345 != this->colStats.end(); ++_iter345)
+ std::vector<ColumnStatisticsObj> ::const_iterator _iter340;
+ for (_iter340 = this->colStats.begin(); _iter340 != this->colStats.end(); ++_iter340)
{
- xfer += (*_iter345).write(oprot);
+ xfer += (*_iter340).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -10325,8 +10171,8 @@ uint32_t AggrStats::write(::apache::thrift::protocol::TProtocol* oprot) const {
xfer += oprot->writeFieldEnd();
if (this->__isset.isStatsCompliant) {
- xfer += oprot->writeFieldBegin("isStatsCompliant", ::apache::thrift::protocol::T_I32, 3);
- xfer += oprot->writeI32((int32_t)this->isStatsCompliant);
+ xfer += oprot->writeFieldBegin("isStatsCompliant", ::apache::thrift::protocol::T_BOOL, 3);
+ xfer += oprot->writeBool(this->isStatsCompliant);
xfer += oprot->writeFieldEnd();
}
xfer += oprot->writeFieldStop();
@@ -10342,17 +10188,17 @@ void swap(AggrStats &a, AggrStats &b) {
swap(a.__isset, b.__isset);
}
-AggrStats::AggrStats(const AggrStats& other346) {
- colStats = other346.colStats;
- partsFound = other346.partsFound;
- isStatsCompliant = other346.isStatsCompliant;
- __isset = other346.__isset;
+AggrStats::AggrStats(const AggrStats& other341) {
+ colStats = other341.colStats;
+ partsFound = other341.partsFound;
+ isStatsCompliant = other341.isStatsCompliant;
+ __isset = other341.__isset;
}
-AggrStats& AggrStats::operator=(const AggrStats& other347) {
- colStats = other347.colStats;
- partsFound = other347.partsFound;
- isStatsCompliant = other347.isStatsCompliant;
- __isset = other347.__isset;
+AggrStats& AggrStats::operator=(const AggrStats& other342) {
+ colStats = other342.colStats;
+ partsFound = other342.partsFound;
+ isStatsCompliant = other342.isStatsCompliant;
+ __isset = other342.__isset;
return *this;
}
void AggrStats::printTo(std::ostream& out) const {
@@ -10419,14 +10265,14 @@ uint32_t SetPartitionsStatsRequest::read(::apache::thrift::protocol::TProtocol*
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->colStats.clear();
- uint32_t _size348;
- ::apache::thrift::protocol::TType _etype351;
- xfer += iprot->readListBegin(_etype351, _size348);
- this->colStats.resize(_size348);
- uint32_t _i352;
- for (_i352 = 0; _i352 < _size348; ++_i352)
+ uint32_t _size343;
+ ::apache::thrift::protocol::TType _etype346;
+ xfer += iprot->readListBegin(_etype346, _size343);
+ this->colStats.resize(_size343);
+ uint32_t _i347;
+ for (_i347 = 0; _i347 < _size343; ++_i347)
{
- xfer += this->colStats[_i352].read(iprot);
+ xfer += this->colStats[_i347].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -10489,10 +10335,10 @@ uint32_t SetPartitionsStatsRequest::write(::apache::thrift::protocol::TProtocol*
xfer += oprot->writeFieldBegin("colStats", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->colStats.size()));
- std::vector<ColumnStatistics> ::const_iterator _iter353;
- for (_iter353 = this->colStats.begin(); _iter353 != this->colStats.end(); ++_iter353)
+ std::vector<ColumnStatistics> ::const_iterator _iter348;
+ for (_iter348 = this->colStats.begin(); _iter348 != this->colStats.end(); ++_iter348)
{
- xfer += (*_iter353).write(oprot);
+ xfer += (*_iter348).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -10533,21 +10379,21 @@ void swap(SetPartitionsStatsRequest &a, SetPartitionsStatsRequest &b) {
swap(a.__isset, b.__isset);
}
-SetPartitionsStatsRequest::SetPartitionsStatsRequest(const SetPartitionsStatsRequest& other354) {
- colStats = other354.colStats;
- needMerge = other354.needMerge;
- txnId = other354.txnId;
- writeId = other354.writeId;
- validWriteIdList = other354.validWriteIdList;
- __isset = other354.__isset;
-}
-SetPartitionsStatsRequest& SetPartitionsStatsRequest::operator=(const SetPartitionsStatsRequest& other355) {
- colStats = other355.colStats;
- needMerge = other355.needMerge;
- txnId = other355.txnId;
- writeId = other355.writeId;
- validWriteIdList = other355.validWriteIdList;
- __isset = other355.__isset;
+SetPartitionsStatsRequest::SetPartitionsStatsRequest(const SetPartitionsStatsRequest& other349) {
+ colStats = other349.colStats;
+ needMerge = other349.needMerge;
+ txnId = other349.txnId;
+ writeId = other349.writeId;
+ validWriteIdList = other349.validWriteIdList;
+ __isset = other349.__isset;
+}
+SetPartitionsStatsRequest& SetPartitionsStatsRequest::operator=(const SetPartitionsStatsRequest& other350) {
+ colStats = other350.colStats;
+ needMerge = other350.needMerge;
+ txnId = other350.txnId;
+ writeId = other350.writeId;
+ validWriteIdList = other350.validWriteIdList;
+ __isset = other350.__isset;
return *this;
}
void SetPartitionsStatsRequest::printTo(std::ostream& out) const {
@@ -10599,14 +10445,14 @@ uint32_t Schema::read(::apache::thrift::protocol::TProtocol* iprot) {
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->fieldSchemas.clear();
- uint32_t _size356;
- ::apache::thrift::protocol::TType _etype359;
- xfer += iprot->readListBegin(_etype359, _size356);
- this->fieldSchemas.resize(_size356);
- uint32_t _i360;
- for (_i360 = 0; _i360 < _size356; ++_i360)
+ uint32_t _size351;
+ ::apache::thrift::protocol::TType _etype354;
+ xfer += iprot->readListBegin(_etype354, _size351);
+ this->fieldSchemas.resize(_size351);
+ uint32_t _i355;
+ for (_i355 = 0; _i355 < _size351; ++_i355)
{
- xfer += this->fieldSchemas[_i360].read(iprot);
+ xfer += this->fieldSchemas[_i355].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -10619,17 +10465,17 @@ uint32_t Schema::read(::apache::thrift::protocol::TProtocol* iprot) {
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->properties.clear();
- uint32_t _size361;
- ::apache::thrift::protocol::TType _ktype362;
- ::apache::thrift::protocol::TType _vtype363;
- xfer += iprot->readMapBegin(_ktype362, _vtype363, _size361);
- uint32_t _i365;
- for (_i365 = 0; _i365 < _size361; ++_i365)
+ uint32_t _size356;
+ ::apache::thrift::protocol::TType _ktype357;
+ ::apache::thrift::protocol::TType _vtype358;
+ xfer += iprot->readMapBegin(_ktype357, _vtype358, _size356);
+ uint32_t _i360;
+ for (_i360 = 0; _i360 < _size356; ++_i360)
{
- std::string _key366;
- xfer += iprot->readString(_key366);
- std::string& _val367 = this->properties[_key366];
- xfer += iprot->readString(_val367);
+ std::string _key361;
+ xfer += iprot->readString(_key361);
+ std::string& _val362 = this->properties[_key361];
+ xfer += iprot->readString(_val362);
}
xfer += iprot->readMapEnd();
}
@@ -10658,10 +10504,10 @@ uint32_t Schema::write(::apache::thrift::protocol::TProtocol* oprot) const {
xfer += oprot->writeFieldBegin("fieldSchemas", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->fieldSchemas.size()));
- std::vector<FieldSchema> ::const_iterator _iter368;
- for (_iter368 = this->fieldSchemas.begin(); _iter368 != this->fieldSchemas.end(); ++_iter368)
+ std::vector<FieldSchema> ::const_iterator _iter363;
+ for (_iter363 = this->fieldSchemas.begin(); _iter363 != this->fieldSchemas.end(); ++_iter363)
{
- xfer += (*_iter368).write(oprot);
+ xfer += (*_iter363).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -10670,11 +10516,11 @@ uint32_t Schema::write(::apache::thrift::protocol::TProtocol* oprot) const {
xfer += oprot->writeFieldBegin("properties", ::apache::thrift::protocol::T_MAP, 2);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->properties.size()));
- std::map<std::string, std::string> ::const_iterator _iter369;
- for (_iter369 = this->properties.begin(); _iter369 != this->properties.end(); ++_iter369)
+ std::map<std::string, std::string> ::const_iterator _iter364;
+ for (_iter364 = this->properties.begin(); _iter364 != this->properties.end(); ++_iter364)
{
- xfer += oprot->writeString(_iter369->first);
- xfer += oprot->writeString(_iter369->second);
+ xfer += oprot->writeString(_iter364->first);
+ xfer += oprot->writeString(_iter364->second);
}
xfer += oprot->writeMapEnd();
}
@@ -10692,15 +10538,15 @@ void swap(Schema &a, Schema &b) {
swap(a.__isset, b.__isset);
}
-Schema::Schema(const Schema& other370) {
- fieldSchemas = other370.fieldSchemas;
- properties = other370.properties;
- __isset = other370.__isset;
+Schema::Schema(const Schema& other365) {
+ fieldSchemas = other365.fieldSchemas;
+ properties = other365.properties;
+ __isset = other365.__isset;
}
-Schema& Schema::operator=(const Schema& other371) {
- fieldSchemas = other371.fieldSchemas;
- properties = other371.properties;
- __isset = other371.__isset;
+Schema& Schema::operator=(const Schema& other366) {
+ fieldSchemas = other366.fieldSchemas;
+ properties = other366.properties;
+ __isset = other366.__isset;
return *this;
}
void Schema::printTo(std::ostream& out) const {
@@ -10745,17 +10591,17 @@ uint32_t EnvironmentContext::read(::apache::thrift::protocol::TProtocol* iprot)
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->properties.clear();
- uint32_t _size372;
- ::apache::thrift::protocol::TType _ktype373;
- ::apache::thrift::protocol::TType _vtype374;
- xfer += iprot->readMapBegin(_ktype373, _vtype374, _size372);
- uint32_t _i376;
- for (_i376 = 0; _i376 < _size372; ++_i376)
+ uint32_t _size367;
+ ::apache::thrift::protocol::TType _ktype368;
+ ::apache::thrift::protocol::TType _vtype369;
+ xfer += iprot->readMapBegin(_ktype368, _vtype369, _size367);
+ uint32_t _i371;
+ for (_i371 = 0; _i371 < _size367; ++_i371)
{
- std::string _key377;
- xfer += iprot->readString(_key377);
- std::string& _val378 = this->properties[_key377];
- xfer += iprot->readString(_val378);
+ std::string _key372;
+ xfer += iprot->readString(_key372);
+ std::string& _val373 = this->properties[_key372];
+ xfer += iprot->readString(_val373);
}
xfer += iprot->readMapEnd();
}
@@ -10784,11 +10630,11 @@ uint32_t EnvironmentContext::write(::apache::thrift::protocol::TProtocol* oprot)
xfer += oprot->writeFieldBegin("properties", ::apache::thrift::protocol::T_MAP, 1);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->properties.size()));
- std::map<std::string, std::string> ::const_iterator _iter379;
- for (_iter379 = this->properties.begin(); _iter379 != this->properties.end(); ++_iter379)
+ std::map<std::string, std::string> ::const_iterator _iter374;
+ for (_iter374 = this->properties.begin(); _iter374 != this->properties.end(); ++_iter374)
{
- xfer += oprot->writeString(_iter379->first);
- xfer += oprot->writeString(_iter379->second);
+ xfer += oprot->writeString(_iter374->first);
+ xfer += oprot->writeString(_iter374->second);
}
xfer += oprot->writeMapEnd();
}
@@ -10805,13 +10651,13 @@ void swap(EnvironmentContext &a, EnvironmentContext &b) {
swap(a.__isset, b.__isset);
}
-EnvironmentContext::EnvironmentContext(const EnvironmentContext& other380) {
- properties = other380.properties;
- __isset = other380.__isset;
+EnvironmentContext::EnvironmentContext(const EnvironmentContext& other375) {
+ properties = other375.properties;
+ __isset = other375.__isset;
}
-EnvironmentContext& EnvironmentContext::operator=(const EnvironmentContext& other381) {
- properties = other381.properties;
- __isset = other381.__isset;
+EnvironmentContext& EnvironmentContext::operator=(const EnvironmentContext& other376) {
+ properties = other376.properties;
+ __isset = other376.__isset;
return *this;
}
void EnvironmentContext::printTo(std::ostream& out) const {
@@ -10933,17 +10779,17 @@ void swap(PrimaryKeysRequest &a, PrimaryKeysRequest &b) {
swap(a.__isset, b.__isset);
}
-PrimaryKeysRequest::PrimaryKeysRequest(const PrimaryKeysRequest& other382) {
- db_name = other382.db_name;
- tbl_name = other382.tbl_name;
- catName = other382.catName;
- __isset = other382.__isset;
+PrimaryKeysRequest::PrimaryKeysRequest(const PrimaryKeysRequest& other377) {
+ db_name = other377.db_name;
+ tbl_name = other377.tbl_name;
+ catName = other377.catName;
+ __isset = other377.__isset;
}
-PrimaryKeysRequest& PrimaryKeysRequest::operator=(const PrimaryKeysRequest& other383) {
- db_name = other383.db_name;
- tbl_name = other383.tbl_name;
- catName = other383.catName;
- __isset = other383.__isset;
+PrimaryKeysRequest& PrimaryKeysRequest::operator=(const PrimaryKeysRequest& other378) {
+ db_name = other378.db_name;
+ tbl_name = other378.tbl_name;
+ catName = other378.catName;
+ __isset = other378.__isset;
return *this;
}
void PrimaryKeysRequest::printTo(std::ostream& out) const {
@@ -10990,14 +10836,14 @@ uint32_t PrimaryKeysResponse::read(::apache::thrift::protocol::TProtocol* iprot)
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->primaryKeys.clear();
- uint32_t _size384;
- ::apache::thrift::protocol::TType _etype387;
- xfer += iprot->readListBegin(_etype387, _size384);
- this->primaryKeys.resize(_size384);
- uint32_t _i388;
- for (_i388 = 0; _i388 < _size384; ++_i388)
+ uint32_t _size379;
+ ::apache::thrift::protocol::TType _etype382;
+ xfer += iprot->readListBegin(_etype382, _size379);
+ this->primaryKeys.resize(_size379);
+ uint32_t _i383;
+ for (_i383 = 0; _i383 < _size379; ++_i383)
{
- xfer += this->primaryKeys[_i388].read(iprot);
+ xfer += this->primaryKeys[_i383].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -11028,10 +10874,10 @@ uint32_t PrimaryKeysResponse::write(::apache::thrift::protocol::TProtocol* oprot
xfer += oprot->writeFieldBegin("primaryKeys", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->primaryKeys.size()));
- std::vector<SQLPrimaryKey> ::const_iterator _iter389;
- for (_iter389 = this->primaryKeys.begin(); _iter389 != this->primaryKeys.end(); ++_iter389)
+ std::vector<SQLPrimaryKey> ::const_iterator _iter384;
+ for (_iter384 = this->primaryKeys.begin(); _iter384 != this->primaryKeys.end(); ++_iter384)
{
- xfer += (*_iter389).write(oprot);
+ xfer += (*_iter384).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -11047,11 +10893,11 @@ void swap(PrimaryKeysResponse &a, PrimaryKeysResponse &b) {
swap(a.primaryKeys, b.primaryKeys);
}
-PrimaryKeysResponse::PrimaryKeysResponse(const PrimaryKeysResponse& other390) {
- primaryKeys = other390.primaryKeys;
+PrimaryKeysResponse::PrimaryKeysResponse(const PrimaryKeysResponse& other385) {
+ primaryKeys = other385.primaryKeys;
}
-PrimaryKeysResponse& PrimaryKeysResponse::operator=(const PrimaryKeysResponse& other391) {
- primaryKeys = other391.primaryKeys;
+PrimaryKeysResponse& PrimaryKeysResponse::operator=(const PrimaryKeysResponse& other386) {
+ primaryKeys = other386.primaryKeys;
return *this;
}
void PrimaryKeysResponse::printTo(std::ostream& out) const {
@@ -11201,21 +11047,21 @@ void swap(ForeignKeysRequest &a, ForeignKeysRequest &b) {
swap(a.__isset, b.__isset);
}
-ForeignKeysRequest::ForeignKeysRequest(const ForeignKeysRequest& other392) {
- parent_db_name = other392.parent_db_name;
- parent_tbl_name = other392.parent_tbl_name;
- foreign_db_name = other392.foreign_db_name;
- foreign_tbl_name = other392.foreign_tbl_name;
- catName = other392.catName;
- __isset = other392.__isset;
-}
-ForeignKeysRequest& ForeignKeysRequest::operator=(const ForeignKeysRequest& other393) {
- parent_db_name = other393.parent_db_name;
- parent_tbl_name = other393.parent_tbl_name;
- foreign_db_name = other393.foreign_db_name;
- foreign_tbl_name = other393.foreign_tbl_name;
- catName = other393.catName;
- __isset = other393.__isset;
+ForeignKeysRequest::ForeignKeysRequest(const ForeignKeysRequest& other387) {
+ parent_db_name = other387.parent_db_name;
+ parent_tbl_name = other387.parent_tbl_name;
+ foreign_db_name = other387.foreign_db_name;
+ foreign_tbl_name = other387.foreign_tbl_name;
+ catName = other387.catName;
+ __isset = other387.__isset;
+}
+ForeignKeysRequest& ForeignKeysRequest::operator=(const ForeignKeysRequest& other388) {
+ parent_db_name = other388.parent_db_name;
+ parent_tbl_name = other388.parent_tbl_name;
+ foreign_db_name = other388.foreign_db_name;
+ foreign_tbl_name = other388.foreign_tbl_name;
+ catName = other388.catName;
+ __isset = other388.__isset;
return *this;
}
void ForeignKeysRequest::printTo(std::ostream& out) const {
@@ -11264,14 +11110,14 @@ uint32_t ForeignKeysResponse::read(::apache::thrift::protocol::TProtocol* iprot)
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->foreignKeys.clear();
- uint32_t _size394;
- ::apache::thrift::protocol::TType _etype397;
- xfer += iprot->readListBegin(_etype397, _size394);
- this->foreignKeys.resize(_size394);
- uint32_t _i398;
- for (_i398 = 0; _i398 < _size394; ++_i398)
+ uint32_t _size389;
+ ::apache::thrift::protocol::TType _etype392;
+ xfer += iprot->readListBegin(_etype392, _size389);
+ this->foreignKeys.resize(_size389);
+ uint32_t _i393;
+ for (_i393 = 0; _i393 < _size389; ++_i393)
{
- xfer += this->foreignKeys[_i398].read(iprot);
+ xfer += this->foreignKeys[_i393].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -11302,10 +11148,10 @@ uint32_t ForeignKeysResponse::write(::apache::thrift::protocol::TProtocol* oprot
xfer += oprot->writeFieldBegin("foreignKeys", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->foreignKeys.size()));
- std::vector<SQLForeignKey> ::const_iterator _iter399;
- for (_iter399 = this->foreignKeys.begin(); _iter399 != this->foreignKeys.end(); ++_iter399)
+ std::vector<SQLForeignKey> ::const_iterator _iter394;
+ for (_iter394 = this->foreignKeys.begin(); _iter394 != this->foreignKeys.end(); ++_iter394)
{
- xfer += (*_iter399).write(oprot);
+ xfer += (*_iter394).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -11321,11 +11167,11 @@ void swap(ForeignKeysResponse &a, ForeignKeysResponse &b) {
swap(a.foreignKeys, b.foreignKeys);
}
-ForeignKeysResponse::ForeignKeysResponse(const ForeignKeysResponse& other400) {
- foreignKeys = other400.foreignKeys;
+ForeignKeysResponse::ForeignKeysResponse(const ForeignKeysResponse& other395) {
+ foreignKeys = other395.foreignKeys;
}
-ForeignKeysResponse& ForeignKeysResponse::operator=(const ForeignKeysResponse& other401) {
- foreignKeys = other401.foreignKeys;
+ForeignKeysResponse& ForeignKeysResponse::operator=(const ForeignKeysResponse& other396) {
+ foreignKeys = other396.foreignKeys;
return *this;
}
void ForeignKeysResponse::printTo(std::ostream& out) const {
@@ -11447,15 +11293,15 @@ void swap(UniqueConstraintsRequest &a, UniqueConstraintsRequest &b) {
swap(a.tbl_name, b.tbl_name);
}
-UniqueConstraintsRequest::UniqueConstraintsRequest(const UniqueConstraintsRequest& other402) {
- catName = other402.catName;
- db_name = other402.db_name;
- tbl_name = other402.tbl_name;
+UniqueConstraintsRequest::UniqueConstraintsRequest(const UniqueConstraintsRequest& other397) {
+ catName = other397.catName;
+ db_name = other397.db_name;
+ tbl_name = other397.tbl_name;
}
-UniqueConstraintsRequest& UniqueConstraintsRequest::operator=(const UniqueConstraintsRequest& other403) {
- catName = other403.catName;
- db_name = other403.db_name;
- tbl_name = other403.tbl_name;
+UniqueConstraintsRequest& UniqueConstraintsRequest::operator=(const UniqueConstraintsRequest& other398) {
+ catName = other398.catName;
+ db_name = other398.db_name;
+ tbl_name = other398.tbl_name;
return *this;
}
void UniqueConstraintsRequest::printTo(std::ostream& out) const {
@@ -11502,14 +11348,14 @@ uint32_t UniqueConstraintsResponse::read(::apache::thrift::protocol::TProtocol*
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->uniqueConstraints.clear();
- uint32_t _size404;
- ::apache::thrift::protocol::TType _etype407;
- xfer += iprot->readListBegin(_etype407, _size404);
- this->uniqueConstraints.resize(_size404);
- uint32_t _i408;
- for (_i408 = 0; _i408 < _size404; ++_i408)
+ uint32_t _size399;
+ ::apache::thrift::protocol::TType _etype402;
+ xfer += iprot->readListBegin(_etype402, _size399);
+ this->uniqueConstraints.resize(_size399);
+ uint32_t _i403;
+ for (_i403 = 0; _i403 < _size399; ++_i403)
{
- xfer += this->uniqueConstraints[_i408].read(iprot);
+ xfer += this->uniqueConstraints[_i403].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -11540,10 +11386,10 @@ uint32_t UniqueConstraintsResponse::write(::apache::thrift::protocol::TProtocol*
xfer += oprot->writeFieldBegin("uniqueConstraints", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->uniqueConstraints.size()));
- std::vector<SQLUniqueConstraint> ::const_iterator _iter409;
- for (_iter409 = this->uniqueConstraints.begin(); _iter409 != this->uniqueConstraints.end(); ++_iter409)
+ std::vector<SQLUniqueConstraint> ::const_iterator _iter404;
+ for (_iter404 = this->uniqueConstraints.begin(); _iter404 != this->uniqueConstraints.end(); ++_iter404)
{
- xfer += (*_iter409).write(oprot);
+ xfer += (*_iter404).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -11559,11 +11405,11 @@ void swap(UniqueConstraintsResponse &a, UniqueConstraintsResponse &b) {
swap(a.uniqueConstraints, b.uniqueConstraints);
}
-UniqueConstraintsResponse::UniqueConstraintsResponse(const UniqueConstraintsResponse& other410) {
- uniqueConstraints = other410.uniqueConstraints;
+UniqueConstraintsResponse::UniqueConstraintsResponse(const UniqueConstraintsResponse& other405) {
+ uniqueConstraints = other405.uniqueConstraints;
}
-UniqueConstraintsResponse& UniqueConstraintsResponse::operator=(const UniqueConstraintsResponse& other411) {
- uniqueConstraints = other411.uniqueConstraints;
+UniqueConstraintsResponse& UniqueConstraintsResponse::operator=(const UniqueConstraintsResponse& other406) {
+ uniqueConstraints = other406.uniqueConstraints;
return *this;
}
void UniqueConstraintsResponse::printTo(std::ostream& out) const {
@@ -11685,15 +11531,15 @@ void swap(NotNullConstraintsRequest &a, NotNullConstraintsRequest &b) {
swap(a.tbl_name, b.tbl_name);
}
-NotNullConstraintsRequest::NotNullConstraintsRequest(const NotNullConstraintsRequest& other412) {
- catName = other412.catName;
- db_name = other412.db_name;
- tbl_name = other412.tbl_name;
+NotNullConstraintsRequest::NotNullConstraintsRequest(const NotNullConstraintsRequest& other407) {
+ catName = other407.catName;
+ db_name = other407.db_name;
+ tbl_name = other407.tbl_name;
}
-NotNullConstraintsRequest& NotNullConstraintsRequest::operator=(const NotNullConstraintsRequest& other413) {
- catName = other413.catName;
- db_name = other413.db_name;
- tbl_name = other413.tbl_name;
+NotNullConstraintsRequest& NotNullConstraintsRequest::operator=(const NotNullConstraintsRequest& other408) {
+ catName = other408.catName;
+ db_name = other408.db_name;
+ tbl_name = other408.tbl_name;
return *this;
}
void NotNullConstraintsRequest::printTo(std::ostream& out) const {
@@ -11740,14 +11586,14 @@ uint32_t NotNullConstraintsResponse::read(::apache::thrift::protocol::TProtocol*
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->notNullConstraints.clear();
- uint32_t _size414;
- ::apache::thrift::protocol::TType _etype417;
- xfer += iprot->readListBegin(_etype417, _size414);
- this->notNullConstraints.resize(_size414);
- uint32_t _i418;
- for (_i418 = 0; _i418 < _size414; ++_i418)
+ uint32_t _size409;
+ ::apache::thrift::protocol::TType _etype412;
+ xfer += iprot->readListBegin(_etype412, _size409);
+ this->notNullConstraints.resize(_size409);
+ uint32_t _i413;
+ for (_i413 = 0; _i413 < _size409; ++_i413)
{
- xfer += this->notNullConstraints[_i418].read(iprot);
+ xfer += this->notNullConstraints[_i413].read(iprot);
}
xfer += iprot->readListEnd();
}
@@ -11778,10 +11624,10 @@ uint32_t NotNullConstraintsResponse::write(::apache::thrift::protocol::TProtocol
xfer += oprot->writeFieldBegin("notNullConstraints", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->notNullConstraints.size()));
- std::vector<SQLNotNullConstraint> ::const_iterator _iter419;
- for (_iter419 = this->notNullConstraints.begin(); _iter419 != this->notNullConstraints.end(); ++_iter419)
+ std::vector<SQLNotNullConstraint> ::const_iterator _iter414;
+ for (_iter414 = this->notNullConstraints.begin(); _iter414 != this->notNullConstraints.end(); ++_iter414)
{
- xfer += (*_iter419).write(oprot);
+ xfer += (*_iter414).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -11797,11 +11643,11 @@ void swap(NotNullConstraintsResponse &a, NotNullConstraintsResponse &b) {
swap(a.notNullConstraints, b.notNullConstraints);
}
-NotNullConstraintsResponse::NotNullConstraintsResponse(const NotNullConstraintsResponse& other420) {
- notNullConstraints = other420.notNullConstraints;
+NotNullConstraintsResponse::NotNullConstraintsResponse(const NotNullConstraintsResponse& other415) {
+ notNullConstraints = other415.notNullConstraints;
}
-NotNullConstraintsResponse& NotNullConstraintsResponse::operator=(const NotNullConstraintsResponse& other421) {
- notNullConstraints = other421.notNullConstraints;
+NotNullConstraintsResponse& NotNullConstraintsResponse::operator=(const NotNullConstraintsResponse& other416) {
+ notNullConstraints = other416.notNullConstraints;
return *this;
}
void NotNullConstraintsResponse::printTo(std::ostream& out) const {
@@ -11923,15 +11769,15 @@ void swap(DefaultConstraintsRequest &a, DefaultConstraintsRequest &b) {
swap(a.tbl_name, b.tbl_name);
}
-DefaultConstraintsRequest::DefaultConstraintsRequest(const DefaultConstraintsRequest& other422) {
- catName = other422.catName;
- db_name = other422.db_name;
- tbl_name = other422.tbl_name;
+DefaultConstraintsRequest::DefaultConstraintsRequest(const DefaultConstraintsRequest& other417) {
+ catName = other417.catName;
+ db_name = other417.db_name;
+ tbl_name = other417.tbl_name;
}
-DefaultConstraintsRequest& DefaultConstraintsRequest::operator=(const DefaultConstraintsRequest& other423) {
- catName = other423.catName;
- db_name = other423.db_name;
- tbl_name = other423.tbl_name;
+DefaultConstraintsRequest& DefaultConstraintsRequest::operator=(const DefaultConstraintsRequest& other418) {
+ catName = other418.catName;
+ db_name = other418.db_name;
+ tbl_name = other418.tbl_name;
return *this;
}
void DefaultConstraintsRequest::printTo(std::ostream& out) const {
@@ -11978,14 +11824,14 @@ uint32_t DefaultConstraintsResponse::read(::apache::thrift::protocol::TProtocol*
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->defaultConstraints.clear();
- uint32_t _size424;
- ::apache::thrift::protocol::TType _etype427;
- xfer += iprot->readListBegin(_etype427, _size424);
- this->defaultConstraints.resize(_size424);
<TRUNCATED>