http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h b/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h index 56060f4..d32cdeb 100644 --- a/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h +++ b/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h @@ -293,6 +293,8 @@ class OpenTxnsResponse; class AbortTxnRequest; +class AbortTxnsRequest; + class CommitTxnRequest; class LockComponent; @@ -4949,6 +4951,46 @@ inline std::ostream& operator<<(std::ostream& out, const AbortTxnRequest& obj) } +class AbortTxnsRequest { + public: + + AbortTxnsRequest(const AbortTxnsRequest&); + AbortTxnsRequest& operator=(const AbortTxnsRequest&); + AbortTxnsRequest() { + } + + virtual ~AbortTxnsRequest() throw(); + std::vector<int64_t> txn_ids; + + void __set_txn_ids(const std::vector<int64_t> & val); + + bool operator == (const AbortTxnsRequest & rhs) const + { + if (!(txn_ids == rhs.txn_ids)) + return false; + return true; + } + bool operator != (const AbortTxnsRequest &rhs) const { + return !(*this == rhs); + } + + bool operator < (const AbortTxnsRequest & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + + virtual void printTo(std::ostream& out) const; +}; + +void swap(AbortTxnsRequest &a, AbortTxnsRequest &b); + +inline std::ostream& operator<<(std::ostream& out, const AbortTxnsRequest& obj) +{ + obj.printTo(out); + return out; +} + + class CommitTxnRequest { public:
http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java new file mode 100644 index 0000000..c434737 --- /dev/null +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java @@ -0,0 +1,438 @@ +/** + * Autogenerated by Thrift Compiler (0.9.3) + * + * 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.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 org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; +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 javax.annotation.Generated; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)") +public class AbortTxnsRequest implements org.apache.thrift.TBase<AbortTxnsRequest, AbortTxnsRequest._Fields>, java.io.Serializable, Cloneable, Comparable<AbortTxnsRequest> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AbortTxnsRequest"); + + private static final org.apache.thrift.protocol.TField TXN_IDS_FIELD_DESC = new org.apache.thrift.protocol.TField("txn_ids", org.apache.thrift.protocol.TType.LIST, (short)1); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new AbortTxnsRequestStandardSchemeFactory()); + schemes.put(TupleScheme.class, new AbortTxnsRequestTupleSchemeFactory()); + } + + private List<Long> txn_ids; // 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 { + TXN_IDS((short)1, "txn_ids"); + + 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: // TXN_IDS + return TXN_IDS; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.TXN_IDS, new org.apache.thrift.meta_data.FieldMetaData("txn_ids", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AbortTxnsRequest.class, metaDataMap); + } + + public AbortTxnsRequest() { + } + + public AbortTxnsRequest( + List<Long> txn_ids) + { + this(); + this.txn_ids = txn_ids; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public AbortTxnsRequest(AbortTxnsRequest other) { + if (other.isSetTxn_ids()) { + List<Long> __this__txn_ids = new ArrayList<Long>(other.txn_ids); + this.txn_ids = __this__txn_ids; + } + } + + public AbortTxnsRequest deepCopy() { + return new AbortTxnsRequest(this); + } + + @Override + public void clear() { + this.txn_ids = null; + } + + public int getTxn_idsSize() { + return (this.txn_ids == null) ? 0 : this.txn_ids.size(); + } + + public java.util.Iterator<Long> getTxn_idsIterator() { + return (this.txn_ids == null) ? null : this.txn_ids.iterator(); + } + + public void addToTxn_ids(long elem) { + if (this.txn_ids == null) { + this.txn_ids = new ArrayList<Long>(); + } + this.txn_ids.add(elem); + } + + public List<Long> getTxn_ids() { + return this.txn_ids; + } + + public void setTxn_ids(List<Long> txn_ids) { + this.txn_ids = txn_ids; + } + + public void unsetTxn_ids() { + this.txn_ids = null; + } + + /** Returns true if field txn_ids is set (has been assigned a value) and false otherwise */ + public boolean isSetTxn_ids() { + return this.txn_ids != null; + } + + public void setTxn_idsIsSet(boolean value) { + if (!value) { + this.txn_ids = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case TXN_IDS: + if (value == null) { + unsetTxn_ids(); + } else { + setTxn_ids((List<Long>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case TXN_IDS: + return getTxn_ids(); + + } + 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 TXN_IDS: + return isSetTxn_ids(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof AbortTxnsRequest) + return this.equals((AbortTxnsRequest)that); + return false; + } + + public boolean equals(AbortTxnsRequest that) { + if (that == null) + return false; + + boolean this_present_txn_ids = true && this.isSetTxn_ids(); + boolean that_present_txn_ids = true && that.isSetTxn_ids(); + if (this_present_txn_ids || that_present_txn_ids) { + if (!(this_present_txn_ids && that_present_txn_ids)) + return false; + if (!this.txn_ids.equals(that.txn_ids)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_txn_ids = true && (isSetTxn_ids()); + list.add(present_txn_ids); + if (present_txn_ids) + list.add(txn_ids); + + return list.hashCode(); + } + + @Override + public int compareTo(AbortTxnsRequest other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetTxn_ids()).compareTo(other.isSetTxn_ids()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTxn_ids()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.txn_ids, other.txn_ids); + 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("AbortTxnsRequest("); + boolean first = true; + + sb.append("txn_ids:"); + if (this.txn_ids == null) { + sb.append("null"); + } else { + sb.append(this.txn_ids); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!isSetTxn_ids()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'txn_ids' 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 { + 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 AbortTxnsRequestStandardSchemeFactory implements SchemeFactory { + public AbortTxnsRequestStandardScheme getScheme() { + return new AbortTxnsRequestStandardScheme(); + } + } + + private static class AbortTxnsRequestStandardScheme extends StandardScheme<AbortTxnsRequest> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, AbortTxnsRequest 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: // TXN_IDS + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list468 = iprot.readListBegin(); + struct.txn_ids = new ArrayList<Long>(_list468.size); + long _elem469; + for (int _i470 = 0; _i470 < _list468.size; ++_i470) + { + _elem469 = iprot.readI64(); + struct.txn_ids.add(_elem469); + } + iprot.readListEnd(); + } + struct.setTxn_idsIsSet(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, AbortTxnsRequest struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.txn_ids != null) { + 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 _iter471 : struct.txn_ids) + { + oprot.writeI64(_iter471); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class AbortTxnsRequestTupleSchemeFactory implements SchemeFactory { + public AbortTxnsRequestTupleScheme getScheme() { + return new AbortTxnsRequestTupleScheme(); + } + } + + private static class AbortTxnsRequestTupleScheme extends TupleScheme<AbortTxnsRequest> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, AbortTxnsRequest struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + { + oprot.writeI32(struct.txn_ids.size()); + for (long _iter472 : struct.txn_ids) + { + oprot.writeI64(_iter472); + } + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, AbortTxnsRequest struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + { + org.apache.thrift.protocol.TList _list473 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.txn_ids = new ArrayList<Long>(_list473.size); + long _elem474; + for (int _i475 = 0; _i475 < _list473.size; ++_i475) + { + _elem474 = iprot.readI64(); + struct.txn_ids.add(_elem474); + } + } + struct.setTxn_idsIsSet(true); + } + } + +} + http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java index 19bdf10..116e04f 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java @@ -630,13 +630,13 @@ public class AddDynamicPartitions implements org.apache.thrift.TBase<AddDynamicP case 4: // PARTITIONNAMES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list508 = iprot.readListBegin(); - struct.partitionnames = new ArrayList<String>(_list508.size); - String _elem509; - for (int _i510 = 0; _i510 < _list508.size; ++_i510) + org.apache.thrift.protocol.TList _list516 = iprot.readListBegin(); + struct.partitionnames = new ArrayList<String>(_list516.size); + String _elem517; + for (int _i518 = 0; _i518 < _list516.size; ++_i518) { - _elem509 = iprot.readString(); - struct.partitionnames.add(_elem509); + _elem517 = iprot.readString(); + struct.partitionnames.add(_elem517); } iprot.readListEnd(); } @@ -675,9 +675,9 @@ public class AddDynamicPartitions implements org.apache.thrift.TBase<AddDynamicP oprot.writeFieldBegin(PARTITIONNAMES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partitionnames.size())); - for (String _iter511 : struct.partitionnames) + for (String _iter519 : struct.partitionnames) { - oprot.writeString(_iter511); + oprot.writeString(_iter519); } oprot.writeListEnd(); } @@ -705,9 +705,9 @@ public class AddDynamicPartitions implements org.apache.thrift.TBase<AddDynamicP oprot.writeString(struct.tablename); { oprot.writeI32(struct.partitionnames.size()); - for (String _iter512 : struct.partitionnames) + for (String _iter520 : struct.partitionnames) { - oprot.writeString(_iter512); + oprot.writeString(_iter520); } } } @@ -722,13 +722,13 @@ public class AddDynamicPartitions implements org.apache.thrift.TBase<AddDynamicP struct.tablename = iprot.readString(); struct.setTablenameIsSet(true); { - org.apache.thrift.protocol.TList _list513 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.partitionnames = new ArrayList<String>(_list513.size); - String _elem514; - for (int _i515 = 0; _i515 < _list513.size; ++_i515) + org.apache.thrift.protocol.TList _list521 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.partitionnames = new ArrayList<String>(_list521.size); + String _elem522; + for (int _i523 = 0; _i523 < _list521.size; ++_i523) { - _elem514 = iprot.readString(); - struct.partitionnames.add(_elem514); + _elem522 = iprot.readString(); + struct.partitionnames.add(_elem522); } } struct.setPartitionnamesIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java index cfec32e..a60ab7e 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java @@ -351,13 +351,13 @@ public class ClearFileMetadataRequest implements org.apache.thrift.TBase<ClearFi case 1: // FILE_IDS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list592 = iprot.readListBegin(); - struct.fileIds = new ArrayList<Long>(_list592.size); - long _elem593; - for (int _i594 = 0; _i594 < _list592.size; ++_i594) + org.apache.thrift.protocol.TList _list600 = iprot.readListBegin(); + struct.fileIds = new ArrayList<Long>(_list600.size); + long _elem601; + for (int _i602 = 0; _i602 < _list600.size; ++_i602) { - _elem593 = iprot.readI64(); - struct.fileIds.add(_elem593); + _elem601 = iprot.readI64(); + struct.fileIds.add(_elem601); } iprot.readListEnd(); } @@ -383,9 +383,9 @@ public class ClearFileMetadataRequest implements org.apache.thrift.TBase<ClearFi 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 _iter595 : struct.fileIds) + for (long _iter603 : struct.fileIds) { - oprot.writeI64(_iter595); + oprot.writeI64(_iter603); } oprot.writeListEnd(); } @@ -410,9 +410,9 @@ public class ClearFileMetadataRequest implements org.apache.thrift.TBase<ClearFi TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.fileIds.size()); - for (long _iter596 : struct.fileIds) + for (long _iter604 : struct.fileIds) { - oprot.writeI64(_iter596); + oprot.writeI64(_iter604); } } } @@ -421,13 +421,13 @@ public class ClearFileMetadataRequest implements org.apache.thrift.TBase<ClearFi public void read(org.apache.thrift.protocol.TProtocol prot, ClearFileMetadataRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list597 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.fileIds = new ArrayList<Long>(_list597.size); - long _elem598; - for (int _i599 = 0; _i599 < _list597.size; ++_i599) + org.apache.thrift.protocol.TList _list605 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.fileIds = new ArrayList<Long>(_list605.size); + long _elem606; + for (int _i607 = 0; _i607 < _list605.size; ++_i607) { - _elem598 = iprot.readI64(); - struct.fileIds.add(_elem598); + _elem606 = iprot.readI64(); + struct.fileIds.add(_elem606); } } struct.setFileIdsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java index 44308cc..ffdfa9b 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java @@ -713,13 +713,13 @@ public class FireEventRequest implements org.apache.thrift.TBase<FireEventReques case 5: // PARTITION_VALS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list532 = iprot.readListBegin(); - struct.partitionVals = new ArrayList<String>(_list532.size); - String _elem533; - for (int _i534 = 0; _i534 < _list532.size; ++_i534) + org.apache.thrift.protocol.TList _list540 = iprot.readListBegin(); + struct.partitionVals = new ArrayList<String>(_list540.size); + String _elem541; + for (int _i542 = 0; _i542 < _list540.size; ++_i542) { - _elem533 = iprot.readString(); - struct.partitionVals.add(_elem533); + _elem541 = iprot.readString(); + struct.partitionVals.add(_elem541); } iprot.readListEnd(); } @@ -768,9 +768,9 @@ public class FireEventRequest implements org.apache.thrift.TBase<FireEventReques oprot.writeFieldBegin(PARTITION_VALS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partitionVals.size())); - for (String _iter535 : struct.partitionVals) + for (String _iter543 : struct.partitionVals) { - oprot.writeString(_iter535); + oprot.writeString(_iter543); } oprot.writeListEnd(); } @@ -816,9 +816,9 @@ public class FireEventRequest implements org.apache.thrift.TBase<FireEventReques if (struct.isSetPartitionVals()) { { oprot.writeI32(struct.partitionVals.size()); - for (String _iter536 : struct.partitionVals) + for (String _iter544 : struct.partitionVals) { - oprot.writeString(_iter536); + oprot.writeString(_iter544); } } } @@ -843,13 +843,13 @@ public class FireEventRequest implements org.apache.thrift.TBase<FireEventReques } if (incoming.get(2)) { { - org.apache.thrift.protocol.TList _list537 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.partitionVals = new ArrayList<String>(_list537.size); - String _elem538; - for (int _i539 = 0; _i539 < _list537.size; ++_i539) + org.apache.thrift.protocol.TList _list545 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.partitionVals = new ArrayList<String>(_list545.size); + String _elem546; + for (int _i547 = 0; _i547 < _list545.size; ++_i547) { - _elem538 = iprot.readString(); - struct.partitionVals.add(_elem538); + _elem546 = iprot.readString(); + struct.partitionVals.add(_elem546); } } struct.setPartitionValsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java index 2c297ef..a074515 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetAllFunctionsResponse.java @@ -346,14 +346,14 @@ public class GetAllFunctionsResponse implements org.apache.thrift.TBase<GetAllFu case 1: // FUNCTIONS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list600 = iprot.readListBegin(); - struct.functions = new ArrayList<Function>(_list600.size); - Function _elem601; - for (int _i602 = 0; _i602 < _list600.size; ++_i602) + org.apache.thrift.protocol.TList _list608 = iprot.readListBegin(); + struct.functions = new ArrayList<Function>(_list608.size); + Function _elem609; + for (int _i610 = 0; _i610 < _list608.size; ++_i610) { - _elem601 = new Function(); - _elem601.read(iprot); - struct.functions.add(_elem601); + _elem609 = new Function(); + _elem609.read(iprot); + struct.functions.add(_elem609); } iprot.readListEnd(); } @@ -380,9 +380,9 @@ public class GetAllFunctionsResponse implements org.apache.thrift.TBase<GetAllFu oprot.writeFieldBegin(FUNCTIONS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.functions.size())); - for (Function _iter603 : struct.functions) + for (Function _iter611 : struct.functions) { - _iter603.write(oprot); + _iter611.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ public class GetAllFunctionsResponse implements org.apache.thrift.TBase<GetAllFu if (struct.isSetFunctions()) { { oprot.writeI32(struct.functions.size()); - for (Function _iter604 : struct.functions) + for (Function _iter612 : struct.functions) { - _iter604.write(oprot); + _iter612.write(oprot); } } } @@ -428,14 +428,14 @@ public class GetAllFunctionsResponse implements org.apache.thrift.TBase<GetAllFu BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list605 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.functions = new ArrayList<Function>(_list605.size); - Function _elem606; - for (int _i607 = 0; _i607 < _list605.size; ++_i607) + org.apache.thrift.protocol.TList _list613 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.functions = new ArrayList<Function>(_list613.size); + Function _elem614; + for (int _i615 = 0; _i615 < _list613.size; ++_i615) { - _elem606 = new Function(); - _elem606.read(iprot); - struct.functions.add(_elem606); + _elem614 = new Function(); + _elem614.read(iprot); + struct.functions.add(_elem614); } } struct.setFunctionsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java index af3e4e3..6df53bb 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java @@ -619,13 +619,13 @@ public class GetFileMetadataByExprRequest implements org.apache.thrift.TBase<Get case 1: // FILE_IDS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list550 = iprot.readListBegin(); - struct.fileIds = new ArrayList<Long>(_list550.size); - long _elem551; - for (int _i552 = 0; _i552 < _list550.size; ++_i552) + org.apache.thrift.protocol.TList _list558 = iprot.readListBegin(); + struct.fileIds = new ArrayList<Long>(_list558.size); + long _elem559; + for (int _i560 = 0; _i560 < _list558.size; ++_i560) { - _elem551 = iprot.readI64(); - struct.fileIds.add(_elem551); + _elem559 = iprot.readI64(); + struct.fileIds.add(_elem559); } iprot.readListEnd(); } @@ -675,9 +675,9 @@ public class GetFileMetadataByExprRequest implements org.apache.thrift.TBase<Get 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 _iter553 : struct.fileIds) + for (long _iter561 : struct.fileIds) { - oprot.writeI64(_iter553); + oprot.writeI64(_iter561); } oprot.writeListEnd(); } @@ -719,9 +719,9 @@ public class GetFileMetadataByExprRequest implements org.apache.thrift.TBase<Get TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.fileIds.size()); - for (long _iter554 : struct.fileIds) + for (long _iter562 : struct.fileIds) { - oprot.writeI64(_iter554); + oprot.writeI64(_iter562); } } oprot.writeBinary(struct.expr); @@ -745,13 +745,13 @@ public class GetFileMetadataByExprRequest implements org.apache.thrift.TBase<Get public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataByExprRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list555 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.fileIds = new ArrayList<Long>(_list555.size); - long _elem556; - for (int _i557 = 0; _i557 < _list555.size; ++_i557) + org.apache.thrift.protocol.TList _list563 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.fileIds = new ArrayList<Long>(_list563.size); + long _elem564; + for (int _i565 = 0; _i565 < _list563.size; ++_i565) { - _elem556 = iprot.readI64(); - struct.fileIds.add(_elem556); + _elem564 = iprot.readI64(); + struct.fileIds.add(_elem564); } } struct.setFileIdsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java index 1405203..c84e86b 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java @@ -444,16 +444,16 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF case 1: // METADATA if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map540 = iprot.readMapBegin(); - struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map540.size); - long _key541; - MetadataPpdResult _val542; - for (int _i543 = 0; _i543 < _map540.size; ++_i543) + org.apache.thrift.protocol.TMap _map548 = iprot.readMapBegin(); + struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map548.size); + long _key549; + MetadataPpdResult _val550; + for (int _i551 = 0; _i551 < _map548.size; ++_i551) { - _key541 = iprot.readI64(); - _val542 = new MetadataPpdResult(); - _val542.read(iprot); - struct.metadata.put(_key541, _val542); + _key549 = iprot.readI64(); + _val550 = new MetadataPpdResult(); + _val550.read(iprot); + struct.metadata.put(_key549, _val550); } iprot.readMapEnd(); } @@ -487,10 +487,10 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF oprot.writeFieldBegin(METADATA_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRUCT, struct.metadata.size())); - for (Map.Entry<Long, MetadataPpdResult> _iter544 : struct.metadata.entrySet()) + for (Map.Entry<Long, MetadataPpdResult> _iter552 : struct.metadata.entrySet()) { - oprot.writeI64(_iter544.getKey()); - _iter544.getValue().write(oprot); + oprot.writeI64(_iter552.getKey()); + _iter552.getValue().write(oprot); } oprot.writeMapEnd(); } @@ -518,10 +518,10 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.metadata.size()); - for (Map.Entry<Long, MetadataPpdResult> _iter545 : struct.metadata.entrySet()) + for (Map.Entry<Long, MetadataPpdResult> _iter553 : struct.metadata.entrySet()) { - oprot.writeI64(_iter545.getKey()); - _iter545.getValue().write(oprot); + oprot.writeI64(_iter553.getKey()); + _iter553.getValue().write(oprot); } } oprot.writeBool(struct.isSupported); @@ -531,16 +531,16 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataByExprResult struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TMap _map546 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map546.size); - long _key547; - MetadataPpdResult _val548; - for (int _i549 = 0; _i549 < _map546.size; ++_i549) + org.apache.thrift.protocol.TMap _map554 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map554.size); + long _key555; + MetadataPpdResult _val556; + for (int _i557 = 0; _i557 < _map554.size; ++_i557) { - _key547 = iprot.readI64(); - _val548 = new MetadataPpdResult(); - _val548.read(iprot); - struct.metadata.put(_key547, _val548); + _key555 = iprot.readI64(); + _val556 = new MetadataPpdResult(); + _val556.read(iprot); + struct.metadata.put(_key555, _val556); } } struct.setMetadataIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java index ae867d0..c48f92f 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java @@ -351,13 +351,13 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe case 1: // FILE_IDS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list568 = iprot.readListBegin(); - struct.fileIds = new ArrayList<Long>(_list568.size); - long _elem569; - for (int _i570 = 0; _i570 < _list568.size; ++_i570) + org.apache.thrift.protocol.TList _list576 = iprot.readListBegin(); + struct.fileIds = new ArrayList<Long>(_list576.size); + long _elem577; + for (int _i578 = 0; _i578 < _list576.size; ++_i578) { - _elem569 = iprot.readI64(); - struct.fileIds.add(_elem569); + _elem577 = iprot.readI64(); + struct.fileIds.add(_elem577); } iprot.readListEnd(); } @@ -383,9 +383,9 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe 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 _iter571 : struct.fileIds) + for (long _iter579 : struct.fileIds) { - oprot.writeI64(_iter571); + oprot.writeI64(_iter579); } oprot.writeListEnd(); } @@ -410,9 +410,9 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.fileIds.size()); - for (long _iter572 : struct.fileIds) + for (long _iter580 : struct.fileIds) { - oprot.writeI64(_iter572); + oprot.writeI64(_iter580); } } } @@ -421,13 +421,13 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list573 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.fileIds = new ArrayList<Long>(_list573.size); - long _elem574; - for (int _i575 = 0; _i575 < _list573.size; ++_i575) + org.apache.thrift.protocol.TList _list581 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.fileIds = new ArrayList<Long>(_list581.size); + long _elem582; + for (int _i583 = 0; _i583 < _list581.size; ++_i583) { - _elem574 = iprot.readI64(); - struct.fileIds.add(_elem574); + _elem582 = iprot.readI64(); + struct.fileIds.add(_elem582); } } struct.setFileIdsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java index 21c9eea..a722b93 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java @@ -433,15 +433,15 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet case 1: // METADATA if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map558 = iprot.readMapBegin(); - struct.metadata = new HashMap<Long,ByteBuffer>(2*_map558.size); - long _key559; - ByteBuffer _val560; - for (int _i561 = 0; _i561 < _map558.size; ++_i561) + org.apache.thrift.protocol.TMap _map566 = iprot.readMapBegin(); + struct.metadata = new HashMap<Long,ByteBuffer>(2*_map566.size); + long _key567; + ByteBuffer _val568; + for (int _i569 = 0; _i569 < _map566.size; ++_i569) { - _key559 = iprot.readI64(); - _val560 = iprot.readBinary(); - struct.metadata.put(_key559, _val560); + _key567 = iprot.readI64(); + _val568 = iprot.readBinary(); + struct.metadata.put(_key567, _val568); } iprot.readMapEnd(); } @@ -475,10 +475,10 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet oprot.writeFieldBegin(METADATA_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRING, struct.metadata.size())); - for (Map.Entry<Long, ByteBuffer> _iter562 : struct.metadata.entrySet()) + for (Map.Entry<Long, ByteBuffer> _iter570 : struct.metadata.entrySet()) { - oprot.writeI64(_iter562.getKey()); - oprot.writeBinary(_iter562.getValue()); + oprot.writeI64(_iter570.getKey()); + oprot.writeBinary(_iter570.getValue()); } oprot.writeMapEnd(); } @@ -506,10 +506,10 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.metadata.size()); - for (Map.Entry<Long, ByteBuffer> _iter563 : struct.metadata.entrySet()) + for (Map.Entry<Long, ByteBuffer> _iter571 : struct.metadata.entrySet()) { - oprot.writeI64(_iter563.getKey()); - oprot.writeBinary(_iter563.getValue()); + oprot.writeI64(_iter571.getKey()); + oprot.writeBinary(_iter571.getValue()); } } oprot.writeBool(struct.isSupported); @@ -519,15 +519,15 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataResult struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TMap _map564 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.metadata = new HashMap<Long,ByteBuffer>(2*_map564.size); - long _key565; - ByteBuffer _val566; - for (int _i567 = 0; _i567 < _map564.size; ++_i567) + org.apache.thrift.protocol.TMap _map572 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.metadata = new HashMap<Long,ByteBuffer>(2*_map572.size); + long _key573; + ByteBuffer _val574; + for (int _i575 = 0; _i575 < _map572.size; ++_i575) { - _key565 = iprot.readI64(); - _val566 = iprot.readBinary(); - struct.metadata.put(_key565, _val566); + _key573 = iprot.readI64(); + _val574 = iprot.readBinary(); + struct.metadata.put(_key573, _val574); } } struct.setMetadataIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java index 5b399ae..b472a4a 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java @@ -453,13 +453,13 @@ public class HeartbeatTxnRangeResponse implements org.apache.thrift.TBase<Heartb case 1: // ABORTED if (schemeField.type == org.apache.thrift.protocol.TType.SET) { { - org.apache.thrift.protocol.TSet _set484 = iprot.readSetBegin(); - struct.aborted = new HashSet<Long>(2*_set484.size); - long _elem485; - for (int _i486 = 0; _i486 < _set484.size; ++_i486) + org.apache.thrift.protocol.TSet _set492 = iprot.readSetBegin(); + struct.aborted = new HashSet<Long>(2*_set492.size); + long _elem493; + for (int _i494 = 0; _i494 < _set492.size; ++_i494) { - _elem485 = iprot.readI64(); - struct.aborted.add(_elem485); + _elem493 = iprot.readI64(); + struct.aborted.add(_elem493); } iprot.readSetEnd(); } @@ -471,13 +471,13 @@ public class HeartbeatTxnRangeResponse implements org.apache.thrift.TBase<Heartb case 2: // NOSUCH if (schemeField.type == org.apache.thrift.protocol.TType.SET) { { - org.apache.thrift.protocol.TSet _set487 = iprot.readSetBegin(); - struct.nosuch = new HashSet<Long>(2*_set487.size); - long _elem488; - for (int _i489 = 0; _i489 < _set487.size; ++_i489) + org.apache.thrift.protocol.TSet _set495 = iprot.readSetBegin(); + struct.nosuch = new HashSet<Long>(2*_set495.size); + long _elem496; + for (int _i497 = 0; _i497 < _set495.size; ++_i497) { - _elem488 = iprot.readI64(); - struct.nosuch.add(_elem488); + _elem496 = iprot.readI64(); + struct.nosuch.add(_elem496); } iprot.readSetEnd(); } @@ -503,9 +503,9 @@ public class HeartbeatTxnRangeResponse implements org.apache.thrift.TBase<Heartb oprot.writeFieldBegin(ABORTED_FIELD_DESC); { oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, struct.aborted.size())); - for (long _iter490 : struct.aborted) + for (long _iter498 : struct.aborted) { - oprot.writeI64(_iter490); + oprot.writeI64(_iter498); } oprot.writeSetEnd(); } @@ -515,9 +515,9 @@ public class HeartbeatTxnRangeResponse implements org.apache.thrift.TBase<Heartb oprot.writeFieldBegin(NOSUCH_FIELD_DESC); { oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, struct.nosuch.size())); - for (long _iter491 : struct.nosuch) + for (long _iter499 : struct.nosuch) { - oprot.writeI64(_iter491); + oprot.writeI64(_iter499); } oprot.writeSetEnd(); } @@ -542,16 +542,16 @@ public class HeartbeatTxnRangeResponse implements org.apache.thrift.TBase<Heartb TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.aborted.size()); - for (long _iter492 : struct.aborted) + for (long _iter500 : struct.aborted) { - oprot.writeI64(_iter492); + oprot.writeI64(_iter500); } } { oprot.writeI32(struct.nosuch.size()); - for (long _iter493 : struct.nosuch) + for (long _iter501 : struct.nosuch) { - oprot.writeI64(_iter493); + oprot.writeI64(_iter501); } } } @@ -560,24 +560,24 @@ public class HeartbeatTxnRangeResponse implements org.apache.thrift.TBase<Heartb public void read(org.apache.thrift.protocol.TProtocol prot, HeartbeatTxnRangeResponse struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TSet _set494 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.aborted = new HashSet<Long>(2*_set494.size); - long _elem495; - for (int _i496 = 0; _i496 < _set494.size; ++_i496) + org.apache.thrift.protocol.TSet _set502 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.aborted = new HashSet<Long>(2*_set502.size); + long _elem503; + for (int _i504 = 0; _i504 < _set502.size; ++_i504) { - _elem495 = iprot.readI64(); - struct.aborted.add(_elem495); + _elem503 = iprot.readI64(); + struct.aborted.add(_elem503); } } struct.setAbortedIsSet(true); { - org.apache.thrift.protocol.TSet _set497 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.nosuch = new HashSet<Long>(2*_set497.size); - long _elem498; - for (int _i499 = 0; _i499 < _set497.size; ++_i499) + org.apache.thrift.protocol.TSet _set505 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.nosuch = new HashSet<Long>(2*_set505.size); + long _elem506; + for (int _i507 = 0; _i507 < _set505.size; ++_i507) { - _elem498 = iprot.readI64(); - struct.nosuch.add(_elem498); + _elem506 = iprot.readI64(); + struct.nosuch.add(_elem506); } } struct.setNosuchIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java index 7511336..88cec2e 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java @@ -351,13 +351,13 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve case 1: // FILES_ADDED if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list524 = iprot.readListBegin(); - struct.filesAdded = new ArrayList<String>(_list524.size); - String _elem525; - for (int _i526 = 0; _i526 < _list524.size; ++_i526) + org.apache.thrift.protocol.TList _list532 = iprot.readListBegin(); + struct.filesAdded = new ArrayList<String>(_list532.size); + String _elem533; + for (int _i534 = 0; _i534 < _list532.size; ++_i534) { - _elem525 = iprot.readString(); - struct.filesAdded.add(_elem525); + _elem533 = iprot.readString(); + struct.filesAdded.add(_elem533); } iprot.readListEnd(); } @@ -383,9 +383,9 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve oprot.writeFieldBegin(FILES_ADDED_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.filesAdded.size())); - for (String _iter527 : struct.filesAdded) + for (String _iter535 : struct.filesAdded) { - oprot.writeString(_iter527); + oprot.writeString(_iter535); } oprot.writeListEnd(); } @@ -410,9 +410,9 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.filesAdded.size()); - for (String _iter528 : struct.filesAdded) + for (String _iter536 : struct.filesAdded) { - oprot.writeString(_iter528); + oprot.writeString(_iter536); } } } @@ -421,13 +421,13 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve public void read(org.apache.thrift.protocol.TProtocol prot, InsertEventRequestData struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list529 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.filesAdded = new ArrayList<String>(_list529.size); - String _elem530; - for (int _i531 = 0; _i531 < _list529.size; ++_i531) + org.apache.thrift.protocol.TList _list537 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.filesAdded = new ArrayList<String>(_list537.size); + String _elem538; + for (int _i539 = 0; _i539 < _list537.size; ++_i539) { - _elem530 = iprot.readString(); - struct.filesAdded.add(_elem530); + _elem538 = iprot.readString(); + struct.filesAdded.add(_elem538); } } struct.setFilesAddedIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java index bd10329..aa9bc64 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java @@ -689,14 +689,14 @@ public class LockRequest implements org.apache.thrift.TBase<LockRequest, LockReq case 1: // COMPONENT if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list468 = iprot.readListBegin(); - struct.component = new ArrayList<LockComponent>(_list468.size); - LockComponent _elem469; - for (int _i470 = 0; _i470 < _list468.size; ++_i470) + org.apache.thrift.protocol.TList _list476 = iprot.readListBegin(); + struct.component = new ArrayList<LockComponent>(_list476.size); + LockComponent _elem477; + for (int _i478 = 0; _i478 < _list476.size; ++_i478) { - _elem469 = new LockComponent(); - _elem469.read(iprot); - struct.component.add(_elem469); + _elem477 = new LockComponent(); + _elem477.read(iprot); + struct.component.add(_elem477); } iprot.readListEnd(); } @@ -754,9 +754,9 @@ public class LockRequest implements org.apache.thrift.TBase<LockRequest, LockReq oprot.writeFieldBegin(COMPONENT_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.component.size())); - for (LockComponent _iter471 : struct.component) + for (LockComponent _iter479 : struct.component) { - _iter471.write(oprot); + _iter479.write(oprot); } oprot.writeListEnd(); } @@ -803,9 +803,9 @@ public class LockRequest implements org.apache.thrift.TBase<LockRequest, LockReq TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.component.size()); - for (LockComponent _iter472 : struct.component) + for (LockComponent _iter480 : struct.component) { - _iter472.write(oprot); + _iter480.write(oprot); } } oprot.writeString(struct.user); @@ -830,14 +830,14 @@ public class LockRequest implements org.apache.thrift.TBase<LockRequest, LockReq 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 _list473 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.component = new ArrayList<LockComponent>(_list473.size); - LockComponent _elem474; - for (int _i475 = 0; _i475 < _list473.size; ++_i475) + org.apache.thrift.protocol.TList _list481 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.component = new ArrayList<LockComponent>(_list481.size); + LockComponent _elem482; + for (int _i483 = 0; _i483 < _list481.size; ++_i483) { - _elem474 = new LockComponent(); - _elem474.read(iprot); - struct.component.add(_elem474); + _elem482 = new LockComponent(); + _elem482.read(iprot); + struct.component.add(_elem482); } } struct.setComponentIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java index 8010cf5..6f9ebb7 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java @@ -354,14 +354,14 @@ public class NotificationEventResponse implements org.apache.thrift.TBase<Notifi case 1: // EVENTS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list516 = iprot.readListBegin(); - struct.events = new ArrayList<NotificationEvent>(_list516.size); - NotificationEvent _elem517; - for (int _i518 = 0; _i518 < _list516.size; ++_i518) + org.apache.thrift.protocol.TList _list524 = iprot.readListBegin(); + struct.events = new ArrayList<NotificationEvent>(_list524.size); + NotificationEvent _elem525; + for (int _i526 = 0; _i526 < _list524.size; ++_i526) { - _elem517 = new NotificationEvent(); - _elem517.read(iprot); - struct.events.add(_elem517); + _elem525 = new NotificationEvent(); + _elem525.read(iprot); + struct.events.add(_elem525); } iprot.readListEnd(); } @@ -387,9 +387,9 @@ public class NotificationEventResponse implements org.apache.thrift.TBase<Notifi oprot.writeFieldBegin(EVENTS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.events.size())); - for (NotificationEvent _iter519 : struct.events) + for (NotificationEvent _iter527 : struct.events) { - _iter519.write(oprot); + _iter527.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ public class NotificationEventResponse implements org.apache.thrift.TBase<Notifi TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.events.size()); - for (NotificationEvent _iter520 : struct.events) + for (NotificationEvent _iter528 : struct.events) { - _iter520.write(oprot); + _iter528.write(oprot); } } } @@ -425,14 +425,14 @@ public class NotificationEventResponse implements org.apache.thrift.TBase<Notifi 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 _list521 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.events = new ArrayList<NotificationEvent>(_list521.size); - NotificationEvent _elem522; - for (int _i523 = 0; _i523 < _list521.size; ++_i523) + org.apache.thrift.protocol.TList _list529 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.events = new ArrayList<NotificationEvent>(_list529.size); + NotificationEvent _elem530; + for (int _i531 = 0; _i531 < _list529.size; ++_i531) { - _elem522 = new NotificationEvent(); - _elem522.read(iprot); - struct.events.add(_elem522); + _elem530 = new NotificationEvent(); + _elem530.read(iprot); + struct.events.add(_elem530); } } struct.setEventsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java index 0905181..6c11240 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java @@ -547,13 +547,13 @@ public class PutFileMetadataRequest implements org.apache.thrift.TBase<PutFileMe case 1: // FILE_IDS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list576 = iprot.readListBegin(); - struct.fileIds = new ArrayList<Long>(_list576.size); - long _elem577; - for (int _i578 = 0; _i578 < _list576.size; ++_i578) + org.apache.thrift.protocol.TList _list584 = iprot.readListBegin(); + struct.fileIds = new ArrayList<Long>(_list584.size); + long _elem585; + for (int _i586 = 0; _i586 < _list584.size; ++_i586) { - _elem577 = iprot.readI64(); - struct.fileIds.add(_elem577); + _elem585 = iprot.readI64(); + struct.fileIds.add(_elem585); } iprot.readListEnd(); } @@ -565,13 +565,13 @@ public class PutFileMetadataRequest implements org.apache.thrift.TBase<PutFileMe case 2: // METADATA if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list579 = iprot.readListBegin(); - struct.metadata = new ArrayList<ByteBuffer>(_list579.size); - ByteBuffer _elem580; - for (int _i581 = 0; _i581 < _list579.size; ++_i581) + org.apache.thrift.protocol.TList _list587 = iprot.readListBegin(); + struct.metadata = new ArrayList<ByteBuffer>(_list587.size); + ByteBuffer _elem588; + for (int _i589 = 0; _i589 < _list587.size; ++_i589) { - _elem580 = iprot.readBinary(); - struct.metadata.add(_elem580); + _elem588 = iprot.readBinary(); + struct.metadata.add(_elem588); } iprot.readListEnd(); } @@ -605,9 +605,9 @@ public class PutFileMetadataRequest implements org.apache.thrift.TBase<PutFileMe 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 _iter582 : struct.fileIds) + for (long _iter590 : struct.fileIds) { - oprot.writeI64(_iter582); + oprot.writeI64(_iter590); } oprot.writeListEnd(); } @@ -617,9 +617,9 @@ public class PutFileMetadataRequest implements org.apache.thrift.TBase<PutFileMe oprot.writeFieldBegin(METADATA_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.metadata.size())); - for (ByteBuffer _iter583 : struct.metadata) + for (ByteBuffer _iter591 : struct.metadata) { - oprot.writeBinary(_iter583); + oprot.writeBinary(_iter591); } oprot.writeListEnd(); } @@ -651,16 +651,16 @@ public class PutFileMetadataRequest implements org.apache.thrift.TBase<PutFileMe TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.fileIds.size()); - for (long _iter584 : struct.fileIds) + for (long _iter592 : struct.fileIds) { - oprot.writeI64(_iter584); + oprot.writeI64(_iter592); } } { oprot.writeI32(struct.metadata.size()); - for (ByteBuffer _iter585 : struct.metadata) + for (ByteBuffer _iter593 : struct.metadata) { - oprot.writeBinary(_iter585); + oprot.writeBinary(_iter593); } } BitSet optionals = new BitSet(); @@ -677,24 +677,24 @@ public class PutFileMetadataRequest implements org.apache.thrift.TBase<PutFileMe 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 _list586 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.fileIds = new ArrayList<Long>(_list586.size); - long _elem587; - for (int _i588 = 0; _i588 < _list586.size; ++_i588) + org.apache.thrift.protocol.TList _list594 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.fileIds = new ArrayList<Long>(_list594.size); + long _elem595; + for (int _i596 = 0; _i596 < _list594.size; ++_i596) { - _elem587 = iprot.readI64(); - struct.fileIds.add(_elem587); + _elem595 = iprot.readI64(); + struct.fileIds.add(_elem595); } } struct.setFileIdsIsSet(true); { - org.apache.thrift.protocol.TList _list589 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.metadata = new ArrayList<ByteBuffer>(_list589.size); - ByteBuffer _elem590; - for (int _i591 = 0; _i591 < _list589.size; ++_i591) + org.apache.thrift.protocol.TList _list597 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.metadata = new ArrayList<ByteBuffer>(_list597.size); + ByteBuffer _elem598; + for (int _i599 = 0; _i599 < _list597.size; ++_i599) { - _elem590 = iprot.readBinary(); - struct.metadata.add(_elem590); + _elem598 = iprot.readBinary(); + struct.metadata.add(_elem598); } } struct.setMetadataIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java index 4df2199..dabfca9 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java @@ -354,14 +354,14 @@ public class ShowCompactResponse implements org.apache.thrift.TBase<ShowCompactR case 1: // COMPACTS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list500 = iprot.readListBegin(); - struct.compacts = new ArrayList<ShowCompactResponseElement>(_list500.size); - ShowCompactResponseElement _elem501; - for (int _i502 = 0; _i502 < _list500.size; ++_i502) + org.apache.thrift.protocol.TList _list508 = iprot.readListBegin(); + struct.compacts = new ArrayList<ShowCompactResponseElement>(_list508.size); + ShowCompactResponseElement _elem509; + for (int _i510 = 0; _i510 < _list508.size; ++_i510) { - _elem501 = new ShowCompactResponseElement(); - _elem501.read(iprot); - struct.compacts.add(_elem501); + _elem509 = new ShowCompactResponseElement(); + _elem509.read(iprot); + struct.compacts.add(_elem509); } iprot.readListEnd(); } @@ -387,9 +387,9 @@ public class ShowCompactResponse implements org.apache.thrift.TBase<ShowCompactR oprot.writeFieldBegin(COMPACTS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.compacts.size())); - for (ShowCompactResponseElement _iter503 : struct.compacts) + for (ShowCompactResponseElement _iter511 : struct.compacts) { - _iter503.write(oprot); + _iter511.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ public class ShowCompactResponse implements org.apache.thrift.TBase<ShowCompactR TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.compacts.size()); - for (ShowCompactResponseElement _iter504 : struct.compacts) + for (ShowCompactResponseElement _iter512 : struct.compacts) { - _iter504.write(oprot); + _iter512.write(oprot); } } } @@ -425,14 +425,14 @@ public class ShowCompactResponse implements org.apache.thrift.TBase<ShowCompactR 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 _list505 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.compacts = new ArrayList<ShowCompactResponseElement>(_list505.size); - ShowCompactResponseElement _elem506; - for (int _i507 = 0; _i507 < _list505.size; ++_i507) + org.apache.thrift.protocol.TList _list513 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.compacts = new ArrayList<ShowCompactResponseElement>(_list513.size); + ShowCompactResponseElement _elem514; + for (int _i515 = 0; _i515 < _list513.size; ++_i515) { - _elem506 = new ShowCompactResponseElement(); - _elem506.read(iprot); - struct.compacts.add(_elem506); + _elem514 = new ShowCompactResponseElement(); + _elem514.read(iprot); + struct.compacts.add(_elem514); } } struct.setCompactsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java index 11944db..0564931 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java @@ -350,14 +350,14 @@ public class ShowLocksResponse implements org.apache.thrift.TBase<ShowLocksRespo case 1: // LOCKS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list476 = iprot.readListBegin(); - struct.locks = new ArrayList<ShowLocksResponseElement>(_list476.size); - ShowLocksResponseElement _elem477; - for (int _i478 = 0; _i478 < _list476.size; ++_i478) + org.apache.thrift.protocol.TList _list484 = iprot.readListBegin(); + struct.locks = new ArrayList<ShowLocksResponseElement>(_list484.size); + ShowLocksResponseElement _elem485; + for (int _i486 = 0; _i486 < _list484.size; ++_i486) { - _elem477 = new ShowLocksResponseElement(); - _elem477.read(iprot); - struct.locks.add(_elem477); + _elem485 = new ShowLocksResponseElement(); + _elem485.read(iprot); + struct.locks.add(_elem485); } iprot.readListEnd(); } @@ -383,9 +383,9 @@ public class ShowLocksResponse implements org.apache.thrift.TBase<ShowLocksRespo oprot.writeFieldBegin(LOCKS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.locks.size())); - for (ShowLocksResponseElement _iter479 : struct.locks) + for (ShowLocksResponseElement _iter487 : struct.locks) { - _iter479.write(oprot); + _iter487.write(oprot); } oprot.writeListEnd(); } @@ -416,9 +416,9 @@ public class ShowLocksResponse implements org.apache.thrift.TBase<ShowLocksRespo if (struct.isSetLocks()) { { oprot.writeI32(struct.locks.size()); - for (ShowLocksResponseElement _iter480 : struct.locks) + for (ShowLocksResponseElement _iter488 : struct.locks) { - _iter480.write(oprot); + _iter488.write(oprot); } } } @@ -430,14 +430,14 @@ public class ShowLocksResponse implements org.apache.thrift.TBase<ShowLocksRespo BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list481 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.locks = new ArrayList<ShowLocksResponseElement>(_list481.size); - ShowLocksResponseElement _elem482; - for (int _i483 = 0; _i483 < _list481.size; ++_i483) + org.apache.thrift.protocol.TList _list489 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.locks = new ArrayList<ShowLocksResponseElement>(_list489.size); + ShowLocksResponseElement _elem490; + for (int _i491 = 0; _i491 < _list489.size; ++_i491) { - _elem482 = new ShowLocksResponseElement(); - _elem482.read(iprot); - struct.locks.add(_elem482); + _elem490 = new ShowLocksResponseElement(); + _elem490.read(iprot); + struct.locks.add(_elem490); } } struct.setLocksIsSet(true);
