http://git-wip-us.apache.org/repos/asf/storm/blob/1fd1e17f/storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java ---------------------------------------------------------------------- diff --git a/storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java b/storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java index 9b4baa6..e4ea4d8 100644 --- a/storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java +++ b/storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.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 TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, TopologyInfo._Fields>, java.io.Serializable, Cloneable, Comparable<TopologyInfo> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TopologyInfo"); @@ -73,22 +46,19 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol private static final org.apache.thrift.protocol.TField ASSIGNED_MEMOFFHEAP_FIELD_DESC = new org.apache.thrift.protocol.TField("assigned_memoffheap", org.apache.thrift.protocol.TType.DOUBLE, (short)525); private static final org.apache.thrift.protocol.TField ASSIGNED_CPU_FIELD_DESC = new org.apache.thrift.protocol.TField("assigned_cpu", org.apache.thrift.protocol.TType.DOUBLE, (short)526); - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new TopologyInfoStandardSchemeFactory()); - schemes.put(TupleScheme.class, new TopologyInfoTupleSchemeFactory()); - } + private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new TopologyInfoStandardSchemeFactory(); + private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new TopologyInfoTupleSchemeFactory(); - private String id; // required - private String name; // required + private java.lang.String id; // required + private java.lang.String name; // required private int uptime_secs; // required - private List<ExecutorSummary> executors; // required - private String status; // required - private Map<String,List<ErrorInfo>> errors; // required - private Map<String,DebugOptions> component_debug; // optional - private String storm_version; // optional - private String sched_status; // optional - private String owner; // optional + private java.util.List<ExecutorSummary> executors; // required + private java.lang.String status; // required + private java.util.Map<java.lang.String,java.util.List<ErrorInfo>> errors; // required + private java.util.Map<java.lang.String,DebugOptions> component_debug; // optional + private java.lang.String storm_version; // optional + private java.lang.String sched_status; // optional + private java.lang.String owner; // optional private int replication_count; // optional private double requested_memonheap; // optional private double requested_memoffheap; // optional @@ -117,10 +87,10 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol ASSIGNED_MEMOFFHEAP((short)525, "assigned_memoffheap"), ASSIGNED_CPU((short)526, "assigned_cpu"); - 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); } } @@ -175,21 +145,21 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol */ 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; } @@ -198,7 +168,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol return _thriftId; } - public String getFieldName() { + public java.lang.String getFieldName() { return _fieldName; } } @@ -214,9 +184,9 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol private static final int __ASSIGNED_CPU_ISSET_ID = 7; private byte __isset_bitfield = 0; private static final _Fields optionals[] = {_Fields.COMPONENT_DEBUG,_Fields.STORM_VERSION,_Fields.SCHED_STATUS,_Fields.OWNER,_Fields.REPLICATION_COUNT,_Fields.REQUESTED_MEMONHEAP,_Fields.REQUESTED_MEMOFFHEAP,_Fields.REQUESTED_CPU,_Fields.ASSIGNED_MEMONHEAP,_Fields.ASSIGNED_MEMOFFHEAP,_Fields.ASSIGNED_CPU}; - 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.REQUIRED, @@ -257,7 +227,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE))); tmpMap.put(_Fields.ASSIGNED_CPU, new org.apache.thrift.meta_data.FieldMetaData("assigned_cpu", 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(TopologyInfo.class, metaDataMap); } @@ -265,12 +235,12 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } public TopologyInfo( - String id, - String name, + java.lang.String id, + java.lang.String name, int uptime_secs, - List<ExecutorSummary> executors, - String status, - Map<String,List<ErrorInfo>> errors) + java.util.List<ExecutorSummary> executors, + java.lang.String status, + java.util.Map<java.lang.String,java.util.List<ErrorInfo>> errors) { this(); this.id = id; @@ -295,7 +265,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } this.uptime_secs = other.uptime_secs; if (other.is_set_executors()) { - List<ExecutorSummary> __this__executors = new ArrayList<ExecutorSummary>(other.executors.size()); + java.util.List<ExecutorSummary> __this__executors = new java.util.ArrayList<ExecutorSummary>(other.executors.size()); for (ExecutorSummary other_element : other.executors) { __this__executors.add(new ExecutorSummary(other_element)); } @@ -305,15 +275,15 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol this.status = other.status; } if (other.is_set_errors()) { - Map<String,List<ErrorInfo>> __this__errors = new HashMap<String,List<ErrorInfo>>(other.errors.size()); - for (Map.Entry<String, List<ErrorInfo>> other_element : other.errors.entrySet()) { + java.util.Map<java.lang.String,java.util.List<ErrorInfo>> __this__errors = new java.util.HashMap<java.lang.String,java.util.List<ErrorInfo>>(other.errors.size()); + for (java.util.Map.Entry<java.lang.String, java.util.List<ErrorInfo>> other_element : other.errors.entrySet()) { - String other_element_key = other_element.getKey(); - List<ErrorInfo> other_element_value = other_element.getValue(); + java.lang.String other_element_key = other_element.getKey(); + java.util.List<ErrorInfo> other_element_value = other_element.getValue(); - String __this__errors_copy_key = other_element_key; + java.lang.String __this__errors_copy_key = other_element_key; - List<ErrorInfo> __this__errors_copy_value = new ArrayList<ErrorInfo>(other_element_value.size()); + java.util.List<ErrorInfo> __this__errors_copy_value = new java.util.ArrayList<ErrorInfo>(other_element_value.size()); for (ErrorInfo other_element_value_element : other_element_value) { __this__errors_copy_value.add(new ErrorInfo(other_element_value_element)); } @@ -323,13 +293,13 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol this.errors = __this__errors; } if (other.is_set_component_debug()) { - Map<String,DebugOptions> __this__component_debug = new HashMap<String,DebugOptions>(other.component_debug.size()); - for (Map.Entry<String, DebugOptions> other_element : other.component_debug.entrySet()) { + java.util.Map<java.lang.String,DebugOptions> __this__component_debug = new java.util.HashMap<java.lang.String,DebugOptions>(other.component_debug.size()); + for (java.util.Map.Entry<java.lang.String, DebugOptions> other_element : other.component_debug.entrySet()) { - String other_element_key = other_element.getKey(); + java.lang.String other_element_key = other_element.getKey(); DebugOptions other_element_value = other_element.getValue(); - String __this__component_debug_copy_key = other_element_key; + java.lang.String __this__component_debug_copy_key = other_element_key; DebugOptions __this__component_debug_copy_value = new DebugOptions(other_element_value); @@ -388,11 +358,11 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol this.assigned_cpu = 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; } @@ -411,11 +381,11 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } } - 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; } @@ -444,16 +414,16 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } 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 int get_executors_size() { @@ -466,16 +436,16 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol public void add_to_executors(ExecutorSummary elem) { if (this.executors == null) { - this.executors = new ArrayList<ExecutorSummary>(); + this.executors = new java.util.ArrayList<ExecutorSummary>(); } this.executors.add(elem); } - public List<ExecutorSummary> get_executors() { + public java.util.List<ExecutorSummary> get_executors() { return this.executors; } - public void set_executors(List<ExecutorSummary> executors) { + public void set_executors(java.util.List<ExecutorSummary> executors) { this.executors = executors; } @@ -494,11 +464,11 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } } - 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; } @@ -521,18 +491,18 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol return (this.errors == null) ? 0 : this.errors.size(); } - public void put_to_errors(String key, List<ErrorInfo> val) { + public void put_to_errors(java.lang.String key, java.util.List<ErrorInfo> val) { if (this.errors == null) { - this.errors = new HashMap<String,List<ErrorInfo>>(); + this.errors = new java.util.HashMap<java.lang.String,java.util.List<ErrorInfo>>(); } this.errors.put(key, val); } - public Map<String,List<ErrorInfo>> get_errors() { + public java.util.Map<java.lang.String,java.util.List<ErrorInfo>> get_errors() { return this.errors; } - public void set_errors(Map<String,List<ErrorInfo>> errors) { + public void set_errors(java.util.Map<java.lang.String,java.util.List<ErrorInfo>> errors) { this.errors = errors; } @@ -555,18 +525,18 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol return (this.component_debug == null) ? 0 : this.component_debug.size(); } - public void put_to_component_debug(String key, DebugOptions val) { + public void put_to_component_debug(java.lang.String key, DebugOptions val) { if (this.component_debug == null) { - this.component_debug = new HashMap<String,DebugOptions>(); + this.component_debug = new java.util.HashMap<java.lang.String,DebugOptions>(); } this.component_debug.put(key, val); } - public Map<String,DebugOptions> get_component_debug() { + public java.util.Map<java.lang.String,DebugOptions> get_component_debug() { return this.component_debug; } - public void set_component_debug(Map<String,DebugOptions> component_debug) { + public void set_component_debug(java.util.Map<java.lang.String,DebugOptions> component_debug) { this.component_debug = component_debug; } @@ -585,11 +555,11 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } } - 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; } @@ -608,11 +578,11 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } } - 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; } @@ -631,11 +601,11 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } } - 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; } @@ -664,16 +634,16 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } 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 double get_requested_memonheap() { @@ -686,16 +656,16 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } 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() { @@ -708,16 +678,16 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } 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() { @@ -730,16 +700,16 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } 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() { @@ -752,16 +722,16 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } 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() { @@ -774,16 +744,16 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } 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() { @@ -796,25 +766,25 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } 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 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; @@ -822,7 +792,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (value == null) { unset_name(); } else { - set_name((String)value); + set_name((java.lang.String)value); } break; @@ -830,7 +800,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (value == null) { unset_uptime_secs(); } else { - set_uptime_secs((Integer)value); + set_uptime_secs((java.lang.Integer)value); } break; @@ -838,7 +808,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (value == null) { unset_executors(); } else { - set_executors((List<ExecutorSummary>)value); + set_executors((java.util.List<ExecutorSummary>)value); } break; @@ -846,7 +816,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (value == null) { unset_status(); } else { - set_status((String)value); + set_status((java.lang.String)value); } break; @@ -854,7 +824,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (value == null) { unset_errors(); } else { - set_errors((Map<String,List<ErrorInfo>>)value); + set_errors((java.util.Map<java.lang.String,java.util.List<ErrorInfo>>)value); } break; @@ -862,7 +832,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (value == null) { unset_component_debug(); } else { - set_component_debug((Map<String,DebugOptions>)value); + set_component_debug((java.util.Map<java.lang.String,DebugOptions>)value); } break; @@ -870,7 +840,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (value == null) { unset_storm_version(); } else { - set_storm_version((String)value); + set_storm_version((java.lang.String)value); } break; @@ -878,7 +848,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (value == null) { unset_sched_status(); } else { - set_sched_status((String)value); + set_sched_status((java.lang.String)value); } break; @@ -886,7 +856,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (value == null) { unset_owner(); } else { - set_owner((String)value); + set_owner((java.lang.String)value); } break; @@ -894,7 +864,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (value == null) { unset_replication_count(); } else { - set_replication_count((Integer)value); + set_replication_count((java.lang.Integer)value); } break; @@ -902,7 +872,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (value == null) { unset_requested_memonheap(); } else { - set_requested_memonheap((Double)value); + set_requested_memonheap((java.lang.Double)value); } break; @@ -910,7 +880,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (value == null) { unset_requested_memoffheap(); } else { - set_requested_memoffheap((Double)value); + set_requested_memoffheap((java.lang.Double)value); } break; @@ -918,7 +888,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (value == null) { unset_requested_cpu(); } else { - set_requested_cpu((Double)value); + set_requested_cpu((java.lang.Double)value); } break; @@ -926,7 +896,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (value == null) { unset_assigned_memonheap(); } else { - set_assigned_memonheap((Double)value); + set_assigned_memonheap((java.lang.Double)value); } break; @@ -934,7 +904,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (value == null) { unset_assigned_memoffheap(); } else { - set_assigned_memoffheap((Double)value); + set_assigned_memoffheap((java.lang.Double)value); } break; @@ -942,14 +912,14 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (value == null) { unset_assigned_cpu(); } else { - set_assigned_cpu((Double)value); + set_assigned_cpu((java.lang.Double)value); } break; } } - public Object getFieldValue(_Fields field) { + public java.lang.Object getFieldValue(_Fields field) { switch (field) { case ID: return get_id(); @@ -1003,13 +973,13 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol return get_assigned_cpu(); } - 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) { @@ -1048,11 +1018,11 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol case ASSIGNED_CPU: return is_set_assigned_cpu(); } - 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 TopologyInfo) @@ -1063,6 +1033,8 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol public boolean equals(TopologyInfo 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(); @@ -1222,94 +1194,75 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol @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; - list.add(present_uptime_secs); - if (present_uptime_secs) - list.add(uptime_secs); - - boolean present_executors = true && (is_set_executors()); - list.add(present_executors); - if (present_executors) - list.add(executors); - - boolean present_status = true && (is_set_status()); - list.add(present_status); - if (present_status) - list.add(status); - - boolean present_errors = true && (is_set_errors()); - list.add(present_errors); - if (present_errors) - list.add(errors); - - boolean present_component_debug = true && (is_set_component_debug()); - list.add(present_component_debug); - if (present_component_debug) - list.add(component_debug); - - boolean present_storm_version = true && (is_set_storm_version()); - list.add(present_storm_version); - if (present_storm_version) - list.add(storm_version); - - boolean present_sched_status = true && (is_set_sched_status()); - list.add(present_sched_status); - if (present_sched_status) - list.add(sched_status); - - boolean present_owner = true && (is_set_owner()); - list.add(present_owner); - if (present_owner) - list.add(owner); - - boolean present_replication_count = true && (is_set_replication_count()); - list.add(present_replication_count); - if (present_replication_count) - list.add(replication_count); - - 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); - - 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 + uptime_secs; + + hashCode = hashCode * 8191 + ((is_set_executors()) ? 131071 : 524287); + if (is_set_executors()) + hashCode = hashCode * 8191 + executors.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_status()) ? 131071 : 524287); + if (is_set_status()) + hashCode = hashCode * 8191 + status.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_errors()) ? 131071 : 524287); + if (is_set_errors()) + hashCode = hashCode * 8191 + errors.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_component_debug()) ? 131071 : 524287); + if (is_set_component_debug()) + hashCode = hashCode * 8191 + component_debug.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_sched_status()) ? 131071 : 524287); + if (is_set_sched_status()) + hashCode = hashCode * 8191 + sched_status.hashCode(); + + hashCode = hashCode * 8191 + ((is_set_owner()) ? 131071 : 524287); + if (is_set_owner()) + hashCode = hashCode * 8191 + owner.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_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); + + return hashCode; } @Override @@ -1320,7 +1273,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol 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; } @@ -1330,7 +1283,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol 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; } @@ -1340,7 +1293,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol 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; } @@ -1350,7 +1303,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_executors()).compareTo(other.is_set_executors()); + lastComparison = java.lang.Boolean.valueOf(is_set_executors()).compareTo(other.is_set_executors()); if (lastComparison != 0) { return lastComparison; } @@ -1360,7 +1313,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol 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; } @@ -1370,7 +1323,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_errors()).compareTo(other.is_set_errors()); + lastComparison = java.lang.Boolean.valueOf(is_set_errors()).compareTo(other.is_set_errors()); if (lastComparison != 0) { return lastComparison; } @@ -1380,7 +1333,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_component_debug()).compareTo(other.is_set_component_debug()); + lastComparison = java.lang.Boolean.valueOf(is_set_component_debug()).compareTo(other.is_set_component_debug()); if (lastComparison != 0) { return lastComparison; } @@ -1390,7 +1343,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol 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; } @@ -1400,7 +1353,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol 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; } @@ -1410,7 +1363,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol 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; } @@ -1420,7 +1373,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol 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; } @@ -1430,7 +1383,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol 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; } @@ -1440,7 +1393,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol 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; } @@ -1450,7 +1403,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol 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; } @@ -1460,7 +1413,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol 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; } @@ -1470,7 +1423,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol 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; } @@ -1480,7 +1433,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol 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; } @@ -1498,16 +1451,16 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } 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("TopologyInfo("); + public java.lang.String toString() { + java.lang.StringBuilder sb = new java.lang.StringBuilder("TopologyInfo("); boolean first = true; sb.append("id:"); @@ -1676,7 +1629,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } } - 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; @@ -1686,13 +1639,13 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } } - private static class TopologyInfoStandardSchemeFactory implements SchemeFactory { + private static class TopologyInfoStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { public TopologyInfoStandardScheme getScheme() { return new TopologyInfoStandardScheme(); } } - private static class TopologyInfoStandardScheme extends StandardScheme<TopologyInfo> { + private static class TopologyInfoStandardScheme extends org.apache.thrift.scheme.StandardScheme<TopologyInfo> { public void read(org.apache.thrift.protocol.TProtocol iprot, TopologyInfo struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; @@ -1732,7 +1685,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { org.apache.thrift.protocol.TList _list360 = iprot.readListBegin(); - struct.executors = new ArrayList<ExecutorSummary>(_list360.size); + struct.executors = new java.util.ArrayList<ExecutorSummary>(_list360.size); ExecutorSummary _elem361; for (int _i362 = 0; _i362 < _list360.size; ++_i362) { @@ -1759,15 +1712,15 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { org.apache.thrift.protocol.TMap _map363 = iprot.readMapBegin(); - struct.errors = new HashMap<String,List<ErrorInfo>>(2*_map363.size); - String _key364; - List<ErrorInfo> _val365; + struct.errors = new java.util.HashMap<java.lang.String,java.util.List<ErrorInfo>>(2*_map363.size); + java.lang.String _key364; + java.util.List<ErrorInfo> _val365; for (int _i366 = 0; _i366 < _map363.size; ++_i366) { _key364 = iprot.readString(); { org.apache.thrift.protocol.TList _list367 = iprot.readListBegin(); - _val365 = new ArrayList<ErrorInfo>(_list367.size); + _val365 = new java.util.ArrayList<ErrorInfo>(_list367.size); ErrorInfo _elem368; for (int _i369 = 0; _i369 < _list367.size; ++_i369) { @@ -1790,8 +1743,8 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { org.apache.thrift.protocol.TMap _map370 = iprot.readMapBegin(); - struct.component_debug = new HashMap<String,DebugOptions>(2*_map370.size); - String _key371; + struct.component_debug = new java.util.HashMap<java.lang.String,DebugOptions>(2*_map370.size); + java.lang.String _key371; DebugOptions _val372; for (int _i373 = 0; _i373 < _map370.size; ++_i373) { @@ -1934,7 +1887,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol oprot.writeFieldBegin(ERRORS_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.LIST, struct.errors.size())); - for (Map.Entry<String, List<ErrorInfo>> _iter375 : struct.errors.entrySet()) + for (java.util.Map.Entry<java.lang.String, java.util.List<ErrorInfo>> _iter375 : struct.errors.entrySet()) { oprot.writeString(_iter375.getKey()); { @@ -1955,7 +1908,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol oprot.writeFieldBegin(COMPONENT_DEBUG_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.component_debug.size())); - for (Map.Entry<String, DebugOptions> _iter377 : struct.component_debug.entrySet()) + for (java.util.Map.Entry<java.lang.String, DebugOptions> _iter377 : struct.component_debug.entrySet()) { oprot.writeString(_iter377.getKey()); _iter377.getValue().write(oprot); @@ -2027,17 +1980,17 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } - private static class TopologyInfoTupleSchemeFactory implements SchemeFactory { + private static class TopologyInfoTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { public TopologyInfoTupleScheme getScheme() { return new TopologyInfoTupleScheme(); } } - private static class TopologyInfoTupleScheme extends TupleScheme<TopologyInfo> { + private static class TopologyInfoTupleScheme extends org.apache.thrift.scheme.TupleScheme<TopologyInfo> { @Override public void write(org.apache.thrift.protocol.TProtocol prot, TopologyInfo 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); oprot.writeString(struct.name); oprot.writeI32(struct.uptime_secs); @@ -2051,7 +2004,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol oprot.writeString(struct.status); { oprot.writeI32(struct.errors.size()); - for (Map.Entry<String, List<ErrorInfo>> _iter379 : struct.errors.entrySet()) + for (java.util.Map.Entry<java.lang.String, java.util.List<ErrorInfo>> _iter379 : struct.errors.entrySet()) { oprot.writeString(_iter379.getKey()); { @@ -2063,7 +2016,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } } } - BitSet optionals = new BitSet(); + java.util.BitSet optionals = new java.util.BitSet(); if (struct.is_set_component_debug()) { optionals.set(0); } @@ -2101,7 +2054,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol if (struct.is_set_component_debug()) { { oprot.writeI32(struct.component_debug.size()); - for (Map.Entry<String, DebugOptions> _iter381 : struct.component_debug.entrySet()) + for (java.util.Map.Entry<java.lang.String, DebugOptions> _iter381 : struct.component_debug.entrySet()) { oprot.writeString(_iter381.getKey()); _iter381.getValue().write(oprot); @@ -2142,7 +2095,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol @Override public void read(org.apache.thrift.protocol.TProtocol prot, TopologyInfo 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); struct.name = iprot.readString(); @@ -2151,7 +2104,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol struct.set_uptime_secs_isSet(true); { org.apache.thrift.protocol.TList _list382 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.executors = new ArrayList<ExecutorSummary>(_list382.size); + struct.executors = new java.util.ArrayList<ExecutorSummary>(_list382.size); ExecutorSummary _elem383; for (int _i384 = 0; _i384 < _list382.size; ++_i384) { @@ -2165,15 +2118,15 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol struct.set_status_isSet(true); { org.apache.thrift.protocol.TMap _map385 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.LIST, iprot.readI32()); - struct.errors = new HashMap<String,List<ErrorInfo>>(2*_map385.size); - String _key386; - List<ErrorInfo> _val387; + struct.errors = new java.util.HashMap<java.lang.String,java.util.List<ErrorInfo>>(2*_map385.size); + java.lang.String _key386; + java.util.List<ErrorInfo> _val387; for (int _i388 = 0; _i388 < _map385.size; ++_i388) { _key386 = iprot.readString(); { org.apache.thrift.protocol.TList _list389 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - _val387 = new ArrayList<ErrorInfo>(_list389.size); + _val387 = new java.util.ArrayList<ErrorInfo>(_list389.size); ErrorInfo _elem390; for (int _i391 = 0; _i391 < _list389.size; ++_i391) { @@ -2186,12 +2139,12 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } } struct.set_errors_isSet(true); - BitSet incoming = iprot.readBitSet(11); + java.util.BitSet incoming = iprot.readBitSet(11); if (incoming.get(0)) { { org.apache.thrift.protocol.TMap _map392 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.component_debug = new HashMap<String,DebugOptions>(2*_map392.size); - String _key393; + struct.component_debug = new java.util.HashMap<java.lang.String,DebugOptions>(2*_map392.size); + java.lang.String _key393; DebugOptions _val394; for (int _i395 = 0; _i395 < _map392.size; ++_i395) { @@ -2246,5 +2199,8 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol } } + private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) { + return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme(); + } }
http://git-wip-us.apache.org/repos/asf/storm/blob/1fd1e17f/storm-client/src/jvm/org/apache/storm/generated/TopologyInitialStatus.java ---------------------------------------------------------------------- diff --git a/storm-client/src/jvm/org/apache/storm/generated/TopologyInitialStatus.java b/storm-client/src/jvm/org/apache/storm/generated/TopologyInitialStatus.java index 5cf2894..c393179 100644 --- a/storm-client/src/jvm/org/apache/storm/generated/TopologyInitialStatus.java +++ b/storm-client/src/jvm/org/apache/storm/generated/TopologyInitialStatus.java @@ -16,7 +16,7 @@ * 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 @@ -24,10 +24,6 @@ package org.apache.storm.generated; -import java.util.Map; -import java.util.HashMap; -import org.apache.thrift.TEnum; - public enum TopologyInitialStatus implements org.apache.thrift.TEnum { ACTIVE(1), INACTIVE(2);
