You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by vg...@apache.org on 2018/03/04 07:26:06 UTC
[12/19] hive git commit: HIVE-18726 : Implement DEFAULT constraint (Vineet Garg, reviewed by Ashutosh Chauhan, Jesús Camacho Rodríguez)
http://git-wip-us.apache.org/repos/asf/hive/blob/4047befe/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h b/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
index 835cbb3..7c38d5b 100644
--- a/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
+++ b/standalone-metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
@@ -198,6 +198,8 @@ class SQLUniqueConstraint;
class SQLNotNullConstraint;
+class SQLDefaultConstraint;
+
class Type;
class HiveObjectRef;
@@ -304,6 +306,10 @@ class NotNullConstraintsRequest;
class NotNullConstraintsResponse;
+class DefaultConstraintsRequest;
+
+class DefaultConstraintsResponse;
+
class DropConstraintRequest;
class AddPrimaryKeyRequest;
@@ -314,6 +320,8 @@ class AddUniqueConstraintRequest;
class AddNotNullConstraintRequest;
+class AddDefaultConstraintRequest;
+
class PartitionsByExprResult;
class PartitionsByExprRequest;
@@ -1084,6 +1092,94 @@ inline std::ostream& operator<<(std::ostream& out, const SQLNotNullConstraint& o
return out;
}
+typedef struct _SQLDefaultConstraint__isset {
+ _SQLDefaultConstraint__isset() : table_db(false), table_name(false), column_name(false), default_value(false), dc_name(false), enable_cstr(false), validate_cstr(false), rely_cstr(false) {}
+ bool table_db :1;
+ bool table_name :1;
+ bool column_name :1;
+ bool default_value :1;
+ bool dc_name :1;
+ bool enable_cstr :1;
+ bool validate_cstr :1;
+ bool rely_cstr :1;
+} _SQLDefaultConstraint__isset;
+
+class SQLDefaultConstraint {
+ public:
+
+ SQLDefaultConstraint(const SQLDefaultConstraint&);
+ SQLDefaultConstraint& operator=(const SQLDefaultConstraint&);
+ SQLDefaultConstraint() : table_db(), table_name(), column_name(), default_value(), dc_name(), enable_cstr(0), validate_cstr(0), rely_cstr(0) {
+ }
+
+ virtual ~SQLDefaultConstraint() throw();
+ std::string table_db;
+ std::string table_name;
+ std::string column_name;
+ std::string default_value;
+ std::string dc_name;
+ bool enable_cstr;
+ bool validate_cstr;
+ bool rely_cstr;
+
+ _SQLDefaultConstraint__isset __isset;
+
+ void __set_table_db(const std::string& val);
+
+ void __set_table_name(const std::string& val);
+
+ void __set_column_name(const std::string& val);
+
+ void __set_default_value(const std::string& val);
+
+ void __set_dc_name(const std::string& val);
+
+ void __set_enable_cstr(const bool val);
+
+ void __set_validate_cstr(const bool val);
+
+ void __set_rely_cstr(const bool val);
+
+ bool operator == (const SQLDefaultConstraint & rhs) const
+ {
+ if (!(table_db == rhs.table_db))
+ return false;
+ if (!(table_name == rhs.table_name))
+ return false;
+ if (!(column_name == rhs.column_name))
+ return false;
+ if (!(default_value == rhs.default_value))
+ return false;
+ if (!(dc_name == rhs.dc_name))
+ return false;
+ if (!(enable_cstr == rhs.enable_cstr))
+ return false;
+ if (!(validate_cstr == rhs.validate_cstr))
+ return false;
+ if (!(rely_cstr == rhs.rely_cstr))
+ return false;
+ return true;
+ }
+ bool operator != (const SQLDefaultConstraint &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const SQLDefaultConstraint & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+ virtual void printTo(std::ostream& out) const;
+};
+
+void swap(SQLDefaultConstraint &a, SQLDefaultConstraint &b);
+
+inline std::ostream& operator<<(std::ostream& out, const SQLDefaultConstraint& obj)
+{
+ obj.printTo(out);
+ return out;
+}
+
typedef struct _Type__isset {
_Type__isset() : name(false), type1(false), type2(false), fields(false) {}
bool name :1;
@@ -4346,6 +4442,91 @@ inline std::ostream& operator<<(std::ostream& out, const NotNullConstraintsRespo
}
+class DefaultConstraintsRequest {
+ public:
+
+ DefaultConstraintsRequest(const DefaultConstraintsRequest&);
+ DefaultConstraintsRequest& operator=(const DefaultConstraintsRequest&);
+ DefaultConstraintsRequest() : db_name(), tbl_name() {
+ }
+
+ virtual ~DefaultConstraintsRequest() throw();
+ std::string db_name;
+ std::string tbl_name;
+
+ void __set_db_name(const std::string& val);
+
+ void __set_tbl_name(const std::string& val);
+
+ bool operator == (const DefaultConstraintsRequest & rhs) const
+ {
+ if (!(db_name == rhs.db_name))
+ return false;
+ if (!(tbl_name == rhs.tbl_name))
+ return false;
+ return true;
+ }
+ bool operator != (const DefaultConstraintsRequest &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const DefaultConstraintsRequest & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+ virtual void printTo(std::ostream& out) const;
+};
+
+void swap(DefaultConstraintsRequest &a, DefaultConstraintsRequest &b);
+
+inline std::ostream& operator<<(std::ostream& out, const DefaultConstraintsRequest& obj)
+{
+ obj.printTo(out);
+ return out;
+}
+
+
+class DefaultConstraintsResponse {
+ public:
+
+ DefaultConstraintsResponse(const DefaultConstraintsResponse&);
+ DefaultConstraintsResponse& operator=(const DefaultConstraintsResponse&);
+ DefaultConstraintsResponse() {
+ }
+
+ virtual ~DefaultConstraintsResponse() throw();
+ std::vector<SQLDefaultConstraint> defaultConstraints;
+
+ void __set_defaultConstraints(const std::vector<SQLDefaultConstraint> & val);
+
+ bool operator == (const DefaultConstraintsResponse & rhs) const
+ {
+ if (!(defaultConstraints == rhs.defaultConstraints))
+ return false;
+ return true;
+ }
+ bool operator != (const DefaultConstraintsResponse &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const DefaultConstraintsResponse & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+ virtual void printTo(std::ostream& out) const;
+};
+
+void swap(DefaultConstraintsResponse &a, DefaultConstraintsResponse &b);
+
+inline std::ostream& operator<<(std::ostream& out, const DefaultConstraintsResponse& obj)
+{
+ obj.printTo(out);
+ return out;
+}
+
+
class DropConstraintRequest {
public:
@@ -4556,6 +4737,46 @@ inline std::ostream& operator<<(std::ostream& out, const AddNotNullConstraintReq
}
+class AddDefaultConstraintRequest {
+ public:
+
+ AddDefaultConstraintRequest(const AddDefaultConstraintRequest&);
+ AddDefaultConstraintRequest& operator=(const AddDefaultConstraintRequest&);
+ AddDefaultConstraintRequest() {
+ }
+
+ virtual ~AddDefaultConstraintRequest() throw();
+ std::vector<SQLDefaultConstraint> defaultConstraintCols;
+
+ void __set_defaultConstraintCols(const std::vector<SQLDefaultConstraint> & val);
+
+ bool operator == (const AddDefaultConstraintRequest & rhs) const
+ {
+ if (!(defaultConstraintCols == rhs.defaultConstraintCols))
+ return false;
+ return true;
+ }
+ bool operator != (const AddDefaultConstraintRequest &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const AddDefaultConstraintRequest & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+ virtual void printTo(std::ostream& out) const;
+};
+
+void swap(AddDefaultConstraintRequest &a, AddDefaultConstraintRequest &b);
+
+inline std::ostream& operator<<(std::ostream& out, const AddDefaultConstraintRequest& obj)
+{
+ obj.printTo(out);
+ return out;
+}
+
+
class PartitionsByExprResult {
public:
http://git-wip-us.apache.org/repos/asf/hive/blob/4047befe/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java
index 0e5dbf7..29e4e69 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnsRequest.java
@@ -351,13 +351,13 @@ import org.slf4j.LoggerFactory;
case 1: // TXN_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list548 = iprot.readListBegin();
- struct.txn_ids = new ArrayList<Long>(_list548.size);
- long _elem549;
- for (int _i550 = 0; _i550 < _list548.size; ++_i550)
+ org.apache.thrift.protocol.TList _list564 = iprot.readListBegin();
+ struct.txn_ids = new ArrayList<Long>(_list564.size);
+ long _elem565;
+ for (int _i566 = 0; _i566 < _list564.size; ++_i566)
{
- _elem549 = iprot.readI64();
- struct.txn_ids.add(_elem549);
+ _elem565 = iprot.readI64();
+ struct.txn_ids.add(_elem565);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TXN_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.txn_ids.size()));
- for (long _iter551 : struct.txn_ids)
+ for (long _iter567 : struct.txn_ids)
{
- oprot.writeI64(_iter551);
+ oprot.writeI64(_iter567);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.txn_ids.size());
- for (long _iter552 : struct.txn_ids)
+ for (long _iter568 : struct.txn_ids)
{
- oprot.writeI64(_iter552);
+ oprot.writeI64(_iter568);
}
}
}
@@ -421,13 +421,13 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, AbortTxnsRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list553 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.txn_ids = new ArrayList<Long>(_list553.size);
- long _elem554;
- for (int _i555 = 0; _i555 < _list553.size; ++_i555)
+ org.apache.thrift.protocol.TList _list569 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.txn_ids = new ArrayList<Long>(_list569.size);
+ long _elem570;
+ for (int _i571 = 0; _i571 < _list569.size; ++_i571)
{
- _elem554 = iprot.readI64();
- struct.txn_ids.add(_elem554);
+ _elem570 = iprot.readI64();
+ struct.txn_ids.add(_elem570);
}
}
struct.setTxn_idsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4047befe/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDefaultConstraintRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDefaultConstraintRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDefaultConstraintRequest.java
new file mode 100644
index 0000000..8703b61
--- /dev/null
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDefaultConstraintRequest.java
@@ -0,0 +1,443 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.hadoop.hive.metastore.api;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class AddDefaultConstraintRequest implements org.apache.thrift.TBase<AddDefaultConstraintRequest, AddDefaultConstraintRequest._Fields>, java.io.Serializable, Cloneable, Comparable<AddDefaultConstraintRequest> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AddDefaultConstraintRequest");
+
+ private static final org.apache.thrift.protocol.TField DEFAULT_CONSTRAINT_COLS_FIELD_DESC = new org.apache.thrift.protocol.TField("defaultConstraintCols", org.apache.thrift.protocol.TType.LIST, (short)1);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new AddDefaultConstraintRequestStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new AddDefaultConstraintRequestTupleSchemeFactory());
+ }
+
+ private List<SQLDefaultConstraint> defaultConstraintCols; // required
+
+ /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+ public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ DEFAULT_CONSTRAINT_COLS((short)1, "defaultConstraintCols");
+
+ private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+ static {
+ for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ byName.put(field.getFieldName(), field);
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, or null if its not found.
+ */
+ public static _Fields findByThriftId(int fieldId) {
+ switch(fieldId) {
+ case 1: // DEFAULT_CONSTRAINT_COLS
+ return DEFAULT_CONSTRAINT_COLS;
+ default:
+ return null;
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, throwing an exception
+ * if it is not found.
+ */
+ public static _Fields findByThriftIdOrThrow(int fieldId) {
+ _Fields fields = findByThriftId(fieldId);
+ if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ return fields;
+ }
+
+ /**
+ * Find the _Fields constant that matches name, or null if its not found.
+ */
+ public static _Fields findByName(String name) {
+ return byName.get(name);
+ }
+
+ private final short _thriftId;
+ private final String _fieldName;
+
+ _Fields(short thriftId, String fieldName) {
+ _thriftId = thriftId;
+ _fieldName = fieldName;
+ }
+
+ public short getThriftFieldId() {
+ return _thriftId;
+ }
+
+ public String getFieldName() {
+ return _fieldName;
+ }
+ }
+
+ // isset id assignments
+ public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ static {
+ Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.DEFAULT_CONSTRAINT_COLS, new org.apache.thrift.meta_data.FieldMetaData("defaultConstraintCols", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, SQLDefaultConstraint.class))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AddDefaultConstraintRequest.class, metaDataMap);
+ }
+
+ public AddDefaultConstraintRequest() {
+ }
+
+ public AddDefaultConstraintRequest(
+ List<SQLDefaultConstraint> defaultConstraintCols)
+ {
+ this();
+ this.defaultConstraintCols = defaultConstraintCols;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public AddDefaultConstraintRequest(AddDefaultConstraintRequest other) {
+ if (other.isSetDefaultConstraintCols()) {
+ List<SQLDefaultConstraint> __this__defaultConstraintCols = new ArrayList<SQLDefaultConstraint>(other.defaultConstraintCols.size());
+ for (SQLDefaultConstraint other_element : other.defaultConstraintCols) {
+ __this__defaultConstraintCols.add(new SQLDefaultConstraint(other_element));
+ }
+ this.defaultConstraintCols = __this__defaultConstraintCols;
+ }
+ }
+
+ public AddDefaultConstraintRequest deepCopy() {
+ return new AddDefaultConstraintRequest(this);
+ }
+
+ @Override
+ public void clear() {
+ this.defaultConstraintCols = null;
+ }
+
+ public int getDefaultConstraintColsSize() {
+ return (this.defaultConstraintCols == null) ? 0 : this.defaultConstraintCols.size();
+ }
+
+ public java.util.Iterator<SQLDefaultConstraint> getDefaultConstraintColsIterator() {
+ return (this.defaultConstraintCols == null) ? null : this.defaultConstraintCols.iterator();
+ }
+
+ public void addToDefaultConstraintCols(SQLDefaultConstraint elem) {
+ if (this.defaultConstraintCols == null) {
+ this.defaultConstraintCols = new ArrayList<SQLDefaultConstraint>();
+ }
+ this.defaultConstraintCols.add(elem);
+ }
+
+ public List<SQLDefaultConstraint> getDefaultConstraintCols() {
+ return this.defaultConstraintCols;
+ }
+
+ public void setDefaultConstraintCols(List<SQLDefaultConstraint> defaultConstraintCols) {
+ this.defaultConstraintCols = defaultConstraintCols;
+ }
+
+ public void unsetDefaultConstraintCols() {
+ this.defaultConstraintCols = null;
+ }
+
+ /** Returns true if field defaultConstraintCols is set (has been assigned a value) and false otherwise */
+ public boolean isSetDefaultConstraintCols() {
+ return this.defaultConstraintCols != null;
+ }
+
+ public void setDefaultConstraintColsIsSet(boolean value) {
+ if (!value) {
+ this.defaultConstraintCols = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case DEFAULT_CONSTRAINT_COLS:
+ if (value == null) {
+ unsetDefaultConstraintCols();
+ } else {
+ setDefaultConstraintCols((List<SQLDefaultConstraint>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case DEFAULT_CONSTRAINT_COLS:
+ return getDefaultConstraintCols();
+
+ }
+ throw new IllegalStateException();
+ }
+
+ /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
+ public boolean isSet(_Fields field) {
+ if (field == null) {
+ throw new IllegalArgumentException();
+ }
+
+ switch (field) {
+ case DEFAULT_CONSTRAINT_COLS:
+ return isSetDefaultConstraintCols();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof AddDefaultConstraintRequest)
+ return this.equals((AddDefaultConstraintRequest)that);
+ return false;
+ }
+
+ public boolean equals(AddDefaultConstraintRequest that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_defaultConstraintCols = true && this.isSetDefaultConstraintCols();
+ boolean that_present_defaultConstraintCols = true && that.isSetDefaultConstraintCols();
+ if (this_present_defaultConstraintCols || that_present_defaultConstraintCols) {
+ if (!(this_present_defaultConstraintCols && that_present_defaultConstraintCols))
+ return false;
+ if (!this.defaultConstraintCols.equals(that.defaultConstraintCols))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_defaultConstraintCols = true && (isSetDefaultConstraintCols());
+ list.add(present_defaultConstraintCols);
+ if (present_defaultConstraintCols)
+ list.add(defaultConstraintCols);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(AddDefaultConstraintRequest other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetDefaultConstraintCols()).compareTo(other.isSetDefaultConstraintCols());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetDefaultConstraintCols()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.defaultConstraintCols, other.defaultConstraintCols);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ return 0;
+ }
+
+ public _Fields fieldForId(int fieldId) {
+ return _Fields.findByThriftId(fieldId);
+ }
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("AddDefaultConstraintRequest(");
+ boolean first = true;
+
+ sb.append("defaultConstraintCols:");
+ if (this.defaultConstraintCols == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.defaultConstraintCols);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetDefaultConstraintCols()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'defaultConstraintCols' is unset! Struct:" + toString());
+ }
+
+ // check for sub-struct validity
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class AddDefaultConstraintRequestStandardSchemeFactory implements SchemeFactory {
+ public AddDefaultConstraintRequestStandardScheme getScheme() {
+ return new AddDefaultConstraintRequestStandardScheme();
+ }
+ }
+
+ private static class AddDefaultConstraintRequestStandardScheme extends StandardScheme<AddDefaultConstraintRequest> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, AddDefaultConstraintRequest struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // DEFAULT_CONSTRAINT_COLS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list394 = iprot.readListBegin();
+ struct.defaultConstraintCols = new ArrayList<SQLDefaultConstraint>(_list394.size);
+ SQLDefaultConstraint _elem395;
+ for (int _i396 = 0; _i396 < _list394.size; ++_i396)
+ {
+ _elem395 = new SQLDefaultConstraint();
+ _elem395.read(iprot);
+ struct.defaultConstraintCols.add(_elem395);
+ }
+ iprot.readListEnd();
+ }
+ struct.setDefaultConstraintColsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, AddDefaultConstraintRequest struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.defaultConstraintCols != null) {
+ oprot.writeFieldBegin(DEFAULT_CONSTRAINT_COLS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.defaultConstraintCols.size()));
+ for (SQLDefaultConstraint _iter397 : struct.defaultConstraintCols)
+ {
+ _iter397.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class AddDefaultConstraintRequestTupleSchemeFactory implements SchemeFactory {
+ public AddDefaultConstraintRequestTupleScheme getScheme() {
+ return new AddDefaultConstraintRequestTupleScheme();
+ }
+ }
+
+ private static class AddDefaultConstraintRequestTupleScheme extends TupleScheme<AddDefaultConstraintRequest> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, AddDefaultConstraintRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ {
+ oprot.writeI32(struct.defaultConstraintCols.size());
+ for (SQLDefaultConstraint _iter398 : struct.defaultConstraintCols)
+ {
+ _iter398.write(oprot);
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, AddDefaultConstraintRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ {
+ org.apache.thrift.protocol.TList _list399 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.defaultConstraintCols = new ArrayList<SQLDefaultConstraint>(_list399.size);
+ SQLDefaultConstraint _elem400;
+ for (int _i401 = 0; _i401 < _list399.size; ++_i401)
+ {
+ _elem400 = new SQLDefaultConstraint();
+ _elem400.read(iprot);
+ struct.defaultConstraintCols.add(_elem400);
+ }
+ }
+ struct.setDefaultConstraintColsIsSet(true);
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/hive/blob/4047befe/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java
index a01dc24..99c0741 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java
@@ -816,13 +816,13 @@ import org.slf4j.LoggerFactory;
case 5: // PARTITIONNAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list646 = iprot.readListBegin();
- struct.partitionnames = new ArrayList<String>(_list646.size);
- String _elem647;
- for (int _i648 = 0; _i648 < _list646.size; ++_i648)
+ org.apache.thrift.protocol.TList _list662 = iprot.readListBegin();
+ struct.partitionnames = new ArrayList<String>(_list662.size);
+ String _elem663;
+ for (int _i664 = 0; _i664 < _list662.size; ++_i664)
{
- _elem647 = iprot.readString();
- struct.partitionnames.add(_elem647);
+ _elem663 = iprot.readString();
+ struct.partitionnames.add(_elem663);
}
iprot.readListEnd();
}
@@ -872,9 +872,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PARTITIONNAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partitionnames.size()));
- for (String _iter649 : struct.partitionnames)
+ for (String _iter665 : struct.partitionnames)
{
- oprot.writeString(_iter649);
+ oprot.writeString(_iter665);
}
oprot.writeListEnd();
}
@@ -910,9 +910,9 @@ import org.slf4j.LoggerFactory;
oprot.writeString(struct.tablename);
{
oprot.writeI32(struct.partitionnames.size());
- for (String _iter650 : struct.partitionnames)
+ for (String _iter666 : struct.partitionnames)
{
- oprot.writeString(_iter650);
+ oprot.writeString(_iter666);
}
}
BitSet optionals = new BitSet();
@@ -937,13 +937,13 @@ import org.slf4j.LoggerFactory;
struct.tablename = iprot.readString();
struct.setTablenameIsSet(true);
{
- org.apache.thrift.protocol.TList _list651 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partitionnames = new ArrayList<String>(_list651.size);
- String _elem652;
- for (int _i653 = 0; _i653 < _list651.size; ++_i653)
+ org.apache.thrift.protocol.TList _list667 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partitionnames = new ArrayList<String>(_list667.size);
+ String _elem668;
+ for (int _i669 = 0; _i669 < _list667.size; ++_i669)
{
- _elem652 = iprot.readString();
- struct.partitionnames.add(_elem652);
+ _elem668 = iprot.readString();
+ struct.partitionnames.add(_elem668);
}
}
struct.setPartitionnamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4047befe/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddForeignKeyRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddForeignKeyRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddForeignKeyRequest.java
index c1c0dbf..2bcdea1 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddForeignKeyRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddForeignKeyRequest.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // FOREIGN_KEY_COLS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list362 = iprot.readListBegin();
- struct.foreignKeyCols = new ArrayList<SQLForeignKey>(_list362.size);
- SQLForeignKey _elem363;
- for (int _i364 = 0; _i364 < _list362.size; ++_i364)
+ org.apache.thrift.protocol.TList _list370 = iprot.readListBegin();
+ struct.foreignKeyCols = new ArrayList<SQLForeignKey>(_list370.size);
+ SQLForeignKey _elem371;
+ for (int _i372 = 0; _i372 < _list370.size; ++_i372)
{
- _elem363 = new SQLForeignKey();
- _elem363.read(iprot);
- struct.foreignKeyCols.add(_elem363);
+ _elem371 = new SQLForeignKey();
+ _elem371.read(iprot);
+ struct.foreignKeyCols.add(_elem371);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FOREIGN_KEY_COLS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.foreignKeyCols.size()));
- for (SQLForeignKey _iter365 : struct.foreignKeyCols)
+ for (SQLForeignKey _iter373 : struct.foreignKeyCols)
{
- _iter365.write(oprot);
+ _iter373.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.foreignKeyCols.size());
- for (SQLForeignKey _iter366 : struct.foreignKeyCols)
+ for (SQLForeignKey _iter374 : struct.foreignKeyCols)
{
- _iter366.write(oprot);
+ _iter374.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, AddForeignKeyRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list367 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.foreignKeyCols = new ArrayList<SQLForeignKey>(_list367.size);
- SQLForeignKey _elem368;
- for (int _i369 = 0; _i369 < _list367.size; ++_i369)
+ org.apache.thrift.protocol.TList _list375 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.foreignKeyCols = new ArrayList<SQLForeignKey>(_list375.size);
+ SQLForeignKey _elem376;
+ for (int _i377 = 0; _i377 < _list375.size; ++_i377)
{
- _elem368 = new SQLForeignKey();
- _elem368.read(iprot);
- struct.foreignKeyCols.add(_elem368);
+ _elem376 = new SQLForeignKey();
+ _elem376.read(iprot);
+ struct.foreignKeyCols.add(_elem376);
}
}
struct.setForeignKeyColsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4047befe/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddNotNullConstraintRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddNotNullConstraintRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddNotNullConstraintRequest.java
index 0bd85f3..f944e46 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddNotNullConstraintRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddNotNullConstraintRequest.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // NOT_NULL_CONSTRAINT_COLS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list378 = iprot.readListBegin();
- struct.notNullConstraintCols = new ArrayList<SQLNotNullConstraint>(_list378.size);
- SQLNotNullConstraint _elem379;
- for (int _i380 = 0; _i380 < _list378.size; ++_i380)
+ org.apache.thrift.protocol.TList _list386 = iprot.readListBegin();
+ struct.notNullConstraintCols = new ArrayList<SQLNotNullConstraint>(_list386.size);
+ SQLNotNullConstraint _elem387;
+ for (int _i388 = 0; _i388 < _list386.size; ++_i388)
{
- _elem379 = new SQLNotNullConstraint();
- _elem379.read(iprot);
- struct.notNullConstraintCols.add(_elem379);
+ _elem387 = new SQLNotNullConstraint();
+ _elem387.read(iprot);
+ struct.notNullConstraintCols.add(_elem387);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(NOT_NULL_CONSTRAINT_COLS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.notNullConstraintCols.size()));
- for (SQLNotNullConstraint _iter381 : struct.notNullConstraintCols)
+ for (SQLNotNullConstraint _iter389 : struct.notNullConstraintCols)
{
- _iter381.write(oprot);
+ _iter389.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.notNullConstraintCols.size());
- for (SQLNotNullConstraint _iter382 : struct.notNullConstraintCols)
+ for (SQLNotNullConstraint _iter390 : struct.notNullConstraintCols)
{
- _iter382.write(oprot);
+ _iter390.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, AddNotNullConstraintRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list383 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.notNullConstraintCols = new ArrayList<SQLNotNullConstraint>(_list383.size);
- SQLNotNullConstraint _elem384;
- for (int _i385 = 0; _i385 < _list383.size; ++_i385)
+ org.apache.thrift.protocol.TList _list391 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.notNullConstraintCols = new ArrayList<SQLNotNullConstraint>(_list391.size);
+ SQLNotNullConstraint _elem392;
+ for (int _i393 = 0; _i393 < _list391.size; ++_i393)
{
- _elem384 = new SQLNotNullConstraint();
- _elem384.read(iprot);
- struct.notNullConstraintCols.add(_elem384);
+ _elem392 = new SQLNotNullConstraint();
+ _elem392.read(iprot);
+ struct.notNullConstraintCols.add(_elem392);
}
}
struct.setNotNullConstraintColsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4047befe/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java
index 9119336..d351678 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java
@@ -704,14 +704,14 @@ import org.slf4j.LoggerFactory;
case 3: // PARTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list452 = iprot.readListBegin();
- struct.parts = new ArrayList<Partition>(_list452.size);
- Partition _elem453;
- for (int _i454 = 0; _i454 < _list452.size; ++_i454)
+ org.apache.thrift.protocol.TList _list468 = iprot.readListBegin();
+ struct.parts = new ArrayList<Partition>(_list468.size);
+ Partition _elem469;
+ for (int _i470 = 0; _i470 < _list468.size; ++_i470)
{
- _elem453 = new Partition();
- _elem453.read(iprot);
- struct.parts.add(_elem453);
+ _elem469 = new Partition();
+ _elem469.read(iprot);
+ struct.parts.add(_elem469);
}
iprot.readListEnd();
}
@@ -763,9 +763,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PARTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.parts.size()));
- for (Partition _iter455 : struct.parts)
+ for (Partition _iter471 : struct.parts)
{
- _iter455.write(oprot);
+ _iter471.write(oprot);
}
oprot.writeListEnd();
}
@@ -800,9 +800,9 @@ import org.slf4j.LoggerFactory;
oprot.writeString(struct.tblName);
{
oprot.writeI32(struct.parts.size());
- for (Partition _iter456 : struct.parts)
+ for (Partition _iter472 : struct.parts)
{
- _iter456.write(oprot);
+ _iter472.write(oprot);
}
}
oprot.writeBool(struct.ifNotExists);
@@ -824,14 +824,14 @@ import org.slf4j.LoggerFactory;
struct.tblName = iprot.readString();
struct.setTblNameIsSet(true);
{
- org.apache.thrift.protocol.TList _list457 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.parts = new ArrayList<Partition>(_list457.size);
- Partition _elem458;
- for (int _i459 = 0; _i459 < _list457.size; ++_i459)
+ org.apache.thrift.protocol.TList _list473 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.parts = new ArrayList<Partition>(_list473.size);
+ Partition _elem474;
+ for (int _i475 = 0; _i475 < _list473.size; ++_i475)
{
- _elem458 = new Partition();
- _elem458.read(iprot);
- struct.parts.add(_elem458);
+ _elem474 = new Partition();
+ _elem474.read(iprot);
+ struct.parts.add(_elem474);
}
}
struct.setPartsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4047befe/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java
index 57d4953..23525e2 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java
@@ -346,14 +346,14 @@ import org.slf4j.LoggerFactory;
case 1: // PARTITIONS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list444 = iprot.readListBegin();
- struct.partitions = new ArrayList<Partition>(_list444.size);
- Partition _elem445;
- for (int _i446 = 0; _i446 < _list444.size; ++_i446)
+ org.apache.thrift.protocol.TList _list460 = iprot.readListBegin();
+ struct.partitions = new ArrayList<Partition>(_list460.size);
+ Partition _elem461;
+ for (int _i462 = 0; _i462 < _list460.size; ++_i462)
{
- _elem445 = new Partition();
- _elem445.read(iprot);
- struct.partitions.add(_elem445);
+ _elem461 = new Partition();
+ _elem461.read(iprot);
+ struct.partitions.add(_elem461);
}
iprot.readListEnd();
}
@@ -380,9 +380,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PARTITIONS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.partitions.size()));
- for (Partition _iter447 : struct.partitions)
+ for (Partition _iter463 : struct.partitions)
{
- _iter447.write(oprot);
+ _iter463.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPartitions()) {
{
oprot.writeI32(struct.partitions.size());
- for (Partition _iter448 : struct.partitions)
+ for (Partition _iter464 : struct.partitions)
{
- _iter448.write(oprot);
+ _iter464.write(oprot);
}
}
}
@@ -428,14 +428,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list449 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.partitions = new ArrayList<Partition>(_list449.size);
- Partition _elem450;
- for (int _i451 = 0; _i451 < _list449.size; ++_i451)
+ org.apache.thrift.protocol.TList _list465 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.partitions = new ArrayList<Partition>(_list465.size);
+ Partition _elem466;
+ for (int _i467 = 0; _i467 < _list465.size; ++_i467)
{
- _elem450 = new Partition();
- _elem450.read(iprot);
- struct.partitions.add(_elem450);
+ _elem466 = new Partition();
+ _elem466.read(iprot);
+ struct.partitions.add(_elem466);
}
}
struct.setPartitionsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4047befe/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPrimaryKeyRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPrimaryKeyRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPrimaryKeyRequest.java
index 900985b..9efcfe0 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPrimaryKeyRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPrimaryKeyRequest.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // PRIMARY_KEY_COLS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list354 = iprot.readListBegin();
- struct.primaryKeyCols = new ArrayList<SQLPrimaryKey>(_list354.size);
- SQLPrimaryKey _elem355;
- for (int _i356 = 0; _i356 < _list354.size; ++_i356)
+ org.apache.thrift.protocol.TList _list362 = iprot.readListBegin();
+ struct.primaryKeyCols = new ArrayList<SQLPrimaryKey>(_list362.size);
+ SQLPrimaryKey _elem363;
+ for (int _i364 = 0; _i364 < _list362.size; ++_i364)
{
- _elem355 = new SQLPrimaryKey();
- _elem355.read(iprot);
- struct.primaryKeyCols.add(_elem355);
+ _elem363 = new SQLPrimaryKey();
+ _elem363.read(iprot);
+ struct.primaryKeyCols.add(_elem363);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PRIMARY_KEY_COLS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.primaryKeyCols.size()));
- for (SQLPrimaryKey _iter357 : struct.primaryKeyCols)
+ for (SQLPrimaryKey _iter365 : struct.primaryKeyCols)
{
- _iter357.write(oprot);
+ _iter365.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.primaryKeyCols.size());
- for (SQLPrimaryKey _iter358 : struct.primaryKeyCols)
+ for (SQLPrimaryKey _iter366 : struct.primaryKeyCols)
{
- _iter358.write(oprot);
+ _iter366.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, AddPrimaryKeyRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list359 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.primaryKeyCols = new ArrayList<SQLPrimaryKey>(_list359.size);
- SQLPrimaryKey _elem360;
- for (int _i361 = 0; _i361 < _list359.size; ++_i361)
+ org.apache.thrift.protocol.TList _list367 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.primaryKeyCols = new ArrayList<SQLPrimaryKey>(_list367.size);
+ SQLPrimaryKey _elem368;
+ for (int _i369 = 0; _i369 < _list367.size; ++_i369)
{
- _elem360 = new SQLPrimaryKey();
- _elem360.read(iprot);
- struct.primaryKeyCols.add(_elem360);
+ _elem368 = new SQLPrimaryKey();
+ _elem368.read(iprot);
+ struct.primaryKeyCols.add(_elem368);
}
}
struct.setPrimaryKeyColsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4047befe/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddUniqueConstraintRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddUniqueConstraintRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddUniqueConstraintRequest.java
index df4f544..0429fd5 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddUniqueConstraintRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddUniqueConstraintRequest.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // UNIQUE_CONSTRAINT_COLS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list370 = iprot.readListBegin();
- struct.uniqueConstraintCols = new ArrayList<SQLUniqueConstraint>(_list370.size);
- SQLUniqueConstraint _elem371;
- for (int _i372 = 0; _i372 < _list370.size; ++_i372)
+ org.apache.thrift.protocol.TList _list378 = iprot.readListBegin();
+ struct.uniqueConstraintCols = new ArrayList<SQLUniqueConstraint>(_list378.size);
+ SQLUniqueConstraint _elem379;
+ for (int _i380 = 0; _i380 < _list378.size; ++_i380)
{
- _elem371 = new SQLUniqueConstraint();
- _elem371.read(iprot);
- struct.uniqueConstraintCols.add(_elem371);
+ _elem379 = new SQLUniqueConstraint();
+ _elem379.read(iprot);
+ struct.uniqueConstraintCols.add(_elem379);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(UNIQUE_CONSTRAINT_COLS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.uniqueConstraintCols.size()));
- for (SQLUniqueConstraint _iter373 : struct.uniqueConstraintCols)
+ for (SQLUniqueConstraint _iter381 : struct.uniqueConstraintCols)
{
- _iter373.write(oprot);
+ _iter381.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.uniqueConstraintCols.size());
- for (SQLUniqueConstraint _iter374 : struct.uniqueConstraintCols)
+ for (SQLUniqueConstraint _iter382 : struct.uniqueConstraintCols)
{
- _iter374.write(oprot);
+ _iter382.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, AddUniqueConstraintRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list375 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.uniqueConstraintCols = new ArrayList<SQLUniqueConstraint>(_list375.size);
- SQLUniqueConstraint _elem376;
- for (int _i377 = 0; _i377 < _list375.size; ++_i377)
+ org.apache.thrift.protocol.TList _list383 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.uniqueConstraintCols = new ArrayList<SQLUniqueConstraint>(_list383.size);
+ SQLUniqueConstraint _elem384;
+ for (int _i385 = 0; _i385 < _list383.size; ++_i385)
{
- _elem376 = new SQLUniqueConstraint();
- _elem376.read(iprot);
- struct.uniqueConstraintCols.add(_elem376);
+ _elem384 = new SQLUniqueConstraint();
+ _elem384.read(iprot);
+ struct.uniqueConstraintCols.add(_elem384);
}
}
struct.setUniqueConstraintColsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4047befe/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsRequest.java
index 1aec53b..60a32ad 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsRequest.java
@@ -521,13 +521,13 @@ import org.slf4j.LoggerFactory;
case 1: // TXN_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list580 = iprot.readListBegin();
- struct.txnIds = new ArrayList<Long>(_list580.size);
- long _elem581;
- for (int _i582 = 0; _i582 < _list580.size; ++_i582)
+ org.apache.thrift.protocol.TList _list596 = iprot.readListBegin();
+ struct.txnIds = new ArrayList<Long>(_list596.size);
+ long _elem597;
+ for (int _i598 = 0; _i598 < _list596.size; ++_i598)
{
- _elem581 = iprot.readI64();
- struct.txnIds.add(_elem581);
+ _elem597 = iprot.readI64();
+ struct.txnIds.add(_elem597);
}
iprot.readListEnd();
}
@@ -569,9 +569,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TXN_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.txnIds.size()));
- for (long _iter583 : struct.txnIds)
+ for (long _iter599 : struct.txnIds)
{
- oprot.writeI64(_iter583);
+ oprot.writeI64(_iter599);
}
oprot.writeListEnd();
}
@@ -606,9 +606,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.txnIds.size());
- for (long _iter584 : struct.txnIds)
+ for (long _iter600 : struct.txnIds)
{
- oprot.writeI64(_iter584);
+ oprot.writeI64(_iter600);
}
}
oprot.writeString(struct.dbName);
@@ -619,13 +619,13 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, AllocateTableWriteIdsRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list585 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.txnIds = new ArrayList<Long>(_list585.size);
- long _elem586;
- for (int _i587 = 0; _i587 < _list585.size; ++_i587)
+ org.apache.thrift.protocol.TList _list601 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.txnIds = new ArrayList<Long>(_list601.size);
+ long _elem602;
+ for (int _i603 = 0; _i603 < _list601.size; ++_i603)
{
- _elem586 = iprot.readI64();
- struct.txnIds.add(_elem586);
+ _elem602 = iprot.readI64();
+ struct.txnIds.add(_elem602);
}
}
struct.setTxnIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4047befe/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsResponse.java
index e29e1db..9bf2f7f 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AllocateTableWriteIdsResponse.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // TXN_TO_WRITE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list588 = iprot.readListBegin();
- struct.txnToWriteIds = new ArrayList<TxnToWriteId>(_list588.size);
- TxnToWriteId _elem589;
- for (int _i590 = 0; _i590 < _list588.size; ++_i590)
+ org.apache.thrift.protocol.TList _list604 = iprot.readListBegin();
+ struct.txnToWriteIds = new ArrayList<TxnToWriteId>(_list604.size);
+ TxnToWriteId _elem605;
+ for (int _i606 = 0; _i606 < _list604.size; ++_i606)
{
- _elem589 = new TxnToWriteId();
- _elem589.read(iprot);
- struct.txnToWriteIds.add(_elem589);
+ _elem605 = new TxnToWriteId();
+ _elem605.read(iprot);
+ struct.txnToWriteIds.add(_elem605);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TXN_TO_WRITE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.txnToWriteIds.size()));
- for (TxnToWriteId _iter591 : struct.txnToWriteIds)
+ for (TxnToWriteId _iter607 : struct.txnToWriteIds)
{
- _iter591.write(oprot);
+ _iter607.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.txnToWriteIds.size());
- for (TxnToWriteId _iter592 : struct.txnToWriteIds)
+ for (TxnToWriteId _iter608 : struct.txnToWriteIds)
{
- _iter592.write(oprot);
+ _iter608.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, AllocateTableWriteIdsResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list593 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.txnToWriteIds = new ArrayList<TxnToWriteId>(_list593.size);
- TxnToWriteId _elem594;
- for (int _i595 = 0; _i595 < _list593.size; ++_i595)
+ org.apache.thrift.protocol.TList _list609 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.txnToWriteIds = new ArrayList<TxnToWriteId>(_list609.size);
+ TxnToWriteId _elem610;
+ for (int _i611 = 0; _i611 < _list609.size; ++_i611)
{
- _elem594 = new TxnToWriteId();
- _elem594.read(iprot);
- struct.txnToWriteIds.add(_elem594);
+ _elem610 = new TxnToWriteId();
+ _elem610.read(iprot);
+ struct.txnToWriteIds.add(_elem610);
}
}
struct.setTxnToWriteIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4047befe/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java
index ee9841f..9feadc4 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClearFileMetadataRequest.java
@@ -351,13 +351,13 @@ import org.slf4j.LoggerFactory;
case 1: // FILE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list746 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list746.size);
- long _elem747;
- for (int _i748 = 0; _i748 < _list746.size; ++_i748)
+ org.apache.thrift.protocol.TList _list762 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list762.size);
+ long _elem763;
+ for (int _i764 = 0; _i764 < _list762.size; ++_i764)
{
- _elem747 = iprot.readI64();
- struct.fileIds.add(_elem747);
+ _elem763 = iprot.readI64();
+ struct.fileIds.add(_elem763);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FILE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.fileIds.size()));
- for (long _iter749 : struct.fileIds)
+ for (long _iter765 : struct.fileIds)
{
- oprot.writeI64(_iter749);
+ oprot.writeI64(_iter765);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter750 : struct.fileIds)
+ for (long _iter766 : struct.fileIds)
{
- oprot.writeI64(_iter750);
+ oprot.writeI64(_iter766);
}
}
}
@@ -421,13 +421,13 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, ClearFileMetadataRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list751 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list751.size);
- long _elem752;
- for (int _i753 = 0; _i753 < _list751.size; ++_i753)
+ org.apache.thrift.protocol.TList _list767 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list767.size);
+ long _elem768;
+ for (int _i769 = 0; _i769 < _list767.size; ++_i769)
{
- _elem752 = iprot.readI64();
- struct.fileIds.add(_elem752);
+ _elem768 = iprot.readI64();
+ struct.fileIds.add(_elem768);
}
}
struct.setFileIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4047befe/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java
index 8dbe4c1..0a1f76f 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ClientCapabilities.java
@@ -354,13 +354,13 @@ import org.slf4j.LoggerFactory;
case 1: // VALUES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list762 = iprot.readListBegin();
- struct.values = new ArrayList<ClientCapability>(_list762.size);
- ClientCapability _elem763;
- for (int _i764 = 0; _i764 < _list762.size; ++_i764)
+ org.apache.thrift.protocol.TList _list778 = iprot.readListBegin();
+ struct.values = new ArrayList<ClientCapability>(_list778.size);
+ ClientCapability _elem779;
+ for (int _i780 = 0; _i780 < _list778.size; ++_i780)
{
- _elem763 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
- struct.values.add(_elem763);
+ _elem779 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
+ struct.values.add(_elem779);
}
iprot.readListEnd();
}
@@ -386,9 +386,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(VALUES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, struct.values.size()));
- for (ClientCapability _iter765 : struct.values)
+ for (ClientCapability _iter781 : struct.values)
{
- oprot.writeI32(_iter765.getValue());
+ oprot.writeI32(_iter781.getValue());
}
oprot.writeListEnd();
}
@@ -413,9 +413,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.values.size());
- for (ClientCapability _iter766 : struct.values)
+ for (ClientCapability _iter782 : struct.values)
{
- oprot.writeI32(_iter766.getValue());
+ oprot.writeI32(_iter782.getValue());
}
}
}
@@ -424,13 +424,13 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, ClientCapabilities struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list767 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.values = new ArrayList<ClientCapability>(_list767.size);
- ClientCapability _elem768;
- for (int _i769 = 0; _i769 < _list767.size; ++_i769)
+ org.apache.thrift.protocol.TList _list783 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ struct.values = new ArrayList<ClientCapability>(_list783.size);
+ ClientCapability _elem784;
+ for (int _i785 = 0; _i785 < _list783.size; ++_i785)
{
- _elem768 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
- struct.values.add(_elem768);
+ _elem784 = org.apache.hadoop.hive.metastore.api.ClientCapability.findByValue(iprot.readI32());
+ struct.values.add(_elem784);
}
}
struct.setValuesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4047befe/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java
index 1853720..af84a9c 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CompactionRequest.java
@@ -814,15 +814,15 @@ import org.slf4j.LoggerFactory;
case 6: // PROPERTIES
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map628 = iprot.readMapBegin();
- struct.properties = new HashMap<String,String>(2*_map628.size);
- String _key629;
- String _val630;
- for (int _i631 = 0; _i631 < _map628.size; ++_i631)
+ org.apache.thrift.protocol.TMap _map644 = iprot.readMapBegin();
+ struct.properties = new HashMap<String,String>(2*_map644.size);
+ String _key645;
+ String _val646;
+ for (int _i647 = 0; _i647 < _map644.size; ++_i647)
{
- _key629 = iprot.readString();
- _val630 = iprot.readString();
- struct.properties.put(_key629, _val630);
+ _key645 = iprot.readString();
+ _val646 = iprot.readString();
+ struct.properties.put(_key645, _val646);
}
iprot.readMapEnd();
}
@@ -878,10 +878,10 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PROPERTIES_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.properties.size()));
- for (Map.Entry<String, String> _iter632 : struct.properties.entrySet())
+ for (Map.Entry<String, String> _iter648 : struct.properties.entrySet())
{
- oprot.writeString(_iter632.getKey());
- oprot.writeString(_iter632.getValue());
+ oprot.writeString(_iter648.getKey());
+ oprot.writeString(_iter648.getValue());
}
oprot.writeMapEnd();
}
@@ -928,10 +928,10 @@ import org.slf4j.LoggerFactory;
if (struct.isSetProperties()) {
{
oprot.writeI32(struct.properties.size());
- for (Map.Entry<String, String> _iter633 : struct.properties.entrySet())
+ for (Map.Entry<String, String> _iter649 : struct.properties.entrySet())
{
- oprot.writeString(_iter633.getKey());
- oprot.writeString(_iter633.getValue());
+ oprot.writeString(_iter649.getKey());
+ oprot.writeString(_iter649.getValue());
}
}
}
@@ -957,15 +957,15 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TMap _map634 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.properties = new HashMap<String,String>(2*_map634.size);
- String _key635;
- String _val636;
- for (int _i637 = 0; _i637 < _map634.size; ++_i637)
+ org.apache.thrift.protocol.TMap _map650 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.properties = new HashMap<String,String>(2*_map650.size);
+ String _key651;
+ String _val652;
+ for (int _i653 = 0; _i653 < _map650.size; ++_i653)
{
- _key635 = iprot.readString();
- _val636 = iprot.readString();
- struct.properties.put(_key635, _val636);
+ _key651 = iprot.readString();
+ _val652 = iprot.readString();
+ struct.properties.put(_key651, _val652);
}
}
struct.setPropertiesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/4047befe/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CreationMetadata.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CreationMetadata.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CreationMetadata.java
index 717840f..3da8ed5 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CreationMetadata.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CreationMetadata.java
@@ -619,13 +619,13 @@ import org.slf4j.LoggerFactory;
case 3: // TABLES_USED
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set654 = iprot.readSetBegin();
- struct.tablesUsed = new HashSet<String>(2*_set654.size);
- String _elem655;
- for (int _i656 = 0; _i656 < _set654.size; ++_i656)
+ org.apache.thrift.protocol.TSet _set670 = iprot.readSetBegin();
+ struct.tablesUsed = new HashSet<String>(2*_set670.size);
+ String _elem671;
+ for (int _i672 = 0; _i672 < _set670.size; ++_i672)
{
- _elem655 = iprot.readString();
- struct.tablesUsed.add(_elem655);
+ _elem671 = iprot.readString();
+ struct.tablesUsed.add(_elem671);
}
iprot.readSetEnd();
}
@@ -669,9 +669,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TABLES_USED_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, struct.tablesUsed.size()));
- for (String _iter657 : struct.tablesUsed)
+ for (String _iter673 : struct.tablesUsed)
{
- oprot.writeString(_iter657);
+ oprot.writeString(_iter673);
}
oprot.writeSetEnd();
}
@@ -705,9 +705,9 @@ import org.slf4j.LoggerFactory;
oprot.writeString(struct.tblName);
{
oprot.writeI32(struct.tablesUsed.size());
- for (String _iter658 : struct.tablesUsed)
+ for (String _iter674 : struct.tablesUsed)
{
- oprot.writeString(_iter658);
+ oprot.writeString(_iter674);
}
}
BitSet optionals = new BitSet();
@@ -728,13 +728,13 @@ import org.slf4j.LoggerFactory;
struct.tblName = iprot.readString();
struct.setTblNameIsSet(true);
{
- org.apache.thrift.protocol.TSet _set659 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tablesUsed = new HashSet<String>(2*_set659.size);
- String _elem660;
- for (int _i661 = 0; _i661 < _set659.size; ++_i661)
+ org.apache.thrift.protocol.TSet _set675 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tablesUsed = new HashSet<String>(2*_set675.size);
+ String _elem676;
+ for (int _i677 = 0; _i677 < _set675.size; ++_i677)
{
- _elem660 = iprot.readString();
- struct.tablesUsed.add(_elem660);
+ _elem676 = iprot.readString();
+ struct.tablesUsed.add(_elem676);
}
}
struct.setTablesUsedIsSet(true);