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 2017/11/06 19:44:55 UTC
[06/10] hive git commit: HIVE-17907 : enable and apply resource plan
commands in HS2 (Sergey Shelukhin, reviewed by Prasanth Jayachandran)
http://git-wip-us.apache.org/repos/asf/hive/blob/ddce801f/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterResourcePlanRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterResourcePlanRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterResourcePlanRequest.java
index fa694f0..db4cf0a 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterResourcePlanRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterResourcePlanRequest.java
@@ -35,11 +35,12 @@ import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
-public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlterResourcePlanRequest, WMAlterResourcePlanRequest._Fields>, java.io.Serializable, Cloneable, Comparable<WMAlterResourcePlanRequest> {
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlterResourcePlanRequest, WMAlterResourcePlanRequest._Fields>, java.io.Serializable, Cloneable, Comparable<WMAlterResourcePlanRequest> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WMAlterResourcePlanRequest");
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 RESOURCE_PLAN_FIELD_DESC = new org.apache.thrift.protocol.TField("resourcePlan", org.apache.thrift.protocol.TType.STRUCT, (short)2);
+ private static final org.apache.thrift.protocol.TField IS_ENABLE_AND_ACTIVATE_FIELD_DESC = new org.apache.thrift.protocol.TField("isEnableAndActivate", org.apache.thrift.protocol.TType.BOOL, (short)3);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
@@ -49,11 +50,13 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
private String resourcePlanName; // optional
private WMResourcePlan resourcePlan; // optional
+ private boolean isEnableAndActivate; // 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((short)2, "resourcePlan");
+ RESOURCE_PLAN((short)2, "resourcePlan"),
+ IS_ENABLE_AND_ACTIVATE((short)3, "isEnableAndActivate");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -72,6 +75,8 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
return RESOURCE_PLAN_NAME;
case 2: // RESOURCE_PLAN
return RESOURCE_PLAN;
+ case 3: // IS_ENABLE_AND_ACTIVATE
+ return IS_ENABLE_AND_ACTIVATE;
default:
return null;
}
@@ -112,7 +117,9 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
}
// isset id assignments
- private static final _Fields optionals[] = {_Fields.RESOURCE_PLAN_NAME,_Fields.RESOURCE_PLAN};
+ private static final int __ISENABLEANDACTIVATE_ISSET_ID = 0;
+ private byte __isset_bitfield = 0;
+ private static final _Fields optionals[] = {_Fields.RESOURCE_PLAN_NAME,_Fields.RESOURCE_PLAN,_Fields.IS_ENABLE_AND_ACTIVATE};
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 +127,8 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.RESOURCE_PLAN, new org.apache.thrift.meta_data.FieldMetaData("resourcePlan", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, WMResourcePlan.class)));
+ tmpMap.put(_Fields.IS_ENABLE_AND_ACTIVATE, new org.apache.thrift.meta_data.FieldMetaData("isEnableAndActivate", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(WMAlterResourcePlanRequest.class, metaDataMap);
}
@@ -131,12 +140,14 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
* Performs a deep copy on <i>other</i>.
*/
public WMAlterResourcePlanRequest(WMAlterResourcePlanRequest other) {
+ __isset_bitfield = other.__isset_bitfield;
if (other.isSetResourcePlanName()) {
this.resourcePlanName = other.resourcePlanName;
}
if (other.isSetResourcePlan()) {
this.resourcePlan = new WMResourcePlan(other.resourcePlan);
}
+ this.isEnableAndActivate = other.isEnableAndActivate;
}
public WMAlterResourcePlanRequest deepCopy() {
@@ -147,6 +158,8 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
public void clear() {
this.resourcePlanName = null;
this.resourcePlan = null;
+ setIsEnableAndActivateIsSet(false);
+ this.isEnableAndActivate = false;
}
public String getResourcePlanName() {
@@ -195,6 +208,28 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
}
}
+ public boolean isIsEnableAndActivate() {
+ return this.isEnableAndActivate;
+ }
+
+ public void setIsEnableAndActivate(boolean isEnableAndActivate) {
+ this.isEnableAndActivate = isEnableAndActivate;
+ setIsEnableAndActivateIsSet(true);
+ }
+
+ public void unsetIsEnableAndActivate() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ISENABLEANDACTIVATE_ISSET_ID);
+ }
+
+ /** Returns true if field isEnableAndActivate is set (has been assigned a value) and false otherwise */
+ public boolean isSetIsEnableAndActivate() {
+ return EncodingUtils.testBit(__isset_bitfield, __ISENABLEANDACTIVATE_ISSET_ID);
+ }
+
+ public void setIsEnableAndActivateIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ISENABLEANDACTIVATE_ISSET_ID, value);
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case RESOURCE_PLAN_NAME:
@@ -213,6 +248,14 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
}
break;
+ case IS_ENABLE_AND_ACTIVATE:
+ if (value == null) {
+ unsetIsEnableAndActivate();
+ } else {
+ setIsEnableAndActivate((Boolean)value);
+ }
+ break;
+
}
}
@@ -224,6 +267,9 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
case RESOURCE_PLAN:
return getResourcePlan();
+ case IS_ENABLE_AND_ACTIVATE:
+ return isIsEnableAndActivate();
+
}
throw new IllegalStateException();
}
@@ -239,6 +285,8 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
return isSetResourcePlanName();
case RESOURCE_PLAN:
return isSetResourcePlan();
+ case IS_ENABLE_AND_ACTIVATE:
+ return isSetIsEnableAndActivate();
}
throw new IllegalStateException();
}
@@ -274,6 +322,15 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
return false;
}
+ boolean this_present_isEnableAndActivate = true && this.isSetIsEnableAndActivate();
+ boolean that_present_isEnableAndActivate = true && that.isSetIsEnableAndActivate();
+ if (this_present_isEnableAndActivate || that_present_isEnableAndActivate) {
+ if (!(this_present_isEnableAndActivate && that_present_isEnableAndActivate))
+ return false;
+ if (this.isEnableAndActivate != that.isEnableAndActivate)
+ return false;
+ }
+
return true;
}
@@ -291,6 +348,11 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
if (present_resourcePlan)
list.add(resourcePlan);
+ boolean present_isEnableAndActivate = true && (isSetIsEnableAndActivate());
+ list.add(present_isEnableAndActivate);
+ if (present_isEnableAndActivate)
+ list.add(isEnableAndActivate);
+
return list.hashCode();
}
@@ -322,6 +384,16 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(isSetIsEnableAndActivate()).compareTo(other.isSetIsEnableAndActivate());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetIsEnableAndActivate()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.isEnableAndActivate, other.isEnableAndActivate);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -361,6 +433,12 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
}
first = false;
}
+ if (isSetIsEnableAndActivate()) {
+ if (!first) sb.append(", ");
+ sb.append("isEnableAndActivate:");
+ sb.append(this.isEnableAndActivate);
+ first = false;
+ }
sb.append(")");
return sb.toString();
}
@@ -383,6 +461,8 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
+ // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+ __isset_bitfield = 0;
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
@@ -424,6 +504,14 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
+ case 3: // IS_ENABLE_AND_ACTIVATE
+ if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
+ struct.isEnableAndActivate = iprot.readBool();
+ struct.setIsEnableAndActivateIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
@@ -451,6 +539,11 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
oprot.writeFieldEnd();
}
}
+ if (struct.isSetIsEnableAndActivate()) {
+ oprot.writeFieldBegin(IS_ENABLE_AND_ACTIVATE_FIELD_DESC);
+ oprot.writeBool(struct.isEnableAndActivate);
+ oprot.writeFieldEnd();
+ }
oprot.writeFieldStop();
oprot.writeStructEnd();
}
@@ -475,19 +568,25 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
if (struct.isSetResourcePlan()) {
optionals.set(1);
}
- oprot.writeBitSet(optionals, 2);
+ if (struct.isSetIsEnableAndActivate()) {
+ optionals.set(2);
+ }
+ oprot.writeBitSet(optionals, 3);
if (struct.isSetResourcePlanName()) {
oprot.writeString(struct.resourcePlanName);
}
if (struct.isSetResourcePlan()) {
struct.resourcePlan.write(oprot);
}
+ if (struct.isSetIsEnableAndActivate()) {
+ oprot.writeBool(struct.isEnableAndActivate);
+ }
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, WMAlterResourcePlanRequest 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);
@@ -497,6 +596,10 @@ public class WMAlterResourcePlanRequest implements org.apache.thrift.TBase<WMAlt
struct.resourcePlan.read(iprot);
struct.setResourcePlanIsSet(true);
}
+ if (incoming.get(2)) {
+ struct.isEnableAndActivate = iprot.readBool();
+ struct.setIsEnableAndActivateIsSet(true);
+ }
}
}
http://git-wip-us.apache.org/repos/asf/hive/blob/ddce801f/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterResourcePlanResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterResourcePlanResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterResourcePlanResponse.java
index 73fc638..28b4fa0 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterResourcePlanResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterResourcePlanResponse.java
@@ -35,9 +35,10 @@ import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
-public class WMAlterResourcePlanResponse implements org.apache.thrift.TBase<WMAlterResourcePlanResponse, WMAlterResourcePlanResponse._Fields>, java.io.Serializable, Cloneable, Comparable<WMAlterResourcePlanResponse> {
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class WMAlterResourcePlanResponse implements org.apache.thrift.TBase<WMAlterResourcePlanResponse, WMAlterResourcePlanResponse._Fields>, java.io.Serializable, Cloneable, Comparable<WMAlterResourcePlanResponse> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WMAlterResourcePlanResponse");
+ private static final org.apache.thrift.protocol.TField FULL_RESOURCE_PLAN_FIELD_DESC = new org.apache.thrift.protocol.TField("fullResourcePlan", org.apache.thrift.protocol.TType.STRUCT, (short)1);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
@@ -45,10 +46,11 @@ public class WMAlterResourcePlanResponse implements org.apache.thrift.TBase<WMAl
schemes.put(TupleScheme.class, new WMAlterResourcePlanResponseTupleSchemeFactory());
}
+ private WMFullResourcePlan fullResourcePlan; // 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 {
-;
+ FULL_RESOURCE_PLAN((short)1, "fullResourcePlan");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -63,6 +65,8 @@ public class WMAlterResourcePlanResponse implements org.apache.thrift.TBase<WMAl
*/
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
+ case 1: // FULL_RESOURCE_PLAN
+ return FULL_RESOURCE_PLAN;
default:
return null;
}
@@ -101,9 +105,14 @@ public class WMAlterResourcePlanResponse implements org.apache.thrift.TBase<WMAl
return _fieldName;
}
}
+
+ // isset id assignments
+ private static final _Fields optionals[] = {_Fields.FULL_RESOURCE_PLAN};
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.FULL_RESOURCE_PLAN, new org.apache.thrift.meta_data.FieldMetaData("fullResourcePlan", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, WMFullResourcePlan.class)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(WMAlterResourcePlanResponse.class, metaDataMap);
}
@@ -115,6 +124,9 @@ public class WMAlterResourcePlanResponse implements org.apache.thrift.TBase<WMAl
* Performs a deep copy on <i>other</i>.
*/
public WMAlterResourcePlanResponse(WMAlterResourcePlanResponse other) {
+ if (other.isSetFullResourcePlan()) {
+ this.fullResourcePlan = new WMFullResourcePlan(other.fullResourcePlan);
+ }
}
public WMAlterResourcePlanResponse deepCopy() {
@@ -123,15 +135,50 @@ public class WMAlterResourcePlanResponse implements org.apache.thrift.TBase<WMAl
@Override
public void clear() {
+ this.fullResourcePlan = null;
+ }
+
+ public WMFullResourcePlan getFullResourcePlan() {
+ return this.fullResourcePlan;
+ }
+
+ public void setFullResourcePlan(WMFullResourcePlan fullResourcePlan) {
+ this.fullResourcePlan = fullResourcePlan;
+ }
+
+ public void unsetFullResourcePlan() {
+ this.fullResourcePlan = null;
+ }
+
+ /** Returns true if field fullResourcePlan is set (has been assigned a value) and false otherwise */
+ public boolean isSetFullResourcePlan() {
+ return this.fullResourcePlan != null;
+ }
+
+ public void setFullResourcePlanIsSet(boolean value) {
+ if (!value) {
+ this.fullResourcePlan = null;
+ }
}
public void setFieldValue(_Fields field, Object value) {
switch (field) {
+ case FULL_RESOURCE_PLAN:
+ if (value == null) {
+ unsetFullResourcePlan();
+ } else {
+ setFullResourcePlan((WMFullResourcePlan)value);
+ }
+ break;
+
}
}
public Object getFieldValue(_Fields field) {
switch (field) {
+ case FULL_RESOURCE_PLAN:
+ return getFullResourcePlan();
+
}
throw new IllegalStateException();
}
@@ -143,6 +190,8 @@ public class WMAlterResourcePlanResponse implements org.apache.thrift.TBase<WMAl
}
switch (field) {
+ case FULL_RESOURCE_PLAN:
+ return isSetFullResourcePlan();
}
throw new IllegalStateException();
}
@@ -160,6 +209,15 @@ public class WMAlterResourcePlanResponse implements org.apache.thrift.TBase<WMAl
if (that == null)
return false;
+ boolean this_present_fullResourcePlan = true && this.isSetFullResourcePlan();
+ boolean that_present_fullResourcePlan = true && that.isSetFullResourcePlan();
+ if (this_present_fullResourcePlan || that_present_fullResourcePlan) {
+ if (!(this_present_fullResourcePlan && that_present_fullResourcePlan))
+ return false;
+ if (!this.fullResourcePlan.equals(that.fullResourcePlan))
+ return false;
+ }
+
return true;
}
@@ -167,6 +225,11 @@ public class WMAlterResourcePlanResponse implements org.apache.thrift.TBase<WMAl
public int hashCode() {
List<Object> list = new ArrayList<Object>();
+ boolean present_fullResourcePlan = true && (isSetFullResourcePlan());
+ list.add(present_fullResourcePlan);
+ if (present_fullResourcePlan)
+ list.add(fullResourcePlan);
+
return list.hashCode();
}
@@ -178,6 +241,16 @@ public class WMAlterResourcePlanResponse implements org.apache.thrift.TBase<WMAl
int lastComparison = 0;
+ lastComparison = Boolean.valueOf(isSetFullResourcePlan()).compareTo(other.isSetFullResourcePlan());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetFullResourcePlan()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.fullResourcePlan, other.fullResourcePlan);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -198,6 +271,15 @@ public class WMAlterResourcePlanResponse implements org.apache.thrift.TBase<WMAl
StringBuilder sb = new StringBuilder("WMAlterResourcePlanResponse(");
boolean first = true;
+ if (isSetFullResourcePlan()) {
+ sb.append("fullResourcePlan:");
+ if (this.fullResourcePlan == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.fullResourcePlan);
+ }
+ first = false;
+ }
sb.append(")");
return sb.toString();
}
@@ -205,6 +287,9 @@ public class WMAlterResourcePlanResponse implements org.apache.thrift.TBase<WMAl
public void validate() throws org.apache.thrift.TException {
// check for required fields
// check for sub-struct validity
+ if (fullResourcePlan != null) {
+ fullResourcePlan.validate();
+ }
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -241,6 +326,15 @@ public class WMAlterResourcePlanResponse implements org.apache.thrift.TBase<WMAl
break;
}
switch (schemeField.id) {
+ case 1: // FULL_RESOURCE_PLAN
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.fullResourcePlan = new WMFullResourcePlan();
+ struct.fullResourcePlan.read(iprot);
+ struct.setFullResourcePlanIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
@@ -254,6 +348,13 @@ public class WMAlterResourcePlanResponse implements org.apache.thrift.TBase<WMAl
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.fullResourcePlan != null) {
+ if (struct.isSetFullResourcePlan()) {
+ oprot.writeFieldBegin(FULL_RESOURCE_PLAN_FIELD_DESC);
+ struct.fullResourcePlan.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ }
oprot.writeFieldStop();
oprot.writeStructEnd();
}
@@ -271,11 +372,25 @@ public class WMAlterResourcePlanResponse implements org.apache.thrift.TBase<WMAl
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, WMAlterResourcePlanResponse struct) throws org.apache.thrift.TException {
TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetFullResourcePlan()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.isSetFullResourcePlan()) {
+ struct.fullResourcePlan.write(oprot);
+ }
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, WMAlterResourcePlanResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ struct.fullResourcePlan = new WMFullResourcePlan();
+ struct.fullResourcePlan.read(iprot);
+ struct.setFullResourcePlanIsSet(true);
+ }
}
}
http://git-wip-us.apache.org/repos/asf/hive/blob/ddce801f/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterTriggerRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterTriggerRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterTriggerRequest.java
index d9938dc..dc0d355 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterTriggerRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterTriggerRequest.java
@@ -35,7 +35,7 @@ import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
-public class WMAlterTriggerRequest implements org.apache.thrift.TBase<WMAlterTriggerRequest, WMAlterTriggerRequest._Fields>, java.io.Serializable, Cloneable, Comparable<WMAlterTriggerRequest> {
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class WMAlterTriggerRequest implements org.apache.thrift.TBase<WMAlterTriggerRequest, WMAlterTriggerRequest._Fields>, java.io.Serializable, Cloneable, Comparable<WMAlterTriggerRequest> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WMAlterTriggerRequest");
private static final org.apache.thrift.protocol.TField TRIGGER_FIELD_DESC = new org.apache.thrift.protocol.TField("trigger", org.apache.thrift.protocol.TType.STRUCT, (short)1);
http://git-wip-us.apache.org/repos/asf/hive/blob/ddce801f/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterTriggerResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterTriggerResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterTriggerResponse.java
index d66aeaa..eb83261 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterTriggerResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMAlterTriggerResponse.java
@@ -35,7 +35,7 @@ import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
-public class WMAlterTriggerResponse implements org.apache.thrift.TBase<WMAlterTriggerResponse, WMAlterTriggerResponse._Fields>, java.io.Serializable, Cloneable, Comparable<WMAlterTriggerResponse> {
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class WMAlterTriggerResponse implements org.apache.thrift.TBase<WMAlterTriggerResponse, WMAlterTriggerResponse._Fields>, java.io.Serializable, Cloneable, Comparable<WMAlterTriggerResponse> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WMAlterTriggerResponse");
http://git-wip-us.apache.org/repos/asf/hive/blob/ddce801f/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateResourcePlanRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateResourcePlanRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateResourcePlanRequest.java
index c5fb10b..1af2159 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateResourcePlanRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateResourcePlanRequest.java
@@ -35,7 +35,7 @@ import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
-public class WMCreateResourcePlanRequest implements org.apache.thrift.TBase<WMCreateResourcePlanRequest, WMCreateResourcePlanRequest._Fields>, java.io.Serializable, Cloneable, Comparable<WMCreateResourcePlanRequest> {
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class WMCreateResourcePlanRequest implements org.apache.thrift.TBase<WMCreateResourcePlanRequest, WMCreateResourcePlanRequest._Fields>, java.io.Serializable, Cloneable, Comparable<WMCreateResourcePlanRequest> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WMCreateResourcePlanRequest");
private static final org.apache.thrift.protocol.TField RESOURCE_PLAN_FIELD_DESC = new org.apache.thrift.protocol.TField("resourcePlan", org.apache.thrift.protocol.TType.STRUCT, (short)1);
http://git-wip-us.apache.org/repos/asf/hive/blob/ddce801f/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateResourcePlanResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateResourcePlanResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateResourcePlanResponse.java
index c6769f8..cb3aa6d 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateResourcePlanResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateResourcePlanResponse.java
@@ -35,7 +35,7 @@ import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
-public class WMCreateResourcePlanResponse implements org.apache.thrift.TBase<WMCreateResourcePlanResponse, WMCreateResourcePlanResponse._Fields>, java.io.Serializable, Cloneable, Comparable<WMCreateResourcePlanResponse> {
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class WMCreateResourcePlanResponse implements org.apache.thrift.TBase<WMCreateResourcePlanResponse, WMCreateResourcePlanResponse._Fields>, java.io.Serializable, Cloneable, Comparable<WMCreateResourcePlanResponse> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WMCreateResourcePlanResponse");
http://git-wip-us.apache.org/repos/asf/hive/blob/ddce801f/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateTriggerRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateTriggerRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateTriggerRequest.java
index be72429..2508129 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateTriggerRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateTriggerRequest.java
@@ -35,7 +35,7 @@ import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
-public class WMCreateTriggerRequest implements org.apache.thrift.TBase<WMCreateTriggerRequest, WMCreateTriggerRequest._Fields>, java.io.Serializable, Cloneable, Comparable<WMCreateTriggerRequest> {
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class WMCreateTriggerRequest implements org.apache.thrift.TBase<WMCreateTriggerRequest, WMCreateTriggerRequest._Fields>, java.io.Serializable, Cloneable, Comparable<WMCreateTriggerRequest> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WMCreateTriggerRequest");
private static final org.apache.thrift.protocol.TField TRIGGER_FIELD_DESC = new org.apache.thrift.protocol.TField("trigger", org.apache.thrift.protocol.TType.STRUCT, (short)1);
http://git-wip-us.apache.org/repos/asf/hive/blob/ddce801f/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateTriggerResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateTriggerResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateTriggerResponse.java
index 53e0082..068bc11 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateTriggerResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMCreateTriggerResponse.java
@@ -35,7 +35,7 @@ import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
-public class WMCreateTriggerResponse implements org.apache.thrift.TBase<WMCreateTriggerResponse, WMCreateTriggerResponse._Fields>, java.io.Serializable, Cloneable, Comparable<WMCreateTriggerResponse> {
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class WMCreateTriggerResponse implements org.apache.thrift.TBase<WMCreateTriggerResponse, WMCreateTriggerResponse._Fields>, java.io.Serializable, Cloneable, Comparable<WMCreateTriggerResponse> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WMCreateTriggerResponse");
http://git-wip-us.apache.org/repos/asf/hive/blob/ddce801f/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropResourcePlanRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropResourcePlanRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropResourcePlanRequest.java
index 2f8d7d2..779b2d1 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropResourcePlanRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropResourcePlanRequest.java
@@ -35,7 +35,7 @@ import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
-public class WMDropResourcePlanRequest implements org.apache.thrift.TBase<WMDropResourcePlanRequest, WMDropResourcePlanRequest._Fields>, java.io.Serializable, Cloneable, Comparable<WMDropResourcePlanRequest> {
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class WMDropResourcePlanRequest implements org.apache.thrift.TBase<WMDropResourcePlanRequest, WMDropResourcePlanRequest._Fields>, java.io.Serializable, Cloneable, Comparable<WMDropResourcePlanRequest> {
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);
http://git-wip-us.apache.org/repos/asf/hive/blob/ddce801f/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropResourcePlanResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropResourcePlanResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropResourcePlanResponse.java
index 9e58fa0..6edab04 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropResourcePlanResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropResourcePlanResponse.java
@@ -35,7 +35,7 @@ import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
-public class WMDropResourcePlanResponse implements org.apache.thrift.TBase<WMDropResourcePlanResponse, WMDropResourcePlanResponse._Fields>, java.io.Serializable, Cloneable, Comparable<WMDropResourcePlanResponse> {
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class WMDropResourcePlanResponse implements org.apache.thrift.TBase<WMDropResourcePlanResponse, WMDropResourcePlanResponse._Fields>, java.io.Serializable, Cloneable, Comparable<WMDropResourcePlanResponse> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WMDropResourcePlanResponse");
http://git-wip-us.apache.org/repos/asf/hive/blob/ddce801f/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropTriggerRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropTriggerRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropTriggerRequest.java
index 05f9c43..9cde38d 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropTriggerRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropTriggerRequest.java
@@ -35,7 +35,7 @@ import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
-public class WMDropTriggerRequest implements org.apache.thrift.TBase<WMDropTriggerRequest, WMDropTriggerRequest._Fields>, java.io.Serializable, Cloneable, Comparable<WMDropTriggerRequest> {
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class WMDropTriggerRequest implements org.apache.thrift.TBase<WMDropTriggerRequest, WMDropTriggerRequest._Fields>, java.io.Serializable, Cloneable, Comparable<WMDropTriggerRequest> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WMDropTriggerRequest");
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);
http://git-wip-us.apache.org/repos/asf/hive/blob/ddce801f/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropTriggerResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropTriggerResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropTriggerResponse.java
index 363018e..419a5e3 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropTriggerResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMDropTriggerResponse.java
@@ -35,7 +35,7 @@ import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
-public class WMDropTriggerResponse implements org.apache.thrift.TBase<WMDropTriggerResponse, WMDropTriggerResponse._Fields>, java.io.Serializable, Cloneable, Comparable<WMDropTriggerResponse> {
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class WMDropTriggerResponse implements org.apache.thrift.TBase<WMDropTriggerResponse, WMDropTriggerResponse._Fields>, java.io.Serializable, Cloneable, Comparable<WMDropTriggerResponse> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WMDropTriggerResponse");
http://git-wip-us.apache.org/repos/asf/hive/blob/ddce801f/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java
new file mode 100644
index 0000000..1d21908
--- /dev/null
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java
@@ -0,0 +1,1033 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.hadoop.hive.metastore.api;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class WMFullResourcePlan implements org.apache.thrift.TBase<WMFullResourcePlan, WMFullResourcePlan._Fields>, java.io.Serializable, Cloneable, Comparable<WMFullResourcePlan> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WMFullResourcePlan");
+
+ private static final org.apache.thrift.protocol.TField PLAN_FIELD_DESC = new org.apache.thrift.protocol.TField("plan", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+ private static final org.apache.thrift.protocol.TField POOLS_FIELD_DESC = new org.apache.thrift.protocol.TField("pools", org.apache.thrift.protocol.TType.LIST, (short)2);
+ private static final org.apache.thrift.protocol.TField MAPPINGS_FIELD_DESC = new org.apache.thrift.protocol.TField("mappings", org.apache.thrift.protocol.TType.LIST, (short)3);
+ private static final org.apache.thrift.protocol.TField TRIGGERS_FIELD_DESC = new org.apache.thrift.protocol.TField("triggers", org.apache.thrift.protocol.TType.LIST, (short)4);
+ private static final org.apache.thrift.protocol.TField POOL_TRIGGERS_FIELD_DESC = new org.apache.thrift.protocol.TField("poolTriggers", org.apache.thrift.protocol.TType.LIST, (short)5);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new WMFullResourcePlanStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new WMFullResourcePlanTupleSchemeFactory());
+ }
+
+ private WMResourcePlan plan; // required
+ private List<WMPool> pools; // required
+ private List<WMMapping> mappings; // optional
+ private List<WMTrigger> triggers; // optional
+ private List<WMPoolTrigger> poolTriggers; // 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 {
+ PLAN((short)1, "plan"),
+ POOLS((short)2, "pools"),
+ MAPPINGS((short)3, "mappings"),
+ TRIGGERS((short)4, "triggers"),
+ POOL_TRIGGERS((short)5, "poolTriggers");
+
+ private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+ static {
+ for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ byName.put(field.getFieldName(), field);
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, or null if its not found.
+ */
+ public static _Fields findByThriftId(int fieldId) {
+ switch(fieldId) {
+ case 1: // PLAN
+ return PLAN;
+ case 2: // POOLS
+ return POOLS;
+ case 3: // MAPPINGS
+ return MAPPINGS;
+ case 4: // TRIGGERS
+ return TRIGGERS;
+ case 5: // POOL_TRIGGERS
+ return POOL_TRIGGERS;
+ default:
+ return null;
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, throwing an exception
+ * if it is not found.
+ */
+ public static _Fields findByThriftIdOrThrow(int fieldId) {
+ _Fields fields = findByThriftId(fieldId);
+ if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ return fields;
+ }
+
+ /**
+ * Find the _Fields constant that matches name, or null if its not found.
+ */
+ public static _Fields findByName(String name) {
+ return byName.get(name);
+ }
+
+ private final short _thriftId;
+ private final String _fieldName;
+
+ _Fields(short thriftId, String fieldName) {
+ _thriftId = thriftId;
+ _fieldName = fieldName;
+ }
+
+ public short getThriftFieldId() {
+ return _thriftId;
+ }
+
+ public String getFieldName() {
+ return _fieldName;
+ }
+ }
+
+ // isset id assignments
+ private static final _Fields optionals[] = {_Fields.MAPPINGS,_Fields.TRIGGERS,_Fields.POOL_TRIGGERS};
+ 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.PLAN, new org.apache.thrift.meta_data.FieldMetaData("plan", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, WMResourcePlan.class)));
+ tmpMap.put(_Fields.POOLS, new org.apache.thrift.meta_data.FieldMetaData("pools", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, WMPool.class))));
+ tmpMap.put(_Fields.MAPPINGS, new org.apache.thrift.meta_data.FieldMetaData("mappings", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, WMMapping.class))));
+ tmpMap.put(_Fields.TRIGGERS, new org.apache.thrift.meta_data.FieldMetaData("triggers", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, WMTrigger.class))));
+ tmpMap.put(_Fields.POOL_TRIGGERS, new org.apache.thrift.meta_data.FieldMetaData("poolTriggers", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, WMPoolTrigger.class))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(WMFullResourcePlan.class, metaDataMap);
+ }
+
+ public WMFullResourcePlan() {
+ }
+
+ public WMFullResourcePlan(
+ WMResourcePlan plan,
+ List<WMPool> pools)
+ {
+ this();
+ this.plan = plan;
+ this.pools = pools;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public WMFullResourcePlan(WMFullResourcePlan other) {
+ if (other.isSetPlan()) {
+ this.plan = new WMResourcePlan(other.plan);
+ }
+ if (other.isSetPools()) {
+ List<WMPool> __this__pools = new ArrayList<WMPool>(other.pools.size());
+ for (WMPool other_element : other.pools) {
+ __this__pools.add(new WMPool(other_element));
+ }
+ this.pools = __this__pools;
+ }
+ if (other.isSetMappings()) {
+ List<WMMapping> __this__mappings = new ArrayList<WMMapping>(other.mappings.size());
+ for (WMMapping other_element : other.mappings) {
+ __this__mappings.add(new WMMapping(other_element));
+ }
+ this.mappings = __this__mappings;
+ }
+ if (other.isSetTriggers()) {
+ List<WMTrigger> __this__triggers = new ArrayList<WMTrigger>(other.triggers.size());
+ for (WMTrigger other_element : other.triggers) {
+ __this__triggers.add(new WMTrigger(other_element));
+ }
+ this.triggers = __this__triggers;
+ }
+ if (other.isSetPoolTriggers()) {
+ List<WMPoolTrigger> __this__poolTriggers = new ArrayList<WMPoolTrigger>(other.poolTriggers.size());
+ for (WMPoolTrigger other_element : other.poolTriggers) {
+ __this__poolTriggers.add(new WMPoolTrigger(other_element));
+ }
+ this.poolTriggers = __this__poolTriggers;
+ }
+ }
+
+ public WMFullResourcePlan deepCopy() {
+ return new WMFullResourcePlan(this);
+ }
+
+ @Override
+ public void clear() {
+ this.plan = null;
+ this.pools = null;
+ this.mappings = null;
+ this.triggers = null;
+ this.poolTriggers = null;
+ }
+
+ public WMResourcePlan getPlan() {
+ return this.plan;
+ }
+
+ public void setPlan(WMResourcePlan plan) {
+ this.plan = plan;
+ }
+
+ public void unsetPlan() {
+ this.plan = null;
+ }
+
+ /** Returns true if field plan is set (has been assigned a value) and false otherwise */
+ public boolean isSetPlan() {
+ return this.plan != null;
+ }
+
+ public void setPlanIsSet(boolean value) {
+ if (!value) {
+ this.plan = null;
+ }
+ }
+
+ public int getPoolsSize() {
+ return (this.pools == null) ? 0 : this.pools.size();
+ }
+
+ public java.util.Iterator<WMPool> getPoolsIterator() {
+ return (this.pools == null) ? null : this.pools.iterator();
+ }
+
+ public void addToPools(WMPool elem) {
+ if (this.pools == null) {
+ this.pools = new ArrayList<WMPool>();
+ }
+ this.pools.add(elem);
+ }
+
+ public List<WMPool> getPools() {
+ return this.pools;
+ }
+
+ public void setPools(List<WMPool> pools) {
+ this.pools = pools;
+ }
+
+ public void unsetPools() {
+ this.pools = null;
+ }
+
+ /** Returns true if field pools is set (has been assigned a value) and false otherwise */
+ public boolean isSetPools() {
+ return this.pools != null;
+ }
+
+ public void setPoolsIsSet(boolean value) {
+ if (!value) {
+ this.pools = null;
+ }
+ }
+
+ public int getMappingsSize() {
+ return (this.mappings == null) ? 0 : this.mappings.size();
+ }
+
+ public java.util.Iterator<WMMapping> getMappingsIterator() {
+ return (this.mappings == null) ? null : this.mappings.iterator();
+ }
+
+ public void addToMappings(WMMapping elem) {
+ if (this.mappings == null) {
+ this.mappings = new ArrayList<WMMapping>();
+ }
+ this.mappings.add(elem);
+ }
+
+ public List<WMMapping> getMappings() {
+ return this.mappings;
+ }
+
+ public void setMappings(List<WMMapping> mappings) {
+ this.mappings = mappings;
+ }
+
+ public void unsetMappings() {
+ this.mappings = null;
+ }
+
+ /** Returns true if field mappings is set (has been assigned a value) and false otherwise */
+ public boolean isSetMappings() {
+ return this.mappings != null;
+ }
+
+ public void setMappingsIsSet(boolean value) {
+ if (!value) {
+ this.mappings = null;
+ }
+ }
+
+ public int getTriggersSize() {
+ return (this.triggers == null) ? 0 : this.triggers.size();
+ }
+
+ public java.util.Iterator<WMTrigger> getTriggersIterator() {
+ return (this.triggers == null) ? null : this.triggers.iterator();
+ }
+
+ public void addToTriggers(WMTrigger elem) {
+ if (this.triggers == null) {
+ this.triggers = new ArrayList<WMTrigger>();
+ }
+ this.triggers.add(elem);
+ }
+
+ public List<WMTrigger> getTriggers() {
+ return this.triggers;
+ }
+
+ public void setTriggers(List<WMTrigger> triggers) {
+ this.triggers = triggers;
+ }
+
+ public void unsetTriggers() {
+ this.triggers = null;
+ }
+
+ /** Returns true if field triggers is set (has been assigned a value) and false otherwise */
+ public boolean isSetTriggers() {
+ return this.triggers != null;
+ }
+
+ public void setTriggersIsSet(boolean value) {
+ if (!value) {
+ this.triggers = null;
+ }
+ }
+
+ public int getPoolTriggersSize() {
+ return (this.poolTriggers == null) ? 0 : this.poolTriggers.size();
+ }
+
+ public java.util.Iterator<WMPoolTrigger> getPoolTriggersIterator() {
+ return (this.poolTriggers == null) ? null : this.poolTriggers.iterator();
+ }
+
+ public void addToPoolTriggers(WMPoolTrigger elem) {
+ if (this.poolTriggers == null) {
+ this.poolTriggers = new ArrayList<WMPoolTrigger>();
+ }
+ this.poolTriggers.add(elem);
+ }
+
+ public List<WMPoolTrigger> getPoolTriggers() {
+ return this.poolTriggers;
+ }
+
+ public void setPoolTriggers(List<WMPoolTrigger> poolTriggers) {
+ this.poolTriggers = poolTriggers;
+ }
+
+ public void unsetPoolTriggers() {
+ this.poolTriggers = null;
+ }
+
+ /** Returns true if field poolTriggers is set (has been assigned a value) and false otherwise */
+ public boolean isSetPoolTriggers() {
+ return this.poolTriggers != null;
+ }
+
+ public void setPoolTriggersIsSet(boolean value) {
+ if (!value) {
+ this.poolTriggers = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case PLAN:
+ if (value == null) {
+ unsetPlan();
+ } else {
+ setPlan((WMResourcePlan)value);
+ }
+ break;
+
+ case POOLS:
+ if (value == null) {
+ unsetPools();
+ } else {
+ setPools((List<WMPool>)value);
+ }
+ break;
+
+ case MAPPINGS:
+ if (value == null) {
+ unsetMappings();
+ } else {
+ setMappings((List<WMMapping>)value);
+ }
+ break;
+
+ case TRIGGERS:
+ if (value == null) {
+ unsetTriggers();
+ } else {
+ setTriggers((List<WMTrigger>)value);
+ }
+ break;
+
+ case POOL_TRIGGERS:
+ if (value == null) {
+ unsetPoolTriggers();
+ } else {
+ setPoolTriggers((List<WMPoolTrigger>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case PLAN:
+ return getPlan();
+
+ case POOLS:
+ return getPools();
+
+ case MAPPINGS:
+ return getMappings();
+
+ case TRIGGERS:
+ return getTriggers();
+
+ case POOL_TRIGGERS:
+ return getPoolTriggers();
+
+ }
+ throw new IllegalStateException();
+ }
+
+ /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
+ public boolean isSet(_Fields field) {
+ if (field == null) {
+ throw new IllegalArgumentException();
+ }
+
+ switch (field) {
+ case PLAN:
+ return isSetPlan();
+ case POOLS:
+ return isSetPools();
+ case MAPPINGS:
+ return isSetMappings();
+ case TRIGGERS:
+ return isSetTriggers();
+ case POOL_TRIGGERS:
+ return isSetPoolTriggers();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof WMFullResourcePlan)
+ return this.equals((WMFullResourcePlan)that);
+ return false;
+ }
+
+ public boolean equals(WMFullResourcePlan that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_plan = true && this.isSetPlan();
+ boolean that_present_plan = true && that.isSetPlan();
+ if (this_present_plan || that_present_plan) {
+ if (!(this_present_plan && that_present_plan))
+ return false;
+ if (!this.plan.equals(that.plan))
+ return false;
+ }
+
+ boolean this_present_pools = true && this.isSetPools();
+ boolean that_present_pools = true && that.isSetPools();
+ if (this_present_pools || that_present_pools) {
+ if (!(this_present_pools && that_present_pools))
+ return false;
+ if (!this.pools.equals(that.pools))
+ return false;
+ }
+
+ boolean this_present_mappings = true && this.isSetMappings();
+ boolean that_present_mappings = true && that.isSetMappings();
+ if (this_present_mappings || that_present_mappings) {
+ if (!(this_present_mappings && that_present_mappings))
+ return false;
+ if (!this.mappings.equals(that.mappings))
+ return false;
+ }
+
+ boolean this_present_triggers = true && this.isSetTriggers();
+ boolean that_present_triggers = true && that.isSetTriggers();
+ if (this_present_triggers || that_present_triggers) {
+ if (!(this_present_triggers && that_present_triggers))
+ return false;
+ if (!this.triggers.equals(that.triggers))
+ return false;
+ }
+
+ boolean this_present_poolTriggers = true && this.isSetPoolTriggers();
+ boolean that_present_poolTriggers = true && that.isSetPoolTriggers();
+ if (this_present_poolTriggers || that_present_poolTriggers) {
+ if (!(this_present_poolTriggers && that_present_poolTriggers))
+ return false;
+ if (!this.poolTriggers.equals(that.poolTriggers))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_plan = true && (isSetPlan());
+ list.add(present_plan);
+ if (present_plan)
+ list.add(plan);
+
+ boolean present_pools = true && (isSetPools());
+ list.add(present_pools);
+ if (present_pools)
+ list.add(pools);
+
+ boolean present_mappings = true && (isSetMappings());
+ list.add(present_mappings);
+ if (present_mappings)
+ list.add(mappings);
+
+ boolean present_triggers = true && (isSetTriggers());
+ list.add(present_triggers);
+ if (present_triggers)
+ list.add(triggers);
+
+ boolean present_poolTriggers = true && (isSetPoolTriggers());
+ list.add(present_poolTriggers);
+ if (present_poolTriggers)
+ list.add(poolTriggers);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(WMFullResourcePlan other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetPlan()).compareTo(other.isSetPlan());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetPlan()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.plan, other.plan);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetPools()).compareTo(other.isSetPools());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetPools()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.pools, other.pools);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetMappings()).compareTo(other.isSetMappings());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetMappings()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.mappings, other.mappings);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetTriggers()).compareTo(other.isSetTriggers());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetTriggers()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.triggers, other.triggers);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetPoolTriggers()).compareTo(other.isSetPoolTriggers());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetPoolTriggers()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.poolTriggers, other.poolTriggers);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ return 0;
+ }
+
+ public _Fields fieldForId(int fieldId) {
+ return _Fields.findByThriftId(fieldId);
+ }
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("WMFullResourcePlan(");
+ boolean first = true;
+
+ sb.append("plan:");
+ if (this.plan == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.plan);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("pools:");
+ if (this.pools == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.pools);
+ }
+ first = false;
+ if (isSetMappings()) {
+ if (!first) sb.append(", ");
+ sb.append("mappings:");
+ if (this.mappings == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.mappings);
+ }
+ first = false;
+ }
+ if (isSetTriggers()) {
+ if (!first) sb.append(", ");
+ sb.append("triggers:");
+ if (this.triggers == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.triggers);
+ }
+ first = false;
+ }
+ if (isSetPoolTriggers()) {
+ if (!first) sb.append(", ");
+ sb.append("poolTriggers:");
+ if (this.poolTriggers == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.poolTriggers);
+ }
+ first = false;
+ }
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetPlan()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'plan' is unset! Struct:" + toString());
+ }
+
+ if (!isSetPools()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'pools' is unset! Struct:" + toString());
+ }
+
+ // check for sub-struct validity
+ if (plan != null) {
+ plan.validate();
+ }
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class WMFullResourcePlanStandardSchemeFactory implements SchemeFactory {
+ public WMFullResourcePlanStandardScheme getScheme() {
+ return new WMFullResourcePlanStandardScheme();
+ }
+ }
+
+ private static class WMFullResourcePlanStandardScheme extends StandardScheme<WMFullResourcePlan> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, WMFullResourcePlan struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // PLAN
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.plan = new WMResourcePlan();
+ struct.plan.read(iprot);
+ struct.setPlanIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // POOLS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list738 = iprot.readListBegin();
+ struct.pools = new ArrayList<WMPool>(_list738.size);
+ WMPool _elem739;
+ for (int _i740 = 0; _i740 < _list738.size; ++_i740)
+ {
+ _elem739 = new WMPool();
+ _elem739.read(iprot);
+ struct.pools.add(_elem739);
+ }
+ iprot.readListEnd();
+ }
+ struct.setPoolsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // MAPPINGS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list741 = iprot.readListBegin();
+ struct.mappings = new ArrayList<WMMapping>(_list741.size);
+ WMMapping _elem742;
+ for (int _i743 = 0; _i743 < _list741.size; ++_i743)
+ {
+ _elem742 = new WMMapping();
+ _elem742.read(iprot);
+ struct.mappings.add(_elem742);
+ }
+ iprot.readListEnd();
+ }
+ struct.setMappingsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 4: // TRIGGERS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list744 = iprot.readListBegin();
+ struct.triggers = new ArrayList<WMTrigger>(_list744.size);
+ WMTrigger _elem745;
+ for (int _i746 = 0; _i746 < _list744.size; ++_i746)
+ {
+ _elem745 = new WMTrigger();
+ _elem745.read(iprot);
+ struct.triggers.add(_elem745);
+ }
+ iprot.readListEnd();
+ }
+ struct.setTriggersIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 5: // POOL_TRIGGERS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list747 = iprot.readListBegin();
+ struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list747.size);
+ WMPoolTrigger _elem748;
+ for (int _i749 = 0; _i749 < _list747.size; ++_i749)
+ {
+ _elem748 = new WMPoolTrigger();
+ _elem748.read(iprot);
+ struct.poolTriggers.add(_elem748);
+ }
+ iprot.readListEnd();
+ }
+ struct.setPoolTriggersIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, WMFullResourcePlan struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.plan != null) {
+ oprot.writeFieldBegin(PLAN_FIELD_DESC);
+ struct.plan.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ if (struct.pools != null) {
+ oprot.writeFieldBegin(POOLS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.pools.size()));
+ for (WMPool _iter750 : struct.pools)
+ {
+ _iter750.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ if (struct.mappings != null) {
+ if (struct.isSetMappings()) {
+ oprot.writeFieldBegin(MAPPINGS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.mappings.size()));
+ for (WMMapping _iter751 : struct.mappings)
+ {
+ _iter751.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.triggers != null) {
+ if (struct.isSetTriggers()) {
+ oprot.writeFieldBegin(TRIGGERS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.triggers.size()));
+ for (WMTrigger _iter752 : struct.triggers)
+ {
+ _iter752.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.poolTriggers != null) {
+ if (struct.isSetPoolTriggers()) {
+ oprot.writeFieldBegin(POOL_TRIGGERS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.poolTriggers.size()));
+ for (WMPoolTrigger _iter753 : struct.poolTriggers)
+ {
+ _iter753.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class WMFullResourcePlanTupleSchemeFactory implements SchemeFactory {
+ public WMFullResourcePlanTupleScheme getScheme() {
+ return new WMFullResourcePlanTupleScheme();
+ }
+ }
+
+ private static class WMFullResourcePlanTupleScheme extends TupleScheme<WMFullResourcePlan> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, WMFullResourcePlan struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ struct.plan.write(oprot);
+ {
+ oprot.writeI32(struct.pools.size());
+ for (WMPool _iter754 : struct.pools)
+ {
+ _iter754.write(oprot);
+ }
+ }
+ BitSet optionals = new BitSet();
+ if (struct.isSetMappings()) {
+ optionals.set(0);
+ }
+ if (struct.isSetTriggers()) {
+ optionals.set(1);
+ }
+ if (struct.isSetPoolTriggers()) {
+ optionals.set(2);
+ }
+ oprot.writeBitSet(optionals, 3);
+ if (struct.isSetMappings()) {
+ {
+ oprot.writeI32(struct.mappings.size());
+ for (WMMapping _iter755 : struct.mappings)
+ {
+ _iter755.write(oprot);
+ }
+ }
+ }
+ if (struct.isSetTriggers()) {
+ {
+ oprot.writeI32(struct.triggers.size());
+ for (WMTrigger _iter756 : struct.triggers)
+ {
+ _iter756.write(oprot);
+ }
+ }
+ }
+ if (struct.isSetPoolTriggers()) {
+ {
+ oprot.writeI32(struct.poolTriggers.size());
+ for (WMPoolTrigger _iter757 : struct.poolTriggers)
+ {
+ _iter757.write(oprot);
+ }
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, WMFullResourcePlan struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.plan = new WMResourcePlan();
+ struct.plan.read(iprot);
+ struct.setPlanIsSet(true);
+ {
+ org.apache.thrift.protocol.TList _list758 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.pools = new ArrayList<WMPool>(_list758.size);
+ WMPool _elem759;
+ for (int _i760 = 0; _i760 < _list758.size; ++_i760)
+ {
+ _elem759 = new WMPool();
+ _elem759.read(iprot);
+ struct.pools.add(_elem759);
+ }
+ }
+ struct.setPoolsIsSet(true);
+ BitSet incoming = iprot.readBitSet(3);
+ if (incoming.get(0)) {
+ {
+ org.apache.thrift.protocol.TList _list761 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.mappings = new ArrayList<WMMapping>(_list761.size);
+ WMMapping _elem762;
+ for (int _i763 = 0; _i763 < _list761.size; ++_i763)
+ {
+ _elem762 = new WMMapping();
+ _elem762.read(iprot);
+ struct.mappings.add(_elem762);
+ }
+ }
+ struct.setMappingsIsSet(true);
+ }
+ if (incoming.get(1)) {
+ {
+ org.apache.thrift.protocol.TList _list764 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.triggers = new ArrayList<WMTrigger>(_list764.size);
+ WMTrigger _elem765;
+ for (int _i766 = 0; _i766 < _list764.size; ++_i766)
+ {
+ _elem765 = new WMTrigger();
+ _elem765.read(iprot);
+ struct.triggers.add(_elem765);
+ }
+ }
+ struct.setTriggersIsSet(true);
+ }
+ if (incoming.get(2)) {
+ {
+ org.apache.thrift.protocol.TList _list767 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list767.size);
+ WMPoolTrigger _elem768;
+ for (int _i769 = 0; _i769 < _list767.size; ++_i769)
+ {
+ _elem768 = new WMPoolTrigger();
+ _elem768.read(iprot);
+ struct.poolTriggers.add(_elem768);
+ }
+ }
+ struct.setPoolTriggersIsSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/hive/blob/ddce801f/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetActiveResourcePlanRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetActiveResourcePlanRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetActiveResourcePlanRequest.java
new file mode 100644
index 0000000..ec2a1f5
--- /dev/null
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetActiveResourcePlanRequest.java
@@ -0,0 +1,283 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.hadoop.hive.metastore.api;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class 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 Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new WMGetActiveResourcePlanRequestStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new WMGetActiveResourcePlanRequestTupleSchemeFactory());
+ }
+
+
+ /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+ public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+;
+
+ private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+ static {
+ for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ byName.put(field.getFieldName(), field);
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, or null if its not found.
+ */
+ public static _Fields findByThriftId(int fieldId) {
+ switch(fieldId) {
+ default:
+ return null;
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, throwing an exception
+ * if it is not found.
+ */
+ public static _Fields findByThriftIdOrThrow(int fieldId) {
+ _Fields fields = findByThriftId(fieldId);
+ if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ return fields;
+ }
+
+ /**
+ * Find the _Fields constant that matches name, or null if its not found.
+ */
+ public static _Fields findByName(String name) {
+ return byName.get(name);
+ }
+
+ private final short _thriftId;
+ private final String _fieldName;
+
+ _Fields(short thriftId, String fieldName) {
+ _thriftId = thriftId;
+ _fieldName = fieldName;
+ }
+
+ public short getThriftFieldId() {
+ return _thriftId;
+ }
+
+ public String getFieldName() {
+ return _fieldName;
+ }
+ }
+ 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);
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(WMGetActiveResourcePlanRequest.class, metaDataMap);
+ }
+
+ public WMGetActiveResourcePlanRequest() {
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public WMGetActiveResourcePlanRequest(WMGetActiveResourcePlanRequest other) {
+ }
+
+ public WMGetActiveResourcePlanRequest deepCopy() {
+ return new WMGetActiveResourcePlanRequest(this);
+ }
+
+ @Override
+ public void clear() {
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ }
+ throw new IllegalStateException();
+ }
+
+ /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
+ public boolean isSet(_Fields field) {
+ if (field == null) {
+ throw new IllegalArgumentException();
+ }
+
+ switch (field) {
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof WMGetActiveResourcePlanRequest)
+ return this.equals((WMGetActiveResourcePlanRequest)that);
+ return false;
+ }
+
+ public boolean equals(WMGetActiveResourcePlanRequest that) {
+ if (that == null)
+ return false;
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(WMGetActiveResourcePlanRequest other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ return 0;
+ }
+
+ public _Fields fieldForId(int fieldId) {
+ return _Fields.findByThriftId(fieldId);
+ }
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("WMGetActiveResourcePlanRequest(");
+ boolean first = true;
+
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ // check for sub-struct validity
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class WMGetActiveResourcePlanRequestStandardSchemeFactory implements SchemeFactory {
+ public WMGetActiveResourcePlanRequestStandardScheme getScheme() {
+ return new WMGetActiveResourcePlanRequestStandardScheme();
+ }
+ }
+
+ private static class WMGetActiveResourcePlanRequestStandardScheme extends StandardScheme<WMGetActiveResourcePlanRequest> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, WMGetActiveResourcePlanRequest struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, WMGetActiveResourcePlanRequest struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class WMGetActiveResourcePlanRequestTupleSchemeFactory implements SchemeFactory {
+ public WMGetActiveResourcePlanRequestTupleScheme getScheme() {
+ return new WMGetActiveResourcePlanRequestTupleScheme();
+ }
+ }
+
+ private static class WMGetActiveResourcePlanRequestTupleScheme extends TupleScheme<WMGetActiveResourcePlanRequest> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, WMGetActiveResourcePlanRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, WMGetActiveResourcePlanRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ }
+ }
+
+}
+