Added: 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=1562653&view=auto ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsResult.java (added) +++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsResult.java Thu Jan 30 00:24:28 2014 @@ -0,0 +1,486 @@ +/** + * 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 PartitionsStatsResult implements org.apache.thrift.TBase<PartitionsStatsResult, PartitionsStatsResult._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("PartitionsStatsResult"); + + private static final org.apache.thrift.protocol.TField PART_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("partStats", org.apache.thrift.protocol.TType.MAP, (short)1); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new PartitionsStatsResultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new PartitionsStatsResultTupleSchemeFactory()); + } + + private Map<String,List<ColumnStatisticsObj>> partStats; // 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 { + PART_STATS((short)1, "partStats"); + + 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: // PART_STATS + return PART_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 + 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.PART_STATS, new org.apache.thrift.meta_data.FieldMetaData("partStats", org.apache.thrift.TFieldRequirementType.REQUIRED, + 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.ListMetaData(org.apache.thrift.protocol.TType.LIST, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ColumnStatisticsObj.class))))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(PartitionsStatsResult.class, metaDataMap); + } + + public PartitionsStatsResult() { + } + + public PartitionsStatsResult( + Map<String,List<ColumnStatisticsObj>> partStats) + { + this(); + this.partStats = partStats; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public PartitionsStatsResult(PartitionsStatsResult other) { + if (other.isSetPartStats()) { + Map<String,List<ColumnStatisticsObj>> __this__partStats = new HashMap<String,List<ColumnStatisticsObj>>(); + for (Map.Entry<String, List<ColumnStatisticsObj>> other_element : other.partStats.entrySet()) { + + String other_element_key = other_element.getKey(); + List<ColumnStatisticsObj> other_element_value = other_element.getValue(); + + String __this__partStats_copy_key = other_element_key; + + List<ColumnStatisticsObj> __this__partStats_copy_value = new ArrayList<ColumnStatisticsObj>(); + for (ColumnStatisticsObj other_element_value_element : other_element_value) { + __this__partStats_copy_value.add(new ColumnStatisticsObj(other_element_value_element)); + } + + __this__partStats.put(__this__partStats_copy_key, __this__partStats_copy_value); + } + this.partStats = __this__partStats; + } + } + + public PartitionsStatsResult deepCopy() { + return new PartitionsStatsResult(this); + } + + @Override + public void clear() { + this.partStats = null; + } + + public int getPartStatsSize() { + return (this.partStats == null) ? 0 : this.partStats.size(); + } + + public void putToPartStats(String key, List<ColumnStatisticsObj> val) { + if (this.partStats == null) { + this.partStats = new HashMap<String,List<ColumnStatisticsObj>>(); + } + this.partStats.put(key, val); + } + + public Map<String,List<ColumnStatisticsObj>> getPartStats() { + return this.partStats; + } + + public void setPartStats(Map<String,List<ColumnStatisticsObj>> partStats) { + this.partStats = partStats; + } + + public void unsetPartStats() { + this.partStats = null; + } + + /** Returns true if field partStats is set (has been assigned a value) and false otherwise */ + public boolean isSetPartStats() { + return this.partStats != null; + } + + public void setPartStatsIsSet(boolean value) { + if (!value) { + this.partStats = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case PART_STATS: + if (value == null) { + unsetPartStats(); + } else { + setPartStats((Map<String,List<ColumnStatisticsObj>>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case PART_STATS: + return getPartStats(); + + } + 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 PART_STATS: + return isSetPartStats(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof PartitionsStatsResult) + return this.equals((PartitionsStatsResult)that); + return false; + } + + public boolean equals(PartitionsStatsResult that) { + if (that == null) + return false; + + boolean this_present_partStats = true && this.isSetPartStats(); + boolean that_present_partStats = true && that.isSetPartStats(); + if (this_present_partStats || that_present_partStats) { + if (!(this_present_partStats && that_present_partStats)) + return false; + if (!this.partStats.equals(that.partStats)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + HashCodeBuilder builder = new HashCodeBuilder(); + + boolean present_partStats = true && (isSetPartStats()); + builder.append(present_partStats); + if (present_partStats) + builder.append(partStats); + + return builder.toHashCode(); + } + + public int compareTo(PartitionsStatsResult other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + PartitionsStatsResult typedOther = (PartitionsStatsResult)other; + + lastComparison = Boolean.valueOf(isSetPartStats()).compareTo(typedOther.isSetPartStats()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetPartStats()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partStats, typedOther.partStats); + 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("PartitionsStatsResult("); + boolean first = true; + + sb.append("partStats:"); + if (this.partStats == null) { + sb.append("null"); + } else { + sb.append(this.partStats); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!isSetPartStats()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'partStats' 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 PartitionsStatsResultStandardSchemeFactory implements SchemeFactory { + public PartitionsStatsResultStandardScheme getScheme() { + return new PartitionsStatsResultStandardScheme(); + } + } + + private static class PartitionsStatsResultStandardScheme extends StandardScheme<PartitionsStatsResult> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, PartitionsStatsResult 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: // PART_STATS + if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { + { + org.apache.thrift.protocol.TMap _map272 = iprot.readMapBegin(); + struct.partStats = new HashMap<String,List<ColumnStatisticsObj>>(2*_map272.size); + for (int _i273 = 0; _i273 < _map272.size; ++_i273) + { + String _key274; // required + List<ColumnStatisticsObj> _val275; // required + _key274 = iprot.readString(); + { + org.apache.thrift.protocol.TList _list276 = iprot.readListBegin(); + _val275 = new ArrayList<ColumnStatisticsObj>(_list276.size); + for (int _i277 = 0; _i277 < _list276.size; ++_i277) + { + ColumnStatisticsObj _elem278; // required + _elem278 = new ColumnStatisticsObj(); + _elem278.read(iprot); + _val275.add(_elem278); + } + iprot.readListEnd(); + } + struct.partStats.put(_key274, _val275); + } + iprot.readMapEnd(); + } + struct.setPartStatsIsSet(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, PartitionsStatsResult struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.partStats != null) { + 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>> _iter279 : struct.partStats.entrySet()) + { + oprot.writeString(_iter279.getKey()); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, _iter279.getValue().size())); + for (ColumnStatisticsObj _iter280 : _iter279.getValue()) + { + _iter280.write(oprot); + } + oprot.writeListEnd(); + } + } + oprot.writeMapEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class PartitionsStatsResultTupleSchemeFactory implements SchemeFactory { + public PartitionsStatsResultTupleScheme getScheme() { + return new PartitionsStatsResultTupleScheme(); + } + } + + private static class PartitionsStatsResultTupleScheme extends TupleScheme<PartitionsStatsResult> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, PartitionsStatsResult struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + { + oprot.writeI32(struct.partStats.size()); + for (Map.Entry<String, List<ColumnStatisticsObj>> _iter281 : struct.partStats.entrySet()) + { + oprot.writeString(_iter281.getKey()); + { + oprot.writeI32(_iter281.getValue().size()); + for (ColumnStatisticsObj _iter282 : _iter281.getValue()) + { + _iter282.write(oprot); + } + } + } + } + } + + @Override + 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 _map283 = 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*_map283.size); + for (int _i284 = 0; _i284 < _map283.size; ++_i284) + { + String _key285; // required + List<ColumnStatisticsObj> _val286; // required + _key285 = iprot.readString(); + { + org.apache.thrift.protocol.TList _list287 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + _val286 = new ArrayList<ColumnStatisticsObj>(_list287.size); + for (int _i288 = 0; _i288 < _list287.size; ++_i288) + { + ColumnStatisticsObj _elem289; // required + _elem289 = new ColumnStatisticsObj(); + _elem289.read(iprot); + _val286.add(_elem289); + } + } + struct.partStats.put(_key285, _val286); + } + } + struct.setPartStatsIsSet(true); + } + } + +} +
Added: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java?rev=1562653&view=auto ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java (added) +++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java Thu Jan 30 00:24:28 2014 @@ -0,0 +1,639 @@ +/** + * 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 TableStatsRequest implements org.apache.thrift.TBase<TableStatsRequest, TableStatsRequest._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TableStatsRequest"); + + private static final org.apache.thrift.protocol.TField DB_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("dbName", 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("tblName", org.apache.thrift.protocol.TType.STRING, (short)2); + private static final org.apache.thrift.protocol.TField COL_NAMES_FIELD_DESC = new org.apache.thrift.protocol.TField("colNames", org.apache.thrift.protocol.TType.LIST, (short)3); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new TableStatsRequestStandardSchemeFactory()); + schemes.put(TupleScheme.class, new TableStatsRequestTupleSchemeFactory()); + } + + private String dbName; // required + private String tblName; // required + private List<String> colNames; // 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 { + DB_NAME((short)1, "dbName"), + TBL_NAME((short)2, "tblName"), + COL_NAMES((short)3, "colNames"); + + 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: // COL_NAMES + return COL_NAMES; + 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.DB_NAME, new org.apache.thrift.meta_data.FieldMetaData("dbName", 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("tblName", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.COL_NAMES, new org.apache.thrift.meta_data.FieldMetaData("colNames", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TableStatsRequest.class, metaDataMap); + } + + public TableStatsRequest() { + } + + public TableStatsRequest( + String dbName, + String tblName, + List<String> colNames) + { + this(); + this.dbName = dbName; + this.tblName = tblName; + this.colNames = colNames; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public TableStatsRequest(TableStatsRequest other) { + if (other.isSetDbName()) { + this.dbName = other.dbName; + } + if (other.isSetTblName()) { + this.tblName = other.tblName; + } + if (other.isSetColNames()) { + List<String> __this__colNames = new ArrayList<String>(); + for (String other_element : other.colNames) { + __this__colNames.add(other_element); + } + this.colNames = __this__colNames; + } + } + + public TableStatsRequest deepCopy() { + return new TableStatsRequest(this); + } + + @Override + public void clear() { + this.dbName = null; + this.tblName = null; + this.colNames = null; + } + + public String getDbName() { + return this.dbName; + } + + public void setDbName(String dbName) { + this.dbName = dbName; + } + + public void unsetDbName() { + this.dbName = null; + } + + /** Returns true if field dbName is set (has been assigned a value) and false otherwise */ + public boolean isSetDbName() { + return this.dbName != null; + } + + public void setDbNameIsSet(boolean value) { + if (!value) { + this.dbName = null; + } + } + + public String getTblName() { + return this.tblName; + } + + public void setTblName(String tblName) { + this.tblName = tblName; + } + + public void unsetTblName() { + this.tblName = null; + } + + /** Returns true if field tblName is set (has been assigned a value) and false otherwise */ + public boolean isSetTblName() { + return this.tblName != null; + } + + public void setTblNameIsSet(boolean value) { + if (!value) { + this.tblName = null; + } + } + + public int getColNamesSize() { + return (this.colNames == null) ? 0 : this.colNames.size(); + } + + public java.util.Iterator<String> getColNamesIterator() { + return (this.colNames == null) ? null : this.colNames.iterator(); + } + + public void addToColNames(String elem) { + if (this.colNames == null) { + this.colNames = new ArrayList<String>(); + } + this.colNames.add(elem); + } + + public List<String> getColNames() { + return this.colNames; + } + + public void setColNames(List<String> colNames) { + this.colNames = colNames; + } + + public void unsetColNames() { + this.colNames = null; + } + + /** Returns true if field colNames is set (has been assigned a value) and false otherwise */ + public boolean isSetColNames() { + return this.colNames != null; + } + + public void setColNamesIsSet(boolean value) { + if (!value) { + this.colNames = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case DB_NAME: + if (value == null) { + unsetDbName(); + } else { + setDbName((String)value); + } + break; + + case TBL_NAME: + if (value == null) { + unsetTblName(); + } else { + setTblName((String)value); + } + break; + + case COL_NAMES: + if (value == null) { + unsetColNames(); + } else { + setColNames((List<String>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case DB_NAME: + return getDbName(); + + case TBL_NAME: + return getTblName(); + + case COL_NAMES: + return getColNames(); + + } + 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 isSetDbName(); + case TBL_NAME: + return isSetTblName(); + case COL_NAMES: + return isSetColNames(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof TableStatsRequest) + return this.equals((TableStatsRequest)that); + return false; + } + + public boolean equals(TableStatsRequest that) { + if (that == null) + return false; + + boolean this_present_dbName = true && this.isSetDbName(); + boolean that_present_dbName = true && that.isSetDbName(); + if (this_present_dbName || that_present_dbName) { + if (!(this_present_dbName && that_present_dbName)) + return false; + if (!this.dbName.equals(that.dbName)) + return false; + } + + boolean this_present_tblName = true && this.isSetTblName(); + boolean that_present_tblName = true && that.isSetTblName(); + if (this_present_tblName || that_present_tblName) { + if (!(this_present_tblName && that_present_tblName)) + return false; + if (!this.tblName.equals(that.tblName)) + return false; + } + + boolean this_present_colNames = true && this.isSetColNames(); + boolean that_present_colNames = true && that.isSetColNames(); + if (this_present_colNames || that_present_colNames) { + if (!(this_present_colNames && that_present_colNames)) + return false; + if (!this.colNames.equals(that.colNames)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + HashCodeBuilder builder = new HashCodeBuilder(); + + boolean present_dbName = true && (isSetDbName()); + builder.append(present_dbName); + if (present_dbName) + builder.append(dbName); + + boolean present_tblName = true && (isSetTblName()); + builder.append(present_tblName); + if (present_tblName) + builder.append(tblName); + + boolean present_colNames = true && (isSetColNames()); + builder.append(present_colNames); + if (present_colNames) + builder.append(colNames); + + return builder.toHashCode(); + } + + public int compareTo(TableStatsRequest other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + TableStatsRequest typedOther = (TableStatsRequest)other; + + lastComparison = Boolean.valueOf(isSetDbName()).compareTo(typedOther.isSetDbName()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetDbName()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.dbName, typedOther.dbName); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetTblName()).compareTo(typedOther.isSetTblName()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTblName()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tblName, typedOther.tblName); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetColNames()).compareTo(typedOther.isSetColNames()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetColNames()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.colNames, typedOther.colNames); + 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("TableStatsRequest("); + boolean first = true; + + sb.append("dbName:"); + if (this.dbName == null) { + sb.append("null"); + } else { + sb.append(this.dbName); + } + first = false; + if (!first) sb.append(", "); + sb.append("tblName:"); + if (this.tblName == null) { + sb.append("null"); + } else { + sb.append(this.tblName); + } + first = false; + if (!first) sb.append(", "); + sb.append("colNames:"); + if (this.colNames == null) { + sb.append("null"); + } else { + sb.append(this.colNames); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!isSetDbName()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'dbName' is unset! Struct:" + toString()); + } + + if (!isSetTblName()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'tblName' is unset! Struct:" + toString()); + } + + if (!isSetColNames()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'colNames' 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 TableStatsRequestStandardSchemeFactory implements SchemeFactory { + public TableStatsRequestStandardScheme getScheme() { + return new TableStatsRequestStandardScheme(); + } + } + + private static class TableStatsRequestStandardScheme extends StandardScheme<TableStatsRequest> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, TableStatsRequest 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.dbName = iprot.readString(); + struct.setDbNameIsSet(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.tblName = iprot.readString(); + struct.setTblNameIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // COL_NAMES + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list290 = iprot.readListBegin(); + struct.colNames = new ArrayList<String>(_list290.size); + for (int _i291 = 0; _i291 < _list290.size; ++_i291) + { + String _elem292; // required + _elem292 = iprot.readString(); + struct.colNames.add(_elem292); + } + iprot.readListEnd(); + } + struct.setColNamesIsSet(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, TableStatsRequest struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.dbName != null) { + oprot.writeFieldBegin(DB_NAME_FIELD_DESC); + oprot.writeString(struct.dbName); + oprot.writeFieldEnd(); + } + if (struct.tblName != null) { + oprot.writeFieldBegin(TBL_NAME_FIELD_DESC); + oprot.writeString(struct.tblName); + oprot.writeFieldEnd(); + } + if (struct.colNames != null) { + 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 _iter293 : struct.colNames) + { + oprot.writeString(_iter293); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class TableStatsRequestTupleSchemeFactory implements SchemeFactory { + public TableStatsRequestTupleScheme getScheme() { + return new TableStatsRequestTupleScheme(); + } + } + + private static class TableStatsRequestTupleScheme extends TupleScheme<TableStatsRequest> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, TableStatsRequest struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + oprot.writeString(struct.dbName); + oprot.writeString(struct.tblName); + { + oprot.writeI32(struct.colNames.size()); + for (String _iter294 : struct.colNames) + { + oprot.writeString(_iter294); + } + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, TableStatsRequest struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + struct.dbName = iprot.readString(); + struct.setDbNameIsSet(true); + struct.tblName = iprot.readString(); + struct.setTblNameIsSet(true); + { + org.apache.thrift.protocol.TList _list295 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.colNames = new ArrayList<String>(_list295.size); + for (int _i296 = 0; _i296 < _list295.size; ++_i296) + { + String _elem297; // required + _elem297 = iprot.readString(); + struct.colNames.add(_elem297); + } + } + struct.setColNamesIsSet(true); + } + } + +} + Added: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java?rev=1562653&view=auto ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java (added) +++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java Thu Jan 30 00:24:28 2014 @@ -0,0 +1,439 @@ +/** + * 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 TableStatsResult implements org.apache.thrift.TBase<TableStatsResult, TableStatsResult._Fields>, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TableStatsResult"); + + private static final org.apache.thrift.protocol.TField TABLE_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("tableStats", 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 TableStatsResultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new TableStatsResultTupleSchemeFactory()); + } + + private List<ColumnStatisticsObj> tableStats; // 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 { + TABLE_STATS((short)1, "tableStats"); + + 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: // TABLE_STATS + return TABLE_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 + 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.TABLE_STATS, new org.apache.thrift.meta_data.FieldMetaData("tableStats", 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, ColumnStatisticsObj.class)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TableStatsResult.class, metaDataMap); + } + + public TableStatsResult() { + } + + public TableStatsResult( + List<ColumnStatisticsObj> tableStats) + { + this(); + this.tableStats = tableStats; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public TableStatsResult(TableStatsResult other) { + if (other.isSetTableStats()) { + List<ColumnStatisticsObj> __this__tableStats = new ArrayList<ColumnStatisticsObj>(); + for (ColumnStatisticsObj other_element : other.tableStats) { + __this__tableStats.add(new ColumnStatisticsObj(other_element)); + } + this.tableStats = __this__tableStats; + } + } + + public TableStatsResult deepCopy() { + return new TableStatsResult(this); + } + + @Override + public void clear() { + this.tableStats = null; + } + + public int getTableStatsSize() { + return (this.tableStats == null) ? 0 : this.tableStats.size(); + } + + public java.util.Iterator<ColumnStatisticsObj> getTableStatsIterator() { + return (this.tableStats == null) ? null : this.tableStats.iterator(); + } + + public void addToTableStats(ColumnStatisticsObj elem) { + if (this.tableStats == null) { + this.tableStats = new ArrayList<ColumnStatisticsObj>(); + } + this.tableStats.add(elem); + } + + public List<ColumnStatisticsObj> getTableStats() { + return this.tableStats; + } + + public void setTableStats(List<ColumnStatisticsObj> tableStats) { + this.tableStats = tableStats; + } + + public void unsetTableStats() { + this.tableStats = null; + } + + /** Returns true if field tableStats is set (has been assigned a value) and false otherwise */ + public boolean isSetTableStats() { + return this.tableStats != null; + } + + public void setTableStatsIsSet(boolean value) { + if (!value) { + this.tableStats = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case TABLE_STATS: + if (value == null) { + unsetTableStats(); + } else { + setTableStats((List<ColumnStatisticsObj>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case TABLE_STATS: + return getTableStats(); + + } + 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 TABLE_STATS: + return isSetTableStats(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof TableStatsResult) + return this.equals((TableStatsResult)that); + return false; + } + + public boolean equals(TableStatsResult that) { + if (that == null) + return false; + + boolean this_present_tableStats = true && this.isSetTableStats(); + boolean that_present_tableStats = true && that.isSetTableStats(); + if (this_present_tableStats || that_present_tableStats) { + if (!(this_present_tableStats && that_present_tableStats)) + return false; + if (!this.tableStats.equals(that.tableStats)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + HashCodeBuilder builder = new HashCodeBuilder(); + + boolean present_tableStats = true && (isSetTableStats()); + builder.append(present_tableStats); + if (present_tableStats) + builder.append(tableStats); + + return builder.toHashCode(); + } + + public int compareTo(TableStatsResult other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + TableStatsResult typedOther = (TableStatsResult)other; + + lastComparison = Boolean.valueOf(isSetTableStats()).compareTo(typedOther.isSetTableStats()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTableStats()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tableStats, typedOther.tableStats); + 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("TableStatsResult("); + boolean first = true; + + sb.append("tableStats:"); + if (this.tableStats == null) { + sb.append("null"); + } else { + sb.append(this.tableStats); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!isSetTableStats()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'tableStats' 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 TableStatsResultStandardSchemeFactory implements SchemeFactory { + public TableStatsResultStandardScheme getScheme() { + return new TableStatsResultStandardScheme(); + } + } + + private static class TableStatsResultStandardScheme extends StandardScheme<TableStatsResult> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, TableStatsResult 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: // TABLE_STATS + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list264 = iprot.readListBegin(); + struct.tableStats = new ArrayList<ColumnStatisticsObj>(_list264.size); + for (int _i265 = 0; _i265 < _list264.size; ++_i265) + { + ColumnStatisticsObj _elem266; // required + _elem266 = new ColumnStatisticsObj(); + _elem266.read(iprot); + struct.tableStats.add(_elem266); + } + iprot.readListEnd(); + } + struct.setTableStatsIsSet(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, TableStatsResult struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.tableStats != null) { + oprot.writeFieldBegin(TABLE_STATS_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.tableStats.size())); + for (ColumnStatisticsObj _iter267 : struct.tableStats) + { + _iter267.write(oprot); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class TableStatsResultTupleSchemeFactory implements SchemeFactory { + public TableStatsResultTupleScheme getScheme() { + return new TableStatsResultTupleScheme(); + } + } + + private static class TableStatsResultTupleScheme extends TupleScheme<TableStatsResult> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, TableStatsResult struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + { + oprot.writeI32(struct.tableStats.size()); + for (ColumnStatisticsObj _iter268 : struct.tableStats) + { + _iter268.write(oprot); + } + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, TableStatsResult struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + { + org.apache.thrift.protocol.TList _list269 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.tableStats = new ArrayList<ColumnStatisticsObj>(_list269.size); + for (int _i270 = 0; _i270 < _list269.size; ++_i270) + { + ColumnStatisticsObj _elem271; // required + _elem271 = new ColumnStatisticsObj(); + _elem271.read(iprot); + struct.tableStats.add(_elem271); + } + } + struct.setTableStatsIsSet(true); + } + } + +} +
