Back to home page

OSCL-LXR
 
 

     

0001 /**
0002  * Autogenerated by Thrift Compiler (0.9.3)
0003  *
0004  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
0005  *  @generated
0006  */
0007 package org.apache.hive.service.rpc.thrift;
0008 
0009 import org.apache.thrift.scheme.IScheme;
0010 import org.apache.thrift.scheme.SchemeFactory;
0011 import org.apache.thrift.scheme.StandardScheme;
0012 
0013 import org.apache.thrift.scheme.TupleScheme;
0014 import org.apache.thrift.protocol.TTupleProtocol;
0015 import org.apache.thrift.protocol.TProtocolException;
0016 import org.apache.thrift.EncodingUtils;
0017 import org.apache.thrift.TException;
0018 import org.apache.thrift.async.AsyncMethodCallback;
0019 import org.apache.thrift.server.AbstractNonblockingServer.*;
0020 import java.util.List;
0021 import java.util.ArrayList;
0022 import java.util.Map;
0023 import java.util.HashMap;
0024 import java.util.EnumMap;
0025 import java.util.Set;
0026 import java.util.HashSet;
0027 import java.util.EnumSet;
0028 import java.util.Collections;
0029 import java.util.BitSet;
0030 import java.nio.ByteBuffer;
0031 import java.util.Arrays;
0032 import javax.annotation.Generated;
0033 import org.slf4j.Logger;
0034 import org.slf4j.LoggerFactory;
0035 
0036 @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
0037 @Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
0038 public class TProgressUpdateResp implements org.apache.thrift.TBase<TProgressUpdateResp, TProgressUpdateResp._Fields>, java.io.Serializable, Cloneable, Comparable<TProgressUpdateResp> {
0039   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TProgressUpdateResp");
0040 
0041   private static final org.apache.thrift.protocol.TField HEADER_NAMES_FIELD_DESC = new org.apache.thrift.protocol.TField("headerNames", org.apache.thrift.protocol.TType.LIST, (short)1);
0042   private static final org.apache.thrift.protocol.TField ROWS_FIELD_DESC = new org.apache.thrift.protocol.TField("rows", org.apache.thrift.protocol.TType.LIST, (short)2);
0043   private static final org.apache.thrift.protocol.TField PROGRESSED_PERCENTAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("progressedPercentage", org.apache.thrift.protocol.TType.DOUBLE, (short)3);
0044   private static final org.apache.thrift.protocol.TField STATUS_FIELD_DESC = new org.apache.thrift.protocol.TField("status", org.apache.thrift.protocol.TType.I32, (short)4);
0045   private static final org.apache.thrift.protocol.TField FOOTER_SUMMARY_FIELD_DESC = new org.apache.thrift.protocol.TField("footerSummary", org.apache.thrift.protocol.TType.STRING, (short)5);
0046   private static final org.apache.thrift.protocol.TField START_TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("startTime", org.apache.thrift.protocol.TType.I64, (short)6);
0047 
0048   private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
0049   static {
0050     schemes.put(StandardScheme.class, new TProgressUpdateRespStandardSchemeFactory());
0051     schemes.put(TupleScheme.class, new TProgressUpdateRespTupleSchemeFactory());
0052   }
0053 
0054   private List<String> headerNames; // required
0055   private List<List<String>> rows; // required
0056   private double progressedPercentage; // required
0057   private TJobExecutionStatus status; // required
0058   private String footerSummary; // required
0059   private long startTime; // required
0060 
0061   /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
0062   public enum _Fields implements org.apache.thrift.TFieldIdEnum {
0063     HEADER_NAMES((short)1, "headerNames"),
0064     ROWS((short)2, "rows"),
0065     PROGRESSED_PERCENTAGE((short)3, "progressedPercentage"),
0066     /**
0067      * 
0068      * @see TJobExecutionStatus
0069      */
0070     STATUS((short)4, "status"),
0071     FOOTER_SUMMARY((short)5, "footerSummary"),
0072     START_TIME((short)6, "startTime");
0073 
0074     private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
0075 
0076     static {
0077       for (_Fields field : EnumSet.allOf(_Fields.class)) {
0078         byName.put(field.getFieldName(), field);
0079       }
0080     }
0081 
0082     /**
0083      * Find the _Fields constant that matches fieldId, or null if its not found.
0084      */
0085     public static _Fields findByThriftId(int fieldId) {
0086       switch(fieldId) {
0087         case 1: // HEADER_NAMES
0088           return HEADER_NAMES;
0089         case 2: // ROWS
0090           return ROWS;
0091         case 3: // PROGRESSED_PERCENTAGE
0092           return PROGRESSED_PERCENTAGE;
0093         case 4: // STATUS
0094           return STATUS;
0095         case 5: // FOOTER_SUMMARY
0096           return FOOTER_SUMMARY;
0097         case 6: // START_TIME
0098           return START_TIME;
0099         default:
0100           return null;
0101       }
0102     }
0103 
0104     /**
0105      * Find the _Fields constant that matches fieldId, throwing an exception
0106      * if it is not found.
0107      */
0108     public static _Fields findByThriftIdOrThrow(int fieldId) {
0109       _Fields fields = findByThriftId(fieldId);
0110       if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
0111       return fields;
0112     }
0113 
0114     /**
0115      * Find the _Fields constant that matches name, or null if its not found.
0116      */
0117     public static _Fields findByName(String name) {
0118       return byName.get(name);
0119     }
0120 
0121     private final short _thriftId;
0122     private final String _fieldName;
0123 
0124     _Fields(short thriftId, String fieldName) {
0125       _thriftId = thriftId;
0126       _fieldName = fieldName;
0127     }
0128 
0129     public short getThriftFieldId() {
0130       return _thriftId;
0131     }
0132 
0133     public String getFieldName() {
0134       return _fieldName;
0135     }
0136   }
0137 
0138   // isset id assignments
0139   private static final int __PROGRESSEDPERCENTAGE_ISSET_ID = 0;
0140   private static final int __STARTTIME_ISSET_ID = 1;
0141   private byte __isset_bitfield = 0;
0142   public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
0143   static {
0144     Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
0145     tmpMap.put(_Fields.HEADER_NAMES, new org.apache.thrift.meta_data.FieldMetaData("headerNames", org.apache.thrift.TFieldRequirementType.REQUIRED, 
0146         new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, 
0147             new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
0148     tmpMap.put(_Fields.ROWS, new org.apache.thrift.meta_data.FieldMetaData("rows", org.apache.thrift.TFieldRequirementType.REQUIRED, 
0149         new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, 
0150             new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, 
0151                 new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))));
0152     tmpMap.put(_Fields.PROGRESSED_PERCENTAGE, new org.apache.thrift.meta_data.FieldMetaData("progressedPercentage", org.apache.thrift.TFieldRequirementType.REQUIRED, 
0153         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)));
0154     tmpMap.put(_Fields.STATUS, new org.apache.thrift.meta_data.FieldMetaData("status", org.apache.thrift.TFieldRequirementType.REQUIRED, 
0155         new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, TJobExecutionStatus.class)));
0156     tmpMap.put(_Fields.FOOTER_SUMMARY, new org.apache.thrift.meta_data.FieldMetaData("footerSummary", org.apache.thrift.TFieldRequirementType.REQUIRED, 
0157         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
0158     tmpMap.put(_Fields.START_TIME, new org.apache.thrift.meta_data.FieldMetaData("startTime", org.apache.thrift.TFieldRequirementType.REQUIRED, 
0159         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
0160     metaDataMap = Collections.unmodifiableMap(tmpMap);
0161     org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TProgressUpdateResp.class, metaDataMap);
0162   }
0163 
0164   public TProgressUpdateResp() {
0165   }
0166 
0167   public TProgressUpdateResp(
0168     List<String> headerNames,
0169     List<List<String>> rows,
0170     double progressedPercentage,
0171     TJobExecutionStatus status,
0172     String footerSummary,
0173     long startTime)
0174   {
0175     this();
0176     this.headerNames = headerNames;
0177     this.rows = rows;
0178     this.progressedPercentage = progressedPercentage;
0179     setProgressedPercentageIsSet(true);
0180     this.status = status;
0181     this.footerSummary = footerSummary;
0182     this.startTime = startTime;
0183     setStartTimeIsSet(true);
0184   }
0185 
0186   /**
0187    * Performs a deep copy on <i>other</i>.
0188    */
0189   public TProgressUpdateResp(TProgressUpdateResp other) {
0190     __isset_bitfield = other.__isset_bitfield;
0191     if (other.isSetHeaderNames()) {
0192       List<String> __this__headerNames = new ArrayList<String>(other.headerNames);
0193       this.headerNames = __this__headerNames;
0194     }
0195     if (other.isSetRows()) {
0196       List<List<String>> __this__rows = new ArrayList<List<String>>(other.rows.size());
0197       for (List<String> other_element : other.rows) {
0198         List<String> __this__rows_copy = new ArrayList<String>(other_element);
0199         __this__rows.add(__this__rows_copy);
0200       }
0201       this.rows = __this__rows;
0202     }
0203     this.progressedPercentage = other.progressedPercentage;
0204     if (other.isSetStatus()) {
0205       this.status = other.status;
0206     }
0207     if (other.isSetFooterSummary()) {
0208       this.footerSummary = other.footerSummary;
0209     }
0210     this.startTime = other.startTime;
0211   }
0212 
0213   public TProgressUpdateResp deepCopy() {
0214     return new TProgressUpdateResp(this);
0215   }
0216 
0217   @Override
0218   public void clear() {
0219     this.headerNames = null;
0220     this.rows = null;
0221     setProgressedPercentageIsSet(false);
0222     this.progressedPercentage = 0.0;
0223     this.status = null;
0224     this.footerSummary = null;
0225     setStartTimeIsSet(false);
0226     this.startTime = 0;
0227   }
0228 
0229   public int getHeaderNamesSize() {
0230     return (this.headerNames == null) ? 0 : this.headerNames.size();
0231   }
0232 
0233   public java.util.Iterator<String> getHeaderNamesIterator() {
0234     return (this.headerNames == null) ? null : this.headerNames.iterator();
0235   }
0236 
0237   public void addToHeaderNames(String elem) {
0238     if (this.headerNames == null) {
0239       this.headerNames = new ArrayList<String>();
0240     }
0241     this.headerNames.add(elem);
0242   }
0243 
0244   public List<String> getHeaderNames() {
0245     return this.headerNames;
0246   }
0247 
0248   public void setHeaderNames(List<String> headerNames) {
0249     this.headerNames = headerNames;
0250   }
0251 
0252   public void unsetHeaderNames() {
0253     this.headerNames = null;
0254   }
0255 
0256   /** Returns true if field headerNames is set (has been assigned a value) and false otherwise */
0257   public boolean isSetHeaderNames() {
0258     return this.headerNames != null;
0259   }
0260 
0261   public void setHeaderNamesIsSet(boolean value) {
0262     if (!value) {
0263       this.headerNames = null;
0264     }
0265   }
0266 
0267   public int getRowsSize() {
0268     return (this.rows == null) ? 0 : this.rows.size();
0269   }
0270 
0271   public java.util.Iterator<List<String>> getRowsIterator() {
0272     return (this.rows == null) ? null : this.rows.iterator();
0273   }
0274 
0275   public void addToRows(List<String> elem) {
0276     if (this.rows == null) {
0277       this.rows = new ArrayList<List<String>>();
0278     }
0279     this.rows.add(elem);
0280   }
0281 
0282   public List<List<String>> getRows() {
0283     return this.rows;
0284   }
0285 
0286   public void setRows(List<List<String>> rows) {
0287     this.rows = rows;
0288   }
0289 
0290   public void unsetRows() {
0291     this.rows = null;
0292   }
0293 
0294   /** Returns true if field rows is set (has been assigned a value) and false otherwise */
0295   public boolean isSetRows() {
0296     return this.rows != null;
0297   }
0298 
0299   public void setRowsIsSet(boolean value) {
0300     if (!value) {
0301       this.rows = null;
0302     }
0303   }
0304 
0305   public double getProgressedPercentage() {
0306     return this.progressedPercentage;
0307   }
0308 
0309   public void setProgressedPercentage(double progressedPercentage) {
0310     this.progressedPercentage = progressedPercentage;
0311     setProgressedPercentageIsSet(true);
0312   }
0313 
0314   public void unsetProgressedPercentage() {
0315     __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __PROGRESSEDPERCENTAGE_ISSET_ID);
0316   }
0317 
0318   /** Returns true if field progressedPercentage is set (has been assigned a value) and false otherwise */
0319   public boolean isSetProgressedPercentage() {
0320     return EncodingUtils.testBit(__isset_bitfield, __PROGRESSEDPERCENTAGE_ISSET_ID);
0321   }
0322 
0323   public void setProgressedPercentageIsSet(boolean value) {
0324     __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __PROGRESSEDPERCENTAGE_ISSET_ID, value);
0325   }
0326 
0327   /**
0328    * 
0329    * @see TJobExecutionStatus
0330    */
0331   public TJobExecutionStatus getStatus() {
0332     return this.status;
0333   }
0334 
0335   /**
0336    * 
0337    * @see TJobExecutionStatus
0338    */
0339   public void setStatus(TJobExecutionStatus status) {
0340     this.status = status;
0341   }
0342 
0343   public void unsetStatus() {
0344     this.status = null;
0345   }
0346 
0347   /** Returns true if field status is set (has been assigned a value) and false otherwise */
0348   public boolean isSetStatus() {
0349     return this.status != null;
0350   }
0351 
0352   public void setStatusIsSet(boolean value) {
0353     if (!value) {
0354       this.status = null;
0355     }
0356   }
0357 
0358   public String getFooterSummary() {
0359     return this.footerSummary;
0360   }
0361 
0362   public void setFooterSummary(String footerSummary) {
0363     this.footerSummary = footerSummary;
0364   }
0365 
0366   public void unsetFooterSummary() {
0367     this.footerSummary = null;
0368   }
0369 
0370   /** Returns true if field footerSummary is set (has been assigned a value) and false otherwise */
0371   public boolean isSetFooterSummary() {
0372     return this.footerSummary != null;
0373   }
0374 
0375   public void setFooterSummaryIsSet(boolean value) {
0376     if (!value) {
0377       this.footerSummary = null;
0378     }
0379   }
0380 
0381   public long getStartTime() {
0382     return this.startTime;
0383   }
0384 
0385   public void setStartTime(long startTime) {
0386     this.startTime = startTime;
0387     setStartTimeIsSet(true);
0388   }
0389 
0390   public void unsetStartTime() {
0391     __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __STARTTIME_ISSET_ID);
0392   }
0393 
0394   /** Returns true if field startTime is set (has been assigned a value) and false otherwise */
0395   public boolean isSetStartTime() {
0396     return EncodingUtils.testBit(__isset_bitfield, __STARTTIME_ISSET_ID);
0397   }
0398 
0399   public void setStartTimeIsSet(boolean value) {
0400     __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __STARTTIME_ISSET_ID, value);
0401   }
0402 
0403   public void setFieldValue(_Fields field, Object value) {
0404     switch (field) {
0405     case HEADER_NAMES:
0406       if (value == null) {
0407         unsetHeaderNames();
0408       } else {
0409         setHeaderNames((List<String>)value);
0410       }
0411       break;
0412 
0413     case ROWS:
0414       if (value == null) {
0415         unsetRows();
0416       } else {
0417         setRows((List<List<String>>)value);
0418       }
0419       break;
0420 
0421     case PROGRESSED_PERCENTAGE:
0422       if (value == null) {
0423         unsetProgressedPercentage();
0424       } else {
0425         setProgressedPercentage((Double)value);
0426       }
0427       break;
0428 
0429     case STATUS:
0430       if (value == null) {
0431         unsetStatus();
0432       } else {
0433         setStatus((TJobExecutionStatus)value);
0434       }
0435       break;
0436 
0437     case FOOTER_SUMMARY:
0438       if (value == null) {
0439         unsetFooterSummary();
0440       } else {
0441         setFooterSummary((String)value);
0442       }
0443       break;
0444 
0445     case START_TIME:
0446       if (value == null) {
0447         unsetStartTime();
0448       } else {
0449         setStartTime((Long)value);
0450       }
0451       break;
0452 
0453     }
0454   }
0455 
0456   public Object getFieldValue(_Fields field) {
0457     switch (field) {
0458     case HEADER_NAMES:
0459       return getHeaderNames();
0460 
0461     case ROWS:
0462       return getRows();
0463 
0464     case PROGRESSED_PERCENTAGE:
0465       return getProgressedPercentage();
0466 
0467     case STATUS:
0468       return getStatus();
0469 
0470     case FOOTER_SUMMARY:
0471       return getFooterSummary();
0472 
0473     case START_TIME:
0474       return getStartTime();
0475 
0476     }
0477     throw new IllegalStateException();
0478   }
0479 
0480   /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
0481   public boolean isSet(_Fields field) {
0482     if (field == null) {
0483       throw new IllegalArgumentException();
0484     }
0485 
0486     switch (field) {
0487     case HEADER_NAMES:
0488       return isSetHeaderNames();
0489     case ROWS:
0490       return isSetRows();
0491     case PROGRESSED_PERCENTAGE:
0492       return isSetProgressedPercentage();
0493     case STATUS:
0494       return isSetStatus();
0495     case FOOTER_SUMMARY:
0496       return isSetFooterSummary();
0497     case START_TIME:
0498       return isSetStartTime();
0499     }
0500     throw new IllegalStateException();
0501   }
0502 
0503   @Override
0504   public boolean equals(Object that) {
0505     if (that == null)
0506       return false;
0507     if (that instanceof TProgressUpdateResp)
0508       return this.equals((TProgressUpdateResp)that);
0509     return false;
0510   }
0511 
0512   public boolean equals(TProgressUpdateResp that) {
0513     if (that == null)
0514       return false;
0515 
0516     boolean this_present_headerNames = true && this.isSetHeaderNames();
0517     boolean that_present_headerNames = true && that.isSetHeaderNames();
0518     if (this_present_headerNames || that_present_headerNames) {
0519       if (!(this_present_headerNames && that_present_headerNames))
0520         return false;
0521       if (!this.headerNames.equals(that.headerNames))
0522         return false;
0523     }
0524 
0525     boolean this_present_rows = true && this.isSetRows();
0526     boolean that_present_rows = true && that.isSetRows();
0527     if (this_present_rows || that_present_rows) {
0528       if (!(this_present_rows && that_present_rows))
0529         return false;
0530       if (!this.rows.equals(that.rows))
0531         return false;
0532     }
0533 
0534     boolean this_present_progressedPercentage = true;
0535     boolean that_present_progressedPercentage = true;
0536     if (this_present_progressedPercentage || that_present_progressedPercentage) {
0537       if (!(this_present_progressedPercentage && that_present_progressedPercentage))
0538         return false;
0539       if (this.progressedPercentage != that.progressedPercentage)
0540         return false;
0541     }
0542 
0543     boolean this_present_status = true && this.isSetStatus();
0544     boolean that_present_status = true && that.isSetStatus();
0545     if (this_present_status || that_present_status) {
0546       if (!(this_present_status && that_present_status))
0547         return false;
0548       if (!this.status.equals(that.status))
0549         return false;
0550     }
0551 
0552     boolean this_present_footerSummary = true && this.isSetFooterSummary();
0553     boolean that_present_footerSummary = true && that.isSetFooterSummary();
0554     if (this_present_footerSummary || that_present_footerSummary) {
0555       if (!(this_present_footerSummary && that_present_footerSummary))
0556         return false;
0557       if (!this.footerSummary.equals(that.footerSummary))
0558         return false;
0559     }
0560 
0561     boolean this_present_startTime = true;
0562     boolean that_present_startTime = true;
0563     if (this_present_startTime || that_present_startTime) {
0564       if (!(this_present_startTime && that_present_startTime))
0565         return false;
0566       if (this.startTime != that.startTime)
0567         return false;
0568     }
0569 
0570     return true;
0571   }
0572 
0573   @Override
0574   public int hashCode() {
0575     List<Object> list = new ArrayList<Object>();
0576 
0577     boolean present_headerNames = true && (isSetHeaderNames());
0578     list.add(present_headerNames);
0579     if (present_headerNames)
0580       list.add(headerNames);
0581 
0582     boolean present_rows = true && (isSetRows());
0583     list.add(present_rows);
0584     if (present_rows)
0585       list.add(rows);
0586 
0587     boolean present_progressedPercentage = true;
0588     list.add(present_progressedPercentage);
0589     if (present_progressedPercentage)
0590       list.add(progressedPercentage);
0591 
0592     boolean present_status = true && (isSetStatus());
0593     list.add(present_status);
0594     if (present_status)
0595       list.add(status.getValue());
0596 
0597     boolean present_footerSummary = true && (isSetFooterSummary());
0598     list.add(present_footerSummary);
0599     if (present_footerSummary)
0600       list.add(footerSummary);
0601 
0602     boolean present_startTime = true;
0603     list.add(present_startTime);
0604     if (present_startTime)
0605       list.add(startTime);
0606 
0607     return list.hashCode();
0608   }
0609 
0610   @Override
0611   public int compareTo(TProgressUpdateResp other) {
0612     if (!getClass().equals(other.getClass())) {
0613       return getClass().getName().compareTo(other.getClass().getName());
0614     }
0615 
0616     int lastComparison = 0;
0617 
0618     lastComparison = Boolean.valueOf(isSetHeaderNames()).compareTo(other.isSetHeaderNames());
0619     if (lastComparison != 0) {
0620       return lastComparison;
0621     }
0622     if (isSetHeaderNames()) {
0623       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.headerNames, other.headerNames);
0624       if (lastComparison != 0) {
0625         return lastComparison;
0626       }
0627     }
0628     lastComparison = Boolean.valueOf(isSetRows()).compareTo(other.isSetRows());
0629     if (lastComparison != 0) {
0630       return lastComparison;
0631     }
0632     if (isSetRows()) {
0633       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.rows, other.rows);
0634       if (lastComparison != 0) {
0635         return lastComparison;
0636       }
0637     }
0638     lastComparison = Boolean.valueOf(isSetProgressedPercentage()).compareTo(other.isSetProgressedPercentage());
0639     if (lastComparison != 0) {
0640       return lastComparison;
0641     }
0642     if (isSetProgressedPercentage()) {
0643       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.progressedPercentage, other.progressedPercentage);
0644       if (lastComparison != 0) {
0645         return lastComparison;
0646       }
0647     }
0648     lastComparison = Boolean.valueOf(isSetStatus()).compareTo(other.isSetStatus());
0649     if (lastComparison != 0) {
0650       return lastComparison;
0651     }
0652     if (isSetStatus()) {
0653       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.status, other.status);
0654       if (lastComparison != 0) {
0655         return lastComparison;
0656       }
0657     }
0658     lastComparison = Boolean.valueOf(isSetFooterSummary()).compareTo(other.isSetFooterSummary());
0659     if (lastComparison != 0) {
0660       return lastComparison;
0661     }
0662     if (isSetFooterSummary()) {
0663       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.footerSummary, other.footerSummary);
0664       if (lastComparison != 0) {
0665         return lastComparison;
0666       }
0667     }
0668     lastComparison = Boolean.valueOf(isSetStartTime()).compareTo(other.isSetStartTime());
0669     if (lastComparison != 0) {
0670       return lastComparison;
0671     }
0672     if (isSetStartTime()) {
0673       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.startTime, other.startTime);
0674       if (lastComparison != 0) {
0675         return lastComparison;
0676       }
0677     }
0678     return 0;
0679   }
0680 
0681   public _Fields fieldForId(int fieldId) {
0682     return _Fields.findByThriftId(fieldId);
0683   }
0684 
0685   public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
0686     schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
0687   }
0688 
0689   public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
0690     schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
0691   }
0692 
0693   @Override
0694   public String toString() {
0695     StringBuilder sb = new StringBuilder("TProgressUpdateResp(");
0696     boolean first = true;
0697 
0698     sb.append("headerNames:");
0699     if (this.headerNames == null) {
0700       sb.append("null");
0701     } else {
0702       sb.append(this.headerNames);
0703     }
0704     first = false;
0705     if (!first) sb.append(", ");
0706     sb.append("rows:");
0707     if (this.rows == null) {
0708       sb.append("null");
0709     } else {
0710       sb.append(this.rows);
0711     }
0712     first = false;
0713     if (!first) sb.append(", ");
0714     sb.append("progressedPercentage:");
0715     sb.append(this.progressedPercentage);
0716     first = false;
0717     if (!first) sb.append(", ");
0718     sb.append("status:");
0719     if (this.status == null) {
0720       sb.append("null");
0721     } else {
0722       sb.append(this.status);
0723     }
0724     first = false;
0725     if (!first) sb.append(", ");
0726     sb.append("footerSummary:");
0727     if (this.footerSummary == null) {
0728       sb.append("null");
0729     } else {
0730       sb.append(this.footerSummary);
0731     }
0732     first = false;
0733     if (!first) sb.append(", ");
0734     sb.append("startTime:");
0735     sb.append(this.startTime);
0736     first = false;
0737     sb.append(")");
0738     return sb.toString();
0739   }
0740 
0741   public void validate() throws org.apache.thrift.TException {
0742     // check for required fields
0743     if (!isSetHeaderNames()) {
0744       throw new org.apache.thrift.protocol.TProtocolException("Required field 'headerNames' is unset! Struct:" + toString());
0745     }
0746 
0747     if (!isSetRows()) {
0748       throw new org.apache.thrift.protocol.TProtocolException("Required field 'rows' is unset! Struct:" + toString());
0749     }
0750 
0751     if (!isSetProgressedPercentage()) {
0752       throw new org.apache.thrift.protocol.TProtocolException("Required field 'progressedPercentage' is unset! Struct:" + toString());
0753     }
0754 
0755     if (!isSetStatus()) {
0756       throw new org.apache.thrift.protocol.TProtocolException("Required field 'status' is unset! Struct:" + toString());
0757     }
0758 
0759     if (!isSetFooterSummary()) {
0760       throw new org.apache.thrift.protocol.TProtocolException("Required field 'footerSummary' is unset! Struct:" + toString());
0761     }
0762 
0763     if (!isSetStartTime()) {
0764       throw new org.apache.thrift.protocol.TProtocolException("Required field 'startTime' is unset! Struct:" + toString());
0765     }
0766 
0767     // check for sub-struct validity
0768   }
0769 
0770   private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
0771     try {
0772       write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
0773     } catch (org.apache.thrift.TException te) {
0774       throw new java.io.IOException(te);
0775     }
0776   }
0777 
0778   private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
0779     try {
0780       // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
0781       __isset_bitfield = 0;
0782       read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
0783     } catch (org.apache.thrift.TException te) {
0784       throw new java.io.IOException(te);
0785     }
0786   }
0787 
0788   private static class TProgressUpdateRespStandardSchemeFactory implements SchemeFactory {
0789     public TProgressUpdateRespStandardScheme getScheme() {
0790       return new TProgressUpdateRespStandardScheme();
0791     }
0792   }
0793 
0794   private static class TProgressUpdateRespStandardScheme extends StandardScheme<TProgressUpdateResp> {
0795 
0796     public void read(org.apache.thrift.protocol.TProtocol iprot, TProgressUpdateResp struct) throws org.apache.thrift.TException {
0797       org.apache.thrift.protocol.TField schemeField;
0798       iprot.readStructBegin();
0799       while (true)
0800       {
0801         schemeField = iprot.readFieldBegin();
0802         if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
0803           break;
0804         }
0805         switch (schemeField.id) {
0806           case 1: // HEADER_NAMES
0807             if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
0808               {
0809                 org.apache.thrift.protocol.TList _list180 = iprot.readListBegin();
0810                 struct.headerNames = new ArrayList<String>(_list180.size);
0811                 String _elem181;
0812                 for (int _i182 = 0; _i182 < _list180.size; ++_i182)
0813                 {
0814                   _elem181 = iprot.readString();
0815                   struct.headerNames.add(_elem181);
0816                 }
0817                 iprot.readListEnd();
0818               }
0819               struct.setHeaderNamesIsSet(true);
0820             } else { 
0821               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
0822             }
0823             break;
0824           case 2: // ROWS
0825             if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
0826               {
0827                 org.apache.thrift.protocol.TList _list183 = iprot.readListBegin();
0828                 struct.rows = new ArrayList<List<String>>(_list183.size);
0829                 List<String> _elem184;
0830                 for (int _i185 = 0; _i185 < _list183.size; ++_i185)
0831                 {
0832                   {
0833                     org.apache.thrift.protocol.TList _list186 = iprot.readListBegin();
0834                     _elem184 = new ArrayList<String>(_list186.size);
0835                     String _elem187;
0836                     for (int _i188 = 0; _i188 < _list186.size; ++_i188)
0837                     {
0838                       _elem187 = iprot.readString();
0839                       _elem184.add(_elem187);
0840                     }
0841                     iprot.readListEnd();
0842                   }
0843                   struct.rows.add(_elem184);
0844                 }
0845                 iprot.readListEnd();
0846               }
0847               struct.setRowsIsSet(true);
0848             } else { 
0849               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
0850             }
0851             break;
0852           case 3: // PROGRESSED_PERCENTAGE
0853             if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
0854               struct.progressedPercentage = iprot.readDouble();
0855               struct.setProgressedPercentageIsSet(true);
0856             } else { 
0857               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
0858             }
0859             break;
0860           case 4: // STATUS
0861             if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
0862               struct.status = org.apache.hive.service.rpc.thrift.TJobExecutionStatus.findByValue(iprot.readI32());
0863               struct.setStatusIsSet(true);
0864             } else { 
0865               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
0866             }
0867             break;
0868           case 5: // FOOTER_SUMMARY
0869             if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
0870               struct.footerSummary = iprot.readString();
0871               struct.setFooterSummaryIsSet(true);
0872             } else { 
0873               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
0874             }
0875             break;
0876           case 6: // START_TIME
0877             if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
0878               struct.startTime = iprot.readI64();
0879               struct.setStartTimeIsSet(true);
0880             } else { 
0881               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
0882             }
0883             break;
0884           default:
0885             org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
0886         }
0887         iprot.readFieldEnd();
0888       }
0889       iprot.readStructEnd();
0890       struct.validate();
0891     }
0892 
0893     public void write(org.apache.thrift.protocol.TProtocol oprot, TProgressUpdateResp struct) throws org.apache.thrift.TException {
0894       struct.validate();
0895 
0896       oprot.writeStructBegin(STRUCT_DESC);
0897       if (struct.headerNames != null) {
0898         oprot.writeFieldBegin(HEADER_NAMES_FIELD_DESC);
0899         {
0900           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.headerNames.size()));
0901           for (String _iter189 : struct.headerNames)
0902           {
0903             oprot.writeString(_iter189);
0904           }
0905           oprot.writeListEnd();
0906         }
0907         oprot.writeFieldEnd();
0908       }
0909       if (struct.rows != null) {
0910         oprot.writeFieldBegin(ROWS_FIELD_DESC);
0911         {
0912           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.LIST, struct.rows.size()));
0913           for (List<String> _iter190 : struct.rows)
0914           {
0915             {
0916               oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, _iter190.size()));
0917               for (String _iter191 : _iter190)
0918               {
0919                 oprot.writeString(_iter191);
0920               }
0921               oprot.writeListEnd();
0922             }
0923           }
0924           oprot.writeListEnd();
0925         }
0926         oprot.writeFieldEnd();
0927       }
0928       oprot.writeFieldBegin(PROGRESSED_PERCENTAGE_FIELD_DESC);
0929       oprot.writeDouble(struct.progressedPercentage);
0930       oprot.writeFieldEnd();
0931       if (struct.status != null) {
0932         oprot.writeFieldBegin(STATUS_FIELD_DESC);
0933         oprot.writeI32(struct.status.getValue());
0934         oprot.writeFieldEnd();
0935       }
0936       if (struct.footerSummary != null) {
0937         oprot.writeFieldBegin(FOOTER_SUMMARY_FIELD_DESC);
0938         oprot.writeString(struct.footerSummary);
0939         oprot.writeFieldEnd();
0940       }
0941       oprot.writeFieldBegin(START_TIME_FIELD_DESC);
0942       oprot.writeI64(struct.startTime);
0943       oprot.writeFieldEnd();
0944       oprot.writeFieldStop();
0945       oprot.writeStructEnd();
0946     }
0947 
0948   }
0949 
0950   private static class TProgressUpdateRespTupleSchemeFactory implements SchemeFactory {
0951     public TProgressUpdateRespTupleScheme getScheme() {
0952       return new TProgressUpdateRespTupleScheme();
0953     }
0954   }
0955 
0956   private static class TProgressUpdateRespTupleScheme extends TupleScheme<TProgressUpdateResp> {
0957 
0958     @Override
0959     public void write(org.apache.thrift.protocol.TProtocol prot, TProgressUpdateResp struct) throws org.apache.thrift.TException {
0960       TTupleProtocol oprot = (TTupleProtocol) prot;
0961       {
0962         oprot.writeI32(struct.headerNames.size());
0963         for (String _iter192 : struct.headerNames)
0964         {
0965           oprot.writeString(_iter192);
0966         }
0967       }
0968       {
0969         oprot.writeI32(struct.rows.size());
0970         for (List<String> _iter193 : struct.rows)
0971         {
0972           {
0973             oprot.writeI32(_iter193.size());
0974             for (String _iter194 : _iter193)
0975             {
0976               oprot.writeString(_iter194);
0977             }
0978           }
0979         }
0980       }
0981       oprot.writeDouble(struct.progressedPercentage);
0982       oprot.writeI32(struct.status.getValue());
0983       oprot.writeString(struct.footerSummary);
0984       oprot.writeI64(struct.startTime);
0985     }
0986 
0987     @Override
0988     public void read(org.apache.thrift.protocol.TProtocol prot, TProgressUpdateResp struct) throws org.apache.thrift.TException {
0989       TTupleProtocol iprot = (TTupleProtocol) prot;
0990       {
0991         org.apache.thrift.protocol.TList _list195 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
0992         struct.headerNames = new ArrayList<String>(_list195.size);
0993         String _elem196;
0994         for (int _i197 = 0; _i197 < _list195.size; ++_i197)
0995         {
0996           _elem196 = iprot.readString();
0997           struct.headerNames.add(_elem196);
0998         }
0999       }
1000       struct.setHeaderNamesIsSet(true);
1001       {
1002         org.apache.thrift.protocol.TList _list198 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.LIST, iprot.readI32());
1003         struct.rows = new ArrayList<List<String>>(_list198.size);
1004         List<String> _elem199;
1005         for (int _i200 = 0; _i200 < _list198.size; ++_i200)
1006         {
1007           {
1008             org.apache.thrift.protocol.TList _list201 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
1009             _elem199 = new ArrayList<String>(_list201.size);
1010             String _elem202;
1011             for (int _i203 = 0; _i203 < _list201.size; ++_i203)
1012             {
1013               _elem202 = iprot.readString();
1014               _elem199.add(_elem202);
1015             }
1016           }
1017           struct.rows.add(_elem199);
1018         }
1019       }
1020       struct.setRowsIsSet(true);
1021       struct.progressedPercentage = iprot.readDouble();
1022       struct.setProgressedPercentageIsSet(true);
1023       struct.status = org.apache.hive.service.rpc.thrift.TJobExecutionStatus.findByValue(iprot.readI32());
1024       struct.setStatusIsSet(true);
1025       struct.footerSummary = iprot.readString();
1026       struct.setFooterSummaryIsSet(true);
1027       struct.startTime = iprot.readI64();
1028       struct.setStartTimeIsSet(true);
1029     }
1030   }
1031 
1032 }
1033
[ Source navigation ] [ Diff markup ] [ Identifier search ] [ general search ]

This page was automatically generated by the 2.1.0 LXR engine.

The LXR team
Valid CSS 2.1! Valid HTML 4.01!