You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by sa...@apache.org on 2019/01/29 14:46:48 UTC
[08/11] hive git commit: HIVE-21079: Replicate column statistics for
partitions of partitioned table (Ashutosh Bapat, reviewed by Sankar Hariappan)
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
index 663f7d0..acac747 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
@@ -689,14 +689,14 @@ import org.slf4j.LoggerFactory;
case 1: // COMPONENT
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list674 = iprot.readListBegin();
- struct.component = new ArrayList<LockComponent>(_list674.size);
- LockComponent _elem675;
- for (int _i676 = 0; _i676 < _list674.size; ++_i676)
+ org.apache.thrift.protocol.TList _list690 = iprot.readListBegin();
+ struct.component = new ArrayList<LockComponent>(_list690.size);
+ LockComponent _elem691;
+ for (int _i692 = 0; _i692 < _list690.size; ++_i692)
{
- _elem675 = new LockComponent();
- _elem675.read(iprot);
- struct.component.add(_elem675);
+ _elem691 = new LockComponent();
+ _elem691.read(iprot);
+ struct.component.add(_elem691);
}
iprot.readListEnd();
}
@@ -754,9 +754,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(COMPONENT_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.component.size()));
- for (LockComponent _iter677 : struct.component)
+ for (LockComponent _iter693 : struct.component)
{
- _iter677.write(oprot);
+ _iter693.write(oprot);
}
oprot.writeListEnd();
}
@@ -803,9 +803,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.component.size());
- for (LockComponent _iter678 : struct.component)
+ for (LockComponent _iter694 : struct.component)
{
- _iter678.write(oprot);
+ _iter694.write(oprot);
}
}
oprot.writeString(struct.user);
@@ -830,14 +830,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, LockRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list679 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.component = new ArrayList<LockComponent>(_list679.size);
- LockComponent _elem680;
- for (int _i681 = 0; _i681 < _list679.size; ++_i681)
+ org.apache.thrift.protocol.TList _list695 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.component = new ArrayList<LockComponent>(_list695.size);
+ LockComponent _elem696;
+ for (int _i697 = 0; _i697 < _list695.size; ++_i697)
{
- _elem680 = new LockComponent();
- _elem680.read(iprot);
- struct.component.add(_elem680);
+ _elem696 = new LockComponent();
+ _elem696.read(iprot);
+ struct.component.add(_elem696);
}
}
struct.setComponentIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventRequest.java
index 288c365..d5c19e1 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventRequest.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventRequest.java
@@ -525,13 +525,13 @@ import org.slf4j.LoggerFactory;
case 3: // EVENT_TYPE_SKIP_LIST
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list740 = iprot.readListBegin();
- struct.eventTypeSkipList = new ArrayList<String>(_list740.size);
- String _elem741;
- for (int _i742 = 0; _i742 < _list740.size; ++_i742)
+ org.apache.thrift.protocol.TList _list756 = iprot.readListBegin();
+ struct.eventTypeSkipList = new ArrayList<String>(_list756.size);
+ String _elem757;
+ for (int _i758 = 0; _i758 < _list756.size; ++_i758)
{
- _elem741 = iprot.readString();
- struct.eventTypeSkipList.add(_elem741);
+ _elem757 = iprot.readString();
+ struct.eventTypeSkipList.add(_elem757);
}
iprot.readListEnd();
}
@@ -566,9 +566,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(EVENT_TYPE_SKIP_LIST_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.eventTypeSkipList.size()));
- for (String _iter743 : struct.eventTypeSkipList)
+ for (String _iter759 : struct.eventTypeSkipList)
{
- oprot.writeString(_iter743);
+ oprot.writeString(_iter759);
}
oprot.writeListEnd();
}
@@ -607,9 +607,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetEventTypeSkipList()) {
{
oprot.writeI32(struct.eventTypeSkipList.size());
- for (String _iter744 : struct.eventTypeSkipList)
+ for (String _iter760 : struct.eventTypeSkipList)
{
- oprot.writeString(_iter744);
+ oprot.writeString(_iter760);
}
}
}
@@ -627,13 +627,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list745 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.eventTypeSkipList = new ArrayList<String>(_list745.size);
- String _elem746;
- for (int _i747 = 0; _i747 < _list745.size; ++_i747)
+ org.apache.thrift.protocol.TList _list761 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.eventTypeSkipList = new ArrayList<String>(_list761.size);
+ String _elem762;
+ for (int _i763 = 0; _i763 < _list761.size; ++_i763)
{
- _elem746 = iprot.readString();
- struct.eventTypeSkipList.add(_elem746);
+ _elem762 = iprot.readString();
+ struct.eventTypeSkipList.add(_elem762);
}
}
struct.setEventTypeSkipListIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
index b86f038..1f2776b 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // EVENTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list748 = iprot.readListBegin();
- struct.events = new ArrayList<NotificationEvent>(_list748.size);
- NotificationEvent _elem749;
- for (int _i750 = 0; _i750 < _list748.size; ++_i750)
+ org.apache.thrift.protocol.TList _list764 = iprot.readListBegin();
+ struct.events = new ArrayList<NotificationEvent>(_list764.size);
+ NotificationEvent _elem765;
+ for (int _i766 = 0; _i766 < _list764.size; ++_i766)
{
- _elem749 = new NotificationEvent();
- _elem749.read(iprot);
- struct.events.add(_elem749);
+ _elem765 = new NotificationEvent();
+ _elem765.read(iprot);
+ struct.events.add(_elem765);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(EVENTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.events.size()));
- for (NotificationEvent _iter751 : struct.events)
+ for (NotificationEvent _iter767 : struct.events)
{
- _iter751.write(oprot);
+ _iter767.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.events.size());
- for (NotificationEvent _iter752 : struct.events)
+ for (NotificationEvent _iter768 : struct.events)
{
- _iter752.write(oprot);
+ _iter768.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, NotificationEventResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list753 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.events = new ArrayList<NotificationEvent>(_list753.size);
- NotificationEvent _elem754;
- for (int _i755 = 0; _i755 < _list753.size; ++_i755)
+ org.apache.thrift.protocol.TList _list769 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.events = new ArrayList<NotificationEvent>(_list769.size);
+ NotificationEvent _elem770;
+ for (int _i771 = 0; _i771 < _list769.size; ++_i771)
{
- _elem754 = new NotificationEvent();
- _elem754.read(iprot);
- struct.events.add(_elem754);
+ _elem770 = new NotificationEvent();
+ _elem770.read(iprot);
+ struct.events.add(_elem770);
}
}
struct.setEventsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnRequest.java
index b5efffd..a8fd4b7 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnRequest.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnRequest.java
@@ -904,13 +904,13 @@ import org.slf4j.LoggerFactory;
case 6: // REPL_SRC_TXN_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list578 = iprot.readListBegin();
- struct.replSrcTxnIds = new ArrayList<Long>(_list578.size);
- long _elem579;
- for (int _i580 = 0; _i580 < _list578.size; ++_i580)
+ org.apache.thrift.protocol.TList _list594 = iprot.readListBegin();
+ struct.replSrcTxnIds = new ArrayList<Long>(_list594.size);
+ long _elem595;
+ for (int _i596 = 0; _i596 < _list594.size; ++_i596)
{
- _elem579 = iprot.readI64();
- struct.replSrcTxnIds.add(_elem579);
+ _elem595 = iprot.readI64();
+ struct.replSrcTxnIds.add(_elem595);
}
iprot.readListEnd();
}
@@ -972,9 +972,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(REPL_SRC_TXN_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.replSrcTxnIds.size()));
- for (long _iter581 : struct.replSrcTxnIds)
+ for (long _iter597 : struct.replSrcTxnIds)
{
- oprot.writeI64(_iter581);
+ oprot.writeI64(_iter597);
}
oprot.writeListEnd();
}
@@ -1031,9 +1031,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetReplSrcTxnIds()) {
{
oprot.writeI32(struct.replSrcTxnIds.size());
- for (long _iter582 : struct.replSrcTxnIds)
+ for (long _iter598 : struct.replSrcTxnIds)
{
- oprot.writeI64(_iter582);
+ oprot.writeI64(_iter598);
}
}
}
@@ -1062,13 +1062,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list583 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.replSrcTxnIds = new ArrayList<Long>(_list583.size);
- long _elem584;
- for (int _i585 = 0; _i585 < _list583.size; ++_i585)
+ org.apache.thrift.protocol.TList _list599 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.replSrcTxnIds = new ArrayList<Long>(_list599.size);
+ long _elem600;
+ for (int _i601 = 0; _i601 < _list599.size; ++_i601)
{
- _elem584 = iprot.readI64();
- struct.replSrcTxnIds.add(_elem584);
+ _elem600 = iprot.readI64();
+ struct.replSrcTxnIds.add(_elem600);
}
}
struct.setReplSrcTxnIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java
index 71a2c4f..f0e6bdb 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java
@@ -351,13 +351,13 @@ import org.slf4j.LoggerFactory;
case 1: // TXN_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list586 = iprot.readListBegin();
- struct.txn_ids = new ArrayList<Long>(_list586.size);
- long _elem587;
- for (int _i588 = 0; _i588 < _list586.size; ++_i588)
+ org.apache.thrift.protocol.TList _list602 = iprot.readListBegin();
+ struct.txn_ids = new ArrayList<Long>(_list602.size);
+ long _elem603;
+ for (int _i604 = 0; _i604 < _list602.size; ++_i604)
{
- _elem587 = iprot.readI64();
- struct.txn_ids.add(_elem587);
+ _elem603 = iprot.readI64();
+ struct.txn_ids.add(_elem603);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TXN_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.txn_ids.size()));
- for (long _iter589 : struct.txn_ids)
+ for (long _iter605 : struct.txn_ids)
{
- oprot.writeI64(_iter589);
+ oprot.writeI64(_iter605);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.txn_ids.size());
- for (long _iter590 : struct.txn_ids)
+ for (long _iter606 : struct.txn_ids)
{
- oprot.writeI64(_iter590);
+ oprot.writeI64(_iter606);
}
}
}
@@ -421,13 +421,13 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, OpenTxnsResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list591 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.txn_ids = new ArrayList<Long>(_list591.size);
- long _elem592;
- for (int _i593 = 0; _i593 < _list591.size; ++_i593)
+ org.apache.thrift.protocol.TList _list607 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.txn_ids = new ArrayList<Long>(_list607.size);
+ long _elem608;
+ for (int _i609 = 0; _i609 < _list607.size; ++_i609)
{
- _elem592 = iprot.readI64();
- struct.txn_ids.add(_elem592);
+ _elem608 = iprot.readI64();
+ struct.txn_ids.add(_elem608);
}
}
struct.setTxn_idsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java
index 0156a9a..a191255 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java
@@ -49,6 +49,7 @@ import org.slf4j.LoggerFactory;
private static final org.apache.thrift.protocol.TField CAT_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("catName", org.apache.thrift.protocol.TType.STRING, (short)9);
private static final org.apache.thrift.protocol.TField WRITE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("writeId", org.apache.thrift.protocol.TType.I64, (short)10);
private static final org.apache.thrift.protocol.TField IS_STATS_COMPLIANT_FIELD_DESC = new org.apache.thrift.protocol.TField("isStatsCompliant", org.apache.thrift.protocol.TType.BOOL, (short)11);
+ private static final org.apache.thrift.protocol.TField COL_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("colStats", org.apache.thrift.protocol.TType.STRUCT, (short)12);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
@@ -67,6 +68,7 @@ import org.slf4j.LoggerFactory;
private String catName; // optional
private long writeId; // optional
private boolean isStatsCompliant; // optional
+ private ColumnStatistics colStats; // optional
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
@@ -80,7 +82,8 @@ import org.slf4j.LoggerFactory;
PRIVILEGES((short)8, "privileges"),
CAT_NAME((short)9, "catName"),
WRITE_ID((short)10, "writeId"),
- IS_STATS_COMPLIANT((short)11, "isStatsCompliant");
+ IS_STATS_COMPLIANT((short)11, "isStatsCompliant"),
+ COL_STATS((short)12, "colStats");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -117,6 +120,8 @@ import org.slf4j.LoggerFactory;
return WRITE_ID;
case 11: // IS_STATS_COMPLIANT
return IS_STATS_COMPLIANT;
+ case 12: // COL_STATS
+ return COL_STATS;
default:
return null;
}
@@ -162,7 +167,7 @@ import org.slf4j.LoggerFactory;
private static final int __WRITEID_ISSET_ID = 2;
private static final int __ISSTATSCOMPLIANT_ISSET_ID = 3;
private byte __isset_bitfield = 0;
- private static final _Fields optionals[] = {_Fields.PRIVILEGES,_Fields.CAT_NAME,_Fields.WRITE_ID,_Fields.IS_STATS_COMPLIANT};
+ private static final _Fields optionals[] = {_Fields.PRIVILEGES,_Fields.CAT_NAME,_Fields.WRITE_ID,_Fields.IS_STATS_COMPLIANT,_Fields.COL_STATS};
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);
@@ -191,6 +196,8 @@ import org.slf4j.LoggerFactory;
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.IS_STATS_COMPLIANT, new org.apache.thrift.meta_data.FieldMetaData("isStatsCompliant", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
+ tmpMap.put(_Fields.COL_STATS, new org.apache.thrift.meta_data.FieldMetaData("colStats", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT , "ColumnStatistics")));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(Partition.class, metaDataMap);
}
@@ -253,6 +260,9 @@ import org.slf4j.LoggerFactory;
}
this.writeId = other.writeId;
this.isStatsCompliant = other.isStatsCompliant;
+ if (other.isSetColStats()) {
+ this.colStats = other.colStats;
+ }
}
public Partition deepCopy() {
@@ -276,6 +286,7 @@ import org.slf4j.LoggerFactory;
setIsStatsCompliantIsSet(false);
this.isStatsCompliant = false;
+ this.colStats = null;
}
public int getValuesSize() {
@@ -553,6 +564,29 @@ import org.slf4j.LoggerFactory;
__isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ISSTATSCOMPLIANT_ISSET_ID, value);
}
+ public ColumnStatistics getColStats() {
+ return this.colStats;
+ }
+
+ public void setColStats(ColumnStatistics colStats) {
+ this.colStats = colStats;
+ }
+
+ public void unsetColStats() {
+ this.colStats = null;
+ }
+
+ /** Returns true if field colStats is set (has been assigned a value) and false otherwise */
+ public boolean isSetColStats() {
+ return this.colStats != null;
+ }
+
+ public void setColStatsIsSet(boolean value) {
+ if (!value) {
+ this.colStats = null;
+ }
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case VALUES:
@@ -643,6 +677,14 @@ import org.slf4j.LoggerFactory;
}
break;
+ case COL_STATS:
+ if (value == null) {
+ unsetColStats();
+ } else {
+ setColStats((ColumnStatistics)value);
+ }
+ break;
+
}
}
@@ -681,6 +723,9 @@ import org.slf4j.LoggerFactory;
case IS_STATS_COMPLIANT:
return isIsStatsCompliant();
+ case COL_STATS:
+ return getColStats();
+
}
throw new IllegalStateException();
}
@@ -714,6 +759,8 @@ import org.slf4j.LoggerFactory;
return isSetWriteId();
case IS_STATS_COMPLIANT:
return isSetIsStatsCompliant();
+ case COL_STATS:
+ return isSetColStats();
}
throw new IllegalStateException();
}
@@ -830,6 +877,15 @@ import org.slf4j.LoggerFactory;
return false;
}
+ boolean this_present_colStats = true && this.isSetColStats();
+ boolean that_present_colStats = true && that.isSetColStats();
+ if (this_present_colStats || that_present_colStats) {
+ if (!(this_present_colStats && that_present_colStats))
+ return false;
+ if (!this.colStats.equals(that.colStats))
+ return false;
+ }
+
return true;
}
@@ -892,6 +948,11 @@ import org.slf4j.LoggerFactory;
if (present_isStatsCompliant)
list.add(isStatsCompliant);
+ boolean present_colStats = true && (isSetColStats());
+ list.add(present_colStats);
+ if (present_colStats)
+ list.add(colStats);
+
return list.hashCode();
}
@@ -1013,6 +1074,16 @@ import org.slf4j.LoggerFactory;
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(isSetColStats()).compareTo(other.isSetColStats());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetColStats()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.colStats, other.colStats);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -1112,6 +1183,16 @@ import org.slf4j.LoggerFactory;
sb.append(this.isStatsCompliant);
first = false;
}
+ if (isSetColStats()) {
+ if (!first) sb.append(", ");
+ sb.append("colStats:");
+ if (this.colStats == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.colStats);
+ }
+ first = false;
+ }
sb.append(")");
return sb.toString();
}
@@ -1275,6 +1356,15 @@ import org.slf4j.LoggerFactory;
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
+ case 12: // COL_STATS
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.colStats = new ColumnStatistics();
+ struct.colStats.read(iprot);
+ struct.setColStatsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
@@ -1358,6 +1448,13 @@ import org.slf4j.LoggerFactory;
oprot.writeBool(struct.isStatsCompliant);
oprot.writeFieldEnd();
}
+ if (struct.colStats != null) {
+ if (struct.isSetColStats()) {
+ oprot.writeFieldBegin(COL_STATS_FIELD_DESC);
+ struct.colStats.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ }
oprot.writeFieldStop();
oprot.writeStructEnd();
}
@@ -1409,7 +1506,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetIsStatsCompliant()) {
optionals.set(10);
}
- oprot.writeBitSet(optionals, 11);
+ if (struct.isSetColStats()) {
+ optionals.set(11);
+ }
+ oprot.writeBitSet(optionals, 12);
if (struct.isSetValues()) {
{
oprot.writeI32(struct.values.size());
@@ -1456,12 +1556,15 @@ import org.slf4j.LoggerFactory;
if (struct.isSetIsStatsCompliant()) {
oprot.writeBool(struct.isStatsCompliant);
}
+ if (struct.isSetColStats()) {
+ struct.colStats.write(oprot);
+ }
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, Partition struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(11);
+ BitSet incoming = iprot.readBitSet(12);
if (incoming.get(0)) {
{
org.apache.thrift.protocol.TList _list235 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
@@ -1528,6 +1631,11 @@ import org.slf4j.LoggerFactory;
struct.isStatsCompliant = iprot.readBool();
struct.setIsStatsCompliantIsSet(true);
}
+ if (incoming.get(11)) {
+ struct.colStats = new ColumnStatistics();
+ struct.colStats.read(iprot);
+ struct.setColStatsIsSet(true);
+ }
}
}
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
index 5cbfe64..8518e44 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
@@ -547,13 +547,13 @@ import org.slf4j.LoggerFactory;
case 1: // FILE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list832 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list832.size);
- long _elem833;
- for (int _i834 = 0; _i834 < _list832.size; ++_i834)
+ org.apache.thrift.protocol.TList _list848 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list848.size);
+ long _elem849;
+ for (int _i850 = 0; _i850 < _list848.size; ++_i850)
{
- _elem833 = iprot.readI64();
- struct.fileIds.add(_elem833);
+ _elem849 = iprot.readI64();
+ struct.fileIds.add(_elem849);
}
iprot.readListEnd();
}
@@ -565,13 +565,13 @@ import org.slf4j.LoggerFactory;
case 2: // METADATA
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list835 = iprot.readListBegin();
- struct.metadata = new ArrayList<ByteBuffer>(_list835.size);
- ByteBuffer _elem836;
- for (int _i837 = 0; _i837 < _list835.size; ++_i837)
+ org.apache.thrift.protocol.TList _list851 = iprot.readListBegin();
+ struct.metadata = new ArrayList<ByteBuffer>(_list851.size);
+ ByteBuffer _elem852;
+ for (int _i853 = 0; _i853 < _list851.size; ++_i853)
{
- _elem836 = iprot.readBinary();
- struct.metadata.add(_elem836);
+ _elem852 = iprot.readBinary();
+ struct.metadata.add(_elem852);
}
iprot.readListEnd();
}
@@ -605,9 +605,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FILE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.fileIds.size()));
- for (long _iter838 : struct.fileIds)
+ for (long _iter854 : struct.fileIds)
{
- oprot.writeI64(_iter838);
+ oprot.writeI64(_iter854);
}
oprot.writeListEnd();
}
@@ -617,9 +617,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(METADATA_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.metadata.size()));
- for (ByteBuffer _iter839 : struct.metadata)
+ for (ByteBuffer _iter855 : struct.metadata)
{
- oprot.writeBinary(_iter839);
+ oprot.writeBinary(_iter855);
}
oprot.writeListEnd();
}
@@ -651,16 +651,16 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter840 : struct.fileIds)
+ for (long _iter856 : struct.fileIds)
{
- oprot.writeI64(_iter840);
+ oprot.writeI64(_iter856);
}
}
{
oprot.writeI32(struct.metadata.size());
- for (ByteBuffer _iter841 : struct.metadata)
+ for (ByteBuffer _iter857 : struct.metadata)
{
- oprot.writeBinary(_iter841);
+ oprot.writeBinary(_iter857);
}
}
BitSet optionals = new BitSet();
@@ -677,24 +677,24 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, PutFileMetadataRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list842 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list842.size);
- long _elem843;
- for (int _i844 = 0; _i844 < _list842.size; ++_i844)
+ org.apache.thrift.protocol.TList _list858 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list858.size);
+ long _elem859;
+ for (int _i860 = 0; _i860 < _list858.size; ++_i860)
{
- _elem843 = iprot.readI64();
- struct.fileIds.add(_elem843);
+ _elem859 = iprot.readI64();
+ struct.fileIds.add(_elem859);
}
}
struct.setFileIdsIsSet(true);
{
- org.apache.thrift.protocol.TList _list845 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.metadata = new ArrayList<ByteBuffer>(_list845.size);
- ByteBuffer _elem846;
- for (int _i847 = 0; _i847 < _list845.size; ++_i847)
+ org.apache.thrift.protocol.TList _list861 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.metadata = new ArrayList<ByteBuffer>(_list861.size);
+ ByteBuffer _elem862;
+ for (int _i863 = 0; _i863 < _list861.size; ++_i863)
{
- _elem846 = iprot.readBinary();
- struct.metadata.add(_elem846);
+ _elem862 = iprot.readBinary();
+ struct.metadata.add(_elem862);
}
}
struct.setMetadataIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RenamePartitionRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RenamePartitionRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RenamePartitionRequest.java
index ea4cc16..6851625 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RenamePartitionRequest.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RenamePartitionRequest.java
@@ -796,13 +796,13 @@ import org.slf4j.LoggerFactory;
case 4: // PART_VALS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list976 = iprot.readListBegin();
- struct.partVals = new ArrayList<String>(_list976.size);
- String _elem977;
- for (int _i978 = 0; _i978 < _list976.size; ++_i978)
+ org.apache.thrift.protocol.TList _list992 = iprot.readListBegin();
+ struct.partVals = new ArrayList<String>(_list992.size);
+ String _elem993;
+ for (int _i994 = 0; _i994 < _list992.size; ++_i994)
{
- _elem977 = iprot.readString();
- struct.partVals.add(_elem977);
+ _elem993 = iprot.readString();
+ struct.partVals.add(_elem993);
}
iprot.readListEnd();
}
@@ -862,9 +862,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PART_VALS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partVals.size()));
- for (String _iter979 : struct.partVals)
+ for (String _iter995 : struct.partVals)
{
- oprot.writeString(_iter979);
+ oprot.writeString(_iter995);
}
oprot.writeListEnd();
}
@@ -903,9 +903,9 @@ import org.slf4j.LoggerFactory;
oprot.writeString(struct.tableName);
{
oprot.writeI32(struct.partVals.size());
- for (String _iter980 : struct.partVals)
+ for (String _iter996 : struct.partVals)
{
- oprot.writeString(_iter980);
+ oprot.writeString(_iter996);
}
}
struct.newPart.write(oprot);
@@ -933,13 +933,13 @@ import org.slf4j.LoggerFactory;
struct.tableName = iprot.readString();
struct.setTableNameIsSet(true);
{
- org.apache.thrift.protocol.TList _list981 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partVals = new ArrayList<String>(_list981.size);
- String _elem982;
- for (int _i983 = 0; _i983 < _list981.size; ++_i983)
+ org.apache.thrift.protocol.TList _list997 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partVals = new ArrayList<String>(_list997.size);
+ String _elem998;
+ for (int _i999 = 0; _i999 < _list997.size; ++_i999)
{
- _elem982 = iprot.readString();
- struct.partVals.add(_elem982);
+ _elem998 = iprot.readString();
+ struct.partVals.add(_elem998);
}
}
struct.setPartValsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplLastIdInfo.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplLastIdInfo.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplLastIdInfo.java
index 4e317d5..2dab332 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplLastIdInfo.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplLastIdInfo.java
@@ -788,13 +788,13 @@ import org.slf4j.LoggerFactory;
case 5: // PARTITION_LIST
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list610 = iprot.readListBegin();
- struct.partitionList = new ArrayList<String>(_list610.size);
- String _elem611;
- for (int _i612 = 0; _i612 < _list610.size; ++_i612)
+ org.apache.thrift.protocol.TList _list626 = iprot.readListBegin();
+ struct.partitionList = new ArrayList<String>(_list626.size);
+ String _elem627;
+ for (int _i628 = 0; _i628 < _list626.size; ++_i628)
{
- _elem611 = iprot.readString();
- struct.partitionList.add(_elem611);
+ _elem627 = iprot.readString();
+ struct.partitionList.add(_elem627);
}
iprot.readListEnd();
}
@@ -851,9 +851,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PARTITION_LIST_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partitionList.size()));
- for (String _iter613 : struct.partitionList)
+ for (String _iter629 : struct.partitionList)
{
- oprot.writeString(_iter613);
+ oprot.writeString(_iter629);
}
oprot.writeListEnd();
}
@@ -907,9 +907,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPartitionList()) {
{
oprot.writeI32(struct.partitionList.size());
- for (String _iter614 : struct.partitionList)
+ for (String _iter630 : struct.partitionList)
{
- oprot.writeString(_iter614);
+ oprot.writeString(_iter630);
}
}
}
@@ -936,13 +936,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list615 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partitionList = new ArrayList<String>(_list615.size);
- String _elem616;
- for (int _i617 = 0; _i617 < _list615.size; ++_i617)
+ org.apache.thrift.protocol.TList _list631 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partitionList = new ArrayList<String>(_list631.size);
+ String _elem632;
+ for (int _i633 = 0; _i633 < _list631.size; ++_i633)
{
- _elem616 = iprot.readString();
- struct.partitionList.add(_elem616);
+ _elem632 = iprot.readString();
+ struct.partitionList.add(_elem632);
}
}
struct.setPartitionListIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java
index 0fa8067..1bfe434 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ReplTblWriteIdStateRequest.java
@@ -813,13 +813,13 @@ import org.slf4j.LoggerFactory;
case 6: // PART_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list618 = iprot.readListBegin();
- struct.partNames = new ArrayList<String>(_list618.size);
- String _elem619;
- for (int _i620 = 0; _i620 < _list618.size; ++_i620)
+ org.apache.thrift.protocol.TList _list634 = iprot.readListBegin();
+ struct.partNames = new ArrayList<String>(_list634.size);
+ String _elem635;
+ for (int _i636 = 0; _i636 < _list634.size; ++_i636)
{
- _elem619 = iprot.readString();
- struct.partNames.add(_elem619);
+ _elem635 = iprot.readString();
+ struct.partNames.add(_elem635);
}
iprot.readListEnd();
}
@@ -871,9 +871,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PART_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partNames.size()));
- for (String _iter621 : struct.partNames)
+ for (String _iter637 : struct.partNames)
{
- oprot.writeString(_iter621);
+ oprot.writeString(_iter637);
}
oprot.writeListEnd();
}
@@ -910,9 +910,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPartNames()) {
{
oprot.writeI32(struct.partNames.size());
- for (String _iter622 : struct.partNames)
+ for (String _iter638 : struct.partNames)
{
- oprot.writeString(_iter622);
+ oprot.writeString(_iter638);
}
}
}
@@ -934,13 +934,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list623 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partNames = new ArrayList<String>(_list623.size);
- String _elem624;
- for (int _i625 = 0; _i625 < _list623.size; ++_i625)
+ org.apache.thrift.protocol.TList _list639 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partNames = new ArrayList<String>(_list639.size);
+ String _elem640;
+ for (int _i641 = 0; _i641 < _list639.size; ++_i641)
{
- _elem624 = iprot.readString();
- struct.partNames.add(_elem624);
+ _elem640 = iprot.readString();
+ struct.partNames.add(_elem640);
}
}
struct.setPartNamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java
index b87f65f..1d7677c 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java
@@ -1119,14 +1119,14 @@ import org.slf4j.LoggerFactory;
case 4: // COLS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list952 = iprot.readListBegin();
- struct.cols = new ArrayList<FieldSchema>(_list952.size);
- FieldSchema _elem953;
- for (int _i954 = 0; _i954 < _list952.size; ++_i954)
+ org.apache.thrift.protocol.TList _list968 = iprot.readListBegin();
+ struct.cols = new ArrayList<FieldSchema>(_list968.size);
+ FieldSchema _elem969;
+ for (int _i970 = 0; _i970 < _list968.size; ++_i970)
{
- _elem953 = new FieldSchema();
- _elem953.read(iprot);
- struct.cols.add(_elem953);
+ _elem969 = new FieldSchema();
+ _elem969.read(iprot);
+ struct.cols.add(_elem969);
}
iprot.readListEnd();
}
@@ -1212,9 +1212,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(COLS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.cols.size()));
- for (FieldSchema _iter955 : struct.cols)
+ for (FieldSchema _iter971 : struct.cols)
{
- _iter955.write(oprot);
+ _iter971.write(oprot);
}
oprot.writeListEnd();
}
@@ -1323,9 +1323,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetCols()) {
{
oprot.writeI32(struct.cols.size());
- for (FieldSchema _iter956 : struct.cols)
+ for (FieldSchema _iter972 : struct.cols)
{
- _iter956.write(oprot);
+ _iter972.write(oprot);
}
}
}
@@ -1368,14 +1368,14 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TList _list957 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.cols = new ArrayList<FieldSchema>(_list957.size);
- FieldSchema _elem958;
- for (int _i959 = 0; _i959 < _list957.size; ++_i959)
+ org.apache.thrift.protocol.TList _list973 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.cols = new ArrayList<FieldSchema>(_list973.size);
+ FieldSchema _elem974;
+ for (int _i975 = 0; _i975 < _list973.size; ++_i975)
{
- _elem958 = new FieldSchema();
- _elem958.read(iprot);
- struct.cols.add(_elem958);
+ _elem974 = new FieldSchema();
+ _elem974.read(iprot);
+ struct.cols.add(_elem974);
}
}
struct.setColsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
index 2a7b3eb..5fcc0dd 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // COMPACTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list716 = iprot.readListBegin();
- struct.compacts = new ArrayList<ShowCompactResponseElement>(_list716.size);
- ShowCompactResponseElement _elem717;
- for (int _i718 = 0; _i718 < _list716.size; ++_i718)
+ org.apache.thrift.protocol.TList _list732 = iprot.readListBegin();
+ struct.compacts = new ArrayList<ShowCompactResponseElement>(_list732.size);
+ ShowCompactResponseElement _elem733;
+ for (int _i734 = 0; _i734 < _list732.size; ++_i734)
{
- _elem717 = new ShowCompactResponseElement();
- _elem717.read(iprot);
- struct.compacts.add(_elem717);
+ _elem733 = new ShowCompactResponseElement();
+ _elem733.read(iprot);
+ struct.compacts.add(_elem733);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(COMPACTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.compacts.size()));
- for (ShowCompactResponseElement _iter719 : struct.compacts)
+ for (ShowCompactResponseElement _iter735 : struct.compacts)
{
- _iter719.write(oprot);
+ _iter735.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.compacts.size());
- for (ShowCompactResponseElement _iter720 : struct.compacts)
+ for (ShowCompactResponseElement _iter736 : struct.compacts)
{
- _iter720.write(oprot);
+ _iter736.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, ShowCompactResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list721 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.compacts = new ArrayList<ShowCompactResponseElement>(_list721.size);
- ShowCompactResponseElement _elem722;
- for (int _i723 = 0; _i723 < _list721.size; ++_i723)
+ org.apache.thrift.protocol.TList _list737 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.compacts = new ArrayList<ShowCompactResponseElement>(_list737.size);
+ ShowCompactResponseElement _elem738;
+ for (int _i739 = 0; _i739 < _list737.size; ++_i739)
{
- _elem722 = new ShowCompactResponseElement();
- _elem722.read(iprot);
- struct.compacts.add(_elem722);
+ _elem738 = new ShowCompactResponseElement();
+ _elem738.read(iprot);
+ struct.compacts.add(_elem738);
}
}
struct.setCompactsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
index 477bf67..3db5327 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
@@ -350,14 +350,14 @@ import org.slf4j.LoggerFactory;
case 1: // LOCKS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list682 = iprot.readListBegin();
- struct.locks = new ArrayList<ShowLocksResponseElement>(_list682.size);
- ShowLocksResponseElement _elem683;
- for (int _i684 = 0; _i684 < _list682.size; ++_i684)
+ org.apache.thrift.protocol.TList _list698 = iprot.readListBegin();
+ struct.locks = new ArrayList<ShowLocksResponseElement>(_list698.size);
+ ShowLocksResponseElement _elem699;
+ for (int _i700 = 0; _i700 < _list698.size; ++_i700)
{
- _elem683 = new ShowLocksResponseElement();
- _elem683.read(iprot);
- struct.locks.add(_elem683);
+ _elem699 = new ShowLocksResponseElement();
+ _elem699.read(iprot);
+ struct.locks.add(_elem699);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(LOCKS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.locks.size()));
- for (ShowLocksResponseElement _iter685 : struct.locks)
+ for (ShowLocksResponseElement _iter701 : struct.locks)
{
- _iter685.write(oprot);
+ _iter701.write(oprot);
}
oprot.writeListEnd();
}
@@ -416,9 +416,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetLocks()) {
{
oprot.writeI32(struct.locks.size());
- for (ShowLocksResponseElement _iter686 : struct.locks)
+ for (ShowLocksResponseElement _iter702 : struct.locks)
{
- _iter686.write(oprot);
+ _iter702.write(oprot);
}
}
}
@@ -430,14 +430,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list687 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.locks = new ArrayList<ShowLocksResponseElement>(_list687.size);
- ShowLocksResponseElement _elem688;
- for (int _i689 = 0; _i689 < _list687.size; ++_i689)
+ org.apache.thrift.protocol.TList _list703 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.locks = new ArrayList<ShowLocksResponseElement>(_list703.size);
+ ShowLocksResponseElement _elem704;
+ for (int _i705 = 0; _i705 < _list703.size; ++_i705)
{
- _elem688 = new ShowLocksResponseElement();
- _elem688.read(iprot);
- struct.locks.add(_elem688);
+ _elem704 = new ShowLocksResponseElement();
+ _elem704.read(iprot);
+ struct.locks.add(_elem704);
}
}
struct.setLocksIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java
index 118f9db..e5ba13d 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java
@@ -708,13 +708,13 @@ import org.slf4j.LoggerFactory;
case 3: // INVALID_WRITE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list634 = iprot.readListBegin();
- struct.invalidWriteIds = new ArrayList<Long>(_list634.size);
- long _elem635;
- for (int _i636 = 0; _i636 < _list634.size; ++_i636)
+ org.apache.thrift.protocol.TList _list650 = iprot.readListBegin();
+ struct.invalidWriteIds = new ArrayList<Long>(_list650.size);
+ long _elem651;
+ for (int _i652 = 0; _i652 < _list650.size; ++_i652)
{
- _elem635 = iprot.readI64();
- struct.invalidWriteIds.add(_elem635);
+ _elem651 = iprot.readI64();
+ struct.invalidWriteIds.add(_elem651);
}
iprot.readListEnd();
}
@@ -764,9 +764,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(INVALID_WRITE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.invalidWriteIds.size()));
- for (long _iter637 : struct.invalidWriteIds)
+ for (long _iter653 : struct.invalidWriteIds)
{
- oprot.writeI64(_iter637);
+ oprot.writeI64(_iter653);
}
oprot.writeListEnd();
}
@@ -803,9 +803,9 @@ import org.slf4j.LoggerFactory;
oprot.writeI64(struct.writeIdHighWaterMark);
{
oprot.writeI32(struct.invalidWriteIds.size());
- for (long _iter638 : struct.invalidWriteIds)
+ for (long _iter654 : struct.invalidWriteIds)
{
- oprot.writeI64(_iter638);
+ oprot.writeI64(_iter654);
}
}
oprot.writeBinary(struct.abortedBits);
@@ -827,13 +827,13 @@ import org.slf4j.LoggerFactory;
struct.writeIdHighWaterMark = iprot.readI64();
struct.setWriteIdHighWaterMarkIsSet(true);
{
- org.apache.thrift.protocol.TList _list639 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.invalidWriteIds = new ArrayList<Long>(_list639.size);
- long _elem640;
- for (int _i641 = 0; _i641 < _list639.size; ++_i641)
+ org.apache.thrift.protocol.TList _list655 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.invalidWriteIds = new ArrayList<Long>(_list655.size);
+ long _elem656;
+ for (int _i657 = 0; _i657 < _list655.size; ++_i657)
{
- _elem640 = iprot.readI64();
- struct.invalidWriteIds.add(_elem640);
+ _elem656 = iprot.readI64();
+ struct.invalidWriteIds.add(_elem656);
}
}
struct.setInvalidWriteIdsIsSet(true);