http://git-wip-us.apache.org/repos/asf/hive/blob/20eb7b51/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnRequest.java new file mode 100644 index 0000000..3530f2b --- /dev/null +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnRequest.java @@ -0,0 +1,497 @@ +/** + * Autogenerated by Thrift Compiler (0.9.3) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.hadoop.hive.metastore.api; + +import org.apache.thrift.scheme.IScheme; +import org.apache.thrift.scheme.SchemeFactory; +import org.apache.thrift.scheme.StandardScheme; + +import org.apache.thrift.scheme.TupleScheme; +import org.apache.thrift.protocol.TTupleProtocol; +import org.apache.thrift.protocol.TProtocolException; +import org.apache.thrift.EncodingUtils; +import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +import javax.annotation.Generated; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)") +@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class AbortTxnRequest implements org.apache.thrift.TBase<AbortTxnRequest, AbortTxnRequest._Fields>, java.io.Serializable, Cloneable, Comparable<AbortTxnRequest> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AbortTxnRequest"); + + private static final org.apache.thrift.protocol.TField TXNID_FIELD_DESC = new org.apache.thrift.protocol.TField("txnid", org.apache.thrift.protocol.TType.I64, (short)1); + private static final org.apache.thrift.protocol.TField REPL_POLICY_FIELD_DESC = new org.apache.thrift.protocol.TField("replPolicy", 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 AbortTxnRequestStandardSchemeFactory()); + schemes.put(TupleScheme.class, new AbortTxnRequestTupleSchemeFactory()); + } + + private long txnid; // required + private String replPolicy; // optional + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { + TXNID((short)1, "txnid"), + REPL_POLICY((short)2, "replPolicy"); + + 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: // TXNID + return TXNID; + case 2: // REPL_POLICY + return REPL_POLICY; + 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 __TXNID_ISSET_ID = 0; + private byte __isset_bitfield = 0; + private static final _Fields optionals[] = {_Fields.REPL_POLICY}; + 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.TXNID, new org.apache.thrift.meta_data.FieldMetaData("txnid", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + tmpMap.put(_Fields.REPL_POLICY, new org.apache.thrift.meta_data.FieldMetaData("replPolicy", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AbortTxnRequest.class, metaDataMap); + } + + public AbortTxnRequest() { + } + + public AbortTxnRequest( + long txnid) + { + this(); + this.txnid = txnid; + setTxnidIsSet(true); + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public AbortTxnRequest(AbortTxnRequest other) { + __isset_bitfield = other.__isset_bitfield; + this.txnid = other.txnid; + if (other.isSetReplPolicy()) { + this.replPolicy = other.replPolicy; + } + } + + public AbortTxnRequest deepCopy() { + return new AbortTxnRequest(this); + } + + @Override + public void clear() { + setTxnidIsSet(false); + this.txnid = 0; + this.replPolicy = null; + } + + public long getTxnid() { + return this.txnid; + } + + public void setTxnid(long txnid) { + this.txnid = txnid; + setTxnidIsSet(true); + } + + public void unsetTxnid() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TXNID_ISSET_ID); + } + + /** Returns true if field txnid is set (has been assigned a value) and false otherwise */ + public boolean isSetTxnid() { + return EncodingUtils.testBit(__isset_bitfield, __TXNID_ISSET_ID); + } + + public void setTxnidIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TXNID_ISSET_ID, value); + } + + public String getReplPolicy() { + return this.replPolicy; + } + + public void setReplPolicy(String replPolicy) { + this.replPolicy = replPolicy; + } + + public void unsetReplPolicy() { + this.replPolicy = null; + } + + /** Returns true if field replPolicy is set (has been assigned a value) and false otherwise */ + public boolean isSetReplPolicy() { + return this.replPolicy != null; + } + + public void setReplPolicyIsSet(boolean value) { + if (!value) { + this.replPolicy = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case TXNID: + if (value == null) { + unsetTxnid(); + } else { + setTxnid((Long)value); + } + break; + + case REPL_POLICY: + if (value == null) { + unsetReplPolicy(); + } else { + setReplPolicy((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case TXNID: + return getTxnid(); + + case REPL_POLICY: + return getReplPolicy(); + + } + 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 TXNID: + return isSetTxnid(); + case REPL_POLICY: + return isSetReplPolicy(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof AbortTxnRequest) + return this.equals((AbortTxnRequest)that); + return false; + } + + public boolean equals(AbortTxnRequest that) { + if (that == null) + return false; + + boolean this_present_txnid = true; + boolean that_present_txnid = true; + if (this_present_txnid || that_present_txnid) { + if (!(this_present_txnid && that_present_txnid)) + return false; + if (this.txnid != that.txnid) + return false; + } + + boolean this_present_replPolicy = true && this.isSetReplPolicy(); + boolean that_present_replPolicy = true && that.isSetReplPolicy(); + if (this_present_replPolicy || that_present_replPolicy) { + if (!(this_present_replPolicy && that_present_replPolicy)) + return false; + if (!this.replPolicy.equals(that.replPolicy)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_txnid = true; + list.add(present_txnid); + if (present_txnid) + list.add(txnid); + + boolean present_replPolicy = true && (isSetReplPolicy()); + list.add(present_replPolicy); + if (present_replPolicy) + list.add(replPolicy); + + return list.hashCode(); + } + + @Override + public int compareTo(AbortTxnRequest other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetTxnid()).compareTo(other.isSetTxnid()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTxnid()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.txnid, other.txnid); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetReplPolicy()).compareTo(other.isSetReplPolicy()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetReplPolicy()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.replPolicy, other.replPolicy); + 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("AbortTxnRequest("); + boolean first = true; + + sb.append("txnid:"); + sb.append(this.txnid); + first = false; + if (isSetReplPolicy()) { + if (!first) sb.append(", "); + sb.append("replPolicy:"); + if (this.replPolicy == null) { + sb.append("null"); + } else { + sb.append(this.replPolicy); + } + first = false; + } + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!isSetTxnid()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'txnid' 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 AbortTxnRequestStandardSchemeFactory implements SchemeFactory { + public AbortTxnRequestStandardScheme getScheme() { + return new AbortTxnRequestStandardScheme(); + } + } + + private static class AbortTxnRequestStandardScheme extends StandardScheme<AbortTxnRequest> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, AbortTxnRequest 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: // TXNID + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.txnid = iprot.readI64(); + struct.setTxnidIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // REPL_POLICY + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.replPolicy = iprot.readString(); + struct.setReplPolicyIsSet(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, AbortTxnRequest struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + oprot.writeFieldBegin(TXNID_FIELD_DESC); + oprot.writeI64(struct.txnid); + oprot.writeFieldEnd(); + if (struct.replPolicy != null) { + if (struct.isSetReplPolicy()) { + oprot.writeFieldBegin(REPL_POLICY_FIELD_DESC); + oprot.writeString(struct.replPolicy); + oprot.writeFieldEnd(); + } + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class AbortTxnRequestTupleSchemeFactory implements SchemeFactory { + public AbortTxnRequestTupleScheme getScheme() { + return new AbortTxnRequestTupleScheme(); + } + } + + private static class AbortTxnRequestTupleScheme extends TupleScheme<AbortTxnRequest> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, AbortTxnRequest struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + oprot.writeI64(struct.txnid); + BitSet optionals = new BitSet(); + if (struct.isSetReplPolicy()) { + optionals.set(0); + } + oprot.writeBitSet(optionals, 1); + if (struct.isSetReplPolicy()) { + oprot.writeString(struct.replPolicy); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, AbortTxnRequest struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + struct.txnid = iprot.readI64(); + struct.setTxnidIsSet(true); + BitSet incoming = iprot.readBitSet(1); + if (incoming.get(0)) { + struct.replPolicy = iprot.readString(); + struct.setReplPolicyIsSet(true); + } + } + } + +} +
http://git-wip-us.apache.org/repos/asf/hive/blob/20eb7b51/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java new file mode 100644 index 0000000..3ee3370 --- /dev/null +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java @@ -0,0 +1,438 @@ +/** + * Autogenerated by Thrift Compiler (0.9.3) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.hadoop.hive.metastore.api; + +import org.apache.thrift.scheme.IScheme; +import org.apache.thrift.scheme.SchemeFactory; +import org.apache.thrift.scheme.StandardScheme; + +import org.apache.thrift.scheme.TupleScheme; +import org.apache.thrift.protocol.TTupleProtocol; +import org.apache.thrift.protocol.TProtocolException; +import org.apache.thrift.EncodingUtils; +import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +import javax.annotation.Generated; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)") +@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class AbortTxnsRequest implements org.apache.thrift.TBase<AbortTxnsRequest, AbortTxnsRequest._Fields>, java.io.Serializable, Cloneable, Comparable<AbortTxnsRequest> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AbortTxnsRequest"); + + private static final org.apache.thrift.protocol.TField TXN_IDS_FIELD_DESC = new org.apache.thrift.protocol.TField("txn_ids", org.apache.thrift.protocol.TType.LIST, (short)1); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new AbortTxnsRequestStandardSchemeFactory()); + schemes.put(TupleScheme.class, new AbortTxnsRequestTupleSchemeFactory()); + } + + private List<Long> txn_ids; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { + TXN_IDS((short)1, "txn_ids"); + + private static final Map<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: // TXN_IDS + return TXN_IDS; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.TXN_IDS, new org.apache.thrift.meta_data.FieldMetaData("txn_ids", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AbortTxnsRequest.class, metaDataMap); + } + + public AbortTxnsRequest() { + } + + public AbortTxnsRequest( + List<Long> txn_ids) + { + this(); + this.txn_ids = txn_ids; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public AbortTxnsRequest(AbortTxnsRequest other) { + if (other.isSetTxn_ids()) { + List<Long> __this__txn_ids = new ArrayList<Long>(other.txn_ids); + this.txn_ids = __this__txn_ids; + } + } + + public AbortTxnsRequest deepCopy() { + return new AbortTxnsRequest(this); + } + + @Override + public void clear() { + this.txn_ids = null; + } + + public int getTxn_idsSize() { + return (this.txn_ids == null) ? 0 : this.txn_ids.size(); + } + + public java.util.Iterator<Long> getTxn_idsIterator() { + return (this.txn_ids == null) ? null : this.txn_ids.iterator(); + } + + public void addToTxn_ids(long elem) { + if (this.txn_ids == null) { + this.txn_ids = new ArrayList<Long>(); + } + this.txn_ids.add(elem); + } + + public List<Long> getTxn_ids() { + return this.txn_ids; + } + + public void setTxn_ids(List<Long> txn_ids) { + this.txn_ids = txn_ids; + } + + public void unsetTxn_ids() { + this.txn_ids = null; + } + + /** Returns true if field txn_ids is set (has been assigned a value) and false otherwise */ + public boolean isSetTxn_ids() { + return this.txn_ids != null; + } + + public void setTxn_idsIsSet(boolean value) { + if (!value) { + this.txn_ids = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case TXN_IDS: + if (value == null) { + unsetTxn_ids(); + } else { + setTxn_ids((List<Long>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case TXN_IDS: + return getTxn_ids(); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case TXN_IDS: + return isSetTxn_ids(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof AbortTxnsRequest) + return this.equals((AbortTxnsRequest)that); + return false; + } + + public boolean equals(AbortTxnsRequest that) { + if (that == null) + return false; + + boolean this_present_txn_ids = true && this.isSetTxn_ids(); + boolean that_present_txn_ids = true && that.isSetTxn_ids(); + if (this_present_txn_ids || that_present_txn_ids) { + if (!(this_present_txn_ids && that_present_txn_ids)) + return false; + if (!this.txn_ids.equals(that.txn_ids)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_txn_ids = true && (isSetTxn_ids()); + list.add(present_txn_ids); + if (present_txn_ids) + list.add(txn_ids); + + return list.hashCode(); + } + + @Override + public int compareTo(AbortTxnsRequest other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetTxn_ids()).compareTo(other.isSetTxn_ids()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTxn_ids()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.txn_ids, other.txn_ids); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("AbortTxnsRequest("); + boolean first = true; + + sb.append("txn_ids:"); + if (this.txn_ids == null) { + sb.append("null"); + } else { + sb.append(this.txn_ids); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!isSetTxn_ids()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'txn_ids' is unset! Struct:" + toString()); + } + + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class AbortTxnsRequestStandardSchemeFactory implements SchemeFactory { + public AbortTxnsRequestStandardScheme getScheme() { + return new AbortTxnsRequestStandardScheme(); + } + } + + private static class AbortTxnsRequestStandardScheme extends StandardScheme<AbortTxnsRequest> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, AbortTxnsRequest struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // TXN_IDS + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list586 = iprot.readListBegin(); + struct.txn_ids = new ArrayList<Long>(_list586.size); + long _elem587; + for (int _i588 = 0; _i588 < _list586.size; ++_i588) + { + _elem587 = iprot.readI64(); + struct.txn_ids.add(_elem587); + } + iprot.readListEnd(); + } + struct.setTxn_idsIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, AbortTxnsRequest struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.txn_ids != null) { + oprot.writeFieldBegin(TXN_IDS_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.txn_ids.size())); + for (long _iter589 : struct.txn_ids) + { + oprot.writeI64(_iter589); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class AbortTxnsRequestTupleSchemeFactory implements SchemeFactory { + public AbortTxnsRequestTupleScheme getScheme() { + return new AbortTxnsRequestTupleScheme(); + } + } + + private static class AbortTxnsRequestTupleScheme extends TupleScheme<AbortTxnsRequest> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, AbortTxnsRequest struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + { + oprot.writeI32(struct.txn_ids.size()); + for (long _iter590 : struct.txn_ids) + { + oprot.writeI64(_iter590); + } + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, AbortTxnsRequest struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + { + org.apache.thrift.protocol.TList _list591 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.txn_ids = new ArrayList<Long>(_list591.size); + long _elem592; + for (int _i593 = 0; _i593 < _list591.size; ++_i593) + { + _elem592 = iprot.readI64(); + struct.txn_ids.add(_elem592); + } + } + struct.setTxn_idsIsSet(true); + } + } + +} + http://git-wip-us.apache.org/repos/asf/hive/blob/20eb7b51/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddCheckConstraintRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddCheckConstraintRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddCheckConstraintRequest.java new file mode 100644 index 0000000..02d552d --- /dev/null +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddCheckConstraintRequest.java @@ -0,0 +1,443 @@ +/** + * Autogenerated by Thrift Compiler (0.9.3) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.hadoop.hive.metastore.api; + +import org.apache.thrift.scheme.IScheme; +import org.apache.thrift.scheme.SchemeFactory; +import org.apache.thrift.scheme.StandardScheme; + +import org.apache.thrift.scheme.TupleScheme; +import org.apache.thrift.protocol.TTupleProtocol; +import org.apache.thrift.protocol.TProtocolException; +import org.apache.thrift.EncodingUtils; +import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +import javax.annotation.Generated; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)") +@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class AddCheckConstraintRequest implements org.apache.thrift.TBase<AddCheckConstraintRequest, AddCheckConstraintRequest._Fields>, java.io.Serializable, Cloneable, Comparable<AddCheckConstraintRequest> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AddCheckConstraintRequest"); + + private static final org.apache.thrift.protocol.TField CHECK_CONSTRAINT_COLS_FIELD_DESC = new org.apache.thrift.protocol.TField("checkConstraintCols", 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 AddCheckConstraintRequestStandardSchemeFactory()); + schemes.put(TupleScheme.class, new AddCheckConstraintRequestTupleSchemeFactory()); + } + + private List<SQLCheckConstraint> checkConstraintCols; // 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 { + CHECK_CONSTRAINT_COLS((short)1, "checkConstraintCols"); + + 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: // CHECK_CONSTRAINT_COLS + return CHECK_CONSTRAINT_COLS; + 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.CHECK_CONSTRAINT_COLS, new org.apache.thrift.meta_data.FieldMetaData("checkConstraintCols", 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, SQLCheckConstraint.class)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AddCheckConstraintRequest.class, metaDataMap); + } + + public AddCheckConstraintRequest() { + } + + public AddCheckConstraintRequest( + List<SQLCheckConstraint> checkConstraintCols) + { + this(); + this.checkConstraintCols = checkConstraintCols; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public AddCheckConstraintRequest(AddCheckConstraintRequest other) { + if (other.isSetCheckConstraintCols()) { + List<SQLCheckConstraint> __this__checkConstraintCols = new ArrayList<SQLCheckConstraint>(other.checkConstraintCols.size()); + for (SQLCheckConstraint other_element : other.checkConstraintCols) { + __this__checkConstraintCols.add(new SQLCheckConstraint(other_element)); + } + this.checkConstraintCols = __this__checkConstraintCols; + } + } + + public AddCheckConstraintRequest deepCopy() { + return new AddCheckConstraintRequest(this); + } + + @Override + public void clear() { + this.checkConstraintCols = null; + } + + public int getCheckConstraintColsSize() { + return (this.checkConstraintCols == null) ? 0 : this.checkConstraintCols.size(); + } + + public java.util.Iterator<SQLCheckConstraint> getCheckConstraintColsIterator() { + return (this.checkConstraintCols == null) ? null : this.checkConstraintCols.iterator(); + } + + public void addToCheckConstraintCols(SQLCheckConstraint elem) { + if (this.checkConstraintCols == null) { + this.checkConstraintCols = new ArrayList<SQLCheckConstraint>(); + } + this.checkConstraintCols.add(elem); + } + + public List<SQLCheckConstraint> getCheckConstraintCols() { + return this.checkConstraintCols; + } + + public void setCheckConstraintCols(List<SQLCheckConstraint> checkConstraintCols) { + this.checkConstraintCols = checkConstraintCols; + } + + public void unsetCheckConstraintCols() { + this.checkConstraintCols = null; + } + + /** Returns true if field checkConstraintCols is set (has been assigned a value) and false otherwise */ + public boolean isSetCheckConstraintCols() { + return this.checkConstraintCols != null; + } + + public void setCheckConstraintColsIsSet(boolean value) { + if (!value) { + this.checkConstraintCols = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case CHECK_CONSTRAINT_COLS: + if (value == null) { + unsetCheckConstraintCols(); + } else { + setCheckConstraintCols((List<SQLCheckConstraint>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case CHECK_CONSTRAINT_COLS: + return getCheckConstraintCols(); + + } + 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 CHECK_CONSTRAINT_COLS: + return isSetCheckConstraintCols(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof AddCheckConstraintRequest) + return this.equals((AddCheckConstraintRequest)that); + return false; + } + + public boolean equals(AddCheckConstraintRequest that) { + if (that == null) + return false; + + boolean this_present_checkConstraintCols = true && this.isSetCheckConstraintCols(); + boolean that_present_checkConstraintCols = true && that.isSetCheckConstraintCols(); + if (this_present_checkConstraintCols || that_present_checkConstraintCols) { + if (!(this_present_checkConstraintCols && that_present_checkConstraintCols)) + return false; + if (!this.checkConstraintCols.equals(that.checkConstraintCols)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_checkConstraintCols = true && (isSetCheckConstraintCols()); + list.add(present_checkConstraintCols); + if (present_checkConstraintCols) + list.add(checkConstraintCols); + + return list.hashCode(); + } + + @Override + public int compareTo(AddCheckConstraintRequest other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetCheckConstraintCols()).compareTo(other.isSetCheckConstraintCols()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetCheckConstraintCols()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.checkConstraintCols, other.checkConstraintCols); + 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("AddCheckConstraintRequest("); + boolean first = true; + + sb.append("checkConstraintCols:"); + if (this.checkConstraintCols == null) { + sb.append("null"); + } else { + sb.append(this.checkConstraintCols); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!isSetCheckConstraintCols()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'checkConstraintCols' 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 AddCheckConstraintRequestStandardSchemeFactory implements SchemeFactory { + public AddCheckConstraintRequestStandardScheme getScheme() { + return new AddCheckConstraintRequestStandardScheme(); + } + } + + private static class AddCheckConstraintRequestStandardScheme extends StandardScheme<AddCheckConstraintRequest> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, AddCheckConstraintRequest 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: // CHECK_CONSTRAINT_COLS + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list408 = iprot.readListBegin(); + struct.checkConstraintCols = new ArrayList<SQLCheckConstraint>(_list408.size); + SQLCheckConstraint _elem409; + for (int _i410 = 0; _i410 < _list408.size; ++_i410) + { + _elem409 = new SQLCheckConstraint(); + _elem409.read(iprot); + struct.checkConstraintCols.add(_elem409); + } + iprot.readListEnd(); + } + struct.setCheckConstraintColsIsSet(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, AddCheckConstraintRequest struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.checkConstraintCols != null) { + oprot.writeFieldBegin(CHECK_CONSTRAINT_COLS_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.checkConstraintCols.size())); + for (SQLCheckConstraint _iter411 : struct.checkConstraintCols) + { + _iter411.write(oprot); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class AddCheckConstraintRequestTupleSchemeFactory implements SchemeFactory { + public AddCheckConstraintRequestTupleScheme getScheme() { + return new AddCheckConstraintRequestTupleScheme(); + } + } + + private static class AddCheckConstraintRequestTupleScheme extends TupleScheme<AddCheckConstraintRequest> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, AddCheckConstraintRequest struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + { + oprot.writeI32(struct.checkConstraintCols.size()); + for (SQLCheckConstraint _iter412 : struct.checkConstraintCols) + { + _iter412.write(oprot); + } + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, AddCheckConstraintRequest struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + { + org.apache.thrift.protocol.TList _list413 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.checkConstraintCols = new ArrayList<SQLCheckConstraint>(_list413.size); + SQLCheckConstraint _elem414; + for (int _i415 = 0; _i415 < _list413.size; ++_i415) + { + _elem414 = new SQLCheckConstraint(); + _elem414.read(iprot); + struct.checkConstraintCols.add(_elem414); + } + } + struct.setCheckConstraintColsIsSet(true); + } + } + +} + http://git-wip-us.apache.org/repos/asf/hive/blob/20eb7b51/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDefaultConstraintRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDefaultConstraintRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDefaultConstraintRequest.java new file mode 100644 index 0000000..6acc6f8 --- /dev/null +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDefaultConstraintRequest.java @@ -0,0 +1,443 @@ +/** + * Autogenerated by Thrift Compiler (0.9.3) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.hadoop.hive.metastore.api; + +import org.apache.thrift.scheme.IScheme; +import org.apache.thrift.scheme.SchemeFactory; +import org.apache.thrift.scheme.StandardScheme; + +import org.apache.thrift.scheme.TupleScheme; +import org.apache.thrift.protocol.TTupleProtocol; +import org.apache.thrift.protocol.TProtocolException; +import org.apache.thrift.EncodingUtils; +import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +import javax.annotation.Generated; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)") +@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class AddDefaultConstraintRequest implements org.apache.thrift.TBase<AddDefaultConstraintRequest, AddDefaultConstraintRequest._Fields>, java.io.Serializable, Cloneable, Comparable<AddDefaultConstraintRequest> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AddDefaultConstraintRequest"); + + private static final org.apache.thrift.protocol.TField DEFAULT_CONSTRAINT_COLS_FIELD_DESC = new org.apache.thrift.protocol.TField("defaultConstraintCols", 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 AddDefaultConstraintRequestStandardSchemeFactory()); + schemes.put(TupleScheme.class, new AddDefaultConstraintRequestTupleSchemeFactory()); + } + + private List<SQLDefaultConstraint> defaultConstraintCols; // 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 { + DEFAULT_CONSTRAINT_COLS((short)1, "defaultConstraintCols"); + + 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: // DEFAULT_CONSTRAINT_COLS + return DEFAULT_CONSTRAINT_COLS; + 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.DEFAULT_CONSTRAINT_COLS, new org.apache.thrift.meta_data.FieldMetaData("defaultConstraintCols", 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, SQLDefaultConstraint.class)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AddDefaultConstraintRequest.class, metaDataMap); + } + + public AddDefaultConstraintRequest() { + } + + public AddDefaultConstraintRequest( + List<SQLDefaultConstraint> defaultConstraintCols) + { + this(); + this.defaultConstraintCols = defaultConstraintCols; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public AddDefaultConstraintRequest(AddDefaultConstraintRequest other) { + if (other.isSetDefaultConstraintCols()) { + List<SQLDefaultConstraint> __this__defaultConstraintCols = new ArrayList<SQLDefaultConstraint>(other.defaultConstraintCols.size()); + for (SQLDefaultConstraint other_element : other.defaultConstraintCols) { + __this__defaultConstraintCols.add(new SQLDefaultConstraint(other_element)); + } + this.defaultConstraintCols = __this__defaultConstraintCols; + } + } + + public AddDefaultConstraintRequest deepCopy() { + return new AddDefaultConstraintRequest(this); + } + + @Override + public void clear() { + this.defaultConstraintCols = null; + } + + public int getDefaultConstraintColsSize() { + return (this.defaultConstraintCols == null) ? 0 : this.defaultConstraintCols.size(); + } + + public java.util.Iterator<SQLDefaultConstraint> getDefaultConstraintColsIterator() { + return (this.defaultConstraintCols == null) ? null : this.defaultConstraintCols.iterator(); + } + + public void addToDefaultConstraintCols(SQLDefaultConstraint elem) { + if (this.defaultConstraintCols == null) { + this.defaultConstraintCols = new ArrayList<SQLDefaultConstraint>(); + } + this.defaultConstraintCols.add(elem); + } + + public List<SQLDefaultConstraint> getDefaultConstraintCols() { + return this.defaultConstraintCols; + } + + public void setDefaultConstraintCols(List<SQLDefaultConstraint> defaultConstraintCols) { + this.defaultConstraintCols = defaultConstraintCols; + } + + public void unsetDefaultConstraintCols() { + this.defaultConstraintCols = null; + } + + /** Returns true if field defaultConstraintCols is set (has been assigned a value) and false otherwise */ + public boolean isSetDefaultConstraintCols() { + return this.defaultConstraintCols != null; + } + + public void setDefaultConstraintColsIsSet(boolean value) { + if (!value) { + this.defaultConstraintCols = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case DEFAULT_CONSTRAINT_COLS: + if (value == null) { + unsetDefaultConstraintCols(); + } else { + setDefaultConstraintCols((List<SQLDefaultConstraint>)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case DEFAULT_CONSTRAINT_COLS: + return getDefaultConstraintCols(); + + } + 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 DEFAULT_CONSTRAINT_COLS: + return isSetDefaultConstraintCols(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof AddDefaultConstraintRequest) + return this.equals((AddDefaultConstraintRequest)that); + return false; + } + + public boolean equals(AddDefaultConstraintRequest that) { + if (that == null) + return false; + + boolean this_present_defaultConstraintCols = true && this.isSetDefaultConstraintCols(); + boolean that_present_defaultConstraintCols = true && that.isSetDefaultConstraintCols(); + if (this_present_defaultConstraintCols || that_present_defaultConstraintCols) { + if (!(this_present_defaultConstraintCols && that_present_defaultConstraintCols)) + return false; + if (!this.defaultConstraintCols.equals(that.defaultConstraintCols)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_defaultConstraintCols = true && (isSetDefaultConstraintCols()); + list.add(present_defaultConstraintCols); + if (present_defaultConstraintCols) + list.add(defaultConstraintCols); + + return list.hashCode(); + } + + @Override + public int compareTo(AddDefaultConstraintRequest other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetDefaultConstraintCols()).compareTo(other.isSetDefaultConstraintCols()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetDefaultConstraintCols()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.defaultConstraintCols, other.defaultConstraintCols); + 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("AddDefaultConstraintRequest("); + boolean first = true; + + sb.append("defaultConstraintCols:"); + if (this.defaultConstraintCols == null) { + sb.append("null"); + } else { + sb.append(this.defaultConstraintCols); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!isSetDefaultConstraintCols()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'defaultConstraintCols' 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 AddDefaultConstraintRequestStandardSchemeFactory implements SchemeFactory { + public AddDefaultConstraintRequestStandardScheme getScheme() { + return new AddDefaultConstraintRequestStandardScheme(); + } + } + + private static class AddDefaultConstraintRequestStandardScheme extends StandardScheme<AddDefaultConstraintRequest> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, AddDefaultConstraintRequest 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: // DEFAULT_CONSTRAINT_COLS + if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { + { + org.apache.thrift.protocol.TList _list400 = iprot.readListBegin(); + struct.defaultConstraintCols = new ArrayList<SQLDefaultConstraint>(_list400.size); + SQLDefaultConstraint _elem401; + for (int _i402 = 0; _i402 < _list400.size; ++_i402) + { + _elem401 = new SQLDefaultConstraint(); + _elem401.read(iprot); + struct.defaultConstraintCols.add(_elem401); + } + iprot.readListEnd(); + } + struct.setDefaultConstraintColsIsSet(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, AddDefaultConstraintRequest struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.defaultConstraintCols != null) { + oprot.writeFieldBegin(DEFAULT_CONSTRAINT_COLS_FIELD_DESC); + { + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.defaultConstraintCols.size())); + for (SQLDefaultConstraint _iter403 : struct.defaultConstraintCols) + { + _iter403.write(oprot); + } + oprot.writeListEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class AddDefaultConstraintRequestTupleSchemeFactory implements SchemeFactory { + public AddDefaultConstraintRequestTupleScheme getScheme() { + return new AddDefaultConstraintRequestTupleScheme(); + } + } + + private static class AddDefaultConstraintRequestTupleScheme extends TupleScheme<AddDefaultConstraintRequest> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, AddDefaultConstraintRequest struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + { + oprot.writeI32(struct.defaultConstraintCols.size()); + for (SQLDefaultConstraint _iter404 : struct.defaultConstraintCols) + { + _iter404.write(oprot); + } + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, AddDefaultConstraintRequest struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + { + org.apache.thrift.protocol.TList _list405 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.defaultConstraintCols = new ArrayList<SQLDefaultConstraint>(_list405.size); + SQLDefaultConstraint _elem406; + for (int _i407 = 0; _i407 < _list405.size; ++_i407) + { + _elem406 = new SQLDefaultConstraint(); + _elem406.read(iprot); + struct.defaultConstraintCols.add(_elem406); + } + } + struct.setDefaultConstraintColsIsSet(true); + } + } + +} +
