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/WMDropPoolRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropPoolRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropPoolRequest.java index 114cdde..555bc5d 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropPoolRequest.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropPoolRequest.java @@ -40,6 +40,7 @@ import org.slf4j.LoggerFactory; 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 POOL_PATH_FIELD_DESC = new org.apache.thrift.protocol.TField("poolPath", 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 resourcePlanName; // optional private String poolPath; // 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"), - POOL_PATH((short)2, "poolPath"); + POOL_PATH((short)2, "poolPath"), + NS((short)3, "ns"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -72,6 +75,8 @@ import org.slf4j.LoggerFactory; return RESOURCE_PLAN_NAME; case 2: // POOL_PATH return POOL_PATH; + case 3: // NS + return NS; default: return null; } @@ -112,7 +117,7 @@ import org.slf4j.LoggerFactory; } // isset id assignments - private static final _Fields optionals[] = {_Fields.RESOURCE_PLAN_NAME,_Fields.POOL_PATH}; + private static final _Fields optionals[] = {_Fields.RESOURCE_PLAN_NAME,_Fields.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); @@ -120,6 +125,8 @@ import org.slf4j.LoggerFactory; new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); tmpMap.put(_Fields.POOL_PATH, new org.apache.thrift.meta_data.FieldMetaData("poolPath", 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(WMDropPoolRequest.class, metaDataMap); } @@ -137,6 +144,9 @@ import org.slf4j.LoggerFactory; if (other.isSetPoolPath()) { this.poolPath = other.poolPath; } + if (other.isSetNs()) { + this.ns = other.ns; + } } public WMDropPoolRequest deepCopy() { @@ -147,6 +157,7 @@ import org.slf4j.LoggerFactory; public void clear() { this.resourcePlanName = null; this.poolPath = null; + this.ns = null; } public String getResourcePlanName() { @@ -195,6 +206,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: @@ -213,6 +247,14 @@ import org.slf4j.LoggerFactory; } break; + case NS: + if (value == null) { + unsetNs(); + } else { + setNs((String)value); + } + break; + } } @@ -224,6 +266,9 @@ import org.slf4j.LoggerFactory; case POOL_PATH: return getPoolPath(); + case NS: + return getNs(); + } throw new IllegalStateException(); } @@ -239,6 +284,8 @@ import org.slf4j.LoggerFactory; return isSetResourcePlanName(); case POOL_PATH: return isSetPoolPath(); + case NS: + return isSetNs(); } throw new IllegalStateException(); } @@ -274,6 +321,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; } @@ -291,6 +347,11 @@ import org.slf4j.LoggerFactory; if (present_poolPath) list.add(poolPath); + boolean present_ns = true && (isSetNs()); + list.add(present_ns); + if (present_ns) + list.add(ns); + return list.hashCode(); } @@ -322,6 +383,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; } @@ -361,6 +432,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(); } @@ -420,6 +501,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); } @@ -447,6 +536,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(); } @@ -471,19 +567,25 @@ import org.slf4j.LoggerFactory; if (struct.isSetPoolPath()) { optionals.set(1); } - oprot.writeBitSet(optionals, 2); + if (struct.isSetNs()) { + optionals.set(2); + } + oprot.writeBitSet(optionals, 3); if (struct.isSetResourcePlanName()) { oprot.writeString(struct.resourcePlanName); } if (struct.isSetPoolPath()) { oprot.writeString(struct.poolPath); } + if (struct.isSetNs()) { + oprot.writeString(struct.ns); + } } @Override public void read(org.apache.thrift.protocol.TProtocol prot, WMDropPoolRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(2); + BitSet incoming = iprot.readBitSet(3); if (incoming.get(0)) { struct.resourcePlanName = iprot.readString(); struct.setResourcePlanNameIsSet(true); @@ -492,6 +594,10 @@ import org.slf4j.LoggerFactory; struct.poolPath = iprot.readString(); struct.setPoolPathIsSet(true); } + if (incoming.get(2)) { + 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/WMDropResourcePlanRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropResourcePlanRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropResourcePlanRequest.java index 779b2d1..49036d2 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropResourcePlanRequest.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropResourcePlanRequest.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("WMDropResourcePlanRequest"); 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(WMDropResourcePlanRequest.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 WMDropResourcePlanRequest 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, WMDropResourcePlanRequest 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-javabean/org/apache/hadoop/hive/metastore/api/WMDropTriggerRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropTriggerRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropTriggerRequest.java index 9cde38d..5122b24 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropTriggerRequest.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropTriggerRequest.java @@ -40,6 +40,7 @@ import org.slf4j.LoggerFactory; 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 TRIGGER_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("triggerName", 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 resourcePlanName; // optional private String triggerName; // 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"), - TRIGGER_NAME((short)2, "triggerName"); + TRIGGER_NAME((short)2, "triggerName"), + NS((short)3, "ns"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -72,6 +75,8 @@ import org.slf4j.LoggerFactory; return RESOURCE_PLAN_NAME; case 2: // TRIGGER_NAME return TRIGGER_NAME; + case 3: // NS + return NS; default: return null; } @@ -112,7 +117,7 @@ import org.slf4j.LoggerFactory; } // isset id assignments - private static final _Fields optionals[] = {_Fields.RESOURCE_PLAN_NAME,_Fields.TRIGGER_NAME}; + private static final _Fields optionals[] = {_Fields.RESOURCE_PLAN_NAME,_Fields.TRIGGER_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); @@ -120,6 +125,8 @@ import org.slf4j.LoggerFactory; new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); tmpMap.put(_Fields.TRIGGER_NAME, new org.apache.thrift.meta_data.FieldMetaData("triggerName", 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(WMDropTriggerRequest.class, metaDataMap); } @@ -137,6 +144,9 @@ import org.slf4j.LoggerFactory; if (other.isSetTriggerName()) { this.triggerName = other.triggerName; } + if (other.isSetNs()) { + this.ns = other.ns; + } } public WMDropTriggerRequest deepCopy() { @@ -147,6 +157,7 @@ import org.slf4j.LoggerFactory; public void clear() { this.resourcePlanName = null; this.triggerName = null; + this.ns = null; } public String getResourcePlanName() { @@ -195,6 +206,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: @@ -213,6 +247,14 @@ import org.slf4j.LoggerFactory; } break; + case NS: + if (value == null) { + unsetNs(); + } else { + setNs((String)value); + } + break; + } } @@ -224,6 +266,9 @@ import org.slf4j.LoggerFactory; case TRIGGER_NAME: return getTriggerName(); + case NS: + return getNs(); + } throw new IllegalStateException(); } @@ -239,6 +284,8 @@ import org.slf4j.LoggerFactory; return isSetResourcePlanName(); case TRIGGER_NAME: return isSetTriggerName(); + case NS: + return isSetNs(); } throw new IllegalStateException(); } @@ -274,6 +321,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; } @@ -291,6 +347,11 @@ import org.slf4j.LoggerFactory; if (present_triggerName) list.add(triggerName); + boolean present_ns = true && (isSetNs()); + list.add(present_ns); + if (present_ns) + list.add(ns); + return list.hashCode(); } @@ -322,6 +383,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; } @@ -361,6 +432,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(); } @@ -420,6 +501,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); } @@ -447,6 +536,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(); } @@ -471,19 +567,25 @@ import org.slf4j.LoggerFactory; if (struct.isSetTriggerName()) { optionals.set(1); } - oprot.writeBitSet(optionals, 2); + if (struct.isSetNs()) { + optionals.set(2); + } + oprot.writeBitSet(optionals, 3); if (struct.isSetResourcePlanName()) { oprot.writeString(struct.resourcePlanName); } if (struct.isSetTriggerName()) { oprot.writeString(struct.triggerName); } + if (struct.isSetNs()) { + oprot.writeString(struct.ns); + } } @Override public void read(org.apache.thrift.protocol.TProtocol prot, WMDropTriggerRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(2); + BitSet incoming = iprot.readBitSet(3); if (incoming.get(0)) { struct.resourcePlanName = iprot.readString(); struct.setResourcePlanNameIsSet(true); @@ -492,6 +594,10 @@ import org.slf4j.LoggerFactory; struct.triggerName = iprot.readString(); struct.setTriggerNameIsSet(true); } + if (incoming.get(2)) { + 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/WMGetActiveResourcePlanRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetActiveResourcePlanRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetActiveResourcePlanRequest.java index ec2a1f5..50efd06 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetActiveResourcePlanRequest.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetActiveResourcePlanRequest.java @@ -38,6 +38,7 @@ import org.slf4j.LoggerFactory; @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class WMGetActiveResourcePlanRequest implements org.apache.thrift.TBase<WMGetActiveResourcePlanRequest, WMGetActiveResourcePlanRequest._Fields>, java.io.Serializable, Cloneable, Comparable<WMGetActiveResourcePlanRequest> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WMGetActiveResourcePlanRequest"); + 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)1); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -45,10 +46,11 @@ import org.slf4j.LoggerFactory; schemes.put(TupleScheme.class, new WMGetActiveResourcePlanRequestTupleSchemeFactory()); } + 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 { -; + NS((short)1, "ns"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -63,6 +65,8 @@ import org.slf4j.LoggerFactory; */ public static _Fields findByThriftId(int fieldId) { switch(fieldId) { + case 1: // NS + return NS; default: return null; } @@ -101,9 +105,14 @@ import org.slf4j.LoggerFactory; return _fieldName; } } + + // 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); + 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(WMGetActiveResourcePlanRequest.class, metaDataMap); } @@ -115,6 +124,9 @@ import org.slf4j.LoggerFactory; * Performs a deep copy on <i>other</i>. */ public WMGetActiveResourcePlanRequest(WMGetActiveResourcePlanRequest other) { + if (other.isSetNs()) { + this.ns = other.ns; + } } public WMGetActiveResourcePlanRequest deepCopy() { @@ -123,15 +135,50 @@ import org.slf4j.LoggerFactory; @Override public void clear() { + this.ns = null; + } + + 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 NS: + if (value == null) { + unsetNs(); + } else { + setNs((String)value); + } + break; + } } public Object getFieldValue(_Fields field) { switch (field) { + case NS: + return getNs(); + } throw new IllegalStateException(); } @@ -143,6 +190,8 @@ import org.slf4j.LoggerFactory; } switch (field) { + case NS: + return isSetNs(); } throw new IllegalStateException(); } @@ -160,6 +209,15 @@ import org.slf4j.LoggerFactory; if (that == null) 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; } @@ -167,6 +225,11 @@ import org.slf4j.LoggerFactory; public int hashCode() { List<Object> list = new ArrayList<Object>(); + boolean present_ns = true && (isSetNs()); + list.add(present_ns); + if (present_ns) + list.add(ns); + return list.hashCode(); } @@ -178,6 +241,16 @@ import org.slf4j.LoggerFactory; int lastComparison = 0; + 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; } @@ -198,6 +271,15 @@ import org.slf4j.LoggerFactory; StringBuilder sb = new StringBuilder("WMGetActiveResourcePlanRequest("); boolean first = true; + if (isSetNs()) { + sb.append("ns:"); + if (this.ns == null) { + sb.append("null"); + } else { + sb.append(this.ns); + } + first = false; + } sb.append(")"); return sb.toString(); } @@ -241,6 +323,14 @@ import org.slf4j.LoggerFactory; break; } switch (schemeField.id) { + case 1: // 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); } @@ -254,6 +344,13 @@ import org.slf4j.LoggerFactory; struct.validate(); oprot.writeStructBegin(STRUCT_DESC); + if (struct.ns != null) { + if (struct.isSetNs()) { + oprot.writeFieldBegin(NS_FIELD_DESC); + oprot.writeString(struct.ns); + oprot.writeFieldEnd(); + } + } oprot.writeFieldStop(); oprot.writeStructEnd(); } @@ -271,11 +368,24 @@ import org.slf4j.LoggerFactory; @Override public void write(org.apache.thrift.protocol.TProtocol prot, WMGetActiveResourcePlanRequest struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetNs()) { + optionals.set(0); + } + oprot.writeBitSet(optionals, 1); + if (struct.isSetNs()) { + oprot.writeString(struct.ns); + } } @Override public void read(org.apache.thrift.protocol.TProtocol prot, WMGetActiveResourcePlanRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; + 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/WMGetAllResourcePlanRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanRequest.java index 3df8610..7efdb18 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanRequest.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanRequest.java @@ -38,6 +38,7 @@ import org.slf4j.LoggerFactory; @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class WMGetAllResourcePlanRequest implements org.apache.thrift.TBase<WMGetAllResourcePlanRequest, WMGetAllResourcePlanRequest._Fields>, java.io.Serializable, Cloneable, Comparable<WMGetAllResourcePlanRequest> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WMGetAllResourcePlanRequest"); + 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)1); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -45,10 +46,11 @@ import org.slf4j.LoggerFactory; schemes.put(TupleScheme.class, new WMGetAllResourcePlanRequestTupleSchemeFactory()); } + 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 { -; + NS((short)1, "ns"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -63,6 +65,8 @@ import org.slf4j.LoggerFactory; */ public static _Fields findByThriftId(int fieldId) { switch(fieldId) { + case 1: // NS + return NS; default: return null; } @@ -101,9 +105,14 @@ import org.slf4j.LoggerFactory; return _fieldName; } } + + // 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); + 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(WMGetAllResourcePlanRequest.class, metaDataMap); } @@ -115,6 +124,9 @@ import org.slf4j.LoggerFactory; * Performs a deep copy on <i>other</i>. */ public WMGetAllResourcePlanRequest(WMGetAllResourcePlanRequest other) { + if (other.isSetNs()) { + this.ns = other.ns; + } } public WMGetAllResourcePlanRequest deepCopy() { @@ -123,15 +135,50 @@ import org.slf4j.LoggerFactory; @Override public void clear() { + this.ns = null; + } + + 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 NS: + if (value == null) { + unsetNs(); + } else { + setNs((String)value); + } + break; + } } public Object getFieldValue(_Fields field) { switch (field) { + case NS: + return getNs(); + } throw new IllegalStateException(); } @@ -143,6 +190,8 @@ import org.slf4j.LoggerFactory; } switch (field) { + case NS: + return isSetNs(); } throw new IllegalStateException(); } @@ -160,6 +209,15 @@ import org.slf4j.LoggerFactory; if (that == null) 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; } @@ -167,6 +225,11 @@ import org.slf4j.LoggerFactory; public int hashCode() { List<Object> list = new ArrayList<Object>(); + boolean present_ns = true && (isSetNs()); + list.add(present_ns); + if (present_ns) + list.add(ns); + return list.hashCode(); } @@ -178,6 +241,16 @@ import org.slf4j.LoggerFactory; int lastComparison = 0; + 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; } @@ -198,6 +271,15 @@ import org.slf4j.LoggerFactory; StringBuilder sb = new StringBuilder("WMGetAllResourcePlanRequest("); boolean first = true; + if (isSetNs()) { + sb.append("ns:"); + if (this.ns == null) { + sb.append("null"); + } else { + sb.append(this.ns); + } + first = false; + } sb.append(")"); return sb.toString(); } @@ -241,6 +323,14 @@ import org.slf4j.LoggerFactory; break; } switch (schemeField.id) { + case 1: // 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); } @@ -254,6 +344,13 @@ import org.slf4j.LoggerFactory; struct.validate(); oprot.writeStructBegin(STRUCT_DESC); + if (struct.ns != null) { + if (struct.isSetNs()) { + oprot.writeFieldBegin(NS_FIELD_DESC); + oprot.writeString(struct.ns); + oprot.writeFieldEnd(); + } + } oprot.writeFieldStop(); oprot.writeStructEnd(); } @@ -271,11 +368,24 @@ import org.slf4j.LoggerFactory; @Override public void write(org.apache.thrift.protocol.TProtocol prot, WMGetAllResourcePlanRequest struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetNs()) { + optionals.set(0); + } + oprot.writeBitSet(optionals, 1); + if (struct.isSetNs()) { + oprot.writeString(struct.ns); + } } @Override public void read(org.apache.thrift.protocol.TProtocol prot, WMGetAllResourcePlanRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; + 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/WMGetResourcePlanRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetResourcePlanRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetResourcePlanRequest.java index d051634..00139dc 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetResourcePlanRequest.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetResourcePlanRequest.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("WMGetResourcePlanRequest"); 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(WMGetResourcePlanRequest.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 WMGetResourcePlanRequest 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, WMGetResourcePlanRequest 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-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanRequest.java index ce64a04..2fac911 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanRequest.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanRequest.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("WMGetTriggersForResourePlanRequest"); 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(WMGetTriggersForResourePlanRequest.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 WMGetTriggersForResourePlanRequest 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, WMGetTriggersForResourePlanRequest 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-javabean/org/apache/hadoop/hive/metastore/api/WMMapping.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMMapping.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMMapping.java index 8b7d41a..8be0441 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMMapping.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMMapping.java @@ -43,6 +43,7 @@ import org.slf4j.LoggerFactory; private static final org.apache.thrift.protocol.TField ENTITY_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("entityName", org.apache.thrift.protocol.TType.STRING, (short)3); private static final org.apache.thrift.protocol.TField POOL_PATH_FIELD_DESC = new org.apache.thrift.protocol.TField("poolPath", org.apache.thrift.protocol.TType.STRING, (short)4); private static final org.apache.thrift.protocol.TField ORDERING_FIELD_DESC = new org.apache.thrift.protocol.TField("ordering", org.apache.thrift.protocol.TType.I32, (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 entityName; // required private String poolPath; // optional private int ordering; // 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; ENTITY_TYPE((short)2, "entityType"), ENTITY_NAME((short)3, "entityName"), POOL_PATH((short)4, "poolPath"), - ORDERING((short)5, "ordering"); + ORDERING((short)5, "ordering"), + NS((short)6, "ns"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -87,6 +90,8 @@ import org.slf4j.LoggerFactory; return POOL_PATH; case 5: // ORDERING return ORDERING; + case 6: // NS + return NS; default: return null; } @@ -129,7 +134,7 @@ import org.slf4j.LoggerFactory; // isset id assignments private static final int __ORDERING_ISSET_ID = 0; private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.POOL_PATH,_Fields.ORDERING}; + private static final _Fields optionals[] = {_Fields.POOL_PATH,_Fields.ORDERING,_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.ORDERING, new org.apache.thrift.meta_data.FieldMetaData("ordering", org.apache.thrift.TFieldRequirementType.OPTIONAL, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); + 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(WMMapping.class, metaDataMap); } @@ -179,6 +186,9 @@ import org.slf4j.LoggerFactory; this.poolPath = other.poolPath; } this.ordering = other.ordering; + if (other.isSetNs()) { + this.ns = other.ns; + } } public WMMapping deepCopy() { @@ -193,6 +203,7 @@ import org.slf4j.LoggerFactory; this.poolPath = null; setOrderingIsSet(false); this.ordering = 0; + this.ns = null; } public String getResourcePlanName() { @@ -309,6 +320,29 @@ import org.slf4j.LoggerFactory; __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ORDERING_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: @@ -351,6 +385,14 @@ import org.slf4j.LoggerFactory; } break; + case NS: + if (value == null) { + unsetNs(); + } else { + setNs((String)value); + } + break; + } } @@ -371,6 +413,9 @@ import org.slf4j.LoggerFactory; case ORDERING: return getOrdering(); + case NS: + return getNs(); + } throw new IllegalStateException(); } @@ -392,6 +437,8 @@ import org.slf4j.LoggerFactory; return isSetPoolPath(); case ORDERING: return isSetOrdering(); + case NS: + return isSetNs(); } throw new IllegalStateException(); } @@ -454,6 +501,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; } @@ -486,6 +542,11 @@ import org.slf4j.LoggerFactory; if (present_ordering) list.add(ordering); + boolean present_ns = true && (isSetNs()); + list.add(present_ns); + if (present_ns) + list.add(ns); + return list.hashCode(); } @@ -547,6 +608,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.ordering); 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(); } @@ -703,6 +784,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); } @@ -743,6 +832,13 @@ import org.slf4j.LoggerFactory; oprot.writeI32(struct.ordering); 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,13 +866,19 @@ import org.slf4j.LoggerFactory; if (struct.isSetOrdering()) { optionals.set(1); } - oprot.writeBitSet(optionals, 2); + if (struct.isSetNs()) { + optionals.set(2); + } + oprot.writeBitSet(optionals, 3); if (struct.isSetPoolPath()) { oprot.writeString(struct.poolPath); } if (struct.isSetOrdering()) { oprot.writeI32(struct.ordering); } + if (struct.isSetNs()) { + oprot.writeString(struct.ns); + } } @Override @@ -788,7 +890,7 @@ import org.slf4j.LoggerFactory; struct.setEntityTypeIsSet(true); struct.entityName = iprot.readString(); struct.setEntityNameIsSet(true); - BitSet incoming = iprot.readBitSet(2); + BitSet incoming = iprot.readBitSet(3); if (incoming.get(0)) { struct.poolPath = iprot.readString(); struct.setPoolPathIsSet(true); @@ -797,6 +899,10 @@ import org.slf4j.LoggerFactory; struct.ordering = iprot.readI32(); struct.setOrderingIsSet(true); } + if (incoming.get(2)) { + 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/WMNullablePool.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMNullablePool.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMNullablePool.java index 5e3e403..fbf9c19 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMNullablePool.java +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMNullablePool.java @@ -44,6 +44,7 @@ import org.slf4j.LoggerFactory; 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 IS_SET_SCHEDULING_POLICY_FIELD_DESC = new org.apache.thrift.protocol.TField("isSetSchedulingPolicy", org.apache.thrift.protocol.TType.BOOL, (short)6); + 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)7); 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 int queryParallelism; // optional private String schedulingPolicy; // optional private boolean isSetSchedulingPolicy; // 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 { @@ -65,7 +67,8 @@ import org.slf4j.LoggerFactory; ALLOC_FRACTION((short)3, "allocFraction"), QUERY_PARALLELISM((short)4, "queryParallelism"), SCHEDULING_POLICY((short)5, "schedulingPolicy"), - IS_SET_SCHEDULING_POLICY((short)6, "isSetSchedulingPolicy"); + IS_SET_SCHEDULING_POLICY((short)6, "isSetSchedulingPolicy"), + NS((short)7, "ns"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -92,6 +95,8 @@ import org.slf4j.LoggerFactory; return SCHEDULING_POLICY; case 6: // IS_SET_SCHEDULING_POLICY return IS_SET_SCHEDULING_POLICY; + case 7: // NS + return NS; default: return null; } @@ -136,7 +141,7 @@ import org.slf4j.LoggerFactory; private static final int __QUERYPARALLELISM_ISSET_ID = 1; private static final int __ISSETSCHEDULINGPOLICY_ISSET_ID = 2; private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.ALLOC_FRACTION,_Fields.QUERY_PARALLELISM,_Fields.SCHEDULING_POLICY,_Fields.IS_SET_SCHEDULING_POLICY}; + private static final _Fields optionals[] = {_Fields.ALLOC_FRACTION,_Fields.QUERY_PARALLELISM,_Fields.SCHEDULING_POLICY,_Fields.IS_SET_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); @@ -152,6 +157,8 @@ import org.slf4j.LoggerFactory; new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); tmpMap.put(_Fields.IS_SET_SCHEDULING_POLICY, new org.apache.thrift.meta_data.FieldMetaData("isSetSchedulingPolicy", 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(WMNullablePool.class, metaDataMap); } @@ -185,6 +192,9 @@ import org.slf4j.LoggerFactory; this.schedulingPolicy = other.schedulingPolicy; } this.isSetSchedulingPolicy = other.isSetSchedulingPolicy; + if (other.isSetNs()) { + this.ns = other.ns; + } } public WMNullablePool deepCopy() { @@ -202,6 +212,7 @@ import org.slf4j.LoggerFactory; this.schedulingPolicy = null; setIsSetSchedulingPolicyIsSet(false); this.isSetSchedulingPolicy = false; + this.ns = null; } public String getResourcePlanName() { @@ -339,6 +350,29 @@ import org.slf4j.LoggerFactory; __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ISSETSCHEDULINGPOLICY_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: @@ -389,6 +423,14 @@ import org.slf4j.LoggerFactory; } break; + case NS: + if (value == null) { + unsetNs(); + } else { + setNs((String)value); + } + break; + } } @@ -412,6 +454,9 @@ import org.slf4j.LoggerFactory; case IS_SET_SCHEDULING_POLICY: return isIsSetSchedulingPolicy(); + case NS: + return getNs(); + } throw new IllegalStateException(); } @@ -435,6 +480,8 @@ import org.slf4j.LoggerFactory; return isSetSchedulingPolicy(); case IS_SET_SCHEDULING_POLICY: return isSetIsSetSchedulingPolicy(); + case NS: + return isSetNs(); } throw new IllegalStateException(); } @@ -506,6 +553,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; } @@ -543,6 +599,11 @@ import org.slf4j.LoggerFactory; if (present_isSetSchedulingPolicy) list.add(isSetSchedulingPolicy); + boolean present_ns = true && (isSetNs()); + list.add(present_ns); + if (present_ns) + list.add(ns); + return list.hashCode(); } @@ -614,6 +675,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; } @@ -677,6 +748,16 @@ import org.slf4j.LoggerFactory; sb.append(this.isSetSchedulingPolicy); 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(); } @@ -778,6 +859,14 @@ import org.slf4j.LoggerFactory; org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; + case 7: // 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); } @@ -823,6 +912,13 @@ import org.slf4j.LoggerFactory; oprot.writeBool(struct.isSetSchedulingPolicy); oprot.writeFieldEnd(); } + if (struct.ns != null) { + if (struct.isSetNs()) { + oprot.writeFieldBegin(NS_FIELD_DESC); + oprot.writeString(struct.ns); + oprot.writeFieldEnd(); + } + } oprot.writeFieldStop(); oprot.writeStructEnd(); } @@ -855,7 +951,10 @@ import org.slf4j.LoggerFactory; if (struct.isSetIsSetSchedulingPolicy()) { optionals.set(3); } - oprot.writeBitSet(optionals, 4); + if (struct.isSetNs()) { + optionals.set(4); + } + oprot.writeBitSet(optionals, 5); if (struct.isSetAllocFraction()) { oprot.writeDouble(struct.allocFraction); } @@ -868,6 +967,9 @@ import org.slf4j.LoggerFactory; if (struct.isSetIsSetSchedulingPolicy()) { oprot.writeBool(struct.isSetSchedulingPolicy); } + if (struct.isSetNs()) { + oprot.writeString(struct.ns); + } } @Override @@ -877,7 +979,7 @@ import org.slf4j.LoggerFactory; struct.setResourcePlanNameIsSet(true); struct.poolPath = iprot.readString(); struct.setPoolPathIsSet(true); - BitSet incoming = iprot.readBitSet(4); + BitSet incoming = iprot.readBitSet(5); if (incoming.get(0)) { struct.allocFraction = iprot.readDouble(); struct.setAllocFractionIsSet(true); @@ -894,6 +996,10 @@ import org.slf4j.LoggerFactory; struct.isSetSchedulingPolicy = iprot.readBool(); struct.setIsSetSchedulingPolicyIsSet(true); } + if (incoming.get(4)) { + struct.ns = iprot.readString(); + struct.setNsIsSet(true); + } } }
