http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsByNamesRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsByNamesRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsByNamesRequest.java new file mode 100644 index 0000000..91199e5 --- /dev/null +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsByNamesRequest.java @@ -0,0 +1,752 @@ +/** + * 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)") +@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class GetPartitionsByNamesRequest implements org.apache.thrift.TBase<GetPartitionsByNamesRequest, GetPartitionsByNamesRequest._Fields>, java.io.Serializable, Cloneable, Comparable<GetPartitionsByNamesRequest> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetPartitionsByNamesRequest"); + + private static final org.apache.thrift.protocol.TField DB_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("db_name", org.apache.thrift.protocol.TType.STRING, (short)1); + private static final org.apache.thrift.protocol.TField TBL_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tbl_name", org.apache.thrift.protocol.TType.STRING, (short)2); + private static final org.apache.thrift.protocol.TField NAMES_FIELD_DESC = new org.apache.thrift.protocol.TField("names", org.apache.thrift.protocol.TType.LIST, (short)3); + private static final org.apache.thrift.protocol.TField GET_COL_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("get_col_stats", org.apache.thrift.protocol.TType.BOOL, (short)4); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new GetPartitionsByNamesRequestStandardSchemeFactory()); + schemes.put(TupleScheme.class, new GetPartitionsByNamesRequestTupleSchemeFactory()); + } + + private String db_name; // required + private String tbl_name; // required + private List<String> names; // optional + private boolean get_col_stats; // optional + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { + DB_NAME((short)1, "db_name"), + TBL_NAME((short)2, "tbl_name"), + NAMES((short)3, "names"), + GET_COL_STATS((short)4, "get_col_stats"); + + 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: // DB_NAME + return DB_NAME; + case 2: // TBL_NAME + return TBL_NAME; + case 3: // NAMES + return NAMES; + case 4: // GET_COL_STATS + return GET_COL_STATS; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + private static final int __GET_COL_STATS_ISSET_ID = 0; + private byte __isset_bitfield = 0; + private static final _Fields optionals[] = {_Fields.NAMES,_Fields.GET_COL_STATS}; + public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.DB_NAME, new org.apache.thrift.meta_data.FieldMetaData("db_name", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.TBL_NAME, new org.apache.thrift.meta_data.FieldMetaData("tbl_name", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.NAMES, new org.apache.thrift.meta_data.FieldMetaData("names", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))); + tmpMap.put(_Fields.GET_COL_STATS, new org.apache.thrift.meta_data.FieldMetaData("get_col_stats", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetPartitionsByNamesRequest.class, metaDataMap); + } + + public GetPartitionsByNamesRequest() { + } + + public GetPartitionsByNamesRequest( + String db_name, + String tbl_name) + { + this(); + this.db_name = db_name; + this.tbl_name = tbl_name; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public GetPartitionsByNamesRequest(GetPartitionsByNamesRequest other) { + __isset_bitfield = other.__isset_bitfield; + if (other.isSetDb_name()) { + this.db_name = other.db_name; + } + if (other.isSetTbl_name()) { + this.tbl_name = other.tbl_name; + } + if (other.isSetNames()) { + List<String> __this__names = new ArrayList<String>(other.names); + this.names = __this__names; + } + this.get_col_stats = other.get_col_stats; + } + + public GetPartitionsByNamesRequest deepCopy() { + return new GetPartitionsByNamesRequest(this); + } + + @Override + public void clear() { + this.db_name = null; + this.tbl_name = null; + this.names = null; + setGet_col_statsIsSet(false); + this.get_col_stats = false; + } + + public String getDb_name() { + return this.db_name; + } + + public void setDb_name(String db_name) { + this.db_name = db_name; + } + + public void unsetDb_name() { + this.db_name = null; + } + + /** Returns true if field db_name is set (has been assigned a value) and false otherwise */ + public boolean isSetDb_name() { + return this.db_name != null; + } + + public void setDb_nameIsSet(boolean value) { + if (!value) { + this.db_name = null; + } + } + + public String getTbl_name() { + return this.tbl_name; + } + + public void setTbl_name(String tbl_name) { + this.tbl_name = tbl_name; + } + + public void unsetTbl_name() { + this.tbl_name = null; + } + + /** Returns true if field tbl_name is set (has been assigned a value) and false otherwise */ + public boolean isSetTbl_name() { + return this.tbl_name != null; + } + + public void setTbl_nameIsSet(boolean value) { + if (!value) { + this.tbl_name = null; + } + } + + public int getNamesSize() { + return (this.names == null) ? 0 : this.names.size(); + } + + public java.util.Iterator<String> getNamesIterator() { + return (this.names == null) ? null : this.names.iterator(); + } + + public void addToNames(String elem) { + if (this.names == null) { + this.names = new ArrayList<String>(); + } + this.names.add(elem); + } + + public List<String> getNames() { + return this.names; + } + + public void setNames(List<String> names) { + this.names = names; + } + + public void unsetNames() { + this.names = null; + } + + /** Returns true if field names is set (has been assigned a value) and false otherwise */ + public boolean isSetNames() { + return this.names != null; + } + + public void setNamesIsSet(boolean value) { + if (!value) { + this.names = null; + } + } + + public boolean isGet_col_stats() { + return this.get_col_stats; + } + + public void setGet_col_stats(boolean get_col_stats) { + this.get_col_stats = get_col_stats; + setGet_col_statsIsSet(true); + } + + public void unsetGet_col_stats() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __GET_COL_STATS_ISSET_ID); + } + + /** Returns true if field get_col_stats is set (has been assigned a value) and false otherwise */ + public boolean isSetGet_col_stats() { + return EncodingUtils.testBit(__isset_bitfield, __GET_COL_STATS_ISSET_ID); + } + + public void setGet_col_statsIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __GET_COL_STATS_ISSET_ID, value); + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case DB_NAME: + if (value == null) { + unsetDb_name(); + } else { + setDb_name((String)value); + } + break; + + case TBL_NAME: + if (value == null) { + unsetTbl_name(); + } else { + setTbl_name((String)value); + } + break; + + case NAMES: + if (value == null) { + unsetNames(); + } else { + setNames((List<String>)value); + } + break; + + case GET_COL_STATS: + if (value == null) { + unsetGet_col_stats(); + } else { + setGet_col_stats((Boolean)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case DB_NAME: + return getDb_name(); + + case TBL_NAME: + return getTbl_name(); + + case NAMES: + return getNames(); + + case GET_COL_STATS: + return isGet_col_stats(); + + } + 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 DB_NAME: + return isSetDb_name(); + case TBL_NAME: + return isSetTbl_name(); + case NAMES: + return isSetNames(); + case GET_COL_STATS: + return isSetGet_col_stats(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof GetPartitionsByNamesRequest) + return this.equals((GetPartitionsByNamesRequest)that); + return false; + } + + public boolean equals(GetPartitionsByNamesRequest that) { + if (that == null) + return false; + + boolean this_present_db_name = true && this.isSetDb_name(); + boolean that_present_db_name = true && that.isSetDb_name(); + if (this_present_db_name || that_present_db_name) { + if (!(this_present_db_name && that_present_db_name)) + return false; + if (!this.db_name.equals(that.db_name)) + return false; + } + + boolean this_present_tbl_name = true && this.isSetTbl_name(); + boolean that_present_tbl_name = true && that.isSetTbl_name(); + if (this_present_tbl_name || that_present_tbl_name) { + if (!(this_present_tbl_name && that_present_tbl_name)) + return false; + if (!this.tbl_name.equals(that.tbl_name)) + return false; + } + + boolean this_present_names = true && this.isSetNames(); + boolean that_present_names = true && that.isSetNames(); + if (this_present_names || that_present_names) { + if (!(this_present_names && that_present_names)) + return false; + if (!this.names.equals(that.names)) + return false; + } + + boolean this_present_get_col_stats = true && this.isSetGet_col_stats(); + boolean that_present_get_col_stats = true && that.isSetGet_col_stats(); + if (this_present_get_col_stats || that_present_get_col_stats) { + if (!(this_present_get_col_stats && that_present_get_col_stats)) + return false; + if (this.get_col_stats != that.get_col_stats) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_db_name = true && (isSetDb_name()); + list.add(present_db_name); + if (present_db_name) + list.add(db_name); + + boolean present_tbl_name = true && (isSetTbl_name()); + list.add(present_tbl_name); + if (present_tbl_name) + list.add(tbl_name); + + boolean present_names = true && (isSetNames()); + list.add(present_names); + if (present_names) + list.add(names); + + boolean present_get_col_stats = true && (isSetGet_col_stats()); + list.add(present_get_col_stats); + if (present_get_col_stats) + list.add(get_col_stats); + + return list.hashCode(); + } + + @Override + public int compareTo(GetPartitionsByNamesRequest other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetDb_name()).compareTo(other.isSetDb_name()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetDb_name()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.db_name, other.db_name); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetTbl_name()).compareTo(other.isSetTbl_name()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTbl_name()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tbl_name, other.tbl_name); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetNames()).compareTo(other.isSetNames()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetNames()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.names, other.names); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetGet_col_stats()).compareTo(other.isSetGet_col_stats()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetGet_col_stats()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.get_col_stats, other.get_col_stats); + 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("GetPartitionsByNamesRequest("); + boolean first = true; + + sb.append("db_name:"); + if (this.db_name == null) { + sb.append("null"); + } else { + sb.append(this.db_name); + } + first = false; + if (!first) sb.append(", "); + sb.append("tbl_name:"); + if (this.tbl_name == null) { + sb.append("null"); + } else { + sb.append(this.tbl_name); + } + first = false; + if (isSetNames()) { + if (!first) sb.append(", "); + sb.append("names:"); + if (this.names == null) { + sb.append("null"); + } else { + sb.append(this.names); + } + first = false; + } + if (isSetGet_col_stats()) { + if (!first) sb.append(", "); + sb.append("get_col_stats:"); + sb.append(this.get_col_stats); + first = false; + } + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!isSetDb_name()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'db_name' is unset! Struct:" + toString()); + } + + if (!isSetTbl_name()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'tbl_name' is unset! Struct:" + toString()); + } + + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. + __isset_bitfield = 0; + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class GetPartitionsByNamesRequestStandardSchemeFactory implements SchemeFactory { + public GetPartitionsByNamesRequestStandardScheme getScheme() { + return new GetPartitionsByNamesRequestStandardScheme(); + } + } + + private static class GetPartitionsByNamesRequestStandardScheme extends StandardScheme<GetPartitionsByNamesRequest> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, GetPartitionsByNamesRequest 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: // DB_NAME + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.db_name = iprot.readString(); + struct.setDb_nameIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // TBL_NAME + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.tbl_name = iprot.readString(); + struct.setTbl_nameIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // NAMES + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list554 = iprot.readListBegin(); + struct.names = new ArrayList<String>(_list554.size); + String _elem555; + for (int _i556 = 0; _i556 < _list554.size; ++_i556) + { + _elem555 = iprot.readString(); + struct.names.add(_elem555); + } + iprot.readListEnd(); + } + struct.setNamesIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 4: // GET_COL_STATS + if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) { + struct.get_col_stats = iprot.readBool(); + struct.setGet_col_statsIsSet(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, GetPartitionsByNamesRequest struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.db_name != null) { + oprot.writeFieldBegin(DB_NAME_FIELD_DESC); + oprot.writeString(struct.db_name); + oprot.writeFieldEnd(); + } + if (struct.tbl_name != null) { + oprot.writeFieldBegin(TBL_NAME_FIELD_DESC); + oprot.writeString(struct.tbl_name); + oprot.writeFieldEnd(); + } + if (struct.names != null) { + if (struct.isSetNames()) { + oprot.writeFieldBegin(NAMES_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.names.size())); + for (String _iter557 : struct.names) + { + oprot.writeString(_iter557); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + } + if (struct.isSetGet_col_stats()) { + oprot.writeFieldBegin(GET_COL_STATS_FIELD_DESC); + oprot.writeBool(struct.get_col_stats); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class GetPartitionsByNamesRequestTupleSchemeFactory implements SchemeFactory { + public GetPartitionsByNamesRequestTupleScheme getScheme() { + return new GetPartitionsByNamesRequestTupleScheme(); + } + } + + private static class GetPartitionsByNamesRequestTupleScheme extends TupleScheme<GetPartitionsByNamesRequest> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, GetPartitionsByNamesRequest struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + oprot.writeString(struct.db_name); + oprot.writeString(struct.tbl_name); + BitSet optionals = new BitSet(); + if (struct.isSetNames()) { + optionals.set(0); + } + if (struct.isSetGet_col_stats()) { + optionals.set(1); + } + oprot.writeBitSet(optionals, 2); + if (struct.isSetNames()) { + { + oprot.writeI32(struct.names.size()); + for (String _iter558 : struct.names) + { + oprot.writeString(_iter558); + } + } + } + if (struct.isSetGet_col_stats()) { + oprot.writeBool(struct.get_col_stats); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, GetPartitionsByNamesRequest struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + struct.db_name = iprot.readString(); + struct.setDb_nameIsSet(true); + struct.tbl_name = iprot.readString(); + struct.setTbl_nameIsSet(true); + BitSet incoming = iprot.readBitSet(2); + if (incoming.get(0)) { + { + org.apache.thrift.protocol.TList _list559 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.names = new ArrayList<String>(_list559.size); + String _elem560; + for (int _i561 = 0; _i561 < _list559.size; ++_i561) + { + _elem560 = iprot.readString(); + struct.names.add(_elem560); + } + } + struct.setNamesIsSet(true); + } + if (incoming.get(1)) { + struct.get_col_stats = iprot.readBool(); + struct.setGet_col_statsIsSet(true); + } + } + } + +} +
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsByNamesResult.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsByNamesResult.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsByNamesResult.java new file mode 100644 index 0000000..d32e4c2 --- /dev/null +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsByNamesResult.java @@ -0,0 +1,443 @@ +/** + * 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)") +@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class GetPartitionsByNamesResult implements org.apache.thrift.TBase<GetPartitionsByNamesResult, GetPartitionsByNamesResult._Fields>, java.io.Serializable, Cloneable, Comparable<GetPartitionsByNamesResult> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetPartitionsByNamesResult"); + + private static final org.apache.thrift.protocol.TField PARTITIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("partitions", 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 GetPartitionsByNamesResultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new GetPartitionsByNamesResultTupleSchemeFactory()); + } + + private List<Partition> partitions; // 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 { + PARTITIONS((short)1, "partitions"); + + 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: // PARTITIONS + return PARTITIONS; + 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.PARTITIONS, new org.apache.thrift.meta_data.FieldMetaData("partitions", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Partition.class)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetPartitionsByNamesResult.class, metaDataMap); + } + + public GetPartitionsByNamesResult() { + } + + public GetPartitionsByNamesResult( + List<Partition> partitions) + { + this(); + this.partitions = partitions; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public GetPartitionsByNamesResult(GetPartitionsByNamesResult other) { + if (other.isSetPartitions()) { + List<Partition> __this__partitions = new ArrayList<Partition>(other.partitions.size()); + for (Partition other_element : other.partitions) { + __this__partitions.add(new Partition(other_element)); + } + this.partitions = __this__partitions; + } + } + + public GetPartitionsByNamesResult deepCopy() { + return new GetPartitionsByNamesResult(this); + } + + @Override + public void clear() { + this.partitions = null; + } + + public int getPartitionsSize() { + return (this.partitions == null) ? 0 : this.partitions.size(); + } + + public java.util.Iterator<Partition> getPartitionsIterator() { + return (this.partitions == null) ? null : this.partitions.iterator(); + } + + public void addToPartitions(Partition elem) { + if (this.partitions == null) { + this.partitions = new ArrayList<Partition>(); + } + this.partitions.add(elem); + } + + public List<Partition> getPartitions() { + return this.partitions; + } + + public void setPartitions(List<Partition> partitions) { + this.partitions = partitions; + } + + public void unsetPartitions() { + this.partitions = null; + } + + /** Returns true if field partitions is set (has been assigned a value) and false otherwise */ + public boolean isSetPartitions() { + return this.partitions != null; + } + + public void setPartitionsIsSet(boolean value) { + if (!value) { + this.partitions = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case PARTITIONS: + if (value == null) { + unsetPartitions(); + } else { + setPartitions((List<Partition>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case PARTITIONS: + return getPartitions(); + + } + 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 PARTITIONS: + return isSetPartitions(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof GetPartitionsByNamesResult) + return this.equals((GetPartitionsByNamesResult)that); + return false; + } + + public boolean equals(GetPartitionsByNamesResult that) { + if (that == null) + return false; + + boolean this_present_partitions = true && this.isSetPartitions(); + boolean that_present_partitions = true && that.isSetPartitions(); + if (this_present_partitions || that_present_partitions) { + if (!(this_present_partitions && that_present_partitions)) + return false; + if (!this.partitions.equals(that.partitions)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_partitions = true && (isSetPartitions()); + list.add(present_partitions); + if (present_partitions) + list.add(partitions); + + return list.hashCode(); + } + + @Override + public int compareTo(GetPartitionsByNamesResult other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetPartitions()).compareTo(other.isSetPartitions()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetPartitions()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partitions, other.partitions); + 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("GetPartitionsByNamesResult("); + boolean first = true; + + sb.append("partitions:"); + if (this.partitions == null) { + sb.append("null"); + } else { + sb.append(this.partitions); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!isSetPartitions()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'partitions' 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 GetPartitionsByNamesResultStandardSchemeFactory implements SchemeFactory { + public GetPartitionsByNamesResultStandardScheme getScheme() { + return new GetPartitionsByNamesResultStandardScheme(); + } + } + + private static class GetPartitionsByNamesResultStandardScheme extends StandardScheme<GetPartitionsByNamesResult> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, GetPartitionsByNamesResult 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: // PARTITIONS + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list562 = iprot.readListBegin(); + struct.partitions = new ArrayList<Partition>(_list562.size); + Partition _elem563; + for (int _i564 = 0; _i564 < _list562.size; ++_i564) + { + _elem563 = new Partition(); + _elem563.read(iprot); + struct.partitions.add(_elem563); + } + iprot.readListEnd(); + } + struct.setPartitionsIsSet(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, GetPartitionsByNamesResult struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.partitions != null) { + oprot.writeFieldBegin(PARTITIONS_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.partitions.size())); + for (Partition _iter565 : struct.partitions) + { + _iter565.write(oprot); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class GetPartitionsByNamesResultTupleSchemeFactory implements SchemeFactory { + public GetPartitionsByNamesResultTupleScheme getScheme() { + return new GetPartitionsByNamesResultTupleScheme(); + } + } + + private static class GetPartitionsByNamesResultTupleScheme extends TupleScheme<GetPartitionsByNamesResult> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, GetPartitionsByNamesResult struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + { + oprot.writeI32(struct.partitions.size()); + for (Partition _iter566 : struct.partitions) + { + _iter566.write(oprot); + } + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, GetPartitionsByNamesResult struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + { + org.apache.thrift.protocol.TList _list567 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.partitions = new ArrayList<Partition>(_list567.size); + Partition _elem568; + for (int _i569 = 0; _i569 < _list567.size; ++_i569) + { + _elem568 = new Partition(); + _elem568.read(iprot); + struct.partitions.add(_elem568); + } + } + struct.setPartitionsIsSet(true); + } + } + +} + http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsFilterSpec.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsFilterSpec.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsFilterSpec.java index b5a2b68..27c81f7 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsFilterSpec.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsFilterSpec.java @@ -444,13 +444,13 @@ import org.slf4j.LoggerFactory; case 8: // FILTERS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list992 = iprot.readListBegin(); - struct.filters = new ArrayList<String>(_list992.size); - String _elem993; - for (int _i994 = 0; _i994 < _list992.size; ++_i994) + org.apache.thrift.protocol.TList _list1008 = iprot.readListBegin(); + struct.filters = new ArrayList<String>(_list1008.size); + String _elem1009; + for (int _i1010 = 0; _i1010 < _list1008.size; ++_i1010) { - _elem993 = iprot.readString(); - struct.filters.add(_elem993); + _elem1009 = iprot.readString(); + struct.filters.add(_elem1009); } iprot.readListEnd(); } @@ -484,9 +484,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(FILTERS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.filters.size())); - for (String _iter995 : struct.filters) + for (String _iter1011 : struct.filters) { - oprot.writeString(_iter995); + oprot.writeString(_iter1011); } oprot.writeListEnd(); } @@ -524,9 +524,9 @@ import org.slf4j.LoggerFactory; if (struct.isSetFilters()) { { oprot.writeI32(struct.filters.size()); - for (String _iter996 : struct.filters) + for (String _iter1012 : struct.filters) { - oprot.writeString(_iter996); + oprot.writeString(_iter1012); } } } @@ -542,13 +542,13 @@ import org.slf4j.LoggerFactory; } if (incoming.get(1)) { { - org.apache.thrift.protocol.TList _list997 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.filters = new ArrayList<String>(_list997.size); - String _elem998; - for (int _i999 = 0; _i999 < _list997.size; ++_i999) + org.apache.thrift.protocol.TList _list1013 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.filters = new ArrayList<String>(_list1013.size); + String _elem1014; + for (int _i1015 = 0; _i1015 < _list1013.size; ++_i1015) { - _elem998 = iprot.readString(); - struct.filters.add(_elem998); + _elem1014 = iprot.readString(); + struct.filters.add(_elem1014); } } struct.setFiltersIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsProjectionSpec.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsProjectionSpec.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsProjectionSpec.java index e6c9c06..30bae47 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsProjectionSpec.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsProjectionSpec.java @@ -509,13 +509,13 @@ import org.slf4j.LoggerFactory; case 1: // FIELD_LIST if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list984 = iprot.readListBegin(); - struct.fieldList = new ArrayList<String>(_list984.size); - String _elem985; - for (int _i986 = 0; _i986 < _list984.size; ++_i986) + org.apache.thrift.protocol.TList _list1000 = iprot.readListBegin(); + struct.fieldList = new ArrayList<String>(_list1000.size); + String _elem1001; + for (int _i1002 = 0; _i1002 < _list1000.size; ++_i1002) { - _elem985 = iprot.readString(); - struct.fieldList.add(_elem985); + _elem1001 = iprot.readString(); + struct.fieldList.add(_elem1001); } iprot.readListEnd(); } @@ -557,9 +557,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(FIELD_LIST_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.fieldList.size())); - for (String _iter987 : struct.fieldList) + for (String _iter1003 : struct.fieldList) { - oprot.writeString(_iter987); + oprot.writeString(_iter1003); } oprot.writeListEnd(); } @@ -606,9 +606,9 @@ import org.slf4j.LoggerFactory; if (struct.isSetFieldList()) { { oprot.writeI32(struct.fieldList.size()); - for (String _iter988 : struct.fieldList) + for (String _iter1004 : struct.fieldList) { - oprot.writeString(_iter988); + oprot.writeString(_iter1004); } } } @@ -626,13 +626,13 @@ import org.slf4j.LoggerFactory; BitSet incoming = iprot.readBitSet(3); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list989 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.fieldList = new ArrayList<String>(_list989.size); - String _elem990; - for (int _i991 = 0; _i991 < _list989.size; ++_i991) + org.apache.thrift.protocol.TList _list1005 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.fieldList = new ArrayList<String>(_list1005.size); + String _elem1006; + for (int _i1007 = 0; _i1007 < _list1005.size; ++_i1007) { - _elem990 = iprot.readString(); - struct.fieldList.add(_elem990); + _elem1006 = iprot.readString(); + struct.fieldList.add(_elem1006); } } struct.setFieldListIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsRequest.java index 7ec107e..97e24f8 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsRequest.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsRequest.java @@ -960,13 +960,13 @@ import org.slf4j.LoggerFactory; case 6: // GROUP_NAMES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list1008 = iprot.readListBegin(); - struct.groupNames = new ArrayList<String>(_list1008.size); - String _elem1009; - for (int _i1010 = 0; _i1010 < _list1008.size; ++_i1010) + org.apache.thrift.protocol.TList _list1024 = iprot.readListBegin(); + struct.groupNames = new ArrayList<String>(_list1024.size); + String _elem1025; + for (int _i1026 = 0; _i1026 < _list1024.size; ++_i1026) { - _elem1009 = iprot.readString(); - struct.groupNames.add(_elem1009); + _elem1025 = iprot.readString(); + struct.groupNames.add(_elem1025); } iprot.readListEnd(); } @@ -1040,9 +1040,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(GROUP_NAMES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.groupNames.size())); - for (String _iter1011 : struct.groupNames) + for (String _iter1027 : struct.groupNames) { - oprot.writeString(_iter1011); + oprot.writeString(_iter1027); } oprot.writeListEnd(); } @@ -1120,9 +1120,9 @@ import org.slf4j.LoggerFactory; if (struct.isSetGroupNames()) { { oprot.writeI32(struct.groupNames.size()); - for (String _iter1012 : struct.groupNames) + for (String _iter1028 : struct.groupNames) { - oprot.writeString(_iter1012); + oprot.writeString(_iter1028); } } } @@ -1160,13 +1160,13 @@ import org.slf4j.LoggerFactory; } if (incoming.get(5)) { { - org.apache.thrift.protocol.TList _list1013 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.groupNames = new ArrayList<String>(_list1013.size); - String _elem1014; - for (int _i1015 = 0; _i1015 < _list1013.size; ++_i1015) + org.apache.thrift.protocol.TList _list1029 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.groupNames = new ArrayList<String>(_list1029.size); + String _elem1030; + for (int _i1031 = 0; _i1031 < _list1029.size; ++_i1031) { - _elem1014 = iprot.readString(); - struct.groupNames.add(_elem1014); + _elem1030 = iprot.readString(); + struct.groupNames.add(_elem1030); } } struct.setGroupNamesIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsResponse.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsResponse.java index faac848..b8216c8 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsResponse.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPartitionsResponse.java @@ -350,14 +350,14 @@ import org.slf4j.LoggerFactory; case 1: // PARTITION_SPEC if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list1000 = iprot.readListBegin(); - struct.partitionSpec = new ArrayList<PartitionSpec>(_list1000.size); - PartitionSpec _elem1001; - for (int _i1002 = 0; _i1002 < _list1000.size; ++_i1002) + org.apache.thrift.protocol.TList _list1016 = iprot.readListBegin(); + struct.partitionSpec = new ArrayList<PartitionSpec>(_list1016.size); + PartitionSpec _elem1017; + for (int _i1018 = 0; _i1018 < _list1016.size; ++_i1018) { - _elem1001 = new PartitionSpec(); - _elem1001.read(iprot); - struct.partitionSpec.add(_elem1001); + _elem1017 = new PartitionSpec(); + _elem1017.read(iprot); + struct.partitionSpec.add(_elem1017); } iprot.readListEnd(); } @@ -383,9 +383,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(PARTITION_SPEC_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.partitionSpec.size())); - for (PartitionSpec _iter1003 : struct.partitionSpec) + for (PartitionSpec _iter1019 : struct.partitionSpec) { - _iter1003.write(oprot); + _iter1019.write(oprot); } oprot.writeListEnd(); } @@ -416,9 +416,9 @@ import org.slf4j.LoggerFactory; if (struct.isSetPartitionSpec()) { { oprot.writeI32(struct.partitionSpec.size()); - for (PartitionSpec _iter1004 : struct.partitionSpec) + for (PartitionSpec _iter1020 : struct.partitionSpec) { - _iter1004.write(oprot); + _iter1020.write(oprot); } } } @@ -430,14 +430,14 @@ import org.slf4j.LoggerFactory; BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list1005 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.partitionSpec = new ArrayList<PartitionSpec>(_list1005.size); - PartitionSpec _elem1006; - for (int _i1007 = 0; _i1007 < _list1005.size; ++_i1007) + org.apache.thrift.protocol.TList _list1021 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.partitionSpec = new ArrayList<PartitionSpec>(_list1021.size); + PartitionSpec _elem1022; + for (int _i1023 = 0; _i1023 < _list1021.size; ++_i1023) { - _elem1006 = new PartitionSpec(); - _elem1006.read(iprot); - struct.partitionSpec.add(_elem1006); + _elem1022 = new PartitionSpec(); + _elem1022.read(iprot); + struct.partitionSpec.add(_elem1022); } } struct.setPartitionSpecIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java index da36157..ed9b709 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java @@ -606,13 +606,13 @@ import org.slf4j.LoggerFactory; case 2: // TBL_NAMES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list872 = iprot.readListBegin(); - struct.tblNames = new ArrayList<String>(_list872.size); - String _elem873; - for (int _i874 = 0; _i874 < _list872.size; ++_i874) + org.apache.thrift.protocol.TList _list888 = iprot.readListBegin(); + struct.tblNames = new ArrayList<String>(_list888.size); + String _elem889; + for (int _i890 = 0; _i890 < _list888.size; ++_i890) { - _elem873 = iprot.readString(); - struct.tblNames.add(_elem873); + _elem889 = iprot.readString(); + struct.tblNames.add(_elem889); } iprot.readListEnd(); } @@ -661,9 +661,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(TBL_NAMES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.tblNames.size())); - for (String _iter875 : struct.tblNames) + for (String _iter891 : struct.tblNames) { - oprot.writeString(_iter875); + oprot.writeString(_iter891); } oprot.writeListEnd(); } @@ -716,9 +716,9 @@ import org.slf4j.LoggerFactory; if (struct.isSetTblNames()) { { oprot.writeI32(struct.tblNames.size()); - for (String _iter876 : struct.tblNames) + for (String _iter892 : struct.tblNames) { - oprot.writeString(_iter876); + oprot.writeString(_iter892); } } } @@ -738,13 +738,13 @@ import org.slf4j.LoggerFactory; BitSet incoming = iprot.readBitSet(3); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list877 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.tblNames = new ArrayList<String>(_list877.size); - String _elem878; - for (int _i879 = 0; _i879 < _list877.size; ++_i879) + org.apache.thrift.protocol.TList _list893 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.tblNames = new ArrayList<String>(_list893.size); + String _elem894; + for (int _i895 = 0; _i895 < _list893.size; ++_i895) { - _elem878 = iprot.readString(); - struct.tblNames.add(_elem878); + _elem894 = iprot.readString(); + struct.tblNames.add(_elem894); } } struct.setTblNamesIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java index b3cfc88..31584b0 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java @@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory; case 1: // TABLES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list880 = iprot.readListBegin(); - struct.tables = new ArrayList<Table>(_list880.size); - Table _elem881; - for (int _i882 = 0; _i882 < _list880.size; ++_i882) + org.apache.thrift.protocol.TList _list896 = iprot.readListBegin(); + struct.tables = new ArrayList<Table>(_list896.size); + Table _elem897; + for (int _i898 = 0; _i898 < _list896.size; ++_i898) { - _elem881 = new Table(); - _elem881.read(iprot); - struct.tables.add(_elem881); + _elem897 = new Table(); + _elem897.read(iprot); + struct.tables.add(_elem897); } iprot.readListEnd(); } @@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(TABLES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.tables.size())); - for (Table _iter883 : struct.tables) + for (Table _iter899 : struct.tables) { - _iter883.write(oprot); + _iter899.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory; TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.tables.size()); - for (Table _iter884 : struct.tables) + for (Table _iter900 : struct.tables) { - _iter884.write(oprot); + _iter900.write(oprot); } } } @@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory; public void read(org.apache.thrift.protocol.TProtocol prot, GetTablesResult struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list885 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.tables = new ArrayList<Table>(_list885.size); - Table _elem886; - for (int _i887 = 0; _i887 < _list885.size; ++_i887) + org.apache.thrift.protocol.TList _list901 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.tables = new ArrayList<Table>(_list901.size); + Table _elem902; + for (int _i903 = 0; _i903 < _list901.size; ++_i903) { - _elem886 = new Table(); - _elem886.read(iprot); - struct.tables.add(_elem886); + _elem902 = new Table(); + _elem902.read(iprot); + struct.tables.add(_elem902); } } struct.setTablesIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java index 1be6d23..70bfbd2 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java @@ -513,13 +513,13 @@ import org.slf4j.LoggerFactory; case 1: // FULL_TABLE_NAMES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list626 = iprot.readListBegin(); - struct.fullTableNames = new ArrayList<String>(_list626.size); - String _elem627; - for (int _i628 = 0; _i628 < _list626.size; ++_i628) + org.apache.thrift.protocol.TList _list642 = iprot.readListBegin(); + struct.fullTableNames = new ArrayList<String>(_list642.size); + String _elem643; + for (int _i644 = 0; _i644 < _list642.size; ++_i644) { - _elem627 = iprot.readString(); - struct.fullTableNames.add(_elem627); + _elem643 = iprot.readString(); + struct.fullTableNames.add(_elem643); } iprot.readListEnd(); } @@ -561,9 +561,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(FULL_TABLE_NAMES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.fullTableNames.size())); - for (String _iter629 : struct.fullTableNames) + for (String _iter645 : struct.fullTableNames) { - oprot.writeString(_iter629); + oprot.writeString(_iter645); } oprot.writeListEnd(); } @@ -600,9 +600,9 @@ import org.slf4j.LoggerFactory; TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.fullTableNames.size()); - for (String _iter630 : struct.fullTableNames) + for (String _iter646 : struct.fullTableNames) { - oprot.writeString(_iter630); + oprot.writeString(_iter646); } } BitSet optionals = new BitSet(); @@ -625,13 +625,13 @@ import org.slf4j.LoggerFactory; public void read(org.apache.thrift.protocol.TProtocol prot, GetValidWriteIdsRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list631 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.fullTableNames = new ArrayList<String>(_list631.size); - String _elem632; - for (int _i633 = 0; _i633 < _list631.size; ++_i633) + org.apache.thrift.protocol.TList _list647 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.fullTableNames = new ArrayList<String>(_list647.size); + String _elem648; + for (int _i649 = 0; _i649 < _list647.size; ++_i649) { - _elem632 = iprot.readString(); - struct.fullTableNames.add(_elem632); + _elem648 = iprot.readString(); + struct.fullTableNames.add(_elem648); } } struct.setFullTableNamesIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java index 6c3617e..fc94183 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java @@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory; case 1: // TBL_VALID_WRITE_IDS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list642 = iprot.readListBegin(); - struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list642.size); - TableValidWriteIds _elem643; - for (int _i644 = 0; _i644 < _list642.size; ++_i644) + org.apache.thrift.protocol.TList _list658 = iprot.readListBegin(); + struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list658.size); + TableValidWriteIds _elem659; + for (int _i660 = 0; _i660 < _list658.size; ++_i660) { - _elem643 = new TableValidWriteIds(); - _elem643.read(iprot); - struct.tblValidWriteIds.add(_elem643); + _elem659 = new TableValidWriteIds(); + _elem659.read(iprot); + struct.tblValidWriteIds.add(_elem659); } iprot.readListEnd(); } @@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(TBL_VALID_WRITE_IDS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.tblValidWriteIds.size())); - for (TableValidWriteIds _iter645 : struct.tblValidWriteIds) + for (TableValidWriteIds _iter661 : struct.tblValidWriteIds) { - _iter645.write(oprot); + _iter661.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory; TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.tblValidWriteIds.size()); - for (TableValidWriteIds _iter646 : struct.tblValidWriteIds) + for (TableValidWriteIds _iter662 : struct.tblValidWriteIds) { - _iter646.write(oprot); + _iter662.write(oprot); } } } @@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory; public void read(org.apache.thrift.protocol.TProtocol prot, GetValidWriteIdsResponse struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list647 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list647.size); - TableValidWriteIds _elem648; - for (int _i649 = 0; _i649 < _list647.size; ++_i649) + org.apache.thrift.protocol.TList _list663 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list663.size); + TableValidWriteIds _elem664; + for (int _i665 = 0; _i665 < _list663.size; ++_i665) { - _elem648 = new TableValidWriteIds(); - _elem648.read(iprot); - struct.tblValidWriteIds.add(_elem648); + _elem664 = new TableValidWriteIds(); + _elem664.read(iprot); + struct.tblValidWriteIds.add(_elem664); } } struct.setTblValidWriteIdsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java index 761ddb3..cfc8740 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java @@ -453,13 +453,13 @@ import org.slf4j.LoggerFactory; case 1: // ABORTED if (schemeField.type == org.apache.thrift.protocol.TType.SET) { { - org.apache.thrift.protocol.TSet _set690 = iprot.readSetBegin(); - struct.aborted = new HashSet<Long>(2*_set690.size); - long _elem691; - for (int _i692 = 0; _i692 < _set690.size; ++_i692) + org.apache.thrift.protocol.TSet _set706 = iprot.readSetBegin(); + struct.aborted = new HashSet<Long>(2*_set706.size); + long _elem707; + for (int _i708 = 0; _i708 < _set706.size; ++_i708) { - _elem691 = iprot.readI64(); - struct.aborted.add(_elem691); + _elem707 = iprot.readI64(); + struct.aborted.add(_elem707); } iprot.readSetEnd(); } @@ -471,13 +471,13 @@ import org.slf4j.LoggerFactory; case 2: // NOSUCH if (schemeField.type == org.apache.thrift.protocol.TType.SET) { { - org.apache.thrift.protocol.TSet _set693 = iprot.readSetBegin(); - struct.nosuch = new HashSet<Long>(2*_set693.size); - long _elem694; - for (int _i695 = 0; _i695 < _set693.size; ++_i695) + org.apache.thrift.protocol.TSet _set709 = iprot.readSetBegin(); + struct.nosuch = new HashSet<Long>(2*_set709.size); + long _elem710; + for (int _i711 = 0; _i711 < _set709.size; ++_i711) { - _elem694 = iprot.readI64(); - struct.nosuch.add(_elem694); + _elem710 = iprot.readI64(); + struct.nosuch.add(_elem710); } iprot.readSetEnd(); } @@ -503,9 +503,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(ABORTED_FIELD_DESC); { oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, struct.aborted.size())); - for (long _iter696 : struct.aborted) + for (long _iter712 : struct.aborted) { - oprot.writeI64(_iter696); + oprot.writeI64(_iter712); } oprot.writeSetEnd(); } @@ -515,9 +515,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(NOSUCH_FIELD_DESC); { oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, struct.nosuch.size())); - for (long _iter697 : struct.nosuch) + for (long _iter713 : struct.nosuch) { - oprot.writeI64(_iter697); + oprot.writeI64(_iter713); } oprot.writeSetEnd(); } @@ -542,16 +542,16 @@ import org.slf4j.LoggerFactory; TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.aborted.size()); - for (long _iter698 : struct.aborted) + for (long _iter714 : struct.aborted) { - oprot.writeI64(_iter698); + oprot.writeI64(_iter714); } } { oprot.writeI32(struct.nosuch.size()); - for (long _iter699 : struct.nosuch) + for (long _iter715 : struct.nosuch) { - oprot.writeI64(_iter699); + oprot.writeI64(_iter715); } } } @@ -560,24 +560,24 @@ import org.slf4j.LoggerFactory; 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 _set700 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.aborted = new HashSet<Long>(2*_set700.size); - long _elem701; - for (int _i702 = 0; _i702 < _set700.size; ++_i702) + org.apache.thrift.protocol.TSet _set716 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.aborted = new HashSet<Long>(2*_set716.size); + long _elem717; + for (int _i718 = 0; _i718 < _set716.size; ++_i718) { - _elem701 = iprot.readI64(); - struct.aborted.add(_elem701); + _elem717 = iprot.readI64(); + struct.aborted.add(_elem717); } } struct.setAbortedIsSet(true); { - org.apache.thrift.protocol.TSet _set703 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.nosuch = new HashSet<Long>(2*_set703.size); - long _elem704; - for (int _i705 = 0; _i705 < _set703.size; ++_i705) + org.apache.thrift.protocol.TSet _set719 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.nosuch = new HashSet<Long>(2*_set719.size); + long _elem720; + for (int _i721 = 0; _i721 < _set719.size; ++_i721) { - _elem704 = iprot.readI64(); - struct.nosuch.add(_elem704); + _elem720 = iprot.readI64(); + struct.nosuch.add(_elem720); } } struct.setNosuchIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java index f1ba643..0279ee1 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java @@ -636,13 +636,13 @@ import org.slf4j.LoggerFactory; case 2: // FILES_ADDED if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list756 = iprot.readListBegin(); - struct.filesAdded = new ArrayList<String>(_list756.size); - String _elem757; - for (int _i758 = 0; _i758 < _list756.size; ++_i758) + org.apache.thrift.protocol.TList _list772 = iprot.readListBegin(); + struct.filesAdded = new ArrayList<String>(_list772.size); + String _elem773; + for (int _i774 = 0; _i774 < _list772.size; ++_i774) { - _elem757 = iprot.readString(); - struct.filesAdded.add(_elem757); + _elem773 = iprot.readString(); + struct.filesAdded.add(_elem773); } iprot.readListEnd(); } @@ -654,13 +654,13 @@ import org.slf4j.LoggerFactory; case 3: // FILES_ADDED_CHECKSUM if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list759 = iprot.readListBegin(); - struct.filesAddedChecksum = new ArrayList<String>(_list759.size); - String _elem760; - for (int _i761 = 0; _i761 < _list759.size; ++_i761) + org.apache.thrift.protocol.TList _list775 = iprot.readListBegin(); + struct.filesAddedChecksum = new ArrayList<String>(_list775.size); + String _elem776; + for (int _i777 = 0; _i777 < _list775.size; ++_i777) { - _elem760 = iprot.readString(); - struct.filesAddedChecksum.add(_elem760); + _elem776 = iprot.readString(); + struct.filesAddedChecksum.add(_elem776); } iprot.readListEnd(); } @@ -672,13 +672,13 @@ import org.slf4j.LoggerFactory; case 4: // SUB_DIRECTORY_LIST if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list762 = iprot.readListBegin(); - struct.subDirectoryList = new ArrayList<String>(_list762.size); - String _elem763; - for (int _i764 = 0; _i764 < _list762.size; ++_i764) + org.apache.thrift.protocol.TList _list778 = iprot.readListBegin(); + struct.subDirectoryList = new ArrayList<String>(_list778.size); + String _elem779; + for (int _i780 = 0; _i780 < _list778.size; ++_i780) { - _elem763 = iprot.readString(); - struct.subDirectoryList.add(_elem763); + _elem779 = iprot.readString(); + struct.subDirectoryList.add(_elem779); } iprot.readListEnd(); } @@ -709,9 +709,9 @@ import org.slf4j.LoggerFactory; 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 _iter765 : struct.filesAdded) + for (String _iter781 : struct.filesAdded) { - oprot.writeString(_iter765); + oprot.writeString(_iter781); } oprot.writeListEnd(); } @@ -722,9 +722,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(FILES_ADDED_CHECKSUM_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.filesAddedChecksum.size())); - for (String _iter766 : struct.filesAddedChecksum) + for (String _iter782 : struct.filesAddedChecksum) { - oprot.writeString(_iter766); + oprot.writeString(_iter782); } oprot.writeListEnd(); } @@ -736,9 +736,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(SUB_DIRECTORY_LIST_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.subDirectoryList.size())); - for (String _iter767 : struct.subDirectoryList) + for (String _iter783 : struct.subDirectoryList) { - oprot.writeString(_iter767); + oprot.writeString(_iter783); } oprot.writeListEnd(); } @@ -764,9 +764,9 @@ import org.slf4j.LoggerFactory; TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.filesAdded.size()); - for (String _iter768 : struct.filesAdded) + for (String _iter784 : struct.filesAdded) { - oprot.writeString(_iter768); + oprot.writeString(_iter784); } } BitSet optionals = new BitSet(); @@ -786,18 +786,18 @@ import org.slf4j.LoggerFactory; if (struct.isSetFilesAddedChecksum()) { { oprot.writeI32(struct.filesAddedChecksum.size()); - for (String _iter769 : struct.filesAddedChecksum) + for (String _iter785 : struct.filesAddedChecksum) { - oprot.writeString(_iter769); + oprot.writeString(_iter785); } } } if (struct.isSetSubDirectoryList()) { { oprot.writeI32(struct.subDirectoryList.size()); - for (String _iter770 : struct.subDirectoryList) + for (String _iter786 : struct.subDirectoryList) { - oprot.writeString(_iter770); + oprot.writeString(_iter786); } } } @@ -807,13 +807,13 @@ import org.slf4j.LoggerFactory; 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 _list771 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.filesAdded = new ArrayList<String>(_list771.size); - String _elem772; - for (int _i773 = 0; _i773 < _list771.size; ++_i773) + org.apache.thrift.protocol.TList _list787 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.filesAdded = new ArrayList<String>(_list787.size); + String _elem788; + for (int _i789 = 0; _i789 < _list787.size; ++_i789) { - _elem772 = iprot.readString(); - struct.filesAdded.add(_elem772); + _elem788 = iprot.readString(); + struct.filesAdded.add(_elem788); } } struct.setFilesAddedIsSet(true); @@ -824,26 +824,26 @@ import org.slf4j.LoggerFactory; } if (incoming.get(1)) { { - org.apache.thrift.protocol.TList _list774 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.filesAddedChecksum = new ArrayList<String>(_list774.size); - String _elem775; - for (int _i776 = 0; _i776 < _list774.size; ++_i776) + org.apache.thrift.protocol.TList _list790 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.filesAddedChecksum = new ArrayList<String>(_list790.size); + String _elem791; + for (int _i792 = 0; _i792 < _list790.size; ++_i792) { - _elem775 = iprot.readString(); - struct.filesAddedChecksum.add(_elem775); + _elem791 = iprot.readString(); + struct.filesAddedChecksum.add(_elem791); } } struct.setFilesAddedChecksumIsSet(true); } if (incoming.get(2)) { { - org.apache.thrift.protocol.TList _list777 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.subDirectoryList = new ArrayList<String>(_list777.size); - String _elem778; - for (int _i779 = 0; _i779 < _list777.size; ++_i779) + org.apache.thrift.protocol.TList _list793 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.subDirectoryList = new ArrayList<String>(_list793.size); + String _elem794; + for (int _i795 = 0; _i795 < _list793.size; ++_i795) { - _elem778 = iprot.readString(); - struct.subDirectoryList.add(_elem778); + _elem794 = iprot.readString(); + struct.subDirectoryList.add(_elem794); } } struct.setSubDirectoryListIsSet(true);
