http://git-wip-us.apache.org/repos/asf/hive/blob/7b24ff74/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h b/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h index 70fe2c3..6838133 100644 --- a/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h +++ b/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h @@ -346,6 +346,8 @@ class HeartbeatTxnRangeResponse; class CompactionRequest; +class CompactionResponse; + class ShowCompactRequest; class ShowCompactResponseElement; @@ -6001,6 +6003,56 @@ inline std::ostream& operator<<(std::ostream& out, const CompactionRequest& obj) } +class CompactionResponse { + public: + + CompactionResponse(const CompactionResponse&); + CompactionResponse& operator=(const CompactionResponse&); + CompactionResponse() : id(0), state(), accepted(0) { + } + + virtual ~CompactionResponse() throw(); + int64_t id; + std::string state; + bool accepted; + + void __set_id(const int64_t val); + + void __set_state(const std::string& val); + + void __set_accepted(const bool val); + + bool operator == (const CompactionResponse & rhs) const + { + if (!(id == rhs.id)) + return false; + if (!(state == rhs.state)) + return false; + if (!(accepted == rhs.accepted)) + return false; + return true; + } + bool operator != (const CompactionResponse &rhs) const { + return !(*this == rhs); + } + + bool operator < (const CompactionResponse & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + + virtual void printTo(std::ostream& out) const; +}; + +void swap(CompactionResponse &a, CompactionResponse &b); + +inline std::ostream& operator<<(std::ostream& out, const CompactionResponse& obj) +{ + obj.printTo(out); + return out; +} + + class ShowCompactRequest { public: @@ -6036,7 +6088,7 @@ inline std::ostream& operator<<(std::ostream& out, const ShowCompactRequest& obj } typedef struct _ShowCompactResponseElement__isset { - _ShowCompactResponseElement__isset() : partitionname(false), workerid(false), start(false), runAs(false), hightestTxnId(false), metaInfo(false), endTime(false), hadoopJobId(true) {} + _ShowCompactResponseElement__isset() : partitionname(false), workerid(false), start(false), runAs(false), hightestTxnId(false), metaInfo(false), endTime(false), hadoopJobId(true), id(false) {} bool partitionname :1; bool workerid :1; bool start :1; @@ -6045,6 +6097,7 @@ typedef struct _ShowCompactResponseElement__isset { bool metaInfo :1; bool endTime :1; bool hadoopJobId :1; + bool id :1; } _ShowCompactResponseElement__isset; class ShowCompactResponseElement { @@ -6052,7 +6105,7 @@ class ShowCompactResponseElement { ShowCompactResponseElement(const ShowCompactResponseElement&); ShowCompactResponseElement& operator=(const ShowCompactResponseElement&); - ShowCompactResponseElement() : dbname(), tablename(), partitionname(), type((CompactionType::type)0), state(), workerid(), start(0), runAs(), hightestTxnId(0), metaInfo(), endTime(0), hadoopJobId("None") { + ShowCompactResponseElement() : dbname(), tablename(), partitionname(), type((CompactionType::type)0), state(), workerid(), start(0), runAs(), hightestTxnId(0), metaInfo(), endTime(0), hadoopJobId("None"), id(0) { } virtual ~ShowCompactResponseElement() throw(); @@ -6068,6 +6121,7 @@ class ShowCompactResponseElement { std::string metaInfo; int64_t endTime; std::string hadoopJobId; + int64_t id; _ShowCompactResponseElement__isset __isset; @@ -6095,6 +6149,8 @@ class ShowCompactResponseElement { void __set_hadoopJobId(const std::string& val); + void __set_id(const int64_t val); + bool operator == (const ShowCompactResponseElement & rhs) const { if (!(dbname == rhs.dbname)) @@ -6137,6 +6193,10 @@ class ShowCompactResponseElement { return false; else if (__isset.hadoopJobId && !(hadoopJobId == rhs.hadoopJobId)) return false; + if (__isset.id != rhs.__isset.id) + return false; + else if (__isset.id && !(id == rhs.id)) + return false; return true; } bool operator != (const ShowCompactResponseElement &rhs) const {
http://git-wip-us.apache.org/repos/asf/hive/blob/7b24ff74/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionResponse.java new file mode 100644 index 0000000..157ff53 --- /dev/null +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionResponse.java @@ -0,0 +1,583 @@ +/** + * 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)") +public class CompactionResponse implements org.apache.thrift.TBase<CompactionResponse, CompactionResponse._Fields>, java.io.Serializable, Cloneable, Comparable<CompactionResponse> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("CompactionResponse"); + + private static final org.apache.thrift.protocol.TField ID_FIELD_DESC = new org.apache.thrift.protocol.TField("id", org.apache.thrift.protocol.TType.I64, (short)1); + private static final org.apache.thrift.protocol.TField STATE_FIELD_DESC = new org.apache.thrift.protocol.TField("state", org.apache.thrift.protocol.TType.STRING, (short)2); + private static final org.apache.thrift.protocol.TField ACCEPTED_FIELD_DESC = new org.apache.thrift.protocol.TField("accepted", org.apache.thrift.protocol.TType.BOOL, (short)3); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new CompactionResponseStandardSchemeFactory()); + schemes.put(TupleScheme.class, new CompactionResponseTupleSchemeFactory()); + } + + private long id; // required + private String state; // required + private boolean accepted; // 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 { + ID((short)1, "id"), + STATE((short)2, "state"), + ACCEPTED((short)3, "accepted"); + + 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: // ID + return ID; + case 2: // STATE + return STATE; + case 3: // ACCEPTED + return ACCEPTED; + 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 __ID_ISSET_ID = 0; + private static final int __ACCEPTED_ISSET_ID = 1; + 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.ID, new org.apache.thrift.meta_data.FieldMetaData("id", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); + tmpMap.put(_Fields.STATE, new org.apache.thrift.meta_data.FieldMetaData("state", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.ACCEPTED, new org.apache.thrift.meta_data.FieldMetaData("accepted", 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(CompactionResponse.class, metaDataMap); + } + + public CompactionResponse() { + } + + public CompactionResponse( + long id, + String state, + boolean accepted) + { + this(); + this.id = id; + setIdIsSet(true); + this.state = state; + this.accepted = accepted; + setAcceptedIsSet(true); + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public CompactionResponse(CompactionResponse other) { + __isset_bitfield = other.__isset_bitfield; + this.id = other.id; + if (other.isSetState()) { + this.state = other.state; + } + this.accepted = other.accepted; + } + + public CompactionResponse deepCopy() { + return new CompactionResponse(this); + } + + @Override + public void clear() { + setIdIsSet(false); + this.id = 0; + this.state = null; + setAcceptedIsSet(false); + this.accepted = false; + } + + public long getId() { + return this.id; + } + + public void setId(long id) { + this.id = id; + setIdIsSet(true); + } + + public void unsetId() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ID_ISSET_ID); + } + + /** Returns true if field id is set (has been assigned a value) and false otherwise */ + public boolean isSetId() { + return EncodingUtils.testBit(__isset_bitfield, __ID_ISSET_ID); + } + + public void setIdIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ID_ISSET_ID, value); + } + + public String getState() { + return this.state; + } + + public void setState(String state) { + this.state = state; + } + + public void unsetState() { + this.state = null; + } + + /** Returns true if field state is set (has been assigned a value) and false otherwise */ + public boolean isSetState() { + return this.state != null; + } + + public void setStateIsSet(boolean value) { + if (!value) { + this.state = null; + } + } + + public boolean isAccepted() { + return this.accepted; + } + + public void setAccepted(boolean accepted) { + this.accepted = accepted; + setAcceptedIsSet(true); + } + + public void unsetAccepted() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ACCEPTED_ISSET_ID); + } + + /** Returns true if field accepted is set (has been assigned a value) and false otherwise */ + public boolean isSetAccepted() { + return EncodingUtils.testBit(__isset_bitfield, __ACCEPTED_ISSET_ID); + } + + public void setAcceptedIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ACCEPTED_ISSET_ID, value); + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case ID: + if (value == null) { + unsetId(); + } else { + setId((Long)value); + } + break; + + case STATE: + if (value == null) { + unsetState(); + } else { + setState((String)value); + } + break; + + case ACCEPTED: + if (value == null) { + unsetAccepted(); + } else { + setAccepted((Boolean)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case ID: + return getId(); + + case STATE: + return getState(); + + case ACCEPTED: + return isAccepted(); + + } + 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 ID: + return isSetId(); + case STATE: + return isSetState(); + case ACCEPTED: + return isSetAccepted(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof CompactionResponse) + return this.equals((CompactionResponse)that); + return false; + } + + public boolean equals(CompactionResponse that) { + if (that == null) + return false; + + boolean this_present_id = true; + boolean that_present_id = true; + if (this_present_id || that_present_id) { + if (!(this_present_id && that_present_id)) + return false; + if (this.id != that.id) + return false; + } + + boolean this_present_state = true && this.isSetState(); + boolean that_present_state = true && that.isSetState(); + if (this_present_state || that_present_state) { + if (!(this_present_state && that_present_state)) + return false; + if (!this.state.equals(that.state)) + return false; + } + + boolean this_present_accepted = true; + boolean that_present_accepted = true; + if (this_present_accepted || that_present_accepted) { + if (!(this_present_accepted && that_present_accepted)) + return false; + if (this.accepted != that.accepted) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_id = true; + list.add(present_id); + if (present_id) + list.add(id); + + boolean present_state = true && (isSetState()); + list.add(present_state); + if (present_state) + list.add(state); + + boolean present_accepted = true; + list.add(present_accepted); + if (present_accepted) + list.add(accepted); + + return list.hashCode(); + } + + @Override + public int compareTo(CompactionResponse other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetId()).compareTo(other.isSetId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.id, other.id); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetState()).compareTo(other.isSetState()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetState()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.state, other.state); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetAccepted()).compareTo(other.isSetAccepted()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetAccepted()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.accepted, other.accepted); + 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("CompactionResponse("); + boolean first = true; + + sb.append("id:"); + sb.append(this.id); + first = false; + if (!first) sb.append(", "); + sb.append("state:"); + if (this.state == null) { + sb.append("null"); + } else { + sb.append(this.state); + } + first = false; + if (!first) sb.append(", "); + sb.append("accepted:"); + sb.append(this.accepted); + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!isSetId()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'id' is unset! Struct:" + toString()); + } + + if (!isSetState()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'state' is unset! Struct:" + toString()); + } + + if (!isSetAccepted()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'accepted' 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 CompactionResponseStandardSchemeFactory implements SchemeFactory { + public CompactionResponseStandardScheme getScheme() { + return new CompactionResponseStandardScheme(); + } + } + + private static class CompactionResponseStandardScheme extends StandardScheme<CompactionResponse> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, CompactionResponse 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: // ID + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.id = iprot.readI64(); + struct.setIdIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // STATE + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.state = iprot.readString(); + struct.setStateIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // ACCEPTED + if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) { + struct.accepted = iprot.readBool(); + struct.setAcceptedIsSet(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, CompactionResponse struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + oprot.writeFieldBegin(ID_FIELD_DESC); + oprot.writeI64(struct.id); + oprot.writeFieldEnd(); + if (struct.state != null) { + oprot.writeFieldBegin(STATE_FIELD_DESC); + oprot.writeString(struct.state); + oprot.writeFieldEnd(); + } + oprot.writeFieldBegin(ACCEPTED_FIELD_DESC); + oprot.writeBool(struct.accepted); + oprot.writeFieldEnd(); + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class CompactionResponseTupleSchemeFactory implements SchemeFactory { + public CompactionResponseTupleScheme getScheme() { + return new CompactionResponseTupleScheme(); + } + } + + private static class CompactionResponseTupleScheme extends TupleScheme<CompactionResponse> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, CompactionResponse struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + oprot.writeI64(struct.id); + oprot.writeString(struct.state); + oprot.writeBool(struct.accepted); + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, CompactionResponse struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + struct.id = iprot.readI64(); + struct.setIdIsSet(true); + struct.state = iprot.readString(); + struct.setStateIsSet(true); + struct.accepted = iprot.readBool(); + struct.setAcceptedIsSet(true); + } + } + +} + http://git-wip-us.apache.org/repos/asf/hive/blob/7b24ff74/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponseElement.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponseElement.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponseElement.java index 212ecd6..78b4f7c 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponseElement.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponseElement.java @@ -50,6 +50,7 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC private static final org.apache.thrift.protocol.TField META_INFO_FIELD_DESC = new org.apache.thrift.protocol.TField("metaInfo", org.apache.thrift.protocol.TType.STRING, (short)10); private static final org.apache.thrift.protocol.TField END_TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("endTime", org.apache.thrift.protocol.TType.I64, (short)11); private static final org.apache.thrift.protocol.TField HADOOP_JOB_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("hadoopJobId", org.apache.thrift.protocol.TType.STRING, (short)12); + private static final org.apache.thrift.protocol.TField ID_FIELD_DESC = new org.apache.thrift.protocol.TField("id", org.apache.thrift.protocol.TType.I64, (short)13); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -69,6 +70,7 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC private String metaInfo; // optional private long endTime; // optional private String hadoopJobId; // optional + private long id; // 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 { @@ -87,7 +89,8 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC HIGHTEST_TXN_ID((short)9, "hightestTxnId"), META_INFO((short)10, "metaInfo"), END_TIME((short)11, "endTime"), - HADOOP_JOB_ID((short)12, "hadoopJobId"); + HADOOP_JOB_ID((short)12, "hadoopJobId"), + ID((short)13, "id"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -126,6 +129,8 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC return END_TIME; case 12: // HADOOP_JOB_ID return HADOOP_JOB_ID; + case 13: // ID + return ID; default: return null; } @@ -169,8 +174,9 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC private static final int __START_ISSET_ID = 0; private static final int __HIGHTESTTXNID_ISSET_ID = 1; private static final int __ENDTIME_ISSET_ID = 2; + private static final int __ID_ISSET_ID = 3; private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.PARTITIONNAME,_Fields.WORKERID,_Fields.START,_Fields.RUN_AS,_Fields.HIGHTEST_TXN_ID,_Fields.META_INFO,_Fields.END_TIME,_Fields.HADOOP_JOB_ID}; + private static final _Fields optionals[] = {_Fields.PARTITIONNAME,_Fields.WORKERID,_Fields.START,_Fields.RUN_AS,_Fields.HIGHTEST_TXN_ID,_Fields.META_INFO,_Fields.END_TIME,_Fields.HADOOP_JOB_ID,_Fields.ID}; 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); @@ -198,6 +204,8 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); tmpMap.put(_Fields.HADOOP_JOB_ID, new org.apache.thrift.meta_data.FieldMetaData("hadoopJobId", org.apache.thrift.TFieldRequirementType.OPTIONAL, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.ID, new org.apache.thrift.meta_data.FieldMetaData("id", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); metaDataMap = Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ShowCompactResponseElement.class, metaDataMap); } @@ -255,6 +263,7 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC if (other.isSetHadoopJobId()) { this.hadoopJobId = other.hadoopJobId; } + this.id = other.id; } public ShowCompactResponseElement deepCopy() { @@ -279,6 +288,8 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC this.endTime = 0; this.hadoopJobId = "None"; + setIdIsSet(false); + this.id = 0; } public String getDbname() { @@ -562,6 +573,28 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC } } + public long getId() { + return this.id; + } + + public void setId(long id) { + this.id = id; + setIdIsSet(true); + } + + public void unsetId() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ID_ISSET_ID); + } + + /** Returns true if field id is set (has been assigned a value) and false otherwise */ + public boolean isSetId() { + return EncodingUtils.testBit(__isset_bitfield, __ID_ISSET_ID); + } + + public void setIdIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ID_ISSET_ID, value); + } + public void setFieldValue(_Fields field, Object value) { switch (field) { case DBNAME: @@ -660,6 +693,14 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC } break; + case ID: + if (value == null) { + unsetId(); + } else { + setId((Long)value); + } + break; + } } @@ -701,6 +742,9 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC case HADOOP_JOB_ID: return getHadoopJobId(); + case ID: + return getId(); + } throw new IllegalStateException(); } @@ -736,6 +780,8 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC return isSetEndTime(); case HADOOP_JOB_ID: return isSetHadoopJobId(); + case ID: + return isSetId(); } throw new IllegalStateException(); } @@ -861,6 +907,15 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC return false; } + boolean this_present_id = true && this.isSetId(); + boolean that_present_id = true && that.isSetId(); + if (this_present_id || that_present_id) { + if (!(this_present_id && that_present_id)) + return false; + if (this.id != that.id) + return false; + } + return true; } @@ -928,6 +983,11 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC if (present_hadoopJobId) list.add(hadoopJobId); + boolean present_id = true && (isSetId()); + list.add(present_id); + if (present_id) + list.add(id); + return list.hashCode(); } @@ -1059,6 +1119,16 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC return lastComparison; } } + lastComparison = Boolean.valueOf(isSetId()).compareTo(other.isSetId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.id, other.id); + if (lastComparison != 0) { + return lastComparison; + } + } return 0; } @@ -1178,6 +1248,12 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC } first = false; } + if (isSetId()) { + if (!first) sb.append(", "); + sb.append("id:"); + sb.append(this.id); + first = false; + } sb.append(")"); return sb.toString(); } @@ -1335,6 +1411,14 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; + case 13: // ID + if (schemeField.type == org.apache.thrift.protocol.TType.I64) { + struct.id = iprot.readI64(); + struct.setIdIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -1418,6 +1502,11 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC oprot.writeFieldEnd(); } } + if (struct.isSetId()) { + oprot.writeFieldBegin(ID_FIELD_DESC); + oprot.writeI64(struct.id); + oprot.writeFieldEnd(); + } oprot.writeFieldStop(); oprot.writeStructEnd(); } @@ -1464,7 +1553,10 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC if (struct.isSetHadoopJobId()) { optionals.set(7); } - oprot.writeBitSet(optionals, 8); + if (struct.isSetId()) { + optionals.set(8); + } + oprot.writeBitSet(optionals, 9); if (struct.isSetPartitionname()) { oprot.writeString(struct.partitionname); } @@ -1489,6 +1581,9 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC if (struct.isSetHadoopJobId()) { oprot.writeString(struct.hadoopJobId); } + if (struct.isSetId()) { + oprot.writeI64(struct.id); + } } @Override @@ -1502,7 +1597,7 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC struct.setTypeIsSet(true); struct.state = iprot.readString(); struct.setStateIsSet(true); - BitSet incoming = iprot.readBitSet(8); + BitSet incoming = iprot.readBitSet(9); if (incoming.get(0)) { struct.partitionname = iprot.readString(); struct.setPartitionnameIsSet(true); @@ -1535,6 +1630,10 @@ public class ShowCompactResponseElement implements org.apache.thrift.TBase<ShowC struct.hadoopJobId = iprot.readString(); struct.setHadoopJobIdIsSet(true); } + if (incoming.get(8)) { + struct.id = iprot.readI64(); + struct.setIdIsSet(true); + } } }
