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