http://git-wip-us.apache.org/repos/asf/storm/blob/1fd1e17f/storm-client/src/jvm/org/apache/storm/generated/Bolt.java ---------------------------------------------------------------------- diff --git a/storm-client/src/jvm/org/apache/storm/generated/Bolt.java b/storm-client/src/jvm/org/apache/storm/generated/Bolt.java index 878ebde..1a3b712 100644 --- a/storm-client/src/jvm/org/apache/storm/generated/Bolt.java +++ b/storm-client/src/jvm/org/apache/storm/generated/Bolt.java @@ -16,53 +16,23 @@ * limitations under the License. */ /** - * Autogenerated by Thrift Compiler (0.9.3) + * Autogenerated by Thrift Compiler (0.11.0) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated */ package org.apache.storm.generated; -import org.apache.thrift.scheme.IScheme; -import org.apache.thrift.scheme.SchemeFactory; -import org.apache.thrift.scheme.StandardScheme; - -import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.protocol.TProtocolException; -import org.apache.thrift.EncodingUtils; -import org.apache.thrift.TException; -import org.apache.thrift.async.AsyncMethodCallback; -import org.apache.thrift.server.AbstractNonblockingServer.*; -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.nio.ByteBuffer; -import java.util.Arrays; -import javax.annotation.Generated; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)") +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) [email protected](value = "Autogenerated by Thrift Compiler (0.11.0)") public class Bolt implements org.apache.thrift.TBase<Bolt, Bolt._Fields>, java.io.Serializable, Cloneable, Comparable<Bolt> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Bolt"); private static final org.apache.thrift.protocol.TField BOLT_OBJECT_FIELD_DESC = new org.apache.thrift.protocol.TField("bolt_object", org.apache.thrift.protocol.TType.STRUCT, (short)1); private static final org.apache.thrift.protocol.TField COMMON_FIELD_DESC = new org.apache.thrift.protocol.TField("common", org.apache.thrift.protocol.TType.STRUCT, (short)2); - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new BoltStandardSchemeFactory()); - schemes.put(TupleScheme.class, new BoltTupleSchemeFactory()); - } + private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new BoltStandardSchemeFactory(); + private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new BoltTupleSchemeFactory(); private ComponentObject bolt_object; // required private ComponentCommon common; // required @@ -72,10 +42,10 @@ public class Bolt implements org.apache.thrift.TBase<Bolt, Bolt._Fields>, java.i BOLT_OBJECT((short)1, "bolt_object"), COMMON((short)2, "common"); - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + private static final java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>(); static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { + for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) { byName.put(field.getFieldName(), field); } } @@ -100,21 +70,21 @@ public class Bolt implements org.apache.thrift.TBase<Bolt, Bolt._Fields>, java.i */ public static _Fields findByThriftIdOrThrow(int fieldId) { _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + if (fields == null) throw new java.lang.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) { + public static _Fields findByName(java.lang.String name) { return byName.get(name); } private final short _thriftId; - private final String _fieldName; + private final java.lang.String _fieldName; - _Fields(short thriftId, String fieldName) { + _Fields(short thriftId, java.lang.String fieldName) { _thriftId = thriftId; _fieldName = fieldName; } @@ -123,20 +93,20 @@ public class Bolt implements org.apache.thrift.TBase<Bolt, Bolt._Fields>, java.i return _thriftId; } - public String getFieldName() { + public java.lang.String getFieldName() { return _fieldName; } } // isset id assignments - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); tmpMap.put(_Fields.BOLT_OBJECT, new org.apache.thrift.meta_data.FieldMetaData("bolt_object", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ComponentObject.class))); tmpMap.put(_Fields.COMMON, new org.apache.thrift.meta_data.FieldMetaData("common", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ComponentCommon.class))); - metaDataMap = Collections.unmodifiableMap(tmpMap); + metaDataMap = java.util.Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(Bolt.class, metaDataMap); } @@ -220,7 +190,7 @@ public class Bolt implements org.apache.thrift.TBase<Bolt, Bolt._Fields>, java.i } } - public void setFieldValue(_Fields field, Object value) { + public void setFieldValue(_Fields field, java.lang.Object value) { switch (field) { case BOLT_OBJECT: if (value == null) { @@ -241,7 +211,7 @@ public class Bolt implements org.apache.thrift.TBase<Bolt, Bolt._Fields>, java.i } } - public Object getFieldValue(_Fields field) { + public java.lang.Object getFieldValue(_Fields field) { switch (field) { case BOLT_OBJECT: return get_bolt_object(); @@ -250,13 +220,13 @@ public class Bolt implements org.apache.thrift.TBase<Bolt, Bolt._Fields>, java.i return get_common(); } - throw new IllegalStateException(); + throw new java.lang.IllegalStateException(); } /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ public boolean isSet(_Fields field) { if (field == null) { - throw new IllegalArgumentException(); + throw new java.lang.IllegalArgumentException(); } switch (field) { @@ -265,11 +235,11 @@ public class Bolt implements org.apache.thrift.TBase<Bolt, Bolt._Fields>, java.i case COMMON: return is_set_common(); } - throw new IllegalStateException(); + throw new java.lang.IllegalStateException(); } @Override - public boolean equals(Object that) { + public boolean equals(java.lang.Object that) { if (that == null) return false; if (that instanceof Bolt) @@ -280,6 +250,8 @@ public class Bolt implements org.apache.thrift.TBase<Bolt, Bolt._Fields>, java.i public boolean equals(Bolt that) { if (that == null) return false; + if (this == that) + return true; boolean this_present_bolt_object = true && this.is_set_bolt_object(); boolean that_present_bolt_object = true && that.is_set_bolt_object(); @@ -304,19 +276,17 @@ public class Bolt implements org.apache.thrift.TBase<Bolt, Bolt._Fields>, java.i @Override public int hashCode() { - List<Object> list = new ArrayList<Object>(); + int hashCode = 1; - boolean present_bolt_object = true && (is_set_bolt_object()); - list.add(present_bolt_object); - if (present_bolt_object) - list.add(bolt_object); + hashCode = hashCode * 8191 + ((is_set_bolt_object()) ? 131071 : 524287); + if (is_set_bolt_object()) + hashCode = hashCode * 8191 + bolt_object.hashCode(); - boolean present_common = true && (is_set_common()); - list.add(present_common); - if (present_common) - list.add(common); + hashCode = hashCode * 8191 + ((is_set_common()) ? 131071 : 524287); + if (is_set_common()) + hashCode = hashCode * 8191 + common.hashCode(); - return list.hashCode(); + return hashCode; } @Override @@ -327,7 +297,7 @@ public class Bolt implements org.apache.thrift.TBase<Bolt, Bolt._Fields>, java.i int lastComparison = 0; - lastComparison = Boolean.valueOf(is_set_bolt_object()).compareTo(other.is_set_bolt_object()); + lastComparison = java.lang.Boolean.valueOf(is_set_bolt_object()).compareTo(other.is_set_bolt_object()); if (lastComparison != 0) { return lastComparison; } @@ -337,7 +307,7 @@ public class Bolt implements org.apache.thrift.TBase<Bolt, Bolt._Fields>, java.i return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_common()).compareTo(other.is_set_common()); + lastComparison = java.lang.Boolean.valueOf(is_set_common()).compareTo(other.is_set_common()); if (lastComparison != 0) { return lastComparison; } @@ -355,16 +325,16 @@ public class Bolt implements org.apache.thrift.TBase<Bolt, Bolt._Fields>, java.i } public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + scheme(iprot).read(iprot, this); } public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + scheme(oprot).write(oprot, this); } @Override - public String toString() { - StringBuilder sb = new StringBuilder("Bolt("); + public java.lang.String toString() { + java.lang.StringBuilder sb = new java.lang.StringBuilder("Bolt("); boolean first = true; sb.append("bolt_object:"); @@ -410,7 +380,7 @@ public class Bolt implements org.apache.thrift.TBase<Bolt, Bolt._Fields>, java.i } } - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException { try { read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); } catch (org.apache.thrift.TException te) { @@ -418,13 +388,13 @@ public class Bolt implements org.apache.thrift.TBase<Bolt, Bolt._Fields>, java.i } } - private static class BoltStandardSchemeFactory implements SchemeFactory { + private static class BoltStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { public BoltStandardScheme getScheme() { return new BoltStandardScheme(); } } - private static class BoltStandardScheme extends StandardScheme<Bolt> { + private static class BoltStandardScheme extends org.apache.thrift.scheme.StandardScheme<Bolt> { public void read(org.apache.thrift.protocol.TProtocol iprot, Bolt struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; @@ -483,24 +453,24 @@ public class Bolt implements org.apache.thrift.TBase<Bolt, Bolt._Fields>, java.i } - private static class BoltTupleSchemeFactory implements SchemeFactory { + private static class BoltTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { public BoltTupleScheme getScheme() { return new BoltTupleScheme(); } } - private static class BoltTupleScheme extends TupleScheme<Bolt> { + private static class BoltTupleScheme extends org.apache.thrift.scheme.TupleScheme<Bolt> { @Override public void write(org.apache.thrift.protocol.TProtocol prot, Bolt struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; + org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot; struct.bolt_object.write(oprot); struct.common.write(oprot); } @Override public void read(org.apache.thrift.protocol.TProtocol prot, Bolt struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; + org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot; struct.bolt_object = new ComponentObject(); struct.bolt_object.read(iprot); struct.set_bolt_object_isSet(true); @@ -510,5 +480,8 @@ public class Bolt implements org.apache.thrift.TBase<Bolt, Bolt._Fields>, java.i } } + private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) { + return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme(); + } }
http://git-wip-us.apache.org/repos/asf/storm/blob/1fd1e17f/storm-client/src/jvm/org/apache/storm/generated/BoltAggregateStats.java ---------------------------------------------------------------------- diff --git a/storm-client/src/jvm/org/apache/storm/generated/BoltAggregateStats.java b/storm-client/src/jvm/org/apache/storm/generated/BoltAggregateStats.java index c5e6bf9..5b1b034 100644 --- a/storm-client/src/jvm/org/apache/storm/generated/BoltAggregateStats.java +++ b/storm-client/src/jvm/org/apache/storm/generated/BoltAggregateStats.java @@ -16,42 +16,15 @@ * limitations under the License. */ /** - * Autogenerated by Thrift Compiler (0.9.3) + * Autogenerated by Thrift Compiler (0.11.0) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated */ package org.apache.storm.generated; -import org.apache.thrift.scheme.IScheme; -import org.apache.thrift.scheme.SchemeFactory; -import org.apache.thrift.scheme.StandardScheme; - -import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.protocol.TProtocolException; -import org.apache.thrift.EncodingUtils; -import org.apache.thrift.TException; -import org.apache.thrift.async.AsyncMethodCallback; -import org.apache.thrift.server.AbstractNonblockingServer.*; -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.nio.ByteBuffer; -import java.util.Arrays; -import javax.annotation.Generated; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)") +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) [email protected](value = "Autogenerated by Thrift Compiler (0.11.0)") public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregateStats, BoltAggregateStats._Fields>, java.io.Serializable, Cloneable, Comparable<BoltAggregateStats> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("BoltAggregateStats"); @@ -60,11 +33,8 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate private static final org.apache.thrift.protocol.TField EXECUTED_FIELD_DESC = new org.apache.thrift.protocol.TField("executed", org.apache.thrift.protocol.TType.I64, (short)3); private static final org.apache.thrift.protocol.TField CAPACITY_FIELD_DESC = new org.apache.thrift.protocol.TField("capacity", org.apache.thrift.protocol.TType.DOUBLE, (short)4); - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new BoltAggregateStatsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new BoltAggregateStatsTupleSchemeFactory()); - } + private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new BoltAggregateStatsStandardSchemeFactory(); + private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new BoltAggregateStatsTupleSchemeFactory(); private double execute_latency_ms; // optional private double process_latency_ms; // optional @@ -78,10 +48,10 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate EXECUTED((short)3, "executed"), CAPACITY((short)4, "capacity"); - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + private static final java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>(); static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { + for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) { byName.put(field.getFieldName(), field); } } @@ -110,21 +80,21 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate */ public static _Fields findByThriftIdOrThrow(int fieldId) { _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + if (fields == null) throw new java.lang.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) { + public static _Fields findByName(java.lang.String name) { return byName.get(name); } private final short _thriftId; - private final String _fieldName; + private final java.lang.String _fieldName; - _Fields(short thriftId, String fieldName) { + _Fields(short thriftId, java.lang.String fieldName) { _thriftId = thriftId; _fieldName = fieldName; } @@ -133,7 +103,7 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate return _thriftId; } - public String getFieldName() { + public java.lang.String getFieldName() { return _fieldName; } } @@ -145,9 +115,9 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate private static final int __CAPACITY_ISSET_ID = 3; private byte __isset_bitfield = 0; private static final _Fields optionals[] = {_Fields.EXECUTE_LATENCY_MS,_Fields.PROCESS_LATENCY_MS,_Fields.EXECUTED,_Fields.CAPACITY}; - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); tmpMap.put(_Fields.EXECUTE_LATENCY_MS, new org.apache.thrift.meta_data.FieldMetaData("execute_latency_ms", org.apache.thrift.TFieldRequirementType.OPTIONAL, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE))); tmpMap.put(_Fields.PROCESS_LATENCY_MS, new org.apache.thrift.meta_data.FieldMetaData("process_latency_ms", org.apache.thrift.TFieldRequirementType.OPTIONAL, @@ -156,7 +126,7 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); tmpMap.put(_Fields.CAPACITY, new org.apache.thrift.meta_data.FieldMetaData("capacity", org.apache.thrift.TFieldRequirementType.OPTIONAL, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE))); - metaDataMap = Collections.unmodifiableMap(tmpMap); + metaDataMap = java.util.Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(BoltAggregateStats.class, metaDataMap); } @@ -200,16 +170,16 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate } public void unset_execute_latency_ms() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __EXECUTE_LATENCY_MS_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __EXECUTE_LATENCY_MS_ISSET_ID); } /** Returns true if field execute_latency_ms is set (has been assigned a value) and false otherwise */ public boolean is_set_execute_latency_ms() { - return EncodingUtils.testBit(__isset_bitfield, __EXECUTE_LATENCY_MS_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __EXECUTE_LATENCY_MS_ISSET_ID); } public void set_execute_latency_ms_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __EXECUTE_LATENCY_MS_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __EXECUTE_LATENCY_MS_ISSET_ID, value); } public double get_process_latency_ms() { @@ -222,16 +192,16 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate } public void unset_process_latency_ms() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __PROCESS_LATENCY_MS_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __PROCESS_LATENCY_MS_ISSET_ID); } /** Returns true if field process_latency_ms is set (has been assigned a value) and false otherwise */ public boolean is_set_process_latency_ms() { - return EncodingUtils.testBit(__isset_bitfield, __PROCESS_LATENCY_MS_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __PROCESS_LATENCY_MS_ISSET_ID); } public void set_process_latency_ms_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __PROCESS_LATENCY_MS_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __PROCESS_LATENCY_MS_ISSET_ID, value); } public long get_executed() { @@ -244,16 +214,16 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate } public void unset_executed() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __EXECUTED_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __EXECUTED_ISSET_ID); } /** Returns true if field executed is set (has been assigned a value) and false otherwise */ public boolean is_set_executed() { - return EncodingUtils.testBit(__isset_bitfield, __EXECUTED_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __EXECUTED_ISSET_ID); } public void set_executed_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __EXECUTED_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __EXECUTED_ISSET_ID, value); } public double get_capacity() { @@ -266,25 +236,25 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate } public void unset_capacity() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __CAPACITY_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __CAPACITY_ISSET_ID); } /** Returns true if field capacity is set (has been assigned a value) and false otherwise */ public boolean is_set_capacity() { - return EncodingUtils.testBit(__isset_bitfield, __CAPACITY_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __CAPACITY_ISSET_ID); } public void set_capacity_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __CAPACITY_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __CAPACITY_ISSET_ID, value); } - public void setFieldValue(_Fields field, Object value) { + public void setFieldValue(_Fields field, java.lang.Object value) { switch (field) { case EXECUTE_LATENCY_MS: if (value == null) { unset_execute_latency_ms(); } else { - set_execute_latency_ms((Double)value); + set_execute_latency_ms((java.lang.Double)value); } break; @@ -292,7 +262,7 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate if (value == null) { unset_process_latency_ms(); } else { - set_process_latency_ms((Double)value); + set_process_latency_ms((java.lang.Double)value); } break; @@ -300,7 +270,7 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate if (value == null) { unset_executed(); } else { - set_executed((Long)value); + set_executed((java.lang.Long)value); } break; @@ -308,14 +278,14 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate if (value == null) { unset_capacity(); } else { - set_capacity((Double)value); + set_capacity((java.lang.Double)value); } break; } } - public Object getFieldValue(_Fields field) { + public java.lang.Object getFieldValue(_Fields field) { switch (field) { case EXECUTE_LATENCY_MS: return get_execute_latency_ms(); @@ -330,13 +300,13 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate return get_capacity(); } - throw new IllegalStateException(); + throw new java.lang.IllegalStateException(); } /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ public boolean isSet(_Fields field) { if (field == null) { - throw new IllegalArgumentException(); + throw new java.lang.IllegalArgumentException(); } switch (field) { @@ -349,11 +319,11 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate case CAPACITY: return is_set_capacity(); } - throw new IllegalStateException(); + throw new java.lang.IllegalStateException(); } @Override - public boolean equals(Object that) { + public boolean equals(java.lang.Object that) { if (that == null) return false; if (that instanceof BoltAggregateStats) @@ -364,6 +334,8 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate public boolean equals(BoltAggregateStats that) { if (that == null) return false; + if (this == that) + return true; boolean this_present_execute_latency_ms = true && this.is_set_execute_latency_ms(); boolean that_present_execute_latency_ms = true && that.is_set_execute_latency_ms(); @@ -406,29 +378,25 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate @Override public int hashCode() { - List<Object> list = new ArrayList<Object>(); + int hashCode = 1; - boolean present_execute_latency_ms = true && (is_set_execute_latency_ms()); - list.add(present_execute_latency_ms); - if (present_execute_latency_ms) - list.add(execute_latency_ms); + hashCode = hashCode * 8191 + ((is_set_execute_latency_ms()) ? 131071 : 524287); + if (is_set_execute_latency_ms()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(execute_latency_ms); - boolean present_process_latency_ms = true && (is_set_process_latency_ms()); - list.add(present_process_latency_ms); - if (present_process_latency_ms) - list.add(process_latency_ms); + hashCode = hashCode * 8191 + ((is_set_process_latency_ms()) ? 131071 : 524287); + if (is_set_process_latency_ms()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(process_latency_ms); - boolean present_executed = true && (is_set_executed()); - list.add(present_executed); - if (present_executed) - list.add(executed); + hashCode = hashCode * 8191 + ((is_set_executed()) ? 131071 : 524287); + if (is_set_executed()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(executed); - boolean present_capacity = true && (is_set_capacity()); - list.add(present_capacity); - if (present_capacity) - list.add(capacity); + hashCode = hashCode * 8191 + ((is_set_capacity()) ? 131071 : 524287); + if (is_set_capacity()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(capacity); - return list.hashCode(); + return hashCode; } @Override @@ -439,7 +407,7 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate int lastComparison = 0; - lastComparison = Boolean.valueOf(is_set_execute_latency_ms()).compareTo(other.is_set_execute_latency_ms()); + lastComparison = java.lang.Boolean.valueOf(is_set_execute_latency_ms()).compareTo(other.is_set_execute_latency_ms()); if (lastComparison != 0) { return lastComparison; } @@ -449,7 +417,7 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_process_latency_ms()).compareTo(other.is_set_process_latency_ms()); + lastComparison = java.lang.Boolean.valueOf(is_set_process_latency_ms()).compareTo(other.is_set_process_latency_ms()); if (lastComparison != 0) { return lastComparison; } @@ -459,7 +427,7 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_executed()).compareTo(other.is_set_executed()); + lastComparison = java.lang.Boolean.valueOf(is_set_executed()).compareTo(other.is_set_executed()); if (lastComparison != 0) { return lastComparison; } @@ -469,7 +437,7 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_capacity()).compareTo(other.is_set_capacity()); + lastComparison = java.lang.Boolean.valueOf(is_set_capacity()).compareTo(other.is_set_capacity()); if (lastComparison != 0) { return lastComparison; } @@ -487,16 +455,16 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate } public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + scheme(iprot).read(iprot, this); } public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + scheme(oprot).write(oprot, this); } @Override - public String toString() { - StringBuilder sb = new StringBuilder("BoltAggregateStats("); + public java.lang.String toString() { + java.lang.StringBuilder sb = new java.lang.StringBuilder("BoltAggregateStats("); boolean first = true; if (is_set_execute_latency_ms()) { @@ -539,7 +507,7 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate } } - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException { try { // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. __isset_bitfield = 0; @@ -549,13 +517,13 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate } } - private static class BoltAggregateStatsStandardSchemeFactory implements SchemeFactory { + private static class BoltAggregateStatsStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { public BoltAggregateStatsStandardScheme getScheme() { return new BoltAggregateStatsStandardScheme(); } } - private static class BoltAggregateStatsStandardScheme extends StandardScheme<BoltAggregateStats> { + private static class BoltAggregateStatsStandardScheme extends org.apache.thrift.scheme.StandardScheme<BoltAggregateStats> { public void read(org.apache.thrift.protocol.TProtocol iprot, BoltAggregateStats struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; @@ -638,18 +606,18 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate } - private static class BoltAggregateStatsTupleSchemeFactory implements SchemeFactory { + private static class BoltAggregateStatsTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { public BoltAggregateStatsTupleScheme getScheme() { return new BoltAggregateStatsTupleScheme(); } } - private static class BoltAggregateStatsTupleScheme extends TupleScheme<BoltAggregateStats> { + private static class BoltAggregateStatsTupleScheme extends org.apache.thrift.scheme.TupleScheme<BoltAggregateStats> { @Override public void write(org.apache.thrift.protocol.TProtocol prot, BoltAggregateStats struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); + org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot; + java.util.BitSet optionals = new java.util.BitSet(); if (struct.is_set_execute_latency_ms()) { optionals.set(0); } @@ -679,8 +647,8 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate @Override public void read(org.apache.thrift.protocol.TProtocol prot, BoltAggregateStats struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(4); + org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot; + java.util.BitSet incoming = iprot.readBitSet(4); if (incoming.get(0)) { struct.execute_latency_ms = iprot.readDouble(); struct.set_execute_latency_ms_isSet(true); @@ -700,5 +668,8 @@ public class BoltAggregateStats implements org.apache.thrift.TBase<BoltAggregate } } + private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) { + return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme(); + } }
