Back to home page

OSCL-LXR
 
 

     

0001 /**
0002  * Autogenerated by Thrift Compiler (0.9.0)
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.cli.thrift;
0008 
0009 import org.apache.commons.lang.builder.HashCodeBuilder;
0010 import org.apache.thrift.scheme.IScheme;
0011 import org.apache.thrift.scheme.SchemeFactory;
0012 import org.apache.thrift.scheme.StandardScheme;
0013 
0014 import org.apache.thrift.scheme.TupleScheme;
0015 import org.apache.thrift.protocol.TTupleProtocol;
0016 import org.apache.thrift.protocol.TProtocolException;
0017 import org.apache.thrift.EncodingUtils;
0018 import org.apache.thrift.TException;
0019 import java.util.List;
0020 import java.util.ArrayList;
0021 import java.util.Map;
0022 import java.util.HashMap;
0023 import java.util.EnumMap;
0024 import java.util.Set;
0025 import java.util.HashSet;
0026 import java.util.EnumSet;
0027 import java.util.Collections;
0028 import java.util.BitSet;
0029 import java.nio.ByteBuffer;
0030 import java.util.Arrays;
0031 import org.slf4j.Logger;
0032 import org.slf4j.LoggerFactory;
0033 
0034 public class TFetchResultsResp implements org.apache.thrift.TBase<TFetchResultsResp, TFetchResultsResp._Fields>, java.io.Serializable, Cloneable {
0035   private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TFetchResultsResp");
0036 
0037   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);
0038   private static final org.apache.thrift.protocol.TField HAS_MORE_ROWS_FIELD_DESC = new org.apache.thrift.protocol.TField("hasMoreRows", org.apache.thrift.protocol.TType.BOOL, (short)2);
0039   private static final org.apache.thrift.protocol.TField RESULTS_FIELD_DESC = new org.apache.thrift.protocol.TField("results", org.apache.thrift.protocol.TType.STRUCT, (short)3);
0040 
0041   private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
0042   static {
0043     schemes.put(StandardScheme.class, new TFetchResultsRespStandardSchemeFactory());
0044     schemes.put(TupleScheme.class, new TFetchResultsRespTupleSchemeFactory());
0045   }
0046 
0047   private TStatus status; // required
0048   private boolean hasMoreRows; // optional
0049   private TRowSet results; // optional
0050 
0051   /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
0052   public enum _Fields implements org.apache.thrift.TFieldIdEnum {
0053     STATUS((short)1, "status"),
0054     HAS_MORE_ROWS((short)2, "hasMoreRows"),
0055     RESULTS((short)3, "results");
0056 
0057     private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
0058 
0059     static {
0060       for (_Fields field : EnumSet.allOf(_Fields.class)) {
0061         byName.put(field.getFieldName(), field);
0062       }
0063     }
0064 
0065     /**
0066      * Find the _Fields constant that matches fieldId, or null if its not found.
0067      */
0068     public static _Fields findByThriftId(int fieldId) {
0069       switch(fieldId) {
0070         case 1: // STATUS
0071           return STATUS;
0072         case 2: // HAS_MORE_ROWS
0073           return HAS_MORE_ROWS;
0074         case 3: // RESULTS
0075           return RESULTS;
0076         default:
0077           return null;
0078       }
0079     }
0080 
0081     /**
0082      * Find the _Fields constant that matches fieldId, throwing an exception
0083      * if it is not found.
0084      */
0085     public static _Fields findByThriftIdOrThrow(int fieldId) {
0086       _Fields fields = findByThriftId(fieldId);
0087       if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
0088       return fields;
0089     }
0090 
0091     /**
0092      * Find the _Fields constant that matches name, or null if its not found.
0093      */
0094     public static _Fields findByName(String name) {
0095       return byName.get(name);
0096     }
0097 
0098     private final short _thriftId;
0099     private final String _fieldName;
0100 
0101     _Fields(short thriftId, String fieldName) {
0102       _thriftId = thriftId;
0103       _fieldName = fieldName;
0104     }
0105 
0106     public short getThriftFieldId() {
0107       return _thriftId;
0108     }
0109 
0110     public String getFieldName() {
0111       return _fieldName;
0112     }
0113   }
0114 
0115   // isset id assignments
0116   private static final int __HASMOREROWS_ISSET_ID = 0;
0117   private byte __isset_bitfield = 0;
0118   private _Fields optionals[] = {_Fields.HAS_MORE_ROWS,_Fields.RESULTS};
0119   public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
0120   static {
0121     Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
0122     tmpMap.put(_Fields.STATUS, new org.apache.thrift.meta_data.FieldMetaData("status", org.apache.thrift.TFieldRequirementType.REQUIRED, 
0123         new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TStatus.class)));
0124     tmpMap.put(_Fields.HAS_MORE_ROWS, new org.apache.thrift.meta_data.FieldMetaData("hasMoreRows", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
0125         new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
0126     tmpMap.put(_Fields.RESULTS, new org.apache.thrift.meta_data.FieldMetaData("results", org.apache.thrift.TFieldRequirementType.OPTIONAL, 
0127         new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TRowSet.class)));
0128     metaDataMap = Collections.unmodifiableMap(tmpMap);
0129     org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TFetchResultsResp.class, metaDataMap);
0130   }
0131 
0132   public TFetchResultsResp() {
0133   }
0134 
0135   public TFetchResultsResp(
0136     TStatus status)
0137   {
0138     this();
0139     this.status = status;
0140   }
0141 
0142   /**
0143    * Performs a deep copy on <i>other</i>.
0144    */
0145   public TFetchResultsResp(TFetchResultsResp other) {
0146     __isset_bitfield = other.__isset_bitfield;
0147     if (other.isSetStatus()) {
0148       this.status = new TStatus(other.status);
0149     }
0150     this.hasMoreRows = other.hasMoreRows;
0151     if (other.isSetResults()) {
0152       this.results = new TRowSet(other.results);
0153     }
0154   }
0155 
0156   public TFetchResultsResp deepCopy() {
0157     return new TFetchResultsResp(this);
0158   }
0159 
0160   @Override
0161   public void clear() {
0162     this.status = null;
0163     setHasMoreRowsIsSet(false);
0164     this.hasMoreRows = false;
0165     this.results = null;
0166   }
0167 
0168   public TStatus getStatus() {
0169     return this.status;
0170   }
0171 
0172   public void setStatus(TStatus status) {
0173     this.status = status;
0174   }
0175 
0176   public void unsetStatus() {
0177     this.status = null;
0178   }
0179 
0180   /** Returns true if field status is set (has been assigned a value) and false otherwise */
0181   public boolean isSetStatus() {
0182     return this.status != null;
0183   }
0184 
0185   public void setStatusIsSet(boolean value) {
0186     if (!value) {
0187       this.status = null;
0188     }
0189   }
0190 
0191   public boolean isHasMoreRows() {
0192     return this.hasMoreRows;
0193   }
0194 
0195   public void setHasMoreRows(boolean hasMoreRows) {
0196     this.hasMoreRows = hasMoreRows;
0197     setHasMoreRowsIsSet(true);
0198   }
0199 
0200   public void unsetHasMoreRows() {
0201     __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __HASMOREROWS_ISSET_ID);
0202   }
0203 
0204   /** Returns true if field hasMoreRows is set (has been assigned a value) and false otherwise */
0205   public boolean isSetHasMoreRows() {
0206     return EncodingUtils.testBit(__isset_bitfield, __HASMOREROWS_ISSET_ID);
0207   }
0208 
0209   public void setHasMoreRowsIsSet(boolean value) {
0210     __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __HASMOREROWS_ISSET_ID, value);
0211   }
0212 
0213   public TRowSet getResults() {
0214     return this.results;
0215   }
0216 
0217   public void setResults(TRowSet results) {
0218     this.results = results;
0219   }
0220 
0221   public void unsetResults() {
0222     this.results = null;
0223   }
0224 
0225   /** Returns true if field results is set (has been assigned a value) and false otherwise */
0226   public boolean isSetResults() {
0227     return this.results != null;
0228   }
0229 
0230   public void setResultsIsSet(boolean value) {
0231     if (!value) {
0232       this.results = null;
0233     }
0234   }
0235 
0236   public void setFieldValue(_Fields field, Object value) {
0237     switch (field) {
0238     case STATUS:
0239       if (value == null) {
0240         unsetStatus();
0241       } else {
0242         setStatus((TStatus)value);
0243       }
0244       break;
0245 
0246     case HAS_MORE_ROWS:
0247       if (value == null) {
0248         unsetHasMoreRows();
0249       } else {
0250         setHasMoreRows((Boolean)value);
0251       }
0252       break;
0253 
0254     case RESULTS:
0255       if (value == null) {
0256         unsetResults();
0257       } else {
0258         setResults((TRowSet)value);
0259       }
0260       break;
0261 
0262     }
0263   }
0264 
0265   public Object getFieldValue(_Fields field) {
0266     switch (field) {
0267     case STATUS:
0268       return getStatus();
0269 
0270     case HAS_MORE_ROWS:
0271       return Boolean.valueOf(isHasMoreRows());
0272 
0273     case RESULTS:
0274       return getResults();
0275 
0276     }
0277     throw new IllegalStateException();
0278   }
0279 
0280   /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
0281   public boolean isSet(_Fields field) {
0282     if (field == null) {
0283       throw new IllegalArgumentException();
0284     }
0285 
0286     switch (field) {
0287     case STATUS:
0288       return isSetStatus();
0289     case HAS_MORE_ROWS:
0290       return isSetHasMoreRows();
0291     case RESULTS:
0292       return isSetResults();
0293     }
0294     throw new IllegalStateException();
0295   }
0296 
0297   @Override
0298   public boolean equals(Object that) {
0299     if (that == null)
0300       return false;
0301     if (that instanceof TFetchResultsResp)
0302       return this.equals((TFetchResultsResp)that);
0303     return false;
0304   }
0305 
0306   public boolean equals(TFetchResultsResp that) {
0307     if (that == null)
0308       return false;
0309 
0310     boolean this_present_status = true && this.isSetStatus();
0311     boolean that_present_status = true && that.isSetStatus();
0312     if (this_present_status || that_present_status) {
0313       if (!(this_present_status && that_present_status))
0314         return false;
0315       if (!this.status.equals(that.status))
0316         return false;
0317     }
0318 
0319     boolean this_present_hasMoreRows = true && this.isSetHasMoreRows();
0320     boolean that_present_hasMoreRows = true && that.isSetHasMoreRows();
0321     if (this_present_hasMoreRows || that_present_hasMoreRows) {
0322       if (!(this_present_hasMoreRows && that_present_hasMoreRows))
0323         return false;
0324       if (this.hasMoreRows != that.hasMoreRows)
0325         return false;
0326     }
0327 
0328     boolean this_present_results = true && this.isSetResults();
0329     boolean that_present_results = true && that.isSetResults();
0330     if (this_present_results || that_present_results) {
0331       if (!(this_present_results && that_present_results))
0332         return false;
0333       if (!this.results.equals(that.results))
0334         return false;
0335     }
0336 
0337     return true;
0338   }
0339 
0340   @Override
0341   public int hashCode() {
0342     HashCodeBuilder builder = new HashCodeBuilder();
0343 
0344     boolean present_status = true && (isSetStatus());
0345     builder.append(present_status);
0346     if (present_status)
0347       builder.append(status);
0348 
0349     boolean present_hasMoreRows = true && (isSetHasMoreRows());
0350     builder.append(present_hasMoreRows);
0351     if (present_hasMoreRows)
0352       builder.append(hasMoreRows);
0353 
0354     boolean present_results = true && (isSetResults());
0355     builder.append(present_results);
0356     if (present_results)
0357       builder.append(results);
0358 
0359     return builder.toHashCode();
0360   }
0361 
0362   public int compareTo(TFetchResultsResp other) {
0363     if (!getClass().equals(other.getClass())) {
0364       return getClass().getName().compareTo(other.getClass().getName());
0365     }
0366 
0367     int lastComparison = 0;
0368     TFetchResultsResp typedOther = (TFetchResultsResp)other;
0369 
0370     lastComparison = Boolean.valueOf(isSetStatus()).compareTo(typedOther.isSetStatus());
0371     if (lastComparison != 0) {
0372       return lastComparison;
0373     }
0374     if (isSetStatus()) {
0375       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.status, typedOther.status);
0376       if (lastComparison != 0) {
0377         return lastComparison;
0378       }
0379     }
0380     lastComparison = Boolean.valueOf(isSetHasMoreRows()).compareTo(typedOther.isSetHasMoreRows());
0381     if (lastComparison != 0) {
0382       return lastComparison;
0383     }
0384     if (isSetHasMoreRows()) {
0385       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.hasMoreRows, typedOther.hasMoreRows);
0386       if (lastComparison != 0) {
0387         return lastComparison;
0388       }
0389     }
0390     lastComparison = Boolean.valueOf(isSetResults()).compareTo(typedOther.isSetResults());
0391     if (lastComparison != 0) {
0392       return lastComparison;
0393     }
0394     if (isSetResults()) {
0395       lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.results, typedOther.results);
0396       if (lastComparison != 0) {
0397         return lastComparison;
0398       }
0399     }
0400     return 0;
0401   }
0402 
0403   public _Fields fieldForId(int fieldId) {
0404     return _Fields.findByThriftId(fieldId);
0405   }
0406 
0407   public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
0408     schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
0409   }
0410 
0411   public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
0412     schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
0413   }
0414 
0415   @Override
0416   public String toString() {
0417     StringBuilder sb = new StringBuilder("TFetchResultsResp(");
0418     boolean first = true;
0419 
0420     sb.append("status:");
0421     if (this.status == null) {
0422       sb.append("null");
0423     } else {
0424       sb.append(this.status);
0425     }
0426     first = false;
0427     if (isSetHasMoreRows()) {
0428       if (!first) sb.append(", ");
0429       sb.append("hasMoreRows:");
0430       sb.append(this.hasMoreRows);
0431       first = false;
0432     }
0433     if (isSetResults()) {
0434       if (!first) sb.append(", ");
0435       sb.append("results:");
0436       if (this.results == null) {
0437         sb.append("null");
0438       } else {
0439         sb.append(this.results);
0440       }
0441       first = false;
0442     }
0443     sb.append(")");
0444     return sb.toString();
0445   }
0446 
0447   public void validate() throws org.apache.thrift.TException {
0448     // check for required fields
0449     if (!isSetStatus()) {
0450       throw new org.apache.thrift.protocol.TProtocolException("Required field 'status' is unset! Struct:" + toString());
0451     }
0452 
0453     // check for sub-struct validity
0454     if (status != null) {
0455       status.validate();
0456     }
0457     if (results != null) {
0458       results.validate();
0459     }
0460   }
0461 
0462   private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
0463     try {
0464       write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
0465     } catch (org.apache.thrift.TException te) {
0466       throw new java.io.IOException(te);
0467     }
0468   }
0469 
0470   private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
0471     try {
0472       // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
0473       __isset_bitfield = 0;
0474       read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
0475     } catch (org.apache.thrift.TException te) {
0476       throw new java.io.IOException(te);
0477     }
0478   }
0479 
0480   private static class TFetchResultsRespStandardSchemeFactory implements SchemeFactory {
0481     public TFetchResultsRespStandardScheme getScheme() {
0482       return new TFetchResultsRespStandardScheme();
0483     }
0484   }
0485 
0486   private static class TFetchResultsRespStandardScheme extends StandardScheme<TFetchResultsResp> {
0487 
0488     public void read(org.apache.thrift.protocol.TProtocol iprot, TFetchResultsResp struct) throws org.apache.thrift.TException {
0489       org.apache.thrift.protocol.TField schemeField;
0490       iprot.readStructBegin();
0491       while (true)
0492       {
0493         schemeField = iprot.readFieldBegin();
0494         if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
0495           break;
0496         }
0497         switch (schemeField.id) {
0498           case 1: // STATUS
0499             if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
0500               struct.status = new TStatus();
0501               struct.status.read(iprot);
0502               struct.setStatusIsSet(true);
0503             } else { 
0504               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
0505             }
0506             break;
0507           case 2: // HAS_MORE_ROWS
0508             if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
0509               struct.hasMoreRows = iprot.readBool();
0510               struct.setHasMoreRowsIsSet(true);
0511             } else { 
0512               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
0513             }
0514             break;
0515           case 3: // RESULTS
0516             if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
0517               struct.results = new TRowSet();
0518               struct.results.read(iprot);
0519               struct.setResultsIsSet(true);
0520             } else { 
0521               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
0522             }
0523             break;
0524           default:
0525             org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
0526         }
0527         iprot.readFieldEnd();
0528       }
0529       iprot.readStructEnd();
0530       struct.validate();
0531     }
0532 
0533     public void write(org.apache.thrift.protocol.TProtocol oprot, TFetchResultsResp struct) throws org.apache.thrift.TException {
0534       struct.validate();
0535 
0536       oprot.writeStructBegin(STRUCT_DESC);
0537       if (struct.status != null) {
0538         oprot.writeFieldBegin(STATUS_FIELD_DESC);
0539         struct.status.write(oprot);
0540         oprot.writeFieldEnd();
0541       }
0542       if (struct.isSetHasMoreRows()) {
0543         oprot.writeFieldBegin(HAS_MORE_ROWS_FIELD_DESC);
0544         oprot.writeBool(struct.hasMoreRows);
0545         oprot.writeFieldEnd();
0546       }
0547       if (struct.results != null) {
0548         if (struct.isSetResults()) {
0549           oprot.writeFieldBegin(RESULTS_FIELD_DESC);
0550           struct.results.write(oprot);
0551           oprot.writeFieldEnd();
0552         }
0553       }
0554       oprot.writeFieldStop();
0555       oprot.writeStructEnd();
0556     }
0557 
0558   }
0559 
0560   private static class TFetchResultsRespTupleSchemeFactory implements SchemeFactory {
0561     public TFetchResultsRespTupleScheme getScheme() {
0562       return new TFetchResultsRespTupleScheme();
0563     }
0564   }
0565 
0566   private static class TFetchResultsRespTupleScheme extends TupleScheme<TFetchResultsResp> {
0567 
0568     @Override
0569     public void write(org.apache.thrift.protocol.TProtocol prot, TFetchResultsResp struct) throws org.apache.thrift.TException {
0570       TTupleProtocol oprot = (TTupleProtocol) prot;
0571       struct.status.write(oprot);
0572       BitSet optionals = new BitSet();
0573       if (struct.isSetHasMoreRows()) {
0574         optionals.set(0);
0575       }
0576       if (struct.isSetResults()) {
0577         optionals.set(1);
0578       }
0579       oprot.writeBitSet(optionals, 2);
0580       if (struct.isSetHasMoreRows()) {
0581         oprot.writeBool(struct.hasMoreRows);
0582       }
0583       if (struct.isSetResults()) {
0584         struct.results.write(oprot);
0585       }
0586     }
0587 
0588     @Override
0589     public void read(org.apache.thrift.protocol.TProtocol prot, TFetchResultsResp struct) throws org.apache.thrift.TException {
0590       TTupleProtocol iprot = (TTupleProtocol) prot;
0591       struct.status = new TStatus();
0592       struct.status.read(iprot);
0593       struct.setStatusIsSet(true);
0594       BitSet incoming = iprot.readBitSet(2);
0595       if (incoming.get(0)) {
0596         struct.hasMoreRows = iprot.readBool();
0597         struct.setHasMoreRowsIsSet(true);
0598       }
0599       if (incoming.get(1)) {
0600         struct.results = new TRowSet();
0601         struct.results.read(iprot);
0602         struct.setResultsIsSet(true);
0603       }
0604     }
0605   }
0606 
0607 }
0608
[ 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!