http://git-wip-us.apache.org/repos/asf/storm/blob/1fd1e17f/storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java ---------------------------------------------------------------------- diff --git a/storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java b/storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java index 77728cd..f4a5a67 100644 --- a/storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java +++ b/storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.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 TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInfo, TopologyPageInfo._Fields>, java.io.Serializable, Cloneable, Comparable<TopologyPageInfo> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TopologyPageInfo"); @@ -88,30 +61,27 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf private static final org.apache.thrift.protocol.TField ASSIGNED_REGULAR_OFF_HEAP_MEMORY_FIELD_DESC = new org.apache.thrift.protocol.TField("assigned_regular_off_heap_memory", org.apache.thrift.protocol.TType.DOUBLE, (short)533); private static final org.apache.thrift.protocol.TField ASSIGNED_SHARED_OFF_HEAP_MEMORY_FIELD_DESC = new org.apache.thrift.protocol.TField("assigned_shared_off_heap_memory", org.apache.thrift.protocol.TType.DOUBLE, (short)534); - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new TopologyPageInfoStandardSchemeFactory()); - schemes.put(TupleScheme.class, new TopologyPageInfoTupleSchemeFactory()); - } + private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new TopologyPageInfoStandardSchemeFactory(); + private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new TopologyPageInfoTupleSchemeFactory(); - private String id; // required - private String name; // optional + private java.lang.String id; // required + private java.lang.String name; // optional private int uptime_secs; // optional - private String status; // optional + private java.lang.String status; // optional private int num_tasks; // optional private int num_workers; // optional private int num_executors; // optional - private String topology_conf; // optional - private Map<String,ComponentAggregateStats> id_to_spout_agg_stats; // optional - private Map<String,ComponentAggregateStats> id_to_bolt_agg_stats; // optional - private String sched_status; // optional + private java.lang.String topology_conf; // optional + private java.util.Map<java.lang.String,ComponentAggregateStats> id_to_spout_agg_stats; // optional + private java.util.Map<java.lang.String,ComponentAggregateStats> id_to_bolt_agg_stats; // optional + private java.lang.String sched_status; // optional private TopologyStats topology_stats; // optional - private String owner; // optional + private java.lang.String owner; // optional private DebugOptions debug_options; // optional private int replication_count; // optional - private List<WorkerSummary> workers; // optional - private String storm_version; // optional - private String topology_version; // optional + private java.util.List<WorkerSummary> workers; // optional + private java.lang.String storm_version; // optional + private java.lang.String topology_version; // optional private double requested_memonheap; // optional private double requested_memoffheap; // optional private double requested_cpu; // optional @@ -162,10 +132,10 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf ASSIGNED_REGULAR_OFF_HEAP_MEMORY((short)533, "assigned_regular_off_heap_memory"), ASSIGNED_SHARED_OFF_HEAP_MEMORY((short)534, "assigned_shared_off_heap_memory"); - 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); } } @@ -250,21 +220,21 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf */ 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; } @@ -273,7 +243,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return _thriftId; } - public String getFieldName() { + public java.lang.String getFieldName() { return _fieldName; } } @@ -300,9 +270,9 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf private static final int __ASSIGNED_SHARED_OFF_HEAP_MEMORY_ISSET_ID = 18; private int __isset_bitfield = 0; private static final _Fields optionals[] = {_Fields.NAME,_Fields.UPTIME_SECS,_Fields.STATUS,_Fields.NUM_TASKS,_Fields.NUM_WORKERS,_Fields.NUM_EXECUTORS,_Fields.TOPOLOGY_CONF,_Fields.ID_TO_SPOUT_AGG_STATS,_Fields.ID_TO_BOLT_AGG_STATS,_Fields.SCHED_STATUS,_Fields.TOPOLOGY_STATS,_Fields.OWNER,_Fields.DEBUG_OPTIONS,_Fields.REPLICATION_COUNT,_Fields.WORKERS,_Fields.STORM_VERSION,_Fields.TOPOLOGY_VERSION,_Fields.REQUESTED_MEMONHEAP,_Fields.REQUESTED_MEMOFFHEAP,_Fields.REQUESTED_CPU,_Fields.ASSIGNED_MEMONHEAP,_Fields.ASSIGNED_MEMOFFHEAP,_Fields.ASSIGNED_CPU,_Fields.REQUESTED_REGULAR_ON_HEAP_MEMORY,_Fields.REQUESTED_SHARED_ON_HEAP_MEMORY,_Fields.REQUESTED_REGULAR_OFF_HEAP_MEMORY,_Fields.REQUESTED_SHARED_OFF_HEAP_MEMORY,_Fields.ASSIGNED_REGULAR_ON_HEAP_MEMORY,_Fields.ASSIGNED_SHARED_ON_HEAP_MEMORY,_Fields.ASSIGNED_REGULAR_OFF_HEAP_MEMORY,_Fields.ASSIGNED_SHARED_OFF_HEAP_MEMORY}; - 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.ID, new org.apache.thrift.meta_data.FieldMetaData("id", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); tmpMap.put(_Fields.NAME, new org.apache.thrift.meta_data.FieldMetaData("name", org.apache.thrift.TFieldRequirementType.OPTIONAL, @@ -372,7 +342,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE))); tmpMap.put(_Fields.ASSIGNED_SHARED_OFF_HEAP_MEMORY, new org.apache.thrift.meta_data.FieldMetaData("assigned_shared_off_heap_memory", 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(TopologyPageInfo.class, metaDataMap); } @@ -380,7 +350,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public TopologyPageInfo( - String id) + java.lang.String id) { this(); this.id = id; @@ -408,13 +378,13 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf this.topology_conf = other.topology_conf; } if (other.is_set_id_to_spout_agg_stats()) { - Map<String,ComponentAggregateStats> __this__id_to_spout_agg_stats = new HashMap<String,ComponentAggregateStats>(other.id_to_spout_agg_stats.size()); - for (Map.Entry<String, ComponentAggregateStats> other_element : other.id_to_spout_agg_stats.entrySet()) { + java.util.Map<java.lang.String,ComponentAggregateStats> __this__id_to_spout_agg_stats = new java.util.HashMap<java.lang.String,ComponentAggregateStats>(other.id_to_spout_agg_stats.size()); + for (java.util.Map.Entry<java.lang.String, ComponentAggregateStats> other_element : other.id_to_spout_agg_stats.entrySet()) { - String other_element_key = other_element.getKey(); + java.lang.String other_element_key = other_element.getKey(); ComponentAggregateStats other_element_value = other_element.getValue(); - String __this__id_to_spout_agg_stats_copy_key = other_element_key; + java.lang.String __this__id_to_spout_agg_stats_copy_key = other_element_key; ComponentAggregateStats __this__id_to_spout_agg_stats_copy_value = new ComponentAggregateStats(other_element_value); @@ -423,13 +393,13 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf this.id_to_spout_agg_stats = __this__id_to_spout_agg_stats; } if (other.is_set_id_to_bolt_agg_stats()) { - Map<String,ComponentAggregateStats> __this__id_to_bolt_agg_stats = new HashMap<String,ComponentAggregateStats>(other.id_to_bolt_agg_stats.size()); - for (Map.Entry<String, ComponentAggregateStats> other_element : other.id_to_bolt_agg_stats.entrySet()) { + java.util.Map<java.lang.String,ComponentAggregateStats> __this__id_to_bolt_agg_stats = new java.util.HashMap<java.lang.String,ComponentAggregateStats>(other.id_to_bolt_agg_stats.size()); + for (java.util.Map.Entry<java.lang.String, ComponentAggregateStats> other_element : other.id_to_bolt_agg_stats.entrySet()) { - String other_element_key = other_element.getKey(); + java.lang.String other_element_key = other_element.getKey(); ComponentAggregateStats other_element_value = other_element.getValue(); - String __this__id_to_bolt_agg_stats_copy_key = other_element_key; + java.lang.String __this__id_to_bolt_agg_stats_copy_key = other_element_key; ComponentAggregateStats __this__id_to_bolt_agg_stats_copy_value = new ComponentAggregateStats(other_element_value); @@ -451,7 +421,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } this.replication_count = other.replication_count; if (other.is_set_workers()) { - List<WorkerSummary> __this__workers = new ArrayList<WorkerSummary>(other.workers.size()); + java.util.List<WorkerSummary> __this__workers = new java.util.ArrayList<WorkerSummary>(other.workers.size()); for (WorkerSummary other_element : other.workers) { __this__workers.add(new WorkerSummary(other_element)); } @@ -538,11 +508,11 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf this.assigned_shared_off_heap_memory = 0.0; } - public String get_id() { + public java.lang.String get_id() { return this.id; } - public void set_id(String id) { + public void set_id(java.lang.String id) { this.id = id; } @@ -561,11 +531,11 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } } - public String get_name() { + public java.lang.String get_name() { return this.name; } - public void set_name(String name) { + public void set_name(java.lang.String name) { this.name = name; } @@ -594,23 +564,23 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_uptime_secs() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __UPTIME_SECS_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __UPTIME_SECS_ISSET_ID); } /** Returns true if field uptime_secs is set (has been assigned a value) and false otherwise */ public boolean is_set_uptime_secs() { - return EncodingUtils.testBit(__isset_bitfield, __UPTIME_SECS_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __UPTIME_SECS_ISSET_ID); } public void set_uptime_secs_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __UPTIME_SECS_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __UPTIME_SECS_ISSET_ID, value); } - public String get_status() { + public java.lang.String get_status() { return this.status; } - public void set_status(String status) { + public void set_status(java.lang.String status) { this.status = status; } @@ -639,16 +609,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_num_tasks() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUM_TASKS_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __NUM_TASKS_ISSET_ID); } /** Returns true if field num_tasks is set (has been assigned a value) and false otherwise */ public boolean is_set_num_tasks() { - return EncodingUtils.testBit(__isset_bitfield, __NUM_TASKS_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __NUM_TASKS_ISSET_ID); } public void set_num_tasks_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUM_TASKS_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __NUM_TASKS_ISSET_ID, value); } public int get_num_workers() { @@ -661,16 +631,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_num_workers() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUM_WORKERS_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __NUM_WORKERS_ISSET_ID); } /** Returns true if field num_workers is set (has been assigned a value) and false otherwise */ public boolean is_set_num_workers() { - return EncodingUtils.testBit(__isset_bitfield, __NUM_WORKERS_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __NUM_WORKERS_ISSET_ID); } public void set_num_workers_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUM_WORKERS_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __NUM_WORKERS_ISSET_ID, value); } public int get_num_executors() { @@ -683,23 +653,23 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_num_executors() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUM_EXECUTORS_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __NUM_EXECUTORS_ISSET_ID); } /** Returns true if field num_executors is set (has been assigned a value) and false otherwise */ public boolean is_set_num_executors() { - return EncodingUtils.testBit(__isset_bitfield, __NUM_EXECUTORS_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __NUM_EXECUTORS_ISSET_ID); } public void set_num_executors_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUM_EXECUTORS_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __NUM_EXECUTORS_ISSET_ID, value); } - public String get_topology_conf() { + public java.lang.String get_topology_conf() { return this.topology_conf; } - public void set_topology_conf(String topology_conf) { + public void set_topology_conf(java.lang.String topology_conf) { this.topology_conf = topology_conf; } @@ -722,18 +692,18 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return (this.id_to_spout_agg_stats == null) ? 0 : this.id_to_spout_agg_stats.size(); } - public void put_to_id_to_spout_agg_stats(String key, ComponentAggregateStats val) { + public void put_to_id_to_spout_agg_stats(java.lang.String key, ComponentAggregateStats val) { if (this.id_to_spout_agg_stats == null) { - this.id_to_spout_agg_stats = new HashMap<String,ComponentAggregateStats>(); + this.id_to_spout_agg_stats = new java.util.HashMap<java.lang.String,ComponentAggregateStats>(); } this.id_to_spout_agg_stats.put(key, val); } - public Map<String,ComponentAggregateStats> get_id_to_spout_agg_stats() { + public java.util.Map<java.lang.String,ComponentAggregateStats> get_id_to_spout_agg_stats() { return this.id_to_spout_agg_stats; } - public void set_id_to_spout_agg_stats(Map<String,ComponentAggregateStats> id_to_spout_agg_stats) { + public void set_id_to_spout_agg_stats(java.util.Map<java.lang.String,ComponentAggregateStats> id_to_spout_agg_stats) { this.id_to_spout_agg_stats = id_to_spout_agg_stats; } @@ -756,18 +726,18 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return (this.id_to_bolt_agg_stats == null) ? 0 : this.id_to_bolt_agg_stats.size(); } - public void put_to_id_to_bolt_agg_stats(String key, ComponentAggregateStats val) { + public void put_to_id_to_bolt_agg_stats(java.lang.String key, ComponentAggregateStats val) { if (this.id_to_bolt_agg_stats == null) { - this.id_to_bolt_agg_stats = new HashMap<String,ComponentAggregateStats>(); + this.id_to_bolt_agg_stats = new java.util.HashMap<java.lang.String,ComponentAggregateStats>(); } this.id_to_bolt_agg_stats.put(key, val); } - public Map<String,ComponentAggregateStats> get_id_to_bolt_agg_stats() { + public java.util.Map<java.lang.String,ComponentAggregateStats> get_id_to_bolt_agg_stats() { return this.id_to_bolt_agg_stats; } - public void set_id_to_bolt_agg_stats(Map<String,ComponentAggregateStats> id_to_bolt_agg_stats) { + public void set_id_to_bolt_agg_stats(java.util.Map<java.lang.String,ComponentAggregateStats> id_to_bolt_agg_stats) { this.id_to_bolt_agg_stats = id_to_bolt_agg_stats; } @@ -786,11 +756,11 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } } - public String get_sched_status() { + public java.lang.String get_sched_status() { return this.sched_status; } - public void set_sched_status(String sched_status) { + public void set_sched_status(java.lang.String sched_status) { this.sched_status = sched_status; } @@ -832,11 +802,11 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } } - public String get_owner() { + public java.lang.String get_owner() { return this.owner; } - public void set_owner(String owner) { + public void set_owner(java.lang.String owner) { this.owner = owner; } @@ -888,16 +858,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_replication_count() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __REPLICATION_COUNT_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __REPLICATION_COUNT_ISSET_ID); } /** Returns true if field replication_count is set (has been assigned a value) and false otherwise */ public boolean is_set_replication_count() { - return EncodingUtils.testBit(__isset_bitfield, __REPLICATION_COUNT_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __REPLICATION_COUNT_ISSET_ID); } public void set_replication_count_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __REPLICATION_COUNT_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __REPLICATION_COUNT_ISSET_ID, value); } public int get_workers_size() { @@ -910,16 +880,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf public void add_to_workers(WorkerSummary elem) { if (this.workers == null) { - this.workers = new ArrayList<WorkerSummary>(); + this.workers = new java.util.ArrayList<WorkerSummary>(); } this.workers.add(elem); } - public List<WorkerSummary> get_workers() { + public java.util.List<WorkerSummary> get_workers() { return this.workers; } - public void set_workers(List<WorkerSummary> workers) { + public void set_workers(java.util.List<WorkerSummary> workers) { this.workers = workers; } @@ -938,11 +908,11 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } } - public String get_storm_version() { + public java.lang.String get_storm_version() { return this.storm_version; } - public void set_storm_version(String storm_version) { + public void set_storm_version(java.lang.String storm_version) { this.storm_version = storm_version; } @@ -961,11 +931,11 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } } - public String get_topology_version() { + public java.lang.String get_topology_version() { return this.topology_version; } - public void set_topology_version(String topology_version) { + public void set_topology_version(java.lang.String topology_version) { this.topology_version = topology_version; } @@ -994,16 +964,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_requested_memonheap() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_MEMONHEAP_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_MEMONHEAP_ISSET_ID); } /** Returns true if field requested_memonheap is set (has been assigned a value) and false otherwise */ public boolean is_set_requested_memonheap() { - return EncodingUtils.testBit(__isset_bitfield, __REQUESTED_MEMONHEAP_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __REQUESTED_MEMONHEAP_ISSET_ID); } public void set_requested_memonheap_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __REQUESTED_MEMONHEAP_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __REQUESTED_MEMONHEAP_ISSET_ID, value); } public double get_requested_memoffheap() { @@ -1016,16 +986,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_requested_memoffheap() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_MEMOFFHEAP_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_MEMOFFHEAP_ISSET_ID); } /** Returns true if field requested_memoffheap is set (has been assigned a value) and false otherwise */ public boolean is_set_requested_memoffheap() { - return EncodingUtils.testBit(__isset_bitfield, __REQUESTED_MEMOFFHEAP_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __REQUESTED_MEMOFFHEAP_ISSET_ID); } public void set_requested_memoffheap_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __REQUESTED_MEMOFFHEAP_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __REQUESTED_MEMOFFHEAP_ISSET_ID, value); } public double get_requested_cpu() { @@ -1038,16 +1008,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_requested_cpu() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_CPU_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_CPU_ISSET_ID); } /** Returns true if field requested_cpu is set (has been assigned a value) and false otherwise */ public boolean is_set_requested_cpu() { - return EncodingUtils.testBit(__isset_bitfield, __REQUESTED_CPU_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __REQUESTED_CPU_ISSET_ID); } public void set_requested_cpu_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __REQUESTED_CPU_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __REQUESTED_CPU_ISSET_ID, value); } public double get_assigned_memonheap() { @@ -1060,16 +1030,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_assigned_memonheap() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ASSIGNED_MEMONHEAP_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __ASSIGNED_MEMONHEAP_ISSET_ID); } /** Returns true if field assigned_memonheap is set (has been assigned a value) and false otherwise */ public boolean is_set_assigned_memonheap() { - return EncodingUtils.testBit(__isset_bitfield, __ASSIGNED_MEMONHEAP_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __ASSIGNED_MEMONHEAP_ISSET_ID); } public void set_assigned_memonheap_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ASSIGNED_MEMONHEAP_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __ASSIGNED_MEMONHEAP_ISSET_ID, value); } public double get_assigned_memoffheap() { @@ -1082,16 +1052,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_assigned_memoffheap() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ASSIGNED_MEMOFFHEAP_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __ASSIGNED_MEMOFFHEAP_ISSET_ID); } /** Returns true if field assigned_memoffheap is set (has been assigned a value) and false otherwise */ public boolean is_set_assigned_memoffheap() { - return EncodingUtils.testBit(__isset_bitfield, __ASSIGNED_MEMOFFHEAP_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __ASSIGNED_MEMOFFHEAP_ISSET_ID); } public void set_assigned_memoffheap_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ASSIGNED_MEMOFFHEAP_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __ASSIGNED_MEMOFFHEAP_ISSET_ID, value); } public double get_assigned_cpu() { @@ -1104,16 +1074,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_assigned_cpu() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ASSIGNED_CPU_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __ASSIGNED_CPU_ISSET_ID); } /** Returns true if field assigned_cpu is set (has been assigned a value) and false otherwise */ public boolean is_set_assigned_cpu() { - return EncodingUtils.testBit(__isset_bitfield, __ASSIGNED_CPU_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __ASSIGNED_CPU_ISSET_ID); } public void set_assigned_cpu_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ASSIGNED_CPU_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __ASSIGNED_CPU_ISSET_ID, value); } public double get_requested_regular_on_heap_memory() { @@ -1126,16 +1096,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_requested_regular_on_heap_memory() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_REGULAR_ON_HEAP_MEMORY_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_REGULAR_ON_HEAP_MEMORY_ISSET_ID); } /** Returns true if field requested_regular_on_heap_memory is set (has been assigned a value) and false otherwise */ public boolean is_set_requested_regular_on_heap_memory() { - return EncodingUtils.testBit(__isset_bitfield, __REQUESTED_REGULAR_ON_HEAP_MEMORY_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __REQUESTED_REGULAR_ON_HEAP_MEMORY_ISSET_ID); } public void set_requested_regular_on_heap_memory_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __REQUESTED_REGULAR_ON_HEAP_MEMORY_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __REQUESTED_REGULAR_ON_HEAP_MEMORY_ISSET_ID, value); } public double get_requested_shared_on_heap_memory() { @@ -1148,16 +1118,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_requested_shared_on_heap_memory() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_SHARED_ON_HEAP_MEMORY_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_SHARED_ON_HEAP_MEMORY_ISSET_ID); } /** Returns true if field requested_shared_on_heap_memory is set (has been assigned a value) and false otherwise */ public boolean is_set_requested_shared_on_heap_memory() { - return EncodingUtils.testBit(__isset_bitfield, __REQUESTED_SHARED_ON_HEAP_MEMORY_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __REQUESTED_SHARED_ON_HEAP_MEMORY_ISSET_ID); } public void set_requested_shared_on_heap_memory_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __REQUESTED_SHARED_ON_HEAP_MEMORY_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __REQUESTED_SHARED_ON_HEAP_MEMORY_ISSET_ID, value); } public double get_requested_regular_off_heap_memory() { @@ -1170,16 +1140,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_requested_regular_off_heap_memory() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_REGULAR_OFF_HEAP_MEMORY_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_REGULAR_OFF_HEAP_MEMORY_ISSET_ID); } /** Returns true if field requested_regular_off_heap_memory is set (has been assigned a value) and false otherwise */ public boolean is_set_requested_regular_off_heap_memory() { - return EncodingUtils.testBit(__isset_bitfield, __REQUESTED_REGULAR_OFF_HEAP_MEMORY_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __REQUESTED_REGULAR_OFF_HEAP_MEMORY_ISSET_ID); } public void set_requested_regular_off_heap_memory_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __REQUESTED_REGULAR_OFF_HEAP_MEMORY_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __REQUESTED_REGULAR_OFF_HEAP_MEMORY_ISSET_ID, value); } public double get_requested_shared_off_heap_memory() { @@ -1192,16 +1162,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_requested_shared_off_heap_memory() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_SHARED_OFF_HEAP_MEMORY_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __REQUESTED_SHARED_OFF_HEAP_MEMORY_ISSET_ID); } /** Returns true if field requested_shared_off_heap_memory is set (has been assigned a value) and false otherwise */ public boolean is_set_requested_shared_off_heap_memory() { - return EncodingUtils.testBit(__isset_bitfield, __REQUESTED_SHARED_OFF_HEAP_MEMORY_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __REQUESTED_SHARED_OFF_HEAP_MEMORY_ISSET_ID); } public void set_requested_shared_off_heap_memory_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __REQUESTED_SHARED_OFF_HEAP_MEMORY_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __REQUESTED_SHARED_OFF_HEAP_MEMORY_ISSET_ID, value); } public double get_assigned_regular_on_heap_memory() { @@ -1214,16 +1184,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_assigned_regular_on_heap_memory() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ASSIGNED_REGULAR_ON_HEAP_MEMORY_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __ASSIGNED_REGULAR_ON_HEAP_MEMORY_ISSET_ID); } /** Returns true if field assigned_regular_on_heap_memory is set (has been assigned a value) and false otherwise */ public boolean is_set_assigned_regular_on_heap_memory() { - return EncodingUtils.testBit(__isset_bitfield, __ASSIGNED_REGULAR_ON_HEAP_MEMORY_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __ASSIGNED_REGULAR_ON_HEAP_MEMORY_ISSET_ID); } public void set_assigned_regular_on_heap_memory_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ASSIGNED_REGULAR_ON_HEAP_MEMORY_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __ASSIGNED_REGULAR_ON_HEAP_MEMORY_ISSET_ID, value); } public double get_assigned_shared_on_heap_memory() { @@ -1236,16 +1206,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_assigned_shared_on_heap_memory() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ASSIGNED_SHARED_ON_HEAP_MEMORY_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __ASSIGNED_SHARED_ON_HEAP_MEMORY_ISSET_ID); } /** Returns true if field assigned_shared_on_heap_memory is set (has been assigned a value) and false otherwise */ public boolean is_set_assigned_shared_on_heap_memory() { - return EncodingUtils.testBit(__isset_bitfield, __ASSIGNED_SHARED_ON_HEAP_MEMORY_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __ASSIGNED_SHARED_ON_HEAP_MEMORY_ISSET_ID); } public void set_assigned_shared_on_heap_memory_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ASSIGNED_SHARED_ON_HEAP_MEMORY_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __ASSIGNED_SHARED_ON_HEAP_MEMORY_ISSET_ID, value); } public double get_assigned_regular_off_heap_memory() { @@ -1258,16 +1228,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_assigned_regular_off_heap_memory() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ASSIGNED_REGULAR_OFF_HEAP_MEMORY_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __ASSIGNED_REGULAR_OFF_HEAP_MEMORY_ISSET_ID); } /** Returns true if field assigned_regular_off_heap_memory is set (has been assigned a value) and false otherwise */ public boolean is_set_assigned_regular_off_heap_memory() { - return EncodingUtils.testBit(__isset_bitfield, __ASSIGNED_REGULAR_OFF_HEAP_MEMORY_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __ASSIGNED_REGULAR_OFF_HEAP_MEMORY_ISSET_ID); } public void set_assigned_regular_off_heap_memory_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ASSIGNED_REGULAR_OFF_HEAP_MEMORY_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __ASSIGNED_REGULAR_OFF_HEAP_MEMORY_ISSET_ID, value); } public double get_assigned_shared_off_heap_memory() { @@ -1280,25 +1250,25 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } public void unset_assigned_shared_off_heap_memory() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ASSIGNED_SHARED_OFF_HEAP_MEMORY_ISSET_ID); + __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __ASSIGNED_SHARED_OFF_HEAP_MEMORY_ISSET_ID); } /** Returns true if field assigned_shared_off_heap_memory is set (has been assigned a value) and false otherwise */ public boolean is_set_assigned_shared_off_heap_memory() { - return EncodingUtils.testBit(__isset_bitfield, __ASSIGNED_SHARED_OFF_HEAP_MEMORY_ISSET_ID); + return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __ASSIGNED_SHARED_OFF_HEAP_MEMORY_ISSET_ID); } public void set_assigned_shared_off_heap_memory_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ASSIGNED_SHARED_OFF_HEAP_MEMORY_ISSET_ID, value); + __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __ASSIGNED_SHARED_OFF_HEAP_MEMORY_ISSET_ID, value); } - public void setFieldValue(_Fields field, Object value) { + public void setFieldValue(_Fields field, java.lang.Object value) { switch (field) { case ID: if (value == null) { unset_id(); } else { - set_id((String)value); + set_id((java.lang.String)value); } break; @@ -1306,7 +1276,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_name(); } else { - set_name((String)value); + set_name((java.lang.String)value); } break; @@ -1314,7 +1284,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_uptime_secs(); } else { - set_uptime_secs((Integer)value); + set_uptime_secs((java.lang.Integer)value); } break; @@ -1322,7 +1292,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_status(); } else { - set_status((String)value); + set_status((java.lang.String)value); } break; @@ -1330,7 +1300,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_num_tasks(); } else { - set_num_tasks((Integer)value); + set_num_tasks((java.lang.Integer)value); } break; @@ -1338,7 +1308,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_num_workers(); } else { - set_num_workers((Integer)value); + set_num_workers((java.lang.Integer)value); } break; @@ -1346,7 +1316,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_num_executors(); } else { - set_num_executors((Integer)value); + set_num_executors((java.lang.Integer)value); } break; @@ -1354,7 +1324,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_topology_conf(); } else { - set_topology_conf((String)value); + set_topology_conf((java.lang.String)value); } break; @@ -1362,7 +1332,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_id_to_spout_agg_stats(); } else { - set_id_to_spout_agg_stats((Map<String,ComponentAggregateStats>)value); + set_id_to_spout_agg_stats((java.util.Map<java.lang.String,ComponentAggregateStats>)value); } break; @@ -1370,7 +1340,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_id_to_bolt_agg_stats(); } else { - set_id_to_bolt_agg_stats((Map<String,ComponentAggregateStats>)value); + set_id_to_bolt_agg_stats((java.util.Map<java.lang.String,ComponentAggregateStats>)value); } break; @@ -1378,7 +1348,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_sched_status(); } else { - set_sched_status((String)value); + set_sched_status((java.lang.String)value); } break; @@ -1394,7 +1364,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_owner(); } else { - set_owner((String)value); + set_owner((java.lang.String)value); } break; @@ -1410,7 +1380,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_replication_count(); } else { - set_replication_count((Integer)value); + set_replication_count((java.lang.Integer)value); } break; @@ -1418,7 +1388,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_workers(); } else { - set_workers((List<WorkerSummary>)value); + set_workers((java.util.List<WorkerSummary>)value); } break; @@ -1426,7 +1396,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_storm_version(); } else { - set_storm_version((String)value); + set_storm_version((java.lang.String)value); } break; @@ -1434,7 +1404,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_topology_version(); } else { - set_topology_version((String)value); + set_topology_version((java.lang.String)value); } break; @@ -1442,7 +1412,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_requested_memonheap(); } else { - set_requested_memonheap((Double)value); + set_requested_memonheap((java.lang.Double)value); } break; @@ -1450,7 +1420,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_requested_memoffheap(); } else { - set_requested_memoffheap((Double)value); + set_requested_memoffheap((java.lang.Double)value); } break; @@ -1458,7 +1428,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_requested_cpu(); } else { - set_requested_cpu((Double)value); + set_requested_cpu((java.lang.Double)value); } break; @@ -1466,7 +1436,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_assigned_memonheap(); } else { - set_assigned_memonheap((Double)value); + set_assigned_memonheap((java.lang.Double)value); } break; @@ -1474,7 +1444,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_assigned_memoffheap(); } else { - set_assigned_memoffheap((Double)value); + set_assigned_memoffheap((java.lang.Double)value); } break; @@ -1482,7 +1452,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_assigned_cpu(); } else { - set_assigned_cpu((Double)value); + set_assigned_cpu((java.lang.Double)value); } break; @@ -1490,7 +1460,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_requested_regular_on_heap_memory(); } else { - set_requested_regular_on_heap_memory((Double)value); + set_requested_regular_on_heap_memory((java.lang.Double)value); } break; @@ -1498,7 +1468,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_requested_shared_on_heap_memory(); } else { - set_requested_shared_on_heap_memory((Double)value); + set_requested_shared_on_heap_memory((java.lang.Double)value); } break; @@ -1506,7 +1476,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_requested_regular_off_heap_memory(); } else { - set_requested_regular_off_heap_memory((Double)value); + set_requested_regular_off_heap_memory((java.lang.Double)value); } break; @@ -1514,7 +1484,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_requested_shared_off_heap_memory(); } else { - set_requested_shared_off_heap_memory((Double)value); + set_requested_shared_off_heap_memory((java.lang.Double)value); } break; @@ -1522,7 +1492,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_assigned_regular_on_heap_memory(); } else { - set_assigned_regular_on_heap_memory((Double)value); + set_assigned_regular_on_heap_memory((java.lang.Double)value); } break; @@ -1530,7 +1500,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_assigned_shared_on_heap_memory(); } else { - set_assigned_shared_on_heap_memory((Double)value); + set_assigned_shared_on_heap_memory((java.lang.Double)value); } break; @@ -1538,7 +1508,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_assigned_regular_off_heap_memory(); } else { - set_assigned_regular_off_heap_memory((Double)value); + set_assigned_regular_off_heap_memory((java.lang.Double)value); } break; @@ -1546,14 +1516,14 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (value == null) { unset_assigned_shared_off_heap_memory(); } else { - set_assigned_shared_off_heap_memory((Double)value); + set_assigned_shared_off_heap_memory((java.lang.Double)value); } break; } } - public Object getFieldValue(_Fields field) { + public java.lang.Object getFieldValue(_Fields field) { switch (field) { case ID: return get_id(); @@ -1652,13 +1622,13 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return get_assigned_shared_off_heap_memory(); } - 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) { @@ -1727,11 +1697,11 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf case ASSIGNED_SHARED_OFF_HEAP_MEMORY: return is_set_assigned_shared_off_heap_memory(); } - 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 TopologyPageInfo) @@ -1742,6 +1712,8 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf public boolean equals(TopologyPageInfo that) { if (that == null) return false; + if (this == that) + return true; boolean this_present_id = true && this.is_set_id(); boolean that_present_id = true && that.is_set_id(); @@ -2036,169 +2008,137 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf @Override public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_id = true && (is_set_id()); - list.add(present_id); - if (present_id) - list.add(id); - - boolean present_name = true && (is_set_name()); - list.add(present_name); - if (present_name) - list.add(name); - - boolean present_uptime_secs = true && (is_set_uptime_secs()); - list.add(present_uptime_secs); - if (present_uptime_secs) - list.add(uptime_secs); - - boolean present_status = true && (is_set_status()); - list.add(present_status); - if (present_status) - list.add(status); - - boolean present_num_tasks = true && (is_set_num_tasks()); - list.add(present_num_tasks); - if (present_num_tasks) - list.add(num_tasks); - - boolean present_num_workers = true && (is_set_num_workers()); - list.add(present_num_workers); - if (present_num_workers) - list.add(num_workers); - - boolean present_num_executors = true && (is_set_num_executors()); - list.add(present_num_executors); - if (present_num_executors) - list.add(num_executors); - - boolean present_topology_conf = true && (is_set_topology_conf()); - list.add(present_topology_conf); - if (present_topology_conf) - list.add(topology_conf); - - boolean present_id_to_spout_agg_stats = true && (is_set_id_to_spout_agg_stats()); - list.add(present_id_to_spout_agg_stats); - if (present_id_to_spout_agg_stats) - list.add(id_to_spout_agg_stats); - - boolean present_id_to_bolt_agg_stats = true && (is_set_id_to_bolt_agg_stats()); - list.add(present_id_to_bolt_agg_stats); - if (present_id_to_bolt_agg_stats) - list.add(id_to_bolt_agg_stats); - - boolean present_sched_status = true && (is_set_sched_status()); - list.add(present_sched_status); - if (present_sched_status) - list.add(sched_status); - - boolean present_topology_stats = true && (is_set_topology_stats()); - list.add(present_topology_stats); - if (present_topology_stats) - list.add(topology_stats); - - boolean present_owner = true && (is_set_owner()); - list.add(present_owner); - if (present_owner) - list.add(owner); - - boolean present_debug_options = true && (is_set_debug_options()); - list.add(present_debug_options); - if (present_debug_options) - list.add(debug_options); - - boolean present_replication_count = true && (is_set_replication_count()); - list.add(present_replication_count); - if (present_replication_count) - list.add(replication_count); - - boolean present_workers = true && (is_set_workers()); - list.add(present_workers); - if (present_workers) - list.add(workers); - - boolean present_storm_version = true && (is_set_storm_version()); - list.add(present_storm_version); - if (present_storm_version) - list.add(storm_version); - - boolean present_topology_version = true && (is_set_topology_version()); - list.add(present_topology_version); - if (present_topology_version) - list.add(topology_version); - - boolean present_requested_memonheap = true && (is_set_requested_memonheap()); - list.add(present_requested_memonheap); - if (present_requested_memonheap) - list.add(requested_memonheap); - - boolean present_requested_memoffheap = true && (is_set_requested_memoffheap()); - list.add(present_requested_memoffheap); - if (present_requested_memoffheap) - list.add(requested_memoffheap); - - boolean present_requested_cpu = true && (is_set_requested_cpu()); - list.add(present_requested_cpu); - if (present_requested_cpu) - list.add(requested_cpu); - - boolean present_assigned_memonheap = true && (is_set_assigned_memonheap()); - list.add(present_assigned_memonheap); - if (present_assigned_memonheap) - list.add(assigned_memonheap); - - boolean present_assigned_memoffheap = true && (is_set_assigned_memoffheap()); - list.add(present_assigned_memoffheap); - if (present_assigned_memoffheap) - list.add(assigned_memoffheap); - - boolean present_assigned_cpu = true && (is_set_assigned_cpu()); - list.add(present_assigned_cpu); - if (present_assigned_cpu) - list.add(assigned_cpu); - - boolean present_requested_regular_on_heap_memory = true && (is_set_requested_regular_on_heap_memory()); - list.add(present_requested_regular_on_heap_memory); - if (present_requested_regular_on_heap_memory) - list.add(requested_regular_on_heap_memory); - - boolean present_requested_shared_on_heap_memory = true && (is_set_requested_shared_on_heap_memory()); - list.add(present_requested_shared_on_heap_memory); - if (present_requested_shared_on_heap_memory) - list.add(requested_shared_on_heap_memory); - - boolean present_requested_regular_off_heap_memory = true && (is_set_requested_regular_off_heap_memory()); - list.add(present_requested_regular_off_heap_memory); - if (present_requested_regular_off_heap_memory) - list.add(requested_regular_off_heap_memory); - - boolean present_requested_shared_off_heap_memory = true && (is_set_requested_shared_off_heap_memory()); - list.add(present_requested_shared_off_heap_memory); - if (present_requested_shared_off_heap_memory) - list.add(requested_shared_off_heap_memory); - - boolean present_assigned_regular_on_heap_memory = true && (is_set_assigned_regular_on_heap_memory()); - list.add(present_assigned_regular_on_heap_memory); - if (present_assigned_regular_on_heap_memory) - list.add(assigned_regular_on_heap_memory); - - boolean present_assigned_shared_on_heap_memory = true && (is_set_assigned_shared_on_heap_memory()); - list.add(present_assigned_shared_on_heap_memory); - if (present_assigned_shared_on_heap_memory) - list.add(assigned_shared_on_heap_memory); - - boolean present_assigned_regular_off_heap_memory = true && (is_set_assigned_regular_off_heap_memory()); - list.add(present_assigned_regular_off_heap_memory); - if (present_assigned_regular_off_heap_memory) - list.add(assigned_regular_off_heap_memory); - - boolean present_assigned_shared_off_heap_memory = true && (is_set_assigned_shared_off_heap_memory()); - list.add(present_assigned_shared_off_heap_memory); - if (present_assigned_shared_off_heap_memory) - list.add(assigned_shared_off_heap_memory); - - return list.hashCode(); + int hashCode = 1; + + hashCode = hashCode * 8191 + ((is_set_id()) ? 131071 : 524287); + if (is_set_id()) + hashCode = hashCode * 8191 + id.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_name()) ? 131071 : 524287); + if (is_set_name()) + hashCode = hashCode * 8191 + name.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_uptime_secs()) ? 131071 : 524287); + if (is_set_uptime_secs()) + hashCode = hashCode * 8191 + uptime_secs; + + hashCode = hashCode * 8191 + ((is_set_status()) ? 131071 : 524287); + if (is_set_status()) + hashCode = hashCode * 8191 + status.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_num_tasks()) ? 131071 : 524287); + if (is_set_num_tasks()) + hashCode = hashCode * 8191 + num_tasks; + + hashCode = hashCode * 8191 + ((is_set_num_workers()) ? 131071 : 524287); + if (is_set_num_workers()) + hashCode = hashCode * 8191 + num_workers; + + hashCode = hashCode * 8191 + ((is_set_num_executors()) ? 131071 : 524287); + if (is_set_num_executors()) + hashCode = hashCode * 8191 + num_executors; + + hashCode = hashCode * 8191 + ((is_set_topology_conf()) ? 131071 : 524287); + if (is_set_topology_conf()) + hashCode = hashCode * 8191 + topology_conf.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_id_to_spout_agg_stats()) ? 131071 : 524287); + if (is_set_id_to_spout_agg_stats()) + hashCode = hashCode * 8191 + id_to_spout_agg_stats.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_id_to_bolt_agg_stats()) ? 131071 : 524287); + if (is_set_id_to_bolt_agg_stats()) + hashCode = hashCode * 8191 + id_to_bolt_agg_stats.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_sched_status()) ? 131071 : 524287); + if (is_set_sched_status()) + hashCode = hashCode * 8191 + sched_status.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_topology_stats()) ? 131071 : 524287); + if (is_set_topology_stats()) + hashCode = hashCode * 8191 + topology_stats.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_owner()) ? 131071 : 524287); + if (is_set_owner()) + hashCode = hashCode * 8191 + owner.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_debug_options()) ? 131071 : 524287); + if (is_set_debug_options()) + hashCode = hashCode * 8191 + debug_options.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_replication_count()) ? 131071 : 524287); + if (is_set_replication_count()) + hashCode = hashCode * 8191 + replication_count; + + hashCode = hashCode * 8191 + ((is_set_workers()) ? 131071 : 524287); + if (is_set_workers()) + hashCode = hashCode * 8191 + workers.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_storm_version()) ? 131071 : 524287); + if (is_set_storm_version()) + hashCode = hashCode * 8191 + storm_version.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_topology_version()) ? 131071 : 524287); + if (is_set_topology_version()) + hashCode = hashCode * 8191 + topology_version.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_requested_memonheap()) ? 131071 : 524287); + if (is_set_requested_memonheap()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(requested_memonheap); + + hashCode = hashCode * 8191 + ((is_set_requested_memoffheap()) ? 131071 : 524287); + if (is_set_requested_memoffheap()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(requested_memoffheap); + + hashCode = hashCode * 8191 + ((is_set_requested_cpu()) ? 131071 : 524287); + if (is_set_requested_cpu()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(requested_cpu); + + hashCode = hashCode * 8191 + ((is_set_assigned_memonheap()) ? 131071 : 524287); + if (is_set_assigned_memonheap()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(assigned_memonheap); + + hashCode = hashCode * 8191 + ((is_set_assigned_memoffheap()) ? 131071 : 524287); + if (is_set_assigned_memoffheap()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(assigned_memoffheap); + + hashCode = hashCode * 8191 + ((is_set_assigned_cpu()) ? 131071 : 524287); + if (is_set_assigned_cpu()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(assigned_cpu); + + hashCode = hashCode * 8191 + ((is_set_requested_regular_on_heap_memory()) ? 131071 : 524287); + if (is_set_requested_regular_on_heap_memory()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(requested_regular_on_heap_memory); + + hashCode = hashCode * 8191 + ((is_set_requested_shared_on_heap_memory()) ? 131071 : 524287); + if (is_set_requested_shared_on_heap_memory()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(requested_shared_on_heap_memory); + + hashCode = hashCode * 8191 + ((is_set_requested_regular_off_heap_memory()) ? 131071 : 524287); + if (is_set_requested_regular_off_heap_memory()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(requested_regular_off_heap_memory); + + hashCode = hashCode * 8191 + ((is_set_requested_shared_off_heap_memory()) ? 131071 : 524287); + if (is_set_requested_shared_off_heap_memory()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(requested_shared_off_heap_memory); + + hashCode = hashCode * 8191 + ((is_set_assigned_regular_on_heap_memory()) ? 131071 : 524287); + if (is_set_assigned_regular_on_heap_memory()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(assigned_regular_on_heap_memory); + + hashCode = hashCode * 8191 + ((is_set_assigned_shared_on_heap_memory()) ? 131071 : 524287); + if (is_set_assigned_shared_on_heap_memory()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(assigned_shared_on_heap_memory); + + hashCode = hashCode * 8191 + ((is_set_assigned_regular_off_heap_memory()) ? 131071 : 524287); + if (is_set_assigned_regular_off_heap_memory()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(assigned_regular_off_heap_memory); + + hashCode = hashCode * 8191 + ((is_set_assigned_shared_off_heap_memory()) ? 131071 : 524287); + if (is_set_assigned_shared_off_heap_memory()) + hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(assigned_shared_off_heap_memory); + + return hashCode; } @Override @@ -2209,7 +2149,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf int lastComparison = 0; - lastComparison = Boolean.valueOf(is_set_id()).compareTo(other.is_set_id()); + lastComparison = java.lang.Boolean.valueOf(is_set_id()).compareTo(other.is_set_id()); if (lastComparison != 0) { return lastComparison; } @@ -2219,7 +2159,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_name()).compareTo(other.is_set_name()); + lastComparison = java.lang.Boolean.valueOf(is_set_name()).compareTo(other.is_set_name()); if (lastComparison != 0) { return lastComparison; } @@ -2229,7 +2169,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_uptime_secs()).compareTo(other.is_set_uptime_secs()); + lastComparison = java.lang.Boolean.valueOf(is_set_uptime_secs()).compareTo(other.is_set_uptime_secs()); if (lastComparison != 0) { return lastComparison; } @@ -2239,7 +2179,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_status()).compareTo(other.is_set_status()); + lastComparison = java.lang.Boolean.valueOf(is_set_status()).compareTo(other.is_set_status()); if (lastComparison != 0) { return lastComparison; } @@ -2249,7 +2189,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_num_tasks()).compareTo(other.is_set_num_tasks()); + lastComparison = java.lang.Boolean.valueOf(is_set_num_tasks()).compareTo(other.is_set_num_tasks()); if (lastComparison != 0) { return lastComparison; } @@ -2259,7 +2199,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_num_workers()).compareTo(other.is_set_num_workers()); + lastComparison = java.lang.Boolean.valueOf(is_set_num_workers()).compareTo(other.is_set_num_workers()); if (lastComparison != 0) { return lastComparison; } @@ -2269,7 +2209,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_num_executors()).compareTo(other.is_set_num_executors()); + lastComparison = java.lang.Boolean.valueOf(is_set_num_executors()).compareTo(other.is_set_num_executors()); if (lastComparison != 0) { return lastComparison; } @@ -2279,7 +2219,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_topology_conf()).compareTo(other.is_set_topology_conf()); + lastComparison = java.lang.Boolean.valueOf(is_set_topology_conf()).compareTo(other.is_set_topology_conf()); if (lastComparison != 0) { return lastComparison; } @@ -2289,7 +2229,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_id_to_spout_agg_stats()).compareTo(other.is_set_id_to_spout_agg_stats()); + lastComparison = java.lang.Boolean.valueOf(is_set_id_to_spout_agg_stats()).compareTo(other.is_set_id_to_spout_agg_stats()); if (lastComparison != 0) { return lastComparison; } @@ -2299,7 +2239,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_id_to_bolt_agg_stats()).compareTo(other.is_set_id_to_bolt_agg_stats()); + lastComparison = java.lang.Boolean.valueOf(is_set_id_to_bolt_agg_stats()).compareTo(other.is_set_id_to_bolt_agg_stats()); if (lastComparison != 0) { return lastComparison; } @@ -2309,7 +2249,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_sched_status()).compareTo(other.is_set_sched_status()); + lastComparison = java.lang.Boolean.valueOf(is_set_sched_status()).compareTo(other.is_set_sched_status()); if (lastComparison != 0) { return lastComparison; } @@ -2319,7 +2259,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_topology_stats()).compareTo(other.is_set_topology_stats()); + lastComparison = java.lang.Boolean.valueOf(is_set_topology_stats()).compareTo(other.is_set_topology_stats()); if (lastComparison != 0) { return lastComparison; } @@ -2329,7 +2269,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_owner()).compareTo(other.is_set_owner()); + lastComparison = java.lang.Boolean.valueOf(is_set_owner()).compareTo(other.is_set_owner()); if (lastComparison != 0) { return lastComparison; } @@ -2339,7 +2279,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_debug_options()).compareTo(other.is_set_debug_options()); + lastComparison = java.lang.Boolean.valueOf(is_set_debug_options()).compareTo(other.is_set_debug_options()); if (lastComparison != 0) { return lastComparison; } @@ -2349,7 +2289,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_replication_count()).compareTo(other.is_set_replication_count()); + lastComparison = java.lang.Boolean.valueOf(is_set_replication_count()).compareTo(other.is_set_replication_count()); if (lastComparison != 0) { return lastComparison; } @@ -2359,7 +2299,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_workers()).compareTo(other.is_set_workers()); + lastComparison = java.lang.Boolean.valueOf(is_set_workers()).compareTo(other.is_set_workers()); if (lastComparison != 0) { return lastComparison; } @@ -2369,7 +2309,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_storm_version()).compareTo(other.is_set_storm_version()); + lastComparison = java.lang.Boolean.valueOf(is_set_storm_version()).compareTo(other.is_set_storm_version()); if (lastComparison != 0) { return lastComparison; } @@ -2379,7 +2319,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_topology_version()).compareTo(other.is_set_topology_version()); + lastComparison = java.lang.Boolean.valueOf(is_set_topology_version()).compareTo(other.is_set_topology_version()); if (lastComparison != 0) { return lastComparison; } @@ -2389,7 +2329,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_requested_memonheap()).compareTo(other.is_set_requested_memonheap()); + lastComparison = java.lang.Boolean.valueOf(is_set_requested_memonheap()).compareTo(other.is_set_requested_memonheap()); if (lastComparison != 0) { return lastComparison; } @@ -2399,7 +2339,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_requested_memoffheap()).compareTo(other.is_set_requested_memoffheap()); + lastComparison = java.lang.Boolean.valueOf(is_set_requested_memoffheap()).compareTo(other.is_set_requested_memoffheap()); if (lastComparison != 0) { return lastComparison; } @@ -2409,7 +2349,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_requested_cpu()).compareTo(other.is_set_requested_cpu()); + lastComparison = java.lang.Boolean.valueOf(is_set_requested_cpu()).compareTo(other.is_set_requested_cpu()); if (lastComparison != 0) { return lastComparison; } @@ -2419,7 +2359,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_assigned_memonheap()).compareTo(other.is_set_assigned_memonheap()); + lastComparison = java.lang.Boolean.valueOf(is_set_assigned_memonheap()).compareTo(other.is_set_assigned_memonheap()); if (lastComparison != 0) { return lastComparison; } @@ -2429,7 +2369,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_assigned_memoffheap()).compareTo(other.is_set_assigned_memoffheap()); + lastComparison = java.lang.Boolean.valueOf(is_set_assigned_memoffheap()).compareTo(other.is_set_assigned_memoffheap()); if (lastComparison != 0) { return lastComparison; } @@ -2439,7 +2379,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_assigned_cpu()).compareTo(other.is_set_assigned_cpu()); + lastComparison = java.lang.Boolean.valueOf(is_set_assigned_cpu()).compareTo(other.is_set_assigned_cpu()); if (lastComparison != 0) { return lastComparison; } @@ -2449,7 +2389,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_requested_regular_on_heap_memory()).compareTo(other.is_set_requested_regular_on_heap_memory()); + lastComparison = java.lang.Boolean.valueOf(is_set_requested_regular_on_heap_memory()).compareTo(other.is_set_requested_regular_on_heap_memory()); if (lastComparison != 0) { return lastComparison; } @@ -2459,7 +2399,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_requested_shared_on_heap_memory()).compareTo(other.is_set_requested_shared_on_heap_memory()); + lastComparison = java.lang.Boolean.valueOf(is_set_requested_shared_on_heap_memory()).compareTo(other.is_set_requested_shared_on_heap_memory()); if (lastComparison != 0) { return lastComparison; } @@ -2469,7 +2409,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_requested_regular_off_heap_memory()).compareTo(other.is_set_requested_regular_off_heap_memory()); + lastComparison = java.lang.Boolean.valueOf(is_set_requested_regular_off_heap_memory()).compareTo(other.is_set_requested_regular_off_heap_memory()); if (lastComparison != 0) { return lastComparison; } @@ -2479,7 +2419,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_requested_shared_off_heap_memory()).compareTo(other.is_set_requested_shared_off_heap_memory()); + lastComparison = java.lang.Boolean.valueOf(is_set_requested_shared_off_heap_memory()).compareTo(other.is_set_requested_shared_off_heap_memory()); if (lastComparison != 0) { return lastComparison; } @@ -2489,7 +2429,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_assigned_regular_on_heap_memory()).compareTo(other.is_set_assigned_regular_on_heap_memory()); + lastComparison = java.lang.Boolean.valueOf(is_set_assigned_regular_on_heap_memory()).compareTo(other.is_set_assigned_regular_on_heap_memory()); if (lastComparison != 0) { return lastComparison; } @@ -2499,7 +2439,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_assigned_shared_on_heap_memory()).compareTo(other.is_set_assigned_shared_on_heap_memory()); + lastComparison = java.lang.Boolean.valueOf(is_set_assigned_shared_on_heap_memory()).compareTo(other.is_set_assigned_shared_on_heap_memory()); if (lastComparison != 0) { return lastComparison; } @@ -2509,7 +2449,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_assigned_regular_off_heap_memory()).compareTo(other.is_set_assigned_regular_off_heap_memory()); + lastComparison = java.lang.Boolean.valueOf(is_set_assigned_regular_off_heap_memory()).compareTo(other.is_set_assigned_regular_off_heap_memory()); if (lastComparison != 0) { return lastComparison; } @@ -2519,7 +2459,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_assigned_shared_off_heap_memory()).compareTo(other.is_set_assigned_shared_off_heap_memory()); + lastComparison = java.lang.Boolean.valueOf(is_set_assigned_shared_off_heap_memory()).compareTo(other.is_set_assigned_shared_off_heap_memory()); if (lastComparison != 0) { return lastComparison; } @@ -2537,16 +2477,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } 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("TopologyPageInfo("); + public java.lang.String toString() { + java.lang.StringBuilder sb = new java.lang.StringBuilder("TopologyPageInfo("); boolean first = true; sb.append("id:"); @@ -2817,7 +2757,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } } - 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; @@ -2827,13 +2767,13 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } } - private static class TopologyPageInfoStandardSchemeFactory implements SchemeFactory { + private static class TopologyPageInfoStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { public TopologyPageInfoStandardScheme getScheme() { return new TopologyPageInfoStandardScheme(); } } - private static class TopologyPageInfoStandardScheme extends StandardScheme<TopologyPageInfo> { + private static class TopologyPageInfoStandardScheme extends org.apache.thrift.scheme.StandardScheme<TopologyPageInfo> { public void read(org.apache.thrift.protocol.TProtocol iprot, TopologyPageInfo struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; @@ -2913,8 +2853,8 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { org.apache.thrift.protocol.TMap _map482 = iprot.readMapBegin(); - struct.id_to_spout_agg_stats = new HashMap<String,ComponentAggregateStats>(2*_map482.size); - String _key483; + struct.id_to_spout_agg_stats = new java.util.HashMap<java.lang.String,ComponentAggregateStats>(2*_map482.size); + java.lang.String _key483; ComponentAggregateStats _val484; for (int _i485 = 0; _i485 < _map482.size; ++_i485) { @@ -2934,8 +2874,8 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { org.apache.thrift.protocol.TMap _map486 = iprot.readMapBegin(); - struct.id_to_bolt_agg_stats = new HashMap<String,ComponentAggregateStats>(2*_map486.size); - String _key487; + struct.id_to_bolt_agg_stats = new java.util.HashMap<java.lang.String,ComponentAggregateStats>(2*_map486.size); + java.lang.String _key487; ComponentAggregateStats _val488; for (int _i489 = 0; _i489 < _map486.size; ++_i489) { @@ -2997,7 +2937,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { org.apache.thrift.protocol.TList _list490 = iprot.readListBegin(); - struct.workers = new ArrayList<WorkerSummary>(_list490.size); + struct.workers = new java.util.ArrayList<WorkerSummary>(_list490.size); WorkerSummary _elem491; for (int _i492 = 0; _i492 < _list490.size; ++_i492) { @@ -3204,7 +3144,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf oprot.writeFieldBegin(ID_TO_SPOUT_AGG_STATS_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.id_to_spout_agg_stats.size())); - for (Map.Entry<String, ComponentAggregateStats> _iter493 : struct.id_to_spout_agg_stats.entrySet()) + for (java.util.Map.Entry<java.lang.String, ComponentAggregateStats> _iter493 : struct.id_to_spout_agg_stats.entrySet()) { oprot.writeString(_iter493.getKey()); _iter493.getValue().write(oprot); @@ -3219,7 +3159,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf oprot.writeFieldBegin(ID_TO_BOLT_AGG_STATS_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.id_to_bolt_agg_stats.size())); - for (Map.Entry<String, ComponentAggregateStats> _iter494 : struct.id_to_bolt_agg_stats.entrySet()) + for (java.util.Map.Entry<java.lang.String, ComponentAggregateStats> _iter494 : struct.id_to_bolt_agg_stats.entrySet()) { oprot.writeString(_iter494.getKey()); _iter494.getValue().write(oprot); @@ -3366,19 +3306,19 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf } - private static class TopologyPageInfoTupleSchemeFactory implements SchemeFactory { + private static class TopologyPageInfoTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { public TopologyPageInfoTupleScheme getScheme() { return new TopologyPageInfoTupleScheme(); } } - private static class TopologyPageInfoTupleScheme extends TupleScheme<TopologyPageInfo> { + private static class TopologyPageInfoTupleScheme extends org.apache.thrift.scheme.TupleScheme<TopologyPageInfo> { @Override public void write(org.apache.thrift.protocol.TProtocol prot, TopologyPageInfo struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; + org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot; oprot.writeString(struct.id); - BitSet optionals = new BitSet(); + java.util.BitSet optionals = new java.util.BitSet(); if (struct.is_set_name()) { optionals.set(0); } @@ -3497,7 +3437,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (struct.is_set_id_to_spout_agg_stats()) { { oprot.writeI32(struct.id_to_spout_agg_stats.size()); - for (Map.Entry<String, ComponentAggregateStats> _iter496 : struct.id_to_spout_agg_stats.entrySet()) + for (java.util.Map.Entry<java.lang.String, ComponentAggregateStats> _iter496 : struct.id_to_spout_agg_stats.entrySet()) { oprot.writeString(_iter496.getKey()); _iter496.getValue().write(oprot); @@ -3507,7 +3447,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (struct.is_set_id_to_bolt_agg_stats()) { { oprot.writeI32(struct.id_to_bolt_agg_stats.size()); - for (Map.Entry<String, ComponentAggregateStats> _iter497 : struct.id_to_bolt_agg_stats.entrySet()) + for (java.util.Map.Entry<java.lang.String, ComponentAggregateStats> _iter497 : struct.id_to_bolt_agg_stats.entrySet()) { oprot.writeString(_iter497.getKey()); _iter497.getValue().write(oprot); @@ -3590,10 +3530,10 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf @Override public void read(org.apache.thrift.protocol.TProtocol prot, TopologyPageInfo struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; + org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot; struct.id = iprot.readString(); struct.set_id_isSet(true); - BitSet incoming = iprot.readBitSet(31); + java.util.BitSet incoming = iprot.readBitSet(31); if (incoming.get(0)) { struct.name = iprot.readString(); struct.set_name_isSet(true); @@ -3625,8 +3565,8 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (incoming.get(7)) { { org.apache.thrift.protocol.TMap _map499 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.id_to_spout_agg_stats = new HashMap<String,ComponentAggregateStats>(2*_map499.size); - String _key500; + struct.id_to_spout_agg_stats = new java.util.HashMap<java.lang.String,ComponentAggregateStats>(2*_map499.size); + java.lang.String _key500; ComponentAggregateStats _val501; for (int _i502 = 0; _i502 < _map499.size; ++_i502) { @@ -3641,8 +3581,8 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (incoming.get(8)) { { org.apache.thrift.protocol.TMap _map503 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.id_to_bolt_agg_stats = new HashMap<String,ComponentAggregateStats>(2*_map503.size); - String _key504; + struct.id_to_bolt_agg_stats = new java.util.HashMap<java.lang.String,ComponentAggregateStats>(2*_map503.size); + java.lang.String _key504; ComponentAggregateStats _val505; for (int _i506 = 0; _i506 < _map503.size; ++_i506) { @@ -3679,7 +3619,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf if (incoming.get(14)) { { org.apache.thrift.protocol.TList _list507 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.workers = new ArrayList<WorkerSummary>(_list507.size); + struct.workers = new java.util.ArrayList<WorkerSummary>(_list507.size); WorkerSummary _elem508; for (int _i509 = 0; _i509 < _list507.size; ++_i509) { @@ -3757,5 +3697,8 @@ public class TopologyPageInfo implements org.apache.thri
<TRUNCATED>
