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:25 UTC
[23/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/GetTablesRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java
new file mode 100644
index 0000000..09ca865
--- /dev/null
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesRequest.java
@@ -0,0 +1,765 @@
+/**
+ * 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 GetTablesRequest implements org.apache.thrift.TBase<GetTablesRequest, GetTablesRequest._Fields>, java.io.Serializable, Cloneable, Comparable<GetTablesRequest> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetTablesRequest");
+
+ private static final org.apache.thrift.protocol.TField DB_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("dbName", org.apache.thrift.protocol.TType.STRING, (short)1);
+ private static final org.apache.thrift.protocol.TField TBL_NAMES_FIELD_DESC = new org.apache.thrift.protocol.TField("tblNames", org.apache.thrift.protocol.TType.LIST, (short)2);
+ private static final org.apache.thrift.protocol.TField CAPABILITIES_FIELD_DESC = new org.apache.thrift.protocol.TField("capabilities", org.apache.thrift.protocol.TType.STRUCT, (short)3);
+ 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)4);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new GetTablesRequestStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new GetTablesRequestTupleSchemeFactory());
+ }
+
+ private String dbName; // required
+ private List<String> tblNames; // optional
+ private ClientCapabilities capabilities; // optional
+ 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 {
+ DB_NAME((short)1, "dbName"),
+ TBL_NAMES((short)2, "tblNames"),
+ CAPABILITIES((short)3, "capabilities"),
+ CAT_NAME((short)4, "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: // DB_NAME
+ return DB_NAME;
+ case 2: // TBL_NAMES
+ return TBL_NAMES;
+ case 3: // CAPABILITIES
+ return CAPABILITIES;
+ case 4: // 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 _Fields optionals[] = {_Fields.TBL_NAMES,_Fields.CAPABILITIES,_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.DB_NAME, new org.apache.thrift.meta_data.FieldMetaData("dbName", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.TBL_NAMES, new org.apache.thrift.meta_data.FieldMetaData("tblNames", 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.STRING))));
+ tmpMap.put(_Fields.CAPABILITIES, new org.apache.thrift.meta_data.FieldMetaData("capabilities", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ClientCapabilities.class)));
+ 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(GetTablesRequest.class, metaDataMap);
+ }
+
+ public GetTablesRequest() {
+ }
+
+ public GetTablesRequest(
+ String dbName)
+ {
+ this();
+ this.dbName = dbName;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public GetTablesRequest(GetTablesRequest other) {
+ if (other.isSetDbName()) {
+ this.dbName = other.dbName;
+ }
+ if (other.isSetTblNames()) {
+ List<String> __this__tblNames = new ArrayList<String>(other.tblNames);
+ this.tblNames = __this__tblNames;
+ }
+ if (other.isSetCapabilities()) {
+ this.capabilities = new ClientCapabilities(other.capabilities);
+ }
+ if (other.isSetCatName()) {
+ this.catName = other.catName;
+ }
+ }
+
+ public GetTablesRequest deepCopy() {
+ return new GetTablesRequest(this);
+ }
+
+ @Override
+ public void clear() {
+ this.dbName = null;
+ this.tblNames = null;
+ this.capabilities = null;
+ this.catName = null;
+ }
+
+ public String getDbName() {
+ return this.dbName;
+ }
+
+ public void setDbName(String dbName) {
+ this.dbName = dbName;
+ }
+
+ public void unsetDbName() {
+ this.dbName = null;
+ }
+
+ /** Returns true if field dbName is set (has been assigned a value) and false otherwise */
+ public boolean isSetDbName() {
+ return this.dbName != null;
+ }
+
+ public void setDbNameIsSet(boolean value) {
+ if (!value) {
+ this.dbName = null;
+ }
+ }
+
+ public int getTblNamesSize() {
+ return (this.tblNames == null) ? 0 : this.tblNames.size();
+ }
+
+ public java.util.Iterator<String> getTblNamesIterator() {
+ return (this.tblNames == null) ? null : this.tblNames.iterator();
+ }
+
+ public void addToTblNames(String elem) {
+ if (this.tblNames == null) {
+ this.tblNames = new ArrayList<String>();
+ }
+ this.tblNames.add(elem);
+ }
+
+ public List<String> getTblNames() {
+ return this.tblNames;
+ }
+
+ public void setTblNames(List<String> tblNames) {
+ this.tblNames = tblNames;
+ }
+
+ public void unsetTblNames() {
+ this.tblNames = null;
+ }
+
+ /** Returns true if field tblNames is set (has been assigned a value) and false otherwise */
+ public boolean isSetTblNames() {
+ return this.tblNames != null;
+ }
+
+ public void setTblNamesIsSet(boolean value) {
+ if (!value) {
+ this.tblNames = null;
+ }
+ }
+
+ public ClientCapabilities getCapabilities() {
+ return this.capabilities;
+ }
+
+ public void setCapabilities(ClientCapabilities capabilities) {
+ this.capabilities = capabilities;
+ }
+
+ public void unsetCapabilities() {
+ this.capabilities = null;
+ }
+
+ /** Returns true if field capabilities is set (has been assigned a value) and false otherwise */
+ public boolean isSetCapabilities() {
+ return this.capabilities != null;
+ }
+
+ public void setCapabilitiesIsSet(boolean value) {
+ if (!value) {
+ this.capabilities = 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 DB_NAME:
+ if (value == null) {
+ unsetDbName();
+ } else {
+ setDbName((String)value);
+ }
+ break;
+
+ case TBL_NAMES:
+ if (value == null) {
+ unsetTblNames();
+ } else {
+ setTblNames((List<String>)value);
+ }
+ break;
+
+ case CAPABILITIES:
+ if (value == null) {
+ unsetCapabilities();
+ } else {
+ setCapabilities((ClientCapabilities)value);
+ }
+ break;
+
+ case CAT_NAME:
+ if (value == null) {
+ unsetCatName();
+ } else {
+ setCatName((String)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case DB_NAME:
+ return getDbName();
+
+ case TBL_NAMES:
+ return getTblNames();
+
+ case CAPABILITIES:
+ return getCapabilities();
+
+ 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 DB_NAME:
+ return isSetDbName();
+ case TBL_NAMES:
+ return isSetTblNames();
+ case CAPABILITIES:
+ return isSetCapabilities();
+ case CAT_NAME:
+ return isSetCatName();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof GetTablesRequest)
+ return this.equals((GetTablesRequest)that);
+ return false;
+ }
+
+ public boolean equals(GetTablesRequest that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_dbName = true && this.isSetDbName();
+ boolean that_present_dbName = true && that.isSetDbName();
+ if (this_present_dbName || that_present_dbName) {
+ if (!(this_present_dbName && that_present_dbName))
+ return false;
+ if (!this.dbName.equals(that.dbName))
+ return false;
+ }
+
+ boolean this_present_tblNames = true && this.isSetTblNames();
+ boolean that_present_tblNames = true && that.isSetTblNames();
+ if (this_present_tblNames || that_present_tblNames) {
+ if (!(this_present_tblNames && that_present_tblNames))
+ return false;
+ if (!this.tblNames.equals(that.tblNames))
+ return false;
+ }
+
+ boolean this_present_capabilities = true && this.isSetCapabilities();
+ boolean that_present_capabilities = true && that.isSetCapabilities();
+ if (this_present_capabilities || that_present_capabilities) {
+ if (!(this_present_capabilities && that_present_capabilities))
+ return false;
+ if (!this.capabilities.equals(that.capabilities))
+ 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_dbName = true && (isSetDbName());
+ list.add(present_dbName);
+ if (present_dbName)
+ list.add(dbName);
+
+ boolean present_tblNames = true && (isSetTblNames());
+ list.add(present_tblNames);
+ if (present_tblNames)
+ list.add(tblNames);
+
+ boolean present_capabilities = true && (isSetCapabilities());
+ list.add(present_capabilities);
+ if (present_capabilities)
+ list.add(capabilities);
+
+ boolean present_catName = true && (isSetCatName());
+ list.add(present_catName);
+ if (present_catName)
+ list.add(catName);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(GetTablesRequest other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ 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(isSetTblNames()).compareTo(other.isSetTblNames());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetTblNames()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tblNames, other.tblNames);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetCapabilities()).compareTo(other.isSetCapabilities());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetCapabilities()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.capabilities, other.capabilities);
+ 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("GetTablesRequest(");
+ boolean first = true;
+
+ sb.append("dbName:");
+ if (this.dbName == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.dbName);
+ }
+ first = false;
+ if (isSetTblNames()) {
+ if (!first) sb.append(", ");
+ sb.append("tblNames:");
+ if (this.tblNames == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.tblNames);
+ }
+ first = false;
+ }
+ if (isSetCapabilities()) {
+ if (!first) sb.append(", ");
+ sb.append("capabilities:");
+ if (this.capabilities == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.capabilities);
+ }
+ 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 (!isSetDbName()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'dbName' is unset! Struct:" + toString());
+ }
+
+ // check for sub-struct validity
+ if (capabilities != null) {
+ capabilities.validate();
+ }
+ }
+
+ 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 GetTablesRequestStandardSchemeFactory implements SchemeFactory {
+ public GetTablesRequestStandardScheme getScheme() {
+ return new GetTablesRequestStandardScheme();
+ }
+ }
+
+ private static class GetTablesRequestStandardScheme extends StandardScheme<GetTablesRequest> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, GetTablesRequest struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // DB_NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.dbName = iprot.readString();
+ struct.setDbNameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // TBL_NAMES
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list848 = iprot.readListBegin();
+ struct.tblNames = new ArrayList<String>(_list848.size);
+ String _elem849;
+ for (int _i850 = 0; _i850 < _list848.size; ++_i850)
+ {
+ _elem849 = iprot.readString();
+ struct.tblNames.add(_elem849);
+ }
+ iprot.readListEnd();
+ }
+ struct.setTblNamesIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // CAPABILITIES
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.capabilities = new ClientCapabilities();
+ struct.capabilities.read(iprot);
+ struct.setCapabilitiesIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 4: // 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, GetTablesRequest struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.dbName != null) {
+ oprot.writeFieldBegin(DB_NAME_FIELD_DESC);
+ oprot.writeString(struct.dbName);
+ oprot.writeFieldEnd();
+ }
+ if (struct.tblNames != null) {
+ if (struct.isSetTblNames()) {
+ oprot.writeFieldBegin(TBL_NAMES_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.tblNames.size()));
+ for (String _iter851 : struct.tblNames)
+ {
+ oprot.writeString(_iter851);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.capabilities != null) {
+ if (struct.isSetCapabilities()) {
+ oprot.writeFieldBegin(CAPABILITIES_FIELD_DESC);
+ struct.capabilities.write(oprot);
+ 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 GetTablesRequestTupleSchemeFactory implements SchemeFactory {
+ public GetTablesRequestTupleScheme getScheme() {
+ return new GetTablesRequestTupleScheme();
+ }
+ }
+
+ private static class GetTablesRequestTupleScheme extends TupleScheme<GetTablesRequest> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, GetTablesRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeString(struct.dbName);
+ BitSet optionals = new BitSet();
+ if (struct.isSetTblNames()) {
+ optionals.set(0);
+ }
+ if (struct.isSetCapabilities()) {
+ optionals.set(1);
+ }
+ if (struct.isSetCatName()) {
+ optionals.set(2);
+ }
+ oprot.writeBitSet(optionals, 3);
+ if (struct.isSetTblNames()) {
+ {
+ oprot.writeI32(struct.tblNames.size());
+ for (String _iter852 : struct.tblNames)
+ {
+ oprot.writeString(_iter852);
+ }
+ }
+ }
+ if (struct.isSetCapabilities()) {
+ struct.capabilities.write(oprot);
+ }
+ if (struct.isSetCatName()) {
+ oprot.writeString(struct.catName);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, GetTablesRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.dbName = iprot.readString();
+ struct.setDbNameIsSet(true);
+ BitSet incoming = iprot.readBitSet(3);
+ if (incoming.get(0)) {
+ {
+ org.apache.thrift.protocol.TList _list853 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tblNames = new ArrayList<String>(_list853.size);
+ String _elem854;
+ for (int _i855 = 0; _i855 < _list853.size; ++_i855)
+ {
+ _elem854 = iprot.readString();
+ struct.tblNames.add(_elem854);
+ }
+ }
+ struct.setTblNamesIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.capabilities = new ClientCapabilities();
+ struct.capabilities.read(iprot);
+ struct.setCapabilitiesIsSet(true);
+ }
+ if (incoming.get(2)) {
+ 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/GetTablesResult.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java
new file mode 100644
index 0000000..72256e6
--- /dev/null
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetTablesResult.java
@@ -0,0 +1,443 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.hadoop.hive.metastore.api;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class GetTablesResult implements org.apache.thrift.TBase<GetTablesResult, GetTablesResult._Fields>, java.io.Serializable, Cloneable, Comparable<GetTablesResult> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetTablesResult");
+
+ private static final org.apache.thrift.protocol.TField TABLES_FIELD_DESC = new org.apache.thrift.protocol.TField("tables", 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 GetTablesResultStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new GetTablesResultTupleSchemeFactory());
+ }
+
+ private List<Table> tables; // 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 {
+ TABLES((short)1, "tables");
+
+ 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: // TABLES
+ return TABLES;
+ 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.TABLES, new org.apache.thrift.meta_data.FieldMetaData("tables", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Table.class))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetTablesResult.class, metaDataMap);
+ }
+
+ public GetTablesResult() {
+ }
+
+ public GetTablesResult(
+ List<Table> tables)
+ {
+ this();
+ this.tables = tables;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public GetTablesResult(GetTablesResult other) {
+ if (other.isSetTables()) {
+ List<Table> __this__tables = new ArrayList<Table>(other.tables.size());
+ for (Table other_element : other.tables) {
+ __this__tables.add(new Table(other_element));
+ }
+ this.tables = __this__tables;
+ }
+ }
+
+ public GetTablesResult deepCopy() {
+ return new GetTablesResult(this);
+ }
+
+ @Override
+ public void clear() {
+ this.tables = null;
+ }
+
+ public int getTablesSize() {
+ return (this.tables == null) ? 0 : this.tables.size();
+ }
+
+ public java.util.Iterator<Table> getTablesIterator() {
+ return (this.tables == null) ? null : this.tables.iterator();
+ }
+
+ public void addToTables(Table elem) {
+ if (this.tables == null) {
+ this.tables = new ArrayList<Table>();
+ }
+ this.tables.add(elem);
+ }
+
+ public List<Table> getTables() {
+ return this.tables;
+ }
+
+ public void setTables(List<Table> tables) {
+ this.tables = tables;
+ }
+
+ public void unsetTables() {
+ this.tables = null;
+ }
+
+ /** Returns true if field tables is set (has been assigned a value) and false otherwise */
+ public boolean isSetTables() {
+ return this.tables != null;
+ }
+
+ public void setTablesIsSet(boolean value) {
+ if (!value) {
+ this.tables = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case TABLES:
+ if (value == null) {
+ unsetTables();
+ } else {
+ setTables((List<Table>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case TABLES:
+ return getTables();
+
+ }
+ 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 TABLES:
+ return isSetTables();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof GetTablesResult)
+ return this.equals((GetTablesResult)that);
+ return false;
+ }
+
+ public boolean equals(GetTablesResult that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_tables = true && this.isSetTables();
+ boolean that_present_tables = true && that.isSetTables();
+ if (this_present_tables || that_present_tables) {
+ if (!(this_present_tables && that_present_tables))
+ return false;
+ if (!this.tables.equals(that.tables))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_tables = true && (isSetTables());
+ list.add(present_tables);
+ if (present_tables)
+ list.add(tables);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(GetTablesResult other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetTables()).compareTo(other.isSetTables());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetTables()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tables, other.tables);
+ 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("GetTablesResult(");
+ boolean first = true;
+
+ sb.append("tables:");
+ if (this.tables == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.tables);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetTables()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'tables' 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 GetTablesResultStandardSchemeFactory implements SchemeFactory {
+ public GetTablesResultStandardScheme getScheme() {
+ return new GetTablesResultStandardScheme();
+ }
+ }
+
+ private static class GetTablesResultStandardScheme extends StandardScheme<GetTablesResult> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, GetTablesResult 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: // TABLES
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list856 = iprot.readListBegin();
+ struct.tables = new ArrayList<Table>(_list856.size);
+ Table _elem857;
+ for (int _i858 = 0; _i858 < _list856.size; ++_i858)
+ {
+ _elem857 = new Table();
+ _elem857.read(iprot);
+ struct.tables.add(_elem857);
+ }
+ iprot.readListEnd();
+ }
+ struct.setTablesIsSet(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, GetTablesResult struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.tables != null) {
+ oprot.writeFieldBegin(TABLES_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.tables.size()));
+ for (Table _iter859 : struct.tables)
+ {
+ _iter859.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class GetTablesResultTupleSchemeFactory implements SchemeFactory {
+ public GetTablesResultTupleScheme getScheme() {
+ return new GetTablesResultTupleScheme();
+ }
+ }
+
+ private static class GetTablesResultTupleScheme extends TupleScheme<GetTablesResult> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, GetTablesResult struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ {
+ oprot.writeI32(struct.tables.size());
+ for (Table _iter860 : struct.tables)
+ {
+ _iter860.write(oprot);
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, GetTablesResult struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ {
+ org.apache.thrift.protocol.TList _list861 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.tables = new ArrayList<Table>(_list861.size);
+ Table _elem862;
+ for (int _i863 = 0; _i863 < _list861.size; ++_i863)
+ {
+ _elem862 = new Table();
+ _elem862.read(iprot);
+ struct.tables.add(_elem862);
+ }
+ }
+ struct.setTablesIsSet(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/GetValidWriteIdsRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java
new file mode 100644
index 0000000..af62ca1
--- /dev/null
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java
@@ -0,0 +1,539 @@
+/**
+ * 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 GetValidWriteIdsRequest implements org.apache.thrift.TBase<GetValidWriteIdsRequest, GetValidWriteIdsRequest._Fields>, java.io.Serializable, Cloneable, Comparable<GetValidWriteIdsRequest> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetValidWriteIdsRequest");
+
+ private static final org.apache.thrift.protocol.TField FULL_TABLE_NAMES_FIELD_DESC = new org.apache.thrift.protocol.TField("fullTableNames", org.apache.thrift.protocol.TType.LIST, (short)1);
+ private static final org.apache.thrift.protocol.TField VALID_TXN_LIST_FIELD_DESC = new org.apache.thrift.protocol.TField("validTxnList", org.apache.thrift.protocol.TType.STRING, (short)2);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new GetValidWriteIdsRequestStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new GetValidWriteIdsRequestTupleSchemeFactory());
+ }
+
+ private List<String> fullTableNames; // required
+ private String validTxnList; // 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 {
+ FULL_TABLE_NAMES((short)1, "fullTableNames"),
+ VALID_TXN_LIST((short)2, "validTxnList");
+
+ 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: // FULL_TABLE_NAMES
+ return FULL_TABLE_NAMES;
+ case 2: // VALID_TXN_LIST
+ return VALID_TXN_LIST;
+ 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.FULL_TABLE_NAMES, new org.apache.thrift.meta_data.FieldMetaData("fullTableNames", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
+ tmpMap.put(_Fields.VALID_TXN_LIST, new org.apache.thrift.meta_data.FieldMetaData("validTxnList", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetValidWriteIdsRequest.class, metaDataMap);
+ }
+
+ public GetValidWriteIdsRequest() {
+ }
+
+ public GetValidWriteIdsRequest(
+ List<String> fullTableNames,
+ String validTxnList)
+ {
+ this();
+ this.fullTableNames = fullTableNames;
+ this.validTxnList = validTxnList;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public GetValidWriteIdsRequest(GetValidWriteIdsRequest other) {
+ if (other.isSetFullTableNames()) {
+ List<String> __this__fullTableNames = new ArrayList<String>(other.fullTableNames);
+ this.fullTableNames = __this__fullTableNames;
+ }
+ if (other.isSetValidTxnList()) {
+ this.validTxnList = other.validTxnList;
+ }
+ }
+
+ public GetValidWriteIdsRequest deepCopy() {
+ return new GetValidWriteIdsRequest(this);
+ }
+
+ @Override
+ public void clear() {
+ this.fullTableNames = null;
+ this.validTxnList = null;
+ }
+
+ public int getFullTableNamesSize() {
+ return (this.fullTableNames == null) ? 0 : this.fullTableNames.size();
+ }
+
+ public java.util.Iterator<String> getFullTableNamesIterator() {
+ return (this.fullTableNames == null) ? null : this.fullTableNames.iterator();
+ }
+
+ public void addToFullTableNames(String elem) {
+ if (this.fullTableNames == null) {
+ this.fullTableNames = new ArrayList<String>();
+ }
+ this.fullTableNames.add(elem);
+ }
+
+ public List<String> getFullTableNames() {
+ return this.fullTableNames;
+ }
+
+ public void setFullTableNames(List<String> fullTableNames) {
+ this.fullTableNames = fullTableNames;
+ }
+
+ public void unsetFullTableNames() {
+ this.fullTableNames = null;
+ }
+
+ /** Returns true if field fullTableNames is set (has been assigned a value) and false otherwise */
+ public boolean isSetFullTableNames() {
+ return this.fullTableNames != null;
+ }
+
+ public void setFullTableNamesIsSet(boolean value) {
+ if (!value) {
+ this.fullTableNames = null;
+ }
+ }
+
+ public String getValidTxnList() {
+ return this.validTxnList;
+ }
+
+ public void setValidTxnList(String validTxnList) {
+ this.validTxnList = validTxnList;
+ }
+
+ public void unsetValidTxnList() {
+ this.validTxnList = null;
+ }
+
+ /** Returns true if field validTxnList is set (has been assigned a value) and false otherwise */
+ public boolean isSetValidTxnList() {
+ return this.validTxnList != null;
+ }
+
+ public void setValidTxnListIsSet(boolean value) {
+ if (!value) {
+ this.validTxnList = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case FULL_TABLE_NAMES:
+ if (value == null) {
+ unsetFullTableNames();
+ } else {
+ setFullTableNames((List<String>)value);
+ }
+ break;
+
+ case VALID_TXN_LIST:
+ if (value == null) {
+ unsetValidTxnList();
+ } else {
+ setValidTxnList((String)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case FULL_TABLE_NAMES:
+ return getFullTableNames();
+
+ case VALID_TXN_LIST:
+ return getValidTxnList();
+
+ }
+ 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 FULL_TABLE_NAMES:
+ return isSetFullTableNames();
+ case VALID_TXN_LIST:
+ return isSetValidTxnList();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof GetValidWriteIdsRequest)
+ return this.equals((GetValidWriteIdsRequest)that);
+ return false;
+ }
+
+ public boolean equals(GetValidWriteIdsRequest that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_fullTableNames = true && this.isSetFullTableNames();
+ boolean that_present_fullTableNames = true && that.isSetFullTableNames();
+ if (this_present_fullTableNames || that_present_fullTableNames) {
+ if (!(this_present_fullTableNames && that_present_fullTableNames))
+ return false;
+ if (!this.fullTableNames.equals(that.fullTableNames))
+ return false;
+ }
+
+ boolean this_present_validTxnList = true && this.isSetValidTxnList();
+ boolean that_present_validTxnList = true && that.isSetValidTxnList();
+ if (this_present_validTxnList || that_present_validTxnList) {
+ if (!(this_present_validTxnList && that_present_validTxnList))
+ return false;
+ if (!this.validTxnList.equals(that.validTxnList))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_fullTableNames = true && (isSetFullTableNames());
+ list.add(present_fullTableNames);
+ if (present_fullTableNames)
+ list.add(fullTableNames);
+
+ boolean present_validTxnList = true && (isSetValidTxnList());
+ list.add(present_validTxnList);
+ if (present_validTxnList)
+ list.add(validTxnList);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(GetValidWriteIdsRequest other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetFullTableNames()).compareTo(other.isSetFullTableNames());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetFullTableNames()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.fullTableNames, other.fullTableNames);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetValidTxnList()).compareTo(other.isSetValidTxnList());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetValidTxnList()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.validTxnList, other.validTxnList);
+ 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("GetValidWriteIdsRequest(");
+ boolean first = true;
+
+ sb.append("fullTableNames:");
+ if (this.fullTableNames == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.fullTableNames);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("validTxnList:");
+ if (this.validTxnList == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.validTxnList);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetFullTableNames()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'fullTableNames' is unset! Struct:" + toString());
+ }
+
+ if (!isSetValidTxnList()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'validTxnList' 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 GetValidWriteIdsRequestStandardSchemeFactory implements SchemeFactory {
+ public GetValidWriteIdsRequestStandardScheme getScheme() {
+ return new GetValidWriteIdsRequestStandardScheme();
+ }
+ }
+
+ private static class GetValidWriteIdsRequestStandardScheme extends StandardScheme<GetValidWriteIdsRequest> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, GetValidWriteIdsRequest 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: // FULL_TABLE_NAMES
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list610 = iprot.readListBegin();
+ struct.fullTableNames = new ArrayList<String>(_list610.size);
+ String _elem611;
+ for (int _i612 = 0; _i612 < _list610.size; ++_i612)
+ {
+ _elem611 = iprot.readString();
+ struct.fullTableNames.add(_elem611);
+ }
+ iprot.readListEnd();
+ }
+ struct.setFullTableNamesIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // VALID_TXN_LIST
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.validTxnList = iprot.readString();
+ struct.setValidTxnListIsSet(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, GetValidWriteIdsRequest struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.fullTableNames != null) {
+ oprot.writeFieldBegin(FULL_TABLE_NAMES_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.fullTableNames.size()));
+ for (String _iter613 : struct.fullTableNames)
+ {
+ oprot.writeString(_iter613);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ if (struct.validTxnList != null) {
+ oprot.writeFieldBegin(VALID_TXN_LIST_FIELD_DESC);
+ oprot.writeString(struct.validTxnList);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class GetValidWriteIdsRequestTupleSchemeFactory implements SchemeFactory {
+ public GetValidWriteIdsRequestTupleScheme getScheme() {
+ return new GetValidWriteIdsRequestTupleScheme();
+ }
+ }
+
+ private static class GetValidWriteIdsRequestTupleScheme extends TupleScheme<GetValidWriteIdsRequest> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, GetValidWriteIdsRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ {
+ oprot.writeI32(struct.fullTableNames.size());
+ for (String _iter614 : struct.fullTableNames)
+ {
+ oprot.writeString(_iter614);
+ }
+ }
+ oprot.writeString(struct.validTxnList);
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, GetValidWriteIdsRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ {
+ org.apache.thrift.protocol.TList _list615 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.fullTableNames = new ArrayList<String>(_list615.size);
+ String _elem616;
+ for (int _i617 = 0; _i617 < _list615.size; ++_i617)
+ {
+ _elem616 = iprot.readString();
+ struct.fullTableNames.add(_elem616);
+ }
+ }
+ struct.setFullTableNamesIsSet(true);
+ struct.validTxnList = iprot.readString();
+ struct.setValidTxnListIsSet(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/GetValidWriteIdsResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java
new file mode 100644
index 0000000..615a422
--- /dev/null
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java
@@ -0,0 +1,443 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.hadoop.hive.metastore.api;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class GetValidWriteIdsResponse implements org.apache.thrift.TBase<GetValidWriteIdsResponse, GetValidWriteIdsResponse._Fields>, java.io.Serializable, Cloneable, Comparable<GetValidWriteIdsResponse> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("GetValidWriteIdsResponse");
+
+ private static final org.apache.thrift.protocol.TField TBL_VALID_WRITE_IDS_FIELD_DESC = new org.apache.thrift.protocol.TField("tblValidWriteIds", 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 GetValidWriteIdsResponseStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new GetValidWriteIdsResponseTupleSchemeFactory());
+ }
+
+ private List<TableValidWriteIds> tblValidWriteIds; // 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 {
+ TBL_VALID_WRITE_IDS((short)1, "tblValidWriteIds");
+
+ 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: // TBL_VALID_WRITE_IDS
+ return TBL_VALID_WRITE_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.TBL_VALID_WRITE_IDS, new org.apache.thrift.meta_data.FieldMetaData("tblValidWriteIds", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TableValidWriteIds.class))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(GetValidWriteIdsResponse.class, metaDataMap);
+ }
+
+ public GetValidWriteIdsResponse() {
+ }
+
+ public GetValidWriteIdsResponse(
+ List<TableValidWriteIds> tblValidWriteIds)
+ {
+ this();
+ this.tblValidWriteIds = tblValidWriteIds;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public GetValidWriteIdsResponse(GetValidWriteIdsResponse other) {
+ if (other.isSetTblValidWriteIds()) {
+ List<TableValidWriteIds> __this__tblValidWriteIds = new ArrayList<TableValidWriteIds>(other.tblValidWriteIds.size());
+ for (TableValidWriteIds other_element : other.tblValidWriteIds) {
+ __this__tblValidWriteIds.add(new TableValidWriteIds(other_element));
+ }
+ this.tblValidWriteIds = __this__tblValidWriteIds;
+ }
+ }
+
+ public GetValidWriteIdsResponse deepCopy() {
+ return new GetValidWriteIdsResponse(this);
+ }
+
+ @Override
+ public void clear() {
+ this.tblValidWriteIds = null;
+ }
+
+ public int getTblValidWriteIdsSize() {
+ return (this.tblValidWriteIds == null) ? 0 : this.tblValidWriteIds.size();
+ }
+
+ public java.util.Iterator<TableValidWriteIds> getTblValidWriteIdsIterator() {
+ return (this.tblValidWriteIds == null) ? null : this.tblValidWriteIds.iterator();
+ }
+
+ public void addToTblValidWriteIds(TableValidWriteIds elem) {
+ if (this.tblValidWriteIds == null) {
+ this.tblValidWriteIds = new ArrayList<TableValidWriteIds>();
+ }
+ this.tblValidWriteIds.add(elem);
+ }
+
+ public List<TableValidWriteIds> getTblValidWriteIds() {
+ return this.tblValidWriteIds;
+ }
+
+ public void setTblValidWriteIds(List<TableValidWriteIds> tblValidWriteIds) {
+ this.tblValidWriteIds = tblValidWriteIds;
+ }
+
+ public void unsetTblValidWriteIds() {
+ this.tblValidWriteIds = null;
+ }
+
+ /** Returns true if field tblValidWriteIds is set (has been assigned a value) and false otherwise */
+ public boolean isSetTblValidWriteIds() {
+ return this.tblValidWriteIds != null;
+ }
+
+ public void setTblValidWriteIdsIsSet(boolean value) {
+ if (!value) {
+ this.tblValidWriteIds = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case TBL_VALID_WRITE_IDS:
+ if (value == null) {
+ unsetTblValidWriteIds();
+ } else {
+ setTblValidWriteIds((List<TableValidWriteIds>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case TBL_VALID_WRITE_IDS:
+ return getTblValidWriteIds();
+
+ }
+ 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 TBL_VALID_WRITE_IDS:
+ return isSetTblValidWriteIds();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof GetValidWriteIdsResponse)
+ return this.equals((GetValidWriteIdsResponse)that);
+ return false;
+ }
+
+ public boolean equals(GetValidWriteIdsResponse that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_tblValidWriteIds = true && this.isSetTblValidWriteIds();
+ boolean that_present_tblValidWriteIds = true && that.isSetTblValidWriteIds();
+ if (this_present_tblValidWriteIds || that_present_tblValidWriteIds) {
+ if (!(this_present_tblValidWriteIds && that_present_tblValidWriteIds))
+ return false;
+ if (!this.tblValidWriteIds.equals(that.tblValidWriteIds))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_tblValidWriteIds = true && (isSetTblValidWriteIds());
+ list.add(present_tblValidWriteIds);
+ if (present_tblValidWriteIds)
+ list.add(tblValidWriteIds);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(GetValidWriteIdsResponse other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetTblValidWriteIds()).compareTo(other.isSetTblValidWriteIds());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetTblValidWriteIds()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tblValidWriteIds, other.tblValidWriteIds);
+ 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("GetValidWriteIdsResponse(");
+ boolean first = true;
+
+ sb.append("tblValidWriteIds:");
+ if (this.tblValidWriteIds == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.tblValidWriteIds);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetTblValidWriteIds()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'tblValidWriteIds' 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 GetValidWriteIdsResponseStandardSchemeFactory implements SchemeFactory {
+ public GetValidWriteIdsResponseStandardScheme getScheme() {
+ return new GetValidWriteIdsResponseStandardScheme();
+ }
+ }
+
+ private static class GetValidWriteIdsResponseStandardScheme extends StandardScheme<GetValidWriteIdsResponse> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, GetValidWriteIdsResponse 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: // TBL_VALID_WRITE_IDS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list626 = iprot.readListBegin();
+ struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list626.size);
+ TableValidWriteIds _elem627;
+ for (int _i628 = 0; _i628 < _list626.size; ++_i628)
+ {
+ _elem627 = new TableValidWriteIds();
+ _elem627.read(iprot);
+ struct.tblValidWriteIds.add(_elem627);
+ }
+ iprot.readListEnd();
+ }
+ struct.setTblValidWriteIdsIsSet(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, GetValidWriteIdsResponse struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.tblValidWriteIds != null) {
+ oprot.writeFieldBegin(TBL_VALID_WRITE_IDS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.tblValidWriteIds.size()));
+ for (TableValidWriteIds _iter629 : struct.tblValidWriteIds)
+ {
+ _iter629.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class GetValidWriteIdsResponseTupleSchemeFactory implements SchemeFactory {
+ public GetValidWriteIdsResponseTupleScheme getScheme() {
+ return new GetValidWriteIdsResponseTupleScheme();
+ }
+ }
+
+ private static class GetValidWriteIdsResponseTupleScheme extends TupleScheme<GetValidWriteIdsResponse> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, GetValidWriteIdsResponse struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ {
+ oprot.writeI32(struct.tblValidWriteIds.size());
+ for (TableValidWriteIds _iter630 : struct.tblValidWriteIds)
+ {
+ _iter630.write(oprot);
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, GetValidWriteIdsResponse struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ {
+ org.apache.thrift.protocol.TList _list631 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list631.size);
+ TableValidWriteIds _elem632;
+ for (int _i633 = 0; _i633 < _list631.size; ++_i633)
+ {
+ _elem632 = new TableValidWriteIds();
+ _elem632.read(iprot);
+ struct.tblValidWriteIds.add(_elem632);
+ }
+ }
+ struct.setTblValidWriteIdsIsSet(true);
+ }
+ }
+
+}
+