diff --git metastore/if/hive_metastore.thrift metastore/if/hive_metastore.thrift index 55f41db..baff894 100755 --- metastore/if/hive_metastore.thrift +++ metastore/if/hive_metastore.thrift @@ -595,12 +595,12 @@ struct ShowCompactRequest { struct ShowCompactResponseElement { 1: required string dbname, 2: required string tablename, - 3: required string partitionname, + 3: optional string partitionname, 4: required CompactionType type, 5: required string state, - 6: required string workerid, - 7: required i64 start, - 8: required string runAs, + 6: optional string workerid, + 7: optional i64 start, + 8: optional string runAs, } struct ShowCompactResponse { diff --git metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp index a6a40fd..2c71c44 100644 --- metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp +++ metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp @@ -8378,8 +8378,8 @@ void swap(ShowCompactRequest &a, ShowCompactRequest &b) { (void) b; } -const char* ShowCompactResponseElement::ascii_fingerprint = "42464F3A97707F984FDE462104223A69"; -const uint8_t ShowCompactResponseElement::binary_fingerprint[16] = {0x42,0x46,0x4F,0x3A,0x97,0x70,0x7F,0x98,0x4F,0xDE,0x46,0x21,0x04,0x22,0x3A,0x69}; +const char* ShowCompactResponseElement::ascii_fingerprint = "2F338C265DC4FD82DD13F4966FE43F13"; +const uint8_t ShowCompactResponseElement::binary_fingerprint[16] = {0x2F,0x33,0x8C,0x26,0x5D,0xC4,0xFD,0x82,0xDD,0x13,0xF4,0x96,0x6F,0xE4,0x3F,0x13}; uint32_t ShowCompactResponseElement::read(::apache::thrift::protocol::TProtocol* iprot) { @@ -8394,12 +8394,8 @@ uint32_t ShowCompactResponseElement::read(::apache::thrift::protocol::TProtocol* bool isset_dbname = false; bool isset_tablename = false; - bool isset_partitionname = false; bool isset_type = false; bool isset_state = false; - bool isset_workerid = false; - bool isset_start = false; - bool isset_runAs = false; while (true) { @@ -8428,7 +8424,7 @@ uint32_t ShowCompactResponseElement::read(::apache::thrift::protocol::TProtocol* case 3: if (ftype == ::apache::thrift::protocol::T_STRING) { xfer += iprot->readString(this->partitionname); - isset_partitionname = true; + this->__isset.partitionname = true; } else { xfer += iprot->skip(ftype); } @@ -8454,7 +8450,7 @@ uint32_t ShowCompactResponseElement::read(::apache::thrift::protocol::TProtocol* case 6: if (ftype == ::apache::thrift::protocol::T_STRING) { xfer += iprot->readString(this->workerid); - isset_workerid = true; + this->__isset.workerid = true; } else { xfer += iprot->skip(ftype); } @@ -8462,7 +8458,7 @@ uint32_t ShowCompactResponseElement::read(::apache::thrift::protocol::TProtocol* case 7: if (ftype == ::apache::thrift::protocol::T_I64) { xfer += iprot->readI64(this->start); - isset_start = true; + this->__isset.start = true; } else { xfer += iprot->skip(ftype); } @@ -8470,7 +8466,7 @@ uint32_t ShowCompactResponseElement::read(::apache::thrift::protocol::TProtocol* case 8: if (ftype == ::apache::thrift::protocol::T_STRING) { xfer += iprot->readString(this->runAs); - isset_runAs = true; + this->__isset.runAs = true; } else { xfer += iprot->skip(ftype); } @@ -8488,18 +8484,10 @@ uint32_t ShowCompactResponseElement::read(::apache::thrift::protocol::TProtocol* throw TProtocolException(TProtocolException::INVALID_DATA); if (!isset_tablename) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_partitionname) - throw TProtocolException(TProtocolException::INVALID_DATA); if (!isset_type) throw TProtocolException(TProtocolException::INVALID_DATA); if (!isset_state) throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_workerid) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_start) - throw TProtocolException(TProtocolException::INVALID_DATA); - if (!isset_runAs) - throw TProtocolException(TProtocolException::INVALID_DATA); return xfer; } @@ -8515,10 +8503,11 @@ uint32_t ShowCompactResponseElement::write(::apache::thrift::protocol::TProtocol xfer += oprot->writeString(this->tablename); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("partitionname", ::apache::thrift::protocol::T_STRING, 3); - xfer += oprot->writeString(this->partitionname); - xfer += oprot->writeFieldEnd(); - + if (this->__isset.partitionname) { + xfer += oprot->writeFieldBegin("partitionname", ::apache::thrift::protocol::T_STRING, 3); + xfer += oprot->writeString(this->partitionname); + xfer += oprot->writeFieldEnd(); + } xfer += oprot->writeFieldBegin("type", ::apache::thrift::protocol::T_I32, 4); xfer += oprot->writeI32((int32_t)this->type); xfer += oprot->writeFieldEnd(); @@ -8527,18 +8516,21 @@ uint32_t ShowCompactResponseElement::write(::apache::thrift::protocol::TProtocol xfer += oprot->writeString(this->state); xfer += oprot->writeFieldEnd(); - xfer += oprot->writeFieldBegin("workerid", ::apache::thrift::protocol::T_STRING, 6); - xfer += oprot->writeString(this->workerid); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("start", ::apache::thrift::protocol::T_I64, 7); - xfer += oprot->writeI64(this->start); - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("runAs", ::apache::thrift::protocol::T_STRING, 8); - xfer += oprot->writeString(this->runAs); - xfer += oprot->writeFieldEnd(); - + if (this->__isset.workerid) { + xfer += oprot->writeFieldBegin("workerid", ::apache::thrift::protocol::T_STRING, 6); + xfer += oprot->writeString(this->workerid); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.start) { + xfer += oprot->writeFieldBegin("start", ::apache::thrift::protocol::T_I64, 7); + xfer += oprot->writeI64(this->start); + xfer += oprot->writeFieldEnd(); + } + if (this->__isset.runAs) { + xfer += oprot->writeFieldBegin("runAs", ::apache::thrift::protocol::T_STRING, 8); + xfer += oprot->writeString(this->runAs); + xfer += oprot->writeFieldEnd(); + } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; @@ -8554,10 +8546,11 @@ void swap(ShowCompactResponseElement &a, ShowCompactResponseElement &b) { swap(a.workerid, b.workerid); swap(a.start, b.start); swap(a.runAs, b.runAs); + swap(a.__isset, b.__isset); } -const char* ShowCompactResponse::ascii_fingerprint = "3CCBC4D398CA25527272FE78625DE88A"; -const uint8_t ShowCompactResponse::binary_fingerprint[16] = {0x3C,0xCB,0xC4,0xD3,0x98,0xCA,0x25,0x52,0x72,0x72,0xFE,0x78,0x62,0x5D,0xE8,0x8A}; +const char* ShowCompactResponse::ascii_fingerprint = "915B7B8DB8966D65769C0F98707BBAE3"; +const uint8_t ShowCompactResponse::binary_fingerprint[16] = {0x91,0x5B,0x7B,0x8D,0xB8,0x96,0x6D,0x65,0x76,0x9C,0x0F,0x98,0x70,0x7B,0xBA,0xE3}; uint32_t ShowCompactResponse::read(::apache::thrift::protocol::TProtocol* iprot) { diff --git metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h index f352cd5..705632e 100644 --- metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h +++ metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h @@ -4592,12 +4592,19 @@ class ShowCompactRequest { void swap(ShowCompactRequest &a, ShowCompactRequest &b); +typedef struct _ShowCompactResponseElement__isset { + _ShowCompactResponseElement__isset() : partitionname(false), workerid(false), start(false), runAs(false) {} + bool partitionname; + bool workerid; + bool start; + bool runAs; +} _ShowCompactResponseElement__isset; class ShowCompactResponseElement { public: - static const char* ascii_fingerprint; // = "42464F3A97707F984FDE462104223A69"; - static const uint8_t binary_fingerprint[16]; // = {0x42,0x46,0x4F,0x3A,0x97,0x70,0x7F,0x98,0x4F,0xDE,0x46,0x21,0x04,0x22,0x3A,0x69}; + static const char* ascii_fingerprint; // = "2F338C265DC4FD82DD13F4966FE43F13"; + static const uint8_t binary_fingerprint[16]; // = {0x2F,0x33,0x8C,0x26,0x5D,0xC4,0xFD,0x82,0xDD,0x13,0xF4,0x96,0x6F,0xE4,0x3F,0x13}; ShowCompactResponseElement() : dbname(), tablename(), partitionname(), type((CompactionType::type)0), state(), workerid(), start(0), runAs() { } @@ -4613,6 +4620,8 @@ class ShowCompactResponseElement { int64_t start; std::string runAs; + _ShowCompactResponseElement__isset __isset; + void __set_dbname(const std::string& val) { dbname = val; } @@ -4623,6 +4632,7 @@ class ShowCompactResponseElement { void __set_partitionname(const std::string& val) { partitionname = val; + __isset.partitionname = true; } void __set_type(const CompactionType::type val) { @@ -4635,14 +4645,17 @@ class ShowCompactResponseElement { void __set_workerid(const std::string& val) { workerid = val; + __isset.workerid = true; } void __set_start(const int64_t val) { start = val; + __isset.start = true; } void __set_runAs(const std::string& val) { runAs = val; + __isset.runAs = true; } bool operator == (const ShowCompactResponseElement & rhs) const @@ -4651,17 +4664,25 @@ class ShowCompactResponseElement { return false; if (!(tablename == rhs.tablename)) return false; - if (!(partitionname == rhs.partitionname)) + if (__isset.partitionname != rhs.__isset.partitionname) + return false; + else if (__isset.partitionname && !(partitionname == rhs.partitionname)) return false; if (!(type == rhs.type)) return false; if (!(state == rhs.state)) return false; - if (!(workerid == rhs.workerid)) + if (__isset.workerid != rhs.__isset.workerid) + return false; + else if (__isset.workerid && !(workerid == rhs.workerid)) + return false; + if (__isset.start != rhs.__isset.start) + return false; + else if (__isset.start && !(start == rhs.start)) return false; - if (!(start == rhs.start)) + if (__isset.runAs != rhs.__isset.runAs) return false; - if (!(runAs == rhs.runAs)) + else if (__isset.runAs && !(runAs == rhs.runAs)) return false; return true; } @@ -4682,8 +4703,8 @@ void swap(ShowCompactResponseElement &a, ShowCompactResponseElement &b); class ShowCompactResponse { public: - static const char* ascii_fingerprint; // = "3CCBC4D398CA25527272FE78625DE88A"; - static const uint8_t binary_fingerprint[16]; // = {0x3C,0xCB,0xC4,0xD3,0x98,0xCA,0x25,0x52,0x72,0x72,0xFE,0x78,0x62,0x5D,0xE8,0x8A}; + static const char* ascii_fingerprint; // = "915B7B8DB8966D65769C0F98707BBAE3"; + static const uint8_t binary_fingerprint[16]; // = {0x91,0x5B,0x7B,0x8D,0xB8,0x96,0x6D,0x65,0x76,0x9C,0x0F,0x98,0x70,0x7B,0xBA,0xE3}; ShowCompactResponse() { } diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java index 4547970..791c46b 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java @@ -704,7 +704,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, AddPartitionsReques struct.parts = new ArrayList(_list338.size); for (int _i339 = 0; _i339 < _list338.size; ++_i339) { - Partition _elem340; // optional + Partition _elem340; // required _elem340 = new Partition(); _elem340.read(iprot); struct.parts.add(_elem340); @@ -824,7 +824,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, AddPartitionsRequest struct.parts = new ArrayList(_list343.size); for (int _i344 = 0; _i344 < _list343.size; ++_i344) { - Partition _elem345; // optional + Partition _elem345; // required _elem345 = new Partition(); _elem345.read(iprot); struct.parts.add(_elem345); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java index 68a4219..2471690 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java @@ -346,7 +346,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, AddPartitionsResult struct.partitions = new ArrayList(_list330.size); for (int _i331 = 0; _i331 < _list330.size; ++_i331) { - Partition _elem332; // optional + Partition _elem332; // required _elem332 = new Partition(); _elem332.read(iprot); struct.partitions.add(_elem332); @@ -428,7 +428,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, AddPartitionsResult struct.partitions = new ArrayList(_list335.size); for (int _i336 = 0; _i336 < _list335.size; ++_i336) { - Partition _elem337; // optional + Partition _elem337; // required _elem337 = new Partition(); _elem337.read(iprot); struct.partitions.add(_elem337); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java index 6aecf26..aa647d4 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java @@ -451,7 +451,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, ColumnStatistics st struct.statsObj = new ArrayList(_list236.size); for (int _i237 = 0; _i237 < _list236.size; ++_i237) { - ColumnStatisticsObj _elem238; // optional + ColumnStatisticsObj _elem238; // required _elem238 = new ColumnStatisticsObj(); _elem238.read(iprot); struct.statsObj.add(_elem238); @@ -531,7 +531,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, ColumnStatistics str struct.statsObj = new ArrayList(_list241.size); for (int _i242 = 0; _i242 < _list241.size; ++_i242) { - ColumnStatisticsObj _elem243; // optional + ColumnStatisticsObj _elem243; // required _elem243 = new ColumnStatisticsObj(); _elem243.read(iprot); struct.statsObj.add(_elem243); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DropPartitionsResult.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DropPartitionsResult.java index a4ae892..b8d5a56 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DropPartitionsResult.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DropPartitionsResult.java @@ -346,7 +346,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, DropPartitionsResul struct.partitions = new ArrayList(_list346.size); for (int _i347 = 0; _i347 < _list346.size; ++_i347) { - Partition _elem348; // optional + Partition _elem348; // required _elem348 = new Partition(); _elem348.read(iprot); struct.partitions.add(_elem348); @@ -428,7 +428,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, DropPartitionsResult struct.partitions = new ArrayList(_list351.size); for (int _i352 = 0; _i352 < _list351.size; ++_i352) { - Partition _elem353; // optional + Partition _elem353; // required _elem353 = new Partition(); _elem353.read(iprot); struct.partitions.add(_elem353); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java index 781281a..4a24bbf 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java @@ -997,7 +997,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, Function struct) th struct.resourceUris = new ArrayList(_list370.size); for (int _i371 = 0; _i371 < _list370.size; ++_i371) { - ResourceUri _elem372; // optional + ResourceUri _elem372; // required _elem372 = new ResourceUri(); _elem372.read(iprot); struct.resourceUris.add(_elem372); @@ -1180,7 +1180,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, Function struct) thr struct.resourceUris = new ArrayList(_list375.size); for (int _i376 = 0; _i376 < _list375.size; ++_i376) { - ResourceUri _elem377; // optional + ResourceUri _elem377; // required _elem377 = new ResourceUri(); _elem377.read(iprot); struct.resourceUris.add(_elem377); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java index b782d32..427204e 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java @@ -447,7 +447,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, GetOpenTxnsInfoResp struct.open_txns = new ArrayList(_list378.size); for (int _i379 = 0; _i379 < _list378.size; ++_i379) { - TxnInfo _elem380; // optional + TxnInfo _elem380; // required _elem380 = new TxnInfo(); _elem380.read(iprot); struct.open_txns.add(_elem380); @@ -524,7 +524,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, GetOpenTxnsInfoRespo struct.open_txns = new ArrayList(_list383.size); for (int _i384 = 0; _i384 < _list383.size; ++_i384) { - TxnInfo _elem385; // optional + TxnInfo _elem385; // required _elem385 = new TxnInfo(); _elem385.read(iprot); struct.open_txns.add(_elem385); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java index d549ce9..eda18ad 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java @@ -447,7 +447,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, GetOpenTxnsResponse struct.open_txns = new HashSet(2*_set386.size); for (int _i387 = 0; _i387 < _set386.size; ++_i387) { - long _elem388; // optional + long _elem388; // required _elem388 = iprot.readI64(); struct.open_txns.add(_elem388); } @@ -523,7 +523,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, GetOpenTxnsResponse struct.open_txns = new HashSet(2*_set391.size); for (int _i392 = 0; _i392 < _set391.size; ++_i392) { - long _elem393; // optional + long _elem393; // required _elem393 = iprot.readI64(); struct.open_txns.add(_elem393); } diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleResponse.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleResponse.java index 3ef6224..083699b 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleResponse.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleResponse.java @@ -354,7 +354,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, GetPrincipalsInRole struct.principalGrants = new ArrayList(_list86.size); for (int _i87 = 0; _i87 < _list86.size; ++_i87) { - RolePrincipalGrant _elem88; // optional + RolePrincipalGrant _elem88; // required _elem88 = new RolePrincipalGrant(); _elem88.read(iprot); struct.principalGrants.add(_elem88); @@ -425,7 +425,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, GetPrincipalsInRoleR struct.principalGrants = new ArrayList(_list91.size); for (int _i92 = 0; _i92 < _list91.size; ++_i92) { - RolePrincipalGrant _elem93; // optional + RolePrincipalGrant _elem93; // required _elem93 = new RolePrincipalGrant(); _elem93.read(iprot); struct.principalGrants.add(_elem93); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalResponse.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalResponse.java index 3ddc1ac..f745c08 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalResponse.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalResponse.java @@ -354,7 +354,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, GetRoleGrantsForPri struct.principalGrants = new ArrayList(_list78.size); for (int _i79 = 0; _i79 < _list78.size; ++_i79) { - RolePrincipalGrant _elem80; // optional + RolePrincipalGrant _elem80; // required _elem80 = new RolePrincipalGrant(); _elem80.read(iprot); struct.principalGrants.add(_elem80); @@ -425,7 +425,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, GetRoleGrantsForPrin struct.principalGrants = new ArrayList(_list83.size); for (int _i84 = 0; _i84 < _list83.size; ++_i84) { - RolePrincipalGrant _elem85; // optional + RolePrincipalGrant _elem85; // required _elem85 = new RolePrincipalGrant(); _elem85.read(iprot); struct.principalGrants.add(_elem85); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java index f3e3c07..0fc4310 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java @@ -459,7 +459,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, HeartbeatTxnRangeRe struct.aborted = new HashSet(2*_set418.size); for (int _i419 = 0; _i419 < _set418.size; ++_i419) { - long _elem420; // optional + long _elem420; // required _elem420 = iprot.readI64(); struct.aborted.add(_elem420); } @@ -477,7 +477,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, HeartbeatTxnRangeRe struct.nosuch = new HashSet(2*_set421.size); for (int _i422 = 0; _i422 < _set421.size; ++_i422) { - long _elem423; // optional + long _elem423; // required _elem423 = iprot.readI64(); struct.nosuch.add(_elem423); } @@ -566,7 +566,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, HeartbeatTxnRangeRes struct.aborted = new HashSet(2*_set428.size); for (int _i429 = 0; _i429 < _set428.size; ++_i429) { - long _elem430; // optional + long _elem430; // required _elem430 = iprot.readI64(); struct.aborted.add(_elem430); } @@ -577,7 +577,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, HeartbeatTxnRangeRes struct.nosuch = new HashSet(2*_set431.size); for (int _i432 = 0; _i432 < _set431.size; ++_i432) { - long _elem433; // optional + long _elem433; // required _elem433 = iprot.readI64(); struct.nosuch.add(_elem433); } diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HiveObjectRef.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HiveObjectRef.java index b22b211..997060f 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HiveObjectRef.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HiveObjectRef.java @@ -710,7 +710,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, HiveObjectRef struc struct.partValues = new ArrayList(_list8.size); for (int _i9 = 0; _i9 < _list8.size; ++_i9) { - String _elem10; // optional + String _elem10; // required _elem10 = iprot.readString(); struct.partValues.add(_elem10); } @@ -853,7 +853,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, HiveObjectRef struct struct.partValues = new ArrayList(_list13.size); for (int _i14 = 0; _i14 < _list13.size; ++_i14) { - String _elem15; // optional + String _elem15; // required _elem15 = iprot.readString(); struct.partValues.add(_elem15); } diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java index cdf6f30..c35aadd 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java @@ -605,7 +605,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, LockRequest struct) struct.component = new ArrayList(_list402.size); for (int _i403 = 0; _i403 < _list402.size; ++_i403) { - LockComponent _elem404; // optional + LockComponent _elem404; // required _elem404 = new LockComponent(); _elem404.read(iprot); struct.component.add(_elem404); @@ -725,7 +725,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, LockRequest struct) struct.component = new ArrayList(_list407.size); for (int _i408 = 0; _i408 < _list407.size; ++_i408) { - LockComponent _elem409; // optional + LockComponent _elem409; // required _elem409 = new LockComponent(); _elem409.read(iprot); struct.component.add(_elem409); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java index 54955c6..3d47286 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java @@ -354,7 +354,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, OpenTxnsResponse st struct.txn_ids = new ArrayList(_list394.size); for (int _i395 = 0; _i395 < _list394.size; ++_i395) { - long _elem396; // optional + long _elem396; // required _elem396 = iprot.readI64(); struct.txn_ids.add(_elem396); } @@ -424,7 +424,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, OpenTxnsResponse str struct.txn_ids = new ArrayList(_list399.size); for (int _i400 = 0; _i400 < _list399.size; ++_i400) { - long _elem401; // optional + long _elem401; // required _elem401 = iprot.readI64(); struct.txn_ids.add(_elem401); } diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java index 7d29d09..312807e 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java @@ -945,7 +945,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, Partition struct) t struct.values = new ArrayList(_list208.size); for (int _i209 = 0; _i209 < _list208.size; ++_i209) { - String _elem210; // optional + String _elem210; // required _elem210 = iprot.readString(); struct.values.add(_elem210); } @@ -1184,7 +1184,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, Partition struct) th struct.values = new ArrayList(_list219.size); for (int _i220 = 0; _i220 < _list219.size; ++_i220) { - String _elem221; // optional + String _elem221; // required _elem221 = iprot.readString(); struct.values.add(_elem221); } diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsByExprResult.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsByExprResult.java index 5ea5a1b..ea8f0bb 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsByExprResult.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsByExprResult.java @@ -439,7 +439,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, PartitionsByExprRes struct.partitions = new ArrayList(_list272.size); for (int _i273 = 0; _i273 < _list272.size; ++_i273) { - Partition _elem274; // optional + Partition _elem274; // required _elem274 = new Partition(); _elem274.read(iprot); struct.partitions.add(_elem274); @@ -522,7 +522,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, PartitionsByExprResu struct.partitions = new ArrayList(_list277.size); for (int _i278 = 0; _i278 < _list277.size; ++_i278) { - Partition _elem279; // optional + Partition _elem279; // required _elem279 = new Partition(); _elem279.read(iprot); struct.partitions.add(_elem279); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java index 80a151a..a46bdc8 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java @@ -645,7 +645,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, PartitionsStatsRequ struct.colNames = new ArrayList(_list314.size); for (int _i315 = 0; _i315 < _list314.size; ++_i315) { - String _elem316; // optional + String _elem316; // required _elem316 = iprot.readString(); struct.colNames.add(_elem316); } @@ -663,7 +663,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, PartitionsStatsRequ struct.partNames = new ArrayList(_list317.size); for (int _i318 = 0; _i318 < _list317.size; ++_i318) { - String _elem319; // optional + String _elem319; // required _elem319 = iprot.readString(); struct.partNames.add(_elem319); } @@ -768,7 +768,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, PartitionsStatsReque struct.colNames = new ArrayList(_list324.size); for (int _i325 = 0; _i325 < _list324.size; ++_i325) { - String _elem326; // optional + String _elem326; // required _elem326 = iprot.readString(); struct.colNames.add(_elem326); } @@ -779,7 +779,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, PartitionsStatsReque struct.partNames = new ArrayList(_list327.size); for (int _i328 = 0; _i328 < _list327.size; ++_i328) { - String _elem329; // optional + String _elem329; // required _elem329 = iprot.readString(); struct.partNames.add(_elem329); } diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsResult.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsResult.java index 537db47..27f654d 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsResult.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsResult.java @@ -371,7 +371,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, PartitionsStatsResu _val291 = new ArrayList(_list292.size); for (int _i293 = 0; _i293 < _list292.size; ++_i293) { - ColumnStatisticsObj _elem294; // optional + ColumnStatisticsObj _elem294; // required _elem294 = new ColumnStatisticsObj(); _elem294.read(iprot); _val291.add(_elem294); @@ -469,7 +469,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, PartitionsStatsResul _val302 = new ArrayList(_list303.size); for (int _i304 = 0; _i304 < _list303.size; ++_i304) { - ColumnStatisticsObj _elem305; // optional + ColumnStatisticsObj _elem305; // required _elem305 = new ColumnStatisticsObj(); _elem305.read(iprot); _val302.add(_elem305); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PrincipalPrivilegeSet.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PrincipalPrivilegeSet.java index 0c9518a..eea86e5 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PrincipalPrivilegeSet.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PrincipalPrivilegeSet.java @@ -587,7 +587,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, PrincipalPrivilegeS _val27 = new ArrayList(_list28.size); for (int _i29 = 0; _i29 < _list28.size; ++_i29) { - PrivilegeGrantInfo _elem30; // optional + PrivilegeGrantInfo _elem30; // required _elem30 = new PrivilegeGrantInfo(); _elem30.read(iprot); _val27.add(_elem30); @@ -618,7 +618,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, PrincipalPrivilegeS _val34 = new ArrayList(_list35.size); for (int _i36 = 0; _i36 < _list35.size; ++_i36) { - PrivilegeGrantInfo _elem37; // optional + PrivilegeGrantInfo _elem37; // required _elem37 = new PrivilegeGrantInfo(); _elem37.read(iprot); _val34.add(_elem37); @@ -649,7 +649,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, PrincipalPrivilegeS _val41 = new ArrayList(_list42.size); for (int _i43 = 0; _i43 < _list42.size; ++_i43) { - PrivilegeGrantInfo _elem44; // optional + PrivilegeGrantInfo _elem44; // required _elem44 = new PrivilegeGrantInfo(); _elem44.read(iprot); _val41.add(_elem44); @@ -834,7 +834,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, PrincipalPrivilegeSe _val60 = new ArrayList(_list61.size); for (int _i62 = 0; _i62 < _list61.size; ++_i62) { - PrivilegeGrantInfo _elem63; // optional + PrivilegeGrantInfo _elem63; // required _elem63 = new PrivilegeGrantInfo(); _elem63.read(iprot); _val60.add(_elem63); @@ -859,7 +859,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, PrincipalPrivilegeSe _val67 = new ArrayList(_list68.size); for (int _i69 = 0; _i69 < _list68.size; ++_i69) { - PrivilegeGrantInfo _elem70; // optional + PrivilegeGrantInfo _elem70; // required _elem70 = new PrivilegeGrantInfo(); _elem70.read(iprot); _val67.add(_elem70); @@ -884,7 +884,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, PrincipalPrivilegeSe _val74 = new ArrayList(_list75.size); for (int _i76 = 0; _i76 < _list75.size; ++_i76) { - PrivilegeGrantInfo _elem77; // optional + PrivilegeGrantInfo _elem77; // required _elem77 = new PrivilegeGrantInfo(); _elem77.read(iprot); _val74.add(_elem77); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PrivilegeBag.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PrivilegeBag.java index 4285ed8..a4687ad 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PrivilegeBag.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PrivilegeBag.java @@ -350,7 +350,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, PrivilegeBag struct struct.privileges = new ArrayList(_list16.size); for (int _i17 = 0; _i17 < _list16.size; ++_i17) { - HiveObjectPrivilege _elem18; // optional + HiveObjectPrivilege _elem18; // required _elem18 = new HiveObjectPrivilege(); _elem18.read(iprot); struct.privileges.add(_elem18); @@ -430,7 +430,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, PrivilegeBag struct) struct.privileges = new ArrayList(_list21.size); for (int _i22 = 0; _i22 < _list21.size; ++_i22) { - HiveObjectPrivilege _elem23; // optional + HiveObjectPrivilege _elem23; // required _elem23 = new HiveObjectPrivilege(); _elem23.read(iprot); struct.privileges.add(_elem23); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RequestPartsSpec.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RequestPartsSpec.java index 2fcb216..5119b83 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RequestPartsSpec.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RequestPartsSpec.java @@ -169,7 +169,7 @@ protected Object standardSchemeReadValue(org.apache.thrift.protocol.TProtocol ip names = new ArrayList(_list354.size); for (int _i355 = 0; _i355 < _list354.size; ++_i355) { - String _elem356; // optional + String _elem356; // required _elem356 = iprot.readString(); names.add(_elem356); } @@ -188,7 +188,7 @@ protected Object standardSchemeReadValue(org.apache.thrift.protocol.TProtocol ip exprs = new ArrayList(_list357.size); for (int _i358 = 0; _i358 < _list357.size; ++_i358) { - DropPartitionsExpr _elem359; // optional + DropPartitionsExpr _elem359; // required _elem359 = new DropPartitionsExpr(); _elem359.read(iprot); exprs.add(_elem359); @@ -250,7 +250,7 @@ protected Object tupleSchemeReadValue(org.apache.thrift.protocol.TProtocol iprot names = new ArrayList(_list362.size); for (int _i363 = 0; _i363 < _list362.size; ++_i363) { - String _elem364; // optional + String _elem364; // required _elem364 = iprot.readString(); names.add(_elem364); } @@ -264,7 +264,7 @@ protected Object tupleSchemeReadValue(org.apache.thrift.protocol.TProtocol iprot exprs = new ArrayList(_list365.size); for (int _i366 = 0; _i366 < _list365.size; ++_i366) { - DropPartitionsExpr _elem367; // optional + DropPartitionsExpr _elem367; // required _elem367 = new DropPartitionsExpr(); _elem367.read(iprot); exprs.add(_elem367); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Schema.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Schema.java index 58e9028..d91ca2d 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Schema.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Schema.java @@ -456,7 +456,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, Schema struct) thro struct.fieldSchemas = new ArrayList(_list244.size); for (int _i245 = 0; _i245 < _list244.size; ++_i245) { - FieldSchema _elem246; // optional + FieldSchema _elem246; // required _elem246 = new FieldSchema(); _elem246.read(iprot); struct.fieldSchemas.add(_elem246); @@ -582,7 +582,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, Schema struct) throw struct.fieldSchemas = new ArrayList(_list255.size); for (int _i256 = 0; _i256 < _list255.size; ++_i256) { - FieldSchema _elem257; // optional + FieldSchema _elem257; // required _elem257 = new FieldSchema(); _elem257.read(iprot); struct.fieldSchemas.add(_elem257); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java index b962e27..a9f9f7c 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java @@ -354,7 +354,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, ShowCompactResponse struct.compacts = new ArrayList(_list434.size); for (int _i435 = 0; _i435 < _list434.size; ++_i435) { - ShowCompactResponseElement _elem436; // optional + ShowCompactResponseElement _elem436; // required _elem436 = new ShowCompactResponseElement(); _elem436.read(iprot); struct.compacts.add(_elem436); @@ -425,7 +425,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, ShowCompactResponse struct.compacts = new ArrayList(_list439.size); for (int _i440 = 0; _i440 < _list439.size; ++_i440) { - ShowCompactResponseElement _elem441; // optional + ShowCompactResponseElement _elem441; // required _elem441 = new ShowCompactResponseElement(); _elem441.read(iprot); struct.compacts.add(_elem441); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponseElement.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponseElement.java index 47da9b3..365a401 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponseElement.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponseElement.java @@ -51,12 +51,12 @@ private String dbname; // required private String tablename; // required - private String partitionname; // required + private String partitionname; // optional private CompactionType type; // required private String state; // required - private String workerid; // required - private long start; // required - private String runAs; // required + private String workerid; // optional + private long start; // optional + private String runAs; // optional /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { @@ -144,6 +144,7 @@ public String getFieldName() { // isset id assignments private static final int __START_ISSET_ID = 0; private byte __isset_bitfield = 0; + private _Fields optionals[] = {_Fields.PARTITIONNAME,_Fields.WORKERID,_Fields.START,_Fields.RUN_AS}; public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; static { Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); @@ -151,17 +152,17 @@ public String getFieldName() { new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); tmpMap.put(_Fields.TABLENAME, new org.apache.thrift.meta_data.FieldMetaData("tablename", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.PARTITIONNAME, new org.apache.thrift.meta_data.FieldMetaData("partitionname", org.apache.thrift.TFieldRequirementType.REQUIRED, + tmpMap.put(_Fields.PARTITIONNAME, new org.apache.thrift.meta_data.FieldMetaData("partitionname", org.apache.thrift.TFieldRequirementType.OPTIONAL, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); tmpMap.put(_Fields.TYPE, new org.apache.thrift.meta_data.FieldMetaData("type", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, CompactionType.class))); tmpMap.put(_Fields.STATE, new org.apache.thrift.meta_data.FieldMetaData("state", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.WORKERID, new org.apache.thrift.meta_data.FieldMetaData("workerid", org.apache.thrift.TFieldRequirementType.REQUIRED, + tmpMap.put(_Fields.WORKERID, new org.apache.thrift.meta_data.FieldMetaData("workerid", org.apache.thrift.TFieldRequirementType.OPTIONAL, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.START, new org.apache.thrift.meta_data.FieldMetaData("start", org.apache.thrift.TFieldRequirementType.REQUIRED, + tmpMap.put(_Fields.START, new org.apache.thrift.meta_data.FieldMetaData("start", org.apache.thrift.TFieldRequirementType.OPTIONAL, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); - tmpMap.put(_Fields.RUN_AS, new org.apache.thrift.meta_data.FieldMetaData("runAs", org.apache.thrift.TFieldRequirementType.REQUIRED, + tmpMap.put(_Fields.RUN_AS, new org.apache.thrift.meta_data.FieldMetaData("runAs", org.apache.thrift.TFieldRequirementType.OPTIONAL, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ShowCompactResponseElement.class, metaDataMap); @@ -173,23 +174,14 @@ public ShowCompactResponseElement() { public ShowCompactResponseElement( String dbname, String tablename, - String partitionname, CompactionType type, - String state, - String workerid, - long start, - String runAs) + String state) { this(); this.dbname = dbname; this.tablename = tablename; - this.partitionname = partitionname; this.type = type; this.state = state; - this.workerid = workerid; - this.start = start; - setStartIsSet(true); - this.runAs = runAs; } /** @@ -622,8 +614,8 @@ public boolean equals(ShowCompactResponseElement that) { return false; } - boolean this_present_start = true; - boolean that_present_start = true; + boolean this_present_start = true && this.isSetStart(); + boolean that_present_start = true && that.isSetStart(); if (this_present_start || that_present_start) { if (!(this_present_start && that_present_start)) return false; @@ -677,7 +669,7 @@ public int hashCode() { if (present_workerid) builder.append(workerid); - boolean present_start = true; + boolean present_start = true && (isSetStart()); builder.append(present_start); if (present_start) builder.append(start); @@ -813,14 +805,16 @@ public String toString() { sb.append(this.tablename); } first = false; - if (!first) sb.append(", "); - sb.append("partitionname:"); - if (this.partitionname == null) { - sb.append("null"); - } else { - sb.append(this.partitionname); + if (isSetPartitionname()) { + if (!first) sb.append(", "); + sb.append("partitionname:"); + if (this.partitionname == null) { + sb.append("null"); + } else { + sb.append(this.partitionname); + } + first = false; } - first = false; if (!first) sb.append(", "); sb.append("type:"); if (this.type == null) { @@ -837,26 +831,32 @@ public String toString() { sb.append(this.state); } first = false; - if (!first) sb.append(", "); - sb.append("workerid:"); - if (this.workerid == null) { - sb.append("null"); - } else { - sb.append(this.workerid); + if (isSetWorkerid()) { + if (!first) sb.append(", "); + sb.append("workerid:"); + if (this.workerid == null) { + sb.append("null"); + } else { + sb.append(this.workerid); + } + first = false; } - first = false; - if (!first) sb.append(", "); - sb.append("start:"); - sb.append(this.start); - first = false; - if (!first) sb.append(", "); - sb.append("runAs:"); - if (this.runAs == null) { - sb.append("null"); - } else { - sb.append(this.runAs); + if (isSetStart()) { + if (!first) sb.append(", "); + sb.append("start:"); + sb.append(this.start); + first = false; + } + if (isSetRunAs()) { + if (!first) sb.append(", "); + sb.append("runAs:"); + if (this.runAs == null) { + sb.append("null"); + } else { + sb.append(this.runAs); + } + first = false; } - first = false; sb.append(")"); return sb.toString(); } @@ -871,10 +871,6 @@ public void validate() throws org.apache.thrift.TException { throw new org.apache.thrift.protocol.TProtocolException("Required field 'tablename' is unset! Struct:" + toString()); } - if (!isSetPartitionname()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'partitionname' is unset! Struct:" + toString()); - } - if (!isSetType()) { throw new org.apache.thrift.protocol.TProtocolException("Required field 'type' is unset! Struct:" + toString()); } @@ -883,18 +879,6 @@ public void validate() throws org.apache.thrift.TException { throw new org.apache.thrift.protocol.TProtocolException("Required field 'state' is unset! Struct:" + toString()); } - if (!isSetWorkerid()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'workerid' is unset! Struct:" + toString()); - } - - if (!isSetStart()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'start' is unset! Struct:" + toString()); - } - - if (!isSetRunAs()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'runAs' is unset! Struct:" + toString()); - } - // check for sub-struct validity } @@ -1022,9 +1006,11 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, ShowCompactRespons oprot.writeFieldEnd(); } if (struct.partitionname != null) { - oprot.writeFieldBegin(PARTITIONNAME_FIELD_DESC); - oprot.writeString(struct.partitionname); - oprot.writeFieldEnd(); + if (struct.isSetPartitionname()) { + oprot.writeFieldBegin(PARTITIONNAME_FIELD_DESC); + oprot.writeString(struct.partitionname); + oprot.writeFieldEnd(); + } } if (struct.type != null) { oprot.writeFieldBegin(TYPE_FIELD_DESC); @@ -1037,17 +1023,23 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, ShowCompactRespons oprot.writeFieldEnd(); } if (struct.workerid != null) { - oprot.writeFieldBegin(WORKERID_FIELD_DESC); - oprot.writeString(struct.workerid); + if (struct.isSetWorkerid()) { + oprot.writeFieldBegin(WORKERID_FIELD_DESC); + oprot.writeString(struct.workerid); + oprot.writeFieldEnd(); + } + } + if (struct.isSetStart()) { + oprot.writeFieldBegin(START_FIELD_DESC); + oprot.writeI64(struct.start); oprot.writeFieldEnd(); } - oprot.writeFieldBegin(START_FIELD_DESC); - oprot.writeI64(struct.start); - oprot.writeFieldEnd(); if (struct.runAs != null) { - oprot.writeFieldBegin(RUN_AS_FIELD_DESC); - oprot.writeString(struct.runAs); - oprot.writeFieldEnd(); + if (struct.isSetRunAs()) { + oprot.writeFieldBegin(RUN_AS_FIELD_DESC); + oprot.writeString(struct.runAs); + oprot.writeFieldEnd(); + } } oprot.writeFieldStop(); oprot.writeStructEnd(); @@ -1068,12 +1060,34 @@ public void write(org.apache.thrift.protocol.TProtocol prot, ShowCompactResponse TTupleProtocol oprot = (TTupleProtocol) prot; oprot.writeString(struct.dbname); oprot.writeString(struct.tablename); - oprot.writeString(struct.partitionname); oprot.writeI32(struct.type.getValue()); oprot.writeString(struct.state); - oprot.writeString(struct.workerid); - oprot.writeI64(struct.start); - oprot.writeString(struct.runAs); + BitSet optionals = new BitSet(); + if (struct.isSetPartitionname()) { + optionals.set(0); + } + if (struct.isSetWorkerid()) { + optionals.set(1); + } + if (struct.isSetStart()) { + optionals.set(2); + } + if (struct.isSetRunAs()) { + optionals.set(3); + } + oprot.writeBitSet(optionals, 4); + if (struct.isSetPartitionname()) { + oprot.writeString(struct.partitionname); + } + if (struct.isSetWorkerid()) { + oprot.writeString(struct.workerid); + } + if (struct.isSetStart()) { + oprot.writeI64(struct.start); + } + if (struct.isSetRunAs()) { + oprot.writeString(struct.runAs); + } } @Override @@ -1083,18 +1097,27 @@ public void read(org.apache.thrift.protocol.TProtocol prot, ShowCompactResponseE struct.setDbnameIsSet(true); struct.tablename = iprot.readString(); struct.setTablenameIsSet(true); - struct.partitionname = iprot.readString(); - struct.setPartitionnameIsSet(true); struct.type = CompactionType.findByValue(iprot.readI32()); struct.setTypeIsSet(true); struct.state = iprot.readString(); struct.setStateIsSet(true); - struct.workerid = iprot.readString(); - struct.setWorkeridIsSet(true); - struct.start = iprot.readI64(); - struct.setStartIsSet(true); - struct.runAs = iprot.readString(); - struct.setRunAsIsSet(true); + BitSet incoming = iprot.readBitSet(4); + if (incoming.get(0)) { + struct.partitionname = iprot.readString(); + struct.setPartitionnameIsSet(true); + } + if (incoming.get(1)) { + struct.workerid = iprot.readString(); + struct.setWorkeridIsSet(true); + } + if (incoming.get(2)) { + struct.start = iprot.readI64(); + struct.setStartIsSet(true); + } + if (incoming.get(3)) { + struct.runAs = iprot.readString(); + struct.setRunAsIsSet(true); + } } } diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java index 1399f8b..d2657e0 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java @@ -350,7 +350,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, ShowLocksResponse s struct.locks = new ArrayList(_list410.size); for (int _i411 = 0; _i411 < _list410.size; ++_i411) { - ShowLocksResponseElement _elem412; // optional + ShowLocksResponseElement _elem412; // required _elem412 = new ShowLocksResponseElement(); _elem412.read(iprot); struct.locks.add(_elem412); @@ -430,7 +430,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, ShowLocksResponse st struct.locks = new ArrayList(_list415.size); for (int _i416 = 0; _i416 < _list415.size; ++_i416) { - ShowLocksResponseElement _elem417; // optional + ShowLocksResponseElement _elem417; // required _elem417 = new ShowLocksResponseElement(); _elem417.read(iprot); struct.locks.add(_elem417); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java index ab5c0ed..83438c7 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java @@ -566,7 +566,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, SkewedInfo struct) struct.skewedColNames = new ArrayList(_list114.size); for (int _i115 = 0; _i115 < _list114.size; ++_i115) { - String _elem116; // optional + String _elem116; // required _elem116 = iprot.readString(); struct.skewedColNames.add(_elem116); } @@ -584,13 +584,13 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, SkewedInfo struct) struct.skewedColValues = new ArrayList>(_list117.size); for (int _i118 = 0; _i118 < _list117.size; ++_i118) { - List _elem119; // optional + List _elem119; // required { org.apache.thrift.protocol.TList _list120 = iprot.readListBegin(); _elem119 = new ArrayList(_list120.size); for (int _i121 = 0; _i121 < _list120.size; ++_i121) { - String _elem122; // optional + String _elem122; // required _elem122 = iprot.readString(); _elem119.add(_elem122); } @@ -619,7 +619,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, SkewedInfo struct) _key125 = new ArrayList(_list127.size); for (int _i128 = 0; _i128 < _list127.size; ++_i128) { - String _elem129; // optional + String _elem129; // required _elem129 = iprot.readString(); _key125.add(_elem129); } @@ -779,7 +779,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, SkewedInfo struct) t struct.skewedColNames = new ArrayList(_list140.size); for (int _i141 = 0; _i141 < _list140.size; ++_i141) { - String _elem142; // optional + String _elem142; // required _elem142 = iprot.readString(); struct.skewedColNames.add(_elem142); } @@ -792,13 +792,13 @@ public void read(org.apache.thrift.protocol.TProtocol prot, SkewedInfo struct) t struct.skewedColValues = new ArrayList>(_list143.size); for (int _i144 = 0; _i144 < _list143.size; ++_i144) { - List _elem145; // optional + List _elem145; // required { org.apache.thrift.protocol.TList _list146 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); _elem145 = new ArrayList(_list146.size); for (int _i147 = 0; _i147 < _list146.size; ++_i147) { - String _elem148; // optional + String _elem148; // required _elem148 = iprot.readString(); _elem145.add(_elem148); } @@ -821,7 +821,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, SkewedInfo struct) t _key151 = new ArrayList(_list153.size); for (int _i154 = 0; _i154 < _list153.size; ++_i154) { - String _elem155; // optional + String _elem155; // required _elem155 = iprot.readString(); _key151.add(_elem155); } diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java index 813b4f0..d0b9843 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java @@ -1304,7 +1304,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, StorageDescriptor s struct.cols = new ArrayList(_list156.size); for (int _i157 = 0; _i157 < _list156.size; ++_i157) { - FieldSchema _elem158; // optional + FieldSchema _elem158; // required _elem158 = new FieldSchema(); _elem158.read(iprot); struct.cols.add(_elem158); @@ -1372,7 +1372,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, StorageDescriptor s struct.bucketCols = new ArrayList(_list159.size); for (int _i160 = 0; _i160 < _list159.size; ++_i160) { - String _elem161; // optional + String _elem161; // required _elem161 = iprot.readString(); struct.bucketCols.add(_elem161); } @@ -1390,7 +1390,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, StorageDescriptor s struct.sortCols = new ArrayList(_list162.size); for (int _i163 = 0; _i163 < _list162.size; ++_i163) { - Order _elem164; // optional + Order _elem164; // required _elem164 = new Order(); _elem164.read(iprot); struct.sortCols.add(_elem164); @@ -1667,7 +1667,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, StorageDescriptor st struct.cols = new ArrayList(_list177.size); for (int _i178 = 0; _i178 < _list177.size; ++_i178) { - FieldSchema _elem179; // optional + FieldSchema _elem179; // required _elem179 = new FieldSchema(); _elem179.read(iprot); struct.cols.add(_elem179); @@ -1706,7 +1706,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, StorageDescriptor st struct.bucketCols = new ArrayList(_list180.size); for (int _i181 = 0; _i181 < _list180.size; ++_i181) { - String _elem182; // optional + String _elem182; // required _elem182 = iprot.readString(); struct.bucketCols.add(_elem182); } @@ -1719,7 +1719,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, StorageDescriptor st struct.sortCols = new ArrayList(_list183.size); for (int _i184 = 0; _i184 < _list183.size; ++_i184) { - Order _elem185; // optional + Order _elem185; // required _elem185 = new Order(); _elem185.read(iprot); struct.sortCols.add(_elem185); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java index 484bd6a..229a819 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java @@ -1481,7 +1481,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, Table struct) throw struct.partitionKeys = new ArrayList(_list190.size); for (int _i191 = 0; _i191 < _list190.size; ++_i191) { - FieldSchema _elem192; // optional + FieldSchema _elem192; // required _elem192 = new FieldSchema(); _elem192.read(iprot); struct.partitionKeys.add(_elem192); @@ -1805,7 +1805,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, Table struct) throws struct.partitionKeys = new ArrayList(_list201.size); for (int _i202 = 0; _i202 < _list201.size; ++_i202) { - FieldSchema _elem203; // optional + FieldSchema _elem203; // required _elem203 = new FieldSchema(); _elem203.read(iprot); struct.partitionKeys.add(_elem203); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java index ddfcccc..48d16b7 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java @@ -540,7 +540,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, TableStatsRequest s struct.colNames = new ArrayList(_list306.size); for (int _i307 = 0; _i307 < _list306.size; ++_i307) { - String _elem308; // optional + String _elem308; // required _elem308 = iprot.readString(); struct.colNames.add(_elem308); } @@ -626,7 +626,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, TableStatsRequest st struct.colNames = new ArrayList(_list311.size); for (int _i312 = 0; _i312 < _list311.size; ++_i312) { - String _elem313; // optional + String _elem313; // required _elem313 = iprot.readString(); struct.colNames.add(_elem313); } diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java index e37b75c..b25c6c2 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java @@ -354,7 +354,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, TableStatsResult st struct.tableStats = new ArrayList(_list280.size); for (int _i281 = 0; _i281 < _list280.size; ++_i281) { - ColumnStatisticsObj _elem282; // optional + ColumnStatisticsObj _elem282; // required _elem282 = new ColumnStatisticsObj(); _elem282.read(iprot); struct.tableStats.add(_elem282); @@ -425,7 +425,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, TableStatsResult str struct.tableStats = new ArrayList(_list285.size); for (int _i286 = 0; _i286 < _list285.size; ++_i286) { - ColumnStatisticsObj _elem287; // optional + ColumnStatisticsObj _elem287; // required _elem287 = new ColumnStatisticsObj(); _elem287.read(iprot); struct.tableStats.add(_elem287); diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java index 1e0cdea..3b66bc5 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java @@ -14376,7 +14376,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_databases_resul struct.success = new ArrayList(_list442.size); for (int _i443 = 0; _i443 < _list442.size; ++_i443) { - String _elem444; // optional + String _elem444; // required _elem444 = iprot.readString(); struct.success.add(_elem444); } @@ -14475,7 +14475,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_databases_result struct.success = new ArrayList(_list447.size); for (int _i448 = 0; _i448 < _list447.size; ++_i448) { - String _elem449; // optional + String _elem449; // required _elem449 = iprot.readString(); struct.success.add(_elem449); } @@ -15138,7 +15138,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_all_databases_r struct.success = new ArrayList(_list450.size); for (int _i451 = 0; _i451 < _list450.size; ++_i451) { - String _elem452; // optional + String _elem452; // required _elem452 = iprot.readString(); struct.success.add(_elem452); } @@ -15237,7 +15237,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_all_databases_re struct.success = new ArrayList(_list455.size); for (int _i456 = 0; _i456 < _list455.size; ++_i456) { - String _elem457; // optional + String _elem457; // required _elem457 = iprot.readString(); struct.success.add(_elem457); } @@ -20998,7 +20998,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_fields_result s struct.success = new ArrayList(_list468.size); for (int _i469 = 0; _i469 < _list468.size; ++_i469) { - FieldSchema _elem470; // optional + FieldSchema _elem470; // required _elem470 = new FieldSchema(); _elem470.read(iprot); struct.success.add(_elem470); @@ -21138,7 +21138,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_fields_result st struct.success = new ArrayList(_list473.size); for (int _i474 = 0; _i474 < _list473.size; ++_i474) { - FieldSchema _elem475; // optional + FieldSchema _elem475; // required _elem475 = new FieldSchema(); _elem475.read(iprot); struct.success.add(_elem475); @@ -22190,7 +22190,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_schema_result s struct.success = new ArrayList(_list476.size); for (int _i477 = 0; _i477 < _list476.size; ++_i477) { - FieldSchema _elem478; // optional + FieldSchema _elem478; // required _elem478 = new FieldSchema(); _elem478.read(iprot); struct.success.add(_elem478); @@ -22330,7 +22330,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_schema_result st struct.success = new ArrayList(_list481.size); for (int _i482 = 0; _i482 < _list481.size; ++_i482) { - FieldSchema _elem483; // optional + FieldSchema _elem483; // required _elem483 = new FieldSchema(); _elem483.read(iprot); struct.success.add(_elem483); @@ -27580,7 +27580,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_tables_result s struct.success = new ArrayList(_list484.size); for (int _i485 = 0; _i485 < _list484.size; ++_i485) { - String _elem486; // optional + String _elem486; // required _elem486 = iprot.readString(); struct.success.add(_elem486); } @@ -27679,7 +27679,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_tables_result st struct.success = new ArrayList(_list489.size); for (int _i490 = 0; _i490 < _list489.size; ++_i490) { - String _elem491; // optional + String _elem491; // required _elem491 = iprot.readString(); struct.success.add(_elem491); } @@ -28454,7 +28454,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_all_tables_resu struct.success = new ArrayList(_list492.size); for (int _i493 = 0; _i493 < _list492.size; ++_i493) { - String _elem494; // optional + String _elem494; // required _elem494 = iprot.readString(); struct.success.add(_elem494); } @@ -28553,7 +28553,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_all_tables_resul struct.success = new ArrayList(_list497.size); for (int _i498 = 0; _i498 < _list497.size; ++_i498) { - String _elem499; // optional + String _elem499; // required _elem499 = iprot.readString(); struct.success.add(_elem499); } @@ -30015,7 +30015,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_table_objects_b struct.tbl_names = new ArrayList(_list500.size); for (int _i501 = 0; _i501 < _list500.size; ++_i501) { - String _elem502; // optional + String _elem502; // required _elem502 = iprot.readString(); struct.tbl_names.add(_elem502); } @@ -30109,7 +30109,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_table_objects_by struct.tbl_names = new ArrayList(_list505.size); for (int _i506 = 0; _i506 < _list505.size; ++_i506) { - String _elem507; // optional + String _elem507; // required _elem507 = iprot.readString(); struct.tbl_names.add(_elem507); } @@ -30683,7 +30683,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_table_objects_b struct.success = new ArrayList(_list508.size); for (int _i509 = 0; _i509 < _list508.size; ++_i509) { - Table _elem510; // optional + Table _elem510; // required _elem510 = new Table(); _elem510.read(iprot); struct.success.add(_elem510); @@ -30823,7 +30823,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_table_objects_by struct.success = new ArrayList
(_list513.size); for (int _i514 = 0; _i514 < _list513.size; ++_i514) { - Table _elem515; // optional + Table _elem515; // required _elem515 = new Table(); _elem515.read(iprot); struct.success.add(_elem515); @@ -31979,7 +31979,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_table_names_by_ struct.success = new ArrayList(_list516.size); for (int _i517 = 0; _i517 < _list516.size; ++_i517) { - String _elem518; // optional + String _elem518; // required _elem518 = iprot.readString(); struct.success.add(_elem518); } @@ -32118,7 +32118,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_table_names_by_f struct.success = new ArrayList(_list521.size); for (int _i522 = 0; _i522 < _list521.size; ++_i522) { - String _elem523; // optional + String _elem523; // required _elem523 = iprot.readString(); struct.success.add(_elem523); } @@ -36844,7 +36844,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, add_partitions_args struct.new_parts = new ArrayList(_list524.size); for (int _i525 = 0; _i525 < _list524.size; ++_i525) { - Partition _elem526; // optional + Partition _elem526; // required _elem526 = new Partition(); _elem526.read(iprot); struct.new_parts.add(_elem526); @@ -36924,7 +36924,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, add_partitions_args struct.new_parts = new ArrayList(_list529.size); for (int _i530 = 0; _i530 < _list529.size; ++_i530) { - Partition _elem531; // optional + Partition _elem531; // required _elem531 = new Partition(); _elem531.read(iprot); struct.new_parts.add(_elem531); @@ -38110,7 +38110,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, append_partition_ar struct.part_vals = new ArrayList(_list532.size); for (int _i533 = 0; _i533 < _list532.size; ++_i533) { - String _elem534; // optional + String _elem534; // required _elem534 = iprot.readString(); struct.part_vals.add(_elem534); } @@ -38219,7 +38219,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, append_partition_arg struct.part_vals = new ArrayList(_list537.size); for (int _i538 = 0; _i538 < _list537.size; ++_i538) { - String _elem539; // optional + String _elem539; // required _elem539 = iprot.readString(); struct.part_vals.add(_elem539); } @@ -40537,7 +40537,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, append_partition_wi struct.part_vals = new ArrayList(_list540.size); for (int _i541 = 0; _i541 < _list540.size; ++_i541) { - String _elem542; // optional + String _elem542; // required _elem542 = iprot.readString(); struct.part_vals.add(_elem542); } @@ -40666,7 +40666,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, append_partition_wit struct.part_vals = new ArrayList(_list545.size); for (int _i546 = 0; _i546 < _list545.size; ++_i546) { - String _elem547; // optional + String _elem547; // required _elem547 = iprot.readString(); struct.part_vals.add(_elem547); } @@ -44545,7 +44545,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, drop_partition_args struct.part_vals = new ArrayList(_list548.size); for (int _i549 = 0; _i549 < _list548.size; ++_i549) { - String _elem550; // optional + String _elem550; // required _elem550 = iprot.readString(); struct.part_vals.add(_elem550); } @@ -44671,7 +44671,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, drop_partition_args struct.part_vals = new ArrayList(_list553.size); for (int _i554 = 0; _i554 < _list553.size; ++_i554) { - String _elem555; // optional + String _elem555; // required _elem555 = iprot.readString(); struct.part_vals.add(_elem555); } @@ -45919,7 +45919,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, drop_partition_with struct.part_vals = new ArrayList(_list556.size); for (int _i557 = 0; _i557 < _list556.size; ++_i557) { - String _elem558; // optional + String _elem558; // required _elem558 = iprot.readString(); struct.part_vals.add(_elem558); } @@ -46065,7 +46065,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, drop_partition_with_ struct.part_vals = new ArrayList(_list561.size); for (int _i562 = 0; _i562 < _list561.size; ++_i562) { - String _elem563; // optional + String _elem563; // required _elem563 = iprot.readString(); struct.part_vals.add(_elem563); } @@ -50676,7 +50676,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_partition_args struct.part_vals = new ArrayList(_list564.size); for (int _i565 = 0; _i565 < _list564.size; ++_i565) { - String _elem566; // optional + String _elem566; // required _elem566 = iprot.readString(); struct.part_vals.add(_elem566); } @@ -50785,7 +50785,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_partition_args s struct.part_vals = new ArrayList(_list569.size); for (int _i570 = 0; _i570 < _list569.size; ++_i570) { - String _elem571; // optional + String _elem571; // required _elem571 = iprot.readString(); struct.part_vals.add(_elem571); } @@ -53675,7 +53675,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_partition_with_ struct.part_vals = new ArrayList(_list582.size); for (int _i583 = 0; _i583 < _list582.size; ++_i583) { - String _elem584; // optional + String _elem584; // required _elem584 = iprot.readString(); struct.part_vals.add(_elem584); } @@ -53701,7 +53701,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_partition_with_ struct.group_names = new ArrayList(_list585.size); for (int _i586 = 0; _i586 < _list585.size; ++_i586) { - String _elem587; // optional + String _elem587; // required _elem587 = iprot.readString(); struct.group_names.add(_elem587); } @@ -53845,7 +53845,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_partition_with_a struct.part_vals = new ArrayList(_list592.size); for (int _i593 = 0; _i593 < _list592.size; ++_i593) { - String _elem594; // optional + String _elem594; // required _elem594 = iprot.readString(); struct.part_vals.add(_elem594); } @@ -53862,7 +53862,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_partition_with_a struct.group_names = new ArrayList(_list595.size); for (int _i596 = 0; _i596 < _list595.size; ++_i596) { - String _elem597; // optional + String _elem597; // required _elem597 = iprot.readString(); struct.group_names.add(_elem597); } @@ -56637,7 +56637,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_partitions_resu struct.success = new ArrayList(_list598.size); for (int _i599 = 0; _i599 < _list598.size; ++_i599) { - Partition _elem600; // optional + Partition _elem600; // required _elem600 = new Partition(); _elem600.read(iprot); struct.success.add(_elem600); @@ -56757,7 +56757,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_partitions_resul struct.success = new ArrayList(_list603.size); for (int _i604 = 0; _i604 < _list603.size; ++_i604) { - Partition _elem605; // optional + Partition _elem605; // required _elem605 = new Partition(); _elem605.read(iprot); struct.success.add(_elem605); @@ -57457,7 +57457,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_partitions_with struct.group_names = new ArrayList(_list606.size); for (int _i607 = 0; _i607 < _list606.size; ++_i607) { - String _elem608; // optional + String _elem608; // required _elem608 = iprot.readString(); struct.group_names.add(_elem608); } @@ -57594,7 +57594,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_partitions_with_ struct.group_names = new ArrayList(_list611.size); for (int _i612 = 0; _i612 < _list611.size; ++_i612) { - String _elem613; // optional + String _elem613; // required _elem613 = iprot.readString(); struct.group_names.add(_elem613); } @@ -58087,7 +58087,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_partitions_with struct.success = new ArrayList(_list614.size); for (int _i615 = 0; _i615 < _list614.size; ++_i615) { - Partition _elem616; // optional + Partition _elem616; // required _elem616 = new Partition(); _elem616.read(iprot); struct.success.add(_elem616); @@ -58207,7 +58207,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_partitions_with_ struct.success = new ArrayList(_list619.size); for (int _i620 = 0; _i620 < _list619.size; ++_i620) { - Partition _elem621; // optional + Partition _elem621; // required _elem621 = new Partition(); _elem621.read(iprot); struct.success.add(_elem621); @@ -59196,7 +59196,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_partition_names struct.success = new ArrayList(_list622.size); for (int _i623 = 0; _i623 < _list622.size; ++_i623) { - String _elem624; // optional + String _elem624; // required _elem624 = iprot.readString(); struct.success.add(_elem624); } @@ -59295,7 +59295,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_partition_names_ struct.success = new ArrayList(_list627.size); for (int _i628 = 0; _i628 < _list627.size; ++_i628) { - String _elem629; // optional + String _elem629; // required _elem629 = iprot.readString(); struct.success.add(_elem629); } @@ -59892,7 +59892,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_partitions_ps_a struct.part_vals = new ArrayList(_list630.size); for (int _i631 = 0; _i631 < _list630.size; ++_i631) { - String _elem632; // optional + String _elem632; // required _elem632 = iprot.readString(); struct.part_vals.add(_elem632); } @@ -60018,7 +60018,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_partitions_ps_ar struct.part_vals = new ArrayList(_list635.size); for (int _i636 = 0; _i636 < _list635.size; ++_i636) { - String _elem637; // optional + String _elem637; // required _elem637 = iprot.readString(); struct.part_vals.add(_elem637); } @@ -60515,7 +60515,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_partitions_ps_r struct.success = new ArrayList(_list638.size); for (int _i639 = 0; _i639 < _list638.size; ++_i639) { - Partition _elem640; // optional + Partition _elem640; // required _elem640 = new Partition(); _elem640.read(iprot); struct.success.add(_elem640); @@ -60635,7 +60635,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_partitions_ps_re struct.success = new ArrayList(_list643.size); for (int _i644 = 0; _i644 < _list643.size; ++_i644) { - Partition _elem645; // optional + Partition _elem645; // required _elem645 = new Partition(); _elem645.read(iprot); struct.success.add(_elem645); @@ -61420,7 +61420,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_partitions_ps_w struct.part_vals = new ArrayList(_list646.size); for (int _i647 = 0; _i647 < _list646.size; ++_i647) { - String _elem648; // optional + String _elem648; // required _elem648 = iprot.readString(); struct.part_vals.add(_elem648); } @@ -61454,7 +61454,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_partitions_ps_w struct.group_names = new ArrayList(_list649.size); for (int _i650 = 0; _i650 < _list649.size; ++_i650) { - String _elem651; // optional + String _elem651; // required _elem651 = iprot.readString(); struct.group_names.add(_elem651); } @@ -61607,7 +61607,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_partitions_ps_wi struct.part_vals = new ArrayList(_list656.size); for (int _i657 = 0; _i657 < _list656.size; ++_i657) { - String _elem658; // optional + String _elem658; // required _elem658 = iprot.readString(); struct.part_vals.add(_elem658); } @@ -61628,7 +61628,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_partitions_ps_wi struct.group_names = new ArrayList(_list659.size); for (int _i660 = 0; _i660 < _list659.size; ++_i660) { - String _elem661; // optional + String _elem661; // required _elem661 = iprot.readString(); struct.group_names.add(_elem661); } @@ -62121,7 +62121,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_partitions_ps_w struct.success = new ArrayList(_list662.size); for (int _i663 = 0; _i663 < _list662.size; ++_i663) { - Partition _elem664; // optional + Partition _elem664; // required _elem664 = new Partition(); _elem664.read(iprot); struct.success.add(_elem664); @@ -62241,7 +62241,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_partitions_ps_wi struct.success = new ArrayList(_list667.size); for (int _i668 = 0; _i668 < _list667.size; ++_i668) { - Partition _elem669; // optional + Partition _elem669; // required _elem669 = new Partition(); _elem669.read(iprot); struct.success.add(_elem669); @@ -62844,7 +62844,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_partition_names struct.part_vals = new ArrayList(_list670.size); for (int _i671 = 0; _i671 < _list670.size; ++_i671) { - String _elem672; // optional + String _elem672; // required _elem672 = iprot.readString(); struct.part_vals.add(_elem672); } @@ -62970,7 +62970,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_partition_names_ struct.part_vals = new ArrayList(_list675.size); for (int _i676 = 0; _i676 < _list675.size; ++_i676) { - String _elem677; // optional + String _elem677; // required _elem677 = iprot.readString(); struct.part_vals.add(_elem677); } @@ -63467,7 +63467,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_partition_names struct.success = new ArrayList(_list678.size); for (int _i679 = 0; _i679 < _list678.size; ++_i679) { - String _elem680; // optional + String _elem680; // required _elem680 = iprot.readString(); struct.success.add(_elem680); } @@ -63586,7 +63586,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_partition_names_ struct.success = new ArrayList(_list683.size); for (int _i684 = 0; _i684 < _list683.size; ++_i684) { - String _elem685; // optional + String _elem685; // required _elem685 = iprot.readString(); struct.success.add(_elem685); } @@ -64759,7 +64759,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_partitions_by_f struct.success = new ArrayList(_list686.size); for (int _i687 = 0; _i687 < _list686.size; ++_i687) { - Partition _elem688; // optional + Partition _elem688; // required _elem688 = new Partition(); _elem688.read(iprot); struct.success.add(_elem688); @@ -64879,7 +64879,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_partitions_by_fi struct.success = new ArrayList(_list691.size); for (int _i692 = 0; _i692 < _list691.size; ++_i692) { - Partition _elem693; // optional + Partition _elem693; // required _elem693 = new Partition(); _elem693.read(iprot); struct.success.add(_elem693); @@ -66337,7 +66337,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_partitions_by_n struct.names = new ArrayList(_list694.size); for (int _i695 = 0; _i695 < _list694.size; ++_i695) { - String _elem696; // optional + String _elem696; // required _elem696 = iprot.readString(); struct.names.add(_elem696); } @@ -66446,7 +66446,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_partitions_by_na struct.names = new ArrayList(_list699.size); for (int _i700 = 0; _i700 < _list699.size; ++_i700) { - String _elem701; // optional + String _elem701; // required _elem701 = iprot.readString(); struct.names.add(_elem701); } @@ -66939,7 +66939,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_partitions_by_n struct.success = new ArrayList(_list702.size); for (int _i703 = 0; _i703 < _list702.size; ++_i703) { - Partition _elem704; // optional + Partition _elem704; // required _elem704 = new Partition(); _elem704.read(iprot); struct.success.add(_elem704); @@ -67059,7 +67059,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_partitions_by_na struct.success = new ArrayList(_list707.size); for (int _i708 = 0; _i708 < _list707.size; ++_i708) { - Partition _elem709; // optional + Partition _elem709; // required _elem709 = new Partition(); _elem709.read(iprot); struct.success.add(_elem709); @@ -68616,7 +68616,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, alter_partitions_ar struct.new_parts = new ArrayList(_list710.size); for (int _i711 = 0; _i711 < _list710.size; ++_i711) { - Partition _elem712; // optional + Partition _elem712; // required _elem712 = new Partition(); _elem712.read(iprot); struct.new_parts.add(_elem712); @@ -68726,7 +68726,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, alter_partitions_arg struct.new_parts = new ArrayList(_list715.size); for (int _i716 = 0; _i716 < _list715.size; ++_i716) { - Partition _elem717; // optional + Partition _elem717; // required _elem717 = new Partition(); _elem717.read(iprot); struct.new_parts.add(_elem717); @@ -70932,7 +70932,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, rename_partition_ar struct.part_vals = new ArrayList(_list718.size); for (int _i719 = 0; _i719 < _list718.size; ++_i719) { - String _elem720; // optional + String _elem720; // required _elem720 = iprot.readString(); struct.part_vals.add(_elem720); } @@ -71061,7 +71061,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, rename_partition_arg struct.part_vals = new ArrayList(_list723.size); for (int _i724 = 0; _i724 < _list723.size; ++_i724) { - String _elem725; // optional + String _elem725; // required _elem725 = iprot.readString(); struct.part_vals.add(_elem725); } @@ -71944,7 +71944,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, partition_name_has_ struct.part_vals = new ArrayList(_list726.size); for (int _i727 = 0; _i727 < _list726.size; ++_i727) { - String _elem728; // optional + String _elem728; // required _elem728 = iprot.readString(); struct.part_vals.add(_elem728); } @@ -72040,7 +72040,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, partition_name_has_v struct.part_vals = new ArrayList(_list731.size); for (int _i732 = 0; _i732 < _list731.size; ++_i732) { - String _elem733; // optional + String _elem733; // required _elem733 = iprot.readString(); struct.part_vals.add(_elem733); } @@ -74204,7 +74204,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, partition_name_to_v struct.success = new ArrayList(_list734.size); for (int _i735 = 0; _i735 < _list734.size; ++_i735) { - String _elem736; // optional + String _elem736; // required _elem736 = iprot.readString(); struct.success.add(_elem736); } @@ -74303,7 +74303,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, partition_name_to_va struct.success = new ArrayList(_list739.size); for (int _i740 = 0; _i740 < _list739.size; ++_i740) { - String _elem741; // optional + String _elem741; // required _elem741 = iprot.readString(); struct.success.add(_elem741); } @@ -84299,7 +84299,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_indexes_result struct.success = new ArrayList(_list772.size); for (int _i773 = 0; _i773 < _list772.size; ++_i773) { - Index _elem774; // optional + Index _elem774; // required _elem774 = new Index(); _elem774.read(iprot); struct.success.add(_elem774); @@ -84419,7 +84419,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_indexes_result s struct.success = new ArrayList(_list777.size); for (int _i778 = 0; _i778 < _list777.size; ++_i778) { - Index _elem779; // optional + Index _elem779; // required _elem779 = new Index(); _elem779.read(iprot); struct.success.add(_elem779); @@ -85408,7 +85408,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_index_names_res struct.success = new ArrayList(_list780.size); for (int _i781 = 0; _i781 < _list780.size; ++_i781) { - String _elem782; // optional + String _elem782; // required _elem782 = iprot.readString(); struct.success.add(_elem782); } @@ -85507,7 +85507,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_index_names_resu struct.success = new ArrayList(_list785.size); for (int _i786 = 0; _i786 < _list785.size; ++_i786) { - String _elem787; // optional + String _elem787; // required _elem787 = iprot.readString(); struct.success.add(_elem787); } @@ -99168,7 +99168,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_functions_resul struct.success = new ArrayList(_list788.size); for (int _i789 = 0; _i789 < _list788.size; ++_i789) { - String _elem790; // optional + String _elem790; // required _elem790 = iprot.readString(); struct.success.add(_elem790); } @@ -99267,7 +99267,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_functions_result struct.success = new ArrayList(_list793.size); for (int _i794 = 0; _i794 < _list793.size; ++_i794) { - String _elem795; // optional + String _elem795; // required _elem795 = iprot.readString(); struct.success.add(_elem795); } @@ -102616,7 +102616,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_role_names_resu struct.success = new ArrayList(_list796.size); for (int _i797 = 0; _i797 < _list796.size; ++_i797) { - String _elem798; // optional + String _elem798; // required _elem798 = iprot.readString(); struct.success.add(_elem798); } @@ -102715,7 +102715,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_role_names_resul struct.success = new ArrayList(_list801.size); for (int _i802 = 0; _i802 < _list801.size; ++_i802) { - String _elem803; // optional + String _elem803; // required _elem803 = iprot.readString(); struct.success.add(_elem803); } @@ -106012,7 +106012,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, list_roles_result s struct.success = new ArrayList(_list804.size); for (int _i805 = 0; _i805 < _list804.size; ++_i805) { - Role _elem806; // optional + Role _elem806; // required _elem806 = new Role(); _elem806.read(iprot); struct.success.add(_elem806); @@ -106112,7 +106112,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, list_roles_result st struct.success = new ArrayList(_list809.size); for (int _i810 = 0; _i810 < _list809.size; ++_i810) { - Role _elem811; // optional + Role _elem811; // required _elem811 = new Role(); _elem811.read(iprot); struct.success.add(_elem811); @@ -109127,7 +109127,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, get_privilege_set_a struct.group_names = new ArrayList(_list812.size); for (int _i813 = 0; _i813 < _list812.size; ++_i813) { - String _elem814; // optional + String _elem814; // required _elem814 = iprot.readString(); struct.group_names.add(_elem814); } @@ -109237,7 +109237,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, get_privilege_set_ar struct.group_names = new ArrayList(_list817.size); for (int _i818 = 0; _i818 < _list817.size; ++_i818) { - String _elem819; // optional + String _elem819; // required _elem819 = iprot.readString(); struct.group_names.add(_elem819); } @@ -110701,7 +110701,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, list_privileges_res struct.success = new ArrayList(_list820.size); for (int _i821 = 0; _i821 < _list820.size; ++_i821) { - HiveObjectPrivilege _elem822; // optional + HiveObjectPrivilege _elem822; // required _elem822 = new HiveObjectPrivilege(); _elem822.read(iprot); struct.success.add(_elem822); @@ -110801,7 +110801,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, list_privileges_resu struct.success = new ArrayList(_list825.size); for (int _i826 = 0; _i826 < _list825.size; ++_i826) { - HiveObjectPrivilege _elem827; // optional + HiveObjectPrivilege _elem827; // required _elem827 = new HiveObjectPrivilege(); _elem827.read(iprot); struct.success.add(_elem827); @@ -113713,7 +113713,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, set_ugi_args struct struct.group_names = new ArrayList(_list828.size); for (int _i829 = 0; _i829 < _list828.size; ++_i829) { - String _elem830; // optional + String _elem830; // required _elem830 = iprot.readString(); struct.group_names.add(_elem830); } @@ -113807,7 +113807,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, set_ugi_args struct) struct.group_names = new ArrayList(_list833.size); for (int _i834 = 0; _i834 < _list833.size; ++_i834) { - String _elem835; // optional + String _elem835; // required _elem835 = iprot.readString(); struct.group_names.add(_elem835); } @@ -114219,7 +114219,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, set_ugi_result stru struct.success = new ArrayList(_list836.size); for (int _i837 = 0; _i837 < _list836.size; ++_i837) { - String _elem838; // optional + String _elem838; // required _elem838 = iprot.readString(); struct.success.add(_elem838); } @@ -114318,7 +114318,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, set_ugi_result struc struct.success = new ArrayList(_list841.size); for (int _i842 = 0; _i842 < _list841.size; ++_i842) { - String _elem843; // optional + String _elem843; // required _elem843 = iprot.readString(); struct.success.add(_elem843); } diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java index 1882b57..bb81e3c 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java @@ -618,7 +618,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, Type struct) throws struct.fields = new ArrayList(_list0.size); for (int _i1 = 0; _i1 < _list0.size; ++_i1) { - FieldSchema _elem2; // optional + FieldSchema _elem2; // required _elem2 = new FieldSchema(); _elem2.read(iprot); struct.fields.add(_elem2); @@ -749,7 +749,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, Type struct) throws struct.fields = new ArrayList(_list5.size); for (int _i6 = 0; _i6 < _list5.size; ++_i6) { - FieldSchema _elem7; // optional + FieldSchema _elem7; // required _elem7 = new FieldSchema(); _elem7.read(iprot); struct.fields.add(_elem7); diff --git metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py index c71b7b7..bc9ae54 100644 --- metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py +++ metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py @@ -7498,18 +7498,10 @@ def validate(self): raise TProtocol.TProtocolException(message='Required field dbname is unset!') if self.tablename is None: raise TProtocol.TProtocolException(message='Required field tablename is unset!') - if self.partitionname is None: - raise TProtocol.TProtocolException(message='Required field partitionname is unset!') if self.type is None: raise TProtocol.TProtocolException(message='Required field type is unset!') if self.state is None: raise TProtocol.TProtocolException(message='Required field state is unset!') - if self.workerid is None: - raise TProtocol.TProtocolException(message='Required field workerid is unset!') - if self.start is None: - raise TProtocol.TProtocolException(message='Required field start is unset!') - if self.runAs is None: - raise TProtocol.TProtocolException(message='Required field runAs is unset!') return diff --git metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb index e21f662..f40dc2c 100644 --- metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb +++ metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb @@ -1825,12 +1825,12 @@ class ShowCompactResponseElement FIELDS = { DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbname'}, TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tablename'}, - PARTITIONNAME => {:type => ::Thrift::Types::STRING, :name => 'partitionname'}, + PARTITIONNAME => {:type => ::Thrift::Types::STRING, :name => 'partitionname', :optional => true}, TYPE => {:type => ::Thrift::Types::I32, :name => 'type', :enum_class => ::CompactionType}, STATE => {:type => ::Thrift::Types::STRING, :name => 'state'}, - WORKERID => {:type => ::Thrift::Types::STRING, :name => 'workerid'}, - START => {:type => ::Thrift::Types::I64, :name => 'start'}, - RUNAS => {:type => ::Thrift::Types::STRING, :name => 'runAs'} + WORKERID => {:type => ::Thrift::Types::STRING, :name => 'workerid', :optional => true}, + START => {:type => ::Thrift::Types::I64, :name => 'start', :optional => true}, + RUNAS => {:type => ::Thrift::Types::STRING, :name => 'runAs', :optional => true} } def struct_fields; FIELDS; end @@ -1838,12 +1838,8 @@ class ShowCompactResponseElement def validate raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbname is unset!') unless @dbname raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tablename is unset!') unless @tablename - raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field partitionname is unset!') unless @partitionname raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field type is unset!') unless @type raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field state is unset!') unless @state - raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field workerid is unset!') unless @workerid - raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field start is unset!') unless @start - raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field runAs is unset!') unless @runAs unless @type.nil? || ::CompactionType::VALID_VALUES.include?(@type) raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field type!') end