You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2018/05/23 20:03:40 UTC
[10/43] storm git commit: STORM-3061: thrift 0.11
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"})
+@javax.annotation.Generated(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>