You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2018/10/30 20:01:16 UTC
[4/6] hive git commit: HIVE-20793 : add RP namespacing to workload
management (Sergey Shelukhin, reviewed by Prasanth Jayachandran)
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);
+ }
}
}