http://git-wip-us.apache.org/repos/asf/storm/blob/7eaf0651/jstorm-core/src/main/java/backtype/storm/generated/TopologyMetric.java ---------------------------------------------------------------------- diff --git a/jstorm-core/src/main/java/backtype/storm/generated/TopologyMetric.java b/jstorm-core/src/main/java/backtype/storm/generated/TopologyMetric.java index 6df50cf..c87e82b 100644 --- a/jstorm-core/src/main/java/backtype/storm/generated/TopologyMetric.java +++ b/jstorm-core/src/main/java/backtype/storm/generated/TopologyMetric.java @@ -34,14 +34,16 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-27") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-20") public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, TopologyMetric._Fields>, java.io.Serializable, Cloneable, Comparable<TopologyMetric> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TopologyMetric"); private static final org.apache.thrift.protocol.TField TOPOLOGY_METRIC_FIELD_DESC = new org.apache.thrift.protocol.TField("topologyMetric", org.apache.thrift.protocol.TType.STRUCT, (short)1); - private static final org.apache.thrift.protocol.TField COMPONENT_METRIC_FIELD_DESC = new org.apache.thrift.protocol.TField("componentMetric", org.apache.thrift.protocol.TType.MAP, (short)2); - private static final org.apache.thrift.protocol.TField WORKER_METRIC_FIELD_DESC = new org.apache.thrift.protocol.TField("workerMetric", org.apache.thrift.protocol.TType.MAP, (short)3); - private static final org.apache.thrift.protocol.TField TASK_METRIC_FIELD_DESC = new org.apache.thrift.protocol.TField("taskMetric", org.apache.thrift.protocol.TType.MAP, (short)4); + private static final org.apache.thrift.protocol.TField COMPONENT_METRIC_FIELD_DESC = new org.apache.thrift.protocol.TField("componentMetric", org.apache.thrift.protocol.TType.STRUCT, (short)2); + private static final org.apache.thrift.protocol.TField WORKER_METRIC_FIELD_DESC = new org.apache.thrift.protocol.TField("workerMetric", org.apache.thrift.protocol.TType.STRUCT, (short)3); + private static final org.apache.thrift.protocol.TField TASK_METRIC_FIELD_DESC = new org.apache.thrift.protocol.TField("taskMetric", org.apache.thrift.protocol.TType.STRUCT, (short)4); + private static final org.apache.thrift.protocol.TField STREAM_METRIC_FIELD_DESC = new org.apache.thrift.protocol.TField("streamMetric", org.apache.thrift.protocol.TType.STRUCT, (short)5); + private static final org.apache.thrift.protocol.TField NETTY_METRIC_FIELD_DESC = new org.apache.thrift.protocol.TField("nettyMetric", org.apache.thrift.protocol.TType.STRUCT, (short)6); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -50,16 +52,20 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T } private MetricInfo topologyMetric; // required - private Map<String,MetricInfo> componentMetric; // required - private Map<String,MetricInfo> workerMetric; // required - private Map<Integer,MetricInfo> taskMetric; // required + private MetricInfo componentMetric; // required + private MetricInfo workerMetric; // required + private MetricInfo taskMetric; // required + private MetricInfo streamMetric; // required + private MetricInfo nettyMetric; // 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 { TOPOLOGY_METRIC((short)1, "topologyMetric"), COMPONENT_METRIC((short)2, "componentMetric"), WORKER_METRIC((short)3, "workerMetric"), - TASK_METRIC((short)4, "taskMetric"); + TASK_METRIC((short)4, "taskMetric"), + STREAM_METRIC((short)5, "streamMetric"), + NETTY_METRIC((short)6, "nettyMetric"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -82,6 +88,10 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T return WORKER_METRIC; case 4: // TASK_METRIC return TASK_METRIC; + case 5: // STREAM_METRIC + return STREAM_METRIC; + case 6: // NETTY_METRIC + return NETTY_METRIC; default: return null; } @@ -128,17 +138,15 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T tmpMap.put(_Fields.TOPOLOGY_METRIC, new org.apache.thrift.meta_data.FieldMetaData("topologyMetric", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, MetricInfo.class))); tmpMap.put(_Fields.COMPONENT_METRIC, new org.apache.thrift.meta_data.FieldMetaData("componentMetric", 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), - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, MetricInfo.class)))); + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, MetricInfo.class))); tmpMap.put(_Fields.WORKER_METRIC, new org.apache.thrift.meta_data.FieldMetaData("workerMetric", 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), - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, MetricInfo.class)))); + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, MetricInfo.class))); tmpMap.put(_Fields.TASK_METRIC, new org.apache.thrift.meta_data.FieldMetaData("taskMetric", 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.I32), - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, MetricInfo.class)))); + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, MetricInfo.class))); + tmpMap.put(_Fields.STREAM_METRIC, new org.apache.thrift.meta_data.FieldMetaData("streamMetric", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, MetricInfo.class))); + tmpMap.put(_Fields.NETTY_METRIC, new org.apache.thrift.meta_data.FieldMetaData("nettyMetric", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, MetricInfo.class))); metaDataMap = Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TopologyMetric.class, metaDataMap); } @@ -148,15 +156,19 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T public TopologyMetric( MetricInfo topologyMetric, - Map<String,MetricInfo> componentMetric, - Map<String,MetricInfo> workerMetric, - Map<Integer,MetricInfo> taskMetric) + MetricInfo componentMetric, + MetricInfo workerMetric, + MetricInfo taskMetric, + MetricInfo streamMetric, + MetricInfo nettyMetric) { this(); this.topologyMetric = topologyMetric; this.componentMetric = componentMetric; this.workerMetric = workerMetric; this.taskMetric = taskMetric; + this.streamMetric = streamMetric; + this.nettyMetric = nettyMetric; } /** @@ -167,49 +179,19 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T this.topologyMetric = new MetricInfo(other.topologyMetric); } if (other.is_set_componentMetric()) { - Map<String,MetricInfo> __this__componentMetric = new HashMap<String,MetricInfo>(other.componentMetric.size()); - for (Map.Entry<String, MetricInfo> other_element : other.componentMetric.entrySet()) { - - String other_element_key = other_element.getKey(); - MetricInfo other_element_value = other_element.getValue(); - - String __this__componentMetric_copy_key = other_element_key; - - MetricInfo __this__componentMetric_copy_value = new MetricInfo(other_element_value); - - __this__componentMetric.put(__this__componentMetric_copy_key, __this__componentMetric_copy_value); - } - this.componentMetric = __this__componentMetric; + this.componentMetric = new MetricInfo(other.componentMetric); } if (other.is_set_workerMetric()) { - Map<String,MetricInfo> __this__workerMetric = new HashMap<String,MetricInfo>(other.workerMetric.size()); - for (Map.Entry<String, MetricInfo> other_element : other.workerMetric.entrySet()) { - - String other_element_key = other_element.getKey(); - MetricInfo other_element_value = other_element.getValue(); - - String __this__workerMetric_copy_key = other_element_key; - - MetricInfo __this__workerMetric_copy_value = new MetricInfo(other_element_value); - - __this__workerMetric.put(__this__workerMetric_copy_key, __this__workerMetric_copy_value); - } - this.workerMetric = __this__workerMetric; + this.workerMetric = new MetricInfo(other.workerMetric); } if (other.is_set_taskMetric()) { - Map<Integer,MetricInfo> __this__taskMetric = new HashMap<Integer,MetricInfo>(other.taskMetric.size()); - for (Map.Entry<Integer, MetricInfo> other_element : other.taskMetric.entrySet()) { - - Integer other_element_key = other_element.getKey(); - MetricInfo other_element_value = other_element.getValue(); - - Integer __this__taskMetric_copy_key = other_element_key; - - MetricInfo __this__taskMetric_copy_value = new MetricInfo(other_element_value); - - __this__taskMetric.put(__this__taskMetric_copy_key, __this__taskMetric_copy_value); - } - this.taskMetric = __this__taskMetric; + this.taskMetric = new MetricInfo(other.taskMetric); + } + if (other.is_set_streamMetric()) { + this.streamMetric = new MetricInfo(other.streamMetric); + } + if (other.is_set_nettyMetric()) { + this.nettyMetric = new MetricInfo(other.nettyMetric); } } @@ -223,6 +205,8 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T this.componentMetric = null; this.workerMetric = null; this.taskMetric = null; + this.streamMetric = null; + this.nettyMetric = null; } public MetricInfo get_topologyMetric() { @@ -248,22 +232,11 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T } } - public int get_componentMetric_size() { - return (this.componentMetric == null) ? 0 : this.componentMetric.size(); - } - - public void put_to_componentMetric(String key, MetricInfo val) { - if (this.componentMetric == null) { - this.componentMetric = new HashMap<String,MetricInfo>(); - } - this.componentMetric.put(key, val); - } - - public Map<String,MetricInfo> get_componentMetric() { + public MetricInfo get_componentMetric() { return this.componentMetric; } - public void set_componentMetric(Map<String,MetricInfo> componentMetric) { + public void set_componentMetric(MetricInfo componentMetric) { this.componentMetric = componentMetric; } @@ -282,22 +255,11 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T } } - public int get_workerMetric_size() { - return (this.workerMetric == null) ? 0 : this.workerMetric.size(); - } - - public void put_to_workerMetric(String key, MetricInfo val) { - if (this.workerMetric == null) { - this.workerMetric = new HashMap<String,MetricInfo>(); - } - this.workerMetric.put(key, val); - } - - public Map<String,MetricInfo> get_workerMetric() { + public MetricInfo get_workerMetric() { return this.workerMetric; } - public void set_workerMetric(Map<String,MetricInfo> workerMetric) { + public void set_workerMetric(MetricInfo workerMetric) { this.workerMetric = workerMetric; } @@ -316,22 +278,11 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T } } - public int get_taskMetric_size() { - return (this.taskMetric == null) ? 0 : this.taskMetric.size(); - } - - public void put_to_taskMetric(int key, MetricInfo val) { - if (this.taskMetric == null) { - this.taskMetric = new HashMap<Integer,MetricInfo>(); - } - this.taskMetric.put(key, val); - } - - public Map<Integer,MetricInfo> get_taskMetric() { + public MetricInfo get_taskMetric() { return this.taskMetric; } - public void set_taskMetric(Map<Integer,MetricInfo> taskMetric) { + public void set_taskMetric(MetricInfo taskMetric) { this.taskMetric = taskMetric; } @@ -350,6 +301,52 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T } } + public MetricInfo get_streamMetric() { + return this.streamMetric; + } + + public void set_streamMetric(MetricInfo streamMetric) { + this.streamMetric = streamMetric; + } + + public void unset_streamMetric() { + this.streamMetric = null; + } + + /** Returns true if field streamMetric is set (has been assigned a value) and false otherwise */ + public boolean is_set_streamMetric() { + return this.streamMetric != null; + } + + public void set_streamMetric_isSet(boolean value) { + if (!value) { + this.streamMetric = null; + } + } + + public MetricInfo get_nettyMetric() { + return this.nettyMetric; + } + + public void set_nettyMetric(MetricInfo nettyMetric) { + this.nettyMetric = nettyMetric; + } + + public void unset_nettyMetric() { + this.nettyMetric = null; + } + + /** Returns true if field nettyMetric is set (has been assigned a value) and false otherwise */ + public boolean is_set_nettyMetric() { + return this.nettyMetric != null; + } + + public void set_nettyMetric_isSet(boolean value) { + if (!value) { + this.nettyMetric = null; + } + } + public void setFieldValue(_Fields field, Object value) { switch (field) { case TOPOLOGY_METRIC: @@ -364,7 +361,7 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T if (value == null) { unset_componentMetric(); } else { - set_componentMetric((Map<String,MetricInfo>)value); + set_componentMetric((MetricInfo)value); } break; @@ -372,7 +369,7 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T if (value == null) { unset_workerMetric(); } else { - set_workerMetric((Map<String,MetricInfo>)value); + set_workerMetric((MetricInfo)value); } break; @@ -380,7 +377,23 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T if (value == null) { unset_taskMetric(); } else { - set_taskMetric((Map<Integer,MetricInfo>)value); + set_taskMetric((MetricInfo)value); + } + break; + + case STREAM_METRIC: + if (value == null) { + unset_streamMetric(); + } else { + set_streamMetric((MetricInfo)value); + } + break; + + case NETTY_METRIC: + if (value == null) { + unset_nettyMetric(); + } else { + set_nettyMetric((MetricInfo)value); } break; @@ -401,6 +414,12 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T case TASK_METRIC: return get_taskMetric(); + case STREAM_METRIC: + return get_streamMetric(); + + case NETTY_METRIC: + return get_nettyMetric(); + } throw new IllegalStateException(); } @@ -420,6 +439,10 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T return is_set_workerMetric(); case TASK_METRIC: return is_set_taskMetric(); + case STREAM_METRIC: + return is_set_streamMetric(); + case NETTY_METRIC: + return is_set_nettyMetric(); } throw new IllegalStateException(); } @@ -473,6 +496,24 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T return false; } + boolean this_present_streamMetric = true && this.is_set_streamMetric(); + boolean that_present_streamMetric = true && that.is_set_streamMetric(); + if (this_present_streamMetric || that_present_streamMetric) { + if (!(this_present_streamMetric && that_present_streamMetric)) + return false; + if (!this.streamMetric.equals(that.streamMetric)) + return false; + } + + boolean this_present_nettyMetric = true && this.is_set_nettyMetric(); + boolean that_present_nettyMetric = true && that.is_set_nettyMetric(); + if (this_present_nettyMetric || that_present_nettyMetric) { + if (!(this_present_nettyMetric && that_present_nettyMetric)) + return false; + if (!this.nettyMetric.equals(that.nettyMetric)) + return false; + } + return true; } @@ -500,6 +541,16 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T if (present_taskMetric) list.add(taskMetric); + boolean present_streamMetric = true && (is_set_streamMetric()); + list.add(present_streamMetric); + if (present_streamMetric) + list.add(streamMetric); + + boolean present_nettyMetric = true && (is_set_nettyMetric()); + list.add(present_nettyMetric); + if (present_nettyMetric) + list.add(nettyMetric); + return list.hashCode(); } @@ -551,6 +602,26 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T return lastComparison; } } + lastComparison = Boolean.valueOf(is_set_streamMetric()).compareTo(other.is_set_streamMetric()); + if (lastComparison != 0) { + return lastComparison; + } + if (is_set_streamMetric()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.streamMetric, other.streamMetric); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(is_set_nettyMetric()).compareTo(other.is_set_nettyMetric()); + if (lastComparison != 0) { + return lastComparison; + } + if (is_set_nettyMetric()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.nettyMetric, other.nettyMetric); + if (lastComparison != 0) { + return lastComparison; + } + } return 0; } @@ -558,11 +629,11 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -602,38 +673,77 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T sb.append(this.taskMetric); } first = false; + if (!first) sb.append(", "); + sb.append("streamMetric:"); + if (this.streamMetric == null) { + sb.append("null"); + } else { + sb.append(this.streamMetric); + } + first = false; + if (!first) sb.append(", "); + sb.append("nettyMetric:"); + if (this.nettyMetric == null) { + sb.append("null"); + } else { + sb.append(this.nettyMetric); + } + first = false; sb.append(")"); return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields if (!is_set_topologyMetric()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'topologyMetric' is unset! Struct:" + toString()); + throw new TProtocolException("Required field 'topologyMetric' is unset! Struct:" + toString()); } if (!is_set_componentMetric()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'componentMetric' is unset! Struct:" + toString()); + throw new TProtocolException("Required field 'componentMetric' is unset! Struct:" + toString()); } if (!is_set_workerMetric()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'workerMetric' is unset! Struct:" + toString()); + throw new TProtocolException("Required field 'workerMetric' is unset! Struct:" + toString()); } if (!is_set_taskMetric()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'taskMetric' is unset! Struct:" + toString()); + throw new TProtocolException("Required field 'taskMetric' is unset! Struct:" + toString()); + } + + if (!is_set_streamMetric()) { + throw new TProtocolException("Required field 'streamMetric' is unset! Struct:" + toString()); + } + + if (!is_set_nettyMetric()) { + throw new TProtocolException("Required field 'nettyMetric' is unset! Struct:" + toString()); } // check for sub-struct validity if (topologyMetric != null) { topologyMetric.validate(); } + if (componentMetric != null) { + componentMetric.validate(); + } + if (workerMetric != null) { + workerMetric.validate(); + } + if (taskMetric != null) { + taskMetric.validate(); + } + if (streamMetric != null) { + streamMetric.validate(); + } + if (nettyMetric != null) { + nettyMetric.validate(); + } } private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { try { write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -641,7 +751,7 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { try { read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -654,7 +764,7 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T private static class TopologyMetricStandardScheme extends StandardScheme<TopologyMetric> { - public void read(org.apache.thrift.protocol.TProtocol iprot, TopologyMetric struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, TopologyMetric struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -674,68 +784,50 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T } break; case 2: // COMPONENT_METRIC - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map166 = iprot.readMapBegin(); - struct.componentMetric = new HashMap<String,MetricInfo>(2*_map166.size); - String _key167; - MetricInfo _val168; - for (int _i169 = 0; _i169 < _map166.size; ++_i169) - { - _key167 = iprot.readString(); - _val168 = new MetricInfo(); - _val168.read(iprot); - struct.componentMetric.put(_key167, _val168); - } - iprot.readMapEnd(); - } + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.componentMetric = new MetricInfo(); + struct.componentMetric.read(iprot); struct.set_componentMetric_isSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; case 3: // WORKER_METRIC - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map170 = iprot.readMapBegin(); - struct.workerMetric = new HashMap<String,MetricInfo>(2*_map170.size); - String _key171; - MetricInfo _val172; - for (int _i173 = 0; _i173 < _map170.size; ++_i173) - { - _key171 = iprot.readString(); - _val172 = new MetricInfo(); - _val172.read(iprot); - struct.workerMetric.put(_key171, _val172); - } - iprot.readMapEnd(); - } + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.workerMetric = new MetricInfo(); + struct.workerMetric.read(iprot); struct.set_workerMetric_isSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; case 4: // TASK_METRIC - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map174 = iprot.readMapBegin(); - struct.taskMetric = new HashMap<Integer,MetricInfo>(2*_map174.size); - int _key175; - MetricInfo _val176; - for (int _i177 = 0; _i177 < _map174.size; ++_i177) - { - _key175 = iprot.readI32(); - _val176 = new MetricInfo(); - _val176.read(iprot); - struct.taskMetric.put(_key175, _val176); - } - iprot.readMapEnd(); - } + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.taskMetric = new MetricInfo(); + struct.taskMetric.read(iprot); struct.set_taskMetric_isSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; + case 5: // STREAM_METRIC + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.streamMetric = new MetricInfo(); + struct.streamMetric.read(iprot); + struct.set_streamMetric_isSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 6: // NETTY_METRIC + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.nettyMetric = new MetricInfo(); + struct.nettyMetric.read(iprot); + struct.set_nettyMetric_isSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -745,7 +837,7 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, TopologyMetric struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, TopologyMetric struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -756,41 +848,27 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T } if (struct.componentMetric != null) { oprot.writeFieldBegin(COMPONENT_METRIC_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.componentMetric.size())); - for (Map.Entry<String, MetricInfo> _iter178 : struct.componentMetric.entrySet()) - { - oprot.writeString(_iter178.getKey()); - _iter178.getValue().write(oprot); - } - oprot.writeMapEnd(); - } + struct.componentMetric.write(oprot); oprot.writeFieldEnd(); } if (struct.workerMetric != null) { oprot.writeFieldBegin(WORKER_METRIC_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.workerMetric.size())); - for (Map.Entry<String, MetricInfo> _iter179 : struct.workerMetric.entrySet()) - { - oprot.writeString(_iter179.getKey()); - _iter179.getValue().write(oprot); - } - oprot.writeMapEnd(); - } + struct.workerMetric.write(oprot); oprot.writeFieldEnd(); } if (struct.taskMetric != null) { oprot.writeFieldBegin(TASK_METRIC_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.STRUCT, struct.taskMetric.size())); - for (Map.Entry<Integer, MetricInfo> _iter180 : struct.taskMetric.entrySet()) - { - oprot.writeI32(_iter180.getKey()); - _iter180.getValue().write(oprot); - } - oprot.writeMapEnd(); - } + struct.taskMetric.write(oprot); + oprot.writeFieldEnd(); + } + if (struct.streamMetric != null) { + oprot.writeFieldBegin(STREAM_METRIC_FIELD_DESC); + struct.streamMetric.write(oprot); + oprot.writeFieldEnd(); + } + if (struct.nettyMetric != null) { + oprot.writeFieldBegin(NETTY_METRIC_FIELD_DESC); + struct.nettyMetric.write(oprot); oprot.writeFieldEnd(); } oprot.writeFieldStop(); @@ -808,83 +886,37 @@ public class TopologyMetric implements org.apache.thrift.TBase<TopologyMetric, T private static class TopologyMetricTupleScheme extends TupleScheme<TopologyMetric> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, TopologyMetric struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, TopologyMetric struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; struct.topologyMetric.write(oprot); - { - oprot.writeI32(struct.componentMetric.size()); - for (Map.Entry<String, MetricInfo> _iter181 : struct.componentMetric.entrySet()) - { - oprot.writeString(_iter181.getKey()); - _iter181.getValue().write(oprot); - } - } - { - oprot.writeI32(struct.workerMetric.size()); - for (Map.Entry<String, MetricInfo> _iter182 : struct.workerMetric.entrySet()) - { - oprot.writeString(_iter182.getKey()); - _iter182.getValue().write(oprot); - } - } - { - oprot.writeI32(struct.taskMetric.size()); - for (Map.Entry<Integer, MetricInfo> _iter183 : struct.taskMetric.entrySet()) - { - oprot.writeI32(_iter183.getKey()); - _iter183.getValue().write(oprot); - } - } + struct.componentMetric.write(oprot); + struct.workerMetric.write(oprot); + struct.taskMetric.write(oprot); + struct.streamMetric.write(oprot); + struct.nettyMetric.write(oprot); } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, TopologyMetric struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, TopologyMetric struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; struct.topologyMetric = new MetricInfo(); struct.topologyMetric.read(iprot); struct.set_topologyMetric_isSet(true); - { - org.apache.thrift.protocol.TMap _map184 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.componentMetric = new HashMap<String,MetricInfo>(2*_map184.size); - String _key185; - MetricInfo _val186; - for (int _i187 = 0; _i187 < _map184.size; ++_i187) - { - _key185 = iprot.readString(); - _val186 = new MetricInfo(); - _val186.read(iprot); - struct.componentMetric.put(_key185, _val186); - } - } + struct.componentMetric = new MetricInfo(); + struct.componentMetric.read(iprot); struct.set_componentMetric_isSet(true); - { - org.apache.thrift.protocol.TMap _map188 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.workerMetric = new HashMap<String,MetricInfo>(2*_map188.size); - String _key189; - MetricInfo _val190; - for (int _i191 = 0; _i191 < _map188.size; ++_i191) - { - _key189 = iprot.readString(); - _val190 = new MetricInfo(); - _val190.read(iprot); - struct.workerMetric.put(_key189, _val190); - } - } + struct.workerMetric = new MetricInfo(); + struct.workerMetric.read(iprot); struct.set_workerMetric_isSet(true); - { - org.apache.thrift.protocol.TMap _map192 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.taskMetric = new HashMap<Integer,MetricInfo>(2*_map192.size); - int _key193; - MetricInfo _val194; - for (int _i195 = 0; _i195 < _map192.size; ++_i195) - { - _key193 = iprot.readI32(); - _val194 = new MetricInfo(); - _val194.read(iprot); - struct.taskMetric.put(_key193, _val194); - } - } + struct.taskMetric = new MetricInfo(); + struct.taskMetric.read(iprot); struct.set_taskMetric_isSet(true); + struct.streamMetric = new MetricInfo(); + struct.streamMetric.read(iprot); + struct.set_streamMetric_isSet(true); + struct.nettyMetric = new MetricInfo(); + struct.nettyMetric.read(iprot); + struct.set_nettyMetric_isSet(true); } }
http://git-wip-us.apache.org/repos/asf/storm/blob/7eaf0651/jstorm-core/src/main/java/backtype/storm/generated/TopologySummary.java ---------------------------------------------------------------------- diff --git a/jstorm-core/src/main/java/backtype/storm/generated/TopologySummary.java b/jstorm-core/src/main/java/backtype/storm/generated/TopologySummary.java index febb095..7369ed9 100644 --- a/jstorm-core/src/main/java/backtype/storm/generated/TopologySummary.java +++ b/jstorm-core/src/main/java/backtype/storm/generated/TopologySummary.java @@ -34,17 +34,17 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-27") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-20") public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, TopologySummary._Fields>, java.io.Serializable, Cloneable, Comparable<TopologySummary> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TopologySummary"); private static final org.apache.thrift.protocol.TField ID_FIELD_DESC = new org.apache.thrift.protocol.TField("id", org.apache.thrift.protocol.TType.STRING, (short)1); private static final org.apache.thrift.protocol.TField NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("name", org.apache.thrift.protocol.TType.STRING, (short)2); private static final org.apache.thrift.protocol.TField STATUS_FIELD_DESC = new org.apache.thrift.protocol.TField("status", org.apache.thrift.protocol.TType.STRING, (short)3); - private static final org.apache.thrift.protocol.TField UPTIME_SECS_FIELD_DESC = new org.apache.thrift.protocol.TField("uptime_secs", org.apache.thrift.protocol.TType.I32, (short)4); - private static final org.apache.thrift.protocol.TField NUM_TASKS_FIELD_DESC = new org.apache.thrift.protocol.TField("num_tasks", org.apache.thrift.protocol.TType.I32, (short)5); - private static final org.apache.thrift.protocol.TField NUM_WORKERS_FIELD_DESC = new org.apache.thrift.protocol.TField("num_workers", org.apache.thrift.protocol.TType.I32, (short)6); - private static final org.apache.thrift.protocol.TField ERROR_INFO_FIELD_DESC = new org.apache.thrift.protocol.TField("error_info", org.apache.thrift.protocol.TType.STRING, (short)7); + private static final org.apache.thrift.protocol.TField UPTIME_SECS_FIELD_DESC = new org.apache.thrift.protocol.TField("uptimeSecs", org.apache.thrift.protocol.TType.I32, (short)4); + private static final org.apache.thrift.protocol.TField NUM_TASKS_FIELD_DESC = new org.apache.thrift.protocol.TField("numTasks", org.apache.thrift.protocol.TType.I32, (short)5); + private static final org.apache.thrift.protocol.TField NUM_WORKERS_FIELD_DESC = new org.apache.thrift.protocol.TField("numWorkers", org.apache.thrift.protocol.TType.I32, (short)6); + private static final org.apache.thrift.protocol.TField ERROR_INFO_FIELD_DESC = new org.apache.thrift.protocol.TField("errorInfo", org.apache.thrift.protocol.TType.STRING, (short)7); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -55,20 +55,20 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, private String id; // required private String name; // required private String status; // required - private int uptime_secs; // required - private int num_tasks; // required - private int num_workers; // required - private String error_info; // optional + private int uptimeSecs; // required + private int numTasks; // required + private int numWorkers; // required + private String errorInfo; // 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 { ID((short)1, "id"), NAME((short)2, "name"), STATUS((short)3, "status"), - UPTIME_SECS((short)4, "uptime_secs"), - NUM_TASKS((short)5, "num_tasks"), - NUM_WORKERS((short)6, "num_workers"), - ERROR_INFO((short)7, "error_info"); + UPTIME_SECS((short)4, "uptimeSecs"), + NUM_TASKS((short)5, "numTasks"), + NUM_WORKERS((short)6, "numWorkers"), + ERROR_INFO((short)7, "errorInfo"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -137,9 +137,9 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, } // isset id assignments - private static final int __UPTIME_SECS_ISSET_ID = 0; - private static final int __NUM_TASKS_ISSET_ID = 1; - private static final int __NUM_WORKERS_ISSET_ID = 2; + private static final int __UPTIMESECS_ISSET_ID = 0; + private static final int __NUMTASKS_ISSET_ID = 1; + private static final int __NUMWORKERS_ISSET_ID = 2; private byte __isset_bitfield = 0; private static final _Fields optionals[] = {_Fields.ERROR_INFO}; public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; @@ -151,13 +151,13 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); tmpMap.put(_Fields.STATUS, new org.apache.thrift.meta_data.FieldMetaData("status", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.UPTIME_SECS, new org.apache.thrift.meta_data.FieldMetaData("uptime_secs", org.apache.thrift.TFieldRequirementType.REQUIRED, + tmpMap.put(_Fields.UPTIME_SECS, new org.apache.thrift.meta_data.FieldMetaData("uptimeSecs", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.NUM_TASKS, new org.apache.thrift.meta_data.FieldMetaData("num_tasks", org.apache.thrift.TFieldRequirementType.REQUIRED, + tmpMap.put(_Fields.NUM_TASKS, new org.apache.thrift.meta_data.FieldMetaData("numTasks", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.NUM_WORKERS, new org.apache.thrift.meta_data.FieldMetaData("num_workers", org.apache.thrift.TFieldRequirementType.REQUIRED, + tmpMap.put(_Fields.NUM_WORKERS, new org.apache.thrift.meta_data.FieldMetaData("numWorkers", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.ERROR_INFO, new org.apache.thrift.meta_data.FieldMetaData("error_info", org.apache.thrift.TFieldRequirementType.OPTIONAL, + tmpMap.put(_Fields.ERROR_INFO, new org.apache.thrift.meta_data.FieldMetaData("errorInfo", org.apache.thrift.TFieldRequirementType.OPTIONAL, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TopologySummary.class, metaDataMap); @@ -170,20 +170,20 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, String id, String name, String status, - int uptime_secs, - int num_tasks, - int num_workers) + int uptimeSecs, + int numTasks, + int numWorkers) { this(); this.id = id; this.name = name; this.status = status; - this.uptime_secs = uptime_secs; - set_uptime_secs_isSet(true); - this.num_tasks = num_tasks; - set_num_tasks_isSet(true); - this.num_workers = num_workers; - set_num_workers_isSet(true); + this.uptimeSecs = uptimeSecs; + set_uptimeSecs_isSet(true); + this.numTasks = numTasks; + set_numTasks_isSet(true); + this.numWorkers = numWorkers; + set_numWorkers_isSet(true); } /** @@ -200,11 +200,11 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, if (other.is_set_status()) { this.status = other.status; } - this.uptime_secs = other.uptime_secs; - this.num_tasks = other.num_tasks; - this.num_workers = other.num_workers; - if (other.is_set_error_info()) { - this.error_info = other.error_info; + this.uptimeSecs = other.uptimeSecs; + this.numTasks = other.numTasks; + this.numWorkers = other.numWorkers; + if (other.is_set_errorInfo()) { + this.errorInfo = other.errorInfo; } } @@ -217,13 +217,13 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, this.id = null; this.name = null; this.status = null; - set_uptime_secs_isSet(false); - this.uptime_secs = 0; - set_num_tasks_isSet(false); - this.num_tasks = 0; - set_num_workers_isSet(false); - this.num_workers = 0; - this.error_info = null; + set_uptimeSecs_isSet(false); + this.uptimeSecs = 0; + set_numTasks_isSet(false); + this.numTasks = 0; + set_numWorkers_isSet(false); + this.numWorkers = 0; + this.errorInfo = null; } public String get_id() { @@ -295,92 +295,92 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, } } - public int get_uptime_secs() { - return this.uptime_secs; + public int get_uptimeSecs() { + return this.uptimeSecs; } - public void set_uptime_secs(int uptime_secs) { - this.uptime_secs = uptime_secs; - set_uptime_secs_isSet(true); + public void set_uptimeSecs(int uptimeSecs) { + this.uptimeSecs = uptimeSecs; + set_uptimeSecs_isSet(true); } - public void unset_uptime_secs() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __UPTIME_SECS_ISSET_ID); + public void unset_uptimeSecs() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __UPTIMESECS_ISSET_ID); } - /** Returns true if field uptime_secs is set (has been assigned a value) and false otherwise */ - public boolean is_set_uptime_secs() { - return EncodingUtils.testBit(__isset_bitfield, __UPTIME_SECS_ISSET_ID); + /** Returns true if field uptimeSecs is set (has been assigned a value) and false otherwise */ + public boolean is_set_uptimeSecs() { + return EncodingUtils.testBit(__isset_bitfield, __UPTIMESECS_ISSET_ID); } - public void set_uptime_secs_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __UPTIME_SECS_ISSET_ID, value); + public void set_uptimeSecs_isSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __UPTIMESECS_ISSET_ID, value); } - public int get_num_tasks() { - return this.num_tasks; + public int get_numTasks() { + return this.numTasks; } - public void set_num_tasks(int num_tasks) { - this.num_tasks = num_tasks; - set_num_tasks_isSet(true); + public void set_numTasks(int numTasks) { + this.numTasks = numTasks; + set_numTasks_isSet(true); } - public void unset_num_tasks() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUM_TASKS_ISSET_ID); + public void unset_numTasks() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUMTASKS_ISSET_ID); } - /** Returns true if field num_tasks is set (has been assigned a value) and false otherwise */ - public boolean is_set_num_tasks() { - return EncodingUtils.testBit(__isset_bitfield, __NUM_TASKS_ISSET_ID); + /** Returns true if field numTasks is set (has been assigned a value) and false otherwise */ + public boolean is_set_numTasks() { + return EncodingUtils.testBit(__isset_bitfield, __NUMTASKS_ISSET_ID); } - public void set_num_tasks_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUM_TASKS_ISSET_ID, value); + public void set_numTasks_isSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUMTASKS_ISSET_ID, value); } - public int get_num_workers() { - return this.num_workers; + public int get_numWorkers() { + return this.numWorkers; } - public void set_num_workers(int num_workers) { - this.num_workers = num_workers; - set_num_workers_isSet(true); + public void set_numWorkers(int numWorkers) { + this.numWorkers = numWorkers; + set_numWorkers_isSet(true); } - public void unset_num_workers() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUM_WORKERS_ISSET_ID); + public void unset_numWorkers() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUMWORKERS_ISSET_ID); } - /** Returns true if field num_workers is set (has been assigned a value) and false otherwise */ - public boolean is_set_num_workers() { - return EncodingUtils.testBit(__isset_bitfield, __NUM_WORKERS_ISSET_ID); + /** Returns true if field numWorkers is set (has been assigned a value) and false otherwise */ + public boolean is_set_numWorkers() { + return EncodingUtils.testBit(__isset_bitfield, __NUMWORKERS_ISSET_ID); } - public void set_num_workers_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUM_WORKERS_ISSET_ID, value); + public void set_numWorkers_isSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUMWORKERS_ISSET_ID, value); } - public String get_error_info() { - return this.error_info; + public String get_errorInfo() { + return this.errorInfo; } - public void set_error_info(String error_info) { - this.error_info = error_info; + public void set_errorInfo(String errorInfo) { + this.errorInfo = errorInfo; } - public void unset_error_info() { - this.error_info = null; + public void unset_errorInfo() { + this.errorInfo = null; } - /** Returns true if field error_info is set (has been assigned a value) and false otherwise */ - public boolean is_set_error_info() { - return this.error_info != null; + /** Returns true if field errorInfo is set (has been assigned a value) and false otherwise */ + public boolean is_set_errorInfo() { + return this.errorInfo != null; } - public void set_error_info_isSet(boolean value) { + public void set_errorInfo_isSet(boolean value) { if (!value) { - this.error_info = null; + this.errorInfo = null; } } @@ -412,33 +412,33 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, case UPTIME_SECS: if (value == null) { - unset_uptime_secs(); + unset_uptimeSecs(); } else { - set_uptime_secs((Integer)value); + set_uptimeSecs((Integer)value); } break; case NUM_TASKS: if (value == null) { - unset_num_tasks(); + unset_numTasks(); } else { - set_num_tasks((Integer)value); + set_numTasks((Integer)value); } break; case NUM_WORKERS: if (value == null) { - unset_num_workers(); + unset_numWorkers(); } else { - set_num_workers((Integer)value); + set_numWorkers((Integer)value); } break; case ERROR_INFO: if (value == null) { - unset_error_info(); + unset_errorInfo(); } else { - set_error_info((String)value); + set_errorInfo((String)value); } break; @@ -457,16 +457,16 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, return get_status(); case UPTIME_SECS: - return Integer.valueOf(get_uptime_secs()); + return Integer.valueOf(get_uptimeSecs()); case NUM_TASKS: - return Integer.valueOf(get_num_tasks()); + return Integer.valueOf(get_numTasks()); case NUM_WORKERS: - return Integer.valueOf(get_num_workers()); + return Integer.valueOf(get_numWorkers()); case ERROR_INFO: - return get_error_info(); + return get_errorInfo(); } throw new IllegalStateException(); @@ -486,13 +486,13 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, case STATUS: return is_set_status(); case UPTIME_SECS: - return is_set_uptime_secs(); + return is_set_uptimeSecs(); case NUM_TASKS: - return is_set_num_tasks(); + return is_set_numTasks(); case NUM_WORKERS: - return is_set_num_workers(); + return is_set_numWorkers(); case ERROR_INFO: - return is_set_error_info(); + return is_set_errorInfo(); } throw new IllegalStateException(); } @@ -537,39 +537,39 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, return false; } - boolean this_present_uptime_secs = true; - boolean that_present_uptime_secs = true; - if (this_present_uptime_secs || that_present_uptime_secs) { - if (!(this_present_uptime_secs && that_present_uptime_secs)) + boolean this_present_uptimeSecs = true; + boolean that_present_uptimeSecs = true; + if (this_present_uptimeSecs || that_present_uptimeSecs) { + if (!(this_present_uptimeSecs && that_present_uptimeSecs)) return false; - if (this.uptime_secs != that.uptime_secs) + if (this.uptimeSecs != that.uptimeSecs) return false; } - boolean this_present_num_tasks = true; - boolean that_present_num_tasks = true; - if (this_present_num_tasks || that_present_num_tasks) { - if (!(this_present_num_tasks && that_present_num_tasks)) + boolean this_present_numTasks = true; + boolean that_present_numTasks = true; + if (this_present_numTasks || that_present_numTasks) { + if (!(this_present_numTasks && that_present_numTasks)) return false; - if (this.num_tasks != that.num_tasks) + if (this.numTasks != that.numTasks) return false; } - boolean this_present_num_workers = true; - boolean that_present_num_workers = true; - if (this_present_num_workers || that_present_num_workers) { - if (!(this_present_num_workers && that_present_num_workers)) + boolean this_present_numWorkers = true; + boolean that_present_numWorkers = true; + if (this_present_numWorkers || that_present_numWorkers) { + if (!(this_present_numWorkers && that_present_numWorkers)) return false; - if (this.num_workers != that.num_workers) + if (this.numWorkers != that.numWorkers) return false; } - boolean this_present_error_info = true && this.is_set_error_info(); - boolean that_present_error_info = true && that.is_set_error_info(); - if (this_present_error_info || that_present_error_info) { - if (!(this_present_error_info && that_present_error_info)) + boolean this_present_errorInfo = true && this.is_set_errorInfo(); + boolean that_present_errorInfo = true && that.is_set_errorInfo(); + if (this_present_errorInfo || that_present_errorInfo) { + if (!(this_present_errorInfo && that_present_errorInfo)) return false; - if (!this.error_info.equals(that.error_info)) + if (!this.errorInfo.equals(that.errorInfo)) return false; } @@ -595,25 +595,25 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, if (present_status) list.add(status); - boolean present_uptime_secs = true; - list.add(present_uptime_secs); - if (present_uptime_secs) - list.add(uptime_secs); + boolean present_uptimeSecs = true; + list.add(present_uptimeSecs); + if (present_uptimeSecs) + list.add(uptimeSecs); - boolean present_num_tasks = true; - list.add(present_num_tasks); - if (present_num_tasks) - list.add(num_tasks); + boolean present_numTasks = true; + list.add(present_numTasks); + if (present_numTasks) + list.add(numTasks); - boolean present_num_workers = true; - list.add(present_num_workers); - if (present_num_workers) - list.add(num_workers); + boolean present_numWorkers = true; + list.add(present_numWorkers); + if (present_numWorkers) + list.add(numWorkers); - boolean present_error_info = true && (is_set_error_info()); - list.add(present_error_info); - if (present_error_info) - list.add(error_info); + boolean present_errorInfo = true && (is_set_errorInfo()); + list.add(present_errorInfo); + if (present_errorInfo) + list.add(errorInfo); return list.hashCode(); } @@ -656,42 +656,42 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_uptime_secs()).compareTo(other.is_set_uptime_secs()); + lastComparison = Boolean.valueOf(is_set_uptimeSecs()).compareTo(other.is_set_uptimeSecs()); if (lastComparison != 0) { return lastComparison; } - if (is_set_uptime_secs()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.uptime_secs, other.uptime_secs); + if (is_set_uptimeSecs()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.uptimeSecs, other.uptimeSecs); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_num_tasks()).compareTo(other.is_set_num_tasks()); + lastComparison = Boolean.valueOf(is_set_numTasks()).compareTo(other.is_set_numTasks()); if (lastComparison != 0) { return lastComparison; } - if (is_set_num_tasks()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.num_tasks, other.num_tasks); + if (is_set_numTasks()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.numTasks, other.numTasks); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_num_workers()).compareTo(other.is_set_num_workers()); + lastComparison = Boolean.valueOf(is_set_numWorkers()).compareTo(other.is_set_numWorkers()); if (lastComparison != 0) { return lastComparison; } - if (is_set_num_workers()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.num_workers, other.num_workers); + if (is_set_numWorkers()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.numWorkers, other.numWorkers); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_error_info()).compareTo(other.is_set_error_info()); + lastComparison = Boolean.valueOf(is_set_errorInfo()).compareTo(other.is_set_errorInfo()); if (lastComparison != 0) { return lastComparison; } - if (is_set_error_info()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.error_info, other.error_info); + if (is_set_errorInfo()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.errorInfo, other.errorInfo); if (lastComparison != 0) { return lastComparison; } @@ -703,11 +703,11 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -740,24 +740,24 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, } first = false; if (!first) sb.append(", "); - sb.append("uptime_secs:"); - sb.append(this.uptime_secs); + sb.append("uptimeSecs:"); + sb.append(this.uptimeSecs); first = false; if (!first) sb.append(", "); - sb.append("num_tasks:"); - sb.append(this.num_tasks); + sb.append("numTasks:"); + sb.append(this.numTasks); first = false; if (!first) sb.append(", "); - sb.append("num_workers:"); - sb.append(this.num_workers); + sb.append("numWorkers:"); + sb.append(this.numWorkers); first = false; - if (is_set_error_info()) { + if (is_set_errorInfo()) { if (!first) sb.append(", "); - sb.append("error_info:"); - if (this.error_info == null) { + sb.append("errorInfo:"); + if (this.errorInfo == null) { sb.append("null"); } else { - sb.append(this.error_info); + sb.append(this.errorInfo); } first = false; } @@ -765,30 +765,30 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields if (!is_set_id()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'id' is unset! Struct:" + toString()); + throw new TProtocolException("Required field 'id' is unset! Struct:" + toString()); } if (!is_set_name()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'name' is unset! Struct:" + toString()); + throw new TProtocolException("Required field 'name' is unset! Struct:" + toString()); } if (!is_set_status()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'status' is unset! Struct:" + toString()); + throw new TProtocolException("Required field 'status' is unset! Struct:" + toString()); } - if (!is_set_uptime_secs()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'uptime_secs' is unset! Struct:" + toString()); + if (!is_set_uptimeSecs()) { + throw new TProtocolException("Required field 'uptimeSecs' is unset! Struct:" + toString()); } - if (!is_set_num_tasks()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'num_tasks' is unset! Struct:" + toString()); + if (!is_set_numTasks()) { + throw new TProtocolException("Required field 'numTasks' is unset! Struct:" + toString()); } - if (!is_set_num_workers()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'num_workers' is unset! Struct:" + toString()); + if (!is_set_numWorkers()) { + throw new TProtocolException("Required field 'numWorkers' is unset! Struct:" + toString()); } // check for sub-struct validity @@ -797,7 +797,7 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { try { write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -807,7 +807,7 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, // 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; read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -820,7 +820,7 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, private static class TopologySummaryStandardScheme extends StandardScheme<TopologySummary> { - public void read(org.apache.thrift.protocol.TProtocol iprot, TopologySummary struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, TopologySummary struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -856,32 +856,32 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, break; case 4: // UPTIME_SECS if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.uptime_secs = iprot.readI32(); - struct.set_uptime_secs_isSet(true); + struct.uptimeSecs = iprot.readI32(); + struct.set_uptimeSecs_isSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; case 5: // NUM_TASKS if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.num_tasks = iprot.readI32(); - struct.set_num_tasks_isSet(true); + struct.numTasks = iprot.readI32(); + struct.set_numTasks_isSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; case 6: // NUM_WORKERS if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.num_workers = iprot.readI32(); - struct.set_num_workers_isSet(true); + struct.numWorkers = iprot.readI32(); + struct.set_numWorkers_isSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; case 7: // ERROR_INFO if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.error_info = iprot.readString(); - struct.set_error_info_isSet(true); + struct.errorInfo = iprot.readString(); + struct.set_errorInfo_isSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -895,7 +895,7 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, TopologySummary struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, TopologySummary struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -915,18 +915,18 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, oprot.writeFieldEnd(); } oprot.writeFieldBegin(UPTIME_SECS_FIELD_DESC); - oprot.writeI32(struct.uptime_secs); + oprot.writeI32(struct.uptimeSecs); oprot.writeFieldEnd(); oprot.writeFieldBegin(NUM_TASKS_FIELD_DESC); - oprot.writeI32(struct.num_tasks); + oprot.writeI32(struct.numTasks); oprot.writeFieldEnd(); oprot.writeFieldBegin(NUM_WORKERS_FIELD_DESC); - oprot.writeI32(struct.num_workers); + oprot.writeI32(struct.numWorkers); oprot.writeFieldEnd(); - if (struct.error_info != null) { - if (struct.is_set_error_info()) { + if (struct.errorInfo != null) { + if (struct.is_set_errorInfo()) { oprot.writeFieldBegin(ERROR_INFO_FIELD_DESC); - oprot.writeString(struct.error_info); + oprot.writeString(struct.errorInfo); oprot.writeFieldEnd(); } } @@ -945,26 +945,26 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, private static class TopologySummaryTupleScheme extends TupleScheme<TopologySummary> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, TopologySummary struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, TopologySummary struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; oprot.writeString(struct.id); oprot.writeString(struct.name); oprot.writeString(struct.status); - oprot.writeI32(struct.uptime_secs); - oprot.writeI32(struct.num_tasks); - oprot.writeI32(struct.num_workers); + oprot.writeI32(struct.uptimeSecs); + oprot.writeI32(struct.numTasks); + oprot.writeI32(struct.numWorkers); BitSet optionals = new BitSet(); - if (struct.is_set_error_info()) { + if (struct.is_set_errorInfo()) { optionals.set(0); } oprot.writeBitSet(optionals, 1); - if (struct.is_set_error_info()) { - oprot.writeString(struct.error_info); + if (struct.is_set_errorInfo()) { + oprot.writeString(struct.errorInfo); } } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, TopologySummary struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, TopologySummary struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; struct.id = iprot.readString(); struct.set_id_isSet(true); @@ -972,16 +972,16 @@ public class TopologySummary implements org.apache.thrift.TBase<TopologySummary, struct.set_name_isSet(true); struct.status = iprot.readString(); struct.set_status_isSet(true); - struct.uptime_secs = iprot.readI32(); - struct.set_uptime_secs_isSet(true); - struct.num_tasks = iprot.readI32(); - struct.set_num_tasks_isSet(true); - struct.num_workers = iprot.readI32(); - struct.set_num_workers_isSet(true); + struct.uptimeSecs = iprot.readI32(); + struct.set_uptimeSecs_isSet(true); + struct.numTasks = iprot.readI32(); + struct.set_numTasks_isSet(true); + struct.numWorkers = iprot.readI32(); + struct.set_numWorkers_isSet(true); BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { - struct.error_info = iprot.readString(); - struct.set_error_info_isSet(true); + struct.errorInfo = iprot.readString(); + struct.set_errorInfo_isSet(true); } } }
