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"}) [email protected](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),
