Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id E768A200AF7 for ; Tue, 10 May 2016 00:31:41 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id E5C311609A8; Mon, 9 May 2016 22:31:41 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id F3B7C160A18 for ; Tue, 10 May 2016 00:31:39 +0200 (CEST) Received: (qmail 12331 invoked by uid 500); 9 May 2016 22:31:38 -0000 Mailing-List: contact commits-help@hive.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: hive-dev@hive.apache.org Delivered-To: mailing list commits@hive.apache.org Received: (qmail 11857 invoked by uid 99); 9 May 2016 22:31:38 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 09 May 2016 22:31:38 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 254DCE78AF; Mon, 9 May 2016 22:31:38 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: weiz@apache.org To: commits@hive.apache.org Date: Mon, 09 May 2016 22:31:43 -0000 Message-Id: <8917904032de4a78bfa2c11a6f813555@git.apache.org> In-Reply-To: <58c8241284b3472fbf1e8ce34f151575@git.apache.org> References: <58c8241284b3472fbf1e8ce34f151575@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [06/10] hive git commit: HIVE-12634 : Add command to kill an ACID transacton (Wei Zheng, reviewed by Eugene Koifman) archived-at: Mon, 09 May 2016 22:31:42 -0000 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 txn_ids; + + void __set_txn_ids(const std::vector & 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, java.io.Serializable, Cloneable, Comparable { + 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, SchemeFactory> schemes = new HashMap, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new AbortTxnsRequestStandardSchemeFactory()); + schemes.put(TupleScheme.class, new AbortTxnsRequestTupleSchemeFactory()); + } + + private List 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 byName = new HashMap(); + + 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 txn_ids) + { + this(); + this.txn_ids = txn_ids; + } + + /** + * Performs a deep copy on other. + */ + public AbortTxnsRequest(AbortTxnsRequest other) { + if (other.isSetTxn_ids()) { + List __this__txn_ids = new ArrayList(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 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(); + } + this.txn_ids.add(elem); + } + + public List getTxn_ids() { + return this.txn_ids; + } + + public void setTxn_ids(List 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)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 list = new ArrayList(); + + 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 { + + 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(_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 { + + @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(_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(_list508.size); - String _elem509; - for (int _i510 = 0; _i510 < _list508.size; ++_i510) + org.apache.thrift.protocol.TList _list516 = iprot.readListBegin(); + struct.partitionnames = new ArrayList(_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(_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(_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(_list592.size); - long _elem593; - for (int _i594 = 0; _i594 < _list592.size; ++_i594) + org.apache.thrift.protocol.TList _list600 = iprot.readListBegin(); + struct.fileIds = new ArrayList(_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(_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(_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(_list532.size); - String _elem533; - for (int _i534 = 0; _i534 < _list532.size; ++_i534) + org.apache.thrift.protocol.TList _list540 = iprot.readListBegin(); + struct.partitionVals = new ArrayList(_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(_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(_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(_list600.size); - Function _elem601; - for (int _i602 = 0; _i602 < _list600.size; ++_i602) + org.apache.thrift.protocol.TList _list608 = iprot.readListBegin(); + struct.functions = new ArrayList(_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(_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(_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(_list550.size); - long _elem551; - for (int _i552 = 0; _i552 < _list550.size; ++_i552) + org.apache.thrift.protocol.TList _list558 = iprot.readListBegin(); + struct.fileIds = new ArrayList(_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(_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(_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(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(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 _iter544 : struct.metadata.entrySet()) + for (Map.Entry _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 _iter545 : struct.metadata.entrySet()) + for (Map.Entry _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(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(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(_list568.size); - long _elem569; - for (int _i570 = 0; _i570 < _list568.size; ++_i570) + org.apache.thrift.protocol.TList _list576 = iprot.readListBegin(); + struct.fileIds = new ArrayList(_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(_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(_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(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(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 _iter562 : struct.metadata.entrySet()) + for (Map.Entry _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 _iter563 : struct.metadata.entrySet()) + for (Map.Entry _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(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(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(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(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(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(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(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(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(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(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(_list524.size); - String _elem525; - for (int _i526 = 0; _i526 < _list524.size; ++_i526) + org.apache.thrift.protocol.TList _list532 = iprot.readListBegin(); + struct.filesAdded = new ArrayList(_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(_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(_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(_list468.size); - LockComponent _elem469; - for (int _i470 = 0; _i470 < _list468.size; ++_i470) + org.apache.thrift.protocol.TList _list476 = iprot.readListBegin(); + struct.component = new ArrayList(_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(_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(_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(_list516.size); - NotificationEvent _elem517; - for (int _i518 = 0; _i518 < _list516.size; ++_i518) + org.apache.thrift.protocol.TList _list524 = iprot.readListBegin(); + struct.events = new ArrayList(_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(_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(_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(_list576.size); - long _elem577; - for (int _i578 = 0; _i578 < _list576.size; ++_i578) + org.apache.thrift.protocol.TList _list584 = iprot.readListBegin(); + struct.fileIds = new ArrayList(_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(_list579.size); - ByteBuffer _elem580; - for (int _i581 = 0; _i581 < _list579.size; ++_i581) + org.apache.thrift.protocol.TList _list587 = iprot.readListBegin(); + struct.metadata = new ArrayList(_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(_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(_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(_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(_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(_list500.size); - ShowCompactResponseElement _elem501; - for (int _i502 = 0; _i502 < _list500.size; ++_i502) + org.apache.thrift.protocol.TList _list508 = iprot.readListBegin(); + struct.compacts = new ArrayList(_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(_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(_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(_list476.size); - ShowLocksResponseElement _elem477; - for (int _i478 = 0; _i478 < _list476.size; ++_i478) + org.apache.thrift.protocol.TList _list484 = iprot.readListBegin(); + struct.locks = new ArrayList(_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(_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(_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);