src/jvm/backtype/storm/generated/TaskSpecificStats.java - storm - Git at Google

 /**
  * Autogenerated by Thrift
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  */
 package backtype.storm.generated;

 import org.apache.commons.lang.builder.HashCodeBuilder;
 import java.util.List;
 import java.util.ArrayList;
 import java.util.Map;
 import java.util.HashMap;
 import java.util.EnumMap;
 import java.util.Set;
 import java.util.HashSet;
 import java.util.EnumSet;
 import java.util.Collections;
 import java.util.BitSet;
 import java.util.Arrays;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

 import org.apache.thrift.*;
 import org.apache.thrift.async.*;
 import org.apache.thrift.meta_data.*;
 import org.apache.thrift.transport.*;
 import org.apache.thrift.protocol.*;

 public class TaskSpecificStats extends TUnion<TaskSpecificStats, TaskSpecificStats._Fields> {
   private static final TStruct STRUCT_DESC = new TStruct("TaskSpecificStats");
   private static final TField BOLT_FIELD_DESC = new TField("bolt", TType.STRUCT, (short)1);
   private static final TField SPOUT_FIELD_DESC = new TField("spout", TType.STRUCT, (short)2);

   /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
   public enum _Fields implements TFieldIdEnum {
     BOLT((short)1, "bolt"),
     SPOUT((short)2, "spout");

     private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();

     static {
       for (_Fields field : EnumSet.allOf(_Fields.class)) {
         byName.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: // BOLT
           return BOLT;
         case 2: // SPOUT
           return SPOUT;
         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 == null) throw 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 byName.get(name);
     }

     private final short _thriftId;
     private final String _fieldName;

     _Fields(short thriftId, String fieldName) {
       _thriftId = thriftId;
       _fieldName = fieldName;
     }

     public short getThriftFieldId() {
       return _thriftId;
     }

     public String getFieldName() {
       return _fieldName;
     }
   }

   public static final Map<_Fields, FieldMetaData> metaDataMap;
   static {
     Map<_Fields, FieldMetaData> tmpMap = new EnumMap<_Fields, FieldMetaData>(_Fields.class);
     tmpMap.put(_Fields.BOLT, new FieldMetaData("bolt", TFieldRequirementType.DEFAULT,
         new StructMetaData(TType.STRUCT, BoltStats.class)));
     tmpMap.put(_Fields.SPOUT, new FieldMetaData("spout", TFieldRequirementType.DEFAULT,
         new StructMetaData(TType.STRUCT, SpoutStats.class)));
     metaDataMap = Collections.unmodifiableMap(tmpMap);
     FieldMetaData.addStructMetaDataMap(TaskSpecificStats.class, metaDataMap);
   }

   public TaskSpecificStats() {
     super();
   }

   public TaskSpecificStats(_Fields setField, Object value) {
     super(setField, value);
   }

   public TaskSpecificStats(TaskSpecificStats other) {
     super(other);
   }
   public TaskSpecificStats deepCopy() {
     return new TaskSpecificStats(this);
   }

   public static TaskSpecificStats bolt(BoltStats value) {
     TaskSpecificStats x = new TaskSpecificStats();
     x.set_bolt(value);
     return x;
   }

   public static TaskSpecificStats spout(SpoutStats value) {
     TaskSpecificStats x = new TaskSpecificStats();
     x.set_spout(value);
     return x;
   }


   @Override
   protected void checkType(_Fields setField, Object value) throws ClassCastException {
     switch (setField) {
       case BOLT:
         if (value instanceof BoltStats) {
           break;
         }
         throw new ClassCastException("Was expecting value of type BoltStats for field 'bolt', but got " + value.getClass().getSimpleName());
       case SPOUT:
         if (value instanceof SpoutStats) {
           break;
         }
         throw new ClassCastException("Was expecting value of type SpoutStats for field 'spout', but got " + value.getClass().getSimpleName());
       default:
         throw new IllegalArgumentException("Unknown field id " + setField);
     }
   }

   @Override
   protected Object readValue(TProtocol iprot, TField field) throws TException {
     _Fields setField = _Fields.findByThriftId(field.id);
     if (setField != null) {
       switch (setField) {
         case BOLT:
           if (field.type == BOLT_FIELD_DESC.type) {
             BoltStats bolt;
             bolt = new BoltStats();
             bolt.read(iprot);
             return bolt;
           } else {
             TProtocolUtil.skip(iprot, field.type);
             return null;
           }
         case SPOUT:
           if (field.type == SPOUT_FIELD_DESC.type) {
             SpoutStats spout;
             spout = new SpoutStats();
             spout.read(iprot);
             return spout;
           } else {
             TProtocolUtil.skip(iprot, field.type);
             return null;
           }
         default:
           throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
       }
     } else {
       TProtocolUtil.skip(iprot, field.type);
       return null;
     }
   }

   @Override
   protected void writeValue(TProtocol oprot) throws TException {
     switch (setField_) {
       case BOLT:
         BoltStats bolt = (BoltStats)value_;
         bolt.write(oprot);
         return;
       case SPOUT:
         SpoutStats spout = (SpoutStats)value_;
         spout.write(oprot);
         return;
       default:
         throw new IllegalStateException("Cannot write union with unknown field " + setField_);
     }
   }

   @Override
   protected TField getFieldDesc(_Fields setField) {
     switch (setField) {
       case BOLT:
         return BOLT_FIELD_DESC;
       case SPOUT:
         return SPOUT_FIELD_DESC;
       default:
         throw new IllegalArgumentException("Unknown field id " + setField);
     }
   }

   @Override
   protected TStruct getStructDesc() {
     return STRUCT_DESC;
   }

   @Override
   protected _Fields enumForId(short id) {
     return _Fields.findByThriftIdOrThrow(id);
   }

   public BoltStats get_bolt() {
     if (getSetField() == _Fields.BOLT) {
       return (BoltStats)getFieldValue();
     } else {
       throw new RuntimeException("Cannot get field 'bolt' because union is currently set to " + getFieldDesc(getSetField()).name);
     }
   }

   public void set_bolt(BoltStats value) {
     if (value == null) throw new NullPointerException();
     setField_ = _Fields.BOLT;
     value_ = value;
   }

   public SpoutStats get_spout() {
     if (getSetField() == _Fields.SPOUT) {
       return (SpoutStats)getFieldValue();
     } else {
       throw new RuntimeException("Cannot get field 'spout' because union is currently set to " + getFieldDesc(getSetField()).name);
     }
   }

   public void set_spout(SpoutStats value) {
     if (value == null) throw new NullPointerException();
     setField_ = _Fields.SPOUT;
     value_ = value;
   }

   public boolean equals(Object other) {
     if (other instanceof TaskSpecificStats) {
       return equals((TaskSpecificStats)other);
     } else {
       return false;
     }
   }

   public boolean equals(TaskSpecificStats other) {
     return other != null && getSetField() == other.getSetField() && ((value_ instanceof byte[]) ?
       Arrays.equals((byte[])getFieldValue(), (byte[])other.getFieldValue()) : getFieldValue().equals(other.getFieldValue()));
   }

   @Override
   public int compareTo(TaskSpecificStats other) {
     int lastComparison = TBaseHelper.compareTo(getSetField(), other.getSetField());
     if (lastComparison == 0) {
       Object myValue = getFieldValue();
       if (myValue instanceof byte[]) {
         return TBaseHelper.compareTo((byte[])myValue, (byte[])other.getFieldValue());
       } else if (myValue instanceof List) {
         return TBaseHelper.compareTo((List)myValue, (List)other.getFieldValue());
       } else if (myValue instanceof Set) {
         return TBaseHelper.compareTo((Set)myValue, (Set)other.getFieldValue());
       } else if (myValue instanceof Map){
         return TBaseHelper.compareTo((Map)myValue, (Map)other.getFieldValue());
       } else {
         return TBaseHelper.compareTo((Comparable)myValue, (Comparable)other.getFieldValue());
       }
     }
     return lastComparison;
   }


   @Override
   public int hashCode() {
     HashCodeBuilder hcb = new HashCodeBuilder();
     hcb.append(this.getClass().getName());
     TFieldIdEnum setField = getSetField();
     if (setField != null) {
       hcb.append(setField.getThriftFieldId());
       Object value = getFieldValue();
       if (value instanceof TEnum) {
         hcb.append(((TEnum)getFieldValue()).getValue());
       } else {
         hcb.append(value);
       }
     }
     return hcb.toHashCode();
   }
 }
	/**
	* Autogenerated by Thrift
	*
	* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
	*/
	package backtype.storm.generated;

	import org.apache.commons.lang.builder.HashCodeBuilder;
	import java.util.List;
	import java.util.ArrayList;
	import java.util.Map;
	import java.util.HashMap;
	import java.util.EnumMap;
	import java.util.Set;
	import java.util.HashSet;
	import java.util.EnumSet;
	import java.util.Collections;
	import java.util.BitSet;
	import java.util.Arrays;
	import org.slf4j.Logger;
	import org.slf4j.LoggerFactory;

	import org.apache.thrift.*;
	import org.apache.thrift.async.*;
	import org.apache.thrift.meta_data.*;
	import org.apache.thrift.transport.*;
	import org.apache.thrift.protocol.*;

	public class TaskSpecificStats extends TUnion<TaskSpecificStats, TaskSpecificStats._Fields> {
	private static final TStruct STRUCT_DESC = new TStruct("TaskSpecificStats");
	private static final TField BOLT_FIELD_DESC = new TField("bolt", TType.STRUCT, (short)1);
	private static final TField SPOUT_FIELD_DESC = new TField("spout", TType.STRUCT, (short)2);

	/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
	public enum _Fields implements TFieldIdEnum {
	BOLT((short)1, "bolt"),
	SPOUT((short)2, "spout");

	private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();

	static {
	for (_Fields field : EnumSet.allOf(_Fields.class)) {
	byName.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: // BOLT
	return BOLT;
	case 2: // SPOUT
	return SPOUT;
	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 == null) throw 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 byName.get(name);
	}

	private final short _thriftId;
	private final String _fieldName;

	_Fields(short thriftId, String fieldName) {
	_thriftId = thriftId;
	_fieldName = fieldName;
	}

	public short getThriftFieldId() {
	return _thriftId;
	}

	public String getFieldName() {
	return _fieldName;
	}
	}

	public static final Map<_Fields, FieldMetaData> metaDataMap;
	static {
	Map<_Fields, FieldMetaData> tmpMap = new EnumMap<_Fields, FieldMetaData>(_Fields.class);
	tmpMap.put(_Fields.BOLT, new FieldMetaData("bolt", TFieldRequirementType.DEFAULT,
	new StructMetaData(TType.STRUCT, BoltStats.class)));
	tmpMap.put(_Fields.SPOUT, new FieldMetaData("spout", TFieldRequirementType.DEFAULT,
	new StructMetaData(TType.STRUCT, SpoutStats.class)));
	metaDataMap = Collections.unmodifiableMap(tmpMap);
	FieldMetaData.addStructMetaDataMap(TaskSpecificStats.class, metaDataMap);
	}

	public TaskSpecificStats() {
	super();
	}

	public TaskSpecificStats(_Fields setField, Object value) {
	super(setField, value);
	}

	public TaskSpecificStats(TaskSpecificStats other) {
	super(other);
	}
	public TaskSpecificStats deepCopy() {
	return new TaskSpecificStats(this);
	}

	public static TaskSpecificStats bolt(BoltStats value) {
	TaskSpecificStats x = new TaskSpecificStats();
	x.set_bolt(value);
	return x;
	}

	public static TaskSpecificStats spout(SpoutStats value) {
	TaskSpecificStats x = new TaskSpecificStats();
	x.set_spout(value);
	return x;
	}


	@Override
	protected void checkType(_Fields setField, Object value) throws ClassCastException {
	switch (setField) {
	case BOLT:
	if (value instanceof BoltStats) {
	break;
	}
	throw new ClassCastException("Was expecting value of type BoltStats for field 'bolt', but got " + value.getClass().getSimpleName());
	case SPOUT:
	if (value instanceof SpoutStats) {
	break;
	}
	throw new ClassCastException("Was expecting value of type SpoutStats for field 'spout', but got " + value.getClass().getSimpleName());
	default:
	throw new IllegalArgumentException("Unknown field id " + setField);
	}
	}

	@Override
	protected Object readValue(TProtocol iprot, TField field) throws TException {
	_Fields setField = _Fields.findByThriftId(field.id);
	if (setField != null) {
	switch (setField) {
	case BOLT:
	if (field.type == BOLT_FIELD_DESC.type) {
	BoltStats bolt;
	bolt = new BoltStats();
	bolt.read(iprot);
	return bolt;
	} else {
	TProtocolUtil.skip(iprot, field.type);
	return null;
	}
	case SPOUT:
	if (field.type == SPOUT_FIELD_DESC.type) {
	SpoutStats spout;
	spout = new SpoutStats();
	spout.read(iprot);
	return spout;
	} else {
	TProtocolUtil.skip(iprot, field.type);
	return null;
	}
	default:
	throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
	}
	} else {
	TProtocolUtil.skip(iprot, field.type);
	return null;
	}
	}

	@Override
	protected void writeValue(TProtocol oprot) throws TException {
	switch (setField_) {
	case BOLT:
	BoltStats bolt = (BoltStats)value_;
	bolt.write(oprot);
	return;
	case SPOUT:
	SpoutStats spout = (SpoutStats)value_;
	spout.write(oprot);
	return;
	default:
	throw new IllegalStateException("Cannot write union with unknown field " + setField_);
	}
	}

	@Override
	protected TField getFieldDesc(_Fields setField) {
	switch (setField) {
	case BOLT:
	return BOLT_FIELD_DESC;
	case SPOUT:
	return SPOUT_FIELD_DESC;
	default:
	throw new IllegalArgumentException("Unknown field id " + setField);
	}
	}

	@Override
	protected TStruct getStructDesc() {
	return STRUCT_DESC;
	}

	@Override
	protected _Fields enumForId(short id) {
	return _Fields.findByThriftIdOrThrow(id);
	}

	public BoltStats get_bolt() {
	if (getSetField() == _Fields.BOLT) {
	return (BoltStats)getFieldValue();
	} else {
	throw new RuntimeException("Cannot get field 'bolt' because union is currently set to " + getFieldDesc(getSetField()).name);
	}
	}

	public void set_bolt(BoltStats value) {
	if (value == null) throw new NullPointerException();
	setField_ = _Fields.BOLT;
	value_ = value;
	}

	public SpoutStats get_spout() {
	if (getSetField() == _Fields.SPOUT) {
	return (SpoutStats)getFieldValue();
	} else {
	throw new RuntimeException("Cannot get field 'spout' because union is currently set to " + getFieldDesc(getSetField()).name);
	}
	}

	public void set_spout(SpoutStats value) {
	if (value == null) throw new NullPointerException();
	setField_ = _Fields.SPOUT;
	value_ = value;
	}

	public boolean equals(Object other) {
	if (other instanceof TaskSpecificStats) {
	return equals((TaskSpecificStats)other);
	} else {
	return false;
	}
	}

	public boolean equals(TaskSpecificStats other) {
	return other != null && getSetField() == other.getSetField() && ((value_ instanceof byte[]) ?
	Arrays.equals((byte[])getFieldValue(), (byte[])other.getFieldValue()) : getFieldValue().equals(other.getFieldValue()));
	}

	@Override
	public int compareTo(TaskSpecificStats other) {
	int lastComparison = TBaseHelper.compareTo(getSetField(), other.getSetField());
	if (lastComparison == 0) {
	Object myValue = getFieldValue();
	if (myValue instanceof byte[]) {
	return TBaseHelper.compareTo((byte[])myValue, (byte[])other.getFieldValue());
	} else if (myValue instanceof List) {
	return TBaseHelper.compareTo((List)myValue, (List)other.getFieldValue());
	} else if (myValue instanceof Set) {
	return TBaseHelper.compareTo((Set)myValue, (Set)other.getFieldValue());
	} else if (myValue instanceof Map){
	return TBaseHelper.compareTo((Map)myValue, (Map)other.getFieldValue());
	} else {
	return TBaseHelper.compareTo((Comparable)myValue, (Comparable)other.getFieldValue());
	}
	}
	return lastComparison;
	}


	@Override
	public int hashCode() {
	HashCodeBuilder hcb = new HashCodeBuilder();
	hcb.append(this.getClass().getName());
	TFieldIdEnum setField = getSetField();
	if (setField != null) {
	hcb.append(setField.getThriftFieldId());
	Object value = getFieldValue();
	if (value instanceof TEnum) {
	hcb.append(((TEnum)getFieldValue()).getValue());
	} else {
	hcb.append(value);
	}
	}
	return hcb.toHashCode();
	}
	}