http://git-wip-us.apache.org/repos/asf/hive/blob/129bed52/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java new file mode 100644 index 0000000..3d69606 --- /dev/null +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprRequest.java @@ -0,0 +1,548 @@ +/** + * Autogenerated by Thrift Compiler (0.9.2) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.hadoop.hive.metastore.api; + +import org.apache.thrift.scheme.IScheme; +import org.apache.thrift.scheme.SchemeFactory; +import org.apache.thrift.scheme.StandardScheme; + +import org.apache.thrift.scheme.TupleScheme; +import org.apache.thrift.protocol.TTupleProtocol; +import org.apache.thrift.protocol.TProtocolException; +import org.apache.thrift.EncodingUtils; +import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +import javax.annotation.Generated; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-17") +public class GetFileMetadataByExprRequest implements org.apache.thrift.TBase<GetFileMetadataByExprRequest, GetFileMetadataByExprRequest._Fields>, java.io.Serializable, Cloneable, Comparable<GetFileMetadataByExprRequest> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetFileMetadataByExprRequest"); + + private static final org.apache.thrift.protocol.TField FILE_IDS_FIELD_DESC = new org.apache.thrift.protocol.TField("fileIds", org.apache.thrift.protocol.TType.LIST, (short)1); + private static final org.apache.thrift.protocol.TField EXPR_FIELD_DESC = new org.apache.thrift.protocol.TField("expr", org.apache.thrift.protocol.TType.STRING, (short)2); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new GetFileMetadataByExprRequestStandardSchemeFactory()); + schemes.put(TupleScheme.class, new GetFileMetadataByExprRequestTupleSchemeFactory()); + } + + private List<Long> fileIds; // required + private ByteBuffer expr; // 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 { + FILE_IDS((short)1, "fileIds"), + EXPR((short)2, "expr"); + + 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: // FILE_IDS + return FILE_IDS; + case 2: // EXPR + return EXPR; + 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.FILE_IDS, new org.apache.thrift.meta_data.FieldMetaData("fileIds", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)))); + tmpMap.put(_Fields.EXPR, new org.apache.thrift.meta_data.FieldMetaData("expr", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetFileMetadataByExprRequest.class, metaDataMap); + } + + public GetFileMetadataByExprRequest() { + } + + public GetFileMetadataByExprRequest( + List<Long> fileIds, + ByteBuffer expr) + { + this(); + this.fileIds = fileIds; + this.expr = org.apache.thrift.TBaseHelper.copyBinary(expr); + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public GetFileMetadataByExprRequest(GetFileMetadataByExprRequest other) { + if (other.isSetFileIds()) { + List<Long> __this__fileIds = new ArrayList<Long>(other.fileIds); + this.fileIds = __this__fileIds; + } + if (other.isSetExpr()) { + this.expr = org.apache.thrift.TBaseHelper.copyBinary(other.expr); + } + } + + public GetFileMetadataByExprRequest deepCopy() { + return new GetFileMetadataByExprRequest(this); + } + + @Override + public void clear() { + this.fileIds = null; + this.expr = null; + } + + public int getFileIdsSize() { + return (this.fileIds == null) ? 0 : this.fileIds.size(); + } + + public java.util.Iterator<Long> getFileIdsIterator() { + return (this.fileIds == null) ? null : this.fileIds.iterator(); + } + + public void addToFileIds(long elem) { + if (this.fileIds == null) { + this.fileIds = new ArrayList<Long>(); + } + this.fileIds.add(elem); + } + + public List<Long> getFileIds() { + return this.fileIds; + } + + public void setFileIds(List<Long> fileIds) { + this.fileIds = fileIds; + } + + public void unsetFileIds() { + this.fileIds = null; + } + + /** Returns true if field fileIds is set (has been assigned a value) and false otherwise */ + public boolean isSetFileIds() { + return this.fileIds != null; + } + + public void setFileIdsIsSet(boolean value) { + if (!value) { + this.fileIds = null; + } + } + + public byte[] getExpr() { + setExpr(org.apache.thrift.TBaseHelper.rightSize(expr)); + return expr == null ? null : expr.array(); + } + + public ByteBuffer bufferForExpr() { + return org.apache.thrift.TBaseHelper.copyBinary(expr); + } + + public void setExpr(byte[] expr) { + this.expr = expr == null ? (ByteBuffer)null : ByteBuffer.wrap(Arrays.copyOf(expr, expr.length)); + } + + public void setExpr(ByteBuffer expr) { + this.expr = org.apache.thrift.TBaseHelper.copyBinary(expr); + } + + public void unsetExpr() { + this.expr = null; + } + + /** Returns true if field expr is set (has been assigned a value) and false otherwise */ + public boolean isSetExpr() { + return this.expr != null; + } + + public void setExprIsSet(boolean value) { + if (!value) { + this.expr = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case FILE_IDS: + if (value == null) { + unsetFileIds(); + } else { + setFileIds((List<Long>)value); + } + break; + + case EXPR: + if (value == null) { + unsetExpr(); + } else { + setExpr((ByteBuffer)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case FILE_IDS: + return getFileIds(); + + case EXPR: + return getExpr(); + + } + 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 FILE_IDS: + return isSetFileIds(); + case EXPR: + return isSetExpr(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof GetFileMetadataByExprRequest) + return this.equals((GetFileMetadataByExprRequest)that); + return false; + } + + public boolean equals(GetFileMetadataByExprRequest that) { + if (that == null) + return false; + + boolean this_present_fileIds = true && this.isSetFileIds(); + boolean that_present_fileIds = true && that.isSetFileIds(); + if (this_present_fileIds || that_present_fileIds) { + if (!(this_present_fileIds && that_present_fileIds)) + return false; + if (!this.fileIds.equals(that.fileIds)) + return false; + } + + boolean this_present_expr = true && this.isSetExpr(); + boolean that_present_expr = true && that.isSetExpr(); + if (this_present_expr || that_present_expr) { + if (!(this_present_expr && that_present_expr)) + return false; + if (!this.expr.equals(that.expr)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_fileIds = true && (isSetFileIds()); + list.add(present_fileIds); + if (present_fileIds) + list.add(fileIds); + + boolean present_expr = true && (isSetExpr()); + list.add(present_expr); + if (present_expr) + list.add(expr); + + return list.hashCode(); + } + + @Override + public int compareTo(GetFileMetadataByExprRequest other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetFileIds()).compareTo(other.isSetFileIds()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetFileIds()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.fileIds, other.fileIds); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetExpr()).compareTo(other.isSetExpr()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetExpr()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.expr, other.expr); + 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("GetFileMetadataByExprRequest("); + boolean first = true; + + sb.append("fileIds:"); + if (this.fileIds == null) { + sb.append("null"); + } else { + sb.append(this.fileIds); + } + first = false; + if (!first) sb.append(", "); + sb.append("expr:"); + if (this.expr == null) { + sb.append("null"); + } else { + org.apache.thrift.TBaseHelper.toString(this.expr, sb); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!isSetFileIds()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'fileIds' is unset! Struct:" + toString()); + } + + if (!isSetExpr()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'expr' 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 GetFileMetadataByExprRequestStandardSchemeFactory implements SchemeFactory { + public GetFileMetadataByExprRequestStandardScheme getScheme() { + return new GetFileMetadataByExprRequestStandardScheme(); + } + } + + private static class GetFileMetadataByExprRequestStandardScheme extends StandardScheme<GetFileMetadataByExprRequest> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, GetFileMetadataByExprRequest 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: // FILE_IDS + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list542 = iprot.readListBegin(); + struct.fileIds = new ArrayList<Long>(_list542.size); + long _elem543; + for (int _i544 = 0; _i544 < _list542.size; ++_i544) + { + _elem543 = iprot.readI64(); + struct.fileIds.add(_elem543); + } + iprot.readListEnd(); + } + struct.setFileIdsIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // EXPR + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.expr = iprot.readBinary(); + struct.setExprIsSet(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, GetFileMetadataByExprRequest struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.fileIds != null) { + oprot.writeFieldBegin(FILE_IDS_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.fileIds.size())); + for (long _iter545 : struct.fileIds) + { + oprot.writeI64(_iter545); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + if (struct.expr != null) { + oprot.writeFieldBegin(EXPR_FIELD_DESC); + oprot.writeBinary(struct.expr); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class GetFileMetadataByExprRequestTupleSchemeFactory implements SchemeFactory { + public GetFileMetadataByExprRequestTupleScheme getScheme() { + return new GetFileMetadataByExprRequestTupleScheme(); + } + } + + private static class GetFileMetadataByExprRequestTupleScheme extends TupleScheme<GetFileMetadataByExprRequest> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataByExprRequest struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + { + oprot.writeI32(struct.fileIds.size()); + for (long _iter546 : struct.fileIds) + { + oprot.writeI64(_iter546); + } + } + oprot.writeBinary(struct.expr); + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataByExprRequest struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + { + org.apache.thrift.protocol.TList _list547 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.fileIds = new ArrayList<Long>(_list547.size); + long _elem548; + for (int _i549 = 0; _i549 < _list547.size; ++_i549) + { + _elem548 = iprot.readI64(); + struct.fileIds.add(_elem548); + } + } + struct.setFileIdsIsSet(true); + struct.expr = iprot.readBinary(); + struct.setExprIsSet(true); + } + } + +} +
http://git-wip-us.apache.org/repos/asf/hive/blob/129bed52/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java new file mode 100644 index 0000000..3ac9921 --- /dev/null +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java @@ -0,0 +1,703 @@ +/** + * Autogenerated by Thrift Compiler (0.9.2) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.hadoop.hive.metastore.api; + +import org.apache.thrift.scheme.IScheme; +import org.apache.thrift.scheme.SchemeFactory; +import org.apache.thrift.scheme.StandardScheme; + +import org.apache.thrift.scheme.TupleScheme; +import org.apache.thrift.protocol.TTupleProtocol; +import org.apache.thrift.protocol.TProtocolException; +import org.apache.thrift.EncodingUtils; +import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +import javax.annotation.Generated; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-17") +public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetFileMetadataByExprResult, GetFileMetadataByExprResult._Fields>, java.io.Serializable, Cloneable, Comparable<GetFileMetadataByExprResult> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetFileMetadataByExprResult"); + + private static final org.apache.thrift.protocol.TField METADATA_FIELD_DESC = new org.apache.thrift.protocol.TField("metadata", org.apache.thrift.protocol.TType.MAP, (short)1); + private static final org.apache.thrift.protocol.TField IS_SUPPORTED_FIELD_DESC = new org.apache.thrift.protocol.TField("isSupported", org.apache.thrift.protocol.TType.BOOL, (short)2); + private static final org.apache.thrift.protocol.TField UNKNOWN_FILE_IDS_FIELD_DESC = new org.apache.thrift.protocol.TField("unknownFileIds", 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 GetFileMetadataByExprResultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new GetFileMetadataByExprResultTupleSchemeFactory()); + } + + private Map<Long,MetadataPpdResult> metadata; // required + private boolean isSupported; // required + private List<Long> unknownFileIds; // 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 { + METADATA((short)1, "metadata"), + IS_SUPPORTED((short)2, "isSupported"), + UNKNOWN_FILE_IDS((short)3, "unknownFileIds"); + + 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: // METADATA + return METADATA; + case 2: // IS_SUPPORTED + return IS_SUPPORTED; + case 3: // UNKNOWN_FILE_IDS + return UNKNOWN_FILE_IDS; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + private static final int __ISSUPPORTED_ISSET_ID = 0; + private byte __isset_bitfield = 0; + 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.METADATA, new org.apache.thrift.meta_data.FieldMetaData("metadata", 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.I64), + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, MetadataPpdResult.class)))); + tmpMap.put(_Fields.IS_SUPPORTED, new org.apache.thrift.meta_data.FieldMetaData("isSupported", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL))); + tmpMap.put(_Fields.UNKNOWN_FILE_IDS, new org.apache.thrift.meta_data.FieldMetaData("unknownFileIds", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetFileMetadataByExprResult.class, metaDataMap); + } + + public GetFileMetadataByExprResult() { + } + + public GetFileMetadataByExprResult( + Map<Long,MetadataPpdResult> metadata, + boolean isSupported, + List<Long> unknownFileIds) + { + this(); + this.metadata = metadata; + this.isSupported = isSupported; + setIsSupportedIsSet(true); + this.unknownFileIds = unknownFileIds; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public GetFileMetadataByExprResult(GetFileMetadataByExprResult other) { + __isset_bitfield = other.__isset_bitfield; + if (other.isSetMetadata()) { + Map<Long,MetadataPpdResult> __this__metadata = new HashMap<Long,MetadataPpdResult>(other.metadata.size()); + for (Map.Entry<Long, MetadataPpdResult> other_element : other.metadata.entrySet()) { + + Long other_element_key = other_element.getKey(); + MetadataPpdResult other_element_value = other_element.getValue(); + + Long __this__metadata_copy_key = other_element_key; + + MetadataPpdResult __this__metadata_copy_value = new MetadataPpdResult(other_element_value); + + __this__metadata.put(__this__metadata_copy_key, __this__metadata_copy_value); + } + this.metadata = __this__metadata; + } + this.isSupported = other.isSupported; + if (other.isSetUnknownFileIds()) { + List<Long> __this__unknownFileIds = new ArrayList<Long>(other.unknownFileIds); + this.unknownFileIds = __this__unknownFileIds; + } + } + + public GetFileMetadataByExprResult deepCopy() { + return new GetFileMetadataByExprResult(this); + } + + @Override + public void clear() { + this.metadata = null; + setIsSupportedIsSet(false); + this.isSupported = false; + this.unknownFileIds = null; + } + + public int getMetadataSize() { + return (this.metadata == null) ? 0 : this.metadata.size(); + } + + public void putToMetadata(long key, MetadataPpdResult val) { + if (this.metadata == null) { + this.metadata = new HashMap<Long,MetadataPpdResult>(); + } + this.metadata.put(key, val); + } + + public Map<Long,MetadataPpdResult> getMetadata() { + return this.metadata; + } + + public void setMetadata(Map<Long,MetadataPpdResult> metadata) { + this.metadata = metadata; + } + + public void unsetMetadata() { + this.metadata = null; + } + + /** Returns true if field metadata is set (has been assigned a value) and false otherwise */ + public boolean isSetMetadata() { + return this.metadata != null; + } + + public void setMetadataIsSet(boolean value) { + if (!value) { + this.metadata = null; + } + } + + public boolean isIsSupported() { + return this.isSupported; + } + + public void setIsSupported(boolean isSupported) { + this.isSupported = isSupported; + setIsSupportedIsSet(true); + } + + public void unsetIsSupported() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ISSUPPORTED_ISSET_ID); + } + + /** Returns true if field isSupported is set (has been assigned a value) and false otherwise */ + public boolean isSetIsSupported() { + return EncodingUtils.testBit(__isset_bitfield, __ISSUPPORTED_ISSET_ID); + } + + public void setIsSupportedIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ISSUPPORTED_ISSET_ID, value); + } + + public int getUnknownFileIdsSize() { + return (this.unknownFileIds == null) ? 0 : this.unknownFileIds.size(); + } + + public java.util.Iterator<Long> getUnknownFileIdsIterator() { + return (this.unknownFileIds == null) ? null : this.unknownFileIds.iterator(); + } + + public void addToUnknownFileIds(long elem) { + if (this.unknownFileIds == null) { + this.unknownFileIds = new ArrayList<Long>(); + } + this.unknownFileIds.add(elem); + } + + public List<Long> getUnknownFileIds() { + return this.unknownFileIds; + } + + public void setUnknownFileIds(List<Long> unknownFileIds) { + this.unknownFileIds = unknownFileIds; + } + + public void unsetUnknownFileIds() { + this.unknownFileIds = null; + } + + /** Returns true if field unknownFileIds is set (has been assigned a value) and false otherwise */ + public boolean isSetUnknownFileIds() { + return this.unknownFileIds != null; + } + + public void setUnknownFileIdsIsSet(boolean value) { + if (!value) { + this.unknownFileIds = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case METADATA: + if (value == null) { + unsetMetadata(); + } else { + setMetadata((Map<Long,MetadataPpdResult>)value); + } + break; + + case IS_SUPPORTED: + if (value == null) { + unsetIsSupported(); + } else { + setIsSupported((Boolean)value); + } + break; + + case UNKNOWN_FILE_IDS: + if (value == null) { + unsetUnknownFileIds(); + } else { + setUnknownFileIds((List<Long>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case METADATA: + return getMetadata(); + + case IS_SUPPORTED: + return Boolean.valueOf(isIsSupported()); + + case UNKNOWN_FILE_IDS: + return getUnknownFileIds(); + + } + 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 METADATA: + return isSetMetadata(); + case IS_SUPPORTED: + return isSetIsSupported(); + case UNKNOWN_FILE_IDS: + return isSetUnknownFileIds(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof GetFileMetadataByExprResult) + return this.equals((GetFileMetadataByExprResult)that); + return false; + } + + public boolean equals(GetFileMetadataByExprResult that) { + if (that == null) + return false; + + boolean this_present_metadata = true && this.isSetMetadata(); + boolean that_present_metadata = true && that.isSetMetadata(); + if (this_present_metadata || that_present_metadata) { + if (!(this_present_metadata && that_present_metadata)) + return false; + if (!this.metadata.equals(that.metadata)) + return false; + } + + boolean this_present_isSupported = true; + boolean that_present_isSupported = true; + if (this_present_isSupported || that_present_isSupported) { + if (!(this_present_isSupported && that_present_isSupported)) + return false; + if (this.isSupported != that.isSupported) + return false; + } + + boolean this_present_unknownFileIds = true && this.isSetUnknownFileIds(); + boolean that_present_unknownFileIds = true && that.isSetUnknownFileIds(); + if (this_present_unknownFileIds || that_present_unknownFileIds) { + if (!(this_present_unknownFileIds && that_present_unknownFileIds)) + return false; + if (!this.unknownFileIds.equals(that.unknownFileIds)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_metadata = true && (isSetMetadata()); + list.add(present_metadata); + if (present_metadata) + list.add(metadata); + + boolean present_isSupported = true; + list.add(present_isSupported); + if (present_isSupported) + list.add(isSupported); + + boolean present_unknownFileIds = true && (isSetUnknownFileIds()); + list.add(present_unknownFileIds); + if (present_unknownFileIds) + list.add(unknownFileIds); + + return list.hashCode(); + } + + @Override + public int compareTo(GetFileMetadataByExprResult other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetMetadata()).compareTo(other.isSetMetadata()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetMetadata()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.metadata, other.metadata); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetIsSupported()).compareTo(other.isSetIsSupported()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetIsSupported()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.isSupported, other.isSupported); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetUnknownFileIds()).compareTo(other.isSetUnknownFileIds()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetUnknownFileIds()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.unknownFileIds, other.unknownFileIds); + 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("GetFileMetadataByExprResult("); + boolean first = true; + + sb.append("metadata:"); + if (this.metadata == null) { + sb.append("null"); + } else { + sb.append(this.metadata); + } + first = false; + if (!first) sb.append(", "); + sb.append("isSupported:"); + sb.append(this.isSupported); + first = false; + if (!first) sb.append(", "); + sb.append("unknownFileIds:"); + if (this.unknownFileIds == null) { + sb.append("null"); + } else { + sb.append(this.unknownFileIds); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!isSetMetadata()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'metadata' is unset! Struct:" + toString()); + } + + if (!isSetIsSupported()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'isSupported' is unset! Struct:" + toString()); + } + + if (!isSetUnknownFileIds()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'unknownFileIds' is unset! Struct:" + toString()); + } + + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. + __isset_bitfield = 0; + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class GetFileMetadataByExprResultStandardSchemeFactory implements SchemeFactory { + public GetFileMetadataByExprResultStandardScheme getScheme() { + return new GetFileMetadataByExprResultStandardScheme(); + } + } + + private static class GetFileMetadataByExprResultStandardScheme extends StandardScheme<GetFileMetadataByExprResult> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, GetFileMetadataByExprResult 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: // METADATA + if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { + { + org.apache.thrift.protocol.TMap _map524 = iprot.readMapBegin(); + struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map524.size); + long _key525; + MetadataPpdResult _val526; + for (int _i527 = 0; _i527 < _map524.size; ++_i527) + { + _key525 = iprot.readI64(); + _val526 = new MetadataPpdResult(); + _val526.read(iprot); + struct.metadata.put(_key525, _val526); + } + iprot.readMapEnd(); + } + struct.setMetadataIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // IS_SUPPORTED + if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) { + struct.isSupported = iprot.readBool(); + struct.setIsSupportedIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // UNKNOWN_FILE_IDS + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list528 = iprot.readListBegin(); + struct.unknownFileIds = new ArrayList<Long>(_list528.size); + long _elem529; + for (int _i530 = 0; _i530 < _list528.size; ++_i530) + { + _elem529 = iprot.readI64(); + struct.unknownFileIds.add(_elem529); + } + iprot.readListEnd(); + } + struct.setUnknownFileIdsIsSet(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, GetFileMetadataByExprResult struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.metadata != null) { + oprot.writeFieldBegin(METADATA_FIELD_DESC); + { + oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRUCT, struct.metadata.size())); + for (Map.Entry<Long, MetadataPpdResult> _iter531 : struct.metadata.entrySet()) + { + oprot.writeI64(_iter531.getKey()); + _iter531.getValue().write(oprot); + } + oprot.writeMapEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldBegin(IS_SUPPORTED_FIELD_DESC); + oprot.writeBool(struct.isSupported); + oprot.writeFieldEnd(); + if (struct.unknownFileIds != null) { + oprot.writeFieldBegin(UNKNOWN_FILE_IDS_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.unknownFileIds.size())); + for (long _iter532 : struct.unknownFileIds) + { + oprot.writeI64(_iter532); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class GetFileMetadataByExprResultTupleSchemeFactory implements SchemeFactory { + public GetFileMetadataByExprResultTupleScheme getScheme() { + return new GetFileMetadataByExprResultTupleScheme(); + } + } + + private static class GetFileMetadataByExprResultTupleScheme extends TupleScheme<GetFileMetadataByExprResult> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataByExprResult struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + { + oprot.writeI32(struct.metadata.size()); + for (Map.Entry<Long, MetadataPpdResult> _iter533 : struct.metadata.entrySet()) + { + oprot.writeI64(_iter533.getKey()); + _iter533.getValue().write(oprot); + } + } + oprot.writeBool(struct.isSupported); + { + oprot.writeI32(struct.unknownFileIds.size()); + for (long _iter534 : struct.unknownFileIds) + { + oprot.writeI64(_iter534); + } + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataByExprResult struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + { + org.apache.thrift.protocol.TMap _map535 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map535.size); + long _key536; + MetadataPpdResult _val537; + for (int _i538 = 0; _i538 < _map535.size; ++_i538) + { + _key536 = iprot.readI64(); + _val537 = new MetadataPpdResult(); + _val537.read(iprot); + struct.metadata.put(_key536, _val537); + } + } + struct.setMetadataIsSet(true); + struct.isSupported = iprot.readBool(); + struct.setIsSupportedIsSet(true); + { + org.apache.thrift.protocol.TList _list539 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.unknownFileIds = new ArrayList<Long>(_list539.size); + long _elem540; + for (int _i541 = 0; _i541 < _list539.size; ++_i541) + { + _elem540 = iprot.readI64(); + struct.unknownFileIds.add(_elem540); + } + } + struct.setUnknownFileIdsIsSet(true); + } + } + +} + http://git-wip-us.apache.org/repos/asf/hive/blob/129bed52/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java new file mode 100644 index 0000000..e4cd1c4 --- /dev/null +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java @@ -0,0 +1,438 @@ +/** + * Autogenerated by Thrift Compiler (0.9.2) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.hadoop.hive.metastore.api; + +import org.apache.thrift.scheme.IScheme; +import org.apache.thrift.scheme.SchemeFactory; +import org.apache.thrift.scheme.StandardScheme; + +import org.apache.thrift.scheme.TupleScheme; +import org.apache.thrift.protocol.TTupleProtocol; +import org.apache.thrift.protocol.TProtocolException; +import org.apache.thrift.EncodingUtils; +import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +import javax.annotation.Generated; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-17") +public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMetadataRequest, GetFileMetadataRequest._Fields>, java.io.Serializable, Cloneable, Comparable<GetFileMetadataRequest> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetFileMetadataRequest"); + + private static final org.apache.thrift.protocol.TField FILE_IDS_FIELD_DESC = new org.apache.thrift.protocol.TField("fileIds", 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 GetFileMetadataRequestStandardSchemeFactory()); + schemes.put(TupleScheme.class, new GetFileMetadataRequestTupleSchemeFactory()); + } + + private List<Long> fileIds; // 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 { + FILE_IDS((short)1, "fileIds"); + + 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: // FILE_IDS + return FILE_IDS; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.FILE_IDS, new org.apache.thrift.meta_data.FieldMetaData("fileIds", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetFileMetadataRequest.class, metaDataMap); + } + + public GetFileMetadataRequest() { + } + + public GetFileMetadataRequest( + List<Long> fileIds) + { + this(); + this.fileIds = fileIds; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public GetFileMetadataRequest(GetFileMetadataRequest other) { + if (other.isSetFileIds()) { + List<Long> __this__fileIds = new ArrayList<Long>(other.fileIds); + this.fileIds = __this__fileIds; + } + } + + public GetFileMetadataRequest deepCopy() { + return new GetFileMetadataRequest(this); + } + + @Override + public void clear() { + this.fileIds = null; + } + + public int getFileIdsSize() { + return (this.fileIds == null) ? 0 : this.fileIds.size(); + } + + public java.util.Iterator<Long> getFileIdsIterator() { + return (this.fileIds == null) ? null : this.fileIds.iterator(); + } + + public void addToFileIds(long elem) { + if (this.fileIds == null) { + this.fileIds = new ArrayList<Long>(); + } + this.fileIds.add(elem); + } + + public List<Long> getFileIds() { + return this.fileIds; + } + + public void setFileIds(List<Long> fileIds) { + this.fileIds = fileIds; + } + + public void unsetFileIds() { + this.fileIds = null; + } + + /** Returns true if field fileIds is set (has been assigned a value) and false otherwise */ + public boolean isSetFileIds() { + return this.fileIds != null; + } + + public void setFileIdsIsSet(boolean value) { + if (!value) { + this.fileIds = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case FILE_IDS: + if (value == null) { + unsetFileIds(); + } else { + setFileIds((List<Long>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case FILE_IDS: + return getFileIds(); + + } + 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 FILE_IDS: + return isSetFileIds(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof GetFileMetadataRequest) + return this.equals((GetFileMetadataRequest)that); + return false; + } + + public boolean equals(GetFileMetadataRequest that) { + if (that == null) + return false; + + boolean this_present_fileIds = true && this.isSetFileIds(); + boolean that_present_fileIds = true && that.isSetFileIds(); + if (this_present_fileIds || that_present_fileIds) { + if (!(this_present_fileIds && that_present_fileIds)) + return false; + if (!this.fileIds.equals(that.fileIds)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_fileIds = true && (isSetFileIds()); + list.add(present_fileIds); + if (present_fileIds) + list.add(fileIds); + + return list.hashCode(); + } + + @Override + public int compareTo(GetFileMetadataRequest other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetFileIds()).compareTo(other.isSetFileIds()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetFileIds()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.fileIds, other.fileIds); + 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("GetFileMetadataRequest("); + boolean first = true; + + sb.append("fileIds:"); + if (this.fileIds == null) { + sb.append("null"); + } else { + sb.append(this.fileIds); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!isSetFileIds()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'fileIds' 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 GetFileMetadataRequestStandardSchemeFactory implements SchemeFactory { + public GetFileMetadataRequestStandardScheme getScheme() { + return new GetFileMetadataRequestStandardScheme(); + } + } + + private static class GetFileMetadataRequestStandardScheme extends StandardScheme<GetFileMetadataRequest> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, GetFileMetadataRequest 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: // FILE_IDS + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list560 = iprot.readListBegin(); + struct.fileIds = new ArrayList<Long>(_list560.size); + long _elem561; + for (int _i562 = 0; _i562 < _list560.size; ++_i562) + { + _elem561 = iprot.readI64(); + struct.fileIds.add(_elem561); + } + iprot.readListEnd(); + } + struct.setFileIdsIsSet(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, GetFileMetadataRequest struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.fileIds != null) { + oprot.writeFieldBegin(FILE_IDS_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.fileIds.size())); + for (long _iter563 : struct.fileIds) + { + oprot.writeI64(_iter563); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class GetFileMetadataRequestTupleSchemeFactory implements SchemeFactory { + public GetFileMetadataRequestTupleScheme getScheme() { + return new GetFileMetadataRequestTupleScheme(); + } + } + + private static class GetFileMetadataRequestTupleScheme extends TupleScheme<GetFileMetadataRequest> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataRequest struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + { + oprot.writeI32(struct.fileIds.size()); + for (long _iter564 : struct.fileIds) + { + oprot.writeI64(_iter564); + } + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataRequest struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + { + org.apache.thrift.protocol.TList _list565 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.fileIds = new ArrayList<Long>(_list565.size); + long _elem566; + for (int _i567 = 0; _i567 < _list565.size; ++_i567) + { + _elem566 = iprot.readI64(); + struct.fileIds.add(_elem566); + } + } + struct.setFileIdsIsSet(true); + } + } + +} + http://git-wip-us.apache.org/repos/asf/hive/blob/129bed52/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java new file mode 100644 index 0000000..a7d01e1 --- /dev/null +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java @@ -0,0 +1,540 @@ +/** + * Autogenerated by Thrift Compiler (0.9.2) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.hadoop.hive.metastore.api; + +import org.apache.thrift.scheme.IScheme; +import org.apache.thrift.scheme.SchemeFactory; +import org.apache.thrift.scheme.StandardScheme; + +import org.apache.thrift.scheme.TupleScheme; +import org.apache.thrift.protocol.TTupleProtocol; +import org.apache.thrift.protocol.TProtocolException; +import org.apache.thrift.EncodingUtils; +import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +import javax.annotation.Generated; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-17") +public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMetadataResult, GetFileMetadataResult._Fields>, java.io.Serializable, Cloneable, Comparable<GetFileMetadataResult> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetFileMetadataResult"); + + private static final org.apache.thrift.protocol.TField METADATA_FIELD_DESC = new org.apache.thrift.protocol.TField("metadata", org.apache.thrift.protocol.TType.MAP, (short)1); + private static final org.apache.thrift.protocol.TField IS_SUPPORTED_FIELD_DESC = new org.apache.thrift.protocol.TField("isSupported", org.apache.thrift.protocol.TType.BOOL, (short)2); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new GetFileMetadataResultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new GetFileMetadataResultTupleSchemeFactory()); + } + + private Map<Long,ByteBuffer> metadata; // required + private boolean isSupported; // 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 { + METADATA((short)1, "metadata"), + IS_SUPPORTED((short)2, "isSupported"); + + 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: // METADATA + return METADATA; + case 2: // IS_SUPPORTED + return IS_SUPPORTED; + 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 __ISSUPPORTED_ISSET_ID = 0; + private byte __isset_bitfield = 0; + 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.METADATA, new org.apache.thrift.meta_data.FieldMetaData("metadata", 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.I64), + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true)))); + tmpMap.put(_Fields.IS_SUPPORTED, new org.apache.thrift.meta_data.FieldMetaData("isSupported", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetFileMetadataResult.class, metaDataMap); + } + + public GetFileMetadataResult() { + } + + public GetFileMetadataResult( + Map<Long,ByteBuffer> metadata, + boolean isSupported) + { + this(); + this.metadata = metadata; + this.isSupported = isSupported; + setIsSupportedIsSet(true); + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public GetFileMetadataResult(GetFileMetadataResult other) { + __isset_bitfield = other.__isset_bitfield; + if (other.isSetMetadata()) { + Map<Long,ByteBuffer> __this__metadata = new HashMap<Long,ByteBuffer>(other.metadata); + this.metadata = __this__metadata; + } + this.isSupported = other.isSupported; + } + + public GetFileMetadataResult deepCopy() { + return new GetFileMetadataResult(this); + } + + @Override + public void clear() { + this.metadata = null; + setIsSupportedIsSet(false); + this.isSupported = false; + } + + public int getMetadataSize() { + return (this.metadata == null) ? 0 : this.metadata.size(); + } + + public void putToMetadata(long key, ByteBuffer val) { + if (this.metadata == null) { + this.metadata = new HashMap<Long,ByteBuffer>(); + } + this.metadata.put(key, val); + } + + public Map<Long,ByteBuffer> getMetadata() { + return this.metadata; + } + + public void setMetadata(Map<Long,ByteBuffer> metadata) { + this.metadata = metadata; + } + + public void unsetMetadata() { + this.metadata = null; + } + + /** Returns true if field metadata is set (has been assigned a value) and false otherwise */ + public boolean isSetMetadata() { + return this.metadata != null; + } + + public void setMetadataIsSet(boolean value) { + if (!value) { + this.metadata = null; + } + } + + public boolean isIsSupported() { + return this.isSupported; + } + + public void setIsSupported(boolean isSupported) { + this.isSupported = isSupported; + setIsSupportedIsSet(true); + } + + public void unsetIsSupported() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ISSUPPORTED_ISSET_ID); + } + + /** Returns true if field isSupported is set (has been assigned a value) and false otherwise */ + public boolean isSetIsSupported() { + return EncodingUtils.testBit(__isset_bitfield, __ISSUPPORTED_ISSET_ID); + } + + public void setIsSupportedIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ISSUPPORTED_ISSET_ID, value); + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case METADATA: + if (value == null) { + unsetMetadata(); + } else { + setMetadata((Map<Long,ByteBuffer>)value); + } + break; + + case IS_SUPPORTED: + if (value == null) { + unsetIsSupported(); + } else { + setIsSupported((Boolean)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case METADATA: + return getMetadata(); + + case IS_SUPPORTED: + return Boolean.valueOf(isIsSupported()); + + } + 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 METADATA: + return isSetMetadata(); + case IS_SUPPORTED: + return isSetIsSupported(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof GetFileMetadataResult) + return this.equals((GetFileMetadataResult)that); + return false; + } + + public boolean equals(GetFileMetadataResult that) { + if (that == null) + return false; + + boolean this_present_metadata = true && this.isSetMetadata(); + boolean that_present_metadata = true && that.isSetMetadata(); + if (this_present_metadata || that_present_metadata) { + if (!(this_present_metadata && that_present_metadata)) + return false; + if (!this.metadata.equals(that.metadata)) + return false; + } + + boolean this_present_isSupported = true; + boolean that_present_isSupported = true; + if (this_present_isSupported || that_present_isSupported) { + if (!(this_present_isSupported && that_present_isSupported)) + return false; + if (this.isSupported != that.isSupported) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_metadata = true && (isSetMetadata()); + list.add(present_metadata); + if (present_metadata) + list.add(metadata); + + boolean present_isSupported = true; + list.add(present_isSupported); + if (present_isSupported) + list.add(isSupported); + + return list.hashCode(); + } + + @Override + public int compareTo(GetFileMetadataResult other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetMetadata()).compareTo(other.isSetMetadata()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetMetadata()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.metadata, other.metadata); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetIsSupported()).compareTo(other.isSetIsSupported()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetIsSupported()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.isSupported, other.isSupported); + 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("GetFileMetadataResult("); + boolean first = true; + + sb.append("metadata:"); + if (this.metadata == null) { + sb.append("null"); + } else { + sb.append(this.metadata); + } + first = false; + if (!first) sb.append(", "); + sb.append("isSupported:"); + sb.append(this.isSupported); + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!isSetMetadata()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'metadata' is unset! Struct:" + toString()); + } + + if (!isSetIsSupported()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'isSupported' is unset! Struct:" + toString()); + } + + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. + __isset_bitfield = 0; + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class GetFileMetadataResultStandardSchemeFactory implements SchemeFactory { + public GetFileMetadataResultStandardScheme getScheme() { + return new GetFileMetadataResultStandardScheme(); + } + } + + private static class GetFileMetadataResultStandardScheme extends StandardScheme<GetFileMetadataResult> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, GetFileMetadataResult 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: // METADATA + if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { + { + org.apache.thrift.protocol.TMap _map550 = iprot.readMapBegin(); + struct.metadata = new HashMap<Long,ByteBuffer>(2*_map550.size); + long _key551; + ByteBuffer _val552; + for (int _i553 = 0; _i553 < _map550.size; ++_i553) + { + _key551 = iprot.readI64(); + _val552 = iprot.readBinary(); + struct.metadata.put(_key551, _val552); + } + iprot.readMapEnd(); + } + struct.setMetadataIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // IS_SUPPORTED + if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) { + struct.isSupported = iprot.readBool(); + struct.setIsSupportedIsSet(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, GetFileMetadataResult struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.metadata != null) { + oprot.writeFieldBegin(METADATA_FIELD_DESC); + { + oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRING, struct.metadata.size())); + for (Map.Entry<Long, ByteBuffer> _iter554 : struct.metadata.entrySet()) + { + oprot.writeI64(_iter554.getKey()); + oprot.writeBinary(_iter554.getValue()); + } + oprot.writeMapEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldBegin(IS_SUPPORTED_FIELD_DESC); + oprot.writeBool(struct.isSupported); + oprot.writeFieldEnd(); + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class GetFileMetadataResultTupleSchemeFactory implements SchemeFactory { + public GetFileMetadataResultTupleScheme getScheme() { + return new GetFileMetadataResultTupleScheme(); + } + } + + private static class GetFileMetadataResultTupleScheme extends TupleScheme<GetFileMetadataResult> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataResult struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + { + oprot.writeI32(struct.metadata.size()); + for (Map.Entry<Long, ByteBuffer> _iter555 : struct.metadata.entrySet()) + { + oprot.writeI64(_iter555.getKey()); + oprot.writeBinary(_iter555.getValue()); + } + } + oprot.writeBool(struct.isSupported); + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataResult struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + { + org.apache.thrift.protocol.TMap _map556 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.metadata = new HashMap<Long,ByteBuffer>(2*_map556.size); + long _key557; + ByteBuffer _val558; + for (int _i559 = 0; _i559 < _map556.size; ++_i559) + { + _key557 = iprot.readI64(); + _val558 = iprot.readBinary(); + struct.metadata.put(_key557, _val558); + } + } + struct.setMetadataIsSet(true); + struct.isSupported = iprot.readBool(); + struct.setIsSupportedIsSet(true); + } + } + +} + http://git-wip-us.apache.org/repos/asf/hive/blob/129bed52/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java index 8d2b62e..ad1af91 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-17") public class GetOpenTxnsInfoResponse implements org.apache.thrift.TBase<GetOpenTxnsInfoResponse, GetOpenTxnsInfoResponse._Fields>, java.io.Serializable, Cloneable, Comparable<GetOpenTxnsInfoResponse> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetOpenTxnsInfoResponse"); http://git-wip-us.apache.org/repos/asf/hive/blob/129bed52/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java index 3d70d93..fb6d841 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-17") public class GetOpenTxnsResponse implements org.apache.thrift.TBase<GetOpenTxnsResponse, GetOpenTxnsResponse._Fields>, java.io.Serializable, Cloneable, Comparable<GetOpenTxnsResponse> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetOpenTxnsResponse"); http://git-wip-us.apache.org/repos/asf/hive/blob/129bed52/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleRequest.java index 1d34a40..6111cb9 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleRequest.java @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-17") public class GetPrincipalsInRoleRequest implements org.apache.thrift.TBase<GetPrincipalsInRoleRequest, GetPrincipalsInRoleRequest._Fields>, java.io.Serializable, Cloneable, Comparable<GetPrincipalsInRoleRequest> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetPrincipalsInRoleRequest"); http://git-wip-us.apache.org/repos/asf/hive/blob/129bed52/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleResponse.java index 3db7c94..abe22af 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleResponse.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleResponse.java @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-17") public class GetPrincipalsInRoleResponse implements org.apache.thrift.TBase<GetPrincipalsInRoleResponse, GetPrincipalsInRoleResponse._Fields>, java.io.Serializable, Cloneable, Comparable<GetPrincipalsInRoleResponse> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetPrincipalsInRoleResponse"); http://git-wip-us.apache.org/repos/asf/hive/blob/129bed52/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalRequest.java index fb9eb88..42154b3 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalRequest.java @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-17") public class GetRoleGrantsForPrincipalRequest implements org.apache.thrift.TBase<GetRoleGrantsForPrincipalRequest, GetRoleGrantsForPrincipalRequest._Fields>, java.io.Serializable, Cloneable, Comparable<GetRoleGrantsForPrincipalRequest> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetRoleGrantsForPrincipalRequest"); http://git-wip-us.apache.org/repos/asf/hive/blob/129bed52/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalResponse.java index 42dfa01..2df6f63 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalResponse.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalResponse.java @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-17") public class GetRoleGrantsForPrincipalResponse implements org.apache.thrift.TBase<GetRoleGrantsForPrincipalResponse, GetRoleGrantsForPrincipalResponse._Fields>, java.io.Serializable, Cloneable, Comparable<GetRoleGrantsForPrincipalResponse> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetRoleGrantsForPrincipalResponse"); http://git-wip-us.apache.org/repos/asf/hive/blob/129bed52/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GrantRevokePrivilegeRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GrantRevokePrivilegeRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GrantRevokePrivilegeRequest.java index 8a042f7..10282e7 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GrantRevokePrivilegeRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GrantRevokePrivilegeRequest.java @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-17") public class GrantRevokePrivilegeRequest implements org.apache.thrift.TBase<GrantRevokePrivilegeRequest, GrantRevokePrivilegeRequest._Fields>, java.io.Serializable, Cloneable, Comparable<GrantRevokePrivilegeRequest> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GrantRevokePrivilegeRequest"); http://git-wip-us.apache.org/repos/asf/hive/blob/129bed52/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GrantRevokePrivilegeResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GrantRevokePrivilegeResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GrantRevokePrivilegeResponse.java index 113a07f..6a123e9 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GrantRevokePrivilegeResponse.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GrantRevokePrivilegeResponse.java @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-17") public class GrantRevokePrivilegeResponse implements org.apache.thrift.TBase<GrantRevokePrivilegeResponse, GrantRevokePrivilegeResponse._Fields>, java.io.Serializable, Cloneable, Comparable<GrantRevokePrivilegeResponse> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GrantRevokePrivilegeResponse");