Added: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionSpecWithSharedSD.java URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionSpecWithSharedSD.java?rev=1622748&view=auto ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionSpecWithSharedSD.java (added) +++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionSpecWithSharedSD.java Fri Sep 5 17:52:32 2014 @@ -0,0 +1,554 @@ +/** + * Autogenerated by Thrift Compiler (0.9.0) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.hadoop.hive.metastore.api; + +import org.apache.commons.lang.builder.HashCodeBuilder; +import org.apache.thrift.scheme.IScheme; +import org.apache.thrift.scheme.SchemeFactory; +import org.apache.thrift.scheme.StandardScheme; + +import org.apache.thrift.scheme.TupleScheme; +import org.apache.thrift.protocol.TTupleProtocol; +import org.apache.thrift.protocol.TProtocolException; +import org.apache.thrift.EncodingUtils; +import org.apache.thrift.TException; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +public class PartitionSpecWithSharedSD implements org.apache.thrift.TBase<PartitionSpecWithSharedSD, PartitionSpecWithSharedSD._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("PartitionSpecWithSharedSD"); + + 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 org.apache.thrift.protocol.TField SD_FIELD_DESC = new org.apache.thrift.protocol.TField("sd", org.apache.thrift.protocol.TType.STRUCT, (short)2); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new PartitionSpecWithSharedSDStandardSchemeFactory()); + schemes.put(TupleScheme.class, new PartitionSpecWithSharedSDTupleSchemeFactory()); + } + + private List<PartitionWithoutSD> partitions; // required + private StorageDescriptor sd; // 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"), + SD((short)2, "sd"); + + 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; + case 2: // SD + return SD; + 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.DEFAULT, + 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, PartitionWithoutSD.class)))); + tmpMap.put(_Fields.SD, new org.apache.thrift.meta_data.FieldMetaData("sd", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, StorageDescriptor.class))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(PartitionSpecWithSharedSD.class, metaDataMap); + } + + public PartitionSpecWithSharedSD() { + } + + public PartitionSpecWithSharedSD( + List<PartitionWithoutSD> partitions, + StorageDescriptor sd) + { + this(); + this.partitions = partitions; + this.sd = sd; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public PartitionSpecWithSharedSD(PartitionSpecWithSharedSD other) { + if (other.isSetPartitions()) { + List<PartitionWithoutSD> __this__partitions = new ArrayList<PartitionWithoutSD>(); + for (PartitionWithoutSD other_element : other.partitions) { + __this__partitions.add(new PartitionWithoutSD(other_element)); + } + this.partitions = __this__partitions; + } + if (other.isSetSd()) { + this.sd = new StorageDescriptor(other.sd); + } + } + + public PartitionSpecWithSharedSD deepCopy() { + return new PartitionSpecWithSharedSD(this); + } + + @Override + public void clear() { + this.partitions = null; + this.sd = null; + } + + public int getPartitionsSize() { + return (this.partitions == null) ? 0 : this.partitions.size(); + } + + public java.util.Iterator<PartitionWithoutSD> getPartitionsIterator() { + return (this.partitions == null) ? null : this.partitions.iterator(); + } + + public void addToPartitions(PartitionWithoutSD elem) { + if (this.partitions == null) { + this.partitions = new ArrayList<PartitionWithoutSD>(); + } + this.partitions.add(elem); + } + + public List<PartitionWithoutSD> getPartitions() { + return this.partitions; + } + + public void setPartitions(List<PartitionWithoutSD> 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 StorageDescriptor getSd() { + return this.sd; + } + + public void setSd(StorageDescriptor sd) { + this.sd = sd; + } + + public void unsetSd() { + this.sd = null; + } + + /** Returns true if field sd is set (has been assigned a value) and false otherwise */ + public boolean isSetSd() { + return this.sd != null; + } + + public void setSdIsSet(boolean value) { + if (!value) { + this.sd = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case PARTITIONS: + if (value == null) { + unsetPartitions(); + } else { + setPartitions((List<PartitionWithoutSD>)value); + } + break; + + case SD: + if (value == null) { + unsetSd(); + } else { + setSd((StorageDescriptor)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case PARTITIONS: + return getPartitions(); + + case SD: + return getSd(); + + } + 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(); + case SD: + return isSetSd(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof PartitionSpecWithSharedSD) + return this.equals((PartitionSpecWithSharedSD)that); + return false; + } + + public boolean equals(PartitionSpecWithSharedSD 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; + } + + boolean this_present_sd = true && this.isSetSd(); + boolean that_present_sd = true && that.isSetSd(); + if (this_present_sd || that_present_sd) { + if (!(this_present_sd && that_present_sd)) + return false; + if (!this.sd.equals(that.sd)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + HashCodeBuilder builder = new HashCodeBuilder(); + + boolean present_partitions = true && (isSetPartitions()); + builder.append(present_partitions); + if (present_partitions) + builder.append(partitions); + + boolean present_sd = true && (isSetSd()); + builder.append(present_sd); + if (present_sd) + builder.append(sd); + + return builder.toHashCode(); + } + + public int compareTo(PartitionSpecWithSharedSD other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + PartitionSpecWithSharedSD typedOther = (PartitionSpecWithSharedSD)other; + + lastComparison = Boolean.valueOf(isSetPartitions()).compareTo(typedOther.isSetPartitions()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetPartitions()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partitions, typedOther.partitions); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetSd()).compareTo(typedOther.isSetSd()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetSd()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sd, typedOther.sd); + 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("PartitionSpecWithSharedSD("); + boolean first = true; + + sb.append("partitions:"); + if (this.partitions == null) { + sb.append("null"); + } else { + sb.append(this.partitions); + } + first = false; + if (!first) sb.append(", "); + sb.append("sd:"); + if (this.sd == null) { + sb.append("null"); + } else { + sb.append(this.sd); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + // check for sub-struct validity + if (sd != null) { + sd.validate(); + } + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + 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 PartitionSpecWithSharedSDStandardSchemeFactory implements SchemeFactory { + public PartitionSpecWithSharedSDStandardScheme getScheme() { + return new PartitionSpecWithSharedSDStandardScheme(); + } + } + + private static class PartitionSpecWithSharedSDStandardScheme extends StandardScheme<PartitionSpecWithSharedSD> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, PartitionSpecWithSharedSD 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 _list244 = iprot.readListBegin(); + struct.partitions = new ArrayList<PartitionWithoutSD>(_list244.size); + for (int _i245 = 0; _i245 < _list244.size; ++_i245) + { + PartitionWithoutSD _elem246; // required + _elem246 = new PartitionWithoutSD(); + _elem246.read(iprot); + struct.partitions.add(_elem246); + } + iprot.readListEnd(); + } + struct.setPartitionsIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // SD + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.sd = new StorageDescriptor(); + struct.sd.read(iprot); + struct.setSdIsSet(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, PartitionSpecWithSharedSD 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 (PartitionWithoutSD _iter247 : struct.partitions) + { + _iter247.write(oprot); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + if (struct.sd != null) { + oprot.writeFieldBegin(SD_FIELD_DESC); + struct.sd.write(oprot); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class PartitionSpecWithSharedSDTupleSchemeFactory implements SchemeFactory { + public PartitionSpecWithSharedSDTupleScheme getScheme() { + return new PartitionSpecWithSharedSDTupleScheme(); + } + } + + private static class PartitionSpecWithSharedSDTupleScheme extends TupleScheme<PartitionSpecWithSharedSD> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, PartitionSpecWithSharedSD struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetPartitions()) { + optionals.set(0); + } + if (struct.isSetSd()) { + optionals.set(1); + } + oprot.writeBitSet(optionals, 2); + if (struct.isSetPartitions()) { + { + oprot.writeI32(struct.partitions.size()); + for (PartitionWithoutSD _iter248 : struct.partitions) + { + _iter248.write(oprot); + } + } + } + if (struct.isSetSd()) { + struct.sd.write(oprot); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, PartitionSpecWithSharedSD struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(2); + if (incoming.get(0)) { + { + org.apache.thrift.protocol.TList _list249 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.partitions = new ArrayList<PartitionWithoutSD>(_list249.size); + for (int _i250 = 0; _i250 < _list249.size; ++_i250) + { + PartitionWithoutSD _elem251; // required + _elem251 = new PartitionWithoutSD(); + _elem251.read(iprot); + struct.partitions.add(_elem251); + } + } + struct.setPartitionsIsSet(true); + } + if (incoming.get(1)) { + struct.sd = new StorageDescriptor(); + struct.sd.read(iprot); + struct.setSdIsSet(true); + } + } + } + +} +
Added: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionWithoutSD.java URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionWithoutSD.java?rev=1622748&view=auto ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionWithoutSD.java (added) +++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionWithoutSD.java Fri Sep 5 17:52:32 2014 @@ -0,0 +1,1026 @@ +/** + * Autogenerated by Thrift Compiler (0.9.0) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.hadoop.hive.metastore.api; + +import org.apache.commons.lang.builder.HashCodeBuilder; +import org.apache.thrift.scheme.IScheme; +import org.apache.thrift.scheme.SchemeFactory; +import org.apache.thrift.scheme.StandardScheme; + +import org.apache.thrift.scheme.TupleScheme; +import org.apache.thrift.protocol.TTupleProtocol; +import org.apache.thrift.protocol.TProtocolException; +import org.apache.thrift.EncodingUtils; +import org.apache.thrift.TException; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +public class PartitionWithoutSD implements org.apache.thrift.TBase<PartitionWithoutSD, PartitionWithoutSD._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("PartitionWithoutSD"); + + private static final org.apache.thrift.protocol.TField VALUES_FIELD_DESC = new org.apache.thrift.protocol.TField("values", org.apache.thrift.protocol.TType.LIST, (short)1); + private static final org.apache.thrift.protocol.TField CREATE_TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("createTime", org.apache.thrift.protocol.TType.I32, (short)2); + private static final org.apache.thrift.protocol.TField LAST_ACCESS_TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("lastAccessTime", org.apache.thrift.protocol.TType.I32, (short)3); + private static final org.apache.thrift.protocol.TField RELATIVE_PATH_FIELD_DESC = new org.apache.thrift.protocol.TField("relativePath", org.apache.thrift.protocol.TType.STRING, (short)4); + private static final org.apache.thrift.protocol.TField PARAMETERS_FIELD_DESC = new org.apache.thrift.protocol.TField("parameters", org.apache.thrift.protocol.TType.MAP, (short)5); + private static final org.apache.thrift.protocol.TField PRIVILEGES_FIELD_DESC = new org.apache.thrift.protocol.TField("privileges", org.apache.thrift.protocol.TType.STRUCT, (short)6); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new PartitionWithoutSDStandardSchemeFactory()); + schemes.put(TupleScheme.class, new PartitionWithoutSDTupleSchemeFactory()); + } + + private List<String> values; // required + private int createTime; // required + private int lastAccessTime; // required + private String relativePath; // required + private Map<String,String> parameters; // required + private PrincipalPrivilegeSet privileges; // 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 { + VALUES((short)1, "values"), + CREATE_TIME((short)2, "createTime"), + LAST_ACCESS_TIME((short)3, "lastAccessTime"), + RELATIVE_PATH((short)4, "relativePath"), + PARAMETERS((short)5, "parameters"), + PRIVILEGES((short)6, "privileges"); + + 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: // VALUES + return VALUES; + case 2: // CREATE_TIME + return CREATE_TIME; + case 3: // LAST_ACCESS_TIME + return LAST_ACCESS_TIME; + case 4: // RELATIVE_PATH + return RELATIVE_PATH; + case 5: // PARAMETERS + return PARAMETERS; + case 6: // PRIVILEGES + return PRIVILEGES; + 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 __CREATETIME_ISSET_ID = 0; + private static final int __LASTACCESSTIME_ISSET_ID = 1; + private byte __isset_bitfield = 0; + private _Fields optionals[] = {_Fields.PRIVILEGES}; + 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.VALUES, new org.apache.thrift.meta_data.FieldMetaData("values", org.apache.thrift.TFieldRequirementType.DEFAULT, + 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.CREATE_TIME, new org.apache.thrift.meta_data.FieldMetaData("createTime", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); + tmpMap.put(_Fields.LAST_ACCESS_TIME, new org.apache.thrift.meta_data.FieldMetaData("lastAccessTime", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); + tmpMap.put(_Fields.RELATIVE_PATH, new org.apache.thrift.meta_data.FieldMetaData("relativePath", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.PARAMETERS, new org.apache.thrift.meta_data.FieldMetaData("parameters", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING), + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))); + tmpMap.put(_Fields.PRIVILEGES, new org.apache.thrift.meta_data.FieldMetaData("privileges", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, PrincipalPrivilegeSet.class))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(PartitionWithoutSD.class, metaDataMap); + } + + public PartitionWithoutSD() { + } + + public PartitionWithoutSD( + List<String> values, + int createTime, + int lastAccessTime, + String relativePath, + Map<String,String> parameters) + { + this(); + this.values = values; + this.createTime = createTime; + setCreateTimeIsSet(true); + this.lastAccessTime = lastAccessTime; + setLastAccessTimeIsSet(true); + this.relativePath = relativePath; + this.parameters = parameters; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public PartitionWithoutSD(PartitionWithoutSD other) { + __isset_bitfield = other.__isset_bitfield; + if (other.isSetValues()) { + List<String> __this__values = new ArrayList<String>(); + for (String other_element : other.values) { + __this__values.add(other_element); + } + this.values = __this__values; + } + this.createTime = other.createTime; + this.lastAccessTime = other.lastAccessTime; + if (other.isSetRelativePath()) { + this.relativePath = other.relativePath; + } + if (other.isSetParameters()) { + Map<String,String> __this__parameters = new HashMap<String,String>(); + for (Map.Entry<String, String> other_element : other.parameters.entrySet()) { + + String other_element_key = other_element.getKey(); + String other_element_value = other_element.getValue(); + + String __this__parameters_copy_key = other_element_key; + + String __this__parameters_copy_value = other_element_value; + + __this__parameters.put(__this__parameters_copy_key, __this__parameters_copy_value); + } + this.parameters = __this__parameters; + } + if (other.isSetPrivileges()) { + this.privileges = new PrincipalPrivilegeSet(other.privileges); + } + } + + public PartitionWithoutSD deepCopy() { + return new PartitionWithoutSD(this); + } + + @Override + public void clear() { + this.values = null; + setCreateTimeIsSet(false); + this.createTime = 0; + setLastAccessTimeIsSet(false); + this.lastAccessTime = 0; + this.relativePath = null; + this.parameters = null; + this.privileges = null; + } + + public int getValuesSize() { + return (this.values == null) ? 0 : this.values.size(); + } + + public java.util.Iterator<String> getValuesIterator() { + return (this.values == null) ? null : this.values.iterator(); + } + + public void addToValues(String elem) { + if (this.values == null) { + this.values = new ArrayList<String>(); + } + this.values.add(elem); + } + + public List<String> getValues() { + return this.values; + } + + public void setValues(List<String> values) { + this.values = values; + } + + public void unsetValues() { + this.values = null; + } + + /** Returns true if field values is set (has been assigned a value) and false otherwise */ + public boolean isSetValues() { + return this.values != null; + } + + public void setValuesIsSet(boolean value) { + if (!value) { + this.values = null; + } + } + + public int getCreateTime() { + return this.createTime; + } + + public void setCreateTime(int createTime) { + this.createTime = createTime; + setCreateTimeIsSet(true); + } + + public void unsetCreateTime() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __CREATETIME_ISSET_ID); + } + + /** Returns true if field createTime is set (has been assigned a value) and false otherwise */ + public boolean isSetCreateTime() { + return EncodingUtils.testBit(__isset_bitfield, __CREATETIME_ISSET_ID); + } + + public void setCreateTimeIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __CREATETIME_ISSET_ID, value); + } + + public int getLastAccessTime() { + return this.lastAccessTime; + } + + public void setLastAccessTime(int lastAccessTime) { + this.lastAccessTime = lastAccessTime; + setLastAccessTimeIsSet(true); + } + + public void unsetLastAccessTime() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __LASTACCESSTIME_ISSET_ID); + } + + /** Returns true if field lastAccessTime is set (has been assigned a value) and false otherwise */ + public boolean isSetLastAccessTime() { + return EncodingUtils.testBit(__isset_bitfield, __LASTACCESSTIME_ISSET_ID); + } + + public void setLastAccessTimeIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __LASTACCESSTIME_ISSET_ID, value); + } + + public String getRelativePath() { + return this.relativePath; + } + + public void setRelativePath(String relativePath) { + this.relativePath = relativePath; + } + + public void unsetRelativePath() { + this.relativePath = null; + } + + /** Returns true if field relativePath is set (has been assigned a value) and false otherwise */ + public boolean isSetRelativePath() { + return this.relativePath != null; + } + + public void setRelativePathIsSet(boolean value) { + if (!value) { + this.relativePath = null; + } + } + + public int getParametersSize() { + return (this.parameters == null) ? 0 : this.parameters.size(); + } + + public void putToParameters(String key, String val) { + if (this.parameters == null) { + this.parameters = new HashMap<String,String>(); + } + this.parameters.put(key, val); + } + + public Map<String,String> getParameters() { + return this.parameters; + } + + public void setParameters(Map<String,String> parameters) { + this.parameters = parameters; + } + + public void unsetParameters() { + this.parameters = null; + } + + /** Returns true if field parameters is set (has been assigned a value) and false otherwise */ + public boolean isSetParameters() { + return this.parameters != null; + } + + public void setParametersIsSet(boolean value) { + if (!value) { + this.parameters = null; + } + } + + public PrincipalPrivilegeSet getPrivileges() { + return this.privileges; + } + + public void setPrivileges(PrincipalPrivilegeSet privileges) { + this.privileges = privileges; + } + + public void unsetPrivileges() { + this.privileges = null; + } + + /** Returns true if field privileges is set (has been assigned a value) and false otherwise */ + public boolean isSetPrivileges() { + return this.privileges != null; + } + + public void setPrivilegesIsSet(boolean value) { + if (!value) { + this.privileges = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case VALUES: + if (value == null) { + unsetValues(); + } else { + setValues((List<String>)value); + } + break; + + case CREATE_TIME: + if (value == null) { + unsetCreateTime(); + } else { + setCreateTime((Integer)value); + } + break; + + case LAST_ACCESS_TIME: + if (value == null) { + unsetLastAccessTime(); + } else { + setLastAccessTime((Integer)value); + } + break; + + case RELATIVE_PATH: + if (value == null) { + unsetRelativePath(); + } else { + setRelativePath((String)value); + } + break; + + case PARAMETERS: + if (value == null) { + unsetParameters(); + } else { + setParameters((Map<String,String>)value); + } + break; + + case PRIVILEGES: + if (value == null) { + unsetPrivileges(); + } else { + setPrivileges((PrincipalPrivilegeSet)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case VALUES: + return getValues(); + + case CREATE_TIME: + return Integer.valueOf(getCreateTime()); + + case LAST_ACCESS_TIME: + return Integer.valueOf(getLastAccessTime()); + + case RELATIVE_PATH: + return getRelativePath(); + + case PARAMETERS: + return getParameters(); + + case PRIVILEGES: + return getPrivileges(); + + } + 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 VALUES: + return isSetValues(); + case CREATE_TIME: + return isSetCreateTime(); + case LAST_ACCESS_TIME: + return isSetLastAccessTime(); + case RELATIVE_PATH: + return isSetRelativePath(); + case PARAMETERS: + return isSetParameters(); + case PRIVILEGES: + return isSetPrivileges(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof PartitionWithoutSD) + return this.equals((PartitionWithoutSD)that); + return false; + } + + public boolean equals(PartitionWithoutSD that) { + if (that == null) + return false; + + boolean this_present_values = true && this.isSetValues(); + boolean that_present_values = true && that.isSetValues(); + if (this_present_values || that_present_values) { + if (!(this_present_values && that_present_values)) + return false; + if (!this.values.equals(that.values)) + return false; + } + + boolean this_present_createTime = true; + boolean that_present_createTime = true; + if (this_present_createTime || that_present_createTime) { + if (!(this_present_createTime && that_present_createTime)) + return false; + if (this.createTime != that.createTime) + return false; + } + + boolean this_present_lastAccessTime = true; + boolean that_present_lastAccessTime = true; + if (this_present_lastAccessTime || that_present_lastAccessTime) { + if (!(this_present_lastAccessTime && that_present_lastAccessTime)) + return false; + if (this.lastAccessTime != that.lastAccessTime) + return false; + } + + boolean this_present_relativePath = true && this.isSetRelativePath(); + boolean that_present_relativePath = true && that.isSetRelativePath(); + if (this_present_relativePath || that_present_relativePath) { + if (!(this_present_relativePath && that_present_relativePath)) + return false; + if (!this.relativePath.equals(that.relativePath)) + return false; + } + + boolean this_present_parameters = true && this.isSetParameters(); + boolean that_present_parameters = true && that.isSetParameters(); + if (this_present_parameters || that_present_parameters) { + if (!(this_present_parameters && that_present_parameters)) + return false; + if (!this.parameters.equals(that.parameters)) + return false; + } + + boolean this_present_privileges = true && this.isSetPrivileges(); + boolean that_present_privileges = true && that.isSetPrivileges(); + if (this_present_privileges || that_present_privileges) { + if (!(this_present_privileges && that_present_privileges)) + return false; + if (!this.privileges.equals(that.privileges)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + HashCodeBuilder builder = new HashCodeBuilder(); + + boolean present_values = true && (isSetValues()); + builder.append(present_values); + if (present_values) + builder.append(values); + + boolean present_createTime = true; + builder.append(present_createTime); + if (present_createTime) + builder.append(createTime); + + boolean present_lastAccessTime = true; + builder.append(present_lastAccessTime); + if (present_lastAccessTime) + builder.append(lastAccessTime); + + boolean present_relativePath = true && (isSetRelativePath()); + builder.append(present_relativePath); + if (present_relativePath) + builder.append(relativePath); + + boolean present_parameters = true && (isSetParameters()); + builder.append(present_parameters); + if (present_parameters) + builder.append(parameters); + + boolean present_privileges = true && (isSetPrivileges()); + builder.append(present_privileges); + if (present_privileges) + builder.append(privileges); + + return builder.toHashCode(); + } + + public int compareTo(PartitionWithoutSD other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + PartitionWithoutSD typedOther = (PartitionWithoutSD)other; + + lastComparison = Boolean.valueOf(isSetValues()).compareTo(typedOther.isSetValues()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetValues()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.values, typedOther.values); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetCreateTime()).compareTo(typedOther.isSetCreateTime()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetCreateTime()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.createTime, typedOther.createTime); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetLastAccessTime()).compareTo(typedOther.isSetLastAccessTime()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetLastAccessTime()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.lastAccessTime, typedOther.lastAccessTime); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetRelativePath()).compareTo(typedOther.isSetRelativePath()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetRelativePath()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.relativePath, typedOther.relativePath); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetParameters()).compareTo(typedOther.isSetParameters()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetParameters()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.parameters, typedOther.parameters); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetPrivileges()).compareTo(typedOther.isSetPrivileges()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetPrivileges()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.privileges, typedOther.privileges); + 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("PartitionWithoutSD("); + boolean first = true; + + sb.append("values:"); + if (this.values == null) { + sb.append("null"); + } else { + sb.append(this.values); + } + first = false; + if (!first) sb.append(", "); + sb.append("createTime:"); + sb.append(this.createTime); + first = false; + if (!first) sb.append(", "); + sb.append("lastAccessTime:"); + sb.append(this.lastAccessTime); + first = false; + if (!first) sb.append(", "); + sb.append("relativePath:"); + if (this.relativePath == null) { + sb.append("null"); + } else { + sb.append(this.relativePath); + } + first = false; + if (!first) sb.append(", "); + sb.append("parameters:"); + if (this.parameters == null) { + sb.append("null"); + } else { + sb.append(this.parameters); + } + first = false; + if (isSetPrivileges()) { + if (!first) sb.append(", "); + sb.append("privileges:"); + if (this.privileges == null) { + sb.append("null"); + } else { + sb.append(this.privileges); + } + first = false; + } + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + // check for sub-struct validity + if (privileges != null) { + privileges.validate(); + } + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. + __isset_bitfield = 0; + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class PartitionWithoutSDStandardSchemeFactory implements SchemeFactory { + public PartitionWithoutSDStandardScheme getScheme() { + return new PartitionWithoutSDStandardScheme(); + } + } + + private static class PartitionWithoutSDStandardScheme extends StandardScheme<PartitionWithoutSD> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, PartitionWithoutSD 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: // VALUES + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list226 = iprot.readListBegin(); + struct.values = new ArrayList<String>(_list226.size); + for (int _i227 = 0; _i227 < _list226.size; ++_i227) + { + String _elem228; // required + _elem228 = iprot.readString(); + struct.values.add(_elem228); + } + iprot.readListEnd(); + } + struct.setValuesIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // CREATE_TIME + if (schemeField.type == org.apache.thrift.protocol.TType.I32) { + struct.createTime = iprot.readI32(); + struct.setCreateTimeIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // LAST_ACCESS_TIME + if (schemeField.type == org.apache.thrift.protocol.TType.I32) { + struct.lastAccessTime = iprot.readI32(); + struct.setLastAccessTimeIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 4: // RELATIVE_PATH + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.relativePath = iprot.readString(); + struct.setRelativePathIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 5: // PARAMETERS + if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { + { + org.apache.thrift.protocol.TMap _map229 = iprot.readMapBegin(); + struct.parameters = new HashMap<String,String>(2*_map229.size); + for (int _i230 = 0; _i230 < _map229.size; ++_i230) + { + String _key231; // required + String _val232; // required + _key231 = iprot.readString(); + _val232 = iprot.readString(); + struct.parameters.put(_key231, _val232); + } + iprot.readMapEnd(); + } + struct.setParametersIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 6: // PRIVILEGES + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.privileges = new PrincipalPrivilegeSet(); + struct.privileges.read(iprot); + struct.setPrivilegesIsSet(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, PartitionWithoutSD struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.values != null) { + oprot.writeFieldBegin(VALUES_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.values.size())); + for (String _iter233 : struct.values) + { + oprot.writeString(_iter233); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldBegin(CREATE_TIME_FIELD_DESC); + oprot.writeI32(struct.createTime); + oprot.writeFieldEnd(); + oprot.writeFieldBegin(LAST_ACCESS_TIME_FIELD_DESC); + oprot.writeI32(struct.lastAccessTime); + oprot.writeFieldEnd(); + if (struct.relativePath != null) { + oprot.writeFieldBegin(RELATIVE_PATH_FIELD_DESC); + oprot.writeString(struct.relativePath); + oprot.writeFieldEnd(); + } + if (struct.parameters != null) { + oprot.writeFieldBegin(PARAMETERS_FIELD_DESC); + { + oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.parameters.size())); + for (Map.Entry<String, String> _iter234 : struct.parameters.entrySet()) + { + oprot.writeString(_iter234.getKey()); + oprot.writeString(_iter234.getValue()); + } + oprot.writeMapEnd(); + } + oprot.writeFieldEnd(); + } + if (struct.privileges != null) { + if (struct.isSetPrivileges()) { + oprot.writeFieldBegin(PRIVILEGES_FIELD_DESC); + struct.privileges.write(oprot); + oprot.writeFieldEnd(); + } + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class PartitionWithoutSDTupleSchemeFactory implements SchemeFactory { + public PartitionWithoutSDTupleScheme getScheme() { + return new PartitionWithoutSDTupleScheme(); + } + } + + private static class PartitionWithoutSDTupleScheme extends TupleScheme<PartitionWithoutSD> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, PartitionWithoutSD struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetValues()) { + optionals.set(0); + } + if (struct.isSetCreateTime()) { + optionals.set(1); + } + if (struct.isSetLastAccessTime()) { + optionals.set(2); + } + if (struct.isSetRelativePath()) { + optionals.set(3); + } + if (struct.isSetParameters()) { + optionals.set(4); + } + if (struct.isSetPrivileges()) { + optionals.set(5); + } + oprot.writeBitSet(optionals, 6); + if (struct.isSetValues()) { + { + oprot.writeI32(struct.values.size()); + for (String _iter235 : struct.values) + { + oprot.writeString(_iter235); + } + } + } + if (struct.isSetCreateTime()) { + oprot.writeI32(struct.createTime); + } + if (struct.isSetLastAccessTime()) { + oprot.writeI32(struct.lastAccessTime); + } + if (struct.isSetRelativePath()) { + oprot.writeString(struct.relativePath); + } + if (struct.isSetParameters()) { + { + oprot.writeI32(struct.parameters.size()); + for (Map.Entry<String, String> _iter236 : struct.parameters.entrySet()) + { + oprot.writeString(_iter236.getKey()); + oprot.writeString(_iter236.getValue()); + } + } + } + if (struct.isSetPrivileges()) { + struct.privileges.write(oprot); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, PartitionWithoutSD struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(6); + if (incoming.get(0)) { + { + org.apache.thrift.protocol.TList _list237 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.values = new ArrayList<String>(_list237.size); + for (int _i238 = 0; _i238 < _list237.size; ++_i238) + { + String _elem239; // required + _elem239 = iprot.readString(); + struct.values.add(_elem239); + } + } + struct.setValuesIsSet(true); + } + if (incoming.get(1)) { + struct.createTime = iprot.readI32(); + struct.setCreateTimeIsSet(true); + } + if (incoming.get(2)) { + struct.lastAccessTime = iprot.readI32(); + struct.setLastAccessTimeIsSet(true); + } + if (incoming.get(3)) { + struct.relativePath = iprot.readString(); + struct.setRelativePathIsSet(true); + } + if (incoming.get(4)) { + { + org.apache.thrift.protocol.TMap _map240 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.parameters = new HashMap<String,String>(2*_map240.size); + for (int _i241 = 0; _i241 < _map240.size; ++_i241) + { + String _key242; // required + String _val243; // required + _key242 = iprot.readString(); + _val243 = iprot.readString(); + struct.parameters.put(_key242, _val243); + } + } + struct.setParametersIsSet(true); + } + if (incoming.get(5)) { + struct.privileges = new PrincipalPrivilegeSet(); + struct.privileges.read(iprot); + struct.setPrivilegesIsSet(true); + } + } + } + +} + Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsByExprResult.java URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsByExprResult.java?rev=1622748&r1=1622747&r2=1622748&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsByExprResult.java (original) +++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsByExprResult.java Fri Sep 5 17:52:32 2014 @@ -435,14 +435,14 @@ public class PartitionsByExprResult impl case 1: // PARTITIONS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list288 = iprot.readListBegin(); - struct.partitions = new ArrayList<Partition>(_list288.size); - for (int _i289 = 0; _i289 < _list288.size; ++_i289) + org.apache.thrift.protocol.TList _list322 = iprot.readListBegin(); + struct.partitions = new ArrayList<Partition>(_list322.size); + for (int _i323 = 0; _i323 < _list322.size; ++_i323) { - Partition _elem290; // required - _elem290 = new Partition(); - _elem290.read(iprot); - struct.partitions.add(_elem290); + Partition _elem324; // required + _elem324 = new Partition(); + _elem324.read(iprot); + struct.partitions.add(_elem324); } iprot.readListEnd(); } @@ -476,9 +476,9 @@ public class PartitionsByExprResult impl oprot.writeFieldBegin(PARTITIONS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.partitions.size())); - for (Partition _iter291 : struct.partitions) + for (Partition _iter325 : struct.partitions) { - _iter291.write(oprot); + _iter325.write(oprot); } oprot.writeListEnd(); } @@ -506,9 +506,9 @@ public class PartitionsByExprResult impl TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.partitions.size()); - for (Partition _iter292 : struct.partitions) + for (Partition _iter326 : struct.partitions) { - _iter292.write(oprot); + _iter326.write(oprot); } } oprot.writeBool(struct.hasUnknownPartitions); @@ -518,14 +518,14 @@ public class PartitionsByExprResult impl public void read(org.apache.thrift.protocol.TProtocol prot, PartitionsByExprResult struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list293 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.partitions = new ArrayList<Partition>(_list293.size); - for (int _i294 = 0; _i294 < _list293.size; ++_i294) + org.apache.thrift.protocol.TList _list327 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.partitions = new ArrayList<Partition>(_list327.size); + for (int _i328 = 0; _i328 < _list327.size; ++_i328) { - Partition _elem295; // required - _elem295 = new Partition(); - _elem295.read(iprot); - struct.partitions.add(_elem295); + Partition _elem329; // required + _elem329 = new Partition(); + _elem329.read(iprot); + struct.partitions.add(_elem329); } } struct.setPartitionsIsSet(true); Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java?rev=1622748&r1=1622747&r2=1622748&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java (original) +++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java Fri Sep 5 17:52:32 2014 @@ -641,13 +641,13 @@ public class PartitionsStatsRequest impl case 3: // COL_NAMES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list330 = iprot.readListBegin(); - struct.colNames = new ArrayList<String>(_list330.size); - for (int _i331 = 0; _i331 < _list330.size; ++_i331) + org.apache.thrift.protocol.TList _list364 = iprot.readListBegin(); + struct.colNames = new ArrayList<String>(_list364.size); + for (int _i365 = 0; _i365 < _list364.size; ++_i365) { - String _elem332; // required - _elem332 = iprot.readString(); - struct.colNames.add(_elem332); + String _elem366; // required + _elem366 = iprot.readString(); + struct.colNames.add(_elem366); } iprot.readListEnd(); } @@ -659,13 +659,13 @@ public class PartitionsStatsRequest impl case 4: // PART_NAMES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list333 = iprot.readListBegin(); - struct.partNames = new ArrayList<String>(_list333.size); - for (int _i334 = 0; _i334 < _list333.size; ++_i334) + org.apache.thrift.protocol.TList _list367 = iprot.readListBegin(); + struct.partNames = new ArrayList<String>(_list367.size); + for (int _i368 = 0; _i368 < _list367.size; ++_i368) { - String _elem335; // required - _elem335 = iprot.readString(); - struct.partNames.add(_elem335); + String _elem369; // required + _elem369 = iprot.readString(); + struct.partNames.add(_elem369); } iprot.readListEnd(); } @@ -701,9 +701,9 @@ public class PartitionsStatsRequest impl oprot.writeFieldBegin(COL_NAMES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.colNames.size())); - for (String _iter336 : struct.colNames) + for (String _iter370 : struct.colNames) { - oprot.writeString(_iter336); + oprot.writeString(_iter370); } oprot.writeListEnd(); } @@ -713,9 +713,9 @@ public class PartitionsStatsRequest impl oprot.writeFieldBegin(PART_NAMES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partNames.size())); - for (String _iter337 : struct.partNames) + for (String _iter371 : struct.partNames) { - oprot.writeString(_iter337); + oprot.writeString(_iter371); } oprot.writeListEnd(); } @@ -742,16 +742,16 @@ public class PartitionsStatsRequest impl oprot.writeString(struct.tblName); { oprot.writeI32(struct.colNames.size()); - for (String _iter338 : struct.colNames) + for (String _iter372 : struct.colNames) { - oprot.writeString(_iter338); + oprot.writeString(_iter372); } } { oprot.writeI32(struct.partNames.size()); - for (String _iter339 : struct.partNames) + for (String _iter373 : struct.partNames) { - oprot.writeString(_iter339); + oprot.writeString(_iter373); } } } @@ -764,24 +764,24 @@ public class PartitionsStatsRequest impl struct.tblName = iprot.readString(); struct.setTblNameIsSet(true); { - org.apache.thrift.protocol.TList _list340 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.colNames = new ArrayList<String>(_list340.size); - for (int _i341 = 0; _i341 < _list340.size; ++_i341) - { - String _elem342; // required - _elem342 = iprot.readString(); - struct.colNames.add(_elem342); + org.apache.thrift.protocol.TList _list374 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.colNames = new ArrayList<String>(_list374.size); + for (int _i375 = 0; _i375 < _list374.size; ++_i375) + { + String _elem376; // required + _elem376 = iprot.readString(); + struct.colNames.add(_elem376); } } struct.setColNamesIsSet(true); { - org.apache.thrift.protocol.TList _list343 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.partNames = new ArrayList<String>(_list343.size); - for (int _i344 = 0; _i344 < _list343.size; ++_i344) - { - String _elem345; // required - _elem345 = iprot.readString(); - struct.partNames.add(_elem345); + org.apache.thrift.protocol.TList _list377 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.partNames = new ArrayList<String>(_list377.size); + for (int _i378 = 0; _i378 < _list377.size; ++_i378) + { + String _elem379; // required + _elem379 = iprot.readString(); + struct.partNames.add(_elem379); } } struct.setPartNamesIsSet(true); Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsResult.java URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsResult.java?rev=1622748&r1=1622747&r2=1622748&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsResult.java (original) +++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsResult.java Fri Sep 5 17:52:32 2014 @@ -359,26 +359,26 @@ public class PartitionsStatsResult imple case 1: // PART_STATS if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map304 = iprot.readMapBegin(); - struct.partStats = new HashMap<String,List<ColumnStatisticsObj>>(2*_map304.size); - for (int _i305 = 0; _i305 < _map304.size; ++_i305) + org.apache.thrift.protocol.TMap _map338 = iprot.readMapBegin(); + struct.partStats = new HashMap<String,List<ColumnStatisticsObj>>(2*_map338.size); + for (int _i339 = 0; _i339 < _map338.size; ++_i339) { - String _key306; // required - List<ColumnStatisticsObj> _val307; // required - _key306 = iprot.readString(); + String _key340; // required + List<ColumnStatisticsObj> _val341; // required + _key340 = iprot.readString(); { - org.apache.thrift.protocol.TList _list308 = iprot.readListBegin(); - _val307 = new ArrayList<ColumnStatisticsObj>(_list308.size); - for (int _i309 = 0; _i309 < _list308.size; ++_i309) + org.apache.thrift.protocol.TList _list342 = iprot.readListBegin(); + _val341 = new ArrayList<ColumnStatisticsObj>(_list342.size); + for (int _i343 = 0; _i343 < _list342.size; ++_i343) { - ColumnStatisticsObj _elem310; // required - _elem310 = new ColumnStatisticsObj(); - _elem310.read(iprot); - _val307.add(_elem310); + ColumnStatisticsObj _elem344; // required + _elem344 = new ColumnStatisticsObj(); + _elem344.read(iprot); + _val341.add(_elem344); } iprot.readListEnd(); } - struct.partStats.put(_key306, _val307); + struct.partStats.put(_key340, _val341); } iprot.readMapEnd(); } @@ -404,14 +404,14 @@ public class PartitionsStatsResult imple oprot.writeFieldBegin(PART_STATS_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.LIST, struct.partStats.size())); - for (Map.Entry<String, List<ColumnStatisticsObj>> _iter311 : struct.partStats.entrySet()) + for (Map.Entry<String, List<ColumnStatisticsObj>> _iter345 : struct.partStats.entrySet()) { - oprot.writeString(_iter311.getKey()); + oprot.writeString(_iter345.getKey()); { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, _iter311.getValue().size())); - for (ColumnStatisticsObj _iter312 : _iter311.getValue()) + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, _iter345.getValue().size())); + for (ColumnStatisticsObj _iter346 : _iter345.getValue()) { - _iter312.write(oprot); + _iter346.write(oprot); } oprot.writeListEnd(); } @@ -439,14 +439,14 @@ public class PartitionsStatsResult imple TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.partStats.size()); - for (Map.Entry<String, List<ColumnStatisticsObj>> _iter313 : struct.partStats.entrySet()) + for (Map.Entry<String, List<ColumnStatisticsObj>> _iter347 : struct.partStats.entrySet()) { - oprot.writeString(_iter313.getKey()); + oprot.writeString(_iter347.getKey()); { - oprot.writeI32(_iter313.getValue().size()); - for (ColumnStatisticsObj _iter314 : _iter313.getValue()) + oprot.writeI32(_iter347.getValue().size()); + for (ColumnStatisticsObj _iter348 : _iter347.getValue()) { - _iter314.write(oprot); + _iter348.write(oprot); } } } @@ -457,25 +457,25 @@ public class PartitionsStatsResult imple public void read(org.apache.thrift.protocol.TProtocol prot, PartitionsStatsResult struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TMap _map315 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.LIST, iprot.readI32()); - struct.partStats = new HashMap<String,List<ColumnStatisticsObj>>(2*_map315.size); - for (int _i316 = 0; _i316 < _map315.size; ++_i316) + org.apache.thrift.protocol.TMap _map349 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.LIST, iprot.readI32()); + struct.partStats = new HashMap<String,List<ColumnStatisticsObj>>(2*_map349.size); + for (int _i350 = 0; _i350 < _map349.size; ++_i350) { - String _key317; // required - List<ColumnStatisticsObj> _val318; // required - _key317 = iprot.readString(); + String _key351; // required + List<ColumnStatisticsObj> _val352; // required + _key351 = iprot.readString(); { - org.apache.thrift.protocol.TList _list319 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - _val318 = new ArrayList<ColumnStatisticsObj>(_list319.size); - for (int _i320 = 0; _i320 < _list319.size; ++_i320) + org.apache.thrift.protocol.TList _list353 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + _val352 = new ArrayList<ColumnStatisticsObj>(_list353.size); + for (int _i354 = 0; _i354 < _list353.size; ++_i354) { - ColumnStatisticsObj _elem321; // required - _elem321 = new ColumnStatisticsObj(); - _elem321.read(iprot); - _val318.add(_elem321); + ColumnStatisticsObj _elem355; // required + _elem355 = new ColumnStatisticsObj(); + _elem355.read(iprot); + _val352.add(_elem355); } } - struct.partStats.put(_key317, _val318); + struct.partStats.put(_key351, _val352); } } struct.setPartStatsIsSet(true); Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RequestPartsSpec.java URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RequestPartsSpec.java?rev=1622748&r1=1622747&r2=1622748&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RequestPartsSpec.java (original) +++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RequestPartsSpec.java Fri Sep 5 17:52:32 2014 @@ -165,13 +165,13 @@ public class RequestPartsSpec extends or if (field.type == NAMES_FIELD_DESC.type) { List<String> names; { - org.apache.thrift.protocol.TList _list370 = iprot.readListBegin(); - names = new ArrayList<String>(_list370.size); - for (int _i371 = 0; _i371 < _list370.size; ++_i371) + org.apache.thrift.protocol.TList _list404 = iprot.readListBegin(); + names = new ArrayList<String>(_list404.size); + for (int _i405 = 0; _i405 < _list404.size; ++_i405) { - String _elem372; // required - _elem372 = iprot.readString(); - names.add(_elem372); + String _elem406; // required + _elem406 = iprot.readString(); + names.add(_elem406); } iprot.readListEnd(); } @@ -184,14 +184,14 @@ public class RequestPartsSpec extends or if (field.type == EXPRS_FIELD_DESC.type) { List<DropPartitionsExpr> exprs; { - org.apache.thrift.protocol.TList _list373 = iprot.readListBegin(); - exprs = new ArrayList<DropPartitionsExpr>(_list373.size); - for (int _i374 = 0; _i374 < _list373.size; ++_i374) + org.apache.thrift.protocol.TList _list407 = iprot.readListBegin(); + exprs = new ArrayList<DropPartitionsExpr>(_list407.size); + for (int _i408 = 0; _i408 < _list407.size; ++_i408) { - DropPartitionsExpr _elem375; // required - _elem375 = new DropPartitionsExpr(); - _elem375.read(iprot); - exprs.add(_elem375); + DropPartitionsExpr _elem409; // required + _elem409 = new DropPartitionsExpr(); + _elem409.read(iprot); + exprs.add(_elem409); } iprot.readListEnd(); } @@ -215,9 +215,9 @@ public class RequestPartsSpec extends or List<String> names = (List<String>)value_; { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, names.size())); - for (String _iter376 : names) + for (String _iter410 : names) { - oprot.writeString(_iter376); + oprot.writeString(_iter410); } oprot.writeListEnd(); } @@ -226,9 +226,9 @@ public class RequestPartsSpec extends or List<DropPartitionsExpr> exprs = (List<DropPartitionsExpr>)value_; { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, exprs.size())); - for (DropPartitionsExpr _iter377 : exprs) + for (DropPartitionsExpr _iter411 : exprs) { - _iter377.write(oprot); + _iter411.write(oprot); } oprot.writeListEnd(); } @@ -246,13 +246,13 @@ public class RequestPartsSpec extends or case NAMES: List<String> names; { - org.apache.thrift.protocol.TList _list378 = iprot.readListBegin(); - names = new ArrayList<String>(_list378.size); - for (int _i379 = 0; _i379 < _list378.size; ++_i379) + org.apache.thrift.protocol.TList _list412 = iprot.readListBegin(); + names = new ArrayList<String>(_list412.size); + for (int _i413 = 0; _i413 < _list412.size; ++_i413) { - String _elem380; // required - _elem380 = iprot.readString(); - names.add(_elem380); + String _elem414; // required + _elem414 = iprot.readString(); + names.add(_elem414); } iprot.readListEnd(); } @@ -260,14 +260,14 @@ public class RequestPartsSpec extends or case EXPRS: List<DropPartitionsExpr> exprs; { - org.apache.thrift.protocol.TList _list381 = iprot.readListBegin(); - exprs = new ArrayList<DropPartitionsExpr>(_list381.size); - for (int _i382 = 0; _i382 < _list381.size; ++_i382) + org.apache.thrift.protocol.TList _list415 = iprot.readListBegin(); + exprs = new ArrayList<DropPartitionsExpr>(_list415.size); + for (int _i416 = 0; _i416 < _list415.size; ++_i416) { - DropPartitionsExpr _elem383; // required - _elem383 = new DropPartitionsExpr(); - _elem383.read(iprot); - exprs.add(_elem383); + DropPartitionsExpr _elem417; // required + _elem417 = new DropPartitionsExpr(); + _elem417.read(iprot); + exprs.add(_elem417); } iprot.readListEnd(); } @@ -287,9 +287,9 @@ public class RequestPartsSpec extends or List<String> names = (List<String>)value_; { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, names.size())); - for (String _iter384 : names) + for (String _iter418 : names) { - oprot.writeString(_iter384); + oprot.writeString(_iter418); } oprot.writeListEnd(); } @@ -298,9 +298,9 @@ public class RequestPartsSpec extends or List<DropPartitionsExpr> exprs = (List<DropPartitionsExpr>)value_; { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, exprs.size())); - for (DropPartitionsExpr _iter385 : exprs) + for (DropPartitionsExpr _iter419 : exprs) { - _iter385.write(oprot); + _iter419.write(oprot); } oprot.writeListEnd(); } Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Schema.java URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Schema.java?rev=1622748&r1=1622747&r2=1622748&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Schema.java (original) +++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Schema.java Fri Sep 5 17:52:32 2014 @@ -452,14 +452,14 @@ public class Schema implements org.apach case 1: // FIELD_SCHEMAS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list260 = iprot.readListBegin(); - struct.fieldSchemas = new ArrayList<FieldSchema>(_list260.size); - for (int _i261 = 0; _i261 < _list260.size; ++_i261) + org.apache.thrift.protocol.TList _list294 = iprot.readListBegin(); + struct.fieldSchemas = new ArrayList<FieldSchema>(_list294.size); + for (int _i295 = 0; _i295 < _list294.size; ++_i295) { - FieldSchema _elem262; // required - _elem262 = new FieldSchema(); - _elem262.read(iprot); - struct.fieldSchemas.add(_elem262); + FieldSchema _elem296; // required + _elem296 = new FieldSchema(); + _elem296.read(iprot); + struct.fieldSchemas.add(_elem296); } iprot.readListEnd(); } @@ -471,15 +471,15 @@ public class Schema implements org.apach case 2: // PROPERTIES if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map263 = iprot.readMapBegin(); - struct.properties = new HashMap<String,String>(2*_map263.size); - for (int _i264 = 0; _i264 < _map263.size; ++_i264) + org.apache.thrift.protocol.TMap _map297 = iprot.readMapBegin(); + struct.properties = new HashMap<String,String>(2*_map297.size); + for (int _i298 = 0; _i298 < _map297.size; ++_i298) { - String _key265; // required - String _val266; // required - _key265 = iprot.readString(); - _val266 = iprot.readString(); - struct.properties.put(_key265, _val266); + String _key299; // required + String _val300; // required + _key299 = iprot.readString(); + _val300 = iprot.readString(); + struct.properties.put(_key299, _val300); } iprot.readMapEnd(); } @@ -505,9 +505,9 @@ public class Schema implements org.apach oprot.writeFieldBegin(FIELD_SCHEMAS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.fieldSchemas.size())); - for (FieldSchema _iter267 : struct.fieldSchemas) + for (FieldSchema _iter301 : struct.fieldSchemas) { - _iter267.write(oprot); + _iter301.write(oprot); } oprot.writeListEnd(); } @@ -517,10 +517,10 @@ public class Schema implements org.apach oprot.writeFieldBegin(PROPERTIES_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.properties.size())); - for (Map.Entry<String, String> _iter268 : struct.properties.entrySet()) + for (Map.Entry<String, String> _iter302 : struct.properties.entrySet()) { - oprot.writeString(_iter268.getKey()); - oprot.writeString(_iter268.getValue()); + oprot.writeString(_iter302.getKey()); + oprot.writeString(_iter302.getValue()); } oprot.writeMapEnd(); } @@ -554,19 +554,19 @@ public class Schema implements org.apach if (struct.isSetFieldSchemas()) { { oprot.writeI32(struct.fieldSchemas.size()); - for (FieldSchema _iter269 : struct.fieldSchemas) + for (FieldSchema _iter303 : struct.fieldSchemas) { - _iter269.write(oprot); + _iter303.write(oprot); } } } if (struct.isSetProperties()) { { oprot.writeI32(struct.properties.size()); - for (Map.Entry<String, String> _iter270 : struct.properties.entrySet()) + for (Map.Entry<String, String> _iter304 : struct.properties.entrySet()) { - oprot.writeString(_iter270.getKey()); - oprot.writeString(_iter270.getValue()); + oprot.writeString(_iter304.getKey()); + oprot.writeString(_iter304.getValue()); } } } @@ -578,29 +578,29 @@ public class Schema implements org.apach BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list271 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.fieldSchemas = new ArrayList<FieldSchema>(_list271.size); - for (int _i272 = 0; _i272 < _list271.size; ++_i272) - { - FieldSchema _elem273; // required - _elem273 = new FieldSchema(); - _elem273.read(iprot); - struct.fieldSchemas.add(_elem273); + org.apache.thrift.protocol.TList _list305 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.fieldSchemas = new ArrayList<FieldSchema>(_list305.size); + for (int _i306 = 0; _i306 < _list305.size; ++_i306) + { + FieldSchema _elem307; // required + _elem307 = new FieldSchema(); + _elem307.read(iprot); + struct.fieldSchemas.add(_elem307); } } struct.setFieldSchemasIsSet(true); } if (incoming.get(1)) { { - org.apache.thrift.protocol.TMap _map274 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.properties = new HashMap<String,String>(2*_map274.size); - for (int _i275 = 0; _i275 < _map274.size; ++_i275) - { - String _key276; // required - String _val277; // required - _key276 = iprot.readString(); - _val277 = iprot.readString(); - struct.properties.put(_key276, _val277); + org.apache.thrift.protocol.TMap _map308 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.properties = new HashMap<String,String>(2*_map308.size); + for (int _i309 = 0; _i309 < _map308.size; ++_i309) + { + String _key310; // required + String _val311; // required + _key310 = iprot.readString(); + _val311 = iprot.readString(); + struct.properties.put(_key310, _val311); } } struct.setPropertiesIsSet(true);
