You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2018/07/13 01:40:15 UTC
[13/91] [abbrv] [partial] hive git commit: HIVE-20097 : Convert
standalone-metastore to a submodule (Alexander Kolbasov reviewed by Vihang
Karajgaonkar)
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/NotificationEventsCountRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventsCountRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventsCountRequest.java
new file mode 100644
index 0000000..a4a5218
--- /dev/null
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventsCountRequest.java
@@ -0,0 +1,598 @@
+/**
+ * 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 NotificationEventsCountRequest implements org.apache.thrift.TBase<NotificationEventsCountRequest, NotificationEventsCountRequest._Fields>, java.io.Serializable, Cloneable, Comparable<NotificationEventsCountRequest> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("NotificationEventsCountRequest");
+
+ private static final org.apache.thrift.protocol.TField FROM_EVENT_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("fromEventId", org.apache.thrift.protocol.TType.I64, (short)1);
+ private static final org.apache.thrift.protocol.TField DB_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("dbName", org.apache.thrift.protocol.TType.STRING, (short)2);
+ private static final org.apache.thrift.protocol.TField CAT_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("catName", org.apache.thrift.protocol.TType.STRING, (short)3);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new NotificationEventsCountRequestStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new NotificationEventsCountRequestTupleSchemeFactory());
+ }
+
+ private long fromEventId; // required
+ private String dbName; // required
+ private String catName; // 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 {
+ FROM_EVENT_ID((short)1, "fromEventId"),
+ DB_NAME((short)2, "dbName"),
+ CAT_NAME((short)3, "catName");
+
+ 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: // FROM_EVENT_ID
+ return FROM_EVENT_ID;
+ case 2: // DB_NAME
+ return DB_NAME;
+ case 3: // CAT_NAME
+ return CAT_NAME;
+ 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 __FROMEVENTID_ISSET_ID = 0;
+ private byte __isset_bitfield = 0;
+ private static final _Fields optionals[] = {_Fields.CAT_NAME};
+ 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.FROM_EVENT_ID, new org.apache.thrift.meta_data.FieldMetaData("fromEventId", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+ tmpMap.put(_Fields.DB_NAME, new org.apache.thrift.meta_data.FieldMetaData("dbName", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.CAT_NAME, new org.apache.thrift.meta_data.FieldMetaData("catName", 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(NotificationEventsCountRequest.class, metaDataMap);
+ }
+
+ public NotificationEventsCountRequest() {
+ }
+
+ public NotificationEventsCountRequest(
+ long fromEventId,
+ String dbName)
+ {
+ this();
+ this.fromEventId = fromEventId;
+ setFromEventIdIsSet(true);
+ this.dbName = dbName;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public NotificationEventsCountRequest(NotificationEventsCountRequest other) {
+ __isset_bitfield = other.__isset_bitfield;
+ this.fromEventId = other.fromEventId;
+ if (other.isSetDbName()) {
+ this.dbName = other.dbName;
+ }
+ if (other.isSetCatName()) {
+ this.catName = other.catName;
+ }
+ }
+
+ public NotificationEventsCountRequest deepCopy() {
+ return new NotificationEventsCountRequest(this);
+ }
+
+ @Override
+ public void clear() {
+ setFromEventIdIsSet(false);
+ this.fromEventId = 0;
+ this.dbName = null;
+ this.catName = null;
+ }
+
+ public long getFromEventId() {
+ return this.fromEventId;
+ }
+
+ public void setFromEventId(long fromEventId) {
+ this.fromEventId = fromEventId;
+ setFromEventIdIsSet(true);
+ }
+
+ public void unsetFromEventId() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __FROMEVENTID_ISSET_ID);
+ }
+
+ /** Returns true if field fromEventId is set (has been assigned a value) and false otherwise */
+ public boolean isSetFromEventId() {
+ return EncodingUtils.testBit(__isset_bitfield, __FROMEVENTID_ISSET_ID);
+ }
+
+ public void setFromEventIdIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __FROMEVENTID_ISSET_ID, value);
+ }
+
+ public String getDbName() {
+ return this.dbName;
+ }
+
+ public void setDbName(String dbName) {
+ this.dbName = dbName;
+ }
+
+ public void unsetDbName() {
+ this.dbName = null;
+ }
+
+ /** Returns true if field dbName is set (has been assigned a value) and false otherwise */
+ public boolean isSetDbName() {
+ return this.dbName != null;
+ }
+
+ public void setDbNameIsSet(boolean value) {
+ if (!value) {
+ this.dbName = null;
+ }
+ }
+
+ public String getCatName() {
+ return this.catName;
+ }
+
+ public void setCatName(String catName) {
+ this.catName = catName;
+ }
+
+ public void unsetCatName() {
+ this.catName = null;
+ }
+
+ /** Returns true if field catName is set (has been assigned a value) and false otherwise */
+ public boolean isSetCatName() {
+ return this.catName != null;
+ }
+
+ public void setCatNameIsSet(boolean value) {
+ if (!value) {
+ this.catName = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case FROM_EVENT_ID:
+ if (value == null) {
+ unsetFromEventId();
+ } else {
+ setFromEventId((Long)value);
+ }
+ break;
+
+ case DB_NAME:
+ if (value == null) {
+ unsetDbName();
+ } else {
+ setDbName((String)value);
+ }
+ break;
+
+ case CAT_NAME:
+ if (value == null) {
+ unsetCatName();
+ } else {
+ setCatName((String)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case FROM_EVENT_ID:
+ return getFromEventId();
+
+ case DB_NAME:
+ return getDbName();
+
+ case CAT_NAME:
+ return getCatName();
+
+ }
+ 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 FROM_EVENT_ID:
+ return isSetFromEventId();
+ case DB_NAME:
+ return isSetDbName();
+ case CAT_NAME:
+ return isSetCatName();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof NotificationEventsCountRequest)
+ return this.equals((NotificationEventsCountRequest)that);
+ return false;
+ }
+
+ public boolean equals(NotificationEventsCountRequest that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_fromEventId = true;
+ boolean that_present_fromEventId = true;
+ if (this_present_fromEventId || that_present_fromEventId) {
+ if (!(this_present_fromEventId && that_present_fromEventId))
+ return false;
+ if (this.fromEventId != that.fromEventId)
+ return false;
+ }
+
+ boolean this_present_dbName = true && this.isSetDbName();
+ boolean that_present_dbName = true && that.isSetDbName();
+ if (this_present_dbName || that_present_dbName) {
+ if (!(this_present_dbName && that_present_dbName))
+ return false;
+ if (!this.dbName.equals(that.dbName))
+ return false;
+ }
+
+ boolean this_present_catName = true && this.isSetCatName();
+ boolean that_present_catName = true && that.isSetCatName();
+ if (this_present_catName || that_present_catName) {
+ if (!(this_present_catName && that_present_catName))
+ return false;
+ if (!this.catName.equals(that.catName))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_fromEventId = true;
+ list.add(present_fromEventId);
+ if (present_fromEventId)
+ list.add(fromEventId);
+
+ boolean present_dbName = true && (isSetDbName());
+ list.add(present_dbName);
+ if (present_dbName)
+ list.add(dbName);
+
+ boolean present_catName = true && (isSetCatName());
+ list.add(present_catName);
+ if (present_catName)
+ list.add(catName);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(NotificationEventsCountRequest other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetFromEventId()).compareTo(other.isSetFromEventId());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetFromEventId()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.fromEventId, other.fromEventId);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetDbName()).compareTo(other.isSetDbName());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetDbName()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.dbName, other.dbName);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetCatName()).compareTo(other.isSetCatName());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetCatName()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.catName, other.catName);
+ 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("NotificationEventsCountRequest(");
+ boolean first = true;
+
+ sb.append("fromEventId:");
+ sb.append(this.fromEventId);
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("dbName:");
+ if (this.dbName == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.dbName);
+ }
+ first = false;
+ if (isSetCatName()) {
+ if (!first) sb.append(", ");
+ sb.append("catName:");
+ if (this.catName == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.catName);
+ }
+ first = false;
+ }
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetFromEventId()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'fromEventId' is unset! Struct:" + toString());
+ }
+
+ if (!isSetDbName()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'dbName' 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 NotificationEventsCountRequestStandardSchemeFactory implements SchemeFactory {
+ public NotificationEventsCountRequestStandardScheme getScheme() {
+ return new NotificationEventsCountRequestStandardScheme();
+ }
+ }
+
+ private static class NotificationEventsCountRequestStandardScheme extends StandardScheme<NotificationEventsCountRequest> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, NotificationEventsCountRequest 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: // FROM_EVENT_ID
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.fromEventId = iprot.readI64();
+ struct.setFromEventIdIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // DB_NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.dbName = iprot.readString();
+ struct.setDbNameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // CAT_NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.catName = iprot.readString();
+ struct.setCatNameIsSet(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, NotificationEventsCountRequest struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ oprot.writeFieldBegin(FROM_EVENT_ID_FIELD_DESC);
+ oprot.writeI64(struct.fromEventId);
+ oprot.writeFieldEnd();
+ if (struct.dbName != null) {
+ oprot.writeFieldBegin(DB_NAME_FIELD_DESC);
+ oprot.writeString(struct.dbName);
+ oprot.writeFieldEnd();
+ }
+ if (struct.catName != null) {
+ if (struct.isSetCatName()) {
+ oprot.writeFieldBegin(CAT_NAME_FIELD_DESC);
+ oprot.writeString(struct.catName);
+ oprot.writeFieldEnd();
+ }
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class NotificationEventsCountRequestTupleSchemeFactory implements SchemeFactory {
+ public NotificationEventsCountRequestTupleScheme getScheme() {
+ return new NotificationEventsCountRequestTupleScheme();
+ }
+ }
+
+ private static class NotificationEventsCountRequestTupleScheme extends TupleScheme<NotificationEventsCountRequest> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, NotificationEventsCountRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeI64(struct.fromEventId);
+ oprot.writeString(struct.dbName);
+ BitSet optionals = new BitSet();
+ if (struct.isSetCatName()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.isSetCatName()) {
+ oprot.writeString(struct.catName);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, NotificationEventsCountRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.fromEventId = iprot.readI64();
+ struct.setFromEventIdIsSet(true);
+ struct.dbName = iprot.readString();
+ struct.setDbNameIsSet(true);
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ struct.catName = iprot.readString();
+ struct.setCatNameIsSet(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/NotificationEventsCountResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventsCountResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventsCountResponse.java
new file mode 100644
index 0000000..137b72d
--- /dev/null
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventsCountResponse.java
@@ -0,0 +1,387 @@
+/**
+ * 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 NotificationEventsCountResponse implements org.apache.thrift.TBase<NotificationEventsCountResponse, NotificationEventsCountResponse._Fields>, java.io.Serializable, Cloneable, Comparable<NotificationEventsCountResponse> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("NotificationEventsCountResponse");
+
+ private static final org.apache.thrift.protocol.TField EVENTS_COUNT_FIELD_DESC = new org.apache.thrift.protocol.TField("eventsCount", org.apache.thrift.protocol.TType.I64, (short)1);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new NotificationEventsCountResponseStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new NotificationEventsCountResponseTupleSchemeFactory());
+ }
+
+ private long eventsCount; // 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 {
+ EVENTS_COUNT((short)1, "eventsCount");
+
+ 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: // EVENTS_COUNT
+ return EVENTS_COUNT;
+ 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 __EVENTSCOUNT_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.EVENTS_COUNT, new org.apache.thrift.meta_data.FieldMetaData("eventsCount", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(NotificationEventsCountResponse.class, metaDataMap);
+ }
+
+ public NotificationEventsCountResponse() {
+ }
+
+ public NotificationEventsCountResponse(
+ long eventsCount)
+ {
+ this();
+ this.eventsCount = eventsCount;
+ setEventsCountIsSet(true);
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public NotificationEventsCountResponse(NotificationEventsCountResponse other) {
+ __isset_bitfield = other.__isset_bitfield;
+ this.eventsCount = other.eventsCount;
+ }
+
+ public NotificationEventsCountResponse deepCopy() {
+ return new NotificationEventsCountResponse(this);
+ }
+
+ @Override
+ public void clear() {
+ setEventsCountIsSet(false);
+ this.eventsCount = 0;
+ }
+
+ public long getEventsCount() {
+ return this.eventsCount;
+ }
+
+ public void setEventsCount(long eventsCount) {
+ this.eventsCount = eventsCount;
+ setEventsCountIsSet(true);
+ }
+
+ public void unsetEventsCount() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __EVENTSCOUNT_ISSET_ID);
+ }
+
+ /** Returns true if field eventsCount is set (has been assigned a value) and false otherwise */
+ public boolean isSetEventsCount() {
+ return EncodingUtils.testBit(__isset_bitfield, __EVENTSCOUNT_ISSET_ID);
+ }
+
+ public void setEventsCountIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __EVENTSCOUNT_ISSET_ID, value);
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case EVENTS_COUNT:
+ if (value == null) {
+ unsetEventsCount();
+ } else {
+ setEventsCount((Long)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case EVENTS_COUNT:
+ return getEventsCount();
+
+ }
+ 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 EVENTS_COUNT:
+ return isSetEventsCount();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof NotificationEventsCountResponse)
+ return this.equals((NotificationEventsCountResponse)that);
+ return false;
+ }
+
+ public boolean equals(NotificationEventsCountResponse that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_eventsCount = true;
+ boolean that_present_eventsCount = true;
+ if (this_present_eventsCount || that_present_eventsCount) {
+ if (!(this_present_eventsCount && that_present_eventsCount))
+ return false;
+ if (this.eventsCount != that.eventsCount)
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_eventsCount = true;
+ list.add(present_eventsCount);
+ if (present_eventsCount)
+ list.add(eventsCount);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(NotificationEventsCountResponse other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetEventsCount()).compareTo(other.isSetEventsCount());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetEventsCount()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.eventsCount, other.eventsCount);
+ 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("NotificationEventsCountResponse(");
+ boolean first = true;
+
+ sb.append("eventsCount:");
+ sb.append(this.eventsCount);
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetEventsCount()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'eventsCount' 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 NotificationEventsCountResponseStandardSchemeFactory implements SchemeFactory {
+ public NotificationEventsCountResponseStandardScheme getScheme() {
+ return new NotificationEventsCountResponseStandardScheme();
+ }
+ }
+
+ private static class NotificationEventsCountResponseStandardScheme extends StandardScheme<NotificationEventsCountResponse> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, NotificationEventsCountResponse 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: // EVENTS_COUNT
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.eventsCount = iprot.readI64();
+ struct.setEventsCountIsSet(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, NotificationEventsCountResponse struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ oprot.writeFieldBegin(EVENTS_COUNT_FIELD_DESC);
+ oprot.writeI64(struct.eventsCount);
+ oprot.writeFieldEnd();
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class NotificationEventsCountResponseTupleSchemeFactory implements SchemeFactory {
+ public NotificationEventsCountResponseTupleScheme getScheme() {
+ return new NotificationEventsCountResponseTupleScheme();
+ }
+ }
+
+ private static class NotificationEventsCountResponseTupleScheme extends TupleScheme<NotificationEventsCountResponse> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, NotificationEventsCountResponse struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeI64(struct.eventsCount);
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, NotificationEventsCountResponse struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.eventsCount = iprot.readI64();
+ struct.setEventsCountIsSet(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/OpenTxnRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnRequest.java
new file mode 100644
index 0000000..2dae2e9
--- /dev/null
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnRequest.java
@@ -0,0 +1,963 @@
+/**
+ * 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 OpenTxnRequest implements org.apache.thrift.TBase<OpenTxnRequest, OpenTxnRequest._Fields>, java.io.Serializable, Cloneable, Comparable<OpenTxnRequest> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("OpenTxnRequest");
+
+ private static final org.apache.thrift.protocol.TField NUM_TXNS_FIELD_DESC = new org.apache.thrift.protocol.TField("num_txns", org.apache.thrift.protocol.TType.I32, (short)1);
+ private static final org.apache.thrift.protocol.TField USER_FIELD_DESC = new org.apache.thrift.protocol.TField("user", org.apache.thrift.protocol.TType.STRING, (short)2);
+ private static final org.apache.thrift.protocol.TField HOSTNAME_FIELD_DESC = new org.apache.thrift.protocol.TField("hostname", org.apache.thrift.protocol.TType.STRING, (short)3);
+ private static final org.apache.thrift.protocol.TField AGENT_INFO_FIELD_DESC = new org.apache.thrift.protocol.TField("agentInfo", org.apache.thrift.protocol.TType.STRING, (short)4);
+ 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)5);
+ private static final org.apache.thrift.protocol.TField REPL_SRC_TXN_IDS_FIELD_DESC = new org.apache.thrift.protocol.TField("replSrcTxnIds", org.apache.thrift.protocol.TType.LIST, (short)6);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new OpenTxnRequestStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new OpenTxnRequestTupleSchemeFactory());
+ }
+
+ private int num_txns; // required
+ private String user; // required
+ private String hostname; // required
+ private String agentInfo; // optional
+ private String replPolicy; // optional
+ private List<Long> replSrcTxnIds; // 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 {
+ NUM_TXNS((short)1, "num_txns"),
+ USER((short)2, "user"),
+ HOSTNAME((short)3, "hostname"),
+ AGENT_INFO((short)4, "agentInfo"),
+ REPL_POLICY((short)5, "replPolicy"),
+ REPL_SRC_TXN_IDS((short)6, "replSrcTxnIds");
+
+ 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: // NUM_TXNS
+ return NUM_TXNS;
+ case 2: // USER
+ return USER;
+ case 3: // HOSTNAME
+ return HOSTNAME;
+ case 4: // AGENT_INFO
+ return AGENT_INFO;
+ case 5: // REPL_POLICY
+ return REPL_POLICY;
+ case 6: // REPL_SRC_TXN_IDS
+ return REPL_SRC_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
+ private static final int __NUM_TXNS_ISSET_ID = 0;
+ private byte __isset_bitfield = 0;
+ private static final _Fields optionals[] = {_Fields.AGENT_INFO,_Fields.REPL_POLICY,_Fields.REPL_SRC_TXN_IDS};
+ 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.NUM_TXNS, new org.apache.thrift.meta_data.FieldMetaData("num_txns", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
+ tmpMap.put(_Fields.USER, new org.apache.thrift.meta_data.FieldMetaData("user", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.HOSTNAME, new org.apache.thrift.meta_data.FieldMetaData("hostname", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.AGENT_INFO, new org.apache.thrift.meta_data.FieldMetaData("agentInfo", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ 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)));
+ tmpMap.put(_Fields.REPL_SRC_TXN_IDS, new org.apache.thrift.meta_data.FieldMetaData("replSrcTxnIds", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ 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(OpenTxnRequest.class, metaDataMap);
+ }
+
+ public OpenTxnRequest() {
+ this.agentInfo = "Unknown";
+
+ }
+
+ public OpenTxnRequest(
+ int num_txns,
+ String user,
+ String hostname)
+ {
+ this();
+ this.num_txns = num_txns;
+ setNum_txnsIsSet(true);
+ this.user = user;
+ this.hostname = hostname;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public OpenTxnRequest(OpenTxnRequest other) {
+ __isset_bitfield = other.__isset_bitfield;
+ this.num_txns = other.num_txns;
+ if (other.isSetUser()) {
+ this.user = other.user;
+ }
+ if (other.isSetHostname()) {
+ this.hostname = other.hostname;
+ }
+ if (other.isSetAgentInfo()) {
+ this.agentInfo = other.agentInfo;
+ }
+ if (other.isSetReplPolicy()) {
+ this.replPolicy = other.replPolicy;
+ }
+ if (other.isSetReplSrcTxnIds()) {
+ List<Long> __this__replSrcTxnIds = new ArrayList<Long>(other.replSrcTxnIds);
+ this.replSrcTxnIds = __this__replSrcTxnIds;
+ }
+ }
+
+ public OpenTxnRequest deepCopy() {
+ return new OpenTxnRequest(this);
+ }
+
+ @Override
+ public void clear() {
+ setNum_txnsIsSet(false);
+ this.num_txns = 0;
+ this.user = null;
+ this.hostname = null;
+ this.agentInfo = "Unknown";
+
+ this.replPolicy = null;
+ this.replSrcTxnIds = null;
+ }
+
+ public int getNum_txns() {
+ return this.num_txns;
+ }
+
+ public void setNum_txns(int num_txns) {
+ this.num_txns = num_txns;
+ setNum_txnsIsSet(true);
+ }
+
+ public void unsetNum_txns() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUM_TXNS_ISSET_ID);
+ }
+
+ /** Returns true if field num_txns is set (has been assigned a value) and false otherwise */
+ public boolean isSetNum_txns() {
+ return EncodingUtils.testBit(__isset_bitfield, __NUM_TXNS_ISSET_ID);
+ }
+
+ public void setNum_txnsIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUM_TXNS_ISSET_ID, value);
+ }
+
+ public String getUser() {
+ return this.user;
+ }
+
+ public void setUser(String user) {
+ this.user = user;
+ }
+
+ public void unsetUser() {
+ this.user = null;
+ }
+
+ /** Returns true if field user is set (has been assigned a value) and false otherwise */
+ public boolean isSetUser() {
+ return this.user != null;
+ }
+
+ public void setUserIsSet(boolean value) {
+ if (!value) {
+ this.user = null;
+ }
+ }
+
+ public String getHostname() {
+ return this.hostname;
+ }
+
+ public void setHostname(String hostname) {
+ this.hostname = hostname;
+ }
+
+ public void unsetHostname() {
+ this.hostname = null;
+ }
+
+ /** Returns true if field hostname is set (has been assigned a value) and false otherwise */
+ public boolean isSetHostname() {
+ return this.hostname != null;
+ }
+
+ public void setHostnameIsSet(boolean value) {
+ if (!value) {
+ this.hostname = null;
+ }
+ }
+
+ public String getAgentInfo() {
+ return this.agentInfo;
+ }
+
+ public void setAgentInfo(String agentInfo) {
+ this.agentInfo = agentInfo;
+ }
+
+ public void unsetAgentInfo() {
+ this.agentInfo = null;
+ }
+
+ /** Returns true if field agentInfo is set (has been assigned a value) and false otherwise */
+ public boolean isSetAgentInfo() {
+ return this.agentInfo != null;
+ }
+
+ public void setAgentInfoIsSet(boolean value) {
+ if (!value) {
+ this.agentInfo = null;
+ }
+ }
+
+ 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 int getReplSrcTxnIdsSize() {
+ return (this.replSrcTxnIds == null) ? 0 : this.replSrcTxnIds.size();
+ }
+
+ public java.util.Iterator<Long> getReplSrcTxnIdsIterator() {
+ return (this.replSrcTxnIds == null) ? null : this.replSrcTxnIds.iterator();
+ }
+
+ public void addToReplSrcTxnIds(long elem) {
+ if (this.replSrcTxnIds == null) {
+ this.replSrcTxnIds = new ArrayList<Long>();
+ }
+ this.replSrcTxnIds.add(elem);
+ }
+
+ public List<Long> getReplSrcTxnIds() {
+ return this.replSrcTxnIds;
+ }
+
+ public void setReplSrcTxnIds(List<Long> replSrcTxnIds) {
+ this.replSrcTxnIds = replSrcTxnIds;
+ }
+
+ public void unsetReplSrcTxnIds() {
+ this.replSrcTxnIds = null;
+ }
+
+ /** Returns true if field replSrcTxnIds is set (has been assigned a value) and false otherwise */
+ public boolean isSetReplSrcTxnIds() {
+ return this.replSrcTxnIds != null;
+ }
+
+ public void setReplSrcTxnIdsIsSet(boolean value) {
+ if (!value) {
+ this.replSrcTxnIds = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case NUM_TXNS:
+ if (value == null) {
+ unsetNum_txns();
+ } else {
+ setNum_txns((Integer)value);
+ }
+ break;
+
+ case USER:
+ if (value == null) {
+ unsetUser();
+ } else {
+ setUser((String)value);
+ }
+ break;
+
+ case HOSTNAME:
+ if (value == null) {
+ unsetHostname();
+ } else {
+ setHostname((String)value);
+ }
+ break;
+
+ case AGENT_INFO:
+ if (value == null) {
+ unsetAgentInfo();
+ } else {
+ setAgentInfo((String)value);
+ }
+ break;
+
+ case REPL_POLICY:
+ if (value == null) {
+ unsetReplPolicy();
+ } else {
+ setReplPolicy((String)value);
+ }
+ break;
+
+ case REPL_SRC_TXN_IDS:
+ if (value == null) {
+ unsetReplSrcTxnIds();
+ } else {
+ setReplSrcTxnIds((List<Long>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case NUM_TXNS:
+ return getNum_txns();
+
+ case USER:
+ return getUser();
+
+ case HOSTNAME:
+ return getHostname();
+
+ case AGENT_INFO:
+ return getAgentInfo();
+
+ case REPL_POLICY:
+ return getReplPolicy();
+
+ case REPL_SRC_TXN_IDS:
+ return getReplSrcTxnIds();
+
+ }
+ 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 NUM_TXNS:
+ return isSetNum_txns();
+ case USER:
+ return isSetUser();
+ case HOSTNAME:
+ return isSetHostname();
+ case AGENT_INFO:
+ return isSetAgentInfo();
+ case REPL_POLICY:
+ return isSetReplPolicy();
+ case REPL_SRC_TXN_IDS:
+ return isSetReplSrcTxnIds();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof OpenTxnRequest)
+ return this.equals((OpenTxnRequest)that);
+ return false;
+ }
+
+ public boolean equals(OpenTxnRequest that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_num_txns = true;
+ boolean that_present_num_txns = true;
+ if (this_present_num_txns || that_present_num_txns) {
+ if (!(this_present_num_txns && that_present_num_txns))
+ return false;
+ if (this.num_txns != that.num_txns)
+ return false;
+ }
+
+ boolean this_present_user = true && this.isSetUser();
+ boolean that_present_user = true && that.isSetUser();
+ if (this_present_user || that_present_user) {
+ if (!(this_present_user && that_present_user))
+ return false;
+ if (!this.user.equals(that.user))
+ return false;
+ }
+
+ boolean this_present_hostname = true && this.isSetHostname();
+ boolean that_present_hostname = true && that.isSetHostname();
+ if (this_present_hostname || that_present_hostname) {
+ if (!(this_present_hostname && that_present_hostname))
+ return false;
+ if (!this.hostname.equals(that.hostname))
+ return false;
+ }
+
+ boolean this_present_agentInfo = true && this.isSetAgentInfo();
+ boolean that_present_agentInfo = true && that.isSetAgentInfo();
+ if (this_present_agentInfo || that_present_agentInfo) {
+ if (!(this_present_agentInfo && that_present_agentInfo))
+ return false;
+ if (!this.agentInfo.equals(that.agentInfo))
+ 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;
+ }
+
+ boolean this_present_replSrcTxnIds = true && this.isSetReplSrcTxnIds();
+ boolean that_present_replSrcTxnIds = true && that.isSetReplSrcTxnIds();
+ if (this_present_replSrcTxnIds || that_present_replSrcTxnIds) {
+ if (!(this_present_replSrcTxnIds && that_present_replSrcTxnIds))
+ return false;
+ if (!this.replSrcTxnIds.equals(that.replSrcTxnIds))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_num_txns = true;
+ list.add(present_num_txns);
+ if (present_num_txns)
+ list.add(num_txns);
+
+ boolean present_user = true && (isSetUser());
+ list.add(present_user);
+ if (present_user)
+ list.add(user);
+
+ boolean present_hostname = true && (isSetHostname());
+ list.add(present_hostname);
+ if (present_hostname)
+ list.add(hostname);
+
+ boolean present_agentInfo = true && (isSetAgentInfo());
+ list.add(present_agentInfo);
+ if (present_agentInfo)
+ list.add(agentInfo);
+
+ boolean present_replPolicy = true && (isSetReplPolicy());
+ list.add(present_replPolicy);
+ if (present_replPolicy)
+ list.add(replPolicy);
+
+ boolean present_replSrcTxnIds = true && (isSetReplSrcTxnIds());
+ list.add(present_replSrcTxnIds);
+ if (present_replSrcTxnIds)
+ list.add(replSrcTxnIds);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(OpenTxnRequest other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetNum_txns()).compareTo(other.isSetNum_txns());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetNum_txns()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.num_txns, other.num_txns);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetUser()).compareTo(other.isSetUser());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetUser()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.user, other.user);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetHostname()).compareTo(other.isSetHostname());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetHostname()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.hostname, other.hostname);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetAgentInfo()).compareTo(other.isSetAgentInfo());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetAgentInfo()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.agentInfo, other.agentInfo);
+ 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;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetReplSrcTxnIds()).compareTo(other.isSetReplSrcTxnIds());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetReplSrcTxnIds()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.replSrcTxnIds, other.replSrcTxnIds);
+ 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("OpenTxnRequest(");
+ boolean first = true;
+
+ sb.append("num_txns:");
+ sb.append(this.num_txns);
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("user:");
+ if (this.user == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.user);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("hostname:");
+ if (this.hostname == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.hostname);
+ }
+ first = false;
+ if (isSetAgentInfo()) {
+ if (!first) sb.append(", ");
+ sb.append("agentInfo:");
+ if (this.agentInfo == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.agentInfo);
+ }
+ 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;
+ }
+ if (isSetReplSrcTxnIds()) {
+ if (!first) sb.append(", ");
+ sb.append("replSrcTxnIds:");
+ if (this.replSrcTxnIds == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.replSrcTxnIds);
+ }
+ first = false;
+ }
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetNum_txns()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'num_txns' is unset! Struct:" + toString());
+ }
+
+ if (!isSetUser()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'user' is unset! Struct:" + toString());
+ }
+
+ if (!isSetHostname()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'hostname' 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 OpenTxnRequestStandardSchemeFactory implements SchemeFactory {
+ public OpenTxnRequestStandardScheme getScheme() {
+ return new OpenTxnRequestStandardScheme();
+ }
+ }
+
+ private static class OpenTxnRequestStandardScheme extends StandardScheme<OpenTxnRequest> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, OpenTxnRequest 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: // NUM_TXNS
+ if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+ struct.num_txns = iprot.readI32();
+ struct.setNum_txnsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // USER
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.user = iprot.readString();
+ struct.setUserIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // HOSTNAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.hostname = iprot.readString();
+ struct.setHostnameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 4: // AGENT_INFO
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.agentInfo = iprot.readString();
+ struct.setAgentInfoIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 5: // 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;
+ case 6: // REPL_SRC_TXN_IDS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list570 = iprot.readListBegin();
+ struct.replSrcTxnIds = new ArrayList<Long>(_list570.size);
+ long _elem571;
+ for (int _i572 = 0; _i572 < _list570.size; ++_i572)
+ {
+ _elem571 = iprot.readI64();
+ struct.replSrcTxnIds.add(_elem571);
+ }
+ iprot.readListEnd();
+ }
+ struct.setReplSrcTxnIdsIsSet(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, OpenTxnRequest struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ oprot.writeFieldBegin(NUM_TXNS_FIELD_DESC);
+ oprot.writeI32(struct.num_txns);
+ oprot.writeFieldEnd();
+ if (struct.user != null) {
+ oprot.writeFieldBegin(USER_FIELD_DESC);
+ oprot.writeString(struct.user);
+ oprot.writeFieldEnd();
+ }
+ if (struct.hostname != null) {
+ oprot.writeFieldBegin(HOSTNAME_FIELD_DESC);
+ oprot.writeString(struct.hostname);
+ oprot.writeFieldEnd();
+ }
+ if (struct.agentInfo != null) {
+ if (struct.isSetAgentInfo()) {
+ oprot.writeFieldBegin(AGENT_INFO_FIELD_DESC);
+ oprot.writeString(struct.agentInfo);
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.replPolicy != null) {
+ if (struct.isSetReplPolicy()) {
+ oprot.writeFieldBegin(REPL_POLICY_FIELD_DESC);
+ oprot.writeString(struct.replPolicy);
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.replSrcTxnIds != null) {
+ if (struct.isSetReplSrcTxnIds()) {
+ oprot.writeFieldBegin(REPL_SRC_TXN_IDS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.replSrcTxnIds.size()));
+ for (long _iter573 : struct.replSrcTxnIds)
+ {
+ oprot.writeI64(_iter573);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class OpenTxnRequestTupleSchemeFactory implements SchemeFactory {
+ public OpenTxnRequestTupleScheme getScheme() {
+ return new OpenTxnRequestTupleScheme();
+ }
+ }
+
+ private static class OpenTxnRequestTupleScheme extends TupleScheme<OpenTxnRequest> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, OpenTxnRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeI32(struct.num_txns);
+ oprot.writeString(struct.user);
+ oprot.writeString(struct.hostname);
+ BitSet optionals = new BitSet();
+ if (struct.isSetAgentInfo()) {
+ optionals.set(0);
+ }
+ if (struct.isSetReplPolicy()) {
+ optionals.set(1);
+ }
+ if (struct.isSetReplSrcTxnIds()) {
+ optionals.set(2);
+ }
+ oprot.writeBitSet(optionals, 3);
+ if (struct.isSetAgentInfo()) {
+ oprot.writeString(struct.agentInfo);
+ }
+ if (struct.isSetReplPolicy()) {
+ oprot.writeString(struct.replPolicy);
+ }
+ if (struct.isSetReplSrcTxnIds()) {
+ {
+ oprot.writeI32(struct.replSrcTxnIds.size());
+ for (long _iter574 : struct.replSrcTxnIds)
+ {
+ oprot.writeI64(_iter574);
+ }
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, OpenTxnRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.num_txns = iprot.readI32();
+ struct.setNum_txnsIsSet(true);
+ struct.user = iprot.readString();
+ struct.setUserIsSet(true);
+ struct.hostname = iprot.readString();
+ struct.setHostnameIsSet(true);
+ BitSet incoming = iprot.readBitSet(3);
+ if (incoming.get(0)) {
+ struct.agentInfo = iprot.readString();
+ struct.setAgentInfoIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.replPolicy = iprot.readString();
+ struct.setReplPolicyIsSet(true);
+ }
+ if (incoming.get(2)) {
+ {
+ org.apache.thrift.protocol.TList _list575 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.replSrcTxnIds = new ArrayList<Long>(_list575.size);
+ long _elem576;
+ for (int _i577 = 0; _i577 < _list575.size; ++_i577)
+ {
+ _elem576 = iprot.readI64();
+ struct.replSrcTxnIds.add(_elem576);
+ }
+ }
+ struct.setReplSrcTxnIdsIsSet(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/OpenTxnsResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java
new file mode 100644
index 0000000..9e38d6c
--- /dev/null
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.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 OpenTxnsResponse implements org.apache.thrift.TBase<OpenTxnsResponse, OpenTxnsResponse._Fields>, java.io.Serializable, Cloneable, Comparable<OpenTxnsResponse> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("OpenTxnsResponse");
+
+ 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 OpenTxnsResponseStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new OpenTxnsResponseTupleSchemeFactory());
+ }
+
+ 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(OpenTxnsResponse.class, metaDataMap);
+ }
+
+ public OpenTxnsResponse() {
+ }
+
+ public OpenTxnsResponse(
+ List<Long> txn_ids)
+ {
+ this();
+ this.txn_ids = txn_ids;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public OpenTxnsResponse(OpenTxnsResponse other) {
+ if (other.isSetTxn_ids()) {
+ List<Long> __this__txn_ids = new ArrayList<Long>(other.txn_ids);
+ this.txn_ids = __this__txn_ids;
+ }
+ }
+
+ public OpenTxnsResponse deepCopy() {
+ return new OpenTxnsResponse(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 OpenTxnsResponse)
+ return this.equals((OpenTxnsResponse)that);
+ return false;
+ }
+
+ public boolean equals(OpenTxnsResponse 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(OpenTxnsResponse 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("OpenTxnsResponse(");
+ 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 OpenTxnsResponseStandardSchemeFactory implements SchemeFactory {
+ public OpenTxnsResponseStandardScheme getScheme() {
+ return new OpenTxnsResponseStandardScheme();
+ }
+ }
+
+ private static class OpenTxnsResponseStandardScheme extends StandardScheme<OpenTxnsResponse> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, OpenTxnsResponse 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 _list578 = iprot.readListBegin();
+ struct.txn_ids = new ArrayList<Long>(_list578.size);
+ long _elem579;
+ for (int _i580 = 0; _i580 < _list578.size; ++_i580)
+ {
+ _elem579 = iprot.readI64();
+ struct.txn_ids.add(_elem579);
+ }
+ 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, OpenTxnsResponse 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 _iter581 : struct.txn_ids)
+ {
+ oprot.writeI64(_iter581);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class OpenTxnsResponseTupleSchemeFactory implements SchemeFactory {
+ public OpenTxnsResponseTupleScheme getScheme() {
+ return new OpenTxnsResponseTupleScheme();
+ }
+ }
+
+ private static class OpenTxnsResponseTupleScheme extends TupleScheme<OpenTxnsResponse> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, OpenTxnsResponse struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ {
+ oprot.writeI32(struct.txn_ids.size());
+ for (long _iter582 : struct.txn_ids)
+ {
+ oprot.writeI64(_iter582);
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, OpenTxnsResponse struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ {
+ org.apache.thrift.protocol.TList _list583 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.txn_ids = new ArrayList<Long>(_list583.size);
+ long _elem584;
+ for (int _i585 = 0; _i585 < _list583.size; ++_i585)
+ {
+ _elem584 = iprot.readI64();
+ struct.txn_ids.add(_elem584);
+ }
+ }
+ struct.setTxn_idsIsSet(true);
+ }
+ }
+
+}
+