You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by na...@apache.org on 2012/08/25 04:44:25 UTC
svn commit: r1377187 [4/8] - in /hive/trunk:
common/src/java/org/apache/hadoop/hive/conf/ metastore/if/
metastore/scripts/upgrade/derby/ metastore/scripts/upgrade/mysql/
metastore/scripts/upgrade/oracle/ metastore/scripts/upgrade/postgres/
metastore/sr...
Modified: hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp?rev=1377187&r1=1377186&r2=1377187&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp Sat Aug 25 02:44:22 2012
@@ -1253,10 +1253,10 @@ uint32_t Order::write(::apache::thrift::
return xfer;
}
-const char* StorageDescriptor::ascii_fingerprint = "11E4CE18F895C13812C853DFDCD1293F";
-const uint8_t StorageDescriptor::binary_fingerprint[16] = {0x11,0xE4,0xCE,0x18,0xF8,0x95,0xC1,0x38,0x12,0xC8,0x53,0xDF,0xDC,0xD1,0x29,0x3F};
+const char* SkewedInfo::ascii_fingerprint = "4BF2ED84BC3C3EB297A2AE2FA8427EB1";
+const uint8_t SkewedInfo::binary_fingerprint[16] = {0x4B,0xF2,0xED,0x84,0xBC,0x3C,0x3E,0xB2,0x97,0xA2,0xAE,0x2F,0xA8,0x42,0x7E,0xB1};
-uint32_t StorageDescriptor::read(::apache::thrift::protocol::TProtocol* iprot) {
+uint32_t SkewedInfo::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
std::string fname;
@@ -1279,15 +1279,195 @@ uint32_t StorageDescriptor::read(::apach
case 1:
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
- this->cols.clear();
+ this->skewedColNames.clear();
uint32_t _size79;
::apache::thrift::protocol::TType _etype82;
iprot->readListBegin(_etype82, _size79);
- this->cols.resize(_size79);
+ this->skewedColNames.resize(_size79);
uint32_t _i83;
for (_i83 = 0; _i83 < _size79; ++_i83)
{
- xfer += this->cols[_i83].read(iprot);
+ xfer += iprot->readString(this->skewedColNames[_i83]);
+ }
+ iprot->readListEnd();
+ }
+ this->__isset.skewedColNames = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ this->skewedColValues.clear();
+ uint32_t _size84;
+ ::apache::thrift::protocol::TType _etype87;
+ iprot->readListBegin(_etype87, _size84);
+ this->skewedColValues.resize(_size84);
+ uint32_t _i88;
+ for (_i88 = 0; _i88 < _size84; ++_i88)
+ {
+ {
+ this->skewedColValues[_i88].clear();
+ uint32_t _size89;
+ ::apache::thrift::protocol::TType _etype92;
+ iprot->readListBegin(_etype92, _size89);
+ this->skewedColValues[_i88].resize(_size89);
+ uint32_t _i93;
+ for (_i93 = 0; _i93 < _size89; ++_i93)
+ {
+ xfer += iprot->readString(this->skewedColValues[_i88][_i93]);
+ }
+ iprot->readListEnd();
+ }
+ }
+ iprot->readListEnd();
+ }
+ this->__isset.skewedColValues = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_MAP) {
+ {
+ this->skewedColValueLocationMaps.clear();
+ uint32_t _size94;
+ ::apache::thrift::protocol::TType _ktype95;
+ ::apache::thrift::protocol::TType _vtype96;
+ iprot->readMapBegin(_ktype95, _vtype96, _size94);
+ uint32_t _i98;
+ for (_i98 = 0; _i98 < _size94; ++_i98)
+ {
+ std::vector<std::string> _key99;
+ {
+ _key99.clear();
+ uint32_t _size101;
+ ::apache::thrift::protocol::TType _etype104;
+ iprot->readListBegin(_etype104, _size101);
+ _key99.resize(_size101);
+ uint32_t _i105;
+ for (_i105 = 0; _i105 < _size101; ++_i105)
+ {
+ xfer += iprot->readString(_key99[_i105]);
+ }
+ iprot->readListEnd();
+ }
+ std::string& _val100 = this->skewedColValueLocationMaps[_key99];
+ xfer += iprot->readString(_val100);
+ }
+ iprot->readMapEnd();
+ }
+ this->__isset.skewedColValueLocationMaps = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ return xfer;
+}
+
+uint32_t SkewedInfo::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("SkewedInfo");
+ xfer += oprot->writeFieldBegin("skewedColNames", ::apache::thrift::protocol::T_LIST, 1);
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->skewedColNames.size()));
+ std::vector<std::string> ::const_iterator _iter106;
+ for (_iter106 = this->skewedColNames.begin(); _iter106 != this->skewedColNames.end(); ++_iter106)
+ {
+ xfer += oprot->writeString((*_iter106));
+ }
+ xfer += oprot->writeListEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ xfer += oprot->writeFieldBegin("skewedColValues", ::apache::thrift::protocol::T_LIST, 2);
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_LIST, static_cast<uint32_t>(this->skewedColValues.size()));
+ std::vector<std::vector<std::string> > ::const_iterator _iter107;
+ for (_iter107 = this->skewedColValues.begin(); _iter107 != this->skewedColValues.end(); ++_iter107)
+ {
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>((*_iter107).size()));
+ std::vector<std::string> ::const_iterator _iter108;
+ for (_iter108 = (*_iter107).begin(); _iter108 != (*_iter107).end(); ++_iter108)
+ {
+ xfer += oprot->writeString((*_iter108));
+ }
+ xfer += oprot->writeListEnd();
+ }
+ }
+ xfer += oprot->writeListEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ xfer += oprot->writeFieldBegin("skewedColValueLocationMaps", ::apache::thrift::protocol::T_MAP, 3);
+ {
+ xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_LIST, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->skewedColValueLocationMaps.size()));
+ std::map<std::vector<std::string> , std::string> ::const_iterator _iter109;
+ for (_iter109 = this->skewedColValueLocationMaps.begin(); _iter109 != this->skewedColValueLocationMaps.end(); ++_iter109)
+ {
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(_iter109->first.size()));
+ std::vector<std::string> ::const_iterator _iter110;
+ for (_iter110 = _iter109->first.begin(); _iter110 != _iter109->first.end(); ++_iter110)
+ {
+ xfer += oprot->writeString((*_iter110));
+ }
+ xfer += oprot->writeListEnd();
+ }
+ xfer += oprot->writeString(_iter109->second);
+ }
+ xfer += oprot->writeMapEnd();
+ }
+ xfer += oprot->writeFieldEnd();
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+const char* StorageDescriptor::ascii_fingerprint = "BDC4DB93B74677CE1C04198D60E6CB80";
+const uint8_t StorageDescriptor::binary_fingerprint[16] = {0xBD,0xC4,0xDB,0x93,0xB7,0x46,0x77,0xCE,0x1C,0x04,0x19,0x8D,0x60,0xE6,0xCB,0x80};
+
+uint32_t StorageDescriptor::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ this->cols.clear();
+ uint32_t _size111;
+ ::apache::thrift::protocol::TType _etype114;
+ iprot->readListBegin(_etype114, _size111);
+ this->cols.resize(_size111);
+ uint32_t _i115;
+ for (_i115 = 0; _i115 < _size111; ++_i115)
+ {
+ xfer += this->cols[_i115].read(iprot);
}
iprot->readListEnd();
}
@@ -1348,14 +1528,14 @@ uint32_t StorageDescriptor::read(::apach
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->bucketCols.clear();
- uint32_t _size84;
- ::apache::thrift::protocol::TType _etype87;
- iprot->readListBegin(_etype87, _size84);
- this->bucketCols.resize(_size84);
- uint32_t _i88;
- for (_i88 = 0; _i88 < _size84; ++_i88)
+ uint32_t _size116;
+ ::apache::thrift::protocol::TType _etype119;
+ iprot->readListBegin(_etype119, _size116);
+ this->bucketCols.resize(_size116);
+ uint32_t _i120;
+ for (_i120 = 0; _i120 < _size116; ++_i120)
{
- xfer += iprot->readString(this->bucketCols[_i88]);
+ xfer += iprot->readString(this->bucketCols[_i120]);
}
iprot->readListEnd();
}
@@ -1368,14 +1548,14 @@ uint32_t StorageDescriptor::read(::apach
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->sortCols.clear();
- uint32_t _size89;
- ::apache::thrift::protocol::TType _etype92;
- iprot->readListBegin(_etype92, _size89);
- this->sortCols.resize(_size89);
- uint32_t _i93;
- for (_i93 = 0; _i93 < _size89; ++_i93)
+ uint32_t _size121;
+ ::apache::thrift::protocol::TType _etype124;
+ iprot->readListBegin(_etype124, _size121);
+ this->sortCols.resize(_size121);
+ uint32_t _i125;
+ for (_i125 = 0; _i125 < _size121; ++_i125)
{
- xfer += this->sortCols[_i93].read(iprot);
+ xfer += this->sortCols[_i125].read(iprot);
}
iprot->readListEnd();
}
@@ -1388,17 +1568,17 @@ uint32_t StorageDescriptor::read(::apach
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->parameters.clear();
- uint32_t _size94;
- ::apache::thrift::protocol::TType _ktype95;
- ::apache::thrift::protocol::TType _vtype96;
- iprot->readMapBegin(_ktype95, _vtype96, _size94);
- uint32_t _i98;
- for (_i98 = 0; _i98 < _size94; ++_i98)
+ uint32_t _size126;
+ ::apache::thrift::protocol::TType _ktype127;
+ ::apache::thrift::protocol::TType _vtype128;
+ iprot->readMapBegin(_ktype127, _vtype128, _size126);
+ uint32_t _i130;
+ for (_i130 = 0; _i130 < _size126; ++_i130)
{
- std::string _key99;
- xfer += iprot->readString(_key99);
- std::string& _val100 = this->parameters[_key99];
- xfer += iprot->readString(_val100);
+ std::string _key131;
+ xfer += iprot->readString(_key131);
+ std::string& _val132 = this->parameters[_key131];
+ xfer += iprot->readString(_val132);
}
iprot->readMapEnd();
}
@@ -1407,6 +1587,14 @@ uint32_t StorageDescriptor::read(::apach
xfer += iprot->skip(ftype);
}
break;
+ case 11:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->skewedInfo.read(iprot);
+ this->__isset.skewedInfo = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
default:
xfer += iprot->skip(ftype);
break;
@@ -1425,10 +1613,10 @@ uint32_t StorageDescriptor::write(::apac
xfer += oprot->writeFieldBegin("cols", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->cols.size()));
- std::vector<FieldSchema> ::const_iterator _iter101;
- for (_iter101 = this->cols.begin(); _iter101 != this->cols.end(); ++_iter101)
+ std::vector<FieldSchema> ::const_iterator _iter133;
+ for (_iter133 = this->cols.begin(); _iter133 != this->cols.end(); ++_iter133)
{
- xfer += (*_iter101).write(oprot);
+ xfer += (*_iter133).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -1454,10 +1642,10 @@ uint32_t StorageDescriptor::write(::apac
xfer += oprot->writeFieldBegin("bucketCols", ::apache::thrift::protocol::T_LIST, 8);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->bucketCols.size()));
- std::vector<std::string> ::const_iterator _iter102;
- for (_iter102 = this->bucketCols.begin(); _iter102 != this->bucketCols.end(); ++_iter102)
+ std::vector<std::string> ::const_iterator _iter134;
+ for (_iter134 = this->bucketCols.begin(); _iter134 != this->bucketCols.end(); ++_iter134)
{
- xfer += oprot->writeString((*_iter102));
+ xfer += oprot->writeString((*_iter134));
}
xfer += oprot->writeListEnd();
}
@@ -1465,10 +1653,10 @@ uint32_t StorageDescriptor::write(::apac
xfer += oprot->writeFieldBegin("sortCols", ::apache::thrift::protocol::T_LIST, 9);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->sortCols.size()));
- std::vector<Order> ::const_iterator _iter103;
- for (_iter103 = this->sortCols.begin(); _iter103 != this->sortCols.end(); ++_iter103)
+ std::vector<Order> ::const_iterator _iter135;
+ for (_iter135 = this->sortCols.begin(); _iter135 != this->sortCols.end(); ++_iter135)
{
- xfer += (*_iter103).write(oprot);
+ xfer += (*_iter135).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -1476,22 +1664,27 @@ uint32_t StorageDescriptor::write(::apac
xfer += oprot->writeFieldBegin("parameters", ::apache::thrift::protocol::T_MAP, 10);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->parameters.size()));
- std::map<std::string, std::string> ::const_iterator _iter104;
- for (_iter104 = this->parameters.begin(); _iter104 != this->parameters.end(); ++_iter104)
+ std::map<std::string, std::string> ::const_iterator _iter136;
+ for (_iter136 = this->parameters.begin(); _iter136 != this->parameters.end(); ++_iter136)
{
- xfer += oprot->writeString(_iter104->first);
- xfer += oprot->writeString(_iter104->second);
+ xfer += oprot->writeString(_iter136->first);
+ xfer += oprot->writeString(_iter136->second);
}
xfer += oprot->writeMapEnd();
}
xfer += oprot->writeFieldEnd();
+ if (this->__isset.skewedInfo) {
+ xfer += oprot->writeFieldBegin("skewedInfo", ::apache::thrift::protocol::T_STRUCT, 11);
+ xfer += this->skewedInfo.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ }
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
-const char* Table::ascii_fingerprint = "26BE788C09746068A2616712C9262900";
-const uint8_t Table::binary_fingerprint[16] = {0x26,0xBE,0x78,0x8C,0x09,0x74,0x60,0x68,0xA2,0x61,0x67,0x12,0xC9,0x26,0x29,0x00};
+const char* Table::ascii_fingerprint = "F21F7F0ACA98ECCFC83F6605440D007F";
+const uint8_t Table::binary_fingerprint[16] = {0xF2,0x1F,0x7F,0x0A,0xCA,0x98,0xEC,0xCF,0xC8,0x3F,0x66,0x05,0x44,0x0D,0x00,0x7F};
uint32_t Table::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -1573,14 +1766,14 @@ uint32_t Table::read(::apache::thrift::p
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->partitionKeys.clear();
- uint32_t _size105;
- ::apache::thrift::protocol::TType _etype108;
- iprot->readListBegin(_etype108, _size105);
- this->partitionKeys.resize(_size105);
- uint32_t _i109;
- for (_i109 = 0; _i109 < _size105; ++_i109)
+ uint32_t _size137;
+ ::apache::thrift::protocol::TType _etype140;
+ iprot->readListBegin(_etype140, _size137);
+ this->partitionKeys.resize(_size137);
+ uint32_t _i141;
+ for (_i141 = 0; _i141 < _size137; ++_i141)
{
- xfer += this->partitionKeys[_i109].read(iprot);
+ xfer += this->partitionKeys[_i141].read(iprot);
}
iprot->readListEnd();
}
@@ -1593,17 +1786,17 @@ uint32_t Table::read(::apache::thrift::p
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->parameters.clear();
- uint32_t _size110;
- ::apache::thrift::protocol::TType _ktype111;
- ::apache::thrift::protocol::TType _vtype112;
- iprot->readMapBegin(_ktype111, _vtype112, _size110);
- uint32_t _i114;
- for (_i114 = 0; _i114 < _size110; ++_i114)
+ uint32_t _size142;
+ ::apache::thrift::protocol::TType _ktype143;
+ ::apache::thrift::protocol::TType _vtype144;
+ iprot->readMapBegin(_ktype143, _vtype144, _size142);
+ uint32_t _i146;
+ for (_i146 = 0; _i146 < _size142; ++_i146)
{
- std::string _key115;
- xfer += iprot->readString(_key115);
- std::string& _val116 = this->parameters[_key115];
- xfer += iprot->readString(_val116);
+ std::string _key147;
+ xfer += iprot->readString(_key147);
+ std::string& _val148 = this->parameters[_key147];
+ xfer += iprot->readString(_val148);
}
iprot->readMapEnd();
}
@@ -1683,10 +1876,10 @@ uint32_t Table::write(::apache::thrift::
xfer += oprot->writeFieldBegin("partitionKeys", ::apache::thrift::protocol::T_LIST, 8);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->partitionKeys.size()));
- std::vector<FieldSchema> ::const_iterator _iter117;
- for (_iter117 = this->partitionKeys.begin(); _iter117 != this->partitionKeys.end(); ++_iter117)
+ std::vector<FieldSchema> ::const_iterator _iter149;
+ for (_iter149 = this->partitionKeys.begin(); _iter149 != this->partitionKeys.end(); ++_iter149)
{
- xfer += (*_iter117).write(oprot);
+ xfer += (*_iter149).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -1694,11 +1887,11 @@ uint32_t Table::write(::apache::thrift::
xfer += oprot->writeFieldBegin("parameters", ::apache::thrift::protocol::T_MAP, 9);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->parameters.size()));
- std::map<std::string, std::string> ::const_iterator _iter118;
- for (_iter118 = this->parameters.begin(); _iter118 != this->parameters.end(); ++_iter118)
+ std::map<std::string, std::string> ::const_iterator _iter150;
+ for (_iter150 = this->parameters.begin(); _iter150 != this->parameters.end(); ++_iter150)
{
- xfer += oprot->writeString(_iter118->first);
- xfer += oprot->writeString(_iter118->second);
+ xfer += oprot->writeString(_iter150->first);
+ xfer += oprot->writeString(_iter150->second);
}
xfer += oprot->writeMapEnd();
}
@@ -1722,8 +1915,8 @@ uint32_t Table::write(::apache::thrift::
return xfer;
}
-const char* Partition::ascii_fingerprint = "F480E1D1B8AEBDDB37F8E180C0F07395";
-const uint8_t Partition::binary_fingerprint[16] = {0xF4,0x80,0xE1,0xD1,0xB8,0xAE,0xBD,0xDB,0x37,0xF8,0xE1,0x80,0xC0,0xF0,0x73,0x95};
+const char* Partition::ascii_fingerprint = "E5EF1F030CF964C052658DD22257D025";
+const uint8_t Partition::binary_fingerprint[16] = {0xE5,0xEF,0x1F,0x03,0x0C,0xF9,0x64,0xC0,0x52,0x65,0x8D,0xD2,0x22,0x57,0xD0,0x25};
uint32_t Partition::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -1749,14 +1942,14 @@ uint32_t Partition::read(::apache::thrif
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->values.clear();
- uint32_t _size119;
- ::apache::thrift::protocol::TType _etype122;
- iprot->readListBegin(_etype122, _size119);
- this->values.resize(_size119);
- uint32_t _i123;
- for (_i123 = 0; _i123 < _size119; ++_i123)
+ uint32_t _size151;
+ ::apache::thrift::protocol::TType _etype154;
+ iprot->readListBegin(_etype154, _size151);
+ this->values.resize(_size151);
+ uint32_t _i155;
+ for (_i155 = 0; _i155 < _size151; ++_i155)
{
- xfer += iprot->readString(this->values[_i123]);
+ xfer += iprot->readString(this->values[_i155]);
}
iprot->readListEnd();
}
@@ -1809,17 +2002,17 @@ uint32_t Partition::read(::apache::thrif
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->parameters.clear();
- uint32_t _size124;
- ::apache::thrift::protocol::TType _ktype125;
- ::apache::thrift::protocol::TType _vtype126;
- iprot->readMapBegin(_ktype125, _vtype126, _size124);
- uint32_t _i128;
- for (_i128 = 0; _i128 < _size124; ++_i128)
+ uint32_t _size156;
+ ::apache::thrift::protocol::TType _ktype157;
+ ::apache::thrift::protocol::TType _vtype158;
+ iprot->readMapBegin(_ktype157, _vtype158, _size156);
+ uint32_t _i160;
+ for (_i160 = 0; _i160 < _size156; ++_i160)
{
- std::string _key129;
- xfer += iprot->readString(_key129);
- std::string& _val130 = this->parameters[_key129];
- xfer += iprot->readString(_val130);
+ std::string _key161;
+ xfer += iprot->readString(_key161);
+ std::string& _val162 = this->parameters[_key161];
+ xfer += iprot->readString(_val162);
}
iprot->readMapEnd();
}
@@ -1854,10 +2047,10 @@ uint32_t Partition::write(::apache::thri
xfer += oprot->writeFieldBegin("values", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->values.size()));
- std::vector<std::string> ::const_iterator _iter131;
- for (_iter131 = this->values.begin(); _iter131 != this->values.end(); ++_iter131)
+ std::vector<std::string> ::const_iterator _iter163;
+ for (_iter163 = this->values.begin(); _iter163 != this->values.end(); ++_iter163)
{
- xfer += oprot->writeString((*_iter131));
+ xfer += oprot->writeString((*_iter163));
}
xfer += oprot->writeListEnd();
}
@@ -1880,11 +2073,11 @@ uint32_t Partition::write(::apache::thri
xfer += oprot->writeFieldBegin("parameters", ::apache::thrift::protocol::T_MAP, 7);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->parameters.size()));
- std::map<std::string, std::string> ::const_iterator _iter132;
- for (_iter132 = this->parameters.begin(); _iter132 != this->parameters.end(); ++_iter132)
+ std::map<std::string, std::string> ::const_iterator _iter164;
+ for (_iter164 = this->parameters.begin(); _iter164 != this->parameters.end(); ++_iter164)
{
- xfer += oprot->writeString(_iter132->first);
- xfer += oprot->writeString(_iter132->second);
+ xfer += oprot->writeString(_iter164->first);
+ xfer += oprot->writeString(_iter164->second);
}
xfer += oprot->writeMapEnd();
}
@@ -1899,8 +2092,8 @@ uint32_t Partition::write(::apache::thri
return xfer;
}
-const char* Index::ascii_fingerprint = "5FEE4F7E28935B644F207D74459F6A29";
-const uint8_t Index::binary_fingerprint[16] = {0x5F,0xEE,0x4F,0x7E,0x28,0x93,0x5B,0x64,0x4F,0x20,0x7D,0x74,0x45,0x9F,0x6A,0x29};
+const char* Index::ascii_fingerprint = "BA1090E838C806A4F8D8D137C5085EDD";
+const uint8_t Index::binary_fingerprint[16] = {0xBA,0x10,0x90,0xE8,0x38,0xC8,0x06,0xA4,0xF8,0xD8,0xD1,0x37,0xC5,0x08,0x5E,0xDD};
uint32_t Index::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -1990,17 +2183,17 @@ uint32_t Index::read(::apache::thrift::p
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->parameters.clear();
- uint32_t _size133;
- ::apache::thrift::protocol::TType _ktype134;
- ::apache::thrift::protocol::TType _vtype135;
- iprot->readMapBegin(_ktype134, _vtype135, _size133);
- uint32_t _i137;
- for (_i137 = 0; _i137 < _size133; ++_i137)
+ uint32_t _size165;
+ ::apache::thrift::protocol::TType _ktype166;
+ ::apache::thrift::protocol::TType _vtype167;
+ iprot->readMapBegin(_ktype166, _vtype167, _size165);
+ uint32_t _i169;
+ for (_i169 = 0; _i169 < _size165; ++_i169)
{
- std::string _key138;
- xfer += iprot->readString(_key138);
- std::string& _val139 = this->parameters[_key138];
- xfer += iprot->readString(_val139);
+ std::string _key170;
+ xfer += iprot->readString(_key170);
+ std::string& _val171 = this->parameters[_key170];
+ xfer += iprot->readString(_val171);
}
iprot->readMapEnd();
}
@@ -2059,11 +2252,11 @@ uint32_t Index::write(::apache::thrift::
xfer += oprot->writeFieldBegin("parameters", ::apache::thrift::protocol::T_MAP, 9);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->parameters.size()));
- std::map<std::string, std::string> ::const_iterator _iter140;
- for (_iter140 = this->parameters.begin(); _iter140 != this->parameters.end(); ++_iter140)
+ std::map<std::string, std::string> ::const_iterator _iter172;
+ for (_iter172 = this->parameters.begin(); _iter172 != this->parameters.end(); ++_iter172)
{
- xfer += oprot->writeString(_iter140->first);
- xfer += oprot->writeString(_iter140->second);
+ xfer += oprot->writeString(_iter172->first);
+ xfer += oprot->writeString(_iter172->second);
}
xfer += oprot->writeMapEnd();
}
@@ -2103,14 +2296,14 @@ uint32_t Schema::read(::apache::thrift::
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->fieldSchemas.clear();
- uint32_t _size141;
- ::apache::thrift::protocol::TType _etype144;
- iprot->readListBegin(_etype144, _size141);
- this->fieldSchemas.resize(_size141);
- uint32_t _i145;
- for (_i145 = 0; _i145 < _size141; ++_i145)
+ uint32_t _size173;
+ ::apache::thrift::protocol::TType _etype176;
+ iprot->readListBegin(_etype176, _size173);
+ this->fieldSchemas.resize(_size173);
+ uint32_t _i177;
+ for (_i177 = 0; _i177 < _size173; ++_i177)
{
- xfer += this->fieldSchemas[_i145].read(iprot);
+ xfer += this->fieldSchemas[_i177].read(iprot);
}
iprot->readListEnd();
}
@@ -2123,17 +2316,17 @@ uint32_t Schema::read(::apache::thrift::
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->properties.clear();
- uint32_t _size146;
- ::apache::thrift::protocol::TType _ktype147;
- ::apache::thrift::protocol::TType _vtype148;
- iprot->readMapBegin(_ktype147, _vtype148, _size146);
- uint32_t _i150;
- for (_i150 = 0; _i150 < _size146; ++_i150)
+ uint32_t _size178;
+ ::apache::thrift::protocol::TType _ktype179;
+ ::apache::thrift::protocol::TType _vtype180;
+ iprot->readMapBegin(_ktype179, _vtype180, _size178);
+ uint32_t _i182;
+ for (_i182 = 0; _i182 < _size178; ++_i182)
{
- std::string _key151;
- xfer += iprot->readString(_key151);
- std::string& _val152 = this->properties[_key151];
- xfer += iprot->readString(_val152);
+ std::string _key183;
+ xfer += iprot->readString(_key183);
+ std::string& _val184 = this->properties[_key183];
+ xfer += iprot->readString(_val184);
}
iprot->readMapEnd();
}
@@ -2160,10 +2353,10 @@ uint32_t Schema::write(::apache::thrift:
xfer += oprot->writeFieldBegin("fieldSchemas", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast<uint32_t>(this->fieldSchemas.size()));
- std::vector<FieldSchema> ::const_iterator _iter153;
- for (_iter153 = this->fieldSchemas.begin(); _iter153 != this->fieldSchemas.end(); ++_iter153)
+ std::vector<FieldSchema> ::const_iterator _iter185;
+ for (_iter185 = this->fieldSchemas.begin(); _iter185 != this->fieldSchemas.end(); ++_iter185)
{
- xfer += (*_iter153).write(oprot);
+ xfer += (*_iter185).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -2171,11 +2364,11 @@ uint32_t Schema::write(::apache::thrift:
xfer += oprot->writeFieldBegin("properties", ::apache::thrift::protocol::T_MAP, 2);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->properties.size()));
- std::map<std::string, std::string> ::const_iterator _iter154;
- for (_iter154 = this->properties.begin(); _iter154 != this->properties.end(); ++_iter154)
+ std::map<std::string, std::string> ::const_iterator _iter186;
+ for (_iter186 = this->properties.begin(); _iter186 != this->properties.end(); ++_iter186)
{
- xfer += oprot->writeString(_iter154->first);
- xfer += oprot->writeString(_iter154->second);
+ xfer += oprot->writeString(_iter186->first);
+ xfer += oprot->writeString(_iter186->second);
}
xfer += oprot->writeMapEnd();
}
@@ -2212,17 +2405,17 @@ uint32_t EnvironmentContext::read(::apac
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->properties.clear();
- uint32_t _size155;
- ::apache::thrift::protocol::TType _ktype156;
- ::apache::thrift::protocol::TType _vtype157;
- iprot->readMapBegin(_ktype156, _vtype157, _size155);
- uint32_t _i159;
- for (_i159 = 0; _i159 < _size155; ++_i159)
+ uint32_t _size187;
+ ::apache::thrift::protocol::TType _ktype188;
+ ::apache::thrift::protocol::TType _vtype189;
+ iprot->readMapBegin(_ktype188, _vtype189, _size187);
+ uint32_t _i191;
+ for (_i191 = 0; _i191 < _size187; ++_i191)
{
- std::string _key160;
- xfer += iprot->readString(_key160);
- std::string& _val161 = this->properties[_key160];
- xfer += iprot->readString(_val161);
+ std::string _key192;
+ xfer += iprot->readString(_key192);
+ std::string& _val193 = this->properties[_key192];
+ xfer += iprot->readString(_val193);
}
iprot->readMapEnd();
}
@@ -2249,11 +2442,11 @@ uint32_t EnvironmentContext::write(::apa
xfer += oprot->writeFieldBegin("properties", ::apache::thrift::protocol::T_MAP, 1);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast<uint32_t>(this->properties.size()));
- std::map<std::string, std::string> ::const_iterator _iter162;
- for (_iter162 = this->properties.begin(); _iter162 != this->properties.end(); ++_iter162)
+ std::map<std::string, std::string> ::const_iterator _iter194;
+ for (_iter194 = this->properties.begin(); _iter194 != this->properties.end(); ++_iter194)
{
- xfer += oprot->writeString(_iter162->first);
- xfer += oprot->writeString(_iter162->second);
+ xfer += oprot->writeString(_iter194->first);
+ xfer += oprot->writeString(_iter194->second);
}
xfer += oprot->writeMapEnd();
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h?rev=1377187&r1=1377186&r2=1377187&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h Sat Aug 25 02:44:22 2012
@@ -774,8 +774,65 @@ class Order {
};
+typedef struct _SkewedInfo__isset {
+ _SkewedInfo__isset() : skewedColNames(false), skewedColValues(false), skewedColValueLocationMaps(false) {}
+ bool skewedColNames;
+ bool skewedColValues;
+ bool skewedColValueLocationMaps;
+} _SkewedInfo__isset;
+
+class SkewedInfo {
+ public:
+
+ static const char* ascii_fingerprint; // = "4BF2ED84BC3C3EB297A2AE2FA8427EB1";
+ static const uint8_t binary_fingerprint[16]; // = {0x4B,0xF2,0xED,0x84,0xBC,0x3C,0x3E,0xB2,0x97,0xA2,0xAE,0x2F,0xA8,0x42,0x7E,0xB1};
+
+ SkewedInfo() {
+ }
+
+ virtual ~SkewedInfo() throw() {}
+
+ std::vector<std::string> skewedColNames;
+ std::vector<std::vector<std::string> > skewedColValues;
+ std::map<std::vector<std::string> , std::string> skewedColValueLocationMaps;
+
+ _SkewedInfo__isset __isset;
+
+ void __set_skewedColNames(const std::vector<std::string> & val) {
+ skewedColNames = val;
+ }
+
+ void __set_skewedColValues(const std::vector<std::vector<std::string> > & val) {
+ skewedColValues = val;
+ }
+
+ void __set_skewedColValueLocationMaps(const std::map<std::vector<std::string> , std::string> & val) {
+ skewedColValueLocationMaps = val;
+ }
+
+ bool operator == (const SkewedInfo & rhs) const
+ {
+ if (!(skewedColNames == rhs.skewedColNames))
+ return false;
+ if (!(skewedColValues == rhs.skewedColValues))
+ return false;
+ if (!(skewedColValueLocationMaps == rhs.skewedColValueLocationMaps))
+ return false;
+ return true;
+ }
+ bool operator != (const SkewedInfo &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const SkewedInfo & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
typedef struct _StorageDescriptor__isset {
- _StorageDescriptor__isset() : cols(false), location(false), inputFormat(false), outputFormat(false), compressed(false), numBuckets(false), serdeInfo(false), bucketCols(false), sortCols(false), parameters(false) {}
+ _StorageDescriptor__isset() : cols(false), location(false), inputFormat(false), outputFormat(false), compressed(false), numBuckets(false), serdeInfo(false), bucketCols(false), sortCols(false), parameters(false), skewedInfo(false) {}
bool cols;
bool location;
bool inputFormat;
@@ -786,13 +843,14 @@ typedef struct _StorageDescriptor__isset
bool bucketCols;
bool sortCols;
bool parameters;
+ bool skewedInfo;
} _StorageDescriptor__isset;
class StorageDescriptor {
public:
- static const char* ascii_fingerprint; // = "11E4CE18F895C13812C853DFDCD1293F";
- static const uint8_t binary_fingerprint[16]; // = {0x11,0xE4,0xCE,0x18,0xF8,0x95,0xC1,0x38,0x12,0xC8,0x53,0xDF,0xDC,0xD1,0x29,0x3F};
+ static const char* ascii_fingerprint; // = "BDC4DB93B74677CE1C04198D60E6CB80";
+ static const uint8_t binary_fingerprint[16]; // = {0xBD,0xC4,0xDB,0x93,0xB7,0x46,0x77,0xCE,0x1C,0x04,0x19,0x8D,0x60,0xE6,0xCB,0x80};
StorageDescriptor() : location(""), inputFormat(""), outputFormat(""), compressed(0), numBuckets(0) {
}
@@ -809,6 +867,7 @@ class StorageDescriptor {
std::vector<std::string> bucketCols;
std::vector<Order> sortCols;
std::map<std::string, std::string> parameters;
+ SkewedInfo skewedInfo;
_StorageDescriptor__isset __isset;
@@ -852,6 +911,11 @@ class StorageDescriptor {
parameters = val;
}
+ void __set_skewedInfo(const SkewedInfo& val) {
+ skewedInfo = val;
+ __isset.skewedInfo = true;
+ }
+
bool operator == (const StorageDescriptor & rhs) const
{
if (!(cols == rhs.cols))
@@ -874,6 +938,10 @@ class StorageDescriptor {
return false;
if (!(parameters == rhs.parameters))
return false;
+ if (__isset.skewedInfo != rhs.__isset.skewedInfo)
+ return false;
+ else if (__isset.skewedInfo && !(skewedInfo == rhs.skewedInfo))
+ return false;
return true;
}
bool operator != (const StorageDescriptor &rhs) const {
@@ -907,8 +975,8 @@ typedef struct _Table__isset {
class Table {
public:
- static const char* ascii_fingerprint; // = "26BE788C09746068A2616712C9262900";
- static const uint8_t binary_fingerprint[16]; // = {0x26,0xBE,0x78,0x8C,0x09,0x74,0x60,0x68,0xA2,0x61,0x67,0x12,0xC9,0x26,0x29,0x00};
+ static const char* ascii_fingerprint; // = "F21F7F0ACA98ECCFC83F6605440D007F";
+ static const uint8_t binary_fingerprint[16]; // = {0xF2,0x1F,0x7F,0x0A,0xCA,0x98,0xEC,0xCF,0xC8,0x3F,0x66,0x05,0x44,0x0D,0x00,0x7F};
Table() : tableName(""), dbName(""), owner(""), createTime(0), lastAccessTime(0), retention(0), viewOriginalText(""), viewExpandedText(""), tableType("") {
}
@@ -1042,8 +1110,8 @@ typedef struct _Partition__isset {
class Partition {
public:
- static const char* ascii_fingerprint; // = "F480E1D1B8AEBDDB37F8E180C0F07395";
- static const uint8_t binary_fingerprint[16]; // = {0xF4,0x80,0xE1,0xD1,0xB8,0xAE,0xBD,0xDB,0x37,0xF8,0xE1,0x80,0xC0,0xF0,0x73,0x95};
+ static const char* ascii_fingerprint; // = "E5EF1F030CF964C052658DD22257D025";
+ static const uint8_t binary_fingerprint[16]; // = {0xE5,0xEF,0x1F,0x03,0x0C,0xF9,0x64,0xC0,0x52,0x65,0x8D,0xD2,0x22,0x57,0xD0,0x25};
Partition() : dbName(""), tableName(""), createTime(0), lastAccessTime(0) {
}
@@ -1144,8 +1212,8 @@ typedef struct _Index__isset {
class Index {
public:
- static const char* ascii_fingerprint; // = "5FEE4F7E28935B644F207D74459F6A29";
- static const uint8_t binary_fingerprint[16]; // = {0x5F,0xEE,0x4F,0x7E,0x28,0x93,0x5B,0x64,0x4F,0x20,0x7D,0x74,0x45,0x9F,0x6A,0x29};
+ static const char* ascii_fingerprint; // = "BA1090E838C806A4F8D8D137C5085EDD";
+ static const uint8_t binary_fingerprint[16]; // = {0xBA,0x10,0x90,0xE8,0x38,0xC8,0x06,0xA4,0xF8,0xD8,0xD1,0x37,0xC5,0x08,0x5E,0xDD};
Index() : indexName(""), indexHandlerClass(""), dbName(""), origTableName(""), createTime(0), lastAccessTime(0), indexTableName(""), deferredRebuild(0) {
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/EnvironmentContext.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/EnvironmentContext.java?rev=1377187&r1=1377186&r2=1377187&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/EnvironmentContext.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/EnvironmentContext.java Sat Aug 25 02:44:22 2012
@@ -283,15 +283,15 @@ public class EnvironmentContext implemen
case 1: // PROPERTIES
if (field.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map98 = iprot.readMapBegin();
- this.properties = new HashMap<String,String>(2*_map98.size);
- for (int _i99 = 0; _i99 < _map98.size; ++_i99)
+ org.apache.thrift.protocol.TMap _map119 = iprot.readMapBegin();
+ this.properties = new HashMap<String,String>(2*_map119.size);
+ for (int _i120 = 0; _i120 < _map119.size; ++_i120)
{
- String _key100; // required
- String _val101; // required
- _key100 = iprot.readString();
- _val101 = iprot.readString();
- this.properties.put(_key100, _val101);
+ String _key121; // required
+ String _val122; // required
+ _key121 = iprot.readString();
+ _val122 = iprot.readString();
+ this.properties.put(_key121, _val122);
}
iprot.readMapEnd();
}
@@ -316,10 +316,10 @@ public class EnvironmentContext implemen
oprot.writeFieldBegin(PROPERTIES_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.properties.size()));
- for (Map.Entry<String, String> _iter102 : this.properties.entrySet())
+ for (Map.Entry<String, String> _iter123 : this.properties.entrySet())
{
- oprot.writeString(_iter102.getKey());
- oprot.writeString(_iter102.getValue());
+ oprot.writeString(_iter123.getKey());
+ oprot.writeString(_iter123.getValue());
}
oprot.writeMapEnd();
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Index.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Index.java?rev=1377187&r1=1377186&r2=1377187&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Index.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Index.java Sat Aug 25 02:44:22 2012
@@ -1002,15 +1002,15 @@ public class Index implements org.apache
case 9: // PARAMETERS
if (field.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map84 = iprot.readMapBegin();
- this.parameters = new HashMap<String,String>(2*_map84.size);
- for (int _i85 = 0; _i85 < _map84.size; ++_i85)
+ org.apache.thrift.protocol.TMap _map105 = iprot.readMapBegin();
+ this.parameters = new HashMap<String,String>(2*_map105.size);
+ for (int _i106 = 0; _i106 < _map105.size; ++_i106)
{
- String _key86; // required
- String _val87; // required
- _key86 = iprot.readString();
- _val87 = iprot.readString();
- this.parameters.put(_key86, _val87);
+ String _key107; // required
+ String _val108; // required
+ _key107 = iprot.readString();
+ _val108 = iprot.readString();
+ this.parameters.put(_key107, _val108);
}
iprot.readMapEnd();
}
@@ -1079,10 +1079,10 @@ public class Index implements org.apache
oprot.writeFieldBegin(PARAMETERS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.parameters.size()));
- for (Map.Entry<String, String> _iter88 : this.parameters.entrySet())
+ for (Map.Entry<String, String> _iter109 : this.parameters.entrySet())
{
- oprot.writeString(_iter88.getKey());
- oprot.writeString(_iter88.getValue());
+ oprot.writeString(_iter109.getKey());
+ oprot.writeString(_iter109.getValue());
}
oprot.writeMapEnd();
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java?rev=1377187&r1=1377186&r2=1377187&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java Sat Aug 25 02:44:22 2012
@@ -815,13 +815,13 @@ public class Partition implements org.ap
case 1: // VALUES
if (field.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list75 = iprot.readListBegin();
- this.values = new ArrayList<String>(_list75.size);
- for (int _i76 = 0; _i76 < _list75.size; ++_i76)
+ org.apache.thrift.protocol.TList _list96 = iprot.readListBegin();
+ this.values = new ArrayList<String>(_list96.size);
+ for (int _i97 = 0; _i97 < _list96.size; ++_i97)
{
- String _elem77; // required
- _elem77 = iprot.readString();
- this.values.add(_elem77);
+ String _elem98; // required
+ _elem98 = iprot.readString();
+ this.values.add(_elem98);
}
iprot.readListEnd();
}
@@ -870,15 +870,15 @@ public class Partition implements org.ap
case 7: // PARAMETERS
if (field.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map78 = iprot.readMapBegin();
- this.parameters = new HashMap<String,String>(2*_map78.size);
- for (int _i79 = 0; _i79 < _map78.size; ++_i79)
+ org.apache.thrift.protocol.TMap _map99 = iprot.readMapBegin();
+ this.parameters = new HashMap<String,String>(2*_map99.size);
+ for (int _i100 = 0; _i100 < _map99.size; ++_i100)
{
- String _key80; // required
- String _val81; // required
- _key80 = iprot.readString();
- _val81 = iprot.readString();
- this.parameters.put(_key80, _val81);
+ String _key101; // required
+ String _val102; // required
+ _key101 = iprot.readString();
+ _val102 = iprot.readString();
+ this.parameters.put(_key101, _val102);
}
iprot.readMapEnd();
}
@@ -911,9 +911,9 @@ public class Partition implements org.ap
oprot.writeFieldBegin(VALUES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, this.values.size()));
- for (String _iter82 : this.values)
+ for (String _iter103 : this.values)
{
- oprot.writeString(_iter82);
+ oprot.writeString(_iter103);
}
oprot.writeListEnd();
}
@@ -944,10 +944,10 @@ public class Partition implements org.ap
oprot.writeFieldBegin(PARAMETERS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.parameters.size()));
- for (Map.Entry<String, String> _iter83 : this.parameters.entrySet())
+ for (Map.Entry<String, String> _iter104 : this.parameters.entrySet())
{
- oprot.writeString(_iter83.getKey());
- oprot.writeString(_iter83.getValue());
+ oprot.writeString(_iter104.getKey());
+ oprot.writeString(_iter104.getValue());
}
oprot.writeMapEnd();
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Schema.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Schema.java?rev=1377187&r1=1377186&r2=1377187&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Schema.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Schema.java Sat Aug 25 02:44:22 2012
@@ -376,14 +376,14 @@ public class Schema implements org.apach
case 1: // FIELD_SCHEMAS
if (field.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list89 = iprot.readListBegin();
- this.fieldSchemas = new ArrayList<FieldSchema>(_list89.size);
- for (int _i90 = 0; _i90 < _list89.size; ++_i90)
+ org.apache.thrift.protocol.TList _list110 = iprot.readListBegin();
+ this.fieldSchemas = new ArrayList<FieldSchema>(_list110.size);
+ for (int _i111 = 0; _i111 < _list110.size; ++_i111)
{
- FieldSchema _elem91; // required
- _elem91 = new FieldSchema();
- _elem91.read(iprot);
- this.fieldSchemas.add(_elem91);
+ FieldSchema _elem112; // required
+ _elem112 = new FieldSchema();
+ _elem112.read(iprot);
+ this.fieldSchemas.add(_elem112);
}
iprot.readListEnd();
}
@@ -394,15 +394,15 @@ public class Schema implements org.apach
case 2: // PROPERTIES
if (field.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map92 = iprot.readMapBegin();
- this.properties = new HashMap<String,String>(2*_map92.size);
- for (int _i93 = 0; _i93 < _map92.size; ++_i93)
+ org.apache.thrift.protocol.TMap _map113 = iprot.readMapBegin();
+ this.properties = new HashMap<String,String>(2*_map113.size);
+ for (int _i114 = 0; _i114 < _map113.size; ++_i114)
{
- String _key94; // required
- String _val95; // required
- _key94 = iprot.readString();
- _val95 = iprot.readString();
- this.properties.put(_key94, _val95);
+ String _key115; // required
+ String _val116; // required
+ _key115 = iprot.readString();
+ _val116 = iprot.readString();
+ this.properties.put(_key115, _val116);
}
iprot.readMapEnd();
}
@@ -427,9 +427,9 @@ public class Schema implements org.apach
oprot.writeFieldBegin(FIELD_SCHEMAS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.fieldSchemas.size()));
- for (FieldSchema _iter96 : this.fieldSchemas)
+ for (FieldSchema _iter117 : this.fieldSchemas)
{
- _iter96.write(oprot);
+ _iter117.write(oprot);
}
oprot.writeListEnd();
}
@@ -439,10 +439,10 @@ public class Schema implements org.apach
oprot.writeFieldBegin(PROPERTIES_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.properties.size()));
- for (Map.Entry<String, String> _iter97 : this.properties.entrySet())
+ for (Map.Entry<String, String> _iter118 : this.properties.entrySet())
{
- oprot.writeString(_iter97.getKey());
- oprot.writeString(_iter97.getValue());
+ oprot.writeString(_iter118.getKey());
+ oprot.writeString(_iter118.getValue());
}
oprot.writeMapEnd();
}
Added: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java?rev=1377187&view=auto
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java (added)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java Sat Aug 25 02:44:22 2012
@@ -0,0 +1,672 @@
+/**
+ * Autogenerated by Thrift Compiler (0.7.0)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ */
+package org.apache.hadoop.hive.metastore.api;
+
+import org.apache.commons.lang.builder.HashCodeBuilder;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class SkewedInfo implements org.apache.thrift.TBase<SkewedInfo, SkewedInfo._Fields>, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("SkewedInfo");
+
+ private static final org.apache.thrift.protocol.TField SKEWED_COL_NAMES_FIELD_DESC = new org.apache.thrift.protocol.TField("skewedColNames", org.apache.thrift.protocol.TType.LIST, (short)1);
+ private static final org.apache.thrift.protocol.TField SKEWED_COL_VALUES_FIELD_DESC = new org.apache.thrift.protocol.TField("skewedColValues", org.apache.thrift.protocol.TType.LIST, (short)2);
+ private static final org.apache.thrift.protocol.TField SKEWED_COL_VALUE_LOCATION_MAPS_FIELD_DESC = new org.apache.thrift.protocol.TField("skewedColValueLocationMaps", org.apache.thrift.protocol.TType.MAP, (short)3);
+
+ private List<String> skewedColNames; // required
+ private List<List<String>> skewedColValues; // required
+ private Map<List<String>,String> skewedColValueLocationMaps; // required
+
+ /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+ public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ SKEWED_COL_NAMES((short)1, "skewedColNames"),
+ SKEWED_COL_VALUES((short)2, "skewedColValues"),
+ SKEWED_COL_VALUE_LOCATION_MAPS((short)3, "skewedColValueLocationMaps");
+
+ private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+ static {
+ for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ byName.put(field.getFieldName(), field);
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, or null if its not found.
+ */
+ public static _Fields findByThriftId(int fieldId) {
+ switch(fieldId) {
+ case 1: // SKEWED_COL_NAMES
+ return SKEWED_COL_NAMES;
+ case 2: // SKEWED_COL_VALUES
+ return SKEWED_COL_VALUES;
+ case 3: // SKEWED_COL_VALUE_LOCATION_MAPS
+ return SKEWED_COL_VALUE_LOCATION_MAPS;
+ default:
+ return null;
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, throwing an exception
+ * if it is not found.
+ */
+ public static _Fields findByThriftIdOrThrow(int fieldId) {
+ _Fields fields = findByThriftId(fieldId);
+ if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ return fields;
+ }
+
+ /**
+ * Find the _Fields constant that matches name, or null if its not found.
+ */
+ public static _Fields findByName(String name) {
+ return byName.get(name);
+ }
+
+ private final short _thriftId;
+ private final String _fieldName;
+
+ _Fields(short thriftId, String fieldName) {
+ _thriftId = thriftId;
+ _fieldName = fieldName;
+ }
+
+ public short getThriftFieldId() {
+ return _thriftId;
+ }
+
+ public String getFieldName() {
+ return _fieldName;
+ }
+ }
+
+ // isset id assignments
+
+ 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);
+ tmpMap.put(_Fields.SKEWED_COL_NAMES, new org.apache.thrift.meta_data.FieldMetaData("skewedColNames", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
+ tmpMap.put(_Fields.SKEWED_COL_VALUES, new org.apache.thrift.meta_data.FieldMetaData("skewedColValues", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))));
+ tmpMap.put(_Fields.SKEWED_COL_VALUE_LOCATION_MAPS, new org.apache.thrift.meta_data.FieldMetaData("skewedColValueLocationMaps", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)),
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(SkewedInfo.class, metaDataMap);
+ }
+
+ public SkewedInfo() {
+ }
+
+ public SkewedInfo(
+ List<String> skewedColNames,
+ List<List<String>> skewedColValues,
+ Map<List<String>,String> skewedColValueLocationMaps)
+ {
+ this();
+ this.skewedColNames = skewedColNames;
+ this.skewedColValues = skewedColValues;
+ this.skewedColValueLocationMaps = skewedColValueLocationMaps;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public SkewedInfo(SkewedInfo other) {
+ if (other.isSetSkewedColNames()) {
+ List<String> __this__skewedColNames = new ArrayList<String>();
+ for (String other_element : other.skewedColNames) {
+ __this__skewedColNames.add(other_element);
+ }
+ this.skewedColNames = __this__skewedColNames;
+ }
+ if (other.isSetSkewedColValues()) {
+ List<List<String>> __this__skewedColValues = new ArrayList<List<String>>();
+ for (List<String> other_element : other.skewedColValues) {
+ List<String> __this__skewedColValues_copy = new ArrayList<String>();
+ for (String other_element_element : other_element) {
+ __this__skewedColValues_copy.add(other_element_element);
+ }
+ __this__skewedColValues.add(__this__skewedColValues_copy);
+ }
+ this.skewedColValues = __this__skewedColValues;
+ }
+ if (other.isSetSkewedColValueLocationMaps()) {
+ Map<List<String>,String> __this__skewedColValueLocationMaps = new HashMap<List<String>,String>();
+ for (Map.Entry<List<String>, String> other_element : other.skewedColValueLocationMaps.entrySet()) {
+
+ List<String> other_element_key = other_element.getKey();
+ String other_element_value = other_element.getValue();
+
+ List<String> __this__skewedColValueLocationMaps_copy_key = new ArrayList<String>();
+ for (String other_element_key_element : other_element_key) {
+ __this__skewedColValueLocationMaps_copy_key.add(other_element_key_element);
+ }
+
+ String __this__skewedColValueLocationMaps_copy_value = other_element_value;
+
+ __this__skewedColValueLocationMaps.put(__this__skewedColValueLocationMaps_copy_key, __this__skewedColValueLocationMaps_copy_value);
+ }
+ this.skewedColValueLocationMaps = __this__skewedColValueLocationMaps;
+ }
+ }
+
+ public SkewedInfo deepCopy() {
+ return new SkewedInfo(this);
+ }
+
+ @Override
+ public void clear() {
+ this.skewedColNames = null;
+ this.skewedColValues = null;
+ this.skewedColValueLocationMaps = null;
+ }
+
+ public int getSkewedColNamesSize() {
+ return (this.skewedColNames == null) ? 0 : this.skewedColNames.size();
+ }
+
+ public java.util.Iterator<String> getSkewedColNamesIterator() {
+ return (this.skewedColNames == null) ? null : this.skewedColNames.iterator();
+ }
+
+ public void addToSkewedColNames(String elem) {
+ if (this.skewedColNames == null) {
+ this.skewedColNames = new ArrayList<String>();
+ }
+ this.skewedColNames.add(elem);
+ }
+
+ public List<String> getSkewedColNames() {
+ return this.skewedColNames;
+ }
+
+ public void setSkewedColNames(List<String> skewedColNames) {
+ this.skewedColNames = skewedColNames;
+ }
+
+ public void unsetSkewedColNames() {
+ this.skewedColNames = null;
+ }
+
+ /** Returns true if field skewedColNames is set (has been assigned a value) and false otherwise */
+ public boolean isSetSkewedColNames() {
+ return this.skewedColNames != null;
+ }
+
+ public void setSkewedColNamesIsSet(boolean value) {
+ if (!value) {
+ this.skewedColNames = null;
+ }
+ }
+
+ public int getSkewedColValuesSize() {
+ return (this.skewedColValues == null) ? 0 : this.skewedColValues.size();
+ }
+
+ public java.util.Iterator<List<String>> getSkewedColValuesIterator() {
+ return (this.skewedColValues == null) ? null : this.skewedColValues.iterator();
+ }
+
+ public void addToSkewedColValues(List<String> elem) {
+ if (this.skewedColValues == null) {
+ this.skewedColValues = new ArrayList<List<String>>();
+ }
+ this.skewedColValues.add(elem);
+ }
+
+ public List<List<String>> getSkewedColValues() {
+ return this.skewedColValues;
+ }
+
+ public void setSkewedColValues(List<List<String>> skewedColValues) {
+ this.skewedColValues = skewedColValues;
+ }
+
+ public void unsetSkewedColValues() {
+ this.skewedColValues = null;
+ }
+
+ /** Returns true if field skewedColValues is set (has been assigned a value) and false otherwise */
+ public boolean isSetSkewedColValues() {
+ return this.skewedColValues != null;
+ }
+
+ public void setSkewedColValuesIsSet(boolean value) {
+ if (!value) {
+ this.skewedColValues = null;
+ }
+ }
+
+ public int getSkewedColValueLocationMapsSize() {
+ return (this.skewedColValueLocationMaps == null) ? 0 : this.skewedColValueLocationMaps.size();
+ }
+
+ public void putToSkewedColValueLocationMaps(List<String> key, String val) {
+ if (this.skewedColValueLocationMaps == null) {
+ this.skewedColValueLocationMaps = new HashMap<List<String>,String>();
+ }
+ this.skewedColValueLocationMaps.put(key, val);
+ }
+
+ public Map<List<String>,String> getSkewedColValueLocationMaps() {
+ return this.skewedColValueLocationMaps;
+ }
+
+ public void setSkewedColValueLocationMaps(Map<List<String>,String> skewedColValueLocationMaps) {
+ this.skewedColValueLocationMaps = skewedColValueLocationMaps;
+ }
+
+ public void unsetSkewedColValueLocationMaps() {
+ this.skewedColValueLocationMaps = null;
+ }
+
+ /** Returns true if field skewedColValueLocationMaps is set (has been assigned a value) and false otherwise */
+ public boolean isSetSkewedColValueLocationMaps() {
+ return this.skewedColValueLocationMaps != null;
+ }
+
+ public void setSkewedColValueLocationMapsIsSet(boolean value) {
+ if (!value) {
+ this.skewedColValueLocationMaps = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case SKEWED_COL_NAMES:
+ if (value == null) {
+ unsetSkewedColNames();
+ } else {
+ setSkewedColNames((List<String>)value);
+ }
+ break;
+
+ case SKEWED_COL_VALUES:
+ if (value == null) {
+ unsetSkewedColValues();
+ } else {
+ setSkewedColValues((List<List<String>>)value);
+ }
+ break;
+
+ case SKEWED_COL_VALUE_LOCATION_MAPS:
+ if (value == null) {
+ unsetSkewedColValueLocationMaps();
+ } else {
+ setSkewedColValueLocationMaps((Map<List<String>,String>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case SKEWED_COL_NAMES:
+ return getSkewedColNames();
+
+ case SKEWED_COL_VALUES:
+ return getSkewedColValues();
+
+ case SKEWED_COL_VALUE_LOCATION_MAPS:
+ return getSkewedColValueLocationMaps();
+
+ }
+ throw new IllegalStateException();
+ }
+
+ /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
+ public boolean isSet(_Fields field) {
+ if (field == null) {
+ throw new IllegalArgumentException();
+ }
+
+ switch (field) {
+ case SKEWED_COL_NAMES:
+ return isSetSkewedColNames();
+ case SKEWED_COL_VALUES:
+ return isSetSkewedColValues();
+ case SKEWED_COL_VALUE_LOCATION_MAPS:
+ return isSetSkewedColValueLocationMaps();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof SkewedInfo)
+ return this.equals((SkewedInfo)that);
+ return false;
+ }
+
+ public boolean equals(SkewedInfo that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_skewedColNames = true && this.isSetSkewedColNames();
+ boolean that_present_skewedColNames = true && that.isSetSkewedColNames();
+ if (this_present_skewedColNames || that_present_skewedColNames) {
+ if (!(this_present_skewedColNames && that_present_skewedColNames))
+ return false;
+ if (!this.skewedColNames.equals(that.skewedColNames))
+ return false;
+ }
+
+ boolean this_present_skewedColValues = true && this.isSetSkewedColValues();
+ boolean that_present_skewedColValues = true && that.isSetSkewedColValues();
+ if (this_present_skewedColValues || that_present_skewedColValues) {
+ if (!(this_present_skewedColValues && that_present_skewedColValues))
+ return false;
+ if (!this.skewedColValues.equals(that.skewedColValues))
+ return false;
+ }
+
+ boolean this_present_skewedColValueLocationMaps = true && this.isSetSkewedColValueLocationMaps();
+ boolean that_present_skewedColValueLocationMaps = true && that.isSetSkewedColValueLocationMaps();
+ if (this_present_skewedColValueLocationMaps || that_present_skewedColValueLocationMaps) {
+ if (!(this_present_skewedColValueLocationMaps && that_present_skewedColValueLocationMaps))
+ return false;
+ if (!this.skewedColValueLocationMaps.equals(that.skewedColValueLocationMaps))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ HashCodeBuilder builder = new HashCodeBuilder();
+
+ boolean present_skewedColNames = true && (isSetSkewedColNames());
+ builder.append(present_skewedColNames);
+ if (present_skewedColNames)
+ builder.append(skewedColNames);
+
+ boolean present_skewedColValues = true && (isSetSkewedColValues());
+ builder.append(present_skewedColValues);
+ if (present_skewedColValues)
+ builder.append(skewedColValues);
+
+ boolean present_skewedColValueLocationMaps = true && (isSetSkewedColValueLocationMaps());
+ builder.append(present_skewedColValueLocationMaps);
+ if (present_skewedColValueLocationMaps)
+ builder.append(skewedColValueLocationMaps);
+
+ return builder.toHashCode();
+ }
+
+ public int compareTo(SkewedInfo other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+ SkewedInfo typedOther = (SkewedInfo)other;
+
+ lastComparison = Boolean.valueOf(isSetSkewedColNames()).compareTo(typedOther.isSetSkewedColNames());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetSkewedColNames()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.skewedColNames, typedOther.skewedColNames);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetSkewedColValues()).compareTo(typedOther.isSetSkewedColValues());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetSkewedColValues()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.skewedColValues, typedOther.skewedColValues);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetSkewedColValueLocationMaps()).compareTo(typedOther.isSetSkewedColValueLocationMaps());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetSkewedColValueLocationMaps()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.skewedColValueLocationMaps, typedOther.skewedColValueLocationMaps);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ return 0;
+ }
+
+ public _Fields fieldForId(int fieldId) {
+ return _Fields.findByThriftId(fieldId);
+ }
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField field;
+ iprot.readStructBegin();
+ while (true)
+ {
+ field = iprot.readFieldBegin();
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (field.id) {
+ case 1: // SKEWED_COL_NAMES
+ if (field.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list49 = iprot.readListBegin();
+ this.skewedColNames = new ArrayList<String>(_list49.size);
+ for (int _i50 = 0; _i50 < _list49.size; ++_i50)
+ {
+ String _elem51; // required
+ _elem51 = iprot.readString();
+ this.skewedColNames.add(_elem51);
+ }
+ iprot.readListEnd();
+ }
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 2: // SKEWED_COL_VALUES
+ if (field.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list52 = iprot.readListBegin();
+ this.skewedColValues = new ArrayList<List<String>>(_list52.size);
+ for (int _i53 = 0; _i53 < _list52.size; ++_i53)
+ {
+ List<String> _elem54; // required
+ {
+ org.apache.thrift.protocol.TList _list55 = iprot.readListBegin();
+ _elem54 = new ArrayList<String>(_list55.size);
+ for (int _i56 = 0; _i56 < _list55.size; ++_i56)
+ {
+ String _elem57; // required
+ _elem57 = iprot.readString();
+ _elem54.add(_elem57);
+ }
+ iprot.readListEnd();
+ }
+ this.skewedColValues.add(_elem54);
+ }
+ iprot.readListEnd();
+ }
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 3: // SKEWED_COL_VALUE_LOCATION_MAPS
+ if (field.type == org.apache.thrift.protocol.TType.MAP) {
+ {
+ org.apache.thrift.protocol.TMap _map58 = iprot.readMapBegin();
+ this.skewedColValueLocationMaps = new HashMap<List<String>,String>(2*_map58.size);
+ for (int _i59 = 0; _i59 < _map58.size; ++_i59)
+ {
+ List<String> _key60; // required
+ String _val61; // required
+ {
+ org.apache.thrift.protocol.TList _list62 = iprot.readListBegin();
+ _key60 = new ArrayList<String>(_list62.size);
+ for (int _i63 = 0; _i63 < _list62.size; ++_i63)
+ {
+ String _elem64; // required
+ _elem64 = iprot.readString();
+ _key60.add(_elem64);
+ }
+ iprot.readListEnd();
+ }
+ _val61 = iprot.readString();
+ this.skewedColValueLocationMaps.put(_key60, _val61);
+ }
+ iprot.readMapEnd();
+ }
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+ validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (this.skewedColNames != null) {
+ oprot.writeFieldBegin(SKEWED_COL_NAMES_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, this.skewedColNames.size()));
+ for (String _iter65 : this.skewedColNames)
+ {
+ oprot.writeString(_iter65);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ if (this.skewedColValues != null) {
+ oprot.writeFieldBegin(SKEWED_COL_VALUES_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.LIST, this.skewedColValues.size()));
+ for (List<String> _iter66 : this.skewedColValues)
+ {
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, _iter66.size()));
+ for (String _iter67 : _iter66)
+ {
+ oprot.writeString(_iter67);
+ }
+ oprot.writeListEnd();
+ }
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ if (this.skewedColValueLocationMaps != null) {
+ oprot.writeFieldBegin(SKEWED_COL_VALUE_LOCATION_MAPS_FIELD_DESC);
+ {
+ oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.LIST, org.apache.thrift.protocol.TType.STRING, this.skewedColValueLocationMaps.size()));
+ for (Map.Entry<List<String>, String> _iter68 : this.skewedColValueLocationMaps.entrySet())
+ {
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, _iter68.getKey().size()));
+ for (String _iter69 : _iter68.getKey())
+ {
+ oprot.writeString(_iter69);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeString(_iter68.getValue());
+ }
+ oprot.writeMapEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("SkewedInfo(");
+ boolean first = true;
+
+ sb.append("skewedColNames:");
+ if (this.skewedColNames == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.skewedColNames);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("skewedColValues:");
+ if (this.skewedColValues == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.skewedColValues);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("skewedColValueLocationMaps:");
+ if (this.skewedColValueLocationMaps == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.skewedColValueLocationMaps);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+}
+