http://git-wip-us.apache.org/repos/asf/storm/blob/1fd1e17f/storm-client/src/jvm/org/apache/storm/generated/BoltStats.java ---------------------------------------------------------------------- diff --git a/storm-client/src/jvm/org/apache/storm/generated/BoltStats.java b/storm-client/src/jvm/org/apache/storm/generated/BoltStats.java index 14800a6..dd84c66 100644 --- a/storm-client/src/jvm/org/apache/storm/generated/BoltStats.java +++ b/storm-client/src/jvm/org/apache/storm/generated/BoltStats.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 BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._Fields>, java.io.Serializable, Cloneable, Comparable<BoltStats> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("BoltStats"); @@ -61,17 +34,14 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ private static final org.apache.thrift.protocol.TField EXECUTED_FIELD_DESC = new org.apache.thrift.protocol.TField("executed", org.apache.thrift.protocol.TType.MAP, (short)4); private static final org.apache.thrift.protocol.TField EXECUTE_MS_AVG_FIELD_DESC = new org.apache.thrift.protocol.TField("execute_ms_avg", org.apache.thrift.protocol.TType.MAP, (short)5); - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new BoltStatsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new BoltStatsTupleSchemeFactory()); - } + private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new BoltStatsStandardSchemeFactory(); + private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new BoltStatsTupleSchemeFactory(); - private Map<String,Map<GlobalStreamId,Long>> acked; // required - private Map<String,Map<GlobalStreamId,Long>> failed; // required - private Map<String,Map<GlobalStreamId,Double>> process_ms_avg; // required - private Map<String,Map<GlobalStreamId,Long>> executed; // required - private Map<String,Map<GlobalStreamId,Double>> execute_ms_avg; // required + private java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>> acked; // required + private java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>> failed; // required + private java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>> process_ms_avg; // required + private java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>> executed; // required + private java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>> execute_ms_avg; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { @@ -81,10 +51,10 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ EXECUTED((short)4, "executed"), EXECUTE_MS_AVG((short)5, "execute_ms_avg"); - 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); } } @@ -115,21 +85,21 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ */ 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; } @@ -138,15 +108,15 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ 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.ACKED, new org.apache.thrift.meta_data.FieldMetaData("acked", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING), @@ -177,7 +147,7 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, GlobalStreamId.class), 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(BoltStats.class, metaDataMap); } @@ -185,11 +155,11 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ } public BoltStats( - Map<String,Map<GlobalStreamId,Long>> acked, - Map<String,Map<GlobalStreamId,Long>> failed, - Map<String,Map<GlobalStreamId,Double>> process_ms_avg, - Map<String,Map<GlobalStreamId,Long>> executed, - Map<String,Map<GlobalStreamId,Double>> execute_ms_avg) + java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>> acked, + java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>> failed, + java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>> process_ms_avg, + java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>> executed, + java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>> execute_ms_avg) { this(); this.acked = acked; @@ -204,23 +174,23 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ */ public BoltStats(BoltStats other) { if (other.is_set_acked()) { - Map<String,Map<GlobalStreamId,Long>> __this__acked = new HashMap<String,Map<GlobalStreamId,Long>>(other.acked.size()); - for (Map.Entry<String, Map<GlobalStreamId,Long>> other_element : other.acked.entrySet()) { + java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>> __this__acked = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>>(other.acked.size()); + for (java.util.Map.Entry<java.lang.String, java.util.Map<GlobalStreamId,java.lang.Long>> other_element : other.acked.entrySet()) { - String other_element_key = other_element.getKey(); - Map<GlobalStreamId,Long> other_element_value = other_element.getValue(); + java.lang.String other_element_key = other_element.getKey(); + java.util.Map<GlobalStreamId,java.lang.Long> other_element_value = other_element.getValue(); - String __this__acked_copy_key = other_element_key; + java.lang.String __this__acked_copy_key = other_element_key; - Map<GlobalStreamId,Long> __this__acked_copy_value = new HashMap<GlobalStreamId,Long>(other_element_value.size()); - for (Map.Entry<GlobalStreamId, Long> other_element_value_element : other_element_value.entrySet()) { + java.util.Map<GlobalStreamId,java.lang.Long> __this__acked_copy_value = new java.util.HashMap<GlobalStreamId,java.lang.Long>(other_element_value.size()); + for (java.util.Map.Entry<GlobalStreamId, java.lang.Long> other_element_value_element : other_element_value.entrySet()) { GlobalStreamId other_element_value_element_key = other_element_value_element.getKey(); - Long other_element_value_element_value = other_element_value_element.getValue(); + java.lang.Long other_element_value_element_value = other_element_value_element.getValue(); GlobalStreamId __this__acked_copy_value_copy_key = new GlobalStreamId(other_element_value_element_key); - Long __this__acked_copy_value_copy_value = other_element_value_element_value; + java.lang.Long __this__acked_copy_value_copy_value = other_element_value_element_value; __this__acked_copy_value.put(__this__acked_copy_value_copy_key, __this__acked_copy_value_copy_value); } @@ -230,23 +200,23 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ this.acked = __this__acked; } if (other.is_set_failed()) { - Map<String,Map<GlobalStreamId,Long>> __this__failed = new HashMap<String,Map<GlobalStreamId,Long>>(other.failed.size()); - for (Map.Entry<String, Map<GlobalStreamId,Long>> other_element : other.failed.entrySet()) { + java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>> __this__failed = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>>(other.failed.size()); + for (java.util.Map.Entry<java.lang.String, java.util.Map<GlobalStreamId,java.lang.Long>> other_element : other.failed.entrySet()) { - String other_element_key = other_element.getKey(); - Map<GlobalStreamId,Long> other_element_value = other_element.getValue(); + java.lang.String other_element_key = other_element.getKey(); + java.util.Map<GlobalStreamId,java.lang.Long> other_element_value = other_element.getValue(); - String __this__failed_copy_key = other_element_key; + java.lang.String __this__failed_copy_key = other_element_key; - Map<GlobalStreamId,Long> __this__failed_copy_value = new HashMap<GlobalStreamId,Long>(other_element_value.size()); - for (Map.Entry<GlobalStreamId, Long> other_element_value_element : other_element_value.entrySet()) { + java.util.Map<GlobalStreamId,java.lang.Long> __this__failed_copy_value = new java.util.HashMap<GlobalStreamId,java.lang.Long>(other_element_value.size()); + for (java.util.Map.Entry<GlobalStreamId, java.lang.Long> other_element_value_element : other_element_value.entrySet()) { GlobalStreamId other_element_value_element_key = other_element_value_element.getKey(); - Long other_element_value_element_value = other_element_value_element.getValue(); + java.lang.Long other_element_value_element_value = other_element_value_element.getValue(); GlobalStreamId __this__failed_copy_value_copy_key = new GlobalStreamId(other_element_value_element_key); - Long __this__failed_copy_value_copy_value = other_element_value_element_value; + java.lang.Long __this__failed_copy_value_copy_value = other_element_value_element_value; __this__failed_copy_value.put(__this__failed_copy_value_copy_key, __this__failed_copy_value_copy_value); } @@ -256,23 +226,23 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ this.failed = __this__failed; } if (other.is_set_process_ms_avg()) { - Map<String,Map<GlobalStreamId,Double>> __this__process_ms_avg = new HashMap<String,Map<GlobalStreamId,Double>>(other.process_ms_avg.size()); - for (Map.Entry<String, Map<GlobalStreamId,Double>> other_element : other.process_ms_avg.entrySet()) { + java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>> __this__process_ms_avg = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>>(other.process_ms_avg.size()); + for (java.util.Map.Entry<java.lang.String, java.util.Map<GlobalStreamId,java.lang.Double>> other_element : other.process_ms_avg.entrySet()) { - String other_element_key = other_element.getKey(); - Map<GlobalStreamId,Double> other_element_value = other_element.getValue(); + java.lang.String other_element_key = other_element.getKey(); + java.util.Map<GlobalStreamId,java.lang.Double> other_element_value = other_element.getValue(); - String __this__process_ms_avg_copy_key = other_element_key; + java.lang.String __this__process_ms_avg_copy_key = other_element_key; - Map<GlobalStreamId,Double> __this__process_ms_avg_copy_value = new HashMap<GlobalStreamId,Double>(other_element_value.size()); - for (Map.Entry<GlobalStreamId, Double> other_element_value_element : other_element_value.entrySet()) { + java.util.Map<GlobalStreamId,java.lang.Double> __this__process_ms_avg_copy_value = new java.util.HashMap<GlobalStreamId,java.lang.Double>(other_element_value.size()); + for (java.util.Map.Entry<GlobalStreamId, java.lang.Double> other_element_value_element : other_element_value.entrySet()) { GlobalStreamId other_element_value_element_key = other_element_value_element.getKey(); - Double other_element_value_element_value = other_element_value_element.getValue(); + java.lang.Double other_element_value_element_value = other_element_value_element.getValue(); GlobalStreamId __this__process_ms_avg_copy_value_copy_key = new GlobalStreamId(other_element_value_element_key); - Double __this__process_ms_avg_copy_value_copy_value = other_element_value_element_value; + java.lang.Double __this__process_ms_avg_copy_value_copy_value = other_element_value_element_value; __this__process_ms_avg_copy_value.put(__this__process_ms_avg_copy_value_copy_key, __this__process_ms_avg_copy_value_copy_value); } @@ -282,23 +252,23 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ this.process_ms_avg = __this__process_ms_avg; } if (other.is_set_executed()) { - Map<String,Map<GlobalStreamId,Long>> __this__executed = new HashMap<String,Map<GlobalStreamId,Long>>(other.executed.size()); - for (Map.Entry<String, Map<GlobalStreamId,Long>> other_element : other.executed.entrySet()) { + java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>> __this__executed = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>>(other.executed.size()); + for (java.util.Map.Entry<java.lang.String, java.util.Map<GlobalStreamId,java.lang.Long>> other_element : other.executed.entrySet()) { - String other_element_key = other_element.getKey(); - Map<GlobalStreamId,Long> other_element_value = other_element.getValue(); + java.lang.String other_element_key = other_element.getKey(); + java.util.Map<GlobalStreamId,java.lang.Long> other_element_value = other_element.getValue(); - String __this__executed_copy_key = other_element_key; + java.lang.String __this__executed_copy_key = other_element_key; - Map<GlobalStreamId,Long> __this__executed_copy_value = new HashMap<GlobalStreamId,Long>(other_element_value.size()); - for (Map.Entry<GlobalStreamId, Long> other_element_value_element : other_element_value.entrySet()) { + java.util.Map<GlobalStreamId,java.lang.Long> __this__executed_copy_value = new java.util.HashMap<GlobalStreamId,java.lang.Long>(other_element_value.size()); + for (java.util.Map.Entry<GlobalStreamId, java.lang.Long> other_element_value_element : other_element_value.entrySet()) { GlobalStreamId other_element_value_element_key = other_element_value_element.getKey(); - Long other_element_value_element_value = other_element_value_element.getValue(); + java.lang.Long other_element_value_element_value = other_element_value_element.getValue(); GlobalStreamId __this__executed_copy_value_copy_key = new GlobalStreamId(other_element_value_element_key); - Long __this__executed_copy_value_copy_value = other_element_value_element_value; + java.lang.Long __this__executed_copy_value_copy_value = other_element_value_element_value; __this__executed_copy_value.put(__this__executed_copy_value_copy_key, __this__executed_copy_value_copy_value); } @@ -308,23 +278,23 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ this.executed = __this__executed; } if (other.is_set_execute_ms_avg()) { - Map<String,Map<GlobalStreamId,Double>> __this__execute_ms_avg = new HashMap<String,Map<GlobalStreamId,Double>>(other.execute_ms_avg.size()); - for (Map.Entry<String, Map<GlobalStreamId,Double>> other_element : other.execute_ms_avg.entrySet()) { + java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>> __this__execute_ms_avg = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>>(other.execute_ms_avg.size()); + for (java.util.Map.Entry<java.lang.String, java.util.Map<GlobalStreamId,java.lang.Double>> other_element : other.execute_ms_avg.entrySet()) { - String other_element_key = other_element.getKey(); - Map<GlobalStreamId,Double> other_element_value = other_element.getValue(); + java.lang.String other_element_key = other_element.getKey(); + java.util.Map<GlobalStreamId,java.lang.Double> other_element_value = other_element.getValue(); - String __this__execute_ms_avg_copy_key = other_element_key; + java.lang.String __this__execute_ms_avg_copy_key = other_element_key; - Map<GlobalStreamId,Double> __this__execute_ms_avg_copy_value = new HashMap<GlobalStreamId,Double>(other_element_value.size()); - for (Map.Entry<GlobalStreamId, Double> other_element_value_element : other_element_value.entrySet()) { + java.util.Map<GlobalStreamId,java.lang.Double> __this__execute_ms_avg_copy_value = new java.util.HashMap<GlobalStreamId,java.lang.Double>(other_element_value.size()); + for (java.util.Map.Entry<GlobalStreamId, java.lang.Double> other_element_value_element : other_element_value.entrySet()) { GlobalStreamId other_element_value_element_key = other_element_value_element.getKey(); - Double other_element_value_element_value = other_element_value_element.getValue(); + java.lang.Double other_element_value_element_value = other_element_value_element.getValue(); GlobalStreamId __this__execute_ms_avg_copy_value_copy_key = new GlobalStreamId(other_element_value_element_key); - Double __this__execute_ms_avg_copy_value_copy_value = other_element_value_element_value; + java.lang.Double __this__execute_ms_avg_copy_value_copy_value = other_element_value_element_value; __this__execute_ms_avg_copy_value.put(__this__execute_ms_avg_copy_value_copy_key, __this__execute_ms_avg_copy_value_copy_value); } @@ -352,18 +322,18 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ return (this.acked == null) ? 0 : this.acked.size(); } - public void put_to_acked(String key, Map<GlobalStreamId,Long> val) { + public void put_to_acked(java.lang.String key, java.util.Map<GlobalStreamId,java.lang.Long> val) { if (this.acked == null) { - this.acked = new HashMap<String,Map<GlobalStreamId,Long>>(); + this.acked = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>>(); } this.acked.put(key, val); } - public Map<String,Map<GlobalStreamId,Long>> get_acked() { + public java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>> get_acked() { return this.acked; } - public void set_acked(Map<String,Map<GlobalStreamId,Long>> acked) { + public void set_acked(java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>> acked) { this.acked = acked; } @@ -386,18 +356,18 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ return (this.failed == null) ? 0 : this.failed.size(); } - public void put_to_failed(String key, Map<GlobalStreamId,Long> val) { + public void put_to_failed(java.lang.String key, java.util.Map<GlobalStreamId,java.lang.Long> val) { if (this.failed == null) { - this.failed = new HashMap<String,Map<GlobalStreamId,Long>>(); + this.failed = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>>(); } this.failed.put(key, val); } - public Map<String,Map<GlobalStreamId,Long>> get_failed() { + public java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>> get_failed() { return this.failed; } - public void set_failed(Map<String,Map<GlobalStreamId,Long>> failed) { + public void set_failed(java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>> failed) { this.failed = failed; } @@ -420,18 +390,18 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ return (this.process_ms_avg == null) ? 0 : this.process_ms_avg.size(); } - public void put_to_process_ms_avg(String key, Map<GlobalStreamId,Double> val) { + public void put_to_process_ms_avg(java.lang.String key, java.util.Map<GlobalStreamId,java.lang.Double> val) { if (this.process_ms_avg == null) { - this.process_ms_avg = new HashMap<String,Map<GlobalStreamId,Double>>(); + this.process_ms_avg = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>>(); } this.process_ms_avg.put(key, val); } - public Map<String,Map<GlobalStreamId,Double>> get_process_ms_avg() { + public java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>> get_process_ms_avg() { return this.process_ms_avg; } - public void set_process_ms_avg(Map<String,Map<GlobalStreamId,Double>> process_ms_avg) { + public void set_process_ms_avg(java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>> process_ms_avg) { this.process_ms_avg = process_ms_avg; } @@ -454,18 +424,18 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ return (this.executed == null) ? 0 : this.executed.size(); } - public void put_to_executed(String key, Map<GlobalStreamId,Long> val) { + public void put_to_executed(java.lang.String key, java.util.Map<GlobalStreamId,java.lang.Long> val) { if (this.executed == null) { - this.executed = new HashMap<String,Map<GlobalStreamId,Long>>(); + this.executed = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>>(); } this.executed.put(key, val); } - public Map<String,Map<GlobalStreamId,Long>> get_executed() { + public java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>> get_executed() { return this.executed; } - public void set_executed(Map<String,Map<GlobalStreamId,Long>> executed) { + public void set_executed(java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>> executed) { this.executed = executed; } @@ -488,18 +458,18 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ return (this.execute_ms_avg == null) ? 0 : this.execute_ms_avg.size(); } - public void put_to_execute_ms_avg(String key, Map<GlobalStreamId,Double> val) { + public void put_to_execute_ms_avg(java.lang.String key, java.util.Map<GlobalStreamId,java.lang.Double> val) { if (this.execute_ms_avg == null) { - this.execute_ms_avg = new HashMap<String,Map<GlobalStreamId,Double>>(); + this.execute_ms_avg = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>>(); } this.execute_ms_avg.put(key, val); } - public Map<String,Map<GlobalStreamId,Double>> get_execute_ms_avg() { + public java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>> get_execute_ms_avg() { return this.execute_ms_avg; } - public void set_execute_ms_avg(Map<String,Map<GlobalStreamId,Double>> execute_ms_avg) { + public void set_execute_ms_avg(java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>> execute_ms_avg) { this.execute_ms_avg = execute_ms_avg; } @@ -518,13 +488,13 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ } } - public void setFieldValue(_Fields field, Object value) { + public void setFieldValue(_Fields field, java.lang.Object value) { switch (field) { case ACKED: if (value == null) { unset_acked(); } else { - set_acked((Map<String,Map<GlobalStreamId,Long>>)value); + set_acked((java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>>)value); } break; @@ -532,7 +502,7 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ if (value == null) { unset_failed(); } else { - set_failed((Map<String,Map<GlobalStreamId,Long>>)value); + set_failed((java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>>)value); } break; @@ -540,7 +510,7 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ if (value == null) { unset_process_ms_avg(); } else { - set_process_ms_avg((Map<String,Map<GlobalStreamId,Double>>)value); + set_process_ms_avg((java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>>)value); } break; @@ -548,7 +518,7 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ if (value == null) { unset_executed(); } else { - set_executed((Map<String,Map<GlobalStreamId,Long>>)value); + set_executed((java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>>)value); } break; @@ -556,14 +526,14 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ if (value == null) { unset_execute_ms_avg(); } else { - set_execute_ms_avg((Map<String,Map<GlobalStreamId,Double>>)value); + set_execute_ms_avg((java.util.Map<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>>)value); } break; } } - public Object getFieldValue(_Fields field) { + public java.lang.Object getFieldValue(_Fields field) { switch (field) { case ACKED: return get_acked(); @@ -581,13 +551,13 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ return get_execute_ms_avg(); } - 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) { @@ -602,11 +572,11 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ case EXECUTE_MS_AVG: return is_set_execute_ms_avg(); } - 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 BoltStats) @@ -617,6 +587,8 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ public boolean equals(BoltStats that) { if (that == null) return false; + if (this == that) + return true; boolean this_present_acked = true && this.is_set_acked(); boolean that_present_acked = true && that.is_set_acked(); @@ -668,34 +640,29 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ @Override public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_acked = true && (is_set_acked()); - list.add(present_acked); - if (present_acked) - list.add(acked); - - boolean present_failed = true && (is_set_failed()); - list.add(present_failed); - if (present_failed) - list.add(failed); - - boolean present_process_ms_avg = true && (is_set_process_ms_avg()); - list.add(present_process_ms_avg); - if (present_process_ms_avg) - list.add(process_ms_avg); - - boolean present_executed = true && (is_set_executed()); - list.add(present_executed); - if (present_executed) - list.add(executed); - - boolean present_execute_ms_avg = true && (is_set_execute_ms_avg()); - list.add(present_execute_ms_avg); - if (present_execute_ms_avg) - list.add(execute_ms_avg); - - return list.hashCode(); + int hashCode = 1; + + hashCode = hashCode * 8191 + ((is_set_acked()) ? 131071 : 524287); + if (is_set_acked()) + hashCode = hashCode * 8191 + acked.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_failed()) ? 131071 : 524287); + if (is_set_failed()) + hashCode = hashCode * 8191 + failed.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_process_ms_avg()) ? 131071 : 524287); + if (is_set_process_ms_avg()) + hashCode = hashCode * 8191 + process_ms_avg.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_executed()) ? 131071 : 524287); + if (is_set_executed()) + hashCode = hashCode * 8191 + executed.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_execute_ms_avg()) ? 131071 : 524287); + if (is_set_execute_ms_avg()) + hashCode = hashCode * 8191 + execute_ms_avg.hashCode(); + + return hashCode; } @Override @@ -706,7 +673,7 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ int lastComparison = 0; - lastComparison = Boolean.valueOf(is_set_acked()).compareTo(other.is_set_acked()); + lastComparison = java.lang.Boolean.valueOf(is_set_acked()).compareTo(other.is_set_acked()); if (lastComparison != 0) { return lastComparison; } @@ -716,7 +683,7 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_failed()).compareTo(other.is_set_failed()); + lastComparison = java.lang.Boolean.valueOf(is_set_failed()).compareTo(other.is_set_failed()); if (lastComparison != 0) { return lastComparison; } @@ -726,7 +693,7 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_process_ms_avg()).compareTo(other.is_set_process_ms_avg()); + lastComparison = java.lang.Boolean.valueOf(is_set_process_ms_avg()).compareTo(other.is_set_process_ms_avg()); if (lastComparison != 0) { return lastComparison; } @@ -736,7 +703,7 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ 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; } @@ -746,7 +713,7 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_execute_ms_avg()).compareTo(other.is_set_execute_ms_avg()); + lastComparison = java.lang.Boolean.valueOf(is_set_execute_ms_avg()).compareTo(other.is_set_execute_ms_avg()); if (lastComparison != 0) { return lastComparison; } @@ -764,16 +731,16 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ } 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("BoltStats("); + public java.lang.String toString() { + java.lang.StringBuilder sb = new java.lang.StringBuilder("BoltStats("); boolean first = true; sb.append("acked:"); @@ -852,7 +819,7 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ } } - 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) { @@ -860,13 +827,13 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ } } - private static class BoltStatsStandardSchemeFactory implements SchemeFactory { + private static class BoltStatsStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { public BoltStatsStandardScheme getScheme() { return new BoltStatsStandardScheme(); } } - private static class BoltStatsStandardScheme extends StandardScheme<BoltStats> { + private static class BoltStatsStandardScheme extends org.apache.thrift.scheme.StandardScheme<BoltStats> { public void read(org.apache.thrift.protocol.TProtocol iprot, BoltStats struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; @@ -882,15 +849,15 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { org.apache.thrift.protocol.TMap _map160 = iprot.readMapBegin(); - struct.acked = new HashMap<String,Map<GlobalStreamId,Long>>(2*_map160.size); - String _key161; - Map<GlobalStreamId,Long> _val162; + struct.acked = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>>(2*_map160.size); + java.lang.String _key161; + java.util.Map<GlobalStreamId,java.lang.Long> _val162; for (int _i163 = 0; _i163 < _map160.size; ++_i163) { _key161 = iprot.readString(); { org.apache.thrift.protocol.TMap _map164 = iprot.readMapBegin(); - _val162 = new HashMap<GlobalStreamId,Long>(2*_map164.size); + _val162 = new java.util.HashMap<GlobalStreamId,java.lang.Long>(2*_map164.size); GlobalStreamId _key165; long _val166; for (int _i167 = 0; _i167 < _map164.size; ++_i167) @@ -915,15 +882,15 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { org.apache.thrift.protocol.TMap _map168 = iprot.readMapBegin(); - struct.failed = new HashMap<String,Map<GlobalStreamId,Long>>(2*_map168.size); - String _key169; - Map<GlobalStreamId,Long> _val170; + struct.failed = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>>(2*_map168.size); + java.lang.String _key169; + java.util.Map<GlobalStreamId,java.lang.Long> _val170; for (int _i171 = 0; _i171 < _map168.size; ++_i171) { _key169 = iprot.readString(); { org.apache.thrift.protocol.TMap _map172 = iprot.readMapBegin(); - _val170 = new HashMap<GlobalStreamId,Long>(2*_map172.size); + _val170 = new java.util.HashMap<GlobalStreamId,java.lang.Long>(2*_map172.size); GlobalStreamId _key173; long _val174; for (int _i175 = 0; _i175 < _map172.size; ++_i175) @@ -948,15 +915,15 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { org.apache.thrift.protocol.TMap _map176 = iprot.readMapBegin(); - struct.process_ms_avg = new HashMap<String,Map<GlobalStreamId,Double>>(2*_map176.size); - String _key177; - Map<GlobalStreamId,Double> _val178; + struct.process_ms_avg = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>>(2*_map176.size); + java.lang.String _key177; + java.util.Map<GlobalStreamId,java.lang.Double> _val178; for (int _i179 = 0; _i179 < _map176.size; ++_i179) { _key177 = iprot.readString(); { org.apache.thrift.protocol.TMap _map180 = iprot.readMapBegin(); - _val178 = new HashMap<GlobalStreamId,Double>(2*_map180.size); + _val178 = new java.util.HashMap<GlobalStreamId,java.lang.Double>(2*_map180.size); GlobalStreamId _key181; double _val182; for (int _i183 = 0; _i183 < _map180.size; ++_i183) @@ -981,15 +948,15 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { org.apache.thrift.protocol.TMap _map184 = iprot.readMapBegin(); - struct.executed = new HashMap<String,Map<GlobalStreamId,Long>>(2*_map184.size); - String _key185; - Map<GlobalStreamId,Long> _val186; + struct.executed = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>>(2*_map184.size); + java.lang.String _key185; + java.util.Map<GlobalStreamId,java.lang.Long> _val186; for (int _i187 = 0; _i187 < _map184.size; ++_i187) { _key185 = iprot.readString(); { org.apache.thrift.protocol.TMap _map188 = iprot.readMapBegin(); - _val186 = new HashMap<GlobalStreamId,Long>(2*_map188.size); + _val186 = new java.util.HashMap<GlobalStreamId,java.lang.Long>(2*_map188.size); GlobalStreamId _key189; long _val190; for (int _i191 = 0; _i191 < _map188.size; ++_i191) @@ -1014,15 +981,15 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { org.apache.thrift.protocol.TMap _map192 = iprot.readMapBegin(); - struct.execute_ms_avg = new HashMap<String,Map<GlobalStreamId,Double>>(2*_map192.size); - String _key193; - Map<GlobalStreamId,Double> _val194; + struct.execute_ms_avg = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>>(2*_map192.size); + java.lang.String _key193; + java.util.Map<GlobalStreamId,java.lang.Double> _val194; for (int _i195 = 0; _i195 < _map192.size; ++_i195) { _key193 = iprot.readString(); { org.apache.thrift.protocol.TMap _map196 = iprot.readMapBegin(); - _val194 = new HashMap<GlobalStreamId,Double>(2*_map196.size); + _val194 = new java.util.HashMap<GlobalStreamId,java.lang.Double>(2*_map196.size); GlobalStreamId _key197; double _val198; for (int _i199 = 0; _i199 < _map196.size; ++_i199) @@ -1060,12 +1027,12 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ oprot.writeFieldBegin(ACKED_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, struct.acked.size())); - for (Map.Entry<String, Map<GlobalStreamId,Long>> _iter200 : struct.acked.entrySet()) + for (java.util.Map.Entry<java.lang.String, java.util.Map<GlobalStreamId,java.lang.Long>> _iter200 : struct.acked.entrySet()) { oprot.writeString(_iter200.getKey()); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.I64, _iter200.getValue().size())); - for (Map.Entry<GlobalStreamId, Long> _iter201 : _iter200.getValue().entrySet()) + for (java.util.Map.Entry<GlobalStreamId, java.lang.Long> _iter201 : _iter200.getValue().entrySet()) { _iter201.getKey().write(oprot); oprot.writeI64(_iter201.getValue()); @@ -1081,12 +1048,12 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ oprot.writeFieldBegin(FAILED_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, struct.failed.size())); - for (Map.Entry<String, Map<GlobalStreamId,Long>> _iter202 : struct.failed.entrySet()) + for (java.util.Map.Entry<java.lang.String, java.util.Map<GlobalStreamId,java.lang.Long>> _iter202 : struct.failed.entrySet()) { oprot.writeString(_iter202.getKey()); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.I64, _iter202.getValue().size())); - for (Map.Entry<GlobalStreamId, Long> _iter203 : _iter202.getValue().entrySet()) + for (java.util.Map.Entry<GlobalStreamId, java.lang.Long> _iter203 : _iter202.getValue().entrySet()) { _iter203.getKey().write(oprot); oprot.writeI64(_iter203.getValue()); @@ -1102,12 +1069,12 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ oprot.writeFieldBegin(PROCESS_MS_AVG_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, struct.process_ms_avg.size())); - for (Map.Entry<String, Map<GlobalStreamId,Double>> _iter204 : struct.process_ms_avg.entrySet()) + for (java.util.Map.Entry<java.lang.String, java.util.Map<GlobalStreamId,java.lang.Double>> _iter204 : struct.process_ms_avg.entrySet()) { oprot.writeString(_iter204.getKey()); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.DOUBLE, _iter204.getValue().size())); - for (Map.Entry<GlobalStreamId, Double> _iter205 : _iter204.getValue().entrySet()) + for (java.util.Map.Entry<GlobalStreamId, java.lang.Double> _iter205 : _iter204.getValue().entrySet()) { _iter205.getKey().write(oprot); oprot.writeDouble(_iter205.getValue()); @@ -1123,12 +1090,12 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ oprot.writeFieldBegin(EXECUTED_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, struct.executed.size())); - for (Map.Entry<String, Map<GlobalStreamId,Long>> _iter206 : struct.executed.entrySet()) + for (java.util.Map.Entry<java.lang.String, java.util.Map<GlobalStreamId,java.lang.Long>> _iter206 : struct.executed.entrySet()) { oprot.writeString(_iter206.getKey()); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.I64, _iter206.getValue().size())); - for (Map.Entry<GlobalStreamId, Long> _iter207 : _iter206.getValue().entrySet()) + for (java.util.Map.Entry<GlobalStreamId, java.lang.Long> _iter207 : _iter206.getValue().entrySet()) { _iter207.getKey().write(oprot); oprot.writeI64(_iter207.getValue()); @@ -1144,12 +1111,12 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ oprot.writeFieldBegin(EXECUTE_MS_AVG_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, struct.execute_ms_avg.size())); - for (Map.Entry<String, Map<GlobalStreamId,Double>> _iter208 : struct.execute_ms_avg.entrySet()) + for (java.util.Map.Entry<java.lang.String, java.util.Map<GlobalStreamId,java.lang.Double>> _iter208 : struct.execute_ms_avg.entrySet()) { oprot.writeString(_iter208.getKey()); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.DOUBLE, _iter208.getValue().size())); - for (Map.Entry<GlobalStreamId, Double> _iter209 : _iter208.getValue().entrySet()) + for (java.util.Map.Entry<GlobalStreamId, java.lang.Double> _iter209 : _iter208.getValue().entrySet()) { _iter209.getKey().write(oprot); oprot.writeDouble(_iter209.getValue()); @@ -1167,25 +1134,25 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ } - private static class BoltStatsTupleSchemeFactory implements SchemeFactory { + private static class BoltStatsTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { public BoltStatsTupleScheme getScheme() { return new BoltStatsTupleScheme(); } } - private static class BoltStatsTupleScheme extends TupleScheme<BoltStats> { + private static class BoltStatsTupleScheme extends org.apache.thrift.scheme.TupleScheme<BoltStats> { @Override public void write(org.apache.thrift.protocol.TProtocol prot, BoltStats struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; + org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot; { oprot.writeI32(struct.acked.size()); - for (Map.Entry<String, Map<GlobalStreamId,Long>> _iter210 : struct.acked.entrySet()) + for (java.util.Map.Entry<java.lang.String, java.util.Map<GlobalStreamId,java.lang.Long>> _iter210 : struct.acked.entrySet()) { oprot.writeString(_iter210.getKey()); { oprot.writeI32(_iter210.getValue().size()); - for (Map.Entry<GlobalStreamId, Long> _iter211 : _iter210.getValue().entrySet()) + for (java.util.Map.Entry<GlobalStreamId, java.lang.Long> _iter211 : _iter210.getValue().entrySet()) { _iter211.getKey().write(oprot); oprot.writeI64(_iter211.getValue()); @@ -1195,12 +1162,12 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ } { oprot.writeI32(struct.failed.size()); - for (Map.Entry<String, Map<GlobalStreamId,Long>> _iter212 : struct.failed.entrySet()) + for (java.util.Map.Entry<java.lang.String, java.util.Map<GlobalStreamId,java.lang.Long>> _iter212 : struct.failed.entrySet()) { oprot.writeString(_iter212.getKey()); { oprot.writeI32(_iter212.getValue().size()); - for (Map.Entry<GlobalStreamId, Long> _iter213 : _iter212.getValue().entrySet()) + for (java.util.Map.Entry<GlobalStreamId, java.lang.Long> _iter213 : _iter212.getValue().entrySet()) { _iter213.getKey().write(oprot); oprot.writeI64(_iter213.getValue()); @@ -1210,12 +1177,12 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ } { oprot.writeI32(struct.process_ms_avg.size()); - for (Map.Entry<String, Map<GlobalStreamId,Double>> _iter214 : struct.process_ms_avg.entrySet()) + for (java.util.Map.Entry<java.lang.String, java.util.Map<GlobalStreamId,java.lang.Double>> _iter214 : struct.process_ms_avg.entrySet()) { oprot.writeString(_iter214.getKey()); { oprot.writeI32(_iter214.getValue().size()); - for (Map.Entry<GlobalStreamId, Double> _iter215 : _iter214.getValue().entrySet()) + for (java.util.Map.Entry<GlobalStreamId, java.lang.Double> _iter215 : _iter214.getValue().entrySet()) { _iter215.getKey().write(oprot); oprot.writeDouble(_iter215.getValue()); @@ -1225,12 +1192,12 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ } { oprot.writeI32(struct.executed.size()); - for (Map.Entry<String, Map<GlobalStreamId,Long>> _iter216 : struct.executed.entrySet()) + for (java.util.Map.Entry<java.lang.String, java.util.Map<GlobalStreamId,java.lang.Long>> _iter216 : struct.executed.entrySet()) { oprot.writeString(_iter216.getKey()); { oprot.writeI32(_iter216.getValue().size()); - for (Map.Entry<GlobalStreamId, Long> _iter217 : _iter216.getValue().entrySet()) + for (java.util.Map.Entry<GlobalStreamId, java.lang.Long> _iter217 : _iter216.getValue().entrySet()) { _iter217.getKey().write(oprot); oprot.writeI64(_iter217.getValue()); @@ -1240,12 +1207,12 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ } { oprot.writeI32(struct.execute_ms_avg.size()); - for (Map.Entry<String, Map<GlobalStreamId,Double>> _iter218 : struct.execute_ms_avg.entrySet()) + for (java.util.Map.Entry<java.lang.String, java.util.Map<GlobalStreamId,java.lang.Double>> _iter218 : struct.execute_ms_avg.entrySet()) { oprot.writeString(_iter218.getKey()); { oprot.writeI32(_iter218.getValue().size()); - for (Map.Entry<GlobalStreamId, Double> _iter219 : _iter218.getValue().entrySet()) + for (java.util.Map.Entry<GlobalStreamId, java.lang.Double> _iter219 : _iter218.getValue().entrySet()) { _iter219.getKey().write(oprot); oprot.writeDouble(_iter219.getValue()); @@ -1257,18 +1224,18 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ @Override public void read(org.apache.thrift.protocol.TProtocol prot, BoltStats struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; + org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot; { org.apache.thrift.protocol.TMap _map220 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, iprot.readI32()); - struct.acked = new HashMap<String,Map<GlobalStreamId,Long>>(2*_map220.size); - String _key221; - Map<GlobalStreamId,Long> _val222; + struct.acked = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>>(2*_map220.size); + java.lang.String _key221; + java.util.Map<GlobalStreamId,java.lang.Long> _val222; for (int _i223 = 0; _i223 < _map220.size; ++_i223) { _key221 = iprot.readString(); { org.apache.thrift.protocol.TMap _map224 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.I64, iprot.readI32()); - _val222 = new HashMap<GlobalStreamId,Long>(2*_map224.size); + _val222 = new java.util.HashMap<GlobalStreamId,java.lang.Long>(2*_map224.size); GlobalStreamId _key225; long _val226; for (int _i227 = 0; _i227 < _map224.size; ++_i227) @@ -1285,15 +1252,15 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ struct.set_acked_isSet(true); { org.apache.thrift.protocol.TMap _map228 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, iprot.readI32()); - struct.failed = new HashMap<String,Map<GlobalStreamId,Long>>(2*_map228.size); - String _key229; - Map<GlobalStreamId,Long> _val230; + struct.failed = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>>(2*_map228.size); + java.lang.String _key229; + java.util.Map<GlobalStreamId,java.lang.Long> _val230; for (int _i231 = 0; _i231 < _map228.size; ++_i231) { _key229 = iprot.readString(); { org.apache.thrift.protocol.TMap _map232 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.I64, iprot.readI32()); - _val230 = new HashMap<GlobalStreamId,Long>(2*_map232.size); + _val230 = new java.util.HashMap<GlobalStreamId,java.lang.Long>(2*_map232.size); GlobalStreamId _key233; long _val234; for (int _i235 = 0; _i235 < _map232.size; ++_i235) @@ -1310,15 +1277,15 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ struct.set_failed_isSet(true); { org.apache.thrift.protocol.TMap _map236 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, iprot.readI32()); - struct.process_ms_avg = new HashMap<String,Map<GlobalStreamId,Double>>(2*_map236.size); - String _key237; - Map<GlobalStreamId,Double> _val238; + struct.process_ms_avg = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>>(2*_map236.size); + java.lang.String _key237; + java.util.Map<GlobalStreamId,java.lang.Double> _val238; for (int _i239 = 0; _i239 < _map236.size; ++_i239) { _key237 = iprot.readString(); { org.apache.thrift.protocol.TMap _map240 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.DOUBLE, iprot.readI32()); - _val238 = new HashMap<GlobalStreamId,Double>(2*_map240.size); + _val238 = new java.util.HashMap<GlobalStreamId,java.lang.Double>(2*_map240.size); GlobalStreamId _key241; double _val242; for (int _i243 = 0; _i243 < _map240.size; ++_i243) @@ -1335,15 +1302,15 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ struct.set_process_ms_avg_isSet(true); { org.apache.thrift.protocol.TMap _map244 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, iprot.readI32()); - struct.executed = new HashMap<String,Map<GlobalStreamId,Long>>(2*_map244.size); - String _key245; - Map<GlobalStreamId,Long> _val246; + struct.executed = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Long>>(2*_map244.size); + java.lang.String _key245; + java.util.Map<GlobalStreamId,java.lang.Long> _val246; for (int _i247 = 0; _i247 < _map244.size; ++_i247) { _key245 = iprot.readString(); { org.apache.thrift.protocol.TMap _map248 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.I64, iprot.readI32()); - _val246 = new HashMap<GlobalStreamId,Long>(2*_map248.size); + _val246 = new java.util.HashMap<GlobalStreamId,java.lang.Long>(2*_map248.size); GlobalStreamId _key249; long _val250; for (int _i251 = 0; _i251 < _map248.size; ++_i251) @@ -1360,15 +1327,15 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ struct.set_executed_isSet(true); { org.apache.thrift.protocol.TMap _map252 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, iprot.readI32()); - struct.execute_ms_avg = new HashMap<String,Map<GlobalStreamId,Double>>(2*_map252.size); - String _key253; - Map<GlobalStreamId,Double> _val254; + struct.execute_ms_avg = new java.util.HashMap<java.lang.String,java.util.Map<GlobalStreamId,java.lang.Double>>(2*_map252.size); + java.lang.String _key253; + java.util.Map<GlobalStreamId,java.lang.Double> _val254; for (int _i255 = 0; _i255 < _map252.size; ++_i255) { _key253 = iprot.readString(); { org.apache.thrift.protocol.TMap _map256 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.DOUBLE, iprot.readI32()); - _val254 = new HashMap<GlobalStreamId,Double>(2*_map256.size); + _val254 = new java.util.HashMap<GlobalStreamId,java.lang.Double>(2*_map256.size); GlobalStreamId _key257; double _val258; for (int _i259 = 0; _i259 < _map256.size; ++_i259) @@ -1386,5 +1353,8 @@ public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._ } } + 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/ClusterSummary.java ---------------------------------------------------------------------- diff --git a/storm-client/src/jvm/org/apache/storm/generated/ClusterSummary.java b/storm-client/src/jvm/org/apache/storm/generated/ClusterSummary.java index 4ca5862..1f8c08f 100644 --- a/storm-client/src/jvm/org/apache/storm/generated/ClusterSummary.java +++ b/storm-client/src/jvm/org/apache/storm/generated/ClusterSummary.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 ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, ClusterSummary._Fields>, java.io.Serializable, Cloneable, Comparable<ClusterSummary> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ClusterSummary"); @@ -60,16 +33,13 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C private static final org.apache.thrift.protocol.TField TOPOLOGIES_FIELD_DESC = new org.apache.thrift.protocol.TField("topologies", org.apache.thrift.protocol.TType.LIST, (short)3); private static final org.apache.thrift.protocol.TField NIMBUSES_FIELD_DESC = new org.apache.thrift.protocol.TField("nimbuses", org.apache.thrift.protocol.TType.LIST, (short)4); - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new ClusterSummaryStandardSchemeFactory()); - schemes.put(TupleScheme.class, new ClusterSummaryTupleSchemeFactory()); - } + private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new ClusterSummaryStandardSchemeFactory(); + private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new ClusterSummaryTupleSchemeFactory(); - private List<SupervisorSummary> supervisors; // required + private java.util.List<SupervisorSummary> supervisors; // required private int nimbus_uptime_secs; // optional - private List<TopologySummary> topologies; // required - private List<NimbusSummary> nimbuses; // required + private java.util.List<TopologySummary> topologies; // required + private java.util.List<NimbusSummary> nimbuses; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { @@ -78,10 +48,10 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C TOPOLOGIES((short)3, "topologies"), NIMBUSES((short)4, "nimbuses"); - 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 ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C */ 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 ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C return _thriftId; } - public String getFieldName() { + public java.lang.String getFieldName() { return _fieldName; } } @@ -142,9 +112,9 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C private static final int __NIMBUS_UPTIME_SECS_ISSET_ID = 0; private byte __isset_bitfield = 0; private static final _Fields optionals[] = {_Fields.NIMBUS_UPTIME_SECS}; - 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.SUPERVISORS, new org.apache.thrift.meta_data.FieldMetaData("supervisors", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, SupervisorSummary.class)))); @@ -156,7 +126,7 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C tmpMap.put(_Fields.NIMBUSES, new org.apache.thrift.meta_data.FieldMetaData("nimbuses", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, NimbusSummary.class)))); - metaDataMap = Collections.unmodifiableMap(tmpMap); + metaDataMap = java.util.Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ClusterSummary.class, metaDataMap); } @@ -166,9 +136,9 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C } public ClusterSummary( - List<SupervisorSummary> supervisors, - List<TopologySummary> topologies, - List<NimbusSummary> nimbuses) + java.util.List<SupervisorSummary> supervisors, + java.util.List<TopologySummary> topologies, + java.util.List<NimbusSummary> nimbuses) { this(); this.supervisors = supervisors; @@ -182,7 +152,7 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C public ClusterSummary(ClusterSummary other) { __isset_bitfield = other.__isset_bitfield; if (other.is_set_supervisors()) { - List<SupervisorSummary> __this__supervisors = new ArrayList<SupervisorSummary>(other.supervisors.size()); + java.util.List<SupervisorSummary> __this__supervisors = new java.util.ArrayList<SupervisorSummary>(other.supervisors.size()); for (SupervisorSummary other_element : other.supervisors) { __this__supervisors.add(new SupervisorSummary(other_element)); } @@ -190,14 +160,14 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C } this.nimbus_uptime_secs = other.nimbus_uptime_secs; if (other.is_set_topologies()) { - List<TopologySummary> __this__topologies = new ArrayList<TopologySummary>(other.topologies.size()); + java.util.List<TopologySummary> __this__topologies = new java.util.ArrayList<TopologySummary>(other.topologies.size()); for (TopologySummary other_element : other.topologies) { __this__topologies.add(new TopologySummary(other_element)); } this.topologies = __this__topologies; } if (other.is_set_nimbuses()) { - List<NimbusSummary> __this__nimbuses = new ArrayList<NimbusSummary>(other.nimbuses.size()); + java.util.List<NimbusSummary> __this__nimbuses = new java.util.ArrayList<NimbusSummary>(other.nimbuses.size()); for (NimbusSummary other_element : other.nimbuses) { __this__nimbuses.add(new NimbusSummary(other_element)); } @@ -228,16 +198,16 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C public void add_to_supervisors(SupervisorSummary elem) { if (this.supervisors == null) { - this.supervisors = new ArrayList<SupervisorSummary>(); + this.supervisors = new java.util.ArrayList<SupervisorSummary>(); } this.supervisors.add(elem); } - public List<SupervisorSummary> get_supervisors() { + public java.util.List<SupervisorSummary> get_supervisors() { return this.supervisors; } - public void set_supervisors(List<SupervisorSummary> supervisors) { + public void set_supervisors(java.util.List<SupervisorSummary> supervisors) { this.supervisors = supervisors; } @@ -266,16 +236,16 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C } public void unset_nimbus_uptime_secs() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NIMBUS_UPTIME_SECS_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __NIMBUS_UPTIME_SECS_ISSET_ID); } /** Returns true if field nimbus_uptime_secs is set (has been assigned a value) and false otherwise */ public boolean is_set_nimbus_uptime_secs() { - return EncodingUtils.testBit(__isset_bitfield, __NIMBUS_UPTIME_SECS_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __NIMBUS_UPTIME_SECS_ISSET_ID); } public void set_nimbus_uptime_secs_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NIMBUS_UPTIME_SECS_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __NIMBUS_UPTIME_SECS_ISSET_ID, value); } public int get_topologies_size() { @@ -288,16 +258,16 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C public void add_to_topologies(TopologySummary elem) { if (this.topologies == null) { - this.topologies = new ArrayList<TopologySummary>(); + this.topologies = new java.util.ArrayList<TopologySummary>(); } this.topologies.add(elem); } - public List<TopologySummary> get_topologies() { + public java.util.List<TopologySummary> get_topologies() { return this.topologies; } - public void set_topologies(List<TopologySummary> topologies) { + public void set_topologies(java.util.List<TopologySummary> topologies) { this.topologies = topologies; } @@ -326,16 +296,16 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C public void add_to_nimbuses(NimbusSummary elem) { if (this.nimbuses == null) { - this.nimbuses = new ArrayList<NimbusSummary>(); + this.nimbuses = new java.util.ArrayList<NimbusSummary>(); } this.nimbuses.add(elem); } - public List<NimbusSummary> get_nimbuses() { + public java.util.List<NimbusSummary> get_nimbuses() { return this.nimbuses; } - public void set_nimbuses(List<NimbusSummary> nimbuses) { + public void set_nimbuses(java.util.List<NimbusSummary> nimbuses) { this.nimbuses = nimbuses; } @@ -354,13 +324,13 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C } } - public void setFieldValue(_Fields field, Object value) { + public void setFieldValue(_Fields field, java.lang.Object value) { switch (field) { case SUPERVISORS: if (value == null) { unset_supervisors(); } else { - set_supervisors((List<SupervisorSummary>)value); + set_supervisors((java.util.List<SupervisorSummary>)value); } break; @@ -368,7 +338,7 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C if (value == null) { unset_nimbus_uptime_secs(); } else { - set_nimbus_uptime_secs((Integer)value); + set_nimbus_uptime_secs((java.lang.Integer)value); } break; @@ -376,7 +346,7 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C if (value == null) { unset_topologies(); } else { - set_topologies((List<TopologySummary>)value); + set_topologies((java.util.List<TopologySummary>)value); } break; @@ -384,14 +354,14 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C if (value == null) { unset_nimbuses(); } else { - set_nimbuses((List<NimbusSummary>)value); + set_nimbuses((java.util.List<NimbusSummary>)value); } break; } } - public Object getFieldValue(_Fields field) { + public java.lang.Object getFieldValue(_Fields field) { switch (field) { case SUPERVISORS: return get_supervisors(); @@ -406,13 +376,13 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C return get_nimbuses(); } - 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) { @@ -425,11 +395,11 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C case NIMBUSES: return is_set_nimbuses(); } - 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 ClusterSummary) @@ -440,6 +410,8 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C public boolean equals(ClusterSummary that) { if (that == null) return false; + if (this == that) + return true; boolean this_present_supervisors = true && this.is_set_supervisors(); boolean that_present_supervisors = true && that.is_set_supervisors(); @@ -482,29 +454,25 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C @Override public int hashCode() { - List<Object> list = new ArrayList<Object>(); + int hashCode = 1; - boolean present_supervisors = true && (is_set_supervisors()); - list.add(present_supervisors); - if (present_supervisors) - list.add(supervisors); + hashCode = hashCode * 8191 + ((is_set_supervisors()) ? 131071 : 524287); + if (is_set_supervisors()) + hashCode = hashCode * 8191 + supervisors.hashCode(); - boolean present_nimbus_uptime_secs = true && (is_set_nimbus_uptime_secs()); - list.add(present_nimbus_uptime_secs); - if (present_nimbus_uptime_secs) - list.add(nimbus_uptime_secs); + hashCode = hashCode * 8191 + ((is_set_nimbus_uptime_secs()) ? 131071 : 524287); + if (is_set_nimbus_uptime_secs()) + hashCode = hashCode * 8191 + nimbus_uptime_secs; - boolean present_topologies = true && (is_set_topologies()); - list.add(present_topologies); - if (present_topologies) - list.add(topologies); + hashCode = hashCode * 8191 + ((is_set_topologies()) ? 131071 : 524287); + if (is_set_topologies()) + hashCode = hashCode * 8191 + topologies.hashCode(); - boolean present_nimbuses = true && (is_set_nimbuses()); - list.add(present_nimbuses); - if (present_nimbuses) - list.add(nimbuses); + hashCode = hashCode * 8191 + ((is_set_nimbuses()) ? 131071 : 524287); + if (is_set_nimbuses()) + hashCode = hashCode * 8191 + nimbuses.hashCode(); - return list.hashCode(); + return hashCode; } @Override @@ -515,7 +483,7 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C int lastComparison = 0; - lastComparison = Boolean.valueOf(is_set_supervisors()).compareTo(other.is_set_supervisors()); + lastComparison = java.lang.Boolean.valueOf(is_set_supervisors()).compareTo(other.is_set_supervisors()); if (lastComparison != 0) { return lastComparison; } @@ -525,7 +493,7 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_nimbus_uptime_secs()).compareTo(other.is_set_nimbus_uptime_secs()); + lastComparison = java.lang.Boolean.valueOf(is_set_nimbus_uptime_secs()).compareTo(other.is_set_nimbus_uptime_secs()); if (lastComparison != 0) { return lastComparison; } @@ -535,7 +503,7 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_topologies()).compareTo(other.is_set_topologies()); + lastComparison = java.lang.Boolean.valueOf(is_set_topologies()).compareTo(other.is_set_topologies()); if (lastComparison != 0) { return lastComparison; } @@ -545,7 +513,7 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_nimbuses()).compareTo(other.is_set_nimbuses()); + lastComparison = java.lang.Boolean.valueOf(is_set_nimbuses()).compareTo(other.is_set_nimbuses()); if (lastComparison != 0) { return lastComparison; } @@ -563,16 +531,16 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C } 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("ClusterSummary("); + public java.lang.String toString() { + java.lang.StringBuilder sb = new java.lang.StringBuilder("ClusterSummary("); boolean first = true; sb.append("supervisors:"); @@ -633,7 +601,7 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C } } - 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; @@ -643,13 +611,13 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C } } - private static class ClusterSummaryStandardSchemeFactory implements SchemeFactory { + private static class ClusterSummaryStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { public ClusterSummaryStandardScheme getScheme() { return new ClusterSummaryStandardScheme(); } } - private static class ClusterSummaryStandardScheme extends StandardScheme<ClusterSummary> { + private static class ClusterSummaryStandardScheme extends org.apache.thrift.scheme.StandardScheme<ClusterSummary> { public void read(org.apache.thrift.protocol.TProtocol iprot, ClusterSummary struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; @@ -665,7 +633,7 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { org.apache.thrift.protocol.TList _list136 = iprot.readListBegin(); - struct.supervisors = new ArrayList<SupervisorSummary>(_list136.size); + struct.supervisors = new java.util.ArrayList<SupervisorSummary>(_list136.size); SupervisorSummary _elem137; for (int _i138 = 0; _i138 < _list136.size; ++_i138) { @@ -692,7 +660,7 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { org.apache.thrift.protocol.TList _list139 = iprot.readListBegin(); - struct.topologies = new ArrayList<TopologySummary>(_list139.size); + struct.topologies = new java.util.ArrayList<TopologySummary>(_list139.size); TopologySummary _elem140; for (int _i141 = 0; _i141 < _list139.size; ++_i141) { @@ -711,7 +679,7 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { org.apache.thrift.protocol.TList _list142 = iprot.readListBegin(); - struct.nimbuses = new ArrayList<NimbusSummary>(_list142.size); + struct.nimbuses = new java.util.ArrayList<NimbusSummary>(_list142.size); NimbusSummary _elem143; for (int _i144 = 0; _i144 < _list142.size; ++_i144) { @@ -786,17 +754,17 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C } - private static class ClusterSummaryTupleSchemeFactory implements SchemeFactory { + private static class ClusterSummaryTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { public ClusterSummaryTupleScheme getScheme() { return new ClusterSummaryTupleScheme(); } } - private static class ClusterSummaryTupleScheme extends TupleScheme<ClusterSummary> { + private static class ClusterSummaryTupleScheme extends org.apache.thrift.scheme.TupleScheme<ClusterSummary> { @Override public void write(org.apache.thrift.protocol.TProtocol prot, ClusterSummary struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; + org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot; { oprot.writeI32(struct.supervisors.size()); for (SupervisorSummary _iter148 : struct.supervisors) @@ -818,7 +786,7 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C _iter150.write(oprot); } } - BitSet optionals = new BitSet(); + java.util.BitSet optionals = new java.util.BitSet(); if (struct.is_set_nimbus_uptime_secs()) { optionals.set(0); } @@ -830,10 +798,10 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C @Override public void read(org.apache.thrift.protocol.TProtocol prot, ClusterSummary struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; + org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot; { org.apache.thrift.protocol.TList _list151 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.supervisors = new ArrayList<SupervisorSummary>(_list151.size); + struct.supervisors = new java.util.ArrayList<SupervisorSummary>(_list151.size); SupervisorSummary _elem152; for (int _i153 = 0; _i153 < _list151.size; ++_i153) { @@ -845,7 +813,7 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C struct.set_supervisors_isSet(true); { org.apache.thrift.protocol.TList _list154 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.topologies = new ArrayList<TopologySummary>(_list154.size); + struct.topologies = new java.util.ArrayList<TopologySummary>(_list154.size); TopologySummary _elem155; for (int _i156 = 0; _i156 < _list154.size; ++_i156) { @@ -857,7 +825,7 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C struct.set_topologies_isSet(true); { org.apache.thrift.protocol.TList _list157 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.nimbuses = new ArrayList<NimbusSummary>(_list157.size); + struct.nimbuses = new java.util.ArrayList<NimbusSummary>(_list157.size); NimbusSummary _elem158; for (int _i159 = 0; _i159 < _list157.size; ++_i159) { @@ -867,7 +835,7 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C } } struct.set_nimbuses_isSet(true); - BitSet incoming = iprot.readBitSet(1); + java.util.BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { struct.nimbus_uptime_secs = iprot.readI32(); struct.set_nimbus_uptime_secs_isSet(true); @@ -875,5 +843,8 @@ public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, C } } + 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(); + } }
