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 TGetOperationStatusResp implements org.apache.thrift.TBase<TGetOperationStatusResp, TGetOperationStatusResp._Fields>, java.io.Serializable, Cloneable, Comparable<TGetOperationStatusResp> {
0039   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TGetOperationStatusResp");
0040 
0041   private static final org.apache.thrift.protocol.TField STATUS_FIELD_DESC = new org.apache.thrift.protocol.TField("status", org.apache.thrift.protocol.TType.STRUCT, (short)1);
0042   private static final org.apache.thrift.protocol.TField OPERATION_STATE_FIELD_DESC = new org.apache.thrift.protocol.TField("operationState", org.apache.thrift.protocol.TType.I32, (short)2);
0043   private static final org.apache.thrift.protocol.TField SQL_STATE_FIELD_DESC = new org.apache.thrift.protocol.TField("sqlState", org.apache.thrift.protocol.TType.STRING, (short)3);
0044   private static final org.apache.thrift.protocol.TField ERROR_CODE_FIELD_DESC = new org.apache.thrift.protocol.TField("errorCode", org.apache.thrift.protocol.TType.I32, (short)4);
0045   private static final org.apache.thrift.protocol.TField ERROR_MESSAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("errorMessage", org.apache.thrift.protocol.TType.STRING, (short)5);
0046   private static final org.apache.thrift.protocol.TField TASK_STATUS_FIELD_DESC = new org.apache.thrift.protocol.TField("taskStatus", org.apache.thrift.protocol.TType.STRING, (short)6);
0047   private static final org.apache.thrift.protocol.TField OPERATION_STARTED_FIELD_DESC = new org.apache.thrift.protocol.TField("operationStarted", org.apache.thrift.protocol.TType.I64, (short)7);
0048   private static final org.apache.thrift.protocol.TField OPERATION_COMPLETED_FIELD_DESC = new org.apache.thrift.protocol.TField("operationCompleted", org.apache.thrift.protocol.TType.I64, (short)8);
0049   private static final org.apache.thrift.protocol.TField HAS_RESULT_SET_FIELD_DESC = new org.apache.thrift.protocol.TField("hasResultSet", org.apache.thrift.protocol.TType.BOOL, (short)9);
0050   private static final org.apache.thrift.protocol.TField PROGRESS_UPDATE_RESPONSE_FIELD_DESC = new org.apache.thrift.protocol.TField("progressUpdateResponse", org.apache.thrift.protocol.TType.STRUCT, (short)10);
0051 
0052   private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
0053   static {
0054     schemes.put(StandardScheme.class, new TGetOperationStatusRespStandardSchemeFactory());
0055     schemes.put(TupleScheme.class, new TGetOperationStatusRespTupleSchemeFactory());
0056   }
0057 
0058   private TStatus status; // required
0059   private TOperationState operationState; // optional
0060   private String sqlState; // optional
0061   private int errorCode; // optional
0062   private String errorMessage; // optional
0063   private String taskStatus; // optional
0064   private long operationStarted; // optional
0065   private long operationCompleted; // optional
0066   private boolean hasResultSet; // optional
0067   private TProgressUpdateResp progressUpdateResponse; // optional
0068 
0069   /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
0070   public enum _Fields implements org.apache.thrift.TFieldIdEnum {
0071     STATUS((short)1, "status"),
0072     /**
0073      * 
0074      * @see TOperationState
0075      */
0076     OPERATION_STATE((short)2, "operationState"),
0077     SQL_STATE((short)3, "sqlState"),
0078     ERROR_CODE((short)4, "errorCode"),
0079     ERROR_MESSAGE((short)5, "errorMessage"),
0080     TASK_STATUS((short)6, "taskStatus"),
0081     OPERATION_STARTED((short)7, "operationStarted"),
0082     OPERATION_COMPLETED((short)8, "operationCompleted"),
0083     HAS_RESULT_SET((short)9, "hasResultSet"),
0084     PROGRESS_UPDATE_RESPONSE((short)10, "progressUpdateResponse");
0085 
0086     private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
0087 
0088     static {
0089       for (_Fields field : EnumSet.allOf(_Fields.class)) {
0090         byName.put(field.getFieldName(), field);
0091       }
0092     }
0093 
0094     /**
0095      * Find the _Fields constant that matches fieldId, or null if its not found.
0096      */
0097     public static _Fields findByThriftId(int fieldId) {
0098       switch(fieldId) {
0099         case 1: // STATUS
0100           return STATUS;
0101         case 2: // OPERATION_STATE
0102           return OPERATION_STATE;
0103         case 3: // SQL_STATE
0104           return SQL_STATE;
0105         case 4: // ERROR_CODE
0106           return ERROR_CODE;
0107         case 5: // ERROR_MESSAGE
0108           return ERROR_MESSAGE;
0109         case 6: // TASK_STATUS
0110           return TASK_STATUS;
0111         case 7: // OPERATION_STARTED
0112           return OPERATION_STARTED;
0113         case 8: // OPERATION_COMPLETED
0114           return OPERATION_COMPLETED;
0115         case 9: // HAS_RESULT_SET
0116           return HAS_RESULT_SET;
0117         case 10: // PROGRESS_UPDATE_RESPONSE
0118           return PROGRESS_UPDATE_RESPONSE;
0119         default:
0120           return null;
0121       }
0122     }
0123 
0124     /**
0125      * Find the _Fields constant that matches fieldId, throwing an exception
0126      * if it is not found.
0127      */
0128     public static _Fields findByThriftIdOrThrow(int fieldId) {
0129       _Fields fields = findByThriftId(fieldId);
0130       if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
0131       return fields;
0132     }
0133 
0134     /**
0135      * Find the _Fields constant that matches name, or null if its not found.
0136      */
0137     public static _Fields findByName(String name) {
0138       return byName.get(name);
0139     }
0140 
0141     private final short _thriftId;
0142     private final String _fieldName;
0143 
0144     _Fields(short thriftId, String fieldName) {
0145       _thriftId = thriftId;
0146       _fieldName = fieldName;
0147     }
0148 
0149     public short getThriftFieldId() {
0150       return _thriftId;
0151     }
0152 
0153     public String getFieldName() {
0154       return _fieldName;
0155     }
0156   }
0157 
0158   // isset id assignments
0159   private static final int __ERRORCODE_ISSET_ID = 0;
0160   private static final int __OPERATIONSTARTED_ISSET_ID = 1;
0161   private static final int __OPERATIONCOMPLETED_ISSET_ID = 2;
0162   private static final int __HASRESULTSET_ISSET_ID = 3;
0163   private byte __isset_bitfield = 0;
0164   private static final _Fields optionals[] = {_Fields.OPERATION_STATE,_Fields.SQL_STATE,_Fields.ERROR_CODE,_Fields.ERROR_MESSAGE,_Fields.TASK_STATUS,_Fields.OPERATION_STARTED,_Fields.OPERATION_COMPLETED,_Fields.HAS_RESULT_SET,_Fields.PROGRESS_UPDATE_RESPONSE};
0165   public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
0166   static {
0167     Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
0168     tmpMap.put(_Fields.STATUS, new org.apache.thrift.meta_data.FieldMetaData("status", org.apache.thrift.TFieldRequirementType.REQUIRED, 
0169         new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TStatus.class)));
0170     tmpMap.put(_Fields.OPERATION_STATE, new org.apache.thrift.meta_data.FieldMetaData("operationState", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
0171         new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, TOperationState.class)));
0172     tmpMap.put(_Fields.SQL_STATE, new org.apache.thrift.meta_data.FieldMetaData("sqlState", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
0173         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
0174     tmpMap.put(_Fields.ERROR_CODE, new org.apache.thrift.meta_data.FieldMetaData("errorCode", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
0175         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
0176     tmpMap.put(_Fields.ERROR_MESSAGE, new org.apache.thrift.meta_data.FieldMetaData("errorMessage", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
0177         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
0178     tmpMap.put(_Fields.TASK_STATUS, new org.apache.thrift.meta_data.FieldMetaData("taskStatus", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
0179         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
0180     tmpMap.put(_Fields.OPERATION_STARTED, new org.apache.thrift.meta_data.FieldMetaData("operationStarted", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
0181         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
0182     tmpMap.put(_Fields.OPERATION_COMPLETED, new org.apache.thrift.meta_data.FieldMetaData("operationCompleted", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
0183         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
0184     tmpMap.put(_Fields.HAS_RESULT_SET, new org.apache.thrift.meta_data.FieldMetaData("hasResultSet", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
0185         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
0186     tmpMap.put(_Fields.PROGRESS_UPDATE_RESPONSE, new org.apache.thrift.meta_data.FieldMetaData("progressUpdateResponse", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
0187         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT        , "TProgressUpdateResp")));
0188     metaDataMap = Collections.unmodifiableMap(tmpMap);
0189     org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TGetOperationStatusResp.class, metaDataMap);
0190   }
0191 
0192   public TGetOperationStatusResp() {
0193   }
0194 
0195   public TGetOperationStatusResp(
0196     TStatus status)
0197   {
0198     this();
0199     this.status = status;
0200   }
0201 
0202   /**
0203    * Performs a deep copy on <i>other</i>.
0204    */
0205   public TGetOperationStatusResp(TGetOperationStatusResp other) {
0206     __isset_bitfield = other.__isset_bitfield;
0207     if (other.isSetStatus()) {
0208       this.status = new TStatus(other.status);
0209     }
0210     if (other.isSetOperationState()) {
0211       this.operationState = other.operationState;
0212     }
0213     if (other.isSetSqlState()) {
0214       this.sqlState = other.sqlState;
0215     }
0216     this.errorCode = other.errorCode;
0217     if (other.isSetErrorMessage()) {
0218       this.errorMessage = other.errorMessage;
0219     }
0220     if (other.isSetTaskStatus()) {
0221       this.taskStatus = other.taskStatus;
0222     }
0223     this.operationStarted = other.operationStarted;
0224     this.operationCompleted = other.operationCompleted;
0225     this.hasResultSet = other.hasResultSet;
0226     if (other.isSetProgressUpdateResponse()) {
0227       this.progressUpdateResponse = other.progressUpdateResponse;
0228     }
0229   }
0230 
0231   public TGetOperationStatusResp deepCopy() {
0232     return new TGetOperationStatusResp(this);
0233   }
0234 
0235   @Override
0236   public void clear() {
0237     this.status = null;
0238     this.operationState = null;
0239     this.sqlState = null;
0240     setErrorCodeIsSet(false);
0241     this.errorCode = 0;
0242     this.errorMessage = null;
0243     this.taskStatus = null;
0244     setOperationStartedIsSet(false);
0245     this.operationStarted = 0;
0246     setOperationCompletedIsSet(false);
0247     this.operationCompleted = 0;
0248     setHasResultSetIsSet(false);
0249     this.hasResultSet = false;
0250     this.progressUpdateResponse = null;
0251   }
0252 
0253   public TStatus getStatus() {
0254     return this.status;
0255   }
0256 
0257   public void setStatus(TStatus status) {
0258     this.status = status;
0259   }
0260 
0261   public void unsetStatus() {
0262     this.status = null;
0263   }
0264 
0265   /** Returns true if field status is set (has been assigned a value) and false otherwise */
0266   public boolean isSetStatus() {
0267     return this.status != null;
0268   }
0269 
0270   public void setStatusIsSet(boolean value) {
0271     if (!value) {
0272       this.status = null;
0273     }
0274   }
0275 
0276   /**
0277    * 
0278    * @see TOperationState
0279    */
0280   public TOperationState getOperationState() {
0281     return this.operationState;
0282   }
0283 
0284   /**
0285    * 
0286    * @see TOperationState
0287    */
0288   public void setOperationState(TOperationState operationState) {
0289     this.operationState = operationState;
0290   }
0291 
0292   public void unsetOperationState() {
0293     this.operationState = null;
0294   }
0295 
0296   /** Returns true if field operationState is set (has been assigned a value) and false otherwise */
0297   public boolean isSetOperationState() {
0298     return this.operationState != null;
0299   }
0300 
0301   public void setOperationStateIsSet(boolean value) {
0302     if (!value) {
0303       this.operationState = null;
0304     }
0305   }
0306 
0307   public String getSqlState() {
0308     return this.sqlState;
0309   }
0310 
0311   public void setSqlState(String sqlState) {
0312     this.sqlState = sqlState;
0313   }
0314 
0315   public void unsetSqlState() {
0316     this.sqlState = null;
0317   }
0318 
0319   /** Returns true if field sqlState is set (has been assigned a value) and false otherwise */
0320   public boolean isSetSqlState() {
0321     return this.sqlState != null;
0322   }
0323 
0324   public void setSqlStateIsSet(boolean value) {
0325     if (!value) {
0326       this.sqlState = null;
0327     }
0328   }
0329 
0330   public int getErrorCode() {
0331     return this.errorCode;
0332   }
0333 
0334   public void setErrorCode(int errorCode) {
0335     this.errorCode = errorCode;
0336     setErrorCodeIsSet(true);
0337   }
0338 
0339   public void unsetErrorCode() {
0340     __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ERRORCODE_ISSET_ID);
0341   }
0342 
0343   /** Returns true if field errorCode is set (has been assigned a value) and false otherwise */
0344   public boolean isSetErrorCode() {
0345     return EncodingUtils.testBit(__isset_bitfield, __ERRORCODE_ISSET_ID);
0346   }
0347 
0348   public void setErrorCodeIsSet(boolean value) {
0349     __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ERRORCODE_ISSET_ID, value);
0350   }
0351 
0352   public String getErrorMessage() {
0353     return this.errorMessage;
0354   }
0355 
0356   public void setErrorMessage(String errorMessage) {
0357     this.errorMessage = errorMessage;
0358   }
0359 
0360   public void unsetErrorMessage() {
0361     this.errorMessage = null;
0362   }
0363 
0364   /** Returns true if field errorMessage is set (has been assigned a value) and false otherwise */
0365   public boolean isSetErrorMessage() {
0366     return this.errorMessage != null;
0367   }
0368 
0369   public void setErrorMessageIsSet(boolean value) {
0370     if (!value) {
0371       this.errorMessage = null;
0372     }
0373   }
0374 
0375   public String getTaskStatus() {
0376     return this.taskStatus;
0377   }
0378 
0379   public void setTaskStatus(String taskStatus) {
0380     this.taskStatus = taskStatus;
0381   }
0382 
0383   public void unsetTaskStatus() {
0384     this.taskStatus = null;
0385   }
0386 
0387   /** Returns true if field taskStatus is set (has been assigned a value) and false otherwise */
0388   public boolean isSetTaskStatus() {
0389     return this.taskStatus != null;
0390   }
0391 
0392   public void setTaskStatusIsSet(boolean value) {
0393     if (!value) {
0394       this.taskStatus = null;
0395     }
0396   }
0397 
0398   public long getOperationStarted() {
0399     return this.operationStarted;
0400   }
0401 
0402   public void setOperationStarted(long operationStarted) {
0403     this.operationStarted = operationStarted;
0404     setOperationStartedIsSet(true);
0405   }
0406 
0407   public void unsetOperationStarted() {
0408     __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __OPERATIONSTARTED_ISSET_ID);
0409   }
0410 
0411   /** Returns true if field operationStarted is set (has been assigned a value) and false otherwise */
0412   public boolean isSetOperationStarted() {
0413     return EncodingUtils.testBit(__isset_bitfield, __OPERATIONSTARTED_ISSET_ID);
0414   }
0415 
0416   public void setOperationStartedIsSet(boolean value) {
0417     __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __OPERATIONSTARTED_ISSET_ID, value);
0418   }
0419 
0420   public long getOperationCompleted() {
0421     return this.operationCompleted;
0422   }
0423 
0424   public void setOperationCompleted(long operationCompleted) {
0425     this.operationCompleted = operationCompleted;
0426     setOperationCompletedIsSet(true);
0427   }
0428 
0429   public void unsetOperationCompleted() {
0430     __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __OPERATIONCOMPLETED_ISSET_ID);
0431   }
0432 
0433   /** Returns true if field operationCompleted is set (has been assigned a value) and false otherwise */
0434   public boolean isSetOperationCompleted() {
0435     return EncodingUtils.testBit(__isset_bitfield, __OPERATIONCOMPLETED_ISSET_ID);
0436   }
0437 
0438   public void setOperationCompletedIsSet(boolean value) {
0439     __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __OPERATIONCOMPLETED_ISSET_ID, value);
0440   }
0441 
0442   public boolean isHasResultSet() {
0443     return this.hasResultSet;
0444   }
0445 
0446   public void setHasResultSet(boolean hasResultSet) {
0447     this.hasResultSet = hasResultSet;
0448     setHasResultSetIsSet(true);
0449   }
0450 
0451   public void unsetHasResultSet() {
0452     __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __HASRESULTSET_ISSET_ID);
0453   }
0454 
0455   /** Returns true if field hasResultSet is set (has been assigned a value) and false otherwise */
0456   public boolean isSetHasResultSet() {
0457     return EncodingUtils.testBit(__isset_bitfield, __HASRESULTSET_ISSET_ID);
0458   }
0459 
0460   public void setHasResultSetIsSet(boolean value) {
0461     __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __HASRESULTSET_ISSET_ID, value);
0462   }
0463 
0464   public TProgressUpdateResp getProgressUpdateResponse() {
0465     return this.progressUpdateResponse;
0466   }
0467 
0468   public void setProgressUpdateResponse(TProgressUpdateResp progressUpdateResponse) {
0469     this.progressUpdateResponse = progressUpdateResponse;
0470   }
0471 
0472   public void unsetProgressUpdateResponse() {
0473     this.progressUpdateResponse = null;
0474   }
0475 
0476   /** Returns true if field progressUpdateResponse is set (has been assigned a value) and false otherwise */
0477   public boolean isSetProgressUpdateResponse() {
0478     return this.progressUpdateResponse != null;
0479   }
0480 
0481   public void setProgressUpdateResponseIsSet(boolean value) {
0482     if (!value) {
0483       this.progressUpdateResponse = null;
0484     }
0485   }
0486 
0487   public void setFieldValue(_Fields field, Object value) {
0488     switch (field) {
0489     case STATUS:
0490       if (value == null) {
0491         unsetStatus();
0492       } else {
0493         setStatus((TStatus)value);
0494       }
0495       break;
0496 
0497     case OPERATION_STATE:
0498       if (value == null) {
0499         unsetOperationState();
0500       } else {
0501         setOperationState((TOperationState)value);
0502       }
0503       break;
0504 
0505     case SQL_STATE:
0506       if (value == null) {
0507         unsetSqlState();
0508       } else {
0509         setSqlState((String)value);
0510       }
0511       break;
0512 
0513     case ERROR_CODE:
0514       if (value == null) {
0515         unsetErrorCode();
0516       } else {
0517         setErrorCode((Integer)value);
0518       }
0519       break;
0520 
0521     case ERROR_MESSAGE:
0522       if (value == null) {
0523         unsetErrorMessage();
0524       } else {
0525         setErrorMessage((String)value);
0526       }
0527       break;
0528 
0529     case TASK_STATUS:
0530       if (value == null) {
0531         unsetTaskStatus();
0532       } else {
0533         setTaskStatus((String)value);
0534       }
0535       break;
0536 
0537     case OPERATION_STARTED:
0538       if (value == null) {
0539         unsetOperationStarted();
0540       } else {
0541         setOperationStarted((Long)value);
0542       }
0543       break;
0544 
0545     case OPERATION_COMPLETED:
0546       if (value == null) {
0547         unsetOperationCompleted();
0548       } else {
0549         setOperationCompleted((Long)value);
0550       }
0551       break;
0552 
0553     case HAS_RESULT_SET:
0554       if (value == null) {
0555         unsetHasResultSet();
0556       } else {
0557         setHasResultSet((Boolean)value);
0558       }
0559       break;
0560 
0561     case PROGRESS_UPDATE_RESPONSE:
0562       if (value == null) {
0563         unsetProgressUpdateResponse();
0564       } else {
0565         setProgressUpdateResponse((TProgressUpdateResp)value);
0566       }
0567       break;
0568 
0569     }
0570   }
0571 
0572   public Object getFieldValue(_Fields field) {
0573     switch (field) {
0574     case STATUS:
0575       return getStatus();
0576 
0577     case OPERATION_STATE:
0578       return getOperationState();
0579 
0580     case SQL_STATE:
0581       return getSqlState();
0582 
0583     case ERROR_CODE:
0584       return getErrorCode();
0585 
0586     case ERROR_MESSAGE:
0587       return getErrorMessage();
0588 
0589     case TASK_STATUS:
0590       return getTaskStatus();
0591 
0592     case OPERATION_STARTED:
0593       return getOperationStarted();
0594 
0595     case OPERATION_COMPLETED:
0596       return getOperationCompleted();
0597 
0598     case HAS_RESULT_SET:
0599       return isHasResultSet();
0600 
0601     case PROGRESS_UPDATE_RESPONSE:
0602       return getProgressUpdateResponse();
0603 
0604     }
0605     throw new IllegalStateException();
0606   }
0607 
0608   /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
0609   public boolean isSet(_Fields field) {
0610     if (field == null) {
0611       throw new IllegalArgumentException();
0612     }
0613 
0614     switch (field) {
0615     case STATUS:
0616       return isSetStatus();
0617     case OPERATION_STATE:
0618       return isSetOperationState();
0619     case SQL_STATE:
0620       return isSetSqlState();
0621     case ERROR_CODE:
0622       return isSetErrorCode();
0623     case ERROR_MESSAGE:
0624       return isSetErrorMessage();
0625     case TASK_STATUS:
0626       return isSetTaskStatus();
0627     case OPERATION_STARTED:
0628       return isSetOperationStarted();
0629     case OPERATION_COMPLETED:
0630       return isSetOperationCompleted();
0631     case HAS_RESULT_SET:
0632       return isSetHasResultSet();
0633     case PROGRESS_UPDATE_RESPONSE:
0634       return isSetProgressUpdateResponse();
0635     }
0636     throw new IllegalStateException();
0637   }
0638 
0639   @Override
0640   public boolean equals(Object that) {
0641     if (that == null)
0642       return false;
0643     if (that instanceof TGetOperationStatusResp)
0644       return this.equals((TGetOperationStatusResp)that);
0645     return false;
0646   }
0647 
0648   public boolean equals(TGetOperationStatusResp that) {
0649     if (that == null)
0650       return false;
0651 
0652     boolean this_present_status = true && this.isSetStatus();
0653     boolean that_present_status = true && that.isSetStatus();
0654     if (this_present_status || that_present_status) {
0655       if (!(this_present_status && that_present_status))
0656         return false;
0657       if (!this.status.equals(that.status))
0658         return false;
0659     }
0660 
0661     boolean this_present_operationState = true && this.isSetOperationState();
0662     boolean that_present_operationState = true && that.isSetOperationState();
0663     if (this_present_operationState || that_present_operationState) {
0664       if (!(this_present_operationState && that_present_operationState))
0665         return false;
0666       if (!this.operationState.equals(that.operationState))
0667         return false;
0668     }
0669 
0670     boolean this_present_sqlState = true && this.isSetSqlState();
0671     boolean that_present_sqlState = true && that.isSetSqlState();
0672     if (this_present_sqlState || that_present_sqlState) {
0673       if (!(this_present_sqlState && that_present_sqlState))
0674         return false;
0675       if (!this.sqlState.equals(that.sqlState))
0676         return false;
0677     }
0678 
0679     boolean this_present_errorCode = true && this.isSetErrorCode();
0680     boolean that_present_errorCode = true && that.isSetErrorCode();
0681     if (this_present_errorCode || that_present_errorCode) {
0682       if (!(this_present_errorCode && that_present_errorCode))
0683         return false;
0684       if (this.errorCode != that.errorCode)
0685         return false;
0686     }
0687 
0688     boolean this_present_errorMessage = true && this.isSetErrorMessage();
0689     boolean that_present_errorMessage = true && that.isSetErrorMessage();
0690     if (this_present_errorMessage || that_present_errorMessage) {
0691       if (!(this_present_errorMessage && that_present_errorMessage))
0692         return false;
0693       if (!this.errorMessage.equals(that.errorMessage))
0694         return false;
0695     }
0696 
0697     boolean this_present_taskStatus = true && this.isSetTaskStatus();
0698     boolean that_present_taskStatus = true && that.isSetTaskStatus();
0699     if (this_present_taskStatus || that_present_taskStatus) {
0700       if (!(this_present_taskStatus && that_present_taskStatus))
0701         return false;
0702       if (!this.taskStatus.equals(that.taskStatus))
0703         return false;
0704     }
0705 
0706     boolean this_present_operationStarted = true && this.isSetOperationStarted();
0707     boolean that_present_operationStarted = true && that.isSetOperationStarted();
0708     if (this_present_operationStarted || that_present_operationStarted) {
0709       if (!(this_present_operationStarted && that_present_operationStarted))
0710         return false;
0711       if (this.operationStarted != that.operationStarted)
0712         return false;
0713     }
0714 
0715     boolean this_present_operationCompleted = true && this.isSetOperationCompleted();
0716     boolean that_present_operationCompleted = true && that.isSetOperationCompleted();
0717     if (this_present_operationCompleted || that_present_operationCompleted) {
0718       if (!(this_present_operationCompleted && that_present_operationCompleted))
0719         return false;
0720       if (this.operationCompleted != that.operationCompleted)
0721         return false;
0722     }
0723 
0724     boolean this_present_hasResultSet = true && this.isSetHasResultSet();
0725     boolean that_present_hasResultSet = true && that.isSetHasResultSet();
0726     if (this_present_hasResultSet || that_present_hasResultSet) {
0727       if (!(this_present_hasResultSet && that_present_hasResultSet))
0728         return false;
0729       if (this.hasResultSet != that.hasResultSet)
0730         return false;
0731     }
0732 
0733     boolean this_present_progressUpdateResponse = true && this.isSetProgressUpdateResponse();
0734     boolean that_present_progressUpdateResponse = true && that.isSetProgressUpdateResponse();
0735     if (this_present_progressUpdateResponse || that_present_progressUpdateResponse) {
0736       if (!(this_present_progressUpdateResponse && that_present_progressUpdateResponse))
0737         return false;
0738       if (!this.progressUpdateResponse.equals(that.progressUpdateResponse))
0739         return false;
0740     }
0741 
0742     return true;
0743   }
0744 
0745   @Override
0746   public int hashCode() {
0747     List<Object> list = new ArrayList<Object>();
0748 
0749     boolean present_status = true && (isSetStatus());
0750     list.add(present_status);
0751     if (present_status)
0752       list.add(status);
0753 
0754     boolean present_operationState = true && (isSetOperationState());
0755     list.add(present_operationState);
0756     if (present_operationState)
0757       list.add(operationState.getValue());
0758 
0759     boolean present_sqlState = true && (isSetSqlState());
0760     list.add(present_sqlState);
0761     if (present_sqlState)
0762       list.add(sqlState);
0763 
0764     boolean present_errorCode = true && (isSetErrorCode());
0765     list.add(present_errorCode);
0766     if (present_errorCode)
0767       list.add(errorCode);
0768 
0769     boolean present_errorMessage = true && (isSetErrorMessage());
0770     list.add(present_errorMessage);
0771     if (present_errorMessage)
0772       list.add(errorMessage);
0773 
0774     boolean present_taskStatus = true && (isSetTaskStatus());
0775     list.add(present_taskStatus);
0776     if (present_taskStatus)
0777       list.add(taskStatus);
0778 
0779     boolean present_operationStarted = true && (isSetOperationStarted());
0780     list.add(present_operationStarted);
0781     if (present_operationStarted)
0782       list.add(operationStarted);
0783 
0784     boolean present_operationCompleted = true && (isSetOperationCompleted());
0785     list.add(present_operationCompleted);
0786     if (present_operationCompleted)
0787       list.add(operationCompleted);
0788 
0789     boolean present_hasResultSet = true && (isSetHasResultSet());
0790     list.add(present_hasResultSet);
0791     if (present_hasResultSet)
0792       list.add(hasResultSet);
0793 
0794     boolean present_progressUpdateResponse = true && (isSetProgressUpdateResponse());
0795     list.add(present_progressUpdateResponse);
0796     if (present_progressUpdateResponse)
0797       list.add(progressUpdateResponse);
0798 
0799     return list.hashCode();
0800   }
0801 
0802   @Override
0803   public int compareTo(TGetOperationStatusResp other) {
0804     if (!getClass().equals(other.getClass())) {
0805       return getClass().getName().compareTo(other.getClass().getName());
0806     }
0807 
0808     int lastComparison = 0;
0809 
0810     lastComparison = Boolean.valueOf(isSetStatus()).compareTo(other.isSetStatus());
0811     if (lastComparison != 0) {
0812       return lastComparison;
0813     }
0814     if (isSetStatus()) {
0815       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.status, other.status);
0816       if (lastComparison != 0) {
0817         return lastComparison;
0818       }
0819     }
0820     lastComparison = Boolean.valueOf(isSetOperationState()).compareTo(other.isSetOperationState());
0821     if (lastComparison != 0) {
0822       return lastComparison;
0823     }
0824     if (isSetOperationState()) {
0825       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.operationState, other.operationState);
0826       if (lastComparison != 0) {
0827         return lastComparison;
0828       }
0829     }
0830     lastComparison = Boolean.valueOf(isSetSqlState()).compareTo(other.isSetSqlState());
0831     if (lastComparison != 0) {
0832       return lastComparison;
0833     }
0834     if (isSetSqlState()) {
0835       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sqlState, other.sqlState);
0836       if (lastComparison != 0) {
0837         return lastComparison;
0838       }
0839     }
0840     lastComparison = Boolean.valueOf(isSetErrorCode()).compareTo(other.isSetErrorCode());
0841     if (lastComparison != 0) {
0842       return lastComparison;
0843     }
0844     if (isSetErrorCode()) {
0845       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.errorCode, other.errorCode);
0846       if (lastComparison != 0) {
0847         return lastComparison;
0848       }
0849     }
0850     lastComparison = Boolean.valueOf(isSetErrorMessage()).compareTo(other.isSetErrorMessage());
0851     if (lastComparison != 0) {
0852       return lastComparison;
0853     }
0854     if (isSetErrorMessage()) {
0855       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.errorMessage, other.errorMessage);
0856       if (lastComparison != 0) {
0857         return lastComparison;
0858       }
0859     }
0860     lastComparison = Boolean.valueOf(isSetTaskStatus()).compareTo(other.isSetTaskStatus());
0861     if (lastComparison != 0) {
0862       return lastComparison;
0863     }
0864     if (isSetTaskStatus()) {
0865       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.taskStatus, other.taskStatus);
0866       if (lastComparison != 0) {
0867         return lastComparison;
0868       }
0869     }
0870     lastComparison = Boolean.valueOf(isSetOperationStarted()).compareTo(other.isSetOperationStarted());
0871     if (lastComparison != 0) {
0872       return lastComparison;
0873     }
0874     if (isSetOperationStarted()) {
0875       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.operationStarted, other.operationStarted);
0876       if (lastComparison != 0) {
0877         return lastComparison;
0878       }
0879     }
0880     lastComparison = Boolean.valueOf(isSetOperationCompleted()).compareTo(other.isSetOperationCompleted());
0881     if (lastComparison != 0) {
0882       return lastComparison;
0883     }
0884     if (isSetOperationCompleted()) {
0885       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.operationCompleted, other.operationCompleted);
0886       if (lastComparison != 0) {
0887         return lastComparison;
0888       }
0889     }
0890     lastComparison = Boolean.valueOf(isSetHasResultSet()).compareTo(other.isSetHasResultSet());
0891     if (lastComparison != 0) {
0892       return lastComparison;
0893     }
0894     if (isSetHasResultSet()) {
0895       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.hasResultSet, other.hasResultSet);
0896       if (lastComparison != 0) {
0897         return lastComparison;
0898       }
0899     }
0900     lastComparison = Boolean.valueOf(isSetProgressUpdateResponse()).compareTo(other.isSetProgressUpdateResponse());
0901     if (lastComparison != 0) {
0902       return lastComparison;
0903     }
0904     if (isSetProgressUpdateResponse()) {
0905       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.progressUpdateResponse, other.progressUpdateResponse);
0906       if (lastComparison != 0) {
0907         return lastComparison;
0908       }
0909     }
0910     return 0;
0911   }
0912 
0913   public _Fields fieldForId(int fieldId) {
0914     return _Fields.findByThriftId(fieldId);
0915   }
0916 
0917   public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
0918     schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
0919   }
0920 
0921   public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
0922     schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
0923   }
0924 
0925   @Override
0926   public String toString() {
0927     StringBuilder sb = new StringBuilder("TGetOperationStatusResp(");
0928     boolean first = true;
0929 
0930     sb.append("status:");
0931     if (this.status == null) {
0932       sb.append("null");
0933     } else {
0934       sb.append(this.status);
0935     }
0936     first = false;
0937     if (isSetOperationState()) {
0938       if (!first) sb.append(", ");
0939       sb.append("operationState:");
0940       if (this.operationState == null) {
0941         sb.append("null");
0942       } else {
0943         sb.append(this.operationState);
0944       }
0945       first = false;
0946     }
0947     if (isSetSqlState()) {
0948       if (!first) sb.append(", ");
0949       sb.append("sqlState:");
0950       if (this.sqlState == null) {
0951         sb.append("null");
0952       } else {
0953         sb.append(this.sqlState);
0954       }
0955       first = false;
0956     }
0957     if (isSetErrorCode()) {
0958       if (!first) sb.append(", ");
0959       sb.append("errorCode:");
0960       sb.append(this.errorCode);
0961       first = false;
0962     }
0963     if (isSetErrorMessage()) {
0964       if (!first) sb.append(", ");
0965       sb.append("errorMessage:");
0966       if (this.errorMessage == null) {
0967         sb.append("null");
0968       } else {
0969         sb.append(this.errorMessage);
0970       }
0971       first = false;
0972     }
0973     if (isSetTaskStatus()) {
0974       if (!first) sb.append(", ");
0975       sb.append("taskStatus:");
0976       if (this.taskStatus == null) {
0977         sb.append("null");
0978       } else {
0979         sb.append(this.taskStatus);
0980       }
0981       first = false;
0982     }
0983     if (isSetOperationStarted()) {
0984       if (!first) sb.append(", ");
0985       sb.append("operationStarted:");
0986       sb.append(this.operationStarted);
0987       first = false;
0988     }
0989     if (isSetOperationCompleted()) {
0990       if (!first) sb.append(", ");
0991       sb.append("operationCompleted:");
0992       sb.append(this.operationCompleted);
0993       first = false;
0994     }
0995     if (isSetHasResultSet()) {
0996       if (!first) sb.append(", ");
0997       sb.append("hasResultSet:");
0998       sb.append(this.hasResultSet);
0999       first = false;
1000     }
1001     if (isSetProgressUpdateResponse()) {
1002       if (!first) sb.append(", ");
1003       sb.append("progressUpdateResponse:");
1004       if (this.progressUpdateResponse == null) {
1005         sb.append("null");
1006       } else {
1007         sb.append(this.progressUpdateResponse);
1008       }
1009       first = false;
1010     }
1011     sb.append(")");
1012     return sb.toString();
1013   }
1014 
1015   public void validate() throws org.apache.thrift.TException {
1016     // check for required fields
1017     if (!isSetStatus()) {
1018       throw new org.apache.thrift.protocol.TProtocolException("Required field 'status' is unset! Struct:" + toString());
1019     }
1020 
1021     // check for sub-struct validity
1022     if (status != null) {
1023       status.validate();
1024     }
1025   }
1026 
1027   private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
1028     try {
1029       write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
1030     } catch (org.apache.thrift.TException te) {
1031       throw new java.io.IOException(te);
1032     }
1033   }
1034 
1035   private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
1036     try {
1037       // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
1038       __isset_bitfield = 0;
1039       read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
1040     } catch (org.apache.thrift.TException te) {
1041       throw new java.io.IOException(te);
1042     }
1043   }
1044 
1045   private static class TGetOperationStatusRespStandardSchemeFactory implements SchemeFactory {
1046     public TGetOperationStatusRespStandardScheme getScheme() {
1047       return new TGetOperationStatusRespStandardScheme();
1048     }
1049   }
1050 
1051   private static class TGetOperationStatusRespStandardScheme extends StandardScheme<TGetOperationStatusResp> {
1052 
1053     public void read(org.apache.thrift.protocol.TProtocol iprot, TGetOperationStatusResp struct) throws org.apache.thrift.TException {
1054       org.apache.thrift.protocol.TField schemeField;
1055       iprot.readStructBegin();
1056       while (true)
1057       {
1058         schemeField = iprot.readFieldBegin();
1059         if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
1060           break;
1061         }
1062         switch (schemeField.id) {
1063           case 1: // STATUS
1064             if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
1065               struct.status = new TStatus();
1066               struct.status.read(iprot);
1067               struct.setStatusIsSet(true);
1068             } else { 
1069               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1070             }
1071             break;
1072           case 2: // OPERATION_STATE
1073             if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
1074               struct.operationState = org.apache.hive.service.rpc.thrift.TOperationState.findByValue(iprot.readI32());
1075               struct.setOperationStateIsSet(true);
1076             } else { 
1077               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1078             }
1079             break;
1080           case 3: // SQL_STATE
1081             if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
1082               struct.sqlState = iprot.readString();
1083               struct.setSqlStateIsSet(true);
1084             } else { 
1085               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1086             }
1087             break;
1088           case 4: // ERROR_CODE
1089             if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
1090               struct.errorCode = iprot.readI32();
1091               struct.setErrorCodeIsSet(true);
1092             } else { 
1093               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1094             }
1095             break;
1096           case 5: // ERROR_MESSAGE
1097             if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
1098               struct.errorMessage = iprot.readString();
1099               struct.setErrorMessageIsSet(true);
1100             } else { 
1101               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1102             }
1103             break;
1104           case 6: // TASK_STATUS
1105             if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
1106               struct.taskStatus = iprot.readString();
1107               struct.setTaskStatusIsSet(true);
1108             } else { 
1109               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1110             }
1111             break;
1112           case 7: // OPERATION_STARTED
1113             if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
1114               struct.operationStarted = iprot.readI64();
1115               struct.setOperationStartedIsSet(true);
1116             } else { 
1117               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1118             }
1119             break;
1120           case 8: // OPERATION_COMPLETED
1121             if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
1122               struct.operationCompleted = iprot.readI64();
1123               struct.setOperationCompletedIsSet(true);
1124             } else { 
1125               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1126             }
1127             break;
1128           case 9: // HAS_RESULT_SET
1129             if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
1130               struct.hasResultSet = iprot.readBool();
1131               struct.setHasResultSetIsSet(true);
1132             } else { 
1133               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1134             }
1135             break;
1136           case 10: // PROGRESS_UPDATE_RESPONSE
1137             if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
1138               struct.progressUpdateResponse = new TProgressUpdateResp();
1139               struct.progressUpdateResponse.read(iprot);
1140               struct.setProgressUpdateResponseIsSet(true);
1141             } else { 
1142               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1143             }
1144             break;
1145           default:
1146             org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
1147         }
1148         iprot.readFieldEnd();
1149       }
1150       iprot.readStructEnd();
1151       struct.validate();
1152     }
1153 
1154     public void write(org.apache.thrift.protocol.TProtocol oprot, TGetOperationStatusResp struct) throws org.apache.thrift.TException {
1155       struct.validate();
1156 
1157       oprot.writeStructBegin(STRUCT_DESC);
1158       if (struct.status != null) {
1159         oprot.writeFieldBegin(STATUS_FIELD_DESC);
1160         struct.status.write(oprot);
1161         oprot.writeFieldEnd();
1162       }
1163       if (struct.operationState != null) {
1164         if (struct.isSetOperationState()) {
1165           oprot.writeFieldBegin(OPERATION_STATE_FIELD_DESC);
1166           oprot.writeI32(struct.operationState.getValue());
1167           oprot.writeFieldEnd();
1168         }
1169       }
1170       if (struct.sqlState != null) {
1171         if (struct.isSetSqlState()) {
1172           oprot.writeFieldBegin(SQL_STATE_FIELD_DESC);
1173           oprot.writeString(struct.sqlState);
1174           oprot.writeFieldEnd();
1175         }
1176       }
1177       if (struct.isSetErrorCode()) {
1178         oprot.writeFieldBegin(ERROR_CODE_FIELD_DESC);
1179         oprot.writeI32(struct.errorCode);
1180         oprot.writeFieldEnd();
1181       }
1182       if (struct.errorMessage != null) {
1183         if (struct.isSetErrorMessage()) {
1184           oprot.writeFieldBegin(ERROR_MESSAGE_FIELD_DESC);
1185           oprot.writeString(struct.errorMessage);
1186           oprot.writeFieldEnd();
1187         }
1188       }
1189       if (struct.taskStatus != null) {
1190         if (struct.isSetTaskStatus()) {
1191           oprot.writeFieldBegin(TASK_STATUS_FIELD_DESC);
1192           oprot.writeString(struct.taskStatus);
1193           oprot.writeFieldEnd();
1194         }
1195       }
1196       if (struct.isSetOperationStarted()) {
1197         oprot.writeFieldBegin(OPERATION_STARTED_FIELD_DESC);
1198         oprot.writeI64(struct.operationStarted);
1199         oprot.writeFieldEnd();
1200       }
1201       if (struct.isSetOperationCompleted()) {
1202         oprot.writeFieldBegin(OPERATION_COMPLETED_FIELD_DESC);
1203         oprot.writeI64(struct.operationCompleted);
1204         oprot.writeFieldEnd();
1205       }
1206       if (struct.isSetHasResultSet()) {
1207         oprot.writeFieldBegin(HAS_RESULT_SET_FIELD_DESC);
1208         oprot.writeBool(struct.hasResultSet);
1209         oprot.writeFieldEnd();
1210       }
1211       if (struct.progressUpdateResponse != null) {
1212         if (struct.isSetProgressUpdateResponse()) {
1213           oprot.writeFieldBegin(PROGRESS_UPDATE_RESPONSE_FIELD_DESC);
1214           struct.progressUpdateResponse.write(oprot);
1215           oprot.writeFieldEnd();
1216         }
1217       }
1218       oprot.writeFieldStop();
1219       oprot.writeStructEnd();
1220     }
1221 
1222   }
1223 
1224   private static class TGetOperationStatusRespTupleSchemeFactory implements SchemeFactory {
1225     public TGetOperationStatusRespTupleScheme getScheme() {
1226       return new TGetOperationStatusRespTupleScheme();
1227     }
1228   }
1229 
1230   private static class TGetOperationStatusRespTupleScheme extends TupleScheme<TGetOperationStatusResp> {
1231 
1232     @Override
1233     public void write(org.apache.thrift.protocol.TProtocol prot, TGetOperationStatusResp struct) throws org.apache.thrift.TException {
1234       TTupleProtocol oprot = (TTupleProtocol) prot;
1235       struct.status.write(oprot);
1236       BitSet optionals = new BitSet();
1237       if (struct.isSetOperationState()) {
1238         optionals.set(0);
1239       }
1240       if (struct.isSetSqlState()) {
1241         optionals.set(1);
1242       }
1243       if (struct.isSetErrorCode()) {
1244         optionals.set(2);
1245       }
1246       if (struct.isSetErrorMessage()) {
1247         optionals.set(3);
1248       }
1249       if (struct.isSetTaskStatus()) {
1250         optionals.set(4);
1251       }
1252       if (struct.isSetOperationStarted()) {
1253         optionals.set(5);
1254       }
1255       if (struct.isSetOperationCompleted()) {
1256         optionals.set(6);
1257       }
1258       if (struct.isSetHasResultSet()) {
1259         optionals.set(7);
1260       }
1261       if (struct.isSetProgressUpdateResponse()) {
1262         optionals.set(8);
1263       }
1264       oprot.writeBitSet(optionals, 9);
1265       if (struct.isSetOperationState()) {
1266         oprot.writeI32(struct.operationState.getValue());
1267       }
1268       if (struct.isSetSqlState()) {
1269         oprot.writeString(struct.sqlState);
1270       }
1271       if (struct.isSetErrorCode()) {
1272         oprot.writeI32(struct.errorCode);
1273       }
1274       if (struct.isSetErrorMessage()) {
1275         oprot.writeString(struct.errorMessage);
1276       }
1277       if (struct.isSetTaskStatus()) {
1278         oprot.writeString(struct.taskStatus);
1279       }
1280       if (struct.isSetOperationStarted()) {
1281         oprot.writeI64(struct.operationStarted);
1282       }
1283       if (struct.isSetOperationCompleted()) {
1284         oprot.writeI64(struct.operationCompleted);
1285       }
1286       if (struct.isSetHasResultSet()) {
1287         oprot.writeBool(struct.hasResultSet);
1288       }
1289       if (struct.isSetProgressUpdateResponse()) {
1290         struct.progressUpdateResponse.write(oprot);
1291       }
1292     }
1293 
1294     @Override
1295     public void read(org.apache.thrift.protocol.TProtocol prot, TGetOperationStatusResp struct) throws org.apache.thrift.TException {
1296       TTupleProtocol iprot = (TTupleProtocol) prot;
1297       struct.status = new TStatus();
1298       struct.status.read(iprot);
1299       struct.setStatusIsSet(true);
1300       BitSet incoming = iprot.readBitSet(9);
1301       if (incoming.get(0)) {
1302         struct.operationState = org.apache.hive.service.rpc.thrift.TOperationState.findByValue(iprot.readI32());
1303         struct.setOperationStateIsSet(true);
1304       }
1305       if (incoming.get(1)) {
1306         struct.sqlState = iprot.readString();
1307         struct.setSqlStateIsSet(true);
1308       }
1309       if (incoming.get(2)) {
1310         struct.errorCode = iprot.readI32();
1311         struct.setErrorCodeIsSet(true);
1312       }
1313       if (incoming.get(3)) {
1314         struct.errorMessage = iprot.readString();
1315         struct.setErrorMessageIsSet(true);
1316       }
1317       if (incoming.get(4)) {
1318         struct.taskStatus = iprot.readString();
1319         struct.setTaskStatusIsSet(true);
1320       }
1321       if (incoming.get(5)) {
1322         struct.operationStarted = iprot.readI64();
1323         struct.setOperationStartedIsSet(true);
1324       }
1325       if (incoming.get(6)) {
1326         struct.operationCompleted = iprot.readI64();
1327         struct.setOperationCompletedIsSet(true);
1328       }
1329       if (incoming.get(7)) {
1330         struct.hasResultSet = iprot.readBool();
1331         struct.setHasResultSetIsSet(true);
1332       }
1333       if (incoming.get(8)) {
1334         struct.progressUpdateResponse = new TProgressUpdateResp();
1335         struct.progressUpdateResponse.read(iprot);
1336         struct.setProgressUpdateResponseIsSet(true);
1337       }
1338     }
1339   }
1340 
1341 }
1342
[ 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!