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:48 UTC
[18/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/StormBase.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/generated/StormBase.java b/storm-client/src/jvm/org/apache/storm/generated/StormBase.java
index 733da58..78cd90e 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/StormBase.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/StormBase.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 StormBase implements org.apache.thrift.TBase<StormBase, StormBase._Fields>, java.io.Serializable, Cloneable, Comparable<StormBase> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("StormBase");
@@ -67,23 +40,20 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
private static final org.apache.thrift.protocol.TField PRINCIPAL_FIELD_DESC = new org.apache.thrift.protocol.TField("principal", org.apache.thrift.protocol.TType.STRING, (short)10);
private static final org.apache.thrift.protocol.TField TOPOLOGY_VERSION_FIELD_DESC = new org.apache.thrift.protocol.TField("topology_version", org.apache.thrift.protocol.TType.STRING, (short)11);
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new StormBaseStandardSchemeFactory());
- schemes.put(TupleScheme.class, new StormBaseTupleSchemeFactory());
- }
+ private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new StormBaseStandardSchemeFactory();
+ private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new StormBaseTupleSchemeFactory();
- private String name; // required
+ private java.lang.String name; // required
private TopologyStatus status; // required
private int num_workers; // required
- private Map<String,Integer> component_executors; // optional
+ private java.util.Map<java.lang.String,java.lang.Integer> component_executors; // optional
private int launch_time_secs; // optional
- private String owner; // optional
+ private java.lang.String owner; // optional
private TopologyActionOptions topology_action_options; // optional
private TopologyStatus prev_status; // optional
- private Map<String,DebugOptions> component_debug; // optional
- private String principal; // optional
- private String topology_version; // optional
+ private java.util.Map<java.lang.String,DebugOptions> component_debug; // optional
+ private java.lang.String principal; // optional
+ private java.lang.String topology_version; // optional
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
@@ -107,10 +77,10 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
PRINCIPAL((short)10, "principal"),
TOPOLOGY_VERSION((short)11, "topology_version");
- 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);
}
}
@@ -153,21 +123,21 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
*/
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;
}
@@ -176,7 +146,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
return _thriftId;
}
- public String getFieldName() {
+ public java.lang.String getFieldName() {
return _fieldName;
}
}
@@ -186,9 +156,9 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
private static final int __LAUNCH_TIME_SECS_ISSET_ID = 1;
private byte __isset_bitfield = 0;
private static final _Fields optionals[] = {_Fields.COMPONENT_EXECUTORS,_Fields.LAUNCH_TIME_SECS,_Fields.OWNER,_Fields.TOPOLOGY_ACTION_OPTIONS,_Fields.PREV_STATUS,_Fields.COMPONENT_DEBUG,_Fields.PRINCIPAL,_Fields.TOPOLOGY_VERSION};
- 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.NAME, new org.apache.thrift.meta_data.FieldMetaData("name", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.STATUS, new org.apache.thrift.meta_data.FieldMetaData("status", org.apache.thrift.TFieldRequirementType.REQUIRED,
@@ -215,7 +185,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.TOPOLOGY_VERSION, new org.apache.thrift.meta_data.FieldMetaData("topology_version", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
+ metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(StormBase.class, metaDataMap);
}
@@ -223,7 +193,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
}
public StormBase(
- String name,
+ java.lang.String name,
TopologyStatus status,
int num_workers)
{
@@ -247,7 +217,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
}
this.num_workers = other.num_workers;
if (other.is_set_component_executors()) {
- Map<String,Integer> __this__component_executors = new HashMap<String,Integer>(other.component_executors);
+ java.util.Map<java.lang.String,java.lang.Integer> __this__component_executors = new java.util.HashMap<java.lang.String,java.lang.Integer>(other.component_executors);
this.component_executors = __this__component_executors;
}
this.launch_time_secs = other.launch_time_secs;
@@ -261,13 +231,13 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
this.prev_status = other.prev_status;
}
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);
@@ -304,11 +274,11 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
this.topology_version = null;
}
- 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;
}
@@ -368,34 +338,34 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
}
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_component_executors_size() {
return (this.component_executors == null) ? 0 : this.component_executors.size();
}
- public void put_to_component_executors(String key, int val) {
+ public void put_to_component_executors(java.lang.String key, int val) {
if (this.component_executors == null) {
- this.component_executors = new HashMap<String,Integer>();
+ this.component_executors = new java.util.HashMap<java.lang.String,java.lang.Integer>();
}
this.component_executors.put(key, val);
}
- public Map<String,Integer> get_component_executors() {
+ public java.util.Map<java.lang.String,java.lang.Integer> get_component_executors() {
return this.component_executors;
}
- public void set_component_executors(Map<String,Integer> component_executors) {
+ public void set_component_executors(java.util.Map<java.lang.String,java.lang.Integer> component_executors) {
this.component_executors = component_executors;
}
@@ -424,23 +394,23 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
}
public void unset_launch_time_secs() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __LAUNCH_TIME_SECS_ISSET_ID);
+ __isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __LAUNCH_TIME_SECS_ISSET_ID);
}
/** Returns true if field launch_time_secs is set (has been assigned a value) and false otherwise */
public boolean is_set_launch_time_secs() {
- return EncodingUtils.testBit(__isset_bitfield, __LAUNCH_TIME_SECS_ISSET_ID);
+ return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __LAUNCH_TIME_SECS_ISSET_ID);
}
public void set_launch_time_secs_isSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __LAUNCH_TIME_SECS_ISSET_ID, value);
+ __isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __LAUNCH_TIME_SECS_ISSET_ID, value);
}
- 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;
}
@@ -517,18 +487,18 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
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;
}
@@ -547,11 +517,11 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
}
}
- public String get_principal() {
+ public java.lang.String get_principal() {
return this.principal;
}
- public void set_principal(String principal) {
+ public void set_principal(java.lang.String principal) {
this.principal = principal;
}
@@ -570,11 +540,11 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
}
}
- 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;
}
@@ -593,13 +563,13 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
}
}
- public void setFieldValue(_Fields field, Object value) {
+ public void setFieldValue(_Fields field, java.lang.Object value) {
switch (field) {
case NAME:
if (value == null) {
unset_name();
} else {
- set_name((String)value);
+ set_name((java.lang.String)value);
}
break;
@@ -615,7 +585,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
if (value == null) {
unset_num_workers();
} else {
- set_num_workers((Integer)value);
+ set_num_workers((java.lang.Integer)value);
}
break;
@@ -623,7 +593,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
if (value == null) {
unset_component_executors();
} else {
- set_component_executors((Map<String,Integer>)value);
+ set_component_executors((java.util.Map<java.lang.String,java.lang.Integer>)value);
}
break;
@@ -631,7 +601,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
if (value == null) {
unset_launch_time_secs();
} else {
- set_launch_time_secs((Integer)value);
+ set_launch_time_secs((java.lang.Integer)value);
}
break;
@@ -639,7 +609,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
if (value == null) {
unset_owner();
} else {
- set_owner((String)value);
+ set_owner((java.lang.String)value);
}
break;
@@ -663,7 +633,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
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;
@@ -671,7 +641,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
if (value == null) {
unset_principal();
} else {
- set_principal((String)value);
+ set_principal((java.lang.String)value);
}
break;
@@ -679,14 +649,14 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
if (value == null) {
unset_topology_version();
} else {
- set_topology_version((String)value);
+ set_topology_version((java.lang.String)value);
}
break;
}
}
- public Object getFieldValue(_Fields field) {
+ public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case NAME:
return get_name();
@@ -722,13 +692,13 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
return get_topology_version();
}
- 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) {
@@ -755,11 +725,11 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
case TOPOLOGY_VERSION:
return is_set_topology_version();
}
- 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 StormBase)
@@ -770,6 +740,8 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
public boolean equals(StormBase that) {
if (that == null)
return false;
+ if (this == that)
+ return true;
boolean this_present_name = true && this.is_set_name();
boolean that_present_name = true && that.is_set_name();
@@ -875,64 +847,51 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
@Override
public int hashCode() {
- List<Object> list = new ArrayList<Object>();
-
- boolean present_name = true && (is_set_name());
- list.add(present_name);
- if (present_name)
- list.add(name);
-
- boolean present_status = true && (is_set_status());
- list.add(present_status);
- if (present_status)
- list.add(status.getValue());
-
- boolean present_num_workers = true;
- list.add(present_num_workers);
- if (present_num_workers)
- list.add(num_workers);
-
- boolean present_component_executors = true && (is_set_component_executors());
- list.add(present_component_executors);
- if (present_component_executors)
- list.add(component_executors);
-
- boolean present_launch_time_secs = true && (is_set_launch_time_secs());
- list.add(present_launch_time_secs);
- if (present_launch_time_secs)
- list.add(launch_time_secs);
-
- boolean present_owner = true && (is_set_owner());
- list.add(present_owner);
- if (present_owner)
- list.add(owner);
-
- boolean present_topology_action_options = true && (is_set_topology_action_options());
- list.add(present_topology_action_options);
- if (present_topology_action_options)
- list.add(topology_action_options);
-
- boolean present_prev_status = true && (is_set_prev_status());
- list.add(present_prev_status);
- if (present_prev_status)
- list.add(prev_status.getValue());
-
- boolean present_component_debug = true && (is_set_component_debug());
- list.add(present_component_debug);
- if (present_component_debug)
- list.add(component_debug);
-
- boolean present_principal = true && (is_set_principal());
- list.add(present_principal);
- if (present_principal)
- list.add(principal);
-
- boolean present_topology_version = true && (is_set_topology_version());
- list.add(present_topology_version);
- if (present_topology_version)
- list.add(topology_version);
-
- return list.hashCode();
+ int hashCode = 1;
+
+ hashCode = hashCode * 8191 + ((is_set_name()) ? 131071 : 524287);
+ if (is_set_name())
+ hashCode = hashCode * 8191 + name.hashCode();
+
+ hashCode = hashCode * 8191 + ((is_set_status()) ? 131071 : 524287);
+ if (is_set_status())
+ hashCode = hashCode * 8191 + status.getValue();
+
+ hashCode = hashCode * 8191 + num_workers;
+
+ hashCode = hashCode * 8191 + ((is_set_component_executors()) ? 131071 : 524287);
+ if (is_set_component_executors())
+ hashCode = hashCode * 8191 + component_executors.hashCode();
+
+ hashCode = hashCode * 8191 + ((is_set_launch_time_secs()) ? 131071 : 524287);
+ if (is_set_launch_time_secs())
+ hashCode = hashCode * 8191 + launch_time_secs;
+
+ hashCode = hashCode * 8191 + ((is_set_owner()) ? 131071 : 524287);
+ if (is_set_owner())
+ hashCode = hashCode * 8191 + owner.hashCode();
+
+ hashCode = hashCode * 8191 + ((is_set_topology_action_options()) ? 131071 : 524287);
+ if (is_set_topology_action_options())
+ hashCode = hashCode * 8191 + topology_action_options.hashCode();
+
+ hashCode = hashCode * 8191 + ((is_set_prev_status()) ? 131071 : 524287);
+ if (is_set_prev_status())
+ hashCode = hashCode * 8191 + prev_status.getValue();
+
+ 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_principal()) ? 131071 : 524287);
+ if (is_set_principal())
+ hashCode = hashCode * 8191 + principal.hashCode();
+
+ hashCode = hashCode * 8191 + ((is_set_topology_version()) ? 131071 : 524287);
+ if (is_set_topology_version())
+ hashCode = hashCode * 8191 + topology_version.hashCode();
+
+ return hashCode;
}
@Override
@@ -943,7 +902,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
int lastComparison = 0;
- 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;
}
@@ -953,7 +912,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
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;
}
@@ -963,7 +922,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
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;
}
@@ -973,7 +932,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_component_executors()).compareTo(other.is_set_component_executors());
+ lastComparison = java.lang.Boolean.valueOf(is_set_component_executors()).compareTo(other.is_set_component_executors());
if (lastComparison != 0) {
return lastComparison;
}
@@ -983,7 +942,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_launch_time_secs()).compareTo(other.is_set_launch_time_secs());
+ lastComparison = java.lang.Boolean.valueOf(is_set_launch_time_secs()).compareTo(other.is_set_launch_time_secs());
if (lastComparison != 0) {
return lastComparison;
}
@@ -993,7 +952,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
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;
}
@@ -1003,7 +962,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_topology_action_options()).compareTo(other.is_set_topology_action_options());
+ lastComparison = java.lang.Boolean.valueOf(is_set_topology_action_options()).compareTo(other.is_set_topology_action_options());
if (lastComparison != 0) {
return lastComparison;
}
@@ -1013,7 +972,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_prev_status()).compareTo(other.is_set_prev_status());
+ lastComparison = java.lang.Boolean.valueOf(is_set_prev_status()).compareTo(other.is_set_prev_status());
if (lastComparison != 0) {
return lastComparison;
}
@@ -1023,7 +982,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
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;
}
@@ -1033,7 +992,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_principal()).compareTo(other.is_set_principal());
+ lastComparison = java.lang.Boolean.valueOf(is_set_principal()).compareTo(other.is_set_principal());
if (lastComparison != 0) {
return lastComparison;
}
@@ -1043,7 +1002,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
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;
}
@@ -1061,16 +1020,16 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
}
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("StormBase(");
+ public java.lang.String toString() {
+ java.lang.StringBuilder sb = new java.lang.StringBuilder("StormBase(");
boolean first = true;
sb.append("name:");
@@ -1197,7 +1156,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
}
}
- 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;
@@ -1207,13 +1166,13 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
}
}
- private static class StormBaseStandardSchemeFactory implements SchemeFactory {
+ private static class StormBaseStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public StormBaseStandardScheme getScheme() {
return new StormBaseStandardScheme();
}
}
- private static class StormBaseStandardScheme extends StandardScheme<StormBase> {
+ private static class StormBaseStandardScheme extends org.apache.thrift.scheme.StandardScheme<StormBase> {
public void read(org.apache.thrift.protocol.TProtocol iprot, StormBase struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
@@ -1253,8 +1212,8 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map752 = iprot.readMapBegin();
- struct.component_executors = new HashMap<String,Integer>(2*_map752.size);
- String _key753;
+ struct.component_executors = new java.util.HashMap<java.lang.String,java.lang.Integer>(2*_map752.size);
+ java.lang.String _key753;
int _val754;
for (int _i755 = 0; _i755 < _map752.size; ++_i755)
{
@@ -1306,8 +1265,8 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map756 = iprot.readMapBegin();
- struct.component_debug = new HashMap<String,DebugOptions>(2*_map756.size);
- String _key757;
+ struct.component_debug = new java.util.HashMap<java.lang.String,DebugOptions>(2*_map756.size);
+ java.lang.String _key757;
DebugOptions _val758;
for (int _i759 = 0; _i759 < _map756.size; ++_i759)
{
@@ -1370,7 +1329,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
oprot.writeFieldBegin(COMPONENT_EXECUTORS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, struct.component_executors.size()));
- for (Map.Entry<String, Integer> _iter760 : struct.component_executors.entrySet())
+ for (java.util.Map.Entry<java.lang.String, java.lang.Integer> _iter760 : struct.component_executors.entrySet())
{
oprot.writeString(_iter760.getKey());
oprot.writeI32(_iter760.getValue());
@@ -1411,7 +1370,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
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> _iter761 : struct.component_debug.entrySet())
+ for (java.util.Map.Entry<java.lang.String, DebugOptions> _iter761 : struct.component_debug.entrySet())
{
oprot.writeString(_iter761.getKey());
_iter761.getValue().write(oprot);
@@ -1441,21 +1400,21 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
}
- private static class StormBaseTupleSchemeFactory implements SchemeFactory {
+ private static class StormBaseTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public StormBaseTupleScheme getScheme() {
return new StormBaseTupleScheme();
}
}
- private static class StormBaseTupleScheme extends TupleScheme<StormBase> {
+ private static class StormBaseTupleScheme extends org.apache.thrift.scheme.TupleScheme<StormBase> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, StormBase 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.name);
oprot.writeI32(struct.status.getValue());
oprot.writeI32(struct.num_workers);
- BitSet optionals = new BitSet();
+ java.util.BitSet optionals = new java.util.BitSet();
if (struct.is_set_component_executors()) {
optionals.set(0);
}
@@ -1484,7 +1443,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
if (struct.is_set_component_executors()) {
{
oprot.writeI32(struct.component_executors.size());
- for (Map.Entry<String, Integer> _iter762 : struct.component_executors.entrySet())
+ for (java.util.Map.Entry<java.lang.String, java.lang.Integer> _iter762 : struct.component_executors.entrySet())
{
oprot.writeString(_iter762.getKey());
oprot.writeI32(_iter762.getValue());
@@ -1506,7 +1465,7 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
if (struct.is_set_component_debug()) {
{
oprot.writeI32(struct.component_debug.size());
- for (Map.Entry<String, DebugOptions> _iter763 : struct.component_debug.entrySet())
+ for (java.util.Map.Entry<java.lang.String, DebugOptions> _iter763 : struct.component_debug.entrySet())
{
oprot.writeString(_iter763.getKey());
_iter763.getValue().write(oprot);
@@ -1523,19 +1482,19 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, StormBase struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
+ org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
struct.name = iprot.readString();
struct.set_name_isSet(true);
struct.status = org.apache.storm.generated.TopologyStatus.findByValue(iprot.readI32());
struct.set_status_isSet(true);
struct.num_workers = iprot.readI32();
struct.set_num_workers_isSet(true);
- BitSet incoming = iprot.readBitSet(8);
+ java.util.BitSet incoming = iprot.readBitSet(8);
if (incoming.get(0)) {
{
org.apache.thrift.protocol.TMap _map764 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.component_executors = new HashMap<String,Integer>(2*_map764.size);
- String _key765;
+ struct.component_executors = new java.util.HashMap<java.lang.String,java.lang.Integer>(2*_map764.size);
+ java.lang.String _key765;
int _val766;
for (int _i767 = 0; _i767 < _map764.size; ++_i767)
{
@@ -1566,8 +1525,8 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
if (incoming.get(5)) {
{
org.apache.thrift.protocol.TMap _map768 = 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*_map768.size);
- String _key769;
+ struct.component_debug = new java.util.HashMap<java.lang.String,DebugOptions>(2*_map768.size);
+ java.lang.String _key769;
DebugOptions _val770;
for (int _i771 = 0; _i771 < _map768.size; ++_i771)
{
@@ -1590,5 +1549,8 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
}
}
+ 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();
+ }
}