http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsRequest.java index 9ad8728..b5d4829 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsRequest.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsRequest.java @@ -38,8 +38,9 @@ import org.slf4j.LoggerFactory; @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class UniqueConstraintsRequest implements org.apache.thrift.TBase<UniqueConstraintsRequest, UniqueConstraintsRequest._Fields>, java.io.Serializable, Cloneable, Comparable<UniqueConstraintsRequest> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("UniqueConstraintsRequest"); - private static final org.apache.thrift.protocol.TField DB_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("db_name", org.apache.thrift.protocol.TType.STRING, (short)1); - private static final org.apache.thrift.protocol.TField TBL_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tbl_name", org.apache.thrift.protocol.TType.STRING, (short)2); + private static final org.apache.thrift.protocol.TField CAT_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("catName", org.apache.thrift.protocol.TType.STRING, (short)1); + private static final org.apache.thrift.protocol.TField DB_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("db_name", org.apache.thrift.protocol.TType.STRING, (short)2); + private static final org.apache.thrift.protocol.TField TBL_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tbl_name", org.apache.thrift.protocol.TType.STRING, (short)3); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -47,13 +48,15 @@ import org.slf4j.LoggerFactory; schemes.put(TupleScheme.class, new UniqueConstraintsRequestTupleSchemeFactory()); } + private String catName; // required private String db_name; // required private String tbl_name; // 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, "db_name"), - TBL_NAME((short)2, "tbl_name"); + CAT_NAME((short)1, "catName"), + DB_NAME((short)2, "db_name"), + TBL_NAME((short)3, "tbl_name"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -68,9 +71,11 @@ import org.slf4j.LoggerFactory; */ public static _Fields findByThriftId(int fieldId) { switch(fieldId) { - case 1: // DB_NAME + case 1: // CAT_NAME + return CAT_NAME; + case 2: // DB_NAME return DB_NAME; - case 2: // TBL_NAME + case 3: // TBL_NAME return TBL_NAME; default: return null; @@ -115,6 +120,8 @@ import org.slf4j.LoggerFactory; 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.CAT_NAME, new org.apache.thrift.meta_data.FieldMetaData("catName", org.apache.thrift.TFieldRequirementType.REQUIRED, + 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("db_name", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); tmpMap.put(_Fields.TBL_NAME, new org.apache.thrift.meta_data.FieldMetaData("tbl_name", org.apache.thrift.TFieldRequirementType.REQUIRED, @@ -127,10 +134,12 @@ import org.slf4j.LoggerFactory; } public UniqueConstraintsRequest( + String catName, String db_name, String tbl_name) { this(); + this.catName = catName; this.db_name = db_name; this.tbl_name = tbl_name; } @@ -139,6 +148,9 @@ import org.slf4j.LoggerFactory; * Performs a deep copy on <i>other</i>. */ public UniqueConstraintsRequest(UniqueConstraintsRequest other) { + if (other.isSetCatName()) { + this.catName = other.catName; + } if (other.isSetDb_name()) { this.db_name = other.db_name; } @@ -153,10 +165,34 @@ import org.slf4j.LoggerFactory; @Override public void clear() { + this.catName = null; this.db_name = null; this.tbl_name = null; } + public String getCatName() { + return this.catName; + } + + public void setCatName(String catName) { + this.catName = catName; + } + + public void unsetCatName() { + this.catName = null; + } + + /** Returns true if field catName is set (has been assigned a value) and false otherwise */ + public boolean isSetCatName() { + return this.catName != null; + } + + public void setCatNameIsSet(boolean value) { + if (!value) { + this.catName = null; + } + } + public String getDb_name() { return this.db_name; } @@ -205,6 +241,14 @@ import org.slf4j.LoggerFactory; public void setFieldValue(_Fields field, Object value) { switch (field) { + case CAT_NAME: + if (value == null) { + unsetCatName(); + } else { + setCatName((String)value); + } + break; + case DB_NAME: if (value == null) { unsetDb_name(); @@ -226,6 +270,9 @@ import org.slf4j.LoggerFactory; public Object getFieldValue(_Fields field) { switch (field) { + case CAT_NAME: + return getCatName(); + case DB_NAME: return getDb_name(); @@ -243,6 +290,8 @@ import org.slf4j.LoggerFactory; } switch (field) { + case CAT_NAME: + return isSetCatName(); case DB_NAME: return isSetDb_name(); case TBL_NAME: @@ -264,6 +313,15 @@ import org.slf4j.LoggerFactory; if (that == null) return false; + boolean this_present_catName = true && this.isSetCatName(); + boolean that_present_catName = true && that.isSetCatName(); + if (this_present_catName || that_present_catName) { + if (!(this_present_catName && that_present_catName)) + return false; + if (!this.catName.equals(that.catName)) + return false; + } + boolean this_present_db_name = true && this.isSetDb_name(); boolean that_present_db_name = true && that.isSetDb_name(); if (this_present_db_name || that_present_db_name) { @@ -289,6 +347,11 @@ import org.slf4j.LoggerFactory; public int hashCode() { List<Object> list = new ArrayList<Object>(); + boolean present_catName = true && (isSetCatName()); + list.add(present_catName); + if (present_catName) + list.add(catName); + boolean present_db_name = true && (isSetDb_name()); list.add(present_db_name); if (present_db_name) @@ -310,6 +373,16 @@ import org.slf4j.LoggerFactory; int lastComparison = 0; + lastComparison = Boolean.valueOf(isSetCatName()).compareTo(other.isSetCatName()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetCatName()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.catName, other.catName); + if (lastComparison != 0) { + return lastComparison; + } + } lastComparison = Boolean.valueOf(isSetDb_name()).compareTo(other.isSetDb_name()); if (lastComparison != 0) { return lastComparison; @@ -350,6 +423,14 @@ import org.slf4j.LoggerFactory; StringBuilder sb = new StringBuilder("UniqueConstraintsRequest("); boolean first = true; + sb.append("catName:"); + if (this.catName == null) { + sb.append("null"); + } else { + sb.append(this.catName); + } + first = false; + if (!first) sb.append(", "); sb.append("db_name:"); if (this.db_name == null) { sb.append("null"); @@ -371,6 +452,10 @@ import org.slf4j.LoggerFactory; public void validate() throws org.apache.thrift.TException { // check for required fields + if (!isSetCatName()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'catName' is unset! Struct:" + toString()); + } + if (!isSetDb_name()) { throw new org.apache.thrift.protocol.TProtocolException("Required field 'db_name' is unset! Struct:" + toString()); } @@ -416,7 +501,15 @@ import org.slf4j.LoggerFactory; break; } switch (schemeField.id) { - case 1: // DB_NAME + case 1: // CAT_NAME + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.catName = iprot.readString(); + struct.setCatNameIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // DB_NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { struct.db_name = iprot.readString(); struct.setDb_nameIsSet(true); @@ -424,7 +517,7 @@ import org.slf4j.LoggerFactory; org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; - case 2: // TBL_NAME + case 3: // TBL_NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { struct.tbl_name = iprot.readString(); struct.setTbl_nameIsSet(true); @@ -445,6 +538,11 @@ import org.slf4j.LoggerFactory; struct.validate(); oprot.writeStructBegin(STRUCT_DESC); + if (struct.catName != null) { + oprot.writeFieldBegin(CAT_NAME_FIELD_DESC); + oprot.writeString(struct.catName); + oprot.writeFieldEnd(); + } if (struct.db_name != null) { oprot.writeFieldBegin(DB_NAME_FIELD_DESC); oprot.writeString(struct.db_name); @@ -472,6 +570,7 @@ import org.slf4j.LoggerFactory; @Override public void write(org.apache.thrift.protocol.TProtocol prot, UniqueConstraintsRequest struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; + oprot.writeString(struct.catName); oprot.writeString(struct.db_name); oprot.writeString(struct.tbl_name); } @@ -479,6 +578,8 @@ import org.slf4j.LoggerFactory; @Override public void read(org.apache.thrift.protocol.TProtocol prot, UniqueConstraintsRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; + struct.catName = iprot.readString(); + struct.setCatNameIsSet(true); struct.db_name = iprot.readString(); struct.setDb_nameIsSet(true); struct.tbl_name = iprot.readString();
http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsResponse.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsResponse.java index 4d45bee..80dea83 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsResponse.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsResponse.java @@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory; case 1: // UNIQUE_CONSTRAINTS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list328 = iprot.readListBegin(); - struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list328.size); - SQLUniqueConstraint _elem329; - for (int _i330 = 0; _i330 < _list328.size; ++_i330) + org.apache.thrift.protocol.TList _list336 = iprot.readListBegin(); + struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list336.size); + SQLUniqueConstraint _elem337; + for (int _i338 = 0; _i338 < _list336.size; ++_i338) { - _elem329 = new SQLUniqueConstraint(); - _elem329.read(iprot); - struct.uniqueConstraints.add(_elem329); + _elem337 = new SQLUniqueConstraint(); + _elem337.read(iprot); + struct.uniqueConstraints.add(_elem337); } iprot.readListEnd(); } @@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(UNIQUE_CONSTRAINTS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.uniqueConstraints.size())); - for (SQLUniqueConstraint _iter331 : struct.uniqueConstraints) + for (SQLUniqueConstraint _iter339 : struct.uniqueConstraints) { - _iter331.write(oprot); + _iter339.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory; TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.uniqueConstraints.size()); - for (SQLUniqueConstraint _iter332 : struct.uniqueConstraints) + for (SQLUniqueConstraint _iter340 : struct.uniqueConstraints) { - _iter332.write(oprot); + _iter340.write(oprot); } } } @@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory; public void read(org.apache.thrift.protocol.TProtocol prot, UniqueConstraintsResponse struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list333 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list333.size); - SQLUniqueConstraint _elem334; - for (int _i335 = 0; _i335 < _list333.size; ++_i335) + org.apache.thrift.protocol.TList _list341 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list341.size); + SQLUniqueConstraint _elem342; + for (int _i343 = 0; _i343 < _list341.size; ++_i343) { - _elem334 = new SQLUniqueConstraint(); - _elem334.read(iprot); - struct.uniqueConstraints.add(_elem334); + _elem342 = new SQLUniqueConstraint(); + _elem342.read(iprot); + struct.uniqueConstraints.add(_elem342); } } struct.setUniqueConstraintsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java index a7be2ec..3560567 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java @@ -755,14 +755,14 @@ import org.slf4j.LoggerFactory; case 2: // POOLS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list816 = iprot.readListBegin(); - struct.pools = new ArrayList<WMPool>(_list816.size); - WMPool _elem817; - for (int _i818 = 0; _i818 < _list816.size; ++_i818) + org.apache.thrift.protocol.TList _list824 = iprot.readListBegin(); + struct.pools = new ArrayList<WMPool>(_list824.size); + WMPool _elem825; + for (int _i826 = 0; _i826 < _list824.size; ++_i826) { - _elem817 = new WMPool(); - _elem817.read(iprot); - struct.pools.add(_elem817); + _elem825 = new WMPool(); + _elem825.read(iprot); + struct.pools.add(_elem825); } iprot.readListEnd(); } @@ -774,14 +774,14 @@ import org.slf4j.LoggerFactory; case 3: // MAPPINGS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list819 = iprot.readListBegin(); - struct.mappings = new ArrayList<WMMapping>(_list819.size); - WMMapping _elem820; - for (int _i821 = 0; _i821 < _list819.size; ++_i821) + org.apache.thrift.protocol.TList _list827 = iprot.readListBegin(); + struct.mappings = new ArrayList<WMMapping>(_list827.size); + WMMapping _elem828; + for (int _i829 = 0; _i829 < _list827.size; ++_i829) { - _elem820 = new WMMapping(); - _elem820.read(iprot); - struct.mappings.add(_elem820); + _elem828 = new WMMapping(); + _elem828.read(iprot); + struct.mappings.add(_elem828); } iprot.readListEnd(); } @@ -793,14 +793,14 @@ import org.slf4j.LoggerFactory; case 4: // TRIGGERS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list822 = iprot.readListBegin(); - struct.triggers = new ArrayList<WMTrigger>(_list822.size); - WMTrigger _elem823; - for (int _i824 = 0; _i824 < _list822.size; ++_i824) + org.apache.thrift.protocol.TList _list830 = iprot.readListBegin(); + struct.triggers = new ArrayList<WMTrigger>(_list830.size); + WMTrigger _elem831; + for (int _i832 = 0; _i832 < _list830.size; ++_i832) { - _elem823 = new WMTrigger(); - _elem823.read(iprot); - struct.triggers.add(_elem823); + _elem831 = new WMTrigger(); + _elem831.read(iprot); + struct.triggers.add(_elem831); } iprot.readListEnd(); } @@ -812,14 +812,14 @@ import org.slf4j.LoggerFactory; case 5: // POOL_TRIGGERS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list825 = iprot.readListBegin(); - struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list825.size); - WMPoolTrigger _elem826; - for (int _i827 = 0; _i827 < _list825.size; ++_i827) + org.apache.thrift.protocol.TList _list833 = iprot.readListBegin(); + struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list833.size); + WMPoolTrigger _elem834; + for (int _i835 = 0; _i835 < _list833.size; ++_i835) { - _elem826 = new WMPoolTrigger(); - _elem826.read(iprot); - struct.poolTriggers.add(_elem826); + _elem834 = new WMPoolTrigger(); + _elem834.read(iprot); + struct.poolTriggers.add(_elem834); } iprot.readListEnd(); } @@ -850,9 +850,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(POOLS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.pools.size())); - for (WMPool _iter828 : struct.pools) + for (WMPool _iter836 : struct.pools) { - _iter828.write(oprot); + _iter836.write(oprot); } oprot.writeListEnd(); } @@ -863,9 +863,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(MAPPINGS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.mappings.size())); - for (WMMapping _iter829 : struct.mappings) + for (WMMapping _iter837 : struct.mappings) { - _iter829.write(oprot); + _iter837.write(oprot); } oprot.writeListEnd(); } @@ -877,9 +877,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(TRIGGERS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.triggers.size())); - for (WMTrigger _iter830 : struct.triggers) + for (WMTrigger _iter838 : struct.triggers) { - _iter830.write(oprot); + _iter838.write(oprot); } oprot.writeListEnd(); } @@ -891,9 +891,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(POOL_TRIGGERS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.poolTriggers.size())); - for (WMPoolTrigger _iter831 : struct.poolTriggers) + for (WMPoolTrigger _iter839 : struct.poolTriggers) { - _iter831.write(oprot); + _iter839.write(oprot); } oprot.writeListEnd(); } @@ -920,9 +920,9 @@ import org.slf4j.LoggerFactory; struct.plan.write(oprot); { oprot.writeI32(struct.pools.size()); - for (WMPool _iter832 : struct.pools) + for (WMPool _iter840 : struct.pools) { - _iter832.write(oprot); + _iter840.write(oprot); } } BitSet optionals = new BitSet(); @@ -939,27 +939,27 @@ import org.slf4j.LoggerFactory; if (struct.isSetMappings()) { { oprot.writeI32(struct.mappings.size()); - for (WMMapping _iter833 : struct.mappings) + for (WMMapping _iter841 : struct.mappings) { - _iter833.write(oprot); + _iter841.write(oprot); } } } if (struct.isSetTriggers()) { { oprot.writeI32(struct.triggers.size()); - for (WMTrigger _iter834 : struct.triggers) + for (WMTrigger _iter842 : struct.triggers) { - _iter834.write(oprot); + _iter842.write(oprot); } } } if (struct.isSetPoolTriggers()) { { oprot.writeI32(struct.poolTriggers.size()); - for (WMPoolTrigger _iter835 : struct.poolTriggers) + for (WMPoolTrigger _iter843 : struct.poolTriggers) { - _iter835.write(oprot); + _iter843.write(oprot); } } } @@ -972,56 +972,56 @@ import org.slf4j.LoggerFactory; struct.plan.read(iprot); struct.setPlanIsSet(true); { - org.apache.thrift.protocol.TList _list836 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.pools = new ArrayList<WMPool>(_list836.size); - WMPool _elem837; - for (int _i838 = 0; _i838 < _list836.size; ++_i838) + org.apache.thrift.protocol.TList _list844 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.pools = new ArrayList<WMPool>(_list844.size); + WMPool _elem845; + for (int _i846 = 0; _i846 < _list844.size; ++_i846) { - _elem837 = new WMPool(); - _elem837.read(iprot); - struct.pools.add(_elem837); + _elem845 = new WMPool(); + _elem845.read(iprot); + struct.pools.add(_elem845); } } struct.setPoolsIsSet(true); BitSet incoming = iprot.readBitSet(3); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list839 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.mappings = new ArrayList<WMMapping>(_list839.size); - WMMapping _elem840; - for (int _i841 = 0; _i841 < _list839.size; ++_i841) + org.apache.thrift.protocol.TList _list847 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.mappings = new ArrayList<WMMapping>(_list847.size); + WMMapping _elem848; + for (int _i849 = 0; _i849 < _list847.size; ++_i849) { - _elem840 = new WMMapping(); - _elem840.read(iprot); - struct.mappings.add(_elem840); + _elem848 = new WMMapping(); + _elem848.read(iprot); + struct.mappings.add(_elem848); } } struct.setMappingsIsSet(true); } if (incoming.get(1)) { { - org.apache.thrift.protocol.TList _list842 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.triggers = new ArrayList<WMTrigger>(_list842.size); - WMTrigger _elem843; - for (int _i844 = 0; _i844 < _list842.size; ++_i844) + org.apache.thrift.protocol.TList _list850 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.triggers = new ArrayList<WMTrigger>(_list850.size); + WMTrigger _elem851; + for (int _i852 = 0; _i852 < _list850.size; ++_i852) { - _elem843 = new WMTrigger(); - _elem843.read(iprot); - struct.triggers.add(_elem843); + _elem851 = new WMTrigger(); + _elem851.read(iprot); + struct.triggers.add(_elem851); } } struct.setTriggersIsSet(true); } if (incoming.get(2)) { { - org.apache.thrift.protocol.TList _list845 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list845.size); - WMPoolTrigger _elem846; - for (int _i847 = 0; _i847 < _list845.size; ++_i847) + org.apache.thrift.protocol.TList _list853 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list853.size); + WMPoolTrigger _elem854; + for (int _i855 = 0; _i855 < _list853.size; ++_i855) { - _elem846 = new WMPoolTrigger(); - _elem846.read(iprot); - struct.poolTriggers.add(_elem846); + _elem854 = new WMPoolTrigger(); + _elem854.read(iprot); + struct.poolTriggers.add(_elem854); } } struct.setPoolTriggersIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java index d931b47..ffe8b68 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java @@ -346,14 +346,14 @@ import org.slf4j.LoggerFactory; case 1: // RESOURCE_PLANS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list848 = iprot.readListBegin(); - struct.resourcePlans = new ArrayList<WMResourcePlan>(_list848.size); - WMResourcePlan _elem849; - for (int _i850 = 0; _i850 < _list848.size; ++_i850) + org.apache.thrift.protocol.TList _list856 = iprot.readListBegin(); + struct.resourcePlans = new ArrayList<WMResourcePlan>(_list856.size); + WMResourcePlan _elem857; + for (int _i858 = 0; _i858 < _list856.size; ++_i858) { - _elem849 = new WMResourcePlan(); - _elem849.read(iprot); - struct.resourcePlans.add(_elem849); + _elem857 = new WMResourcePlan(); + _elem857.read(iprot); + struct.resourcePlans.add(_elem857); } iprot.readListEnd(); } @@ -380,9 +380,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(RESOURCE_PLANS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.resourcePlans.size())); - for (WMResourcePlan _iter851 : struct.resourcePlans) + for (WMResourcePlan _iter859 : struct.resourcePlans) { - _iter851.write(oprot); + _iter859.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory; if (struct.isSetResourcePlans()) { { oprot.writeI32(struct.resourcePlans.size()); - for (WMResourcePlan _iter852 : struct.resourcePlans) + for (WMResourcePlan _iter860 : struct.resourcePlans) { - _iter852.write(oprot); + _iter860.write(oprot); } } } @@ -428,14 +428,14 @@ import org.slf4j.LoggerFactory; BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list853 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.resourcePlans = new ArrayList<WMResourcePlan>(_list853.size); - WMResourcePlan _elem854; - for (int _i855 = 0; _i855 < _list853.size; ++_i855) + org.apache.thrift.protocol.TList _list861 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.resourcePlans = new ArrayList<WMResourcePlan>(_list861.size); + WMResourcePlan _elem862; + for (int _i863 = 0; _i863 < _list861.size; ++_i863) { - _elem854 = new WMResourcePlan(); - _elem854.read(iprot); - struct.resourcePlans.add(_elem854); + _elem862 = new WMResourcePlan(); + _elem862.read(iprot); + struct.resourcePlans.add(_elem862); } } struct.setResourcePlansIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java index a674db2..9dfebf0 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java @@ -346,14 +346,14 @@ import org.slf4j.LoggerFactory; case 1: // TRIGGERS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list872 = iprot.readListBegin(); - struct.triggers = new ArrayList<WMTrigger>(_list872.size); - WMTrigger _elem873; - for (int _i874 = 0; _i874 < _list872.size; ++_i874) + org.apache.thrift.protocol.TList _list880 = iprot.readListBegin(); + struct.triggers = new ArrayList<WMTrigger>(_list880.size); + WMTrigger _elem881; + for (int _i882 = 0; _i882 < _list880.size; ++_i882) { - _elem873 = new WMTrigger(); - _elem873.read(iprot); - struct.triggers.add(_elem873); + _elem881 = new WMTrigger(); + _elem881.read(iprot); + struct.triggers.add(_elem881); } iprot.readListEnd(); } @@ -380,9 +380,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(TRIGGERS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.triggers.size())); - for (WMTrigger _iter875 : struct.triggers) + for (WMTrigger _iter883 : struct.triggers) { - _iter875.write(oprot); + _iter883.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory; if (struct.isSetTriggers()) { { oprot.writeI32(struct.triggers.size()); - for (WMTrigger _iter876 : struct.triggers) + for (WMTrigger _iter884 : struct.triggers) { - _iter876.write(oprot); + _iter884.write(oprot); } } } @@ -428,14 +428,14 @@ import org.slf4j.LoggerFactory; BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list877 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.triggers = new ArrayList<WMTrigger>(_list877.size); - WMTrigger _elem878; - for (int _i879 = 0; _i879 < _list877.size; ++_i879) + org.apache.thrift.protocol.TList _list885 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.triggers = new ArrayList<WMTrigger>(_list885.size); + WMTrigger _elem886; + for (int _i887 = 0; _i887 < _list885.size; ++_i887) { - _elem878 = new WMTrigger(); - _elem878.read(iprot); - struct.triggers.add(_elem878); + _elem886 = new WMTrigger(); + _elem886.read(iprot); + struct.triggers.add(_elem886); } } struct.setTriggersIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java index db11958..8f3b065 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java @@ -441,13 +441,13 @@ import org.slf4j.LoggerFactory; case 1: // ERRORS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list856 = iprot.readListBegin(); - struct.errors = new ArrayList<String>(_list856.size); - String _elem857; - for (int _i858 = 0; _i858 < _list856.size; ++_i858) + org.apache.thrift.protocol.TList _list864 = iprot.readListBegin(); + struct.errors = new ArrayList<String>(_list864.size); + String _elem865; + for (int _i866 = 0; _i866 < _list864.size; ++_i866) { - _elem857 = iprot.readString(); - struct.errors.add(_elem857); + _elem865 = iprot.readString(); + struct.errors.add(_elem865); } iprot.readListEnd(); } @@ -459,13 +459,13 @@ import org.slf4j.LoggerFactory; case 2: // WARNINGS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list859 = iprot.readListBegin(); - struct.warnings = new ArrayList<String>(_list859.size); - String _elem860; - for (int _i861 = 0; _i861 < _list859.size; ++_i861) + org.apache.thrift.protocol.TList _list867 = iprot.readListBegin(); + struct.warnings = new ArrayList<String>(_list867.size); + String _elem868; + for (int _i869 = 0; _i869 < _list867.size; ++_i869) { - _elem860 = iprot.readString(); - struct.warnings.add(_elem860); + _elem868 = iprot.readString(); + struct.warnings.add(_elem868); } iprot.readListEnd(); } @@ -492,9 +492,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(ERRORS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.errors.size())); - for (String _iter862 : struct.errors) + for (String _iter870 : struct.errors) { - oprot.writeString(_iter862); + oprot.writeString(_iter870); } oprot.writeListEnd(); } @@ -506,9 +506,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(WARNINGS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.warnings.size())); - for (String _iter863 : struct.warnings) + for (String _iter871 : struct.warnings) { - oprot.writeString(_iter863); + oprot.writeString(_iter871); } oprot.writeListEnd(); } @@ -543,18 +543,18 @@ import org.slf4j.LoggerFactory; if (struct.isSetErrors()) { { oprot.writeI32(struct.errors.size()); - for (String _iter864 : struct.errors) + for (String _iter872 : struct.errors) { - oprot.writeString(_iter864); + oprot.writeString(_iter872); } } } if (struct.isSetWarnings()) { { oprot.writeI32(struct.warnings.size()); - for (String _iter865 : struct.warnings) + for (String _iter873 : struct.warnings) { - oprot.writeString(_iter865); + oprot.writeString(_iter873); } } } @@ -566,26 +566,26 @@ import org.slf4j.LoggerFactory; BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list866 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.errors = new ArrayList<String>(_list866.size); - String _elem867; - for (int _i868 = 0; _i868 < _list866.size; ++_i868) + org.apache.thrift.protocol.TList _list874 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.errors = new ArrayList<String>(_list874.size); + String _elem875; + for (int _i876 = 0; _i876 < _list874.size; ++_i876) { - _elem867 = iprot.readString(); - struct.errors.add(_elem867); + _elem875 = iprot.readString(); + struct.errors.add(_elem875); } } struct.setErrorsIsSet(true); } if (incoming.get(1)) { { - org.apache.thrift.protocol.TList _list869 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.warnings = new ArrayList<String>(_list869.size); - String _elem870; - for (int _i871 = 0; _i871 < _list869.size; ++_i871) + org.apache.thrift.protocol.TList _list877 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.warnings = new ArrayList<String>(_list877.size); + String _elem878; + for (int _i879 = 0; _i879 < _list877.size; ++_i879) { - _elem870 = iprot.readString(); - struct.warnings.add(_elem870); + _elem878 = iprot.readString(); + struct.warnings.add(_elem878); } } struct.setWarningsIsSet(true);
