http://git-wip-us.apache.org/repos/asf/hive/blob/5258c67e/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMNullableResourcePlan.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMNullableResourcePlan.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMNullableResourcePlan.java index 4621e10..15bb764 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMNullableResourcePlan.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMNullableResourcePlan.java @@ -44,6 +44,7 @@ import org.slf4j.LoggerFactory; private static final org.apache.thrift.protocol.TField IS_SET_QUERY_PARALLELISM_FIELD_DESC = new org.apache.thrift.protocol.TField("isSetQueryParallelism", org.apache.thrift.protocol.TType.BOOL, (short)5); private static final org.apache.thrift.protocol.TField DEFAULT_POOL_PATH_FIELD_DESC = new org.apache.thrift.protocol.TField("defaultPoolPath", org.apache.thrift.protocol.TType.STRING, (short)6); private static final org.apache.thrift.protocol.TField IS_SET_DEFAULT_POOL_PATH_FIELD_DESC = new org.apache.thrift.protocol.TField("isSetDefaultPoolPath", org.apache.thrift.protocol.TType.BOOL, (short)7); + private static final org.apache.thrift.protocol.TField NS_FIELD_DESC = new org.apache.thrift.protocol.TField("ns", org.apache.thrift.protocol.TType.STRING, (short)8); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -57,6 +58,7 @@ import org.slf4j.LoggerFactory; private boolean isSetQueryParallelism; // optional private String defaultPoolPath; // optional private boolean isSetDefaultPoolPath; // optional + private String ns; // optional /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { @@ -69,7 +71,8 @@ import org.slf4j.LoggerFactory; QUERY_PARALLELISM((short)4, "queryParallelism"), IS_SET_QUERY_PARALLELISM((short)5, "isSetQueryParallelism"), DEFAULT_POOL_PATH((short)6, "defaultPoolPath"), - IS_SET_DEFAULT_POOL_PATH((short)7, "isSetDefaultPoolPath"); + IS_SET_DEFAULT_POOL_PATH((short)7, "isSetDefaultPoolPath"), + NS((short)8, "ns"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -96,6 +99,8 @@ import org.slf4j.LoggerFactory; return DEFAULT_POOL_PATH; case 7: // IS_SET_DEFAULT_POOL_PATH return IS_SET_DEFAULT_POOL_PATH; + case 8: // NS + return NS; default: return null; } @@ -140,7 +145,7 @@ import org.slf4j.LoggerFactory; private static final int __ISSETQUERYPARALLELISM_ISSET_ID = 1; private static final int __ISSETDEFAULTPOOLPATH_ISSET_ID = 2; private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.NAME,_Fields.STATUS,_Fields.QUERY_PARALLELISM,_Fields.IS_SET_QUERY_PARALLELISM,_Fields.DEFAULT_POOL_PATH,_Fields.IS_SET_DEFAULT_POOL_PATH}; + private static final _Fields optionals[] = {_Fields.NAME,_Fields.STATUS,_Fields.QUERY_PARALLELISM,_Fields.IS_SET_QUERY_PARALLELISM,_Fields.DEFAULT_POOL_PATH,_Fields.IS_SET_DEFAULT_POOL_PATH,_Fields.NS}; 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); @@ -156,6 +161,8 @@ import org.slf4j.LoggerFactory; new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); tmpMap.put(_Fields.IS_SET_DEFAULT_POOL_PATH, new org.apache.thrift.meta_data.FieldMetaData("isSetDefaultPoolPath", org.apache.thrift.TFieldRequirementType.OPTIONAL, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL))); + tmpMap.put(_Fields.NS, new org.apache.thrift.meta_data.FieldMetaData("ns", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(WMNullableResourcePlan.class, metaDataMap); } @@ -180,6 +187,9 @@ import org.slf4j.LoggerFactory; this.defaultPoolPath = other.defaultPoolPath; } this.isSetDefaultPoolPath = other.isSetDefaultPoolPath; + if (other.isSetNs()) { + this.ns = other.ns; + } } public WMNullableResourcePlan deepCopy() { @@ -197,6 +207,7 @@ import org.slf4j.LoggerFactory; this.defaultPoolPath = null; setIsSetDefaultPoolPathIsSet(false); this.isSetDefaultPoolPath = false; + this.ns = null; } public String getName() { @@ -342,6 +353,29 @@ import org.slf4j.LoggerFactory; __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ISSETDEFAULTPOOLPATH_ISSET_ID, value); } + public String getNs() { + return this.ns; + } + + public void setNs(String ns) { + this.ns = ns; + } + + public void unsetNs() { + this.ns = null; + } + + /** Returns true if field ns is set (has been assigned a value) and false otherwise */ + public boolean isSetNs() { + return this.ns != null; + } + + public void setNsIsSet(boolean value) { + if (!value) { + this.ns = null; + } + } + public void setFieldValue(_Fields field, Object value) { switch (field) { case NAME: @@ -392,6 +426,14 @@ import org.slf4j.LoggerFactory; } break; + case NS: + if (value == null) { + unsetNs(); + } else { + setNs((String)value); + } + break; + } } @@ -415,6 +457,9 @@ import org.slf4j.LoggerFactory; case IS_SET_DEFAULT_POOL_PATH: return isIsSetDefaultPoolPath(); + case NS: + return getNs(); + } throw new IllegalStateException(); } @@ -438,6 +483,8 @@ import org.slf4j.LoggerFactory; return isSetDefaultPoolPath(); case IS_SET_DEFAULT_POOL_PATH: return isSetIsSetDefaultPoolPath(); + case NS: + return isSetNs(); } throw new IllegalStateException(); } @@ -509,6 +556,15 @@ import org.slf4j.LoggerFactory; return false; } + boolean this_present_ns = true && this.isSetNs(); + boolean that_present_ns = true && that.isSetNs(); + if (this_present_ns || that_present_ns) { + if (!(this_present_ns && that_present_ns)) + return false; + if (!this.ns.equals(that.ns)) + return false; + } + return true; } @@ -546,6 +602,11 @@ import org.slf4j.LoggerFactory; if (present_isSetDefaultPoolPath) list.add(isSetDefaultPoolPath); + boolean present_ns = true && (isSetNs()); + list.add(present_ns); + if (present_ns) + list.add(ns); + return list.hashCode(); } @@ -617,6 +678,16 @@ import org.slf4j.LoggerFactory; return lastComparison; } } + lastComparison = Boolean.valueOf(isSetNs()).compareTo(other.isSetNs()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetNs()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ns, other.ns); + if (lastComparison != 0) { + return lastComparison; + } + } return 0; } @@ -684,6 +755,16 @@ import org.slf4j.LoggerFactory; sb.append(this.isSetDefaultPoolPath); first = false; } + if (isSetNs()) { + if (!first) sb.append(", "); + sb.append("ns:"); + if (this.ns == null) { + sb.append("null"); + } else { + sb.append(this.ns); + } + first = false; + } sb.append(")"); return sb.toString(); } @@ -777,6 +858,14 @@ import org.slf4j.LoggerFactory; org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; + case 8: // NS + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.ns = iprot.readString(); + struct.setNsIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -826,6 +915,13 @@ import org.slf4j.LoggerFactory; oprot.writeBool(struct.isSetDefaultPoolPath); oprot.writeFieldEnd(); } + if (struct.ns != null) { + if (struct.isSetNs()) { + oprot.writeFieldBegin(NS_FIELD_DESC); + oprot.writeString(struct.ns); + oprot.writeFieldEnd(); + } + } oprot.writeFieldStop(); oprot.writeStructEnd(); } @@ -862,7 +958,10 @@ import org.slf4j.LoggerFactory; if (struct.isSetIsSetDefaultPoolPath()) { optionals.set(5); } - oprot.writeBitSet(optionals, 6); + if (struct.isSetNs()) { + optionals.set(6); + } + oprot.writeBitSet(optionals, 7); if (struct.isSetName()) { oprot.writeString(struct.name); } @@ -881,12 +980,15 @@ import org.slf4j.LoggerFactory; if (struct.isSetIsSetDefaultPoolPath()) { oprot.writeBool(struct.isSetDefaultPoolPath); } + if (struct.isSetNs()) { + oprot.writeString(struct.ns); + } } @Override public void read(org.apache.thrift.protocol.TProtocol prot, WMNullableResourcePlan struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(6); + BitSet incoming = iprot.readBitSet(7); if (incoming.get(0)) { struct.name = iprot.readString(); struct.setNameIsSet(true); @@ -911,6 +1013,10 @@ import org.slf4j.LoggerFactory; struct.isSetDefaultPoolPath = iprot.readBool(); struct.setIsSetDefaultPoolPathIsSet(true); } + if (incoming.get(6)) { + struct.ns = iprot.readString(); + struct.setNsIsSet(true); + } } }
http://git-wip-us.apache.org/repos/asf/hive/blob/5258c67e/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMPool.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMPool.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMPool.java index 0fc5ecf..ba683dd 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMPool.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMPool.java @@ -43,6 +43,7 @@ import org.slf4j.LoggerFactory; private static final org.apache.thrift.protocol.TField ALLOC_FRACTION_FIELD_DESC = new org.apache.thrift.protocol.TField("allocFraction", org.apache.thrift.protocol.TType.DOUBLE, (short)3); private static final org.apache.thrift.protocol.TField QUERY_PARALLELISM_FIELD_DESC = new org.apache.thrift.protocol.TField("queryParallelism", org.apache.thrift.protocol.TType.I32, (short)4); private static final org.apache.thrift.protocol.TField SCHEDULING_POLICY_FIELD_DESC = new org.apache.thrift.protocol.TField("schedulingPolicy", org.apache.thrift.protocol.TType.STRING, (short)5); + private static final org.apache.thrift.protocol.TField NS_FIELD_DESC = new org.apache.thrift.protocol.TField("ns", org.apache.thrift.protocol.TType.STRING, (short)6); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -55,6 +56,7 @@ import org.slf4j.LoggerFactory; private double allocFraction; // optional private int queryParallelism; // optional private String schedulingPolicy; // optional + private String ns; // optional /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { @@ -62,7 +64,8 @@ import org.slf4j.LoggerFactory; POOL_PATH((short)2, "poolPath"), ALLOC_FRACTION((short)3, "allocFraction"), QUERY_PARALLELISM((short)4, "queryParallelism"), - SCHEDULING_POLICY((short)5, "schedulingPolicy"); + SCHEDULING_POLICY((short)5, "schedulingPolicy"), + NS((short)6, "ns"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -87,6 +90,8 @@ import org.slf4j.LoggerFactory; return QUERY_PARALLELISM; case 5: // SCHEDULING_POLICY return SCHEDULING_POLICY; + case 6: // NS + return NS; default: return null; } @@ -130,7 +135,7 @@ import org.slf4j.LoggerFactory; private static final int __ALLOCFRACTION_ISSET_ID = 0; private static final int __QUERYPARALLELISM_ISSET_ID = 1; private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.ALLOC_FRACTION,_Fields.QUERY_PARALLELISM,_Fields.SCHEDULING_POLICY}; + private static final _Fields optionals[] = {_Fields.ALLOC_FRACTION,_Fields.QUERY_PARALLELISM,_Fields.SCHEDULING_POLICY,_Fields.NS}; 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); @@ -144,6 +149,8 @@ import org.slf4j.LoggerFactory; new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); tmpMap.put(_Fields.SCHEDULING_POLICY, new org.apache.thrift.meta_data.FieldMetaData("schedulingPolicy", org.apache.thrift.TFieldRequirementType.OPTIONAL, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.NS, new org.apache.thrift.meta_data.FieldMetaData("ns", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(WMPool.class, metaDataMap); } @@ -176,6 +183,9 @@ import org.slf4j.LoggerFactory; if (other.isSetSchedulingPolicy()) { this.schedulingPolicy = other.schedulingPolicy; } + if (other.isSetNs()) { + this.ns = other.ns; + } } public WMPool deepCopy() { @@ -191,6 +201,7 @@ import org.slf4j.LoggerFactory; setQueryParallelismIsSet(false); this.queryParallelism = 0; this.schedulingPolicy = null; + this.ns = null; } public String getResourcePlanName() { @@ -306,6 +317,29 @@ import org.slf4j.LoggerFactory; } } + public String getNs() { + return this.ns; + } + + public void setNs(String ns) { + this.ns = ns; + } + + public void unsetNs() { + this.ns = null; + } + + /** Returns true if field ns is set (has been assigned a value) and false otherwise */ + public boolean isSetNs() { + return this.ns != null; + } + + public void setNsIsSet(boolean value) { + if (!value) { + this.ns = null; + } + } + public void setFieldValue(_Fields field, Object value) { switch (field) { case RESOURCE_PLAN_NAME: @@ -348,6 +382,14 @@ import org.slf4j.LoggerFactory; } break; + case NS: + if (value == null) { + unsetNs(); + } else { + setNs((String)value); + } + break; + } } @@ -368,6 +410,9 @@ import org.slf4j.LoggerFactory; case SCHEDULING_POLICY: return getSchedulingPolicy(); + case NS: + return getNs(); + } throw new IllegalStateException(); } @@ -389,6 +434,8 @@ import org.slf4j.LoggerFactory; return isSetQueryParallelism(); case SCHEDULING_POLICY: return isSetSchedulingPolicy(); + case NS: + return isSetNs(); } throw new IllegalStateException(); } @@ -451,6 +498,15 @@ import org.slf4j.LoggerFactory; return false; } + boolean this_present_ns = true && this.isSetNs(); + boolean that_present_ns = true && that.isSetNs(); + if (this_present_ns || that_present_ns) { + if (!(this_present_ns && that_present_ns)) + return false; + if (!this.ns.equals(that.ns)) + return false; + } + return true; } @@ -483,6 +539,11 @@ import org.slf4j.LoggerFactory; if (present_schedulingPolicy) list.add(schedulingPolicy); + boolean present_ns = true && (isSetNs()); + list.add(present_ns); + if (present_ns) + list.add(ns); + return list.hashCode(); } @@ -544,6 +605,16 @@ import org.slf4j.LoggerFactory; return lastComparison; } } + lastComparison = Boolean.valueOf(isSetNs()).compareTo(other.isSetNs()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetNs()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ns, other.ns); + if (lastComparison != 0) { + return lastComparison; + } + } return 0; } @@ -601,6 +672,16 @@ import org.slf4j.LoggerFactory; } first = false; } + if (isSetNs()) { + if (!first) sb.append(", "); + sb.append("ns:"); + if (this.ns == null) { + sb.append("null"); + } else { + sb.append(this.ns); + } + first = false; + } sb.append(")"); return sb.toString(); } @@ -694,6 +775,14 @@ import org.slf4j.LoggerFactory; org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; + case 6: // NS + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.ns = iprot.readString(); + struct.setNsIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -734,6 +823,13 @@ import org.slf4j.LoggerFactory; oprot.writeFieldEnd(); } } + if (struct.ns != null) { + if (struct.isSetNs()) { + oprot.writeFieldBegin(NS_FIELD_DESC); + oprot.writeString(struct.ns); + oprot.writeFieldEnd(); + } + } oprot.writeFieldStop(); oprot.writeStructEnd(); } @@ -763,7 +859,10 @@ import org.slf4j.LoggerFactory; if (struct.isSetSchedulingPolicy()) { optionals.set(2); } - oprot.writeBitSet(optionals, 3); + if (struct.isSetNs()) { + optionals.set(3); + } + oprot.writeBitSet(optionals, 4); if (struct.isSetAllocFraction()) { oprot.writeDouble(struct.allocFraction); } @@ -773,6 +872,9 @@ import org.slf4j.LoggerFactory; if (struct.isSetSchedulingPolicy()) { oprot.writeString(struct.schedulingPolicy); } + if (struct.isSetNs()) { + oprot.writeString(struct.ns); + } } @Override @@ -782,7 +884,7 @@ import org.slf4j.LoggerFactory; struct.setResourcePlanNameIsSet(true); struct.poolPath = iprot.readString(); struct.setPoolPathIsSet(true); - BitSet incoming = iprot.readBitSet(3); + BitSet incoming = iprot.readBitSet(4); if (incoming.get(0)) { struct.allocFraction = iprot.readDouble(); struct.setAllocFractionIsSet(true); @@ -795,6 +897,10 @@ import org.slf4j.LoggerFactory; struct.schedulingPolicy = iprot.readString(); struct.setSchedulingPolicyIsSet(true); } + if (incoming.get(3)) { + struct.ns = iprot.readString(); + struct.setNsIsSet(true); + } } } http://git-wip-us.apache.org/repos/asf/hive/blob/5258c67e/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMPoolTrigger.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMPoolTrigger.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMPoolTrigger.java index efbb5e6..d6db458 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMPoolTrigger.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMPoolTrigger.java @@ -40,6 +40,7 @@ import org.slf4j.LoggerFactory; private static final org.apache.thrift.protocol.TField POOL_FIELD_DESC = new org.apache.thrift.protocol.TField("pool", org.apache.thrift.protocol.TType.STRING, (short)1); private static final org.apache.thrift.protocol.TField TRIGGER_FIELD_DESC = new org.apache.thrift.protocol.TField("trigger", org.apache.thrift.protocol.TType.STRING, (short)2); + private static final org.apache.thrift.protocol.TField NS_FIELD_DESC = new org.apache.thrift.protocol.TField("ns", org.apache.thrift.protocol.TType.STRING, (short)3); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -49,11 +50,13 @@ import org.slf4j.LoggerFactory; private String pool; // required private String trigger; // required + private String ns; // optional /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { POOL((short)1, "pool"), - TRIGGER((short)2, "trigger"); + TRIGGER((short)2, "trigger"), + NS((short)3, "ns"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -72,6 +75,8 @@ import org.slf4j.LoggerFactory; return POOL; case 2: // TRIGGER return TRIGGER; + case 3: // NS + return NS; default: return null; } @@ -112,6 +117,7 @@ import org.slf4j.LoggerFactory; } // isset id assignments + private static final _Fields optionals[] = {_Fields.NS}; 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); @@ -119,6 +125,8 @@ import org.slf4j.LoggerFactory; new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); tmpMap.put(_Fields.TRIGGER, new org.apache.thrift.meta_data.FieldMetaData("trigger", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.NS, new org.apache.thrift.meta_data.FieldMetaData("ns", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(WMPoolTrigger.class, metaDataMap); } @@ -145,6 +153,9 @@ import org.slf4j.LoggerFactory; if (other.isSetTrigger()) { this.trigger = other.trigger; } + if (other.isSetNs()) { + this.ns = other.ns; + } } public WMPoolTrigger deepCopy() { @@ -155,6 +166,7 @@ import org.slf4j.LoggerFactory; public void clear() { this.pool = null; this.trigger = null; + this.ns = null; } public String getPool() { @@ -203,6 +215,29 @@ import org.slf4j.LoggerFactory; } } + public String getNs() { + return this.ns; + } + + public void setNs(String ns) { + this.ns = ns; + } + + public void unsetNs() { + this.ns = null; + } + + /** Returns true if field ns is set (has been assigned a value) and false otherwise */ + public boolean isSetNs() { + return this.ns != null; + } + + public void setNsIsSet(boolean value) { + if (!value) { + this.ns = null; + } + } + public void setFieldValue(_Fields field, Object value) { switch (field) { case POOL: @@ -221,6 +256,14 @@ import org.slf4j.LoggerFactory; } break; + case NS: + if (value == null) { + unsetNs(); + } else { + setNs((String)value); + } + break; + } } @@ -232,6 +275,9 @@ import org.slf4j.LoggerFactory; case TRIGGER: return getTrigger(); + case NS: + return getNs(); + } throw new IllegalStateException(); } @@ -247,6 +293,8 @@ import org.slf4j.LoggerFactory; return isSetPool(); case TRIGGER: return isSetTrigger(); + case NS: + return isSetNs(); } throw new IllegalStateException(); } @@ -282,6 +330,15 @@ import org.slf4j.LoggerFactory; return false; } + boolean this_present_ns = true && this.isSetNs(); + boolean that_present_ns = true && that.isSetNs(); + if (this_present_ns || that_present_ns) { + if (!(this_present_ns && that_present_ns)) + return false; + if (!this.ns.equals(that.ns)) + return false; + } + return true; } @@ -299,6 +356,11 @@ import org.slf4j.LoggerFactory; if (present_trigger) list.add(trigger); + boolean present_ns = true && (isSetNs()); + list.add(present_ns); + if (present_ns) + list.add(ns); + return list.hashCode(); } @@ -330,6 +392,16 @@ import org.slf4j.LoggerFactory; return lastComparison; } } + lastComparison = Boolean.valueOf(isSetNs()).compareTo(other.isSetNs()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetNs()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ns, other.ns); + if (lastComparison != 0) { + return lastComparison; + } + } return 0; } @@ -365,6 +437,16 @@ import org.slf4j.LoggerFactory; sb.append(this.trigger); } first = false; + if (isSetNs()) { + if (!first) sb.append(", "); + sb.append("ns:"); + if (this.ns == null) { + sb.append("null"); + } else { + sb.append(this.ns); + } + first = false; + } sb.append(")"); return sb.toString(); } @@ -432,6 +514,14 @@ import org.slf4j.LoggerFactory; org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; + case 3: // NS + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.ns = iprot.readString(); + struct.setNsIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -455,6 +545,13 @@ import org.slf4j.LoggerFactory; oprot.writeString(struct.trigger); oprot.writeFieldEnd(); } + if (struct.ns != null) { + if (struct.isSetNs()) { + oprot.writeFieldBegin(NS_FIELD_DESC); + oprot.writeString(struct.ns); + oprot.writeFieldEnd(); + } + } oprot.writeFieldStop(); oprot.writeStructEnd(); } @@ -474,6 +571,14 @@ import org.slf4j.LoggerFactory; TTupleProtocol oprot = (TTupleProtocol) prot; oprot.writeString(struct.pool); oprot.writeString(struct.trigger); + BitSet optionals = new BitSet(); + if (struct.isSetNs()) { + optionals.set(0); + } + oprot.writeBitSet(optionals, 1); + if (struct.isSetNs()) { + oprot.writeString(struct.ns); + } } @Override @@ -483,6 +588,11 @@ import org.slf4j.LoggerFactory; struct.setPoolIsSet(true); struct.trigger = iprot.readString(); struct.setTriggerIsSet(true); + BitSet incoming = iprot.readBitSet(1); + if (incoming.get(0)) { + struct.ns = iprot.readString(); + struct.setNsIsSet(true); + } } } http://git-wip-us.apache.org/repos/asf/hive/blob/5258c67e/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMResourcePlan.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMResourcePlan.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMResourcePlan.java index d9f8c02..a96757b 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMResourcePlan.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMResourcePlan.java @@ -42,6 +42,7 @@ import org.slf4j.LoggerFactory; private static final org.apache.thrift.protocol.TField STATUS_FIELD_DESC = new org.apache.thrift.protocol.TField("status", org.apache.thrift.protocol.TType.I32, (short)2); private static final org.apache.thrift.protocol.TField QUERY_PARALLELISM_FIELD_DESC = new org.apache.thrift.protocol.TField("queryParallelism", org.apache.thrift.protocol.TType.I32, (short)3); private static final org.apache.thrift.protocol.TField DEFAULT_POOL_PATH_FIELD_DESC = new org.apache.thrift.protocol.TField("defaultPoolPath", org.apache.thrift.protocol.TType.STRING, (short)4); + private static final org.apache.thrift.protocol.TField NS_FIELD_DESC = new org.apache.thrift.protocol.TField("ns", org.apache.thrift.protocol.TType.STRING, (short)5); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -53,6 +54,7 @@ import org.slf4j.LoggerFactory; private WMResourcePlanStatus status; // optional private int queryParallelism; // optional private String defaultPoolPath; // optional + private String ns; // optional /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { @@ -63,7 +65,8 @@ import org.slf4j.LoggerFactory; */ STATUS((short)2, "status"), QUERY_PARALLELISM((short)3, "queryParallelism"), - DEFAULT_POOL_PATH((short)4, "defaultPoolPath"); + DEFAULT_POOL_PATH((short)4, "defaultPoolPath"), + NS((short)5, "ns"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -86,6 +89,8 @@ import org.slf4j.LoggerFactory; return QUERY_PARALLELISM; case 4: // DEFAULT_POOL_PATH return DEFAULT_POOL_PATH; + case 5: // NS + return NS; default: return null; } @@ -128,7 +133,7 @@ import org.slf4j.LoggerFactory; // isset id assignments private static final int __QUERYPARALLELISM_ISSET_ID = 0; private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.STATUS,_Fields.QUERY_PARALLELISM,_Fields.DEFAULT_POOL_PATH}; + private static final _Fields optionals[] = {_Fields.STATUS,_Fields.QUERY_PARALLELISM,_Fields.DEFAULT_POOL_PATH,_Fields.NS}; 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); @@ -140,6 +145,8 @@ import org.slf4j.LoggerFactory; new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); tmpMap.put(_Fields.DEFAULT_POOL_PATH, new org.apache.thrift.meta_data.FieldMetaData("defaultPoolPath", org.apache.thrift.TFieldRequirementType.OPTIONAL, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.NS, new org.apache.thrift.meta_data.FieldMetaData("ns", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(WMResourcePlan.class, metaDataMap); } @@ -169,6 +176,9 @@ import org.slf4j.LoggerFactory; if (other.isSetDefaultPoolPath()) { this.defaultPoolPath = other.defaultPoolPath; } + if (other.isSetNs()) { + this.ns = other.ns; + } } public WMResourcePlan deepCopy() { @@ -182,6 +192,7 @@ import org.slf4j.LoggerFactory; setQueryParallelismIsSet(false); this.queryParallelism = 0; this.defaultPoolPath = null; + this.ns = null; } public String getName() { @@ -283,6 +294,29 @@ import org.slf4j.LoggerFactory; } } + public String getNs() { + return this.ns; + } + + public void setNs(String ns) { + this.ns = ns; + } + + public void unsetNs() { + this.ns = null; + } + + /** Returns true if field ns is set (has been assigned a value) and false otherwise */ + public boolean isSetNs() { + return this.ns != null; + } + + public void setNsIsSet(boolean value) { + if (!value) { + this.ns = null; + } + } + public void setFieldValue(_Fields field, Object value) { switch (field) { case NAME: @@ -317,6 +351,14 @@ import org.slf4j.LoggerFactory; } break; + case NS: + if (value == null) { + unsetNs(); + } else { + setNs((String)value); + } + break; + } } @@ -334,6 +376,9 @@ import org.slf4j.LoggerFactory; case DEFAULT_POOL_PATH: return getDefaultPoolPath(); + case NS: + return getNs(); + } throw new IllegalStateException(); } @@ -353,6 +398,8 @@ import org.slf4j.LoggerFactory; return isSetQueryParallelism(); case DEFAULT_POOL_PATH: return isSetDefaultPoolPath(); + case NS: + return isSetNs(); } throw new IllegalStateException(); } @@ -406,6 +453,15 @@ import org.slf4j.LoggerFactory; return false; } + boolean this_present_ns = true && this.isSetNs(); + boolean that_present_ns = true && that.isSetNs(); + if (this_present_ns || that_present_ns) { + if (!(this_present_ns && that_present_ns)) + return false; + if (!this.ns.equals(that.ns)) + return false; + } + return true; } @@ -433,6 +489,11 @@ import org.slf4j.LoggerFactory; if (present_defaultPoolPath) list.add(defaultPoolPath); + boolean present_ns = true && (isSetNs()); + list.add(present_ns); + if (present_ns) + list.add(ns); + return list.hashCode(); } @@ -484,6 +545,16 @@ import org.slf4j.LoggerFactory; return lastComparison; } } + lastComparison = Boolean.valueOf(isSetNs()).compareTo(other.isSetNs()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetNs()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ns, other.ns); + if (lastComparison != 0) { + return lastComparison; + } + } return 0; } @@ -537,6 +608,16 @@ import org.slf4j.LoggerFactory; } first = false; } + if (isSetNs()) { + if (!first) sb.append(", "); + sb.append("ns:"); + if (this.ns == null) { + sb.append("null"); + } else { + sb.append(this.ns); + } + first = false; + } sb.append(")"); return sb.toString(); } @@ -618,6 +699,14 @@ import org.slf4j.LoggerFactory; org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; + case 5: // NS + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.ns = iprot.readString(); + struct.setNsIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -655,6 +744,13 @@ import org.slf4j.LoggerFactory; oprot.writeFieldEnd(); } } + if (struct.ns != null) { + if (struct.isSetNs()) { + oprot.writeFieldBegin(NS_FIELD_DESC); + oprot.writeString(struct.ns); + oprot.writeFieldEnd(); + } + } oprot.writeFieldStop(); oprot.writeStructEnd(); } @@ -683,7 +779,10 @@ import org.slf4j.LoggerFactory; if (struct.isSetDefaultPoolPath()) { optionals.set(2); } - oprot.writeBitSet(optionals, 3); + if (struct.isSetNs()) { + optionals.set(3); + } + oprot.writeBitSet(optionals, 4); if (struct.isSetStatus()) { oprot.writeI32(struct.status.getValue()); } @@ -693,6 +792,9 @@ import org.slf4j.LoggerFactory; if (struct.isSetDefaultPoolPath()) { oprot.writeString(struct.defaultPoolPath); } + if (struct.isSetNs()) { + oprot.writeString(struct.ns); + } } @Override @@ -700,7 +802,7 @@ import org.slf4j.LoggerFactory; TTupleProtocol iprot = (TTupleProtocol) prot; struct.name = iprot.readString(); struct.setNameIsSet(true); - BitSet incoming = iprot.readBitSet(3); + BitSet incoming = iprot.readBitSet(4); if (incoming.get(0)) { struct.status = org.apache.hadoop.hive.metastore.api.WMResourcePlanStatus.findByValue(iprot.readI32()); struct.setStatusIsSet(true); @@ -713,6 +815,10 @@ import org.slf4j.LoggerFactory; struct.defaultPoolPath = iprot.readString(); struct.setDefaultPoolPathIsSet(true); } + if (incoming.get(3)) { + struct.ns = iprot.readString(); + struct.setNsIsSet(true); + } } } http://git-wip-us.apache.org/repos/asf/hive/blob/5258c67e/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMTrigger.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMTrigger.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMTrigger.java index 63bd40f..820b6d5 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMTrigger.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMTrigger.java @@ -43,6 +43,7 @@ import org.slf4j.LoggerFactory; private static final org.apache.thrift.protocol.TField TRIGGER_EXPRESSION_FIELD_DESC = new org.apache.thrift.protocol.TField("triggerExpression", org.apache.thrift.protocol.TType.STRING, (short)3); private static final org.apache.thrift.protocol.TField ACTION_EXPRESSION_FIELD_DESC = new org.apache.thrift.protocol.TField("actionExpression", org.apache.thrift.protocol.TType.STRING, (short)4); private static final org.apache.thrift.protocol.TField IS_IN_UNMANAGED_FIELD_DESC = new org.apache.thrift.protocol.TField("isInUnmanaged", org.apache.thrift.protocol.TType.BOOL, (short)5); + private static final org.apache.thrift.protocol.TField NS_FIELD_DESC = new org.apache.thrift.protocol.TField("ns", org.apache.thrift.protocol.TType.STRING, (short)6); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -55,6 +56,7 @@ import org.slf4j.LoggerFactory; private String triggerExpression; // optional private String actionExpression; // optional private boolean isInUnmanaged; // optional + private String ns; // optional /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { @@ -62,7 +64,8 @@ import org.slf4j.LoggerFactory; TRIGGER_NAME((short)2, "triggerName"), TRIGGER_EXPRESSION((short)3, "triggerExpression"), ACTION_EXPRESSION((short)4, "actionExpression"), - IS_IN_UNMANAGED((short)5, "isInUnmanaged"); + IS_IN_UNMANAGED((short)5, "isInUnmanaged"), + NS((short)6, "ns"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -87,6 +90,8 @@ import org.slf4j.LoggerFactory; return ACTION_EXPRESSION; case 5: // IS_IN_UNMANAGED return IS_IN_UNMANAGED; + case 6: // NS + return NS; default: return null; } @@ -129,7 +134,7 @@ import org.slf4j.LoggerFactory; // isset id assignments private static final int __ISINUNMANAGED_ISSET_ID = 0; private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.TRIGGER_EXPRESSION,_Fields.ACTION_EXPRESSION,_Fields.IS_IN_UNMANAGED}; + private static final _Fields optionals[] = {_Fields.TRIGGER_EXPRESSION,_Fields.ACTION_EXPRESSION,_Fields.IS_IN_UNMANAGED,_Fields.NS}; 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); @@ -143,6 +148,8 @@ import org.slf4j.LoggerFactory; new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); tmpMap.put(_Fields.IS_IN_UNMANAGED, new org.apache.thrift.meta_data.FieldMetaData("isInUnmanaged", org.apache.thrift.TFieldRequirementType.OPTIONAL, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL))); + tmpMap.put(_Fields.NS, new org.apache.thrift.meta_data.FieldMetaData("ns", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(WMTrigger.class, metaDataMap); } @@ -177,6 +184,9 @@ import org.slf4j.LoggerFactory; this.actionExpression = other.actionExpression; } this.isInUnmanaged = other.isInUnmanaged; + if (other.isSetNs()) { + this.ns = other.ns; + } } public WMTrigger deepCopy() { @@ -191,6 +201,7 @@ import org.slf4j.LoggerFactory; this.actionExpression = null; setIsInUnmanagedIsSet(false); this.isInUnmanaged = false; + this.ns = null; } public String getResourcePlanName() { @@ -307,6 +318,29 @@ import org.slf4j.LoggerFactory; __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ISINUNMANAGED_ISSET_ID, value); } + public String getNs() { + return this.ns; + } + + public void setNs(String ns) { + this.ns = ns; + } + + public void unsetNs() { + this.ns = null; + } + + /** Returns true if field ns is set (has been assigned a value) and false otherwise */ + public boolean isSetNs() { + return this.ns != null; + } + + public void setNsIsSet(boolean value) { + if (!value) { + this.ns = null; + } + } + public void setFieldValue(_Fields field, Object value) { switch (field) { case RESOURCE_PLAN_NAME: @@ -349,6 +383,14 @@ import org.slf4j.LoggerFactory; } break; + case NS: + if (value == null) { + unsetNs(); + } else { + setNs((String)value); + } + break; + } } @@ -369,6 +411,9 @@ import org.slf4j.LoggerFactory; case IS_IN_UNMANAGED: return isIsInUnmanaged(); + case NS: + return getNs(); + } throw new IllegalStateException(); } @@ -390,6 +435,8 @@ import org.slf4j.LoggerFactory; return isSetActionExpression(); case IS_IN_UNMANAGED: return isSetIsInUnmanaged(); + case NS: + return isSetNs(); } throw new IllegalStateException(); } @@ -452,6 +499,15 @@ import org.slf4j.LoggerFactory; return false; } + boolean this_present_ns = true && this.isSetNs(); + boolean that_present_ns = true && that.isSetNs(); + if (this_present_ns || that_present_ns) { + if (!(this_present_ns && that_present_ns)) + return false; + if (!this.ns.equals(that.ns)) + return false; + } + return true; } @@ -484,6 +540,11 @@ import org.slf4j.LoggerFactory; if (present_isInUnmanaged) list.add(isInUnmanaged); + boolean present_ns = true && (isSetNs()); + list.add(present_ns); + if (present_ns) + list.add(ns); + return list.hashCode(); } @@ -545,6 +606,16 @@ import org.slf4j.LoggerFactory; return lastComparison; } } + lastComparison = Boolean.valueOf(isSetNs()).compareTo(other.isSetNs()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetNs()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ns, other.ns); + if (lastComparison != 0) { + return lastComparison; + } + } return 0; } @@ -606,6 +677,16 @@ import org.slf4j.LoggerFactory; sb.append(this.isInUnmanaged); first = false; } + if (isSetNs()) { + if (!first) sb.append(", "); + sb.append("ns:"); + if (this.ns == null) { + sb.append("null"); + } else { + sb.append(this.ns); + } + first = false; + } sb.append(")"); return sb.toString(); } @@ -699,6 +780,14 @@ import org.slf4j.LoggerFactory; org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; + case 6: // NS + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.ns = iprot.readString(); + struct.setNsIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -741,6 +830,13 @@ import org.slf4j.LoggerFactory; oprot.writeBool(struct.isInUnmanaged); oprot.writeFieldEnd(); } + if (struct.ns != null) { + if (struct.isSetNs()) { + oprot.writeFieldBegin(NS_FIELD_DESC); + oprot.writeString(struct.ns); + oprot.writeFieldEnd(); + } + } oprot.writeFieldStop(); oprot.writeStructEnd(); } @@ -770,7 +866,10 @@ import org.slf4j.LoggerFactory; if (struct.isSetIsInUnmanaged()) { optionals.set(2); } - oprot.writeBitSet(optionals, 3); + if (struct.isSetNs()) { + optionals.set(3); + } + oprot.writeBitSet(optionals, 4); if (struct.isSetTriggerExpression()) { oprot.writeString(struct.triggerExpression); } @@ -780,6 +879,9 @@ import org.slf4j.LoggerFactory; if (struct.isSetIsInUnmanaged()) { oprot.writeBool(struct.isInUnmanaged); } + if (struct.isSetNs()) { + oprot.writeString(struct.ns); + } } @Override @@ -789,7 +891,7 @@ import org.slf4j.LoggerFactory; struct.setResourcePlanNameIsSet(true); struct.triggerName = iprot.readString(); struct.setTriggerNameIsSet(true); - BitSet incoming = iprot.readBitSet(3); + BitSet incoming = iprot.readBitSet(4); if (incoming.get(0)) { struct.triggerExpression = iprot.readString(); struct.setTriggerExpressionIsSet(true); @@ -802,6 +904,10 @@ import org.slf4j.LoggerFactory; struct.isInUnmanaged = iprot.readBool(); struct.setIsInUnmanagedIsSet(true); } + if (incoming.get(3)) { + struct.ns = iprot.readString(); + struct.setNsIsSet(true); + } } } http://git-wip-us.apache.org/repos/asf/hive/blob/5258c67e/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanRequest.java index aad6d43..0c81199 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanRequest.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanRequest.java @@ -39,6 +39,7 @@ import org.slf4j.LoggerFactory; private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WMValidateResourcePlanRequest"); private static final org.apache.thrift.protocol.TField RESOURCE_PLAN_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("resourcePlanName", org.apache.thrift.protocol.TType.STRING, (short)1); + private static final org.apache.thrift.protocol.TField NS_FIELD_DESC = new org.apache.thrift.protocol.TField("ns", org.apache.thrift.protocol.TType.STRING, (short)2); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -47,10 +48,12 @@ import org.slf4j.LoggerFactory; } private String resourcePlanName; // optional + private String ns; // optional /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { - RESOURCE_PLAN_NAME((short)1, "resourcePlanName"); + RESOURCE_PLAN_NAME((short)1, "resourcePlanName"), + NS((short)2, "ns"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -67,6 +70,8 @@ import org.slf4j.LoggerFactory; switch(fieldId) { case 1: // RESOURCE_PLAN_NAME return RESOURCE_PLAN_NAME; + case 2: // NS + return NS; default: return null; } @@ -107,12 +112,14 @@ import org.slf4j.LoggerFactory; } // isset id assignments - private static final _Fields optionals[] = {_Fields.RESOURCE_PLAN_NAME}; + private static final _Fields optionals[] = {_Fields.RESOURCE_PLAN_NAME,_Fields.NS}; 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.RESOURCE_PLAN_NAME, new org.apache.thrift.meta_data.FieldMetaData("resourcePlanName", org.apache.thrift.TFieldRequirementType.OPTIONAL, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.NS, new org.apache.thrift.meta_data.FieldMetaData("ns", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(WMValidateResourcePlanRequest.class, metaDataMap); } @@ -127,6 +134,9 @@ import org.slf4j.LoggerFactory; if (other.isSetResourcePlanName()) { this.resourcePlanName = other.resourcePlanName; } + if (other.isSetNs()) { + this.ns = other.ns; + } } public WMValidateResourcePlanRequest deepCopy() { @@ -136,6 +146,7 @@ import org.slf4j.LoggerFactory; @Override public void clear() { this.resourcePlanName = null; + this.ns = null; } public String getResourcePlanName() { @@ -161,6 +172,29 @@ import org.slf4j.LoggerFactory; } } + public String getNs() { + return this.ns; + } + + public void setNs(String ns) { + this.ns = ns; + } + + public void unsetNs() { + this.ns = null; + } + + /** Returns true if field ns is set (has been assigned a value) and false otherwise */ + public boolean isSetNs() { + return this.ns != null; + } + + public void setNsIsSet(boolean value) { + if (!value) { + this.ns = null; + } + } + public void setFieldValue(_Fields field, Object value) { switch (field) { case RESOURCE_PLAN_NAME: @@ -171,6 +205,14 @@ import org.slf4j.LoggerFactory; } break; + case NS: + if (value == null) { + unsetNs(); + } else { + setNs((String)value); + } + break; + } } @@ -179,6 +221,9 @@ import org.slf4j.LoggerFactory; case RESOURCE_PLAN_NAME: return getResourcePlanName(); + case NS: + return getNs(); + } throw new IllegalStateException(); } @@ -192,6 +237,8 @@ import org.slf4j.LoggerFactory; switch (field) { case RESOURCE_PLAN_NAME: return isSetResourcePlanName(); + case NS: + return isSetNs(); } throw new IllegalStateException(); } @@ -218,6 +265,15 @@ import org.slf4j.LoggerFactory; return false; } + boolean this_present_ns = true && this.isSetNs(); + boolean that_present_ns = true && that.isSetNs(); + if (this_present_ns || that_present_ns) { + if (!(this_present_ns && that_present_ns)) + return false; + if (!this.ns.equals(that.ns)) + return false; + } + return true; } @@ -230,6 +286,11 @@ import org.slf4j.LoggerFactory; if (present_resourcePlanName) list.add(resourcePlanName); + boolean present_ns = true && (isSetNs()); + list.add(present_ns); + if (present_ns) + list.add(ns); + return list.hashCode(); } @@ -251,6 +312,16 @@ import org.slf4j.LoggerFactory; return lastComparison; } } + lastComparison = Boolean.valueOf(isSetNs()).compareTo(other.isSetNs()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetNs()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.ns, other.ns); + if (lastComparison != 0) { + return lastComparison; + } + } return 0; } @@ -280,6 +351,16 @@ import org.slf4j.LoggerFactory; } first = false; } + if (isSetNs()) { + if (!first) sb.append(", "); + sb.append("ns:"); + if (this.ns == null) { + sb.append("null"); + } else { + sb.append(this.ns); + } + first = false; + } sb.append(")"); return sb.toString(); } @@ -331,6 +412,14 @@ import org.slf4j.LoggerFactory; org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; + case 2: // NS + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.ns = iprot.readString(); + struct.setNsIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -351,6 +440,13 @@ import org.slf4j.LoggerFactory; oprot.writeFieldEnd(); } } + if (struct.ns != null) { + if (struct.isSetNs()) { + oprot.writeFieldBegin(NS_FIELD_DESC); + oprot.writeString(struct.ns); + oprot.writeFieldEnd(); + } + } oprot.writeFieldStop(); oprot.writeStructEnd(); } @@ -372,20 +468,30 @@ import org.slf4j.LoggerFactory; if (struct.isSetResourcePlanName()) { optionals.set(0); } - oprot.writeBitSet(optionals, 1); + if (struct.isSetNs()) { + optionals.set(1); + } + oprot.writeBitSet(optionals, 2); if (struct.isSetResourcePlanName()) { oprot.writeString(struct.resourcePlanName); } + if (struct.isSetNs()) { + oprot.writeString(struct.ns); + } } @Override public void read(org.apache.thrift.protocol.TProtocol prot, WMValidateResourcePlanRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(1); + BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { struct.resourcePlanName = iprot.readString(); struct.setResourcePlanNameIsSet(true); } + if (incoming.get(1)) { + struct.ns = iprot.readString(); + struct.setNsIsSet(true); + } } } http://git-wip-us.apache.org/repos/asf/hive/blob/5258c67e/standalone-metastore/metastore-common/src/gen/thrift/gen-php/metastore/Types.php ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-php/metastore/Types.php b/standalone-metastore/metastore-common/src/gen/thrift/gen-php/metastore/Types.php index 5fd5d78..bf6dfba 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-php/metastore/Types.php +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-php/metastore/Types.php @@ -26084,6 +26084,10 @@ class WMResourcePlan { * @var string */ public $defaultPoolPath = null; + /** + * @var string + */ + public $ns = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -26104,6 +26108,10 @@ class WMResourcePlan { 'var' => 'defaultPoolPath', 'type' => TType::STRING, ), + 5 => array( + 'var' => 'ns', + 'type' => TType::STRING, + ), ); } if (is_array($vals)) { @@ -26119,6 +26127,9 @@ class WMResourcePlan { if (isset($vals['defaultPoolPath'])) { $this->defaultPoolPath = $vals['defaultPoolPath']; } + if (isset($vals['ns'])) { + $this->ns = $vals['ns']; + } } } @@ -26169,6 +26180,13 @@ class WMResourcePlan { $xfer += $input->skip($ftype); } break; + case 5: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ns); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -26202,6 +26220,11 @@ class WMResourcePlan { $xfer += $output->writeString($this->defaultPoolPath); $xfer += $output->writeFieldEnd(); } + if ($this->ns !== null) { + $xfer += $output->writeFieldBegin('ns', TType::STRING, 5); + $xfer += $output->writeString($this->ns); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -26236,6 +26259,10 @@ class WMNullableResourcePlan { * @var bool */ public $isSetDefaultPoolPath = null; + /** + * @var string + */ + public $ns = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -26264,6 +26291,10 @@ class WMNullableResourcePlan { 'var' => 'isSetDefaultPoolPath', 'type' => TType::BOOL, ), + 8 => array( + 'var' => 'ns', + 'type' => TType::STRING, + ), ); } if (is_array($vals)) { @@ -26285,6 +26316,9 @@ class WMNullableResourcePlan { if (isset($vals['isSetDefaultPoolPath'])) { $this->isSetDefaultPoolPath = $vals['isSetDefaultPoolPath']; } + if (isset($vals['ns'])) { + $this->ns = $vals['ns']; + } } } @@ -26349,6 +26383,13 @@ class WMNullableResourcePlan { $xfer += $input->skip($ftype); } break; + case 8: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ns); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -26392,6 +26433,11 @@ class WMNullableResourcePlan { $xfer += $output->writeBool($this->isSetDefaultPoolPath); $xfer += $output->writeFieldEnd(); } + if ($this->ns !== null) { + $xfer += $output->writeFieldBegin('ns', TType::STRING, 8); + $xfer += $output->writeString($this->ns); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -26422,6 +26468,10 @@ class WMPool { * @var string */ public $schedulingPolicy = null; + /** + * @var string + */ + public $ns = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -26446,6 +26496,10 @@ class WMPool { 'var' => 'schedulingPolicy', 'type' => TType::STRING, ), + 6 => array( + 'var' => 'ns', + 'type' => TType::STRING, + ), ); } if (is_array($vals)) { @@ -26464,6 +26518,9 @@ class WMPool { if (isset($vals['schedulingPolicy'])) { $this->schedulingPolicy = $vals['schedulingPolicy']; } + if (isset($vals['ns'])) { + $this->ns = $vals['ns']; + } } } @@ -26521,6 +26578,13 @@ class WMPool { $xfer += $input->skip($ftype); } break; + case 6: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ns); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -26559,6 +26623,11 @@ class WMPool { $xfer += $output->writeString($this->schedulingPolicy); $xfer += $output->writeFieldEnd(); } + if ($this->ns !== null) { + $xfer += $output->writeFieldBegin('ns', TType::STRING, 6); + $xfer += $output->writeString($this->ns); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -26593,6 +26662,10 @@ class WMNullablePool { * @var bool */ public $isSetSchedulingPolicy = null; + /** + * @var string + */ + public $ns = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -26621,6 +26694,10 @@ class WMNullablePool { 'var' => 'isSetSchedulingPolicy', 'type' => TType::BOOL, ), + 7 => array( + 'var' => 'ns', + 'type' => TType::STRING, + ), ); } if (is_array($vals)) { @@ -26642,6 +26719,9 @@ class WMNullablePool { if (isset($vals['isSetSchedulingPolicy'])) { $this->isSetSchedulingPolicy = $vals['isSetSchedulingPolicy']; } + if (isset($vals['ns'])) { + $this->ns = $vals['ns']; + } } } @@ -26706,6 +26786,13 @@ class WMNullablePool { $xfer += $input->skip($ftype); } break; + case 7: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ns); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -26749,6 +26836,11 @@ class WMNullablePool { $xfer += $output->writeBool($this->isSetSchedulingPolicy); $xfer += $output->writeFieldEnd(); } + if ($this->ns !== null) { + $xfer += $output->writeFieldBegin('ns', TType::STRING, 7); + $xfer += $output->writeString($this->ns); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -26779,6 +26871,10 @@ class WMTrigger { * @var bool */ public $isInUnmanaged = null; + /** + * @var string + */ + public $ns = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -26803,6 +26899,10 @@ class WMTrigger { 'var' => 'isInUnmanaged', 'type' => TType::BOOL, ), + 6 => array( + 'var' => 'ns', + 'type' => TType::STRING, + ), ); } if (is_array($vals)) { @@ -26821,6 +26921,9 @@ class WMTrigger { if (isset($vals['isInUnmanaged'])) { $this->isInUnmanaged = $vals['isInUnmanaged']; } + if (isset($vals['ns'])) { + $this->ns = $vals['ns']; + } } } @@ -26878,6 +26981,13 @@ class WMTrigger { $xfer += $input->skip($ftype); } break; + case 6: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ns); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -26916,6 +27026,11 @@ class WMTrigger { $xfer += $output->writeBool($this->isInUnmanaged); $xfer += $output->writeFieldEnd(); } + if ($this->ns !== null) { + $xfer += $output->writeFieldBegin('ns', TType::STRING, 6); + $xfer += $output->writeString($this->ns); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -26946,6 +27061,10 @@ class WMMapping { * @var int */ public $ordering = null; + /** + * @var string + */ + public $ns = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -26970,6 +27089,10 @@ class WMMapping { 'var' => 'ordering', 'type' => TType::I32, ), + 6 => array( + 'var' => 'ns', + 'type' => TType::STRING, + ), ); } if (is_array($vals)) { @@ -26988,6 +27111,9 @@ class WMMapping { if (isset($vals['ordering'])) { $this->ordering = $vals['ordering']; } + if (isset($vals['ns'])) { + $this->ns = $vals['ns']; + } } } @@ -27045,6 +27171,13 @@ class WMMapping { $xfer += $input->skip($ftype); } break; + case 6: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ns); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -27083,6 +27216,11 @@ class WMMapping { $xfer += $output->writeI32($this->ordering); $xfer += $output->writeFieldEnd(); } + if ($this->ns !== null) { + $xfer += $output->writeFieldBegin('ns', TType::STRING, 6); + $xfer += $output->writeString($this->ns); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -27101,6 +27239,10 @@ class WMPoolTrigger { * @var string */ public $trigger = null; + /** + * @var string + */ + public $ns = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -27113,6 +27255,10 @@ class WMPoolTrigger { 'var' => 'trigger', 'type' => TType::STRING, ), + 3 => array( + 'var' => 'ns', + 'type' => TType::STRING, + ), ); } if (is_array($vals)) { @@ -27122,6 +27268,9 @@ class WMPoolTrigger { if (isset($vals['trigger'])) { $this->trigger = $vals['trigger']; } + if (isset($vals['ns'])) { + $this->ns = $vals['ns']; + } } } @@ -27158,6 +27307,13 @@ class WMPoolTrigger { $xfer += $input->skip($ftype); } break; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ns); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -27181,6 +27337,11 @@ class WMPoolTrigger { $xfer += $output->writeString($this->trigger); $xfer += $output->writeFieldEnd(); } + if ($this->ns !== null) { + $xfer += $output->writeFieldBegin('ns', TType::STRING, 3); + $xfer += $output->writeString($this->ns); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -27628,12 +27789,25 @@ class WMCreateResourcePlanResponse { class WMGetActiveResourcePlanRequest { static $_TSPEC; + /** + * @var string + */ + public $ns = null; - public function __construct() { + public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { self::$_TSPEC = array( + 1 => array( + 'var' => 'ns', + 'type' => TType::STRING, + ), ); } + if (is_array($vals)) { + if (isset($vals['ns'])) { + $this->ns = $vals['ns']; + } + } } public function getName() { @@ -27655,6 +27829,13 @@ class WMGetActiveResourcePlanRequest { } switch ($fid) { + case 1: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ns); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -27668,6 +27849,11 @@ class WMGetActiveResourcePlanRequest { public function write($output) { $xfer = 0; $xfer += $output->writeStructBegin('WMGetActiveResourcePlanRequest'); + if ($this->ns !== null) { + $xfer += $output->writeFieldBegin('ns', TType::STRING, 1); + $xfer += $output->writeString($this->ns); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -27762,6 +27948,10 @@ class WMGetResourcePlanRequest { * @var string */ public $resourcePlanName = null; + /** + * @var string + */ + public $ns = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -27770,12 +27960,19 @@ class WMGetResourcePlanRequest { 'var' => 'resourcePlanName', 'type' => TType::STRING, ), + 2 => array( + 'var' => 'ns', + 'type' => TType::STRING, + ), ); } if (is_array($vals)) { if (isset($vals['resourcePlanName'])) { $this->resourcePlanName = $vals['resourcePlanName']; } + if (isset($vals['ns'])) { + $this->ns = $vals['ns']; + } } } @@ -27805,6 +28002,13 @@ class WMGetResourcePlanRequest { $xfer += $input->skip($ftype); } break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ns); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -27823,6 +28027,11 @@ class WMGetResourcePlanRequest { $xfer += $output->writeString($this->resourcePlanName); $xfer += $output->writeFieldEnd(); } + if ($this->ns !== null) { + $xfer += $output->writeFieldBegin('ns', TType::STRING, 2); + $xfer += $output->writeString($this->ns); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -27913,12 +28122,25 @@ class WMGetResourcePlanResponse { class WMGetAllResourcePlanRequest { static $_TSPEC; + /** + * @var string + */ + public $ns = null; - public function __construct() { + public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { self::$_TSPEC = array( + 1 => array( + 'var' => 'ns', + 'type' => TType::STRING, + ), ); } + if (is_array($vals)) { + if (isset($vals['ns'])) { + $this->ns = $vals['ns']; + } + } } public function getName() { @@ -27940,6 +28162,13 @@ class WMGetAllResourcePlanRequest { } switch ($fid) { + case 1: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ns); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -27953,6 +28182,11 @@ class WMGetAllResourcePlanRequest { public function write($output) { $xfer = 0; $xfer += $output->writeStructBegin('WMGetAllResourcePlanRequest'); + if ($this->ns !== null) { + $xfer += $output->writeFieldBegin('ns', TType::STRING, 1); + $xfer += $output->writeString($this->ns); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -28086,6 +28320,10 @@ class WMAlterResourcePlanRequest { * @var bool */ public $isReplace = null; + /** + * @var string + */ + public $ns = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -28111,6 +28349,10 @@ class WMAlterResourcePlanRequest { 'var' => 'isReplace', 'type' => TType::BOOL, ), + 6 => array( + 'var' => 'ns', + 'type' => TType::STRING, + ), ); } if (is_array($vals)) { @@ -28129,6 +28371,9 @@ class WMAlterResourcePlanRequest { if (isset($vals['isReplace'])) { $this->isReplace = $vals['isReplace']; } + if (isset($vals['ns'])) { + $this->ns = $vals['ns']; + } } } @@ -28187,6 +28432,13 @@ class WMAlterResourcePlanRequest { $xfer += $input->skip($ftype); } break; + case 6: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ns); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -28228,6 +28480,11 @@ class WMAlterResourcePlanRequest { $xfer += $output->writeBool($this->isReplace); $xfer += $output->writeFieldEnd(); } + if ($this->ns !== null) { + $xfer += $output->writeFieldBegin('ns', TType::STRING, 6); + $xfer += $output->writeString($this->ns); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -28322,6 +28579,10 @@ class WMValidateResourcePlanRequest { * @var string */ public $resourcePlanName = null; + /** + * @var string + */ + public $ns = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -28330,12 +28591,19 @@ class WMValidateResourcePlanRequest { 'var' => 'resourcePlanName', 'type' => TType::STRING, ), + 2 => array( + 'var' => 'ns', + 'type' => TType::STRING, + ), ); } if (is_array($vals)) { if (isset($vals['resourcePlanName'])) { $this->resourcePlanName = $vals['resourcePlanName']; } + if (isset($vals['ns'])) { + $this->ns = $vals['ns']; + } } } @@ -28365,6 +28633,13 @@ class WMValidateResourcePlanRequest { $xfer += $input->skip($ftype); } break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ns); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -28383,6 +28658,11 @@ class WMValidateResourcePlanRequest { $xfer += $output->writeString($this->resourcePlanName); $xfer += $output->writeFieldEnd(); } + if ($this->ns !== null) { + $xfer += $output->writeFieldBegin('ns', TType::STRING, 2); + $xfer += $output->writeString($this->ns); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -28547,6 +28827,10 @@ class WMDropResourcePlanRequest { * @var string */ public $resourcePlanName = null; + /** + * @var string + */ + public $ns = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -28555,12 +28839,19 @@ class WMDropResourcePlanRequest { 'var' => 'resourcePlanName', 'type' => TType::STRING, ), + 2 => array( + 'var' => 'ns', + 'type' => TType::STRING, + ), ); } if (is_array($vals)) { if (isset($vals['resourcePlanName'])) { $this->resourcePlanName = $vals['resourcePlanName']; } + if (isset($vals['ns'])) { + $this->ns = $vals['ns']; + } } } @@ -28590,6 +28881,13 @@ class WMDropResourcePlanRequest { $xfer += $input->skip($ftype); } break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ns); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -28608,6 +28906,11 @@ class WMDropResourcePlanRequest { $xfer += $output->writeString($this->resourcePlanName); $xfer += $output->writeFieldEnd(); } + if ($this->ns !== null) { + $xfer += $output->writeFieldBegin('ns', TType::STRING, 2); + $xfer += $output->writeString($this->ns); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -28936,6 +29239,10 @@ class WMDropTriggerRequest { * @var string */ public $triggerName = null; + /** + * @var string + */ + public $ns = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -28948,6 +29255,10 @@ class WMDropTriggerRequest { 'var' => 'triggerName', 'type' => TType::STRING, ), + 3 => array( + 'var' => 'ns', + 'type' => TType::STRING, + ), ); } if (is_array($vals)) { @@ -28957,6 +29268,9 @@ class WMDropTriggerRequest { if (isset($vals['triggerName'])) { $this->triggerName = $vals['triggerName']; } + if (isset($vals['ns'])) { + $this->ns = $vals['ns']; + } } } @@ -28993,6 +29307,13 @@ class WMDropTriggerRequest { $xfer += $input->skip($ftype); } break; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ns); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -29016,6 +29337,11 @@ class WMDropTriggerRequest { $xfer += $output->writeString($this->triggerName); $xfer += $output->writeFieldEnd(); } + if ($this->ns !== null) { + $xfer += $output->writeFieldBegin('ns', TType::STRING, 3); + $xfer += $output->writeString($this->ns); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -29080,6 +29406,10 @@ class WMGetTriggersForResourePlanRequest { * @var string */ public $resourcePlanName = null; + /** + * @var string + */ + public $ns = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -29088,12 +29418,19 @@ class WMGetTriggersForResourePlanRequest { 'var' => 'resourcePlanName', 'type' => TType::STRING, ), + 2 => array( + 'var' => 'ns', + 'type' => TType::STRING, + ), ); } if (is_array($vals)) { if (isset($vals['resourcePlanName'])) { $this->resourcePlanName = $vals['resourcePlanName']; } + if (isset($vals['ns'])) { + $this->ns = $vals['ns']; + } } } @@ -29123,6 +29460,13 @@ class WMGetTriggersForResourePlanRequest { $xfer += $input->skip($ftype); } break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ns); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -29141,6 +29485,11 @@ class WMGetTriggersForResourePlanRequest { $xfer += $output->writeString($this->resourcePlanName); $xfer += $output->writeFieldEnd(); } + if ($this->ns !== null) { + $xfer += $output->writeFieldBegin('ns', TType::STRING, 2); + $xfer += $output->writeString($this->ns); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -29545,6 +29894,10 @@ class WMDropPoolRequest { * @var string */ public $poolPath = null; + /** + * @var string + */ + public $ns = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -29557,6 +29910,10 @@ class WMDropPoolRequest { 'var' => 'poolPath', 'type' => TType::STRING, ), + 3 => array( + 'var' => 'ns', + 'type' => TType::STRING, + ), ); } if (is_array($vals)) { @@ -29566,6 +29923,9 @@ class WMDropPoolRequest { if (isset($vals['poolPath'])) { $this->poolPath = $vals['poolPath']; } + if (isset($vals['ns'])) { + $this->ns = $vals['ns']; + } } } @@ -29602,6 +29962,13 @@ class WMDropPoolRequest { $xfer += $input->skip($ftype); } break; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ns); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -29625,6 +29992,11 @@ class WMDropPoolRequest { $xfer += $output->writeString($this->poolPath); $xfer += $output->writeFieldEnd(); } + if ($this->ns !== null) { + $xfer += $output->writeFieldBegin('ns', TType::STRING, 3); + $xfer += $output->writeString($this->ns); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -29984,6 +30356,10 @@ class WMCreateOrDropTriggerToPoolMappingRequest { * @var bool */ public $drop = null; + /** + * @var string + */ + public $ns = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -30004,6 +30380,10 @@ class WMCreateOrDropTriggerToPoolMappingRequest { 'var' => 'drop', 'type' => TType::BOOL, ), + 5 => array( + 'var' => 'ns', + 'type' => TType::STRING, + ), ); } if (is_array($vals)) { @@ -30019,6 +30399,9 @@ class WMCreateOrDropTriggerToPoolMappingRequest { if (isset($vals['drop'])) { $this->drop = $vals['drop']; } + if (isset($vals['ns'])) { + $this->ns = $vals['ns']; + } } } @@ -30069,6 +30452,13 @@ class WMCreateOrDropTriggerToPoolMappingRequest { $xfer += $input->skip($ftype); } break; + case 5: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ns); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -30102,6 +30492,11 @@ class WMCreateOrDropTriggerToPoolMappingRequest { $xfer += $output->writeBool($this->drop); $xfer += $output->writeFieldEnd(); } + if ($this->ns !== null) { + $xfer += $output->writeFieldBegin('ns', TType::STRING, 5); + $xfer += $output->writeString($this->ns); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer;
