You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ga...@apache.org on 2018/03/12 23:55:52 UTC
[12/18] hive git commit: HIVE-17990 Add Thrift and DB storage for
Schema Registry objects (Alan Gates, reviewed by Thejas Nair)
http://git-wip-us.apache.org/repos/asf/hive/blob/12041d39/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ISchema.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ISchema.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ISchema.java
new file mode 100644
index 0000000..92d8b52
--- /dev/null
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ISchema.java
@@ -0,0 +1,1162 @@
+/**
+ * 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 ISchema implements org.apache.thrift.TBase<ISchema, ISchema._Fields>, java.io.Serializable, Cloneable, Comparable<ISchema> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ISchema");
+
+ private static final org.apache.thrift.protocol.TField SCHEMA_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("schemaType", org.apache.thrift.protocol.TType.I32, (short)1);
+ private static final org.apache.thrift.protocol.TField NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("name", org.apache.thrift.protocol.TType.STRING, (short)2);
+ 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)3);
+ private static final org.apache.thrift.protocol.TField COMPATIBILITY_FIELD_DESC = new org.apache.thrift.protocol.TField("compatibility", org.apache.thrift.protocol.TType.I32, (short)4);
+ private static final org.apache.thrift.protocol.TField VALIDATION_LEVEL_FIELD_DESC = new org.apache.thrift.protocol.TField("validationLevel", org.apache.thrift.protocol.TType.I32, (short)5);
+ private static final org.apache.thrift.protocol.TField CAN_EVOLVE_FIELD_DESC = new org.apache.thrift.protocol.TField("canEvolve", org.apache.thrift.protocol.TType.BOOL, (short)6);
+ private static final org.apache.thrift.protocol.TField SCHEMA_GROUP_FIELD_DESC = new org.apache.thrift.protocol.TField("schemaGroup", org.apache.thrift.protocol.TType.STRING, (short)7);
+ private static final org.apache.thrift.protocol.TField DESCRIPTION_FIELD_DESC = new org.apache.thrift.protocol.TField("description", org.apache.thrift.protocol.TType.STRING, (short)8);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new ISchemaStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new ISchemaTupleSchemeFactory());
+ }
+
+ private SchemaType schemaType; // required
+ private String name; // required
+ private String dbName; // required
+ private SchemaCompatibility compatibility; // required
+ private SchemaValidation validationLevel; // required
+ private boolean canEvolve; // required
+ private String schemaGroup; // optional
+ private String description; // 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 {
+ /**
+ *
+ * @see SchemaType
+ */
+ SCHEMA_TYPE((short)1, "schemaType"),
+ NAME((short)2, "name"),
+ DB_NAME((short)3, "dbName"),
+ /**
+ *
+ * @see SchemaCompatibility
+ */
+ COMPATIBILITY((short)4, "compatibility"),
+ /**
+ *
+ * @see SchemaValidation
+ */
+ VALIDATION_LEVEL((short)5, "validationLevel"),
+ CAN_EVOLVE((short)6, "canEvolve"),
+ SCHEMA_GROUP((short)7, "schemaGroup"),
+ DESCRIPTION((short)8, "description");
+
+ 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: // SCHEMA_TYPE
+ return SCHEMA_TYPE;
+ case 2: // NAME
+ return NAME;
+ case 3: // DB_NAME
+ return DB_NAME;
+ case 4: // COMPATIBILITY
+ return COMPATIBILITY;
+ case 5: // VALIDATION_LEVEL
+ return VALIDATION_LEVEL;
+ case 6: // CAN_EVOLVE
+ return CAN_EVOLVE;
+ case 7: // SCHEMA_GROUP
+ return SCHEMA_GROUP;
+ case 8: // DESCRIPTION
+ return DESCRIPTION;
+ 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 __CANEVOLVE_ISSET_ID = 0;
+ private byte __isset_bitfield = 0;
+ private static final _Fields optionals[] = {_Fields.SCHEMA_GROUP,_Fields.DESCRIPTION};
+ 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.SCHEMA_TYPE, new org.apache.thrift.meta_data.FieldMetaData("schemaType", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, SchemaType.class)));
+ tmpMap.put(_Fields.NAME, new org.apache.thrift.meta_data.FieldMetaData("name", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.DB_NAME, new org.apache.thrift.meta_data.FieldMetaData("dbName", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.COMPATIBILITY, new org.apache.thrift.meta_data.FieldMetaData("compatibility", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, SchemaCompatibility.class)));
+ tmpMap.put(_Fields.VALIDATION_LEVEL, new org.apache.thrift.meta_data.FieldMetaData("validationLevel", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, SchemaValidation.class)));
+ tmpMap.put(_Fields.CAN_EVOLVE, new org.apache.thrift.meta_data.FieldMetaData("canEvolve", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
+ tmpMap.put(_Fields.SCHEMA_GROUP, new org.apache.thrift.meta_data.FieldMetaData("schemaGroup", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.DESCRIPTION, new org.apache.thrift.meta_data.FieldMetaData("description", 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(ISchema.class, metaDataMap);
+ }
+
+ public ISchema() {
+ }
+
+ public ISchema(
+ SchemaType schemaType,
+ String name,
+ String dbName,
+ SchemaCompatibility compatibility,
+ SchemaValidation validationLevel,
+ boolean canEvolve)
+ {
+ this();
+ this.schemaType = schemaType;
+ this.name = name;
+ this.dbName = dbName;
+ this.compatibility = compatibility;
+ this.validationLevel = validationLevel;
+ this.canEvolve = canEvolve;
+ setCanEvolveIsSet(true);
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public ISchema(ISchema other) {
+ __isset_bitfield = other.__isset_bitfield;
+ if (other.isSetSchemaType()) {
+ this.schemaType = other.schemaType;
+ }
+ if (other.isSetName()) {
+ this.name = other.name;
+ }
+ if (other.isSetDbName()) {
+ this.dbName = other.dbName;
+ }
+ if (other.isSetCompatibility()) {
+ this.compatibility = other.compatibility;
+ }
+ if (other.isSetValidationLevel()) {
+ this.validationLevel = other.validationLevel;
+ }
+ this.canEvolve = other.canEvolve;
+ if (other.isSetSchemaGroup()) {
+ this.schemaGroup = other.schemaGroup;
+ }
+ if (other.isSetDescription()) {
+ this.description = other.description;
+ }
+ }
+
+ public ISchema deepCopy() {
+ return new ISchema(this);
+ }
+
+ @Override
+ public void clear() {
+ this.schemaType = null;
+ this.name = null;
+ this.dbName = null;
+ this.compatibility = null;
+ this.validationLevel = null;
+ setCanEvolveIsSet(false);
+ this.canEvolve = false;
+ this.schemaGroup = null;
+ this.description = null;
+ }
+
+ /**
+ *
+ * @see SchemaType
+ */
+ public SchemaType getSchemaType() {
+ return this.schemaType;
+ }
+
+ /**
+ *
+ * @see SchemaType
+ */
+ public void setSchemaType(SchemaType schemaType) {
+ this.schemaType = schemaType;
+ }
+
+ public void unsetSchemaType() {
+ this.schemaType = null;
+ }
+
+ /** Returns true if field schemaType is set (has been assigned a value) and false otherwise */
+ public boolean isSetSchemaType() {
+ return this.schemaType != null;
+ }
+
+ public void setSchemaTypeIsSet(boolean value) {
+ if (!value) {
+ this.schemaType = null;
+ }
+ }
+
+ public String getName() {
+ return this.name;
+ }
+
+ public void setName(String name) {
+ this.name = name;
+ }
+
+ public void unsetName() {
+ this.name = null;
+ }
+
+ /** Returns true if field name is set (has been assigned a value) and false otherwise */
+ public boolean isSetName() {
+ return this.name != null;
+ }
+
+ public void setNameIsSet(boolean value) {
+ if (!value) {
+ this.name = 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;
+ }
+ }
+
+ /**
+ *
+ * @see SchemaCompatibility
+ */
+ public SchemaCompatibility getCompatibility() {
+ return this.compatibility;
+ }
+
+ /**
+ *
+ * @see SchemaCompatibility
+ */
+ public void setCompatibility(SchemaCompatibility compatibility) {
+ this.compatibility = compatibility;
+ }
+
+ public void unsetCompatibility() {
+ this.compatibility = null;
+ }
+
+ /** Returns true if field compatibility is set (has been assigned a value) and false otherwise */
+ public boolean isSetCompatibility() {
+ return this.compatibility != null;
+ }
+
+ public void setCompatibilityIsSet(boolean value) {
+ if (!value) {
+ this.compatibility = null;
+ }
+ }
+
+ /**
+ *
+ * @see SchemaValidation
+ */
+ public SchemaValidation getValidationLevel() {
+ return this.validationLevel;
+ }
+
+ /**
+ *
+ * @see SchemaValidation
+ */
+ public void setValidationLevel(SchemaValidation validationLevel) {
+ this.validationLevel = validationLevel;
+ }
+
+ public void unsetValidationLevel() {
+ this.validationLevel = null;
+ }
+
+ /** Returns true if field validationLevel is set (has been assigned a value) and false otherwise */
+ public boolean isSetValidationLevel() {
+ return this.validationLevel != null;
+ }
+
+ public void setValidationLevelIsSet(boolean value) {
+ if (!value) {
+ this.validationLevel = null;
+ }
+ }
+
+ public boolean isCanEvolve() {
+ return this.canEvolve;
+ }
+
+ public void setCanEvolve(boolean canEvolve) {
+ this.canEvolve = canEvolve;
+ setCanEvolveIsSet(true);
+ }
+
+ public void unsetCanEvolve() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __CANEVOLVE_ISSET_ID);
+ }
+
+ /** Returns true if field canEvolve is set (has been assigned a value) and false otherwise */
+ public boolean isSetCanEvolve() {
+ return EncodingUtils.testBit(__isset_bitfield, __CANEVOLVE_ISSET_ID);
+ }
+
+ public void setCanEvolveIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __CANEVOLVE_ISSET_ID, value);
+ }
+
+ public String getSchemaGroup() {
+ return this.schemaGroup;
+ }
+
+ public void setSchemaGroup(String schemaGroup) {
+ this.schemaGroup = schemaGroup;
+ }
+
+ public void unsetSchemaGroup() {
+ this.schemaGroup = null;
+ }
+
+ /** Returns true if field schemaGroup is set (has been assigned a value) and false otherwise */
+ public boolean isSetSchemaGroup() {
+ return this.schemaGroup != null;
+ }
+
+ public void setSchemaGroupIsSet(boolean value) {
+ if (!value) {
+ this.schemaGroup = null;
+ }
+ }
+
+ public String getDescription() {
+ return this.description;
+ }
+
+ public void setDescription(String description) {
+ this.description = description;
+ }
+
+ public void unsetDescription() {
+ this.description = null;
+ }
+
+ /** Returns true if field description is set (has been assigned a value) and false otherwise */
+ public boolean isSetDescription() {
+ return this.description != null;
+ }
+
+ public void setDescriptionIsSet(boolean value) {
+ if (!value) {
+ this.description = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case SCHEMA_TYPE:
+ if (value == null) {
+ unsetSchemaType();
+ } else {
+ setSchemaType((SchemaType)value);
+ }
+ break;
+
+ case NAME:
+ if (value == null) {
+ unsetName();
+ } else {
+ setName((String)value);
+ }
+ break;
+
+ case DB_NAME:
+ if (value == null) {
+ unsetDbName();
+ } else {
+ setDbName((String)value);
+ }
+ break;
+
+ case COMPATIBILITY:
+ if (value == null) {
+ unsetCompatibility();
+ } else {
+ setCompatibility((SchemaCompatibility)value);
+ }
+ break;
+
+ case VALIDATION_LEVEL:
+ if (value == null) {
+ unsetValidationLevel();
+ } else {
+ setValidationLevel((SchemaValidation)value);
+ }
+ break;
+
+ case CAN_EVOLVE:
+ if (value == null) {
+ unsetCanEvolve();
+ } else {
+ setCanEvolve((Boolean)value);
+ }
+ break;
+
+ case SCHEMA_GROUP:
+ if (value == null) {
+ unsetSchemaGroup();
+ } else {
+ setSchemaGroup((String)value);
+ }
+ break;
+
+ case DESCRIPTION:
+ if (value == null) {
+ unsetDescription();
+ } else {
+ setDescription((String)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case SCHEMA_TYPE:
+ return getSchemaType();
+
+ case NAME:
+ return getName();
+
+ case DB_NAME:
+ return getDbName();
+
+ case COMPATIBILITY:
+ return getCompatibility();
+
+ case VALIDATION_LEVEL:
+ return getValidationLevel();
+
+ case CAN_EVOLVE:
+ return isCanEvolve();
+
+ case SCHEMA_GROUP:
+ return getSchemaGroup();
+
+ case DESCRIPTION:
+ return getDescription();
+
+ }
+ 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 SCHEMA_TYPE:
+ return isSetSchemaType();
+ case NAME:
+ return isSetName();
+ case DB_NAME:
+ return isSetDbName();
+ case COMPATIBILITY:
+ return isSetCompatibility();
+ case VALIDATION_LEVEL:
+ return isSetValidationLevel();
+ case CAN_EVOLVE:
+ return isSetCanEvolve();
+ case SCHEMA_GROUP:
+ return isSetSchemaGroup();
+ case DESCRIPTION:
+ return isSetDescription();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof ISchema)
+ return this.equals((ISchema)that);
+ return false;
+ }
+
+ public boolean equals(ISchema that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_schemaType = true && this.isSetSchemaType();
+ boolean that_present_schemaType = true && that.isSetSchemaType();
+ if (this_present_schemaType || that_present_schemaType) {
+ if (!(this_present_schemaType && that_present_schemaType))
+ return false;
+ if (!this.schemaType.equals(that.schemaType))
+ return false;
+ }
+
+ boolean this_present_name = true && this.isSetName();
+ boolean that_present_name = true && that.isSetName();
+ if (this_present_name || that_present_name) {
+ if (!(this_present_name && that_present_name))
+ return false;
+ if (!this.name.equals(that.name))
+ 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_compatibility = true && this.isSetCompatibility();
+ boolean that_present_compatibility = true && that.isSetCompatibility();
+ if (this_present_compatibility || that_present_compatibility) {
+ if (!(this_present_compatibility && that_present_compatibility))
+ return false;
+ if (!this.compatibility.equals(that.compatibility))
+ return false;
+ }
+
+ boolean this_present_validationLevel = true && this.isSetValidationLevel();
+ boolean that_present_validationLevel = true && that.isSetValidationLevel();
+ if (this_present_validationLevel || that_present_validationLevel) {
+ if (!(this_present_validationLevel && that_present_validationLevel))
+ return false;
+ if (!this.validationLevel.equals(that.validationLevel))
+ return false;
+ }
+
+ boolean this_present_canEvolve = true;
+ boolean that_present_canEvolve = true;
+ if (this_present_canEvolve || that_present_canEvolve) {
+ if (!(this_present_canEvolve && that_present_canEvolve))
+ return false;
+ if (this.canEvolve != that.canEvolve)
+ return false;
+ }
+
+ boolean this_present_schemaGroup = true && this.isSetSchemaGroup();
+ boolean that_present_schemaGroup = true && that.isSetSchemaGroup();
+ if (this_present_schemaGroup || that_present_schemaGroup) {
+ if (!(this_present_schemaGroup && that_present_schemaGroup))
+ return false;
+ if (!this.schemaGroup.equals(that.schemaGroup))
+ return false;
+ }
+
+ boolean this_present_description = true && this.isSetDescription();
+ boolean that_present_description = true && that.isSetDescription();
+ if (this_present_description || that_present_description) {
+ if (!(this_present_description && that_present_description))
+ return false;
+ if (!this.description.equals(that.description))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_schemaType = true && (isSetSchemaType());
+ list.add(present_schemaType);
+ if (present_schemaType)
+ list.add(schemaType.getValue());
+
+ boolean present_name = true && (isSetName());
+ list.add(present_name);
+ if (present_name)
+ list.add(name);
+
+ boolean present_dbName = true && (isSetDbName());
+ list.add(present_dbName);
+ if (present_dbName)
+ list.add(dbName);
+
+ boolean present_compatibility = true && (isSetCompatibility());
+ list.add(present_compatibility);
+ if (present_compatibility)
+ list.add(compatibility.getValue());
+
+ boolean present_validationLevel = true && (isSetValidationLevel());
+ list.add(present_validationLevel);
+ if (present_validationLevel)
+ list.add(validationLevel.getValue());
+
+ boolean present_canEvolve = true;
+ list.add(present_canEvolve);
+ if (present_canEvolve)
+ list.add(canEvolve);
+
+ boolean present_schemaGroup = true && (isSetSchemaGroup());
+ list.add(present_schemaGroup);
+ if (present_schemaGroup)
+ list.add(schemaGroup);
+
+ boolean present_description = true && (isSetDescription());
+ list.add(present_description);
+ if (present_description)
+ list.add(description);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(ISchema other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetSchemaType()).compareTo(other.isSetSchemaType());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetSchemaType()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.schemaType, other.schemaType);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetName()).compareTo(other.isSetName());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetName()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.name, other.name);
+ 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(isSetCompatibility()).compareTo(other.isSetCompatibility());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetCompatibility()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.compatibility, other.compatibility);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetValidationLevel()).compareTo(other.isSetValidationLevel());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetValidationLevel()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.validationLevel, other.validationLevel);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetCanEvolve()).compareTo(other.isSetCanEvolve());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetCanEvolve()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.canEvolve, other.canEvolve);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetSchemaGroup()).compareTo(other.isSetSchemaGroup());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetSchemaGroup()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.schemaGroup, other.schemaGroup);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetDescription()).compareTo(other.isSetDescription());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetDescription()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.description, other.description);
+ 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("ISchema(");
+ boolean first = true;
+
+ sb.append("schemaType:");
+ if (this.schemaType == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.schemaType);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("name:");
+ if (this.name == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.name);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("dbName:");
+ if (this.dbName == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.dbName);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("compatibility:");
+ if (this.compatibility == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.compatibility);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("validationLevel:");
+ if (this.validationLevel == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.validationLevel);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("canEvolve:");
+ sb.append(this.canEvolve);
+ first = false;
+ if (isSetSchemaGroup()) {
+ if (!first) sb.append(", ");
+ sb.append("schemaGroup:");
+ if (this.schemaGroup == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.schemaGroup);
+ }
+ first = false;
+ }
+ if (isSetDescription()) {
+ if (!first) sb.append(", ");
+ sb.append("description:");
+ if (this.description == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.description);
+ }
+ first = false;
+ }
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ // 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 ISchemaStandardSchemeFactory implements SchemeFactory {
+ public ISchemaStandardScheme getScheme() {
+ return new ISchemaStandardScheme();
+ }
+ }
+
+ private static class ISchemaStandardScheme extends StandardScheme<ISchema> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, ISchema 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: // SCHEMA_TYPE
+ if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+ struct.schemaType = org.apache.hadoop.hive.metastore.api.SchemaType.findByValue(iprot.readI32());
+ struct.setSchemaTypeIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.name = iprot.readString();
+ struct.setNameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // 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 4: // COMPATIBILITY
+ if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+ struct.compatibility = org.apache.hadoop.hive.metastore.api.SchemaCompatibility.findByValue(iprot.readI32());
+ struct.setCompatibilityIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 5: // VALIDATION_LEVEL
+ if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+ struct.validationLevel = org.apache.hadoop.hive.metastore.api.SchemaValidation.findByValue(iprot.readI32());
+ struct.setValidationLevelIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 6: // CAN_EVOLVE
+ if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
+ struct.canEvolve = iprot.readBool();
+ struct.setCanEvolveIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 7: // SCHEMA_GROUP
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.schemaGroup = iprot.readString();
+ struct.setSchemaGroupIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 8: // DESCRIPTION
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.description = iprot.readString();
+ struct.setDescriptionIsSet(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, ISchema struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.schemaType != null) {
+ oprot.writeFieldBegin(SCHEMA_TYPE_FIELD_DESC);
+ oprot.writeI32(struct.schemaType.getValue());
+ oprot.writeFieldEnd();
+ }
+ if (struct.name != null) {
+ oprot.writeFieldBegin(NAME_FIELD_DESC);
+ oprot.writeString(struct.name);
+ oprot.writeFieldEnd();
+ }
+ if (struct.dbName != null) {
+ oprot.writeFieldBegin(DB_NAME_FIELD_DESC);
+ oprot.writeString(struct.dbName);
+ oprot.writeFieldEnd();
+ }
+ if (struct.compatibility != null) {
+ oprot.writeFieldBegin(COMPATIBILITY_FIELD_DESC);
+ oprot.writeI32(struct.compatibility.getValue());
+ oprot.writeFieldEnd();
+ }
+ if (struct.validationLevel != null) {
+ oprot.writeFieldBegin(VALIDATION_LEVEL_FIELD_DESC);
+ oprot.writeI32(struct.validationLevel.getValue());
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldBegin(CAN_EVOLVE_FIELD_DESC);
+ oprot.writeBool(struct.canEvolve);
+ oprot.writeFieldEnd();
+ if (struct.schemaGroup != null) {
+ if (struct.isSetSchemaGroup()) {
+ oprot.writeFieldBegin(SCHEMA_GROUP_FIELD_DESC);
+ oprot.writeString(struct.schemaGroup);
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.description != null) {
+ if (struct.isSetDescription()) {
+ oprot.writeFieldBegin(DESCRIPTION_FIELD_DESC);
+ oprot.writeString(struct.description);
+ oprot.writeFieldEnd();
+ }
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class ISchemaTupleSchemeFactory implements SchemeFactory {
+ public ISchemaTupleScheme getScheme() {
+ return new ISchemaTupleScheme();
+ }
+ }
+
+ private static class ISchemaTupleScheme extends TupleScheme<ISchema> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, ISchema struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetSchemaType()) {
+ optionals.set(0);
+ }
+ if (struct.isSetName()) {
+ optionals.set(1);
+ }
+ if (struct.isSetDbName()) {
+ optionals.set(2);
+ }
+ if (struct.isSetCompatibility()) {
+ optionals.set(3);
+ }
+ if (struct.isSetValidationLevel()) {
+ optionals.set(4);
+ }
+ if (struct.isSetCanEvolve()) {
+ optionals.set(5);
+ }
+ if (struct.isSetSchemaGroup()) {
+ optionals.set(6);
+ }
+ if (struct.isSetDescription()) {
+ optionals.set(7);
+ }
+ oprot.writeBitSet(optionals, 8);
+ if (struct.isSetSchemaType()) {
+ oprot.writeI32(struct.schemaType.getValue());
+ }
+ if (struct.isSetName()) {
+ oprot.writeString(struct.name);
+ }
+ if (struct.isSetDbName()) {
+ oprot.writeString(struct.dbName);
+ }
+ if (struct.isSetCompatibility()) {
+ oprot.writeI32(struct.compatibility.getValue());
+ }
+ if (struct.isSetValidationLevel()) {
+ oprot.writeI32(struct.validationLevel.getValue());
+ }
+ if (struct.isSetCanEvolve()) {
+ oprot.writeBool(struct.canEvolve);
+ }
+ if (struct.isSetSchemaGroup()) {
+ oprot.writeString(struct.schemaGroup);
+ }
+ if (struct.isSetDescription()) {
+ oprot.writeString(struct.description);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, ISchema struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(8);
+ if (incoming.get(0)) {
+ struct.schemaType = org.apache.hadoop.hive.metastore.api.SchemaType.findByValue(iprot.readI32());
+ struct.setSchemaTypeIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.name = iprot.readString();
+ struct.setNameIsSet(true);
+ }
+ if (incoming.get(2)) {
+ struct.dbName = iprot.readString();
+ struct.setDbNameIsSet(true);
+ }
+ if (incoming.get(3)) {
+ struct.compatibility = org.apache.hadoop.hive.metastore.api.SchemaCompatibility.findByValue(iprot.readI32());
+ struct.setCompatibilityIsSet(true);
+ }
+ if (incoming.get(4)) {
+ struct.validationLevel = org.apache.hadoop.hive.metastore.api.SchemaValidation.findByValue(iprot.readI32());
+ struct.setValidationLevelIsSet(true);
+ }
+ if (incoming.get(5)) {
+ struct.canEvolve = iprot.readBool();
+ struct.setCanEvolveIsSet(true);
+ }
+ if (incoming.get(6)) {
+ struct.schemaGroup = iprot.readString();
+ struct.setSchemaGroupIsSet(true);
+ }
+ if (incoming.get(7)) {
+ struct.description = iprot.readString();
+ struct.setDescriptionIsSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/hive/blob/12041d39/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ISchemaName.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ISchemaName.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ISchemaName.java
new file mode 100644
index 0000000..ad25051
--- /dev/null
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ISchemaName.java
@@ -0,0 +1,499 @@
+/**
+ * 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 ISchemaName implements org.apache.thrift.TBase<ISchemaName, ISchemaName._Fields>, java.io.Serializable, Cloneable, Comparable<ISchemaName> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ISchemaName");
+
+ 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 SCHEMA_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("schemaName", 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 ISchemaNameStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new ISchemaNameTupleSchemeFactory());
+ }
+
+ private String dbName; // required
+ private String schemaName; // 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 {
+ DB_NAME((short)1, "dbName"),
+ SCHEMA_NAME((short)2, "schemaName");
+
+ 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: // SCHEMA_NAME
+ return SCHEMA_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
+ 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.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.SCHEMA_NAME, new org.apache.thrift.meta_data.FieldMetaData("schemaName", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ISchemaName.class, metaDataMap);
+ }
+
+ public ISchemaName() {
+ }
+
+ public ISchemaName(
+ String dbName,
+ String schemaName)
+ {
+ this();
+ this.dbName = dbName;
+ this.schemaName = schemaName;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public ISchemaName(ISchemaName other) {
+ if (other.isSetDbName()) {
+ this.dbName = other.dbName;
+ }
+ if (other.isSetSchemaName()) {
+ this.schemaName = other.schemaName;
+ }
+ }
+
+ public ISchemaName deepCopy() {
+ return new ISchemaName(this);
+ }
+
+ @Override
+ public void clear() {
+ this.dbName = null;
+ this.schemaName = 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 String getSchemaName() {
+ return this.schemaName;
+ }
+
+ public void setSchemaName(String schemaName) {
+ this.schemaName = schemaName;
+ }
+
+ public void unsetSchemaName() {
+ this.schemaName = null;
+ }
+
+ /** Returns true if field schemaName is set (has been assigned a value) and false otherwise */
+ public boolean isSetSchemaName() {
+ return this.schemaName != null;
+ }
+
+ public void setSchemaNameIsSet(boolean value) {
+ if (!value) {
+ this.schemaName = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case DB_NAME:
+ if (value == null) {
+ unsetDbName();
+ } else {
+ setDbName((String)value);
+ }
+ break;
+
+ case SCHEMA_NAME:
+ if (value == null) {
+ unsetSchemaName();
+ } else {
+ setSchemaName((String)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case DB_NAME:
+ return getDbName();
+
+ case SCHEMA_NAME:
+ return getSchemaName();
+
+ }
+ 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 SCHEMA_NAME:
+ return isSetSchemaName();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof ISchemaName)
+ return this.equals((ISchemaName)that);
+ return false;
+ }
+
+ public boolean equals(ISchemaName 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_schemaName = true && this.isSetSchemaName();
+ boolean that_present_schemaName = true && that.isSetSchemaName();
+ if (this_present_schemaName || that_present_schemaName) {
+ if (!(this_present_schemaName && that_present_schemaName))
+ return false;
+ if (!this.schemaName.equals(that.schemaName))
+ 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_schemaName = true && (isSetSchemaName());
+ list.add(present_schemaName);
+ if (present_schemaName)
+ list.add(schemaName);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(ISchemaName 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(isSetSchemaName()).compareTo(other.isSetSchemaName());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetSchemaName()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.schemaName, other.schemaName);
+ 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("ISchemaName(");
+ boolean first = true;
+
+ sb.append("dbName:");
+ if (this.dbName == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.dbName);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("schemaName:");
+ if (this.schemaName == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.schemaName);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ // 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 ISchemaNameStandardSchemeFactory implements SchemeFactory {
+ public ISchemaNameStandardScheme getScheme() {
+ return new ISchemaNameStandardScheme();
+ }
+ }
+
+ private static class ISchemaNameStandardScheme extends StandardScheme<ISchemaName> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, ISchemaName 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: // SCHEMA_NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.schemaName = iprot.readString();
+ struct.setSchemaNameIsSet(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, ISchemaName 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.schemaName != null) {
+ oprot.writeFieldBegin(SCHEMA_NAME_FIELD_DESC);
+ oprot.writeString(struct.schemaName);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class ISchemaNameTupleSchemeFactory implements SchemeFactory {
+ public ISchemaNameTupleScheme getScheme() {
+ return new ISchemaNameTupleScheme();
+ }
+ }
+
+ private static class ISchemaNameTupleScheme extends TupleScheme<ISchemaName> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, ISchemaName struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetDbName()) {
+ optionals.set(0);
+ }
+ if (struct.isSetSchemaName()) {
+ optionals.set(1);
+ }
+ oprot.writeBitSet(optionals, 2);
+ if (struct.isSetDbName()) {
+ oprot.writeString(struct.dbName);
+ }
+ if (struct.isSetSchemaName()) {
+ oprot.writeString(struct.schemaName);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, ISchemaName struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(2);
+ if (incoming.get(0)) {
+ struct.dbName = iprot.readString();
+ struct.setDbNameIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.schemaName = iprot.readString();
+ struct.setSchemaNameIsSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/hive/blob/12041d39/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/MapSchemaVersionToSerdeRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/MapSchemaVersionToSerdeRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/MapSchemaVersionToSerdeRequest.java
new file mode 100644
index 0000000..81eb732
--- /dev/null
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/MapSchemaVersionToSerdeRequest.java
@@ -0,0 +1,504 @@
+/**
+ * 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 MapSchemaVersionToSerdeRequest implements org.apache.thrift.TBase<MapSchemaVersionToSerdeRequest, MapSchemaVersionToSerdeRequest._Fields>, java.io.Serializable, Cloneable, Comparable<MapSchemaVersionToSerdeRequest> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("MapSchemaVersionToSerdeRequest");
+
+ private static final org.apache.thrift.protocol.TField SCHEMA_VERSION_FIELD_DESC = new org.apache.thrift.protocol.TField("schemaVersion", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+ private static final org.apache.thrift.protocol.TField SERDE_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("serdeName", 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 MapSchemaVersionToSerdeRequestStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new MapSchemaVersionToSerdeRequestTupleSchemeFactory());
+ }
+
+ private SchemaVersionDescriptor schemaVersion; // required
+ private String serdeName; // 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 {
+ SCHEMA_VERSION((short)1, "schemaVersion"),
+ SERDE_NAME((short)2, "serdeName");
+
+ 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: // SCHEMA_VERSION
+ return SCHEMA_VERSION;
+ case 2: // SERDE_NAME
+ return SERDE_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
+ 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.SCHEMA_VERSION, new org.apache.thrift.meta_data.FieldMetaData("schemaVersion", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, SchemaVersionDescriptor.class)));
+ tmpMap.put(_Fields.SERDE_NAME, new org.apache.thrift.meta_data.FieldMetaData("serdeName", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(MapSchemaVersionToSerdeRequest.class, metaDataMap);
+ }
+
+ public MapSchemaVersionToSerdeRequest() {
+ }
+
+ public MapSchemaVersionToSerdeRequest(
+ SchemaVersionDescriptor schemaVersion,
+ String serdeName)
+ {
+ this();
+ this.schemaVersion = schemaVersion;
+ this.serdeName = serdeName;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public MapSchemaVersionToSerdeRequest(MapSchemaVersionToSerdeRequest other) {
+ if (other.isSetSchemaVersion()) {
+ this.schemaVersion = new SchemaVersionDescriptor(other.schemaVersion);
+ }
+ if (other.isSetSerdeName()) {
+ this.serdeName = other.serdeName;
+ }
+ }
+
+ public MapSchemaVersionToSerdeRequest deepCopy() {
+ return new MapSchemaVersionToSerdeRequest(this);
+ }
+
+ @Override
+ public void clear() {
+ this.schemaVersion = null;
+ this.serdeName = null;
+ }
+
+ public SchemaVersionDescriptor getSchemaVersion() {
+ return this.schemaVersion;
+ }
+
+ public void setSchemaVersion(SchemaVersionDescriptor schemaVersion) {
+ this.schemaVersion = schemaVersion;
+ }
+
+ public void unsetSchemaVersion() {
+ this.schemaVersion = null;
+ }
+
+ /** Returns true if field schemaVersion is set (has been assigned a value) and false otherwise */
+ public boolean isSetSchemaVersion() {
+ return this.schemaVersion != null;
+ }
+
+ public void setSchemaVersionIsSet(boolean value) {
+ if (!value) {
+ this.schemaVersion = null;
+ }
+ }
+
+ public String getSerdeName() {
+ return this.serdeName;
+ }
+
+ public void setSerdeName(String serdeName) {
+ this.serdeName = serdeName;
+ }
+
+ public void unsetSerdeName() {
+ this.serdeName = null;
+ }
+
+ /** Returns true if field serdeName is set (has been assigned a value) and false otherwise */
+ public boolean isSetSerdeName() {
+ return this.serdeName != null;
+ }
+
+ public void setSerdeNameIsSet(boolean value) {
+ if (!value) {
+ this.serdeName = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case SCHEMA_VERSION:
+ if (value == null) {
+ unsetSchemaVersion();
+ } else {
+ setSchemaVersion((SchemaVersionDescriptor)value);
+ }
+ break;
+
+ case SERDE_NAME:
+ if (value == null) {
+ unsetSerdeName();
+ } else {
+ setSerdeName((String)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case SCHEMA_VERSION:
+ return getSchemaVersion();
+
+ case SERDE_NAME:
+ return getSerdeName();
+
+ }
+ 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 SCHEMA_VERSION:
+ return isSetSchemaVersion();
+ case SERDE_NAME:
+ return isSetSerdeName();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof MapSchemaVersionToSerdeRequest)
+ return this.equals((MapSchemaVersionToSerdeRequest)that);
+ return false;
+ }
+
+ public boolean equals(MapSchemaVersionToSerdeRequest that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_schemaVersion = true && this.isSetSchemaVersion();
+ boolean that_present_schemaVersion = true && that.isSetSchemaVersion();
+ if (this_present_schemaVersion || that_present_schemaVersion) {
+ if (!(this_present_schemaVersion && that_present_schemaVersion))
+ return false;
+ if (!this.schemaVersion.equals(that.schemaVersion))
+ return false;
+ }
+
+ boolean this_present_serdeName = true && this.isSetSerdeName();
+ boolean that_present_serdeName = true && that.isSetSerdeName();
+ if (this_present_serdeName || that_present_serdeName) {
+ if (!(this_present_serdeName && that_present_serdeName))
+ return false;
+ if (!this.serdeName.equals(that.serdeName))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_schemaVersion = true && (isSetSchemaVersion());
+ list.add(present_schemaVersion);
+ if (present_schemaVersion)
+ list.add(schemaVersion);
+
+ boolean present_serdeName = true && (isSetSerdeName());
+ list.add(present_serdeName);
+ if (present_serdeName)
+ list.add(serdeName);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(MapSchemaVersionToSerdeRequest other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetSchemaVersion()).compareTo(other.isSetSchemaVersion());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetSchemaVersion()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.schemaVersion, other.schemaVersion);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetSerdeName()).compareTo(other.isSetSerdeName());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetSerdeName()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.serdeName, other.serdeName);
+ 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("MapSchemaVersionToSerdeRequest(");
+ boolean first = true;
+
+ sb.append("schemaVersion:");
+ if (this.schemaVersion == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.schemaVersion);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("serdeName:");
+ if (this.serdeName == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.serdeName);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ // check for sub-struct validity
+ if (schemaVersion != null) {
+ schemaVersion.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 MapSchemaVersionToSerdeRequestStandardSchemeFactory implements SchemeFactory {
+ public MapSchemaVersionToSerdeRequestStandardScheme getScheme() {
+ return new MapSchemaVersionToSerdeRequestStandardScheme();
+ }
+ }
+
+ private static class MapSchemaVersionToSerdeRequestStandardScheme extends StandardScheme<MapSchemaVersionToSerdeRequest> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, MapSchemaVersionToSerdeRequest 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: // SCHEMA_VERSION
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.schemaVersion = new SchemaVersionDescriptor();
+ struct.schemaVersion.read(iprot);
+ struct.setSchemaVersionIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // SERDE_NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.serdeName = iprot.readString();
+ struct.setSerdeNameIsSet(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, MapSchemaVersionToSerdeRequest struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.schemaVersion != null) {
+ oprot.writeFieldBegin(SCHEMA_VERSION_FIELD_DESC);
+ struct.schemaVersion.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ if (struct.serdeName != null) {
+ oprot.writeFieldBegin(SERDE_NAME_FIELD_DESC);
+ oprot.writeString(struct.serdeName);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class MapSchemaVersionToSerdeRequestTupleSchemeFactory implements SchemeFactory {
+ public MapSchemaVersionToSerdeRequestTupleScheme getScheme() {
+ return new MapSchemaVersionToSerdeRequestTupleScheme();
+ }
+ }
+
+ private static class MapSchemaVersionToSerdeRequestTupleScheme extends TupleScheme<MapSchemaVersionToSerdeRequest> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, MapSchemaVersionToSerdeRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetSchemaVersion()) {
+ optionals.set(0);
+ }
+ if (struct.isSetSerdeName()) {
+ optionals.set(1);
+ }
+ oprot.writeBitSet(optionals, 2);
+ if (struct.isSetSchemaVersion()) {
+ struct.schemaVersion.write(oprot);
+ }
+ if (struct.isSetSerdeName()) {
+ oprot.writeString(struct.serdeName);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, MapSchemaVersionToSerdeRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(2);
+ if (incoming.get(0)) {
+ struct.schemaVersion = new SchemaVersionDescriptor();
+ struct.schemaVersion.read(iprot);
+ struct.setSchemaVersionIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.serdeName = iprot.readString();
+ struct.setSerdeNameIsSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/hive/blob/12041d39/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaCompatibility.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaCompatibility.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaCompatibility.java
new file mode 100644
index 0000000..4c0bb5a
--- /dev/null
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaCompatibility.java
@@ -0,0 +1,51 @@
+/**
+ * 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 java.util.Map;
+import java.util.HashMap;
+import org.apache.thrift.TEnum;
+
+public enum SchemaCompatibility implements org.apache.thrift.TEnum {
+ NONE(1),
+ BACKWARD(2),
+ FORWARD(3),
+ BOTH(4);
+
+ private final int value;
+
+ private SchemaCompatibility(int value) {
+ this.value = value;
+ }
+
+ /**
+ * Get the integer value of this enum value, as defined in the Thrift IDL.
+ */
+ public int getValue() {
+ return value;
+ }
+
+ /**
+ * Find a the enum type by its integer value, as defined in the Thrift IDL.
+ * @return null if the value is not found.
+ */
+ public static SchemaCompatibility findByValue(int value) {
+ switch (value) {
+ case 1:
+ return NONE;
+ case 2:
+ return BACKWARD;
+ case 3:
+ return FORWARD;
+ case 4:
+ return BOTH;
+ default:
+ return null;
+ }
+ }
+}
http://git-wip-us.apache.org/repos/asf/hive/blob/12041d39/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaType.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaType.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaType.java
new file mode 100644
index 0000000..f4adeb9
--- /dev/null
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaType.java
@@ -0,0 +1,45 @@
+/**
+ * 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 java.util.Map;
+import java.util.HashMap;
+import org.apache.thrift.TEnum;
+
+public enum SchemaType implements org.apache.thrift.TEnum {
+ HIVE(1),
+ AVRO(2);
+
+ private final int value;
+
+ private SchemaType(int value) {
+ this.value = value;
+ }
+
+ /**
+ * Get the integer value of this enum value, as defined in the Thrift IDL.
+ */
+ public int getValue() {
+ return value;
+ }
+
+ /**
+ * Find a the enum type by its integer value, as defined in the Thrift IDL.
+ * @return null if the value is not found.
+ */
+ public static SchemaType findByValue(int value) {
+ switch (value) {
+ case 1:
+ return HIVE;
+ case 2:
+ return AVRO;
+ default:
+ return null;
+ }
+ }
+}
http://git-wip-us.apache.org/repos/asf/hive/blob/12041d39/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaValidation.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaValidation.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaValidation.java
new file mode 100644
index 0000000..1983f56
--- /dev/null
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaValidation.java
@@ -0,0 +1,45 @@
+/**
+ * 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 java.util.Map;
+import java.util.HashMap;
+import org.apache.thrift.TEnum;
+
+public enum SchemaValidation implements org.apache.thrift.TEnum {
+ LATEST(1),
+ ALL(2);
+
+ private final int value;
+
+ private SchemaValidation(int value) {
+ this.value = value;
+ }
+
+ /**
+ * Get the integer value of this enum value, as defined in the Thrift IDL.
+ */
+ public int getValue() {
+ return value;
+ }
+
+ /**
+ * Find a the enum type by its integer value, as defined in the Thrift IDL.
+ * @return null if the value is not found.
+ */
+ public static SchemaValidation findByValue(int value) {
+ switch (value) {
+ case 1:
+ return LATEST;
+ case 2:
+ return ALL;
+ default:
+ return null;
+ }
+ }
+}