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:39 UTC
[09/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/TopologyStats.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/generated/TopologyStats.java b/storm-client/src/jvm/org/apache/storm/generated/TopologyStats.java
index ee073bc..5dea004 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/TopologyStats.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/TopologyStats.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 TopologyStats implements org.apache.thrift.TBase<TopologyStats, TopologyStats._Fields>, java.io.Serializable, Cloneable, Comparable<TopologyStats> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TopologyStats");
@@ -61,17 +34,14 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
private static final org.apache.thrift.protocol.TField WINDOW_TO_ACKED_FIELD_DESC = new org.apache.thrift.protocol.TField("window_to_acked", org.apache.thrift.protocol.TType.MAP, (short)4);
private static final org.apache.thrift.protocol.TField WINDOW_TO_FAILED_FIELD_DESC = new org.apache.thrift.protocol.TField("window_to_failed", 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 TopologyStatsStandardSchemeFactory());
- schemes.put(TupleScheme.class, new TopologyStatsTupleSchemeFactory());
- }
+ private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new TopologyStatsStandardSchemeFactory();
+ private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new TopologyStatsTupleSchemeFactory();
- private Map<String,Long> window_to_emitted; // optional
- private Map<String,Long> window_to_transferred; // optional
- private Map<String,Double> window_to_complete_latencies_ms; // optional
- private Map<String,Long> window_to_acked; // optional
- private Map<String,Long> window_to_failed; // optional
+ private java.util.Map<java.lang.String,java.lang.Long> window_to_emitted; // optional
+ private java.util.Map<java.lang.String,java.lang.Long> window_to_transferred; // optional
+ private java.util.Map<java.lang.String,java.lang.Double> window_to_complete_latencies_ms; // optional
+ private java.util.Map<java.lang.String,java.lang.Long> window_to_acked; // optional
+ private java.util.Map<java.lang.String,java.lang.Long> window_to_failed; // 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 {
@@ -81,10 +51,10 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
WINDOW_TO_ACKED((short)4, "window_to_acked"),
WINDOW_TO_FAILED((short)5, "window_to_failed");
- 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 TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
*/
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,16 +108,16 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
return _thriftId;
}
- public String getFieldName() {
+ public java.lang.String getFieldName() {
return _fieldName;
}
}
// isset id assignments
private static final _Fields optionals[] = {_Fields.WINDOW_TO_EMITTED,_Fields.WINDOW_TO_TRANSFERRED,_Fields.WINDOW_TO_COMPLETE_LATENCIES_MS,_Fields.WINDOW_TO_ACKED,_Fields.WINDOW_TO_FAILED};
- 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.WINDOW_TO_EMITTED, new org.apache.thrift.meta_data.FieldMetaData("window_to_emitted", org.apache.thrift.TFieldRequirementType.OPTIONAL,
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),
@@ -168,7 +138,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
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),
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
+ metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TopologyStats.class, metaDataMap);
}
@@ -180,23 +150,23 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
*/
public TopologyStats(TopologyStats other) {
if (other.is_set_window_to_emitted()) {
- Map<String,Long> __this__window_to_emitted = new HashMap<String,Long>(other.window_to_emitted);
+ java.util.Map<java.lang.String,java.lang.Long> __this__window_to_emitted = new java.util.HashMap<java.lang.String,java.lang.Long>(other.window_to_emitted);
this.window_to_emitted = __this__window_to_emitted;
}
if (other.is_set_window_to_transferred()) {
- Map<String,Long> __this__window_to_transferred = new HashMap<String,Long>(other.window_to_transferred);
+ java.util.Map<java.lang.String,java.lang.Long> __this__window_to_transferred = new java.util.HashMap<java.lang.String,java.lang.Long>(other.window_to_transferred);
this.window_to_transferred = __this__window_to_transferred;
}
if (other.is_set_window_to_complete_latencies_ms()) {
- Map<String,Double> __this__window_to_complete_latencies_ms = new HashMap<String,Double>(other.window_to_complete_latencies_ms);
+ java.util.Map<java.lang.String,java.lang.Double> __this__window_to_complete_latencies_ms = new java.util.HashMap<java.lang.String,java.lang.Double>(other.window_to_complete_latencies_ms);
this.window_to_complete_latencies_ms = __this__window_to_complete_latencies_ms;
}
if (other.is_set_window_to_acked()) {
- Map<String,Long> __this__window_to_acked = new HashMap<String,Long>(other.window_to_acked);
+ java.util.Map<java.lang.String,java.lang.Long> __this__window_to_acked = new java.util.HashMap<java.lang.String,java.lang.Long>(other.window_to_acked);
this.window_to_acked = __this__window_to_acked;
}
if (other.is_set_window_to_failed()) {
- Map<String,Long> __this__window_to_failed = new HashMap<String,Long>(other.window_to_failed);
+ java.util.Map<java.lang.String,java.lang.Long> __this__window_to_failed = new java.util.HashMap<java.lang.String,java.lang.Long>(other.window_to_failed);
this.window_to_failed = __this__window_to_failed;
}
}
@@ -218,18 +188,18 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
return (this.window_to_emitted == null) ? 0 : this.window_to_emitted.size();
}
- public void put_to_window_to_emitted(String key, long val) {
+ public void put_to_window_to_emitted(java.lang.String key, long val) {
if (this.window_to_emitted == null) {
- this.window_to_emitted = new HashMap<String,Long>();
+ this.window_to_emitted = new java.util.HashMap<java.lang.String,java.lang.Long>();
}
this.window_to_emitted.put(key, val);
}
- public Map<String,Long> get_window_to_emitted() {
+ public java.util.Map<java.lang.String,java.lang.Long> get_window_to_emitted() {
return this.window_to_emitted;
}
- public void set_window_to_emitted(Map<String,Long> window_to_emitted) {
+ public void set_window_to_emitted(java.util.Map<java.lang.String,java.lang.Long> window_to_emitted) {
this.window_to_emitted = window_to_emitted;
}
@@ -252,18 +222,18 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
return (this.window_to_transferred == null) ? 0 : this.window_to_transferred.size();
}
- public void put_to_window_to_transferred(String key, long val) {
+ public void put_to_window_to_transferred(java.lang.String key, long val) {
if (this.window_to_transferred == null) {
- this.window_to_transferred = new HashMap<String,Long>();
+ this.window_to_transferred = new java.util.HashMap<java.lang.String,java.lang.Long>();
}
this.window_to_transferred.put(key, val);
}
- public Map<String,Long> get_window_to_transferred() {
+ public java.util.Map<java.lang.String,java.lang.Long> get_window_to_transferred() {
return this.window_to_transferred;
}
- public void set_window_to_transferred(Map<String,Long> window_to_transferred) {
+ public void set_window_to_transferred(java.util.Map<java.lang.String,java.lang.Long> window_to_transferred) {
this.window_to_transferred = window_to_transferred;
}
@@ -286,18 +256,18 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
return (this.window_to_complete_latencies_ms == null) ? 0 : this.window_to_complete_latencies_ms.size();
}
- public void put_to_window_to_complete_latencies_ms(String key, double val) {
+ public void put_to_window_to_complete_latencies_ms(java.lang.String key, double val) {
if (this.window_to_complete_latencies_ms == null) {
- this.window_to_complete_latencies_ms = new HashMap<String,Double>();
+ this.window_to_complete_latencies_ms = new java.util.HashMap<java.lang.String,java.lang.Double>();
}
this.window_to_complete_latencies_ms.put(key, val);
}
- public Map<String,Double> get_window_to_complete_latencies_ms() {
+ public java.util.Map<java.lang.String,java.lang.Double> get_window_to_complete_latencies_ms() {
return this.window_to_complete_latencies_ms;
}
- public void set_window_to_complete_latencies_ms(Map<String,Double> window_to_complete_latencies_ms) {
+ public void set_window_to_complete_latencies_ms(java.util.Map<java.lang.String,java.lang.Double> window_to_complete_latencies_ms) {
this.window_to_complete_latencies_ms = window_to_complete_latencies_ms;
}
@@ -320,18 +290,18 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
return (this.window_to_acked == null) ? 0 : this.window_to_acked.size();
}
- public void put_to_window_to_acked(String key, long val) {
+ public void put_to_window_to_acked(java.lang.String key, long val) {
if (this.window_to_acked == null) {
- this.window_to_acked = new HashMap<String,Long>();
+ this.window_to_acked = new java.util.HashMap<java.lang.String,java.lang.Long>();
}
this.window_to_acked.put(key, val);
}
- public Map<String,Long> get_window_to_acked() {
+ public java.util.Map<java.lang.String,java.lang.Long> get_window_to_acked() {
return this.window_to_acked;
}
- public void set_window_to_acked(Map<String,Long> window_to_acked) {
+ public void set_window_to_acked(java.util.Map<java.lang.String,java.lang.Long> window_to_acked) {
this.window_to_acked = window_to_acked;
}
@@ -354,18 +324,18 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
return (this.window_to_failed == null) ? 0 : this.window_to_failed.size();
}
- public void put_to_window_to_failed(String key, long val) {
+ public void put_to_window_to_failed(java.lang.String key, long val) {
if (this.window_to_failed == null) {
- this.window_to_failed = new HashMap<String,Long>();
+ this.window_to_failed = new java.util.HashMap<java.lang.String,java.lang.Long>();
}
this.window_to_failed.put(key, val);
}
- public Map<String,Long> get_window_to_failed() {
+ public java.util.Map<java.lang.String,java.lang.Long> get_window_to_failed() {
return this.window_to_failed;
}
- public void set_window_to_failed(Map<String,Long> window_to_failed) {
+ public void set_window_to_failed(java.util.Map<java.lang.String,java.lang.Long> window_to_failed) {
this.window_to_failed = window_to_failed;
}
@@ -384,13 +354,13 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
}
}
- public void setFieldValue(_Fields field, Object value) {
+ public void setFieldValue(_Fields field, java.lang.Object value) {
switch (field) {
case WINDOW_TO_EMITTED:
if (value == null) {
unset_window_to_emitted();
} else {
- set_window_to_emitted((Map<String,Long>)value);
+ set_window_to_emitted((java.util.Map<java.lang.String,java.lang.Long>)value);
}
break;
@@ -398,7 +368,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
if (value == null) {
unset_window_to_transferred();
} else {
- set_window_to_transferred((Map<String,Long>)value);
+ set_window_to_transferred((java.util.Map<java.lang.String,java.lang.Long>)value);
}
break;
@@ -406,7 +376,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
if (value == null) {
unset_window_to_complete_latencies_ms();
} else {
- set_window_to_complete_latencies_ms((Map<String,Double>)value);
+ set_window_to_complete_latencies_ms((java.util.Map<java.lang.String,java.lang.Double>)value);
}
break;
@@ -414,7 +384,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
if (value == null) {
unset_window_to_acked();
} else {
- set_window_to_acked((Map<String,Long>)value);
+ set_window_to_acked((java.util.Map<java.lang.String,java.lang.Long>)value);
}
break;
@@ -422,14 +392,14 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
if (value == null) {
unset_window_to_failed();
} else {
- set_window_to_failed((Map<String,Long>)value);
+ set_window_to_failed((java.util.Map<java.lang.String,java.lang.Long>)value);
}
break;
}
}
- public Object getFieldValue(_Fields field) {
+ public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case WINDOW_TO_EMITTED:
return get_window_to_emitted();
@@ -447,13 +417,13 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
return get_window_to_failed();
}
- 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) {
@@ -468,11 +438,11 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
case WINDOW_TO_FAILED:
return is_set_window_to_failed();
}
- 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 TopologyStats)
@@ -483,6 +453,8 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
public boolean equals(TopologyStats that) {
if (that == null)
return false;
+ if (this == that)
+ return true;
boolean this_present_window_to_emitted = true && this.is_set_window_to_emitted();
boolean that_present_window_to_emitted = true && that.is_set_window_to_emitted();
@@ -534,34 +506,29 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
@Override
public int hashCode() {
- List<Object> list = new ArrayList<Object>();
-
- boolean present_window_to_emitted = true && (is_set_window_to_emitted());
- list.add(present_window_to_emitted);
- if (present_window_to_emitted)
- list.add(window_to_emitted);
-
- boolean present_window_to_transferred = true && (is_set_window_to_transferred());
- list.add(present_window_to_transferred);
- if (present_window_to_transferred)
- list.add(window_to_transferred);
-
- boolean present_window_to_complete_latencies_ms = true && (is_set_window_to_complete_latencies_ms());
- list.add(present_window_to_complete_latencies_ms);
- if (present_window_to_complete_latencies_ms)
- list.add(window_to_complete_latencies_ms);
-
- boolean present_window_to_acked = true && (is_set_window_to_acked());
- list.add(present_window_to_acked);
- if (present_window_to_acked)
- list.add(window_to_acked);
-
- boolean present_window_to_failed = true && (is_set_window_to_failed());
- list.add(present_window_to_failed);
- if (present_window_to_failed)
- list.add(window_to_failed);
-
- return list.hashCode();
+ int hashCode = 1;
+
+ hashCode = hashCode * 8191 + ((is_set_window_to_emitted()) ? 131071 : 524287);
+ if (is_set_window_to_emitted())
+ hashCode = hashCode * 8191 + window_to_emitted.hashCode();
+
+ hashCode = hashCode * 8191 + ((is_set_window_to_transferred()) ? 131071 : 524287);
+ if (is_set_window_to_transferred())
+ hashCode = hashCode * 8191 + window_to_transferred.hashCode();
+
+ hashCode = hashCode * 8191 + ((is_set_window_to_complete_latencies_ms()) ? 131071 : 524287);
+ if (is_set_window_to_complete_latencies_ms())
+ hashCode = hashCode * 8191 + window_to_complete_latencies_ms.hashCode();
+
+ hashCode = hashCode * 8191 + ((is_set_window_to_acked()) ? 131071 : 524287);
+ if (is_set_window_to_acked())
+ hashCode = hashCode * 8191 + window_to_acked.hashCode();
+
+ hashCode = hashCode * 8191 + ((is_set_window_to_failed()) ? 131071 : 524287);
+ if (is_set_window_to_failed())
+ hashCode = hashCode * 8191 + window_to_failed.hashCode();
+
+ return hashCode;
}
@Override
@@ -572,7 +539,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
int lastComparison = 0;
- lastComparison = Boolean.valueOf(is_set_window_to_emitted()).compareTo(other.is_set_window_to_emitted());
+ lastComparison = java.lang.Boolean.valueOf(is_set_window_to_emitted()).compareTo(other.is_set_window_to_emitted());
if (lastComparison != 0) {
return lastComparison;
}
@@ -582,7 +549,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_window_to_transferred()).compareTo(other.is_set_window_to_transferred());
+ lastComparison = java.lang.Boolean.valueOf(is_set_window_to_transferred()).compareTo(other.is_set_window_to_transferred());
if (lastComparison != 0) {
return lastComparison;
}
@@ -592,7 +559,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_window_to_complete_latencies_ms()).compareTo(other.is_set_window_to_complete_latencies_ms());
+ lastComparison = java.lang.Boolean.valueOf(is_set_window_to_complete_latencies_ms()).compareTo(other.is_set_window_to_complete_latencies_ms());
if (lastComparison != 0) {
return lastComparison;
}
@@ -602,7 +569,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_window_to_acked()).compareTo(other.is_set_window_to_acked());
+ lastComparison = java.lang.Boolean.valueOf(is_set_window_to_acked()).compareTo(other.is_set_window_to_acked());
if (lastComparison != 0) {
return lastComparison;
}
@@ -612,7 +579,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(is_set_window_to_failed()).compareTo(other.is_set_window_to_failed());
+ lastComparison = java.lang.Boolean.valueOf(is_set_window_to_failed()).compareTo(other.is_set_window_to_failed());
if (lastComparison != 0) {
return lastComparison;
}
@@ -630,16 +597,16 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
}
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("TopologyStats(");
+ public java.lang.String toString() {
+ java.lang.StringBuilder sb = new java.lang.StringBuilder("TopologyStats(");
boolean first = true;
if (is_set_window_to_emitted()) {
@@ -708,7 +675,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
}
}
- 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) {
@@ -716,13 +683,13 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
}
}
- private static class TopologyStatsStandardSchemeFactory implements SchemeFactory {
+ private static class TopologyStatsStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TopologyStatsStandardScheme getScheme() {
return new TopologyStatsStandardScheme();
}
}
- private static class TopologyStatsStandardScheme extends StandardScheme<TopologyStats> {
+ private static class TopologyStatsStandardScheme extends org.apache.thrift.scheme.StandardScheme<TopologyStats> {
public void read(org.apache.thrift.protocol.TProtocol iprot, TopologyStats struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
@@ -738,8 +705,8 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map406 = iprot.readMapBegin();
- struct.window_to_emitted = new HashMap<String,Long>(2*_map406.size);
- String _key407;
+ struct.window_to_emitted = new java.util.HashMap<java.lang.String,java.lang.Long>(2*_map406.size);
+ java.lang.String _key407;
long _val408;
for (int _i409 = 0; _i409 < _map406.size; ++_i409)
{
@@ -758,8 +725,8 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map410 = iprot.readMapBegin();
- struct.window_to_transferred = new HashMap<String,Long>(2*_map410.size);
- String _key411;
+ struct.window_to_transferred = new java.util.HashMap<java.lang.String,java.lang.Long>(2*_map410.size);
+ java.lang.String _key411;
long _val412;
for (int _i413 = 0; _i413 < _map410.size; ++_i413)
{
@@ -778,8 +745,8 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map414 = iprot.readMapBegin();
- struct.window_to_complete_latencies_ms = new HashMap<String,Double>(2*_map414.size);
- String _key415;
+ struct.window_to_complete_latencies_ms = new java.util.HashMap<java.lang.String,java.lang.Double>(2*_map414.size);
+ java.lang.String _key415;
double _val416;
for (int _i417 = 0; _i417 < _map414.size; ++_i417)
{
@@ -798,8 +765,8 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map418 = iprot.readMapBegin();
- struct.window_to_acked = new HashMap<String,Long>(2*_map418.size);
- String _key419;
+ struct.window_to_acked = new java.util.HashMap<java.lang.String,java.lang.Long>(2*_map418.size);
+ java.lang.String _key419;
long _val420;
for (int _i421 = 0; _i421 < _map418.size; ++_i421)
{
@@ -818,8 +785,8 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
org.apache.thrift.protocol.TMap _map422 = iprot.readMapBegin();
- struct.window_to_failed = new HashMap<String,Long>(2*_map422.size);
- String _key423;
+ struct.window_to_failed = new java.util.HashMap<java.lang.String,java.lang.Long>(2*_map422.size);
+ java.lang.String _key423;
long _val424;
for (int _i425 = 0; _i425 < _map422.size; ++_i425)
{
@@ -852,7 +819,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
oprot.writeFieldBegin(WINDOW_TO_EMITTED_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, struct.window_to_emitted.size()));
- for (Map.Entry<String, Long> _iter426 : struct.window_to_emitted.entrySet())
+ for (java.util.Map.Entry<java.lang.String, java.lang.Long> _iter426 : struct.window_to_emitted.entrySet())
{
oprot.writeString(_iter426.getKey());
oprot.writeI64(_iter426.getValue());
@@ -867,7 +834,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
oprot.writeFieldBegin(WINDOW_TO_TRANSFERRED_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, struct.window_to_transferred.size()));
- for (Map.Entry<String, Long> _iter427 : struct.window_to_transferred.entrySet())
+ for (java.util.Map.Entry<java.lang.String, java.lang.Long> _iter427 : struct.window_to_transferred.entrySet())
{
oprot.writeString(_iter427.getKey());
oprot.writeI64(_iter427.getValue());
@@ -882,7 +849,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
oprot.writeFieldBegin(WINDOW_TO_COMPLETE_LATENCIES_MS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.DOUBLE, struct.window_to_complete_latencies_ms.size()));
- for (Map.Entry<String, Double> _iter428 : struct.window_to_complete_latencies_ms.entrySet())
+ for (java.util.Map.Entry<java.lang.String, java.lang.Double> _iter428 : struct.window_to_complete_latencies_ms.entrySet())
{
oprot.writeString(_iter428.getKey());
oprot.writeDouble(_iter428.getValue());
@@ -897,7 +864,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
oprot.writeFieldBegin(WINDOW_TO_ACKED_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, struct.window_to_acked.size()));
- for (Map.Entry<String, Long> _iter429 : struct.window_to_acked.entrySet())
+ for (java.util.Map.Entry<java.lang.String, java.lang.Long> _iter429 : struct.window_to_acked.entrySet())
{
oprot.writeString(_iter429.getKey());
oprot.writeI64(_iter429.getValue());
@@ -912,7 +879,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
oprot.writeFieldBegin(WINDOW_TO_FAILED_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, struct.window_to_failed.size()));
- for (Map.Entry<String, Long> _iter430 : struct.window_to_failed.entrySet())
+ for (java.util.Map.Entry<java.lang.String, java.lang.Long> _iter430 : struct.window_to_failed.entrySet())
{
oprot.writeString(_iter430.getKey());
oprot.writeI64(_iter430.getValue());
@@ -928,18 +895,18 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
}
- private static class TopologyStatsTupleSchemeFactory implements SchemeFactory {
+ private static class TopologyStatsTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
public TopologyStatsTupleScheme getScheme() {
return new TopologyStatsTupleScheme();
}
}
- private static class TopologyStatsTupleScheme extends TupleScheme<TopologyStats> {
+ private static class TopologyStatsTupleScheme extends org.apache.thrift.scheme.TupleScheme<TopologyStats> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, TopologyStats struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- BitSet optionals = new BitSet();
+ org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
+ java.util.BitSet optionals = new java.util.BitSet();
if (struct.is_set_window_to_emitted()) {
optionals.set(0);
}
@@ -959,7 +926,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
if (struct.is_set_window_to_emitted()) {
{
oprot.writeI32(struct.window_to_emitted.size());
- for (Map.Entry<String, Long> _iter431 : struct.window_to_emitted.entrySet())
+ for (java.util.Map.Entry<java.lang.String, java.lang.Long> _iter431 : struct.window_to_emitted.entrySet())
{
oprot.writeString(_iter431.getKey());
oprot.writeI64(_iter431.getValue());
@@ -969,7 +936,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
if (struct.is_set_window_to_transferred()) {
{
oprot.writeI32(struct.window_to_transferred.size());
- for (Map.Entry<String, Long> _iter432 : struct.window_to_transferred.entrySet())
+ for (java.util.Map.Entry<java.lang.String, java.lang.Long> _iter432 : struct.window_to_transferred.entrySet())
{
oprot.writeString(_iter432.getKey());
oprot.writeI64(_iter432.getValue());
@@ -979,7 +946,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
if (struct.is_set_window_to_complete_latencies_ms()) {
{
oprot.writeI32(struct.window_to_complete_latencies_ms.size());
- for (Map.Entry<String, Double> _iter433 : struct.window_to_complete_latencies_ms.entrySet())
+ for (java.util.Map.Entry<java.lang.String, java.lang.Double> _iter433 : struct.window_to_complete_latencies_ms.entrySet())
{
oprot.writeString(_iter433.getKey());
oprot.writeDouble(_iter433.getValue());
@@ -989,7 +956,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
if (struct.is_set_window_to_acked()) {
{
oprot.writeI32(struct.window_to_acked.size());
- for (Map.Entry<String, Long> _iter434 : struct.window_to_acked.entrySet())
+ for (java.util.Map.Entry<java.lang.String, java.lang.Long> _iter434 : struct.window_to_acked.entrySet())
{
oprot.writeString(_iter434.getKey());
oprot.writeI64(_iter434.getValue());
@@ -999,7 +966,7 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
if (struct.is_set_window_to_failed()) {
{
oprot.writeI32(struct.window_to_failed.size());
- for (Map.Entry<String, Long> _iter435 : struct.window_to_failed.entrySet())
+ for (java.util.Map.Entry<java.lang.String, java.lang.Long> _iter435 : struct.window_to_failed.entrySet())
{
oprot.writeString(_iter435.getKey());
oprot.writeI64(_iter435.getValue());
@@ -1010,13 +977,13 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, TopologyStats struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(5);
+ org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
+ java.util.BitSet incoming = iprot.readBitSet(5);
if (incoming.get(0)) {
{
org.apache.thrift.protocol.TMap _map436 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.window_to_emitted = new HashMap<String,Long>(2*_map436.size);
- String _key437;
+ struct.window_to_emitted = new java.util.HashMap<java.lang.String,java.lang.Long>(2*_map436.size);
+ java.lang.String _key437;
long _val438;
for (int _i439 = 0; _i439 < _map436.size; ++_i439)
{
@@ -1030,8 +997,8 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
if (incoming.get(1)) {
{
org.apache.thrift.protocol.TMap _map440 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.window_to_transferred = new HashMap<String,Long>(2*_map440.size);
- String _key441;
+ struct.window_to_transferred = new java.util.HashMap<java.lang.String,java.lang.Long>(2*_map440.size);
+ java.lang.String _key441;
long _val442;
for (int _i443 = 0; _i443 < _map440.size; ++_i443)
{
@@ -1045,8 +1012,8 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
if (incoming.get(2)) {
{
org.apache.thrift.protocol.TMap _map444 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.DOUBLE, iprot.readI32());
- struct.window_to_complete_latencies_ms = new HashMap<String,Double>(2*_map444.size);
- String _key445;
+ struct.window_to_complete_latencies_ms = new java.util.HashMap<java.lang.String,java.lang.Double>(2*_map444.size);
+ java.lang.String _key445;
double _val446;
for (int _i447 = 0; _i447 < _map444.size; ++_i447)
{
@@ -1060,8 +1027,8 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
if (incoming.get(3)) {
{
org.apache.thrift.protocol.TMap _map448 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.window_to_acked = new HashMap<String,Long>(2*_map448.size);
- String _key449;
+ struct.window_to_acked = new java.util.HashMap<java.lang.String,java.lang.Long>(2*_map448.size);
+ java.lang.String _key449;
long _val450;
for (int _i451 = 0; _i451 < _map448.size; ++_i451)
{
@@ -1075,8 +1042,8 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
if (incoming.get(4)) {
{
org.apache.thrift.protocol.TMap _map452 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.window_to_failed = new HashMap<String,Long>(2*_map452.size);
- String _key453;
+ struct.window_to_failed = new java.util.HashMap<java.lang.String,java.lang.Long>(2*_map452.size);
+ java.lang.String _key453;
long _val454;
for (int _i455 = 0; _i455 < _map452.size; ++_i455)
{
@@ -1090,5 +1057,8 @@ public class TopologyStats implements org.apache.thrift.TBase<TopologyStats, Top
}
}
+ 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/TopologyStatus.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/generated/TopologyStatus.java b/storm-client/src/jvm/org/apache/storm/generated/TopologyStatus.java
index dd33d12..19a5cec 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/TopologyStatus.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/TopologyStatus.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.3)
+ * Autogenerated by Thrift Compiler (0.11.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,10 +24,6 @@
package org.apache.storm.generated;
-import java.util.Map;
-import java.util.HashMap;
-import org.apache.thrift.TEnum;
-
public enum TopologyStatus implements org.apache.thrift.TEnum {
ACTIVE(1),
INACTIVE(2),