Author: jdere
Date: Tue Apr 14 20:47:29 2015
New Revision: 1673553
URL: http://svn.apache.org/r1673553
Log:
HIVE-10226: Column stats for Date columns not supported (Jason Dere, reviewed by Ashutosh Chauhan)
Added:
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Date.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DateColumnStatsData.java
hive/trunk/ql/src/test/queries/clientpositive/compute_stats_date.q
hive/trunk/ql/src/test/results/clientpositive/compute_stats_date.q.out
Modified:
hive/trunk/metastore/if/hive_metastore.thrift
hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp
hive/trunk/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsData.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DropPartitionsResult.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FieldSchema.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleResponse.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalResponse.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HiveObjectRef.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionListComposingSpec.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionSpecWithSharedSD.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionWithoutSD.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsByExprResult.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsResult.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PrincipalPrivilegeSet.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PrivilegeBag.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RequestPartsSpec.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Schema.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SerDeInfo.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SetPartitionsStatsRequest.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java
hive/trunk/metastore/src/gen/thrift/gen-php/metastore/Types.php
hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/StatObjectConverter.java
hive/trunk/metastore/src/model/org/apache/hadoop/hive/metastore/model/MPartitionColumnStatistics.java
hive/trunk/metastore/src/model/org/apache/hadoop/hive/metastore/model/MTableColumnStatistics.java
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnStatsTask.java
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnStatsUpdateTask.java
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/metadata/formatting/MetaDataFormatUtils.java
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFComputeStats.java
Modified: hive/trunk/metastore/if/hive_metastore.thrift
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/if/hive_metastore.thrift?rev=1673553&r1=1673552&r2=1673553&view=diff
==============================================================================
--- hive/trunk/metastore/if/hive_metastore.thrift (original)
+++ hive/trunk/metastore/if/hive_metastore.thrift Tue Apr 14 20:47:29 2015
@@ -368,13 +368,25 @@ struct DecimalColumnStatsData {
4: required i64 numDVs
}
+struct Date {
+1: required i64 daysSinceEpoch
+}
+
+struct DateColumnStatsData {
+1: optional Date lowValue,
+2: optional Date highValue,
+3: required i64 numNulls,
+4: required i64 numDVs
+}
+
union ColumnStatisticsData {
1: BooleanColumnStatsData booleanStats,
2: LongColumnStatsData longStats,
3: DoubleColumnStatsData doubleStats,
4: StringColumnStatsData stringStats,
5: BinaryColumnStatsData binaryStats,
-6: DecimalColumnStatsData decimalStats
+6: DecimalColumnStatsData decimalStats,
+7: DateColumnStatsData dateStats
}
struct ColumnStatisticsObj {
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=1673553&r1=1673552&r2=1673553&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 Tue Apr 14 20:47:29 2015
@@ -4697,8 +4697,181 @@ void swap(DecimalColumnStatsData &a, Dec
swap(a.__isset, b.__isset);
}
-const char* ColumnStatisticsData::ascii_fingerprint = "D079ACEA6EE0998D0A45CB65FF1EAADD";
-const uint8_t ColumnStatisticsData::binary_fingerprint[16] = {0xD0,0x79,0xAC,0xEA,0x6E,0xE0,0x99,0x8D,0x0A,0x45,0xCB,0x65,0xFF,0x1E,0xAA,0xDD};
+const char* Date::ascii_fingerprint = "56A59CE7FFAF82BCA8A19FAACDE4FB75";
+const uint8_t Date::binary_fingerprint[16] = {0x56,0xA5,0x9C,0xE7,0xFF,0xAF,0x82,0xBC,0xA8,0xA1,0x9F,0xAA,0xCD,0xE4,0xFB,0x75};
+
+uint32_t Date::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;
+
+ bool isset_daysSinceEpoch = false;
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_I64) {
+ xfer += iprot->readI64(this->daysSinceEpoch);
+ isset_daysSinceEpoch = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_daysSinceEpoch)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t Date::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Date");
+
+ xfer += oprot->writeFieldBegin("daysSinceEpoch", ::apache::thrift::protocol::T_I64, 1);
+ xfer += oprot->writeI64(this->daysSinceEpoch);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+void swap(Date &a, Date &b) {
+ using ::std::swap;
+ swap(a.daysSinceEpoch, b.daysSinceEpoch);
+}
+
+const char* DateColumnStatsData::ascii_fingerprint = "D0719F3BBA8248297BB5287552897F59";
+const uint8_t DateColumnStatsData::binary_fingerprint[16] = {0xD0,0x71,0x9F,0x3B,0xBA,0x82,0x48,0x29,0x7B,0xB5,0x28,0x75,0x52,0x89,0x7F,0x59};
+
+uint32_t DateColumnStatsData::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;
+
+ bool isset_numNulls = false;
+ bool isset_numDVs = false;
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->lowValue.read(iprot);
+ this->__isset.lowValue = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->highValue.read(iprot);
+ this->__isset.highValue = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_I64) {
+ xfer += iprot->readI64(this->numNulls);
+ isset_numNulls = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 4:
+ if (ftype == ::apache::thrift::protocol::T_I64) {
+ xfer += iprot->readI64(this->numDVs);
+ isset_numDVs = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_numNulls)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_numDVs)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t DateColumnStatsData::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("DateColumnStatsData");
+
+ if (this->__isset.lowValue) {
+ xfer += oprot->writeFieldBegin("lowValue", ::apache::thrift::protocol::T_STRUCT, 1);
+ xfer += this->lowValue.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.highValue) {
+ xfer += oprot->writeFieldBegin("highValue", ::apache::thrift::protocol::T_STRUCT, 2);
+ xfer += this->highValue.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ }
+ xfer += oprot->writeFieldBegin("numNulls", ::apache::thrift::protocol::T_I64, 3);
+ xfer += oprot->writeI64(this->numNulls);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("numDVs", ::apache::thrift::protocol::T_I64, 4);
+ xfer += oprot->writeI64(this->numDVs);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+void swap(DateColumnStatsData &a, DateColumnStatsData &b) {
+ using ::std::swap;
+ swap(a.lowValue, b.lowValue);
+ swap(a.highValue, b.highValue);
+ swap(a.numNulls, b.numNulls);
+ swap(a.numDVs, b.numDVs);
+ swap(a.__isset, b.__isset);
+}
+
+const char* ColumnStatisticsData::ascii_fingerprint = "15E449CA15A23E37F2D54C31ACA52106";
+const uint8_t ColumnStatisticsData::binary_fingerprint[16] = {0x15,0xE4,0x49,0xCA,0x15,0xA2,0x3E,0x37,0xF2,0xD5,0x4C,0x31,0xAC,0xA5,0x21,0x06};
uint32_t ColumnStatisticsData::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -4768,6 +4941,14 @@ uint32_t ColumnStatisticsData::read(::ap
xfer += iprot->skip(ftype);
}
break;
+ case 7:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->dateStats.read(iprot);
+ this->__isset.dateStats = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
default:
xfer += iprot->skip(ftype);
break;
@@ -4808,6 +4989,10 @@ uint32_t ColumnStatisticsData::write(::a
xfer += this->decimalStats.write(oprot);
xfer += oprot->writeFieldEnd();
+ xfer += oprot->writeFieldBegin("dateStats", ::apache::thrift::protocol::T_STRUCT, 7);
+ xfer += this->dateStats.write(oprot);
+ xfer += oprot->writeFieldEnd();
+
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
@@ -4821,11 +5006,12 @@ void swap(ColumnStatisticsData &a, Colum
swap(a.stringStats, b.stringStats);
swap(a.binaryStats, b.binaryStats);
swap(a.decimalStats, b.decimalStats);
+ swap(a.dateStats, b.dateStats);
swap(a.__isset, b.__isset);
}
-const char* ColumnStatisticsObj::ascii_fingerprint = "E49E62CFC71682004614EFEDAC3CD3F4";
-const uint8_t ColumnStatisticsObj::binary_fingerprint[16] = {0xE4,0x9E,0x62,0xCF,0xC7,0x16,0x82,0x00,0x46,0x14,0xEF,0xED,0xAC,0x3C,0xD3,0xF4};
+const char* ColumnStatisticsObj::ascii_fingerprint = "A82BA819C9FFEDDEBC0D50F6F4E46534";
+const uint8_t ColumnStatisticsObj::binary_fingerprint[16] = {0xA8,0x2B,0xA8,0x19,0xC9,0xFF,0xED,0xDE,0xBC,0x0D,0x50,0xF6,0xF4,0xE4,0x65,0x34};
uint32_t ColumnStatisticsObj::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -5045,8 +5231,8 @@ void swap(ColumnStatisticsDesc &a, Colum
swap(a.__isset, b.__isset);
}
-const char* ColumnStatistics::ascii_fingerprint = "6682E234199B2CD3807B1ED420C6A7F8";
-const uint8_t ColumnStatistics::binary_fingerprint[16] = {0x66,0x82,0xE2,0x34,0x19,0x9B,0x2C,0xD3,0x80,0x7B,0x1E,0xD4,0x20,0xC6,0xA7,0xF8};
+const char* ColumnStatistics::ascii_fingerprint = "8A64D0A67FFD3A372726A320B3913D5A";
+const uint8_t ColumnStatistics::binary_fingerprint[16] = {0x8A,0x64,0xD0,0xA6,0x7F,0xFD,0x3A,0x37,0x27,0x26,0xA3,0x20,0xB3,0x91,0x3D,0x5A};
uint32_t ColumnStatistics::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -5145,8 +5331,8 @@ void swap(ColumnStatistics &a, ColumnSta
swap(a.statsObj, b.statsObj);
}
-const char* AggrStats::ascii_fingerprint = "399BDBAF7503E0BFB5E1D99C83D790CD";
-const uint8_t AggrStats::binary_fingerprint[16] = {0x39,0x9B,0xDB,0xAF,0x75,0x03,0xE0,0xBF,0xB5,0xE1,0xD9,0x9C,0x83,0xD7,0x90,0xCD};
+const char* AggrStats::ascii_fingerprint = "1FC765A3AB2954591C14B0D946778213";
+const uint8_t AggrStats::binary_fingerprint[16] = {0x1F,0xC7,0x65,0xA3,0xAB,0x29,0x54,0x59,0x1C,0x14,0xB0,0xD9,0x46,0x77,0x82,0x13};
uint32_t AggrStats::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -5245,8 +5431,8 @@ void swap(AggrStats &a, AggrStats &b) {
swap(a.partsFound, b.partsFound);
}
-const char* SetPartitionsStatsRequest::ascii_fingerprint = "635C0DA9A947DA57AAE693A5DFB86569";
-const uint8_t SetPartitionsStatsRequest::binary_fingerprint[16] = {0x63,0x5C,0x0D,0xA9,0xA9,0x47,0xDA,0x57,0xAA,0xE6,0x93,0xA5,0xDF,0xB8,0x65,0x69};
+const char* SetPartitionsStatsRequest::ascii_fingerprint = "8BCBF2CE9E942D0FB7D8F4ED57D8DC27";
+const uint8_t SetPartitionsStatsRequest::binary_fingerprint[16] = {0x8B,0xCB,0xF2,0xCE,0x9E,0x94,0x2D,0x0F,0xB7,0xD8,0xF4,0xED,0x57,0xD8,0xDC,0x27};
uint32_t SetPartitionsStatsRequest::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -5759,8 +5945,8 @@ void swap(PartitionsByExprRequest &a, Pa
swap(a.__isset, b.__isset);
}
-const char* TableStatsResult::ascii_fingerprint = "CE3E8F0D9B310B8D33CB7A89A75F3E05";
-const uint8_t TableStatsResult::binary_fingerprint[16] = {0xCE,0x3E,0x8F,0x0D,0x9B,0x31,0x0B,0x8D,0x33,0xCB,0x7A,0x89,0xA7,0x5F,0x3E,0x05};
+const char* TableStatsResult::ascii_fingerprint = "2E398BAC949C93A194F1A19CA5074FF8";
+const uint8_t TableStatsResult::binary_fingerprint[16] = {0x2E,0x39,0x8B,0xAC,0x94,0x9C,0x93,0xA1,0x94,0xF1,0xA1,0x9C,0xA5,0x07,0x4F,0xF8};
uint32_t TableStatsResult::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -5843,8 +6029,8 @@ void swap(TableStatsResult &a, TableStat
swap(a.tableStats, b.tableStats);
}
-const char* PartitionsStatsResult::ascii_fingerprint = "FF175B50C5EF6F442D3AF25B06435A39";
-const uint8_t PartitionsStatsResult::binary_fingerprint[16] = {0xFF,0x17,0x5B,0x50,0xC5,0xEF,0x6F,0x44,0x2D,0x3A,0xF2,0x5B,0x06,0x43,0x5A,0x39};
+const char* PartitionsStatsResult::ascii_fingerprint = "DD38B4AA7D02E288659AA12CBAAEF33B";
+const uint8_t PartitionsStatsResult::binary_fingerprint[16] = {0xDD,0x38,0xB4,0xAA,0x7D,0x02,0xE2,0x88,0x65,0x9A,0xA1,0x2C,0xBA,0xAE,0xF3,0x3B};
uint32_t PartitionsStatsResult::read(::apache::thrift::protocol::TProtocol* iprot) {
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=1673553&r1=1673552&r2=1673553&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 Tue Apr 14 20:47:29 2015
@@ -2652,21 +2652,130 @@ class DecimalColumnStatsData {
void swap(DecimalColumnStatsData &a, DecimalColumnStatsData &b);
+
+class Date {
+ public:
+
+ static const char* ascii_fingerprint; // = "56A59CE7FFAF82BCA8A19FAACDE4FB75";
+ static const uint8_t binary_fingerprint[16]; // = {0x56,0xA5,0x9C,0xE7,0xFF,0xAF,0x82,0xBC,0xA8,0xA1,0x9F,0xAA,0xCD,0xE4,0xFB,0x75};
+
+ Date() : daysSinceEpoch(0) {
+ }
+
+ virtual ~Date() throw() {}
+
+ int64_t daysSinceEpoch;
+
+ void __set_daysSinceEpoch(const int64_t val) {
+ daysSinceEpoch = val;
+ }
+
+ bool operator == (const Date & rhs) const
+ {
+ if (!(daysSinceEpoch == rhs.daysSinceEpoch))
+ return false;
+ return true;
+ }
+ bool operator != (const Date &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Date & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+void swap(Date &a, Date &b);
+
+typedef struct _DateColumnStatsData__isset {
+ _DateColumnStatsData__isset() : lowValue(false), highValue(false) {}
+ bool lowValue;
+ bool highValue;
+} _DateColumnStatsData__isset;
+
+class DateColumnStatsData {
+ public:
+
+ static const char* ascii_fingerprint; // = "D0719F3BBA8248297BB5287552897F59";
+ static const uint8_t binary_fingerprint[16]; // = {0xD0,0x71,0x9F,0x3B,0xBA,0x82,0x48,0x29,0x7B,0xB5,0x28,0x75,0x52,0x89,0x7F,0x59};
+
+ DateColumnStatsData() : numNulls(0), numDVs(0) {
+ }
+
+ virtual ~DateColumnStatsData() throw() {}
+
+ Date lowValue;
+ Date highValue;
+ int64_t numNulls;
+ int64_t numDVs;
+
+ _DateColumnStatsData__isset __isset;
+
+ void __set_lowValue(const Date& val) {
+ lowValue = val;
+ __isset.lowValue = true;
+ }
+
+ void __set_highValue(const Date& val) {
+ highValue = val;
+ __isset.highValue = true;
+ }
+
+ void __set_numNulls(const int64_t val) {
+ numNulls = val;
+ }
+
+ void __set_numDVs(const int64_t val) {
+ numDVs = val;
+ }
+
+ bool operator == (const DateColumnStatsData & rhs) const
+ {
+ if (__isset.lowValue != rhs.__isset.lowValue)
+ return false;
+ else if (__isset.lowValue && !(lowValue == rhs.lowValue))
+ return false;
+ if (__isset.highValue != rhs.__isset.highValue)
+ return false;
+ else if (__isset.highValue && !(highValue == rhs.highValue))
+ return false;
+ if (!(numNulls == rhs.numNulls))
+ return false;
+ if (!(numDVs == rhs.numDVs))
+ return false;
+ return true;
+ }
+ bool operator != (const DateColumnStatsData &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const DateColumnStatsData & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+void swap(DateColumnStatsData &a, DateColumnStatsData &b);
+
typedef struct _ColumnStatisticsData__isset {
- _ColumnStatisticsData__isset() : booleanStats(false), longStats(false), doubleStats(false), stringStats(false), binaryStats(false), decimalStats(false) {}
+ _ColumnStatisticsData__isset() : booleanStats(false), longStats(false), doubleStats(false), stringStats(false), binaryStats(false), decimalStats(false), dateStats(false) {}
bool booleanStats;
bool longStats;
bool doubleStats;
bool stringStats;
bool binaryStats;
bool decimalStats;
+ bool dateStats;
} _ColumnStatisticsData__isset;
class ColumnStatisticsData {
public:
- static const char* ascii_fingerprint; // = "D079ACEA6EE0998D0A45CB65FF1EAADD";
- static const uint8_t binary_fingerprint[16]; // = {0xD0,0x79,0xAC,0xEA,0x6E,0xE0,0x99,0x8D,0x0A,0x45,0xCB,0x65,0xFF,0x1E,0xAA,0xDD};
+ static const char* ascii_fingerprint; // = "15E449CA15A23E37F2D54C31ACA52106";
+ static const uint8_t binary_fingerprint[16]; // = {0x15,0xE4,0x49,0xCA,0x15,0xA2,0x3E,0x37,0xF2,0xD5,0x4C,0x31,0xAC,0xA5,0x21,0x06};
ColumnStatisticsData() {
}
@@ -2679,6 +2788,7 @@ class ColumnStatisticsData {
StringColumnStatsData stringStats;
BinaryColumnStatsData binaryStats;
DecimalColumnStatsData decimalStats;
+ DateColumnStatsData dateStats;
_ColumnStatisticsData__isset __isset;
@@ -2706,6 +2816,10 @@ class ColumnStatisticsData {
decimalStats = val;
}
+ void __set_dateStats(const DateColumnStatsData& val) {
+ dateStats = val;
+ }
+
bool operator == (const ColumnStatisticsData & rhs) const
{
if (!(booleanStats == rhs.booleanStats))
@@ -2720,6 +2834,8 @@ class ColumnStatisticsData {
return false;
if (!(decimalStats == rhs.decimalStats))
return false;
+ if (!(dateStats == rhs.dateStats))
+ return false;
return true;
}
bool operator != (const ColumnStatisticsData &rhs) const {
@@ -2739,8 +2855,8 @@ void swap(ColumnStatisticsData &a, Colum
class ColumnStatisticsObj {
public:
- static const char* ascii_fingerprint; // = "E49E62CFC71682004614EFEDAC3CD3F4";
- static const uint8_t binary_fingerprint[16]; // = {0xE4,0x9E,0x62,0xCF,0xC7,0x16,0x82,0x00,0x46,0x14,0xEF,0xED,0xAC,0x3C,0xD3,0xF4};
+ static const char* ascii_fingerprint; // = "A82BA819C9FFEDDEBC0D50F6F4E46534";
+ static const uint8_t binary_fingerprint[16]; // = {0xA8,0x2B,0xA8,0x19,0xC9,0xFF,0xED,0xDE,0xBC,0x0D,0x50,0xF6,0xF4,0xE4,0x65,0x34};
ColumnStatisticsObj() : colName(), colType() {
}
@@ -2868,8 +2984,8 @@ void swap(ColumnStatisticsDesc &a, Colum
class ColumnStatistics {
public:
- static const char* ascii_fingerprint; // = "6682E234199B2CD3807B1ED420C6A7F8";
- static const uint8_t binary_fingerprint[16]; // = {0x66,0x82,0xE2,0x34,0x19,0x9B,0x2C,0xD3,0x80,0x7B,0x1E,0xD4,0x20,0xC6,0xA7,0xF8};
+ static const char* ascii_fingerprint; // = "8A64D0A67FFD3A372726A320B3913D5A";
+ static const uint8_t binary_fingerprint[16]; // = {0x8A,0x64,0xD0,0xA6,0x7F,0xFD,0x3A,0x37,0x27,0x26,0xA3,0x20,0xB3,0x91,0x3D,0x5A};
ColumnStatistics() {
}
@@ -2912,8 +3028,8 @@ void swap(ColumnStatistics &a, ColumnSta
class AggrStats {
public:
- static const char* ascii_fingerprint; // = "399BDBAF7503E0BFB5E1D99C83D790CD";
- static const uint8_t binary_fingerprint[16]; // = {0x39,0x9B,0xDB,0xAF,0x75,0x03,0xE0,0xBF,0xB5,0xE1,0xD9,0x9C,0x83,0xD7,0x90,0xCD};
+ static const char* ascii_fingerprint; // = "1FC765A3AB2954591C14B0D946778213";
+ static const uint8_t binary_fingerprint[16]; // = {0x1F,0xC7,0x65,0xA3,0xAB,0x29,0x54,0x59,0x1C,0x14,0xB0,0xD9,0x46,0x77,0x82,0x13};
AggrStats() : partsFound(0) {
}
@@ -2956,8 +3072,8 @@ void swap(AggrStats &a, AggrStats &b);
class SetPartitionsStatsRequest {
public:
- static const char* ascii_fingerprint; // = "635C0DA9A947DA57AAE693A5DFB86569";
- static const uint8_t binary_fingerprint[16]; // = {0x63,0x5C,0x0D,0xA9,0xA9,0x47,0xDA,0x57,0xAA,0xE6,0x93,0xA5,0xDF,0xB8,0x65,0x69};
+ static const char* ascii_fingerprint; // = "8BCBF2CE9E942D0FB7D8F4ED57D8DC27";
+ static const uint8_t binary_fingerprint[16]; // = {0x8B,0xCB,0xF2,0xCE,0x9E,0x94,0x2D,0x0F,0xB7,0xD8,0xF4,0xED,0x57,0xD8,0xDC,0x27};
SetPartitionsStatsRequest() {
}
@@ -3209,8 +3325,8 @@ void swap(PartitionsByExprRequest &a, Pa
class TableStatsResult {
public:
- static const char* ascii_fingerprint; // = "CE3E8F0D9B310B8D33CB7A89A75F3E05";
- static const uint8_t binary_fingerprint[16]; // = {0xCE,0x3E,0x8F,0x0D,0x9B,0x31,0x0B,0x8D,0x33,0xCB,0x7A,0x89,0xA7,0x5F,0x3E,0x05};
+ static const char* ascii_fingerprint; // = "2E398BAC949C93A194F1A19CA5074FF8";
+ static const uint8_t binary_fingerprint[16]; // = {0x2E,0x39,0x8B,0xAC,0x94,0x9C,0x93,0xA1,0x94,0xF1,0xA1,0x9C,0xA5,0x07,0x4F,0xF8};
TableStatsResult() {
}
@@ -3246,8 +3362,8 @@ void swap(TableStatsResult &a, TableStat
class PartitionsStatsResult {
public:
- static const char* ascii_fingerprint; // = "FF175B50C5EF6F442D3AF25B06435A39";
- static const uint8_t binary_fingerprint[16]; // = {0xFF,0x17,0x5B,0x50,0xC5,0xEF,0x6F,0x44,0x2D,0x3A,0xF2,0x5B,0x06,0x43,0x5A,0x39};
+ static const char* ascii_fingerprint; // = "DD38B4AA7D02E288659AA12CBAAEF33B";
+ static const uint8_t binary_fingerprint[16]; // = {0xDD,0x38,0xB4,0xAA,0x7D,0x02,0xE2,0x88,0x65,0x9A,0xA1,0x2C,0xBA,0xAE,0xF3,0x3B};
PartitionsStatsResult() {
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java?rev=1673553&r1=1673552&r2=1673553&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java Tue Apr 14 20:47:29 2015
@@ -633,7 +633,7 @@ public class AddDynamicPartitions implem
struct.partitionnames = new ArrayList<String>(_list492.size);
for (int _i493 = 0; _i493 < _list492.size; ++_i493)
{
- String _elem494; // required
+ String _elem494; // optional
_elem494 = iprot.readString();
struct.partitionnames.add(_elem494);
}
@@ -725,7 +725,7 @@ public class AddDynamicPartitions implem
struct.partitionnames = new ArrayList<String>(_list497.size);
for (int _i498 = 0; _i498 < _list497.size; ++_i498)
{
- String _elem499; // required
+ String _elem499; // optional
_elem499 = iprot.readString();
struct.partitionnames.add(_elem499);
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java?rev=1673553&r1=1673552&r2=1673553&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java Tue Apr 14 20:47:29 2015
@@ -704,7 +704,7 @@ public class AddPartitionsRequest implem
struct.parts = new ArrayList<Partition>(_list388.size);
for (int _i389 = 0; _i389 < _list388.size; ++_i389)
{
- Partition _elem390; // required
+ Partition _elem390; // optional
_elem390 = new Partition();
_elem390.read(iprot);
struct.parts.add(_elem390);
@@ -824,7 +824,7 @@ public class AddPartitionsRequest implem
struct.parts = new ArrayList<Partition>(_list393.size);
for (int _i394 = 0; _i394 < _list393.size; ++_i394)
{
- Partition _elem395; // required
+ Partition _elem395; // optional
_elem395 = new Partition();
_elem395.read(iprot);
struct.parts.add(_elem395);
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java?rev=1673553&r1=1673552&r2=1673553&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java Tue Apr 14 20:47:29 2015
@@ -346,7 +346,7 @@ public class AddPartitionsResult impleme
struct.partitions = new ArrayList<Partition>(_list380.size);
for (int _i381 = 0; _i381 < _list380.size; ++_i381)
{
- Partition _elem382; // required
+ Partition _elem382; // optional
_elem382 = new Partition();
_elem382.read(iprot);
struct.partitions.add(_elem382);
@@ -428,7 +428,7 @@ public class AddPartitionsResult impleme
struct.partitions = new ArrayList<Partition>(_list385.size);
for (int _i386 = 0; _i386 < _list385.size; ++_i386)
{
- Partition _elem387; // required
+ Partition _elem387; // optional
_elem387 = new Partition();
_elem387.read(iprot);
struct.partitions.add(_elem387);
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java?rev=1673553&r1=1673552&r2=1673553&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java Tue Apr 14 20:47:29 2015
@@ -439,7 +439,7 @@ public class AggrStats implements org.ap
struct.colStats = new ArrayList<ColumnStatisticsObj>(_list278.size);
for (int _i279 = 0; _i279 < _list278.size; ++_i279)
{
- ColumnStatisticsObj _elem280; // required
+ ColumnStatisticsObj _elem280; // optional
_elem280 = new ColumnStatisticsObj();
_elem280.read(iprot);
struct.colStats.add(_elem280);
@@ -522,7 +522,7 @@ public class AggrStats implements org.ap
struct.colStats = new ArrayList<ColumnStatisticsObj>(_list283.size);
for (int _i284 = 0; _i284 < _list283.size; ++_i284)
{
- ColumnStatisticsObj _elem285; // required
+ ColumnStatisticsObj _elem285; // optional
_elem285 = new ColumnStatisticsObj();
_elem285.read(iprot);
struct.colStats.add(_elem285);
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java?rev=1673553&r1=1673552&r2=1673553&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java Tue Apr 14 20:47:29 2015
@@ -451,7 +451,7 @@ public class ColumnStatistics implements
struct.statsObj = new ArrayList<ColumnStatisticsObj>(_list270.size);
for (int _i271 = 0; _i271 < _list270.size; ++_i271)
{
- ColumnStatisticsObj _elem272; // required
+ ColumnStatisticsObj _elem272; // optional
_elem272 = new ColumnStatisticsObj();
_elem272.read(iprot);
struct.statsObj.add(_elem272);
@@ -531,7 +531,7 @@ public class ColumnStatistics implements
struct.statsObj = new ArrayList<ColumnStatisticsObj>(_list275.size);
for (int _i276 = 0; _i276 < _list275.size; ++_i276)
{
- ColumnStatisticsObj _elem277; // required
+ ColumnStatisticsObj _elem277; // optional
_elem277 = new ColumnStatisticsObj();
_elem277.read(iprot);
struct.statsObj.add(_elem277);
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsData.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsData.java?rev=1673553&r1=1673552&r2=1673553&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsData.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsData.java Tue Apr 14 20:47:29 2015
@@ -39,6 +39,7 @@ public class ColumnStatisticsData extend
private static final org.apache.thrift.protocol.TField STRING_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("stringStats", org.apache.thrift.protocol.TType.STRUCT, (short)4);
private static final org.apache.thrift.protocol.TField BINARY_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("binaryStats", org.apache.thrift.protocol.TType.STRUCT, (short)5);
private static final org.apache.thrift.protocol.TField DECIMAL_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("decimalStats", org.apache.thrift.protocol.TType.STRUCT, (short)6);
+ private static final org.apache.thrift.protocol.TField DATE_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("dateStats", org.apache.thrift.protocol.TType.STRUCT, (short)7);
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
@@ -47,7 +48,8 @@ public class ColumnStatisticsData extend
DOUBLE_STATS((short)3, "doubleStats"),
STRING_STATS((short)4, "stringStats"),
BINARY_STATS((short)5, "binaryStats"),
- DECIMAL_STATS((short)6, "decimalStats");
+ DECIMAL_STATS((short)6, "decimalStats"),
+ DATE_STATS((short)7, "dateStats");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -74,6 +76,8 @@ public class ColumnStatisticsData extend
return BINARY_STATS;
case 6: // DECIMAL_STATS
return DECIMAL_STATS;
+ case 7: // DATE_STATS
+ return DATE_STATS;
default:
return null;
}
@@ -128,6 +132,8 @@ public class ColumnStatisticsData extend
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, BinaryColumnStatsData.class)));
tmpMap.put(_Fields.DECIMAL_STATS, new org.apache.thrift.meta_data.FieldMetaData("decimalStats", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, DecimalColumnStatsData.class)));
+ tmpMap.put(_Fields.DATE_STATS, new org.apache.thrift.meta_data.FieldMetaData("dateStats", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, DateColumnStatsData.class)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ColumnStatisticsData.class, metaDataMap);
}
@@ -183,6 +189,12 @@ public class ColumnStatisticsData extend
return x;
}
+ public static ColumnStatisticsData dateStats(DateColumnStatsData value) {
+ ColumnStatisticsData x = new ColumnStatisticsData();
+ x.setDateStats(value);
+ return x;
+ }
+
@Override
protected void checkType(_Fields setField, Object value) throws ClassCastException {
@@ -217,6 +229,11 @@ public class ColumnStatisticsData extend
break;
}
throw new ClassCastException("Was expecting value of type DecimalColumnStatsData for field 'decimalStats', but got " + value.getClass().getSimpleName());
+ case DATE_STATS:
+ if (value instanceof DateColumnStatsData) {
+ break;
+ }
+ throw new ClassCastException("Was expecting value of type DateColumnStatsData for field 'dateStats', but got " + value.getClass().getSimpleName());
default:
throw new IllegalArgumentException("Unknown field id " + setField);
}
@@ -287,6 +304,16 @@ public class ColumnStatisticsData extend
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
return null;
}
+ case DATE_STATS:
+ if (field.type == DATE_STATS_FIELD_DESC.type) {
+ DateColumnStatsData dateStats;
+ dateStats = new DateColumnStatsData();
+ dateStats.read(iprot);
+ return dateStats;
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ return null;
+ }
default:
throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
}
@@ -322,6 +349,10 @@ public class ColumnStatisticsData extend
DecimalColumnStatsData decimalStats = (DecimalColumnStatsData)value_;
decimalStats.write(oprot);
return;
+ case DATE_STATS:
+ DateColumnStatsData dateStats = (DateColumnStatsData)value_;
+ dateStats.write(oprot);
+ return;
default:
throw new IllegalStateException("Cannot write union with unknown field " + setField_);
}
@@ -362,6 +393,11 @@ public class ColumnStatisticsData extend
decimalStats = new DecimalColumnStatsData();
decimalStats.read(iprot);
return decimalStats;
+ case DATE_STATS:
+ DateColumnStatsData dateStats;
+ dateStats = new DateColumnStatsData();
+ dateStats.read(iprot);
+ return dateStats;
default:
throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
}
@@ -397,6 +433,10 @@ public class ColumnStatisticsData extend
DecimalColumnStatsData decimalStats = (DecimalColumnStatsData)value_;
decimalStats.write(oprot);
return;
+ case DATE_STATS:
+ DateColumnStatsData dateStats = (DateColumnStatsData)value_;
+ dateStats.write(oprot);
+ return;
default:
throw new IllegalStateException("Cannot write union with unknown field " + setField_);
}
@@ -417,6 +457,8 @@ public class ColumnStatisticsData extend
return BINARY_STATS_FIELD_DESC;
case DECIMAL_STATS:
return DECIMAL_STATS_FIELD_DESC;
+ case DATE_STATS:
+ return DATE_STATS_FIELD_DESC;
default:
throw new IllegalArgumentException("Unknown field id " + setField);
}
@@ -521,6 +563,20 @@ public class ColumnStatisticsData extend
value_ = value;
}
+ public DateColumnStatsData getDateStats() {
+ if (getSetField() == _Fields.DATE_STATS) {
+ return (DateColumnStatsData)getFieldValue();
+ } else {
+ throw new RuntimeException("Cannot get field 'dateStats' because union is currently set to " + getFieldDesc(getSetField()).name);
+ }
+ }
+
+ public void setDateStats(DateColumnStatsData value) {
+ if (value == null) throw new NullPointerException();
+ setField_ = _Fields.DATE_STATS;
+ value_ = value;
+ }
+
public boolean isSetBooleanStats() {
return setField_ == _Fields.BOOLEAN_STATS;
}
@@ -551,6 +607,11 @@ public class ColumnStatisticsData extend
}
+ public boolean isSetDateStats() {
+ return setField_ == _Fields.DATE_STATS;
+ }
+
+
public boolean equals(Object other) {
if (other instanceof ColumnStatisticsData) {
return equals((ColumnStatisticsData)other);
Added: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Date.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Date.java?rev=1673553&view=auto
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Date.java (added)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Date.java Tue Apr 14 20:47:29 2015
@@ -0,0 +1,383 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.0)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.hadoop.hive.metastore.api;
+
+import org.apache.commons.lang.builder.HashCodeBuilder;
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+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 Date implements org.apache.thrift.TBase<Date, Date._Fields>, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Date");
+
+ private static final org.apache.thrift.protocol.TField DAYS_SINCE_EPOCH_FIELD_DESC = new org.apache.thrift.protocol.TField("daysSinceEpoch", org.apache.thrift.protocol.TType.I64, (short)1);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new DateStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new DateTupleSchemeFactory());
+ }
+
+ private long daysSinceEpoch; // 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 {
+ DAYS_SINCE_EPOCH((short)1, "daysSinceEpoch");
+
+ 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: // DAYS_SINCE_EPOCH
+ return DAYS_SINCE_EPOCH;
+ 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
+ private static final int __DAYSSINCEEPOCH_ISSET_ID = 0;
+ private byte __isset_bitfield = 0;
+ 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.DAYS_SINCE_EPOCH, new org.apache.thrift.meta_data.FieldMetaData("daysSinceEpoch", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(Date.class, metaDataMap);
+ }
+
+ public Date() {
+ }
+
+ public Date(
+ long daysSinceEpoch)
+ {
+ this();
+ this.daysSinceEpoch = daysSinceEpoch;
+ setDaysSinceEpochIsSet(true);
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public Date(Date other) {
+ __isset_bitfield = other.__isset_bitfield;
+ this.daysSinceEpoch = other.daysSinceEpoch;
+ }
+
+ public Date deepCopy() {
+ return new Date(this);
+ }
+
+ @Override
+ public void clear() {
+ setDaysSinceEpochIsSet(false);
+ this.daysSinceEpoch = 0;
+ }
+
+ public long getDaysSinceEpoch() {
+ return this.daysSinceEpoch;
+ }
+
+ public void setDaysSinceEpoch(long daysSinceEpoch) {
+ this.daysSinceEpoch = daysSinceEpoch;
+ setDaysSinceEpochIsSet(true);
+ }
+
+ public void unsetDaysSinceEpoch() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __DAYSSINCEEPOCH_ISSET_ID);
+ }
+
+ /** Returns true if field daysSinceEpoch is set (has been assigned a value) and false otherwise */
+ public boolean isSetDaysSinceEpoch() {
+ return EncodingUtils.testBit(__isset_bitfield, __DAYSSINCEEPOCH_ISSET_ID);
+ }
+
+ public void setDaysSinceEpochIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __DAYSSINCEEPOCH_ISSET_ID, value);
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case DAYS_SINCE_EPOCH:
+ if (value == null) {
+ unsetDaysSinceEpoch();
+ } else {
+ setDaysSinceEpoch((Long)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case DAYS_SINCE_EPOCH:
+ return Long.valueOf(getDaysSinceEpoch());
+
+ }
+ 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 DAYS_SINCE_EPOCH:
+ return isSetDaysSinceEpoch();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof Date)
+ return this.equals((Date)that);
+ return false;
+ }
+
+ public boolean equals(Date that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_daysSinceEpoch = true;
+ boolean that_present_daysSinceEpoch = true;
+ if (this_present_daysSinceEpoch || that_present_daysSinceEpoch) {
+ if (!(this_present_daysSinceEpoch && that_present_daysSinceEpoch))
+ return false;
+ if (this.daysSinceEpoch != that.daysSinceEpoch)
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ HashCodeBuilder builder = new HashCodeBuilder();
+
+ boolean present_daysSinceEpoch = true;
+ builder.append(present_daysSinceEpoch);
+ if (present_daysSinceEpoch)
+ builder.append(daysSinceEpoch);
+
+ return builder.toHashCode();
+ }
+
+ public int compareTo(Date other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+ Date typedOther = (Date)other;
+
+ lastComparison = Boolean.valueOf(isSetDaysSinceEpoch()).compareTo(typedOther.isSetDaysSinceEpoch());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetDaysSinceEpoch()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.daysSinceEpoch, typedOther.daysSinceEpoch);
+ 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 {
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("Date(");
+ boolean first = true;
+
+ sb.append("daysSinceEpoch:");
+ sb.append(this.daysSinceEpoch);
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetDaysSinceEpoch()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'daysSinceEpoch' is unset! Struct:" + toString());
+ }
+
+ // check for sub-struct validity
+ }
+
+ 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 {
+ // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+ __isset_bitfield = 0;
+ 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);
+ }
+ }
+
+ private static class DateStandardSchemeFactory implements SchemeFactory {
+ public DateStandardScheme getScheme() {
+ return new DateStandardScheme();
+ }
+ }
+
+ private static class DateStandardScheme extends StandardScheme<Date> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, Date struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // DAYS_SINCE_EPOCH
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.daysSinceEpoch = iprot.readI64();
+ struct.setDaysSinceEpochIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, Date struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ oprot.writeFieldBegin(DAYS_SINCE_EPOCH_FIELD_DESC);
+ oprot.writeI64(struct.daysSinceEpoch);
+ oprot.writeFieldEnd();
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class DateTupleSchemeFactory implements SchemeFactory {
+ public DateTupleScheme getScheme() {
+ return new DateTupleScheme();
+ }
+ }
+
+ private static class DateTupleScheme extends TupleScheme<Date> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, Date struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeI64(struct.daysSinceEpoch);
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, Date struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.daysSinceEpoch = iprot.readI64();
+ struct.setDaysSinceEpochIsSet(true);
+ }
+ }
+
+}
+
Added: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DateColumnStatsData.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DateColumnStatsData.java?rev=1673553&view=auto
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DateColumnStatsData.java (added)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DateColumnStatsData.java Tue Apr 14 20:47:29 2015
@@ -0,0 +1,704 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.0)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.hadoop.hive.metastore.api;
+
+import org.apache.commons.lang.builder.HashCodeBuilder;
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+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 DateColumnStatsData implements org.apache.thrift.TBase<DateColumnStatsData, DateColumnStatsData._Fields>, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("DateColumnStatsData");
+
+ private static final org.apache.thrift.protocol.TField LOW_VALUE_FIELD_DESC = new org.apache.thrift.protocol.TField("lowValue", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+ private static final org.apache.thrift.protocol.TField HIGH_VALUE_FIELD_DESC = new org.apache.thrift.protocol.TField("highValue", org.apache.thrift.protocol.TType.STRUCT, (short)2);
+ private static final org.apache.thrift.protocol.TField NUM_NULLS_FIELD_DESC = new org.apache.thrift.protocol.TField("numNulls", org.apache.thrift.protocol.TType.I64, (short)3);
+ private static final org.apache.thrift.protocol.TField NUM_DVS_FIELD_DESC = new org.apache.thrift.protocol.TField("numDVs", org.apache.thrift.protocol.TType.I64, (short)4);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new DateColumnStatsDataStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new DateColumnStatsDataTupleSchemeFactory());
+ }
+
+ private Date lowValue; // optional
+ private Date highValue; // optional
+ private long numNulls; // required
+ private long numDVs; // 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 {
+ LOW_VALUE((short)1, "lowValue"),
+ HIGH_VALUE((short)2, "highValue"),
+ NUM_NULLS((short)3, "numNulls"),
+ NUM_DVS((short)4, "numDVs");
+
+ 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: // LOW_VALUE
+ return LOW_VALUE;
+ case 2: // HIGH_VALUE
+ return HIGH_VALUE;
+ case 3: // NUM_NULLS
+ return NUM_NULLS;
+ case 4: // NUM_DVS
+ return NUM_DVS;
+ 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
+ private static final int __NUMNULLS_ISSET_ID = 0;
+ private static final int __NUMDVS_ISSET_ID = 1;
+ private byte __isset_bitfield = 0;
+ private _Fields optionals[] = {_Fields.LOW_VALUE,_Fields.HIGH_VALUE};
+ 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.LOW_VALUE, new org.apache.thrift.meta_data.FieldMetaData("lowValue", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Date.class)));
+ tmpMap.put(_Fields.HIGH_VALUE, new org.apache.thrift.meta_data.FieldMetaData("highValue", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Date.class)));
+ tmpMap.put(_Fields.NUM_NULLS, new org.apache.thrift.meta_data.FieldMetaData("numNulls", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+ tmpMap.put(_Fields.NUM_DVS, new org.apache.thrift.meta_data.FieldMetaData("numDVs", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(DateColumnStatsData.class, metaDataMap);
+ }
+
+ public DateColumnStatsData() {
+ }
+
+ public DateColumnStatsData(
+ long numNulls,
+ long numDVs)
+ {
+ this();
+ this.numNulls = numNulls;
+ setNumNullsIsSet(true);
+ this.numDVs = numDVs;
+ setNumDVsIsSet(true);
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public DateColumnStatsData(DateColumnStatsData other) {
+ __isset_bitfield = other.__isset_bitfield;
+ if (other.isSetLowValue()) {
+ this.lowValue = new Date(other.lowValue);
+ }
+ if (other.isSetHighValue()) {
+ this.highValue = new Date(other.highValue);
+ }
+ this.numNulls = other.numNulls;
+ this.numDVs = other.numDVs;
+ }
+
+ public DateColumnStatsData deepCopy() {
+ return new DateColumnStatsData(this);
+ }
+
+ @Override
+ public void clear() {
+ this.lowValue = null;
+ this.highValue = null;
+ setNumNullsIsSet(false);
+ this.numNulls = 0;
+ setNumDVsIsSet(false);
+ this.numDVs = 0;
+ }
+
+ public Date getLowValue() {
+ return this.lowValue;
+ }
+
+ public void setLowValue(Date lowValue) {
+ this.lowValue = lowValue;
+ }
+
+ public void unsetLowValue() {
+ this.lowValue = null;
+ }
+
+ /** Returns true if field lowValue is set (has been assigned a value) and false otherwise */
+ public boolean isSetLowValue() {
+ return this.lowValue != null;
+ }
+
+ public void setLowValueIsSet(boolean value) {
+ if (!value) {
+ this.lowValue = null;
+ }
+ }
+
+ public Date getHighValue() {
+ return this.highValue;
+ }
+
+ public void setHighValue(Date highValue) {
+ this.highValue = highValue;
+ }
+
+ public void unsetHighValue() {
+ this.highValue = null;
+ }
+
+ /** Returns true if field highValue is set (has been assigned a value) and false otherwise */
+ public boolean isSetHighValue() {
+ return this.highValue != null;
+ }
+
+ public void setHighValueIsSet(boolean value) {
+ if (!value) {
+ this.highValue = null;
+ }
+ }
+
+ public long getNumNulls() {
+ return this.numNulls;
+ }
+
+ public void setNumNulls(long numNulls) {
+ this.numNulls = numNulls;
+ setNumNullsIsSet(true);
+ }
+
+ public void unsetNumNulls() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUMNULLS_ISSET_ID);
+ }
+
+ /** Returns true if field numNulls is set (has been assigned a value) and false otherwise */
+ public boolean isSetNumNulls() {
+ return EncodingUtils.testBit(__isset_bitfield, __NUMNULLS_ISSET_ID);
+ }
+
+ public void setNumNullsIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUMNULLS_ISSET_ID, value);
+ }
+
+ public long getNumDVs() {
+ return this.numDVs;
+ }
+
+ public void setNumDVs(long numDVs) {
+ this.numDVs = numDVs;
+ setNumDVsIsSet(true);
+ }
+
+ public void unsetNumDVs() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUMDVS_ISSET_ID);
+ }
+
+ /** Returns true if field numDVs is set (has been assigned a value) and false otherwise */
+ public boolean isSetNumDVs() {
+ return EncodingUtils.testBit(__isset_bitfield, __NUMDVS_ISSET_ID);
+ }
+
+ public void setNumDVsIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUMDVS_ISSET_ID, value);
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case LOW_VALUE:
+ if (value == null) {
+ unsetLowValue();
+ } else {
+ setLowValue((Date)value);
+ }
+ break;
+
+ case HIGH_VALUE:
+ if (value == null) {
+ unsetHighValue();
+ } else {
+ setHighValue((Date)value);
+ }
+ break;
+
+ case NUM_NULLS:
+ if (value == null) {
+ unsetNumNulls();
+ } else {
+ setNumNulls((Long)value);
+ }
+ break;
+
+ case NUM_DVS:
+ if (value == null) {
+ unsetNumDVs();
+ } else {
+ setNumDVs((Long)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case LOW_VALUE:
+ return getLowValue();
+
+ case HIGH_VALUE:
+ return getHighValue();
+
+ case NUM_NULLS:
+ return Long.valueOf(getNumNulls());
+
+ case NUM_DVS:
+ return Long.valueOf(getNumDVs());
+
+ }
+ 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 LOW_VALUE:
+ return isSetLowValue();
+ case HIGH_VALUE:
+ return isSetHighValue();
+ case NUM_NULLS:
+ return isSetNumNulls();
+ case NUM_DVS:
+ return isSetNumDVs();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof DateColumnStatsData)
+ return this.equals((DateColumnStatsData)that);
+ return false;
+ }
+
+ public boolean equals(DateColumnStatsData that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_lowValue = true && this.isSetLowValue();
+ boolean that_present_lowValue = true && that.isSetLowValue();
+ if (this_present_lowValue || that_present_lowValue) {
+ if (!(this_present_lowValue && that_present_lowValue))
+ return false;
+ if (!this.lowValue.equals(that.lowValue))
+ return false;
+ }
+
+ boolean this_present_highValue = true && this.isSetHighValue();
+ boolean that_present_highValue = true && that.isSetHighValue();
+ if (this_present_highValue || that_present_highValue) {
+ if (!(this_present_highValue && that_present_highValue))
+ return false;
+ if (!this.highValue.equals(that.highValue))
+ return false;
+ }
+
+ boolean this_present_numNulls = true;
+ boolean that_present_numNulls = true;
+ if (this_present_numNulls || that_present_numNulls) {
+ if (!(this_present_numNulls && that_present_numNulls))
+ return false;
+ if (this.numNulls != that.numNulls)
+ return false;
+ }
+
+ boolean this_present_numDVs = true;
+ boolean that_present_numDVs = true;
+ if (this_present_numDVs || that_present_numDVs) {
+ if (!(this_present_numDVs && that_present_numDVs))
+ return false;
+ if (this.numDVs != that.numDVs)
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ HashCodeBuilder builder = new HashCodeBuilder();
+
+ boolean present_lowValue = true && (isSetLowValue());
+ builder.append(present_lowValue);
+ if (present_lowValue)
+ builder.append(lowValue);
+
+ boolean present_highValue = true && (isSetHighValue());
+ builder.append(present_highValue);
+ if (present_highValue)
+ builder.append(highValue);
+
+ boolean present_numNulls = true;
+ builder.append(present_numNulls);
+ if (present_numNulls)
+ builder.append(numNulls);
+
+ boolean present_numDVs = true;
+ builder.append(present_numDVs);
+ if (present_numDVs)
+ builder.append(numDVs);
+
+ return builder.toHashCode();
+ }
+
+ public int compareTo(DateColumnStatsData other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+ DateColumnStatsData typedOther = (DateColumnStatsData)other;
+
+ lastComparison = Boolean.valueOf(isSetLowValue()).compareTo(typedOther.isSetLowValue());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetLowValue()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.lowValue, typedOther.lowValue);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetHighValue()).compareTo(typedOther.isSetHighValue());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetHighValue()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.highValue, typedOther.highValue);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetNumNulls()).compareTo(typedOther.isSetNumNulls());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetNumNulls()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.numNulls, typedOther.numNulls);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetNumDVs()).compareTo(typedOther.isSetNumDVs());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetNumDVs()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.numDVs, typedOther.numDVs);
+ 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 {
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("DateColumnStatsData(");
+ boolean first = true;
+
+ if (isSetLowValue()) {
+ sb.append("lowValue:");
+ if (this.lowValue == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.lowValue);
+ }
+ first = false;
+ }
+ if (isSetHighValue()) {
+ if (!first) sb.append(", ");
+ sb.append("highValue:");
+ if (this.highValue == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.highValue);
+ }
+ first = false;
+ }
+ if (!first) sb.append(", ");
+ sb.append("numNulls:");
+ sb.append(this.numNulls);
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("numDVs:");
+ sb.append(this.numDVs);
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetNumNulls()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'numNulls' is unset! Struct:" + toString());
+ }
+
+ if (!isSetNumDVs()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'numDVs' is unset! Struct:" + toString());
+ }
+
+ // check for sub-struct validity
+ if (lowValue != null) {
+ lowValue.validate();
+ }
+ if (highValue != null) {
+ highValue.validate();
+ }
+ }
+
+ 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 {
+ // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+ __isset_bitfield = 0;
+ 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);
+ }
+ }
+
+ private static class DateColumnStatsDataStandardSchemeFactory implements SchemeFactory {
+ public DateColumnStatsDataStandardScheme getScheme() {
+ return new DateColumnStatsDataStandardScheme();
+ }
+ }
+
+ private static class DateColumnStatsDataStandardScheme extends StandardScheme<DateColumnStatsData> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, DateColumnStatsData struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // LOW_VALUE
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.lowValue = new Date();
+ struct.lowValue.read(iprot);
+ struct.setLowValueIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // HIGH_VALUE
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.highValue = new Date();
+ struct.highValue.read(iprot);
+ struct.setHighValueIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // NUM_NULLS
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.numNulls = iprot.readI64();
+ struct.setNumNullsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 4: // NUM_DVS
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.numDVs = iprot.readI64();
+ struct.setNumDVsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, DateColumnStatsData struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.lowValue != null) {
+ if (struct.isSetLowValue()) {
+ oprot.writeFieldBegin(LOW_VALUE_FIELD_DESC);
+ struct.lowValue.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.highValue != null) {
+ if (struct.isSetHighValue()) {
+ oprot.writeFieldBegin(HIGH_VALUE_FIELD_DESC);
+ struct.highValue.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ }
+ oprot.writeFieldBegin(NUM_NULLS_FIELD_DESC);
+ oprot.writeI64(struct.numNulls);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(NUM_DVS_FIELD_DESC);
+ oprot.writeI64(struct.numDVs);
+ oprot.writeFieldEnd();
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class DateColumnStatsDataTupleSchemeFactory implements SchemeFactory {
+ public DateColumnStatsDataTupleScheme getScheme() {
+ return new DateColumnStatsDataTupleScheme();
+ }
+ }
+
+ private static class DateColumnStatsDataTupleScheme extends TupleScheme<DateColumnStatsData> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, DateColumnStatsData struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeI64(struct.numNulls);
+ oprot.writeI64(struct.numDVs);
+ BitSet optionals = new BitSet();
+ if (struct.isSetLowValue()) {
+ optionals.set(0);
+ }
+ if (struct.isSetHighValue()) {
+ optionals.set(1);
+ }
+ oprot.writeBitSet(optionals, 2);
+ if (struct.isSetLowValue()) {
+ struct.lowValue.write(oprot);
+ }
+ if (struct.isSetHighValue()) {
+ struct.highValue.write(oprot);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, DateColumnStatsData struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.numNulls = iprot.readI64();
+ struct.setNumNullsIsSet(true);
+ struct.numDVs = iprot.readI64();
+ struct.setNumDVsIsSet(true);
+ BitSet incoming = iprot.readBitSet(2);
+ if (incoming.get(0)) {
+ struct.lowValue = new Date();
+ struct.lowValue.read(iprot);
+ struct.setLowValueIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.highValue = new Date();
+ struct.highValue.read(iprot);
+ struct.setHighValueIsSet(true);
+ }
+ }
+ }
+
+}
+
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DropPartitionsResult.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DropPartitionsResult.java?rev=1673553&r1=1673552&r2=1673553&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DropPartitionsResult.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DropPartitionsResult.java Tue Apr 14 20:47:29 2015
@@ -346,7 +346,7 @@ public class DropPartitionsResult implem
struct.partitions = new ArrayList<Partition>(_list396.size);
for (int _i397 = 0; _i397 < _list396.size; ++_i397)
{
- Partition _elem398; // required
+ Partition _elem398; // optional
_elem398 = new Partition();
_elem398.read(iprot);
struct.partitions.add(_elem398);
@@ -428,7 +428,7 @@ public class DropPartitionsResult implem
struct.partitions = new ArrayList<Partition>(_list401.size);
for (int _i402 = 0; _i402 < _list401.size; ++_i402)
{
- Partition _elem403; // required
+ Partition _elem403; // optional
_elem403 = new Partition();
_elem403.read(iprot);
struct.partitions.add(_elem403);
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FieldSchema.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FieldSchema.java?rev=1673553&r1=1673552&r2=1673553&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FieldSchema.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FieldSchema.java Tue Apr 14 20:47:29 2015
@@ -135,9 +135,9 @@ public class FieldSchema implements org.
String comment)
{
this();
- this.name = org.apache.hive.common.util.HiveStringUtils.intern(name);
- this.type = org.apache.hive.common.util.HiveStringUtils.intern(type);
- this.comment = org.apache.hive.common.util.HiveStringUtils.intern(comment);
+ this.name = name;
+ this.type = type;
+ this.comment = comment;
}
/**
@@ -145,13 +145,13 @@ public class FieldSchema implements org.
*/
public FieldSchema(FieldSchema other) {
if (other.isSetName()) {
- this.name = org.apache.hive.common.util.HiveStringUtils.intern(other.name);
+ this.name = other.name;
}
if (other.isSetType()) {
- this.type = org.apache.hive.common.util.HiveStringUtils.intern(other.type);
+ this.type = other.type;
}
if (other.isSetComment()) {
- this.comment = org.apache.hive.common.util.HiveStringUtils.intern(other.comment);
+ this.comment = other.comment;
}
}
@@ -171,7 +171,7 @@ public class FieldSchema implements org.
}
public void setName(String name) {
- this.name = org.apache.hive.common.util.HiveStringUtils.intern(name);
+ this.name = name;
}
public void unsetName() {
@@ -194,7 +194,7 @@ public class FieldSchema implements org.
}
public void setType(String type) {
- this.type = org.apache.hive.common.util.HiveStringUtils.intern(type);
+ this.type = type;
}
public void unsetType() {
@@ -217,7 +217,7 @@ public class FieldSchema implements org.
}
public void setComment(String comment) {
- this.comment = org.apache.hive.common.util.HiveStringUtils.intern(comment);
+ this.comment = comment;
}
public void unsetComment() {
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java?rev=1673553&r1=1673552&r2=1673553&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java Tue Apr 14 20:47:29 2015
@@ -716,7 +716,7 @@ public class FireEventRequest implements
struct.partitionVals = new ArrayList<String>(_list516.size);
for (int _i517 = 0; _i517 < _list516.size; ++_i517)
{
- String _elem518; // required
+ String _elem518; // optional
_elem518 = iprot.readString();
struct.partitionVals.add(_elem518);
}
@@ -846,7 +846,7 @@ public class FireEventRequest implements
struct.partitionVals = new ArrayList<String>(_list521.size);
for (int _i522 = 0; _i522 < _list521.size; ++_i522)
{
- String _elem523; // required
+ String _elem523; // optional
_elem523 = iprot.readString();
struct.partitionVals.add(_elem523);
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java?rev=1673553&r1=1673552&r2=1673553&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java Tue Apr 14 20:47:29 2015
@@ -997,7 +997,7 @@ public class Function implements org.apa
struct.resourceUris = new ArrayList<ResourceUri>(_list420.size);
for (int _i421 = 0; _i421 < _list420.size; ++_i421)
{
- ResourceUri _elem422; // required
+ ResourceUri _elem422; // optional
_elem422 = new ResourceUri();
_elem422.read(iprot);
struct.resourceUris.add(_elem422);
@@ -1180,7 +1180,7 @@ public class Function implements org.apa
struct.resourceUris = new ArrayList<ResourceUri>(_list425.size);
for (int _i426 = 0; _i426 < _list425.size; ++_i426)
{
- ResourceUri _elem427; // required
+ ResourceUri _elem427; // optional
_elem427 = new ResourceUri();
_elem427.read(iprot);
struct.resourceUris.add(_elem427);
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java?rev=1673553&r1=1673552&r2=1673553&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java Tue Apr 14 20:47:29 2015
@@ -447,7 +447,7 @@ public class GetOpenTxnsInfoResponse imp
struct.open_txns = new ArrayList<TxnInfo>(_list428.size);
for (int _i429 = 0; _i429 < _list428.size; ++_i429)
{
- TxnInfo _elem430; // required
+ TxnInfo _elem430; // optional
_elem430 = new TxnInfo();
_elem430.read(iprot);
struct.open_txns.add(_elem430);
@@ -524,7 +524,7 @@ public class GetOpenTxnsInfoResponse imp
struct.open_txns = new ArrayList<TxnInfo>(_list433.size);
for (int _i434 = 0; _i434 < _list433.size; ++_i434)
{
- TxnInfo _elem435; // required
+ TxnInfo _elem435; // optional
_elem435 = new TxnInfo();
_elem435.read(iprot);
struct.open_txns.add(_elem435);
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java?rev=1673553&r1=1673552&r2=1673553&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java Tue Apr 14 20:47:29 2015
@@ -447,7 +447,7 @@ public class GetOpenTxnsResponse impleme
struct.open_txns = new HashSet<Long>(2*_set436.size);
for (int _i437 = 0; _i437 < _set436.size; ++_i437)
{
- long _elem438; // required
+ long _elem438; // optional
_elem438 = iprot.readI64();
struct.open_txns.add(_elem438);
}
@@ -523,7 +523,7 @@ public class GetOpenTxnsResponse impleme
struct.open_txns = new HashSet<Long>(2*_set441.size);
for (int _i442 = 0; _i442 < _set441.size; ++_i442)
{
- long _elem443; // required
+ long _elem443; // optional
_elem443 = iprot.readI64();
struct.open_txns.add(_elem443);
}