hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ser...@apache.org
Subject [4/8] hive git commit: HIVE-18179 : Implement validate resource plan (part 1) (Harish Jaiprakash, reviewed by Sergey Shelukhin)
Date Wed, 06 Dec 2017 00:07:34 GMT
http://git-wip-us.apache.org/repos/asf/hive/blob/0d832335/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java
b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java
index 63b1c9a..b274250 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java
@@ -346,14 +346,14 @@ import org.slf4j.LoggerFactory;
           case 1: // TRIGGERS
             if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
               {
-                org.apache.thrift.protocol.TList _list778 = iprot.readListBegin();
-                struct.triggers = new ArrayList<WMTrigger>(_list778.size);
-                WMTrigger _elem779;
-                for (int _i780 = 0; _i780 < _list778.size; ++_i780)
+                org.apache.thrift.protocol.TList _list786 = iprot.readListBegin();
+                struct.triggers = new ArrayList<WMTrigger>(_list786.size);
+                WMTrigger _elem787;
+                for (int _i788 = 0; _i788 < _list786.size; ++_i788)
                 {
-                  _elem779 = new WMTrigger();
-                  _elem779.read(iprot);
-                  struct.triggers.add(_elem779);
+                  _elem787 = new WMTrigger();
+                  _elem787.read(iprot);
+                  struct.triggers.add(_elem787);
                 }
                 iprot.readListEnd();
               }
@@ -380,9 +380,9 @@ import org.slf4j.LoggerFactory;
           oprot.writeFieldBegin(TRIGGERS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT,
struct.triggers.size()));
-            for (WMTrigger _iter781 : struct.triggers)
+            for (WMTrigger _iter789 : struct.triggers)
             {
-              _iter781.write(oprot);
+              _iter789.write(oprot);
             }
             oprot.writeListEnd();
           }
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
       if (struct.isSetTriggers()) {
         {
           oprot.writeI32(struct.triggers.size());
-          for (WMTrigger _iter782 : struct.triggers)
+          for (WMTrigger _iter790 : struct.triggers)
           {
-            _iter782.write(oprot);
+            _iter790.write(oprot);
           }
         }
       }
@@ -428,14 +428,14 @@ import org.slf4j.LoggerFactory;
       BitSet incoming = iprot.readBitSet(1);
       if (incoming.get(0)) {
         {
-          org.apache.thrift.protocol.TList _list783 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT,
iprot.readI32());
-          struct.triggers = new ArrayList<WMTrigger>(_list783.size);
-          WMTrigger _elem784;
-          for (int _i785 = 0; _i785 < _list783.size; ++_i785)
+          org.apache.thrift.protocol.TList _list791 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT,
iprot.readI32());
+          struct.triggers = new ArrayList<WMTrigger>(_list791.size);
+          WMTrigger _elem792;
+          for (int _i793 = 0; _i793 < _list791.size; ++_i793)
           {
-            _elem784 = new WMTrigger();
-            _elem784.read(iprot);
-            struct.triggers.add(_elem784);
+            _elem792 = new WMTrigger();
+            _elem792.read(iprot);
+            struct.triggers.add(_elem792);
           }
         }
         struct.setTriggersIsSet(true);

http://git-wip-us.apache.org/repos/asf/hive/blob/0d832335/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java
b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java
index 17938ae..b69cd4c 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java
@@ -38,7 +38,7 @@ import org.slf4j.LoggerFactory;
 @org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable
public class WMValidateResourcePlanResponse implements org.apache.thrift.TBase<WMValidateResourcePlanResponse,
WMValidateResourcePlanResponse._Fields>, java.io.Serializable, Cloneable, Comparable<WMValidateResourcePlanResponse>
{
   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WMValidateResourcePlanResponse");
 
-  private static final org.apache.thrift.protocol.TField IS_VALID_FIELD_DESC = new org.apache.thrift.protocol.TField("isValid",
org.apache.thrift.protocol.TType.BOOL, (short)1);
+  private static final org.apache.thrift.protocol.TField ERRORS_FIELD_DESC = new org.apache.thrift.protocol.TField("errors",
org.apache.thrift.protocol.TType.LIST, (short)1);
 
   private static final Map<Class<? extends IScheme>, SchemeFactory> schemes =
new HashMap<Class<? extends IScheme>, SchemeFactory>();
   static {
@@ -46,11 +46,11 @@ import org.slf4j.LoggerFactory;
     schemes.put(TupleScheme.class, new WMValidateResourcePlanResponseTupleSchemeFactory());
   }
 
-  private boolean isValid; // optional
+  private List<String> errors; // 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 {
-    IS_VALID((short)1, "isValid");
+    ERRORS((short)1, "errors");
 
     private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -65,8 +65,8 @@ import org.slf4j.LoggerFactory;
      */
     public static _Fields findByThriftId(int fieldId) {
       switch(fieldId) {
-        case 1: // IS_VALID
-          return IS_VALID;
+        case 1: // ERRORS
+          return ERRORS;
         default:
           return null;
       }
@@ -107,14 +107,13 @@ import org.slf4j.LoggerFactory;
   }
 
   // isset id assignments
-  private static final int __ISVALID_ISSET_ID = 0;
-  private byte __isset_bitfield = 0;
-  private static final _Fields optionals[] = {_Fields.IS_VALID};
+  private static final _Fields optionals[] = {_Fields.ERRORS};
   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.IS_VALID, new org.apache.thrift.meta_data.FieldMetaData("isValid",
org.apache.thrift.TFieldRequirementType.OPTIONAL, 
-        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
+    tmpMap.put(_Fields.ERRORS, new org.apache.thrift.meta_data.FieldMetaData("errors", org.apache.thrift.TFieldRequirementType.OPTIONAL,

+        new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,

+            new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
     metaDataMap = Collections.unmodifiableMap(tmpMap);
     org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(WMValidateResourcePlanResponse.class,
metaDataMap);
   }
@@ -126,8 +125,10 @@ import org.slf4j.LoggerFactory;
    * Performs a deep copy on <i>other</i>.
    */
   public WMValidateResourcePlanResponse(WMValidateResourcePlanResponse other) {
-    __isset_bitfield = other.__isset_bitfield;
-    this.isValid = other.isValid;
+    if (other.isSetErrors()) {
+      List<String> __this__errors = new ArrayList<String>(other.errors);
+      this.errors = __this__errors;
+    }
   }
 
   public WMValidateResourcePlanResponse deepCopy() {
@@ -136,39 +137,54 @@ import org.slf4j.LoggerFactory;
 
   @Override
   public void clear() {
-    setIsValidIsSet(false);
-    this.isValid = false;
+    this.errors = null;
+  }
+
+  public int getErrorsSize() {
+    return (this.errors == null) ? 0 : this.errors.size();
+  }
+
+  public java.util.Iterator<String> getErrorsIterator() {
+    return (this.errors == null) ? null : this.errors.iterator();
   }
 
-  public boolean isIsValid() {
-    return this.isValid;
+  public void addToErrors(String elem) {
+    if (this.errors == null) {
+      this.errors = new ArrayList<String>();
+    }
+    this.errors.add(elem);
   }
 
-  public void setIsValid(boolean isValid) {
-    this.isValid = isValid;
-    setIsValidIsSet(true);
+  public List<String> getErrors() {
+    return this.errors;
   }
 
-  public void unsetIsValid() {
-    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ISVALID_ISSET_ID);
+  public void setErrors(List<String> errors) {
+    this.errors = errors;
   }
 
-  /** Returns true if field isValid is set (has been assigned a value) and false otherwise
*/
-  public boolean isSetIsValid() {
-    return EncodingUtils.testBit(__isset_bitfield, __ISVALID_ISSET_ID);
+  public void unsetErrors() {
+    this.errors = null;
   }
 
-  public void setIsValidIsSet(boolean value) {
-    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ISVALID_ISSET_ID, value);
+  /** Returns true if field errors is set (has been assigned a value) and false otherwise
*/
+  public boolean isSetErrors() {
+    return this.errors != null;
+  }
+
+  public void setErrorsIsSet(boolean value) {
+    if (!value) {
+      this.errors = null;
+    }
   }
 
   public void setFieldValue(_Fields field, Object value) {
     switch (field) {
-    case IS_VALID:
+    case ERRORS:
       if (value == null) {
-        unsetIsValid();
+        unsetErrors();
       } else {
-        setIsValid((Boolean)value);
+        setErrors((List<String>)value);
       }
       break;
 
@@ -177,8 +193,8 @@ import org.slf4j.LoggerFactory;
 
   public Object getFieldValue(_Fields field) {
     switch (field) {
-    case IS_VALID:
-      return isIsValid();
+    case ERRORS:
+      return getErrors();
 
     }
     throw new IllegalStateException();
@@ -191,8 +207,8 @@ import org.slf4j.LoggerFactory;
     }
 
     switch (field) {
-    case IS_VALID:
-      return isSetIsValid();
+    case ERRORS:
+      return isSetErrors();
     }
     throw new IllegalStateException();
   }
@@ -210,12 +226,12 @@ import org.slf4j.LoggerFactory;
     if (that == null)
       return false;
 
-    boolean this_present_isValid = true && this.isSetIsValid();
-    boolean that_present_isValid = true && that.isSetIsValid();
-    if (this_present_isValid || that_present_isValid) {
-      if (!(this_present_isValid && that_present_isValid))
+    boolean this_present_errors = true && this.isSetErrors();
+    boolean that_present_errors = true && that.isSetErrors();
+    if (this_present_errors || that_present_errors) {
+      if (!(this_present_errors && that_present_errors))
         return false;
-      if (this.isValid != that.isValid)
+      if (!this.errors.equals(that.errors))
         return false;
     }
 
@@ -226,10 +242,10 @@ import org.slf4j.LoggerFactory;
   public int hashCode() {
     List<Object> list = new ArrayList<Object>();
 
-    boolean present_isValid = true && (isSetIsValid());
-    list.add(present_isValid);
-    if (present_isValid)
-      list.add(isValid);
+    boolean present_errors = true && (isSetErrors());
+    list.add(present_errors);
+    if (present_errors)
+      list.add(errors);
 
     return list.hashCode();
   }
@@ -242,12 +258,12 @@ import org.slf4j.LoggerFactory;
 
     int lastComparison = 0;
 
-    lastComparison = Boolean.valueOf(isSetIsValid()).compareTo(other.isSetIsValid());
+    lastComparison = Boolean.valueOf(isSetErrors()).compareTo(other.isSetErrors());
     if (lastComparison != 0) {
       return lastComparison;
     }
-    if (isSetIsValid()) {
-      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.isValid, other.isValid);
+    if (isSetErrors()) {
+      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.errors, other.errors);
       if (lastComparison != 0) {
         return lastComparison;
       }
@@ -272,9 +288,13 @@ import org.slf4j.LoggerFactory;
     StringBuilder sb = new StringBuilder("WMValidateResourcePlanResponse(");
     boolean first = true;
 
-    if (isSetIsValid()) {
-      sb.append("isValid:");
-      sb.append(this.isValid);
+    if (isSetErrors()) {
+      sb.append("errors:");
+      if (this.errors == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.errors);
+      }
       first = false;
     }
     sb.append(")");
@@ -296,8 +316,6 @@ import org.slf4j.LoggerFactory;
 
   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);
@@ -322,10 +340,20 @@ import org.slf4j.LoggerFactory;
           break;
         }
         switch (schemeField.id) {
-          case 1: // IS_VALID
-            if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
-              struct.isValid = iprot.readBool();
-              struct.setIsValidIsSet(true);
+          case 1: // ERRORS
+            if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+              {
+                org.apache.thrift.protocol.TList _list778 = iprot.readListBegin();
+                struct.errors = new ArrayList<String>(_list778.size);
+                String _elem779;
+                for (int _i780 = 0; _i780 < _list778.size; ++_i780)
+                {
+                  _elem779 = iprot.readString();
+                  struct.errors.add(_elem779);
+                }
+                iprot.readListEnd();
+              }
+              struct.setErrorsIsSet(true);
             } else { 
               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
             }
@@ -343,10 +371,19 @@ import org.slf4j.LoggerFactory;
       struct.validate();
 
       oprot.writeStructBegin(STRUCT_DESC);
-      if (struct.isSetIsValid()) {
-        oprot.writeFieldBegin(IS_VALID_FIELD_DESC);
-        oprot.writeBool(struct.isValid);
-        oprot.writeFieldEnd();
+      if (struct.errors != null) {
+        if (struct.isSetErrors()) {
+          oprot.writeFieldBegin(ERRORS_FIELD_DESC);
+          {
+            oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING,
struct.errors.size()));
+            for (String _iter781 : struct.errors)
+            {
+              oprot.writeString(_iter781);
+            }
+            oprot.writeListEnd();
+          }
+          oprot.writeFieldEnd();
+        }
       }
       oprot.writeFieldStop();
       oprot.writeStructEnd();
@@ -366,12 +403,18 @@ import org.slf4j.LoggerFactory;
     public void write(org.apache.thrift.protocol.TProtocol prot, WMValidateResourcePlanResponse
struct) throws org.apache.thrift.TException {
       TTupleProtocol oprot = (TTupleProtocol) prot;
       BitSet optionals = new BitSet();
-      if (struct.isSetIsValid()) {
+      if (struct.isSetErrors()) {
         optionals.set(0);
       }
       oprot.writeBitSet(optionals, 1);
-      if (struct.isSetIsValid()) {
-        oprot.writeBool(struct.isValid);
+      if (struct.isSetErrors()) {
+        {
+          oprot.writeI32(struct.errors.size());
+          for (String _iter782 : struct.errors)
+          {
+            oprot.writeString(_iter782);
+          }
+        }
       }
     }
 
@@ -380,8 +423,17 @@ import org.slf4j.LoggerFactory;
       TTupleProtocol iprot = (TTupleProtocol) prot;
       BitSet incoming = iprot.readBitSet(1);
       if (incoming.get(0)) {
-        struct.isValid = iprot.readBool();
-        struct.setIsValidIsSet(true);
+        {
+          org.apache.thrift.protocol.TList _list783 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING,
iprot.readI32());
+          struct.errors = new ArrayList<String>(_list783.size);
+          String _elem784;
+          for (int _i785 = 0; _i785 < _list783.size; ++_i785)
+          {
+            _elem784 = iprot.readString();
+            struct.errors.add(_elem784);
+          }
+        }
+        struct.setErrorsIsSet(true);
       }
     }
   }


Mime
View raw message