Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
Autogenerated by Thrift DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  
  package org.apache.hadoop.hive.ql.plan.api;
  
  import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import  org.slf4j.Logger;
 import  org.slf4j.LoggerFactory;
 
 import  org.apache.thrift.async.*;
 
 public class Operator implements TBase<OperatorOperator._Fields>, java.io.SerializableCloneable {
   private static final TStruct STRUCT_DESC = new TStruct("Operator");
 
   private static final TField OPERATOR_ID_FIELD_DESC = new TField("operatorId"., (short)1);
   private static final TField OPERATOR_TYPE_FIELD_DESC = new TField("operatorType"., (short)2);
   private static final TField OPERATOR_ATTRIBUTES_FIELD_DESC = new TField("operatorAttributes"., (short)3);
   private static final TField OPERATOR_COUNTERS_FIELD_DESC = new TField("operatorCounters"., (short)4);
   private static final TField DONE_FIELD_DESC = new TField("done"., (short)5);
   private static final TField STARTED_FIELD_DESC = new TField("started"., (short)6);
 
   private String operatorId;
   private OperatorType operatorType;
   private Map<String,LongoperatorCounters;
   private boolean done;
   private boolean started;

  
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
 
   public enum _Fields implements TFieldIdEnum {
     OPERATOR_ID((short)1, "operatorId"),
    

See also:
OperatorType
 
     OPERATOR_TYPE((short)2, "operatorType"),
     OPERATOR_ATTRIBUTES((short)3, "operatorAttributes"),
     OPERATOR_COUNTERS((short)4, "operatorCounters"),
     DONE((short)5, "done"),
     STARTED((short)6, "started");
 
     private static final Map<String_FieldsbyName = new HashMap<String_Fields>();
 
     static {
       for (_Fields field : EnumSet.allOf(_Fields.class)) {
         .put(field.getFieldName(), field);
       }
     }

    
Find the _Fields constant that matches fieldId, or null if its not found.
 
     public static _Fields findByThriftId(int fieldId) {
       switch(fieldId) {
         case 1: // OPERATOR_ID
           return ;
         case 2: // OPERATOR_TYPE
           return ;
         case 3: // OPERATOR_ATTRIBUTES
           return ;
         case 4: // OPERATOR_COUNTERS
           return ;
         case 5: // DONE
           return ;
         case 6: // STARTED
           return ;
         default:
           return null;
       }
     }

    
Find the _Fields constant that matches fieldId, throwing an exception if it is not found.
 
     public static _Fields findByThriftIdOrThrow(int fieldId) {
       _Fields fields = findByThriftId(fieldId);
       if (fields == nullthrow new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
       return fields;
     }

    
Find the _Fields constant that matches name, or null if its not found.
    public static _Fields findByName(String name) {
      return .get(name);
    }
    private final short _thriftId;
    private final String _fieldName;
    _Fields(short thriftIdString fieldName) {
       = thriftId;
       = fieldName;
    }
    public short getThriftFieldId() {
      return ;
    }
    public String getFieldName() {
      return ;
    }
  }
  // isset id assignments
  private static final int __DONE_ISSET_ID = 0;
  private static final int __STARTED_ISSET_ID = 1;
  private BitSet __isset_bit_vector = new BitSet(2);
  public static final Map<_FieldsFieldMetaDatametaDataMap;
  static {
    Map<_FieldsFieldMetaDatatmpMap = new EnumMap<_FieldsFieldMetaData>(_Fields.class);
    tmpMap.put(.new FieldMetaData("operatorId".
        new FieldValueMetaData(.)));
    tmpMap.put(.new FieldMetaData("operatorType".
        new EnumMetaData(.OperatorType.class)));
    tmpMap.put(.new FieldMetaData("operatorAttributes".
        new MapMetaData(.
            new FieldValueMetaData(.), 
            new FieldValueMetaData(.))));
    tmpMap.put(.new FieldMetaData("operatorCounters".
        new MapMetaData(.
            new FieldValueMetaData(.), 
            new FieldValueMetaData(.))));
    tmpMap.put(.new FieldMetaData("done".
        new FieldValueMetaData(.)));
    tmpMap.put(.new FieldMetaData("started".
        new FieldValueMetaData(.)));
     = Collections.unmodifiableMap(tmpMap);
    FieldMetaData.addStructMetaDataMap(Operator.class);
  }
  public Operator() {
  }
  public Operator(
    String operatorId,
    OperatorType operatorType,
    Map<String,StringoperatorAttributes,
    Map<String,LongoperatorCounters,
    boolean done,
    boolean started)
  {
    this();
    this. = operatorId;
    this. = operatorType;
    this. = operatorAttributes;
    this. = operatorCounters;
    this. = done;
    setDoneIsSet(true);
    this. = started;
    setStartedIsSet(true);
  }

  
Performs a deep copy on other.
  public Operator(Operator other) {
    .or(other.__isset_bit_vector);
    if (other.isSetOperatorId()) {
      this. = other.operatorId;
    }
    if (other.isSetOperatorType()) {
      this. = other.operatorType;
    }
    if (other.isSetOperatorAttributes()) {
      Map<String,String__this__operatorAttributes = new HashMap<String,String>();
      for (Map.Entry<StringStringother_element : other.operatorAttributes.entrySet()) {
        String other_element_key = other_element.getKey();
        String other_element_value = other_element.getValue();
        String __this__operatorAttributes_copy_key = other_element_key;
        String __this__operatorAttributes_copy_value = other_element_value;
        __this__operatorAttributes.put(__this__operatorAttributes_copy_key__this__operatorAttributes_copy_value);
      }
      this. = __this__operatorAttributes;
    }
    if (other.isSetOperatorCounters()) {
      Map<String,Long__this__operatorCounters = new HashMap<String,Long>();
      for (Map.Entry<StringLongother_element : other.operatorCounters.entrySet()) {
        String other_element_key = other_element.getKey();
        Long other_element_value = other_element.getValue();
        String __this__operatorCounters_copy_key = other_element_key;
        Long __this__operatorCounters_copy_value = other_element_value;
        __this__operatorCounters.put(__this__operatorCounters_copy_key__this__operatorCounters_copy_value);
      }
      this. = __this__operatorCounters;
    }
    this. = other.done;
    this. = other.started;
  }
  public Operator deepCopy() {
    return new Operator(this);
  }
  public void clear() {
    this. = null;
    this. = null;
    this. = null;
    this. = null;
    setDoneIsSet(false);
    this. = false;
    setStartedIsSet(false);
    this. = false;
  }
  public String getOperatorId() {
    return this.;
  }
  public void setOperatorId(String operatorId) {
    this. = operatorId;
  }
  public void unsetOperatorId() {
    this. = null;
  }

  
Returns true if field operatorId is set (has been asigned a value) and false otherwise
  public boolean isSetOperatorId() {
    return this. != null;
  }
  public void setOperatorIdIsSet(boolean value) {
    if (!value) {
      this. = null;
    }
  }

  

See also:
OperatorType
    return this.;
  }

  

See also:
OperatorType
  public void setOperatorType(OperatorType operatorType) {
    this. = operatorType;
  }
  public void unsetOperatorType() {
    this. = null;
  }

  
Returns true if field operatorType is set (has been asigned a value) and false otherwise
  public boolean isSetOperatorType() {
    return this. != null;
  }
  public void setOperatorTypeIsSet(boolean value) {
    if (!value) {
      this. = null;
    }
  }
  public int getOperatorAttributesSize() {
    return (this. == null) ? 0 : this..size();
  }
  public void putToOperatorAttributes(String keyString val) {
    if (this. == null) {
      this. = new HashMap<String,String>();
    }
    this..put(keyval);
  }
    return this.;
  }
  public void setOperatorAttributes(Map<String,StringoperatorAttributes) {
    this. = operatorAttributes;
  }
  public void unsetOperatorAttributes() {
    this. = null;
  }

  
Returns true if field operatorAttributes is set (has been asigned a value) and false otherwise
  public boolean isSetOperatorAttributes() {
    return this. != null;
  }
  public void setOperatorAttributesIsSet(boolean value) {
    if (!value) {
      this. = null;
    }
  }
  public int getOperatorCountersSize() {
    return (this. == null) ? 0 : this..size();
  }
  public void putToOperatorCounters(String keylong val) {
    if (this. == null) {
      this. = new HashMap<String,Long>();
    }
    this..put(keyval);
  }
    return this.;
  }
  public void setOperatorCounters(Map<String,LongoperatorCounters) {
    this. = operatorCounters;
  }
  public void unsetOperatorCounters() {
    this. = null;
  }

  
Returns true if field operatorCounters is set (has been asigned a value) and false otherwise
  public boolean isSetOperatorCounters() {
    return this. != null;
  }
  public void setOperatorCountersIsSet(boolean value) {
    if (!value) {
      this. = null;
    }
  }
  public boolean isDone() {
    return this.;
  }
  public void setDone(boolean done) {
    this. = done;
    setDoneIsSet(true);
  }
  public void unsetDone() {
  }

  
Returns true if field done is set (has been asigned a value) and false otherwise
  public boolean isSetDone() {
  }
  public void setDoneIsSet(boolean value) {
  }
  public boolean isStarted() {
    return this.;
  }
  public void setStarted(boolean started) {
    this. = started;
    setStartedIsSet(true);
  }
  public void unsetStarted() {
  }

  
Returns true if field started is set (has been asigned a value) and false otherwise
  public boolean isSetStarted() {
  }
  public void setStartedIsSet(boolean value) {
  }
  public void setFieldValue(_Fields fieldObject value) {
    switch (field) {
    case :
      if (value == null) {
        unsetOperatorId();
      } else {
        setOperatorId((String)value);
      }
      break;
    case :
      if (value == null) {
        unsetOperatorType();
      } else {
        setOperatorType((OperatorType)value);
      }
      break;
    case :
      if (value == null) {
        unsetOperatorAttributes();
      } else {
        setOperatorAttributes((Map<String,String>)value);
      }
      break;
    case :
      if (value == null) {
        unsetOperatorCounters();
      } else {
        setOperatorCounters((Map<String,Long>)value);
      }
      break;
    case :
      if (value == null) {
        unsetDone();
      } else {
        setDone((Boolean)value);
      }
      break;
    case :
      if (value == null) {
        unsetStarted();
      } else {
        setStarted((Boolean)value);
      }
      break;
    }
  }
  public Object getFieldValue(_Fields field) {
    switch (field) {
    case :
      return getOperatorId();
    case :
      return getOperatorType();
    case :
      return getOperatorAttributes();
    case :
      return getOperatorCounters();
    case :
      return new Boolean(isDone());
    case :
      return new Boolean(isStarted());
    }
    throw new IllegalStateException();
  }

  
Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise
  public boolean isSet(_Fields field) {
    if (field == null) {
      throw new IllegalArgumentException();
    }
    switch (field) {
    case :
      return isSetOperatorId();
    case :
      return isSetOperatorType();
    case :
      return isSetOperatorAttributes();
    case :
      return isSetOperatorCounters();
    case :
      return isSetDone();
    case :
      return isSetStarted();
    }
    throw new IllegalStateException();
  }
  public boolean equals(Object that) {
    if (that == null)
      return false;
    if (that instanceof Operator)
      return this.equals((Operator)that);
    return false;
  }
  public boolean equals(Operator that) {
    if (that == null)
      return false;
    boolean this_present_operatorId = true && this.isSetOperatorId();
    boolean that_present_operatorId = true && that.isSetOperatorId();
    if (this_present_operatorId || that_present_operatorId) {
      if (!(this_present_operatorId && that_present_operatorId))
        return false;
      if (!this..equals(that.operatorId))
        return false;
    }
    boolean this_present_operatorType = true && this.isSetOperatorType();
    boolean that_present_operatorType = true && that.isSetOperatorType();
    if (this_present_operatorType || that_present_operatorType) {
      if (!(this_present_operatorType && that_present_operatorType))
        return false;
      if (!this..equals(that.operatorType))
        return false;
    }
    boolean this_present_operatorAttributes = true && this.isSetOperatorAttributes();
    boolean that_present_operatorAttributes = true && that.isSetOperatorAttributes();
    if (this_present_operatorAttributes || that_present_operatorAttributes) {
      if (!(this_present_operatorAttributes && that_present_operatorAttributes))
        return false;
      if (!this..equals(that.operatorAttributes))
        return false;
    }
    boolean this_present_operatorCounters = true && this.isSetOperatorCounters();
    boolean that_present_operatorCounters = true && that.isSetOperatorCounters();
    if (this_present_operatorCounters || that_present_operatorCounters) {
      if (!(this_present_operatorCounters && that_present_operatorCounters))
        return false;
      if (!this..equals(that.operatorCounters))
        return false;
    }
    boolean this_present_done = true;
    boolean that_present_done = true;
    if (this_present_done || that_present_done) {
      if (!(this_present_done && that_present_done))
        return false;
      if (this. != that.done)
        return false;
    }
    boolean this_present_started = true;
    boolean that_present_started = true;
    if (this_present_started || that_present_started) {
      if (!(this_present_started && that_present_started))
        return false;
      if (this. != that.started)
        return false;
    }
    return true;
  }
  public int hashCode() {
    return 0;
  }
  public int compareTo(Operator other) {
    if (!getClass().equals(other.getClass())) {
      return getClass().getName().compareTo(other.getClass().getName());
    }
    int lastComparison = 0;
    Operator typedOther = (Operator)other;
    lastComparison = Boolean.valueOf(isSetOperatorId()).compareTo(typedOther.isSetOperatorId());
    if (lastComparison != 0) {
      return lastComparison;
    }
    if (isSetOperatorId()) {
      lastComparison = TBaseHelper.compareTo(this.typedOther.operatorId);
      if (lastComparison != 0) {
        return lastComparison;
      }
    }
    lastComparison = Boolean.valueOf(isSetOperatorType()).compareTo(typedOther.isSetOperatorType());
    if (lastComparison != 0) {
      return lastComparison;
    }
    if (isSetOperatorType()) {
      lastComparison = TBaseHelper.compareTo(this.typedOther.operatorType);
      if (lastComparison != 0) {
        return lastComparison;
      }
    }
    lastComparison = Boolean.valueOf(isSetOperatorAttributes()).compareTo(typedOther.isSetOperatorAttributes());
    if (lastComparison != 0) {
      return lastComparison;
    }
    if (isSetOperatorAttributes()) {
      lastComparison = TBaseHelper.compareTo(this.typedOther.operatorAttributes);
      if (lastComparison != 0) {
        return lastComparison;
      }
    }
    lastComparison = Boolean.valueOf(isSetOperatorCounters()).compareTo(typedOther.isSetOperatorCounters());
    if (lastComparison != 0) {
      return lastComparison;
    }
    if (isSetOperatorCounters()) {
      lastComparison = TBaseHelper.compareTo(this.typedOther.operatorCounters);
      if (lastComparison != 0) {
        return lastComparison;
      }
    }
    lastComparison = Boolean.valueOf(isSetDone()).compareTo(typedOther.isSetDone());
    if (lastComparison != 0) {
      return lastComparison;
    }
    if (isSetDone()) {
      lastComparison = TBaseHelper.compareTo(this.typedOther.done);
      if (lastComparison != 0) {
        return lastComparison;
      }
    }
    lastComparison = Boolean.valueOf(isSetStarted()).compareTo(typedOther.isSetStarted());
    if (lastComparison != 0) {
      return lastComparison;
    }
    if (isSetStarted()) {
      lastComparison = TBaseHelper.compareTo(this.typedOther.started);
      if (lastComparison != 0) {
        return lastComparison;
      }
    }
    return 0;
  }
  public _Fields fieldForId(int fieldId) {
    return _Fields.findByThriftId(fieldId);
  }
  public void read(TProtocol iprotthrows TException {
    TField field;
    iprot.readStructBegin();
    while (true)
    {
      field = iprot.readFieldBegin();
      if (field.type == .) { 
        break;
      }
      switch (field.id) {
        case 1: // OPERATOR_ID
          if (field.type == .) {
            this. = iprot.readString();
          } else { 
            TProtocolUtil.skip(iprotfield.type);
          }
          break;
        case 2: // OPERATOR_TYPE
          if (field.type == .) {
            this. = OperatorType.findByValue(iprot.readI32());
          } else { 
            TProtocolUtil.skip(iprotfield.type);
          }
          break;
        case 3: // OPERATOR_ATTRIBUTES
          if (field.type == .) {
            {
              TMap _map12 = iprot.readMapBegin();
              this. = new HashMap<String,String>(2*_map12.size);
              for (int _i13 = 0; _i13 < _map12.size; ++_i13)
              {
                String _key14;
                String _val15;
                _key14 = iprot.readString();
                _val15 = iprot.readString();
                this..put(_key14_val15);
              }
              iprot.readMapEnd();
            }
          } else { 
            TProtocolUtil.skip(iprotfield.type);
          }
          break;
        case 4: // OPERATOR_COUNTERS
          if (field.type == .) {
            {
              TMap _map16 = iprot.readMapBegin();
              this. = new HashMap<String,Long>(2*_map16.size);
              for (int _i17 = 0; _i17 < _map16.size; ++_i17)
              {
                String _key18;
                long _val19;
                _key18 = iprot.readString();
                _val19 = iprot.readI64();
                this..put(_key18_val19);
              }
              iprot.readMapEnd();
            }
          } else { 
            TProtocolUtil.skip(iprotfield.type);
          }
          break;
        case 5: // DONE
          if (field.type == .) {
            this. = iprot.readBool();
            setDoneIsSet(true);
          } else { 
            TProtocolUtil.skip(iprotfield.type);
          }
          break;
        case 6: // STARTED
          if (field.type == .) {
            this. = iprot.readBool();
            setStartedIsSet(true);
          } else { 
            TProtocolUtil.skip(iprotfield.type);
          }
          break;
        default:
          TProtocolUtil.skip(iprotfield.type);
      }
      iprot.readFieldEnd();
    }
    iprot.readStructEnd();
    validate();
  }
  public void write(TProtocol oprotthrows TException {
    validate();
    if (this. != null) {
      oprot.writeString(this.);
      oprot.writeFieldEnd();
    }
    if (this. != null) {
      oprot.writeI32(this..getValue());
      oprot.writeFieldEnd();
    }
    if (this. != null) {
      {
        oprot.writeMapBegin(new TMap(..this..size()));
        for (Map.Entry<StringString_iter20 : this..entrySet())
        {
          oprot.writeString(_iter20.getKey());
          oprot.writeString(_iter20.getValue());
        }
        oprot.writeMapEnd();
      }
      oprot.writeFieldEnd();
    }
    if (this. != null) {
      {
        oprot.writeMapBegin(new TMap(..this..size()));
        for (Map.Entry<StringLong_iter21 : this..entrySet())
        {
          oprot.writeString(_iter21.getKey());
          oprot.writeI64(_iter21.getValue());
        }
        oprot.writeMapEnd();
      }
      oprot.writeFieldEnd();
    }
    oprot.writeBool(this.);
    oprot.writeFieldEnd();
    oprot.writeBool(this.);
    oprot.writeFieldEnd();
    oprot.writeFieldStop();
    oprot.writeStructEnd();
  }
  public String toString() {
    StringBuilder sb = new StringBuilder("Operator(");
    boolean first = true;
    sb.append("operatorId:");
    if (this. == null) {
      sb.append("null");
    } else {
      sb.append(this.);
    }
    first = false;
    if (!firstsb.append(", ");
    sb.append("operatorType:");
    if (this. == null) {
      sb.append("null");
    } else {
      sb.append(this.);
    }
    first = false;
    if (!firstsb.append(", ");
    sb.append("operatorAttributes:");
    if (this. == null) {
      sb.append("null");
    } else {
      sb.append(this.);
    }
    first = false;
    if (!firstsb.append(", ");
    sb.append("operatorCounters:");
    if (this. == null) {
      sb.append("null");
    } else {
      sb.append(this.);
    }
    first = false;
    if (!firstsb.append(", ");
    sb.append("done:");
    sb.append(this.);
    first = false;
    if (!firstsb.append(", ");
    sb.append("started:");
    sb.append(this.);
    first = false;
    sb.append(")");
    return sb.toString();
  }
  public void validate() throws TException {
    // check for required fields
  }
New to GrepCode? Check out our FAQ X