http://git-wip-us.apache.org/repos/asf/storm/blob/d839d1bf/storm-core/src/jvm/backtype/storm/generated/ClusterWorkerHeartbeat.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/ClusterWorkerHeartbeat.java b/storm-core/src/jvm/backtype/storm/generated/ClusterWorkerHeartbeat.java deleted file mode 100644 index 2754abd..0000000 --- a/storm-core/src/jvm/backtype/storm/generated/ClusterWorkerHeartbeat.java +++ /dev/null @@ -1,768 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package backtype.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)") -public class ClusterWorkerHeartbeat implements org.apache.thrift.TBase<ClusterWorkerHeartbeat, ClusterWorkerHeartbeat._Fields>, java.io.Serializable, Cloneable, Comparable<ClusterWorkerHeartbeat> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ClusterWorkerHeartbeat"); - - private static final org.apache.thrift.protocol.TField STORM_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("storm_id", org.apache.thrift.protocol.TType.STRING, (short)1); - private static final org.apache.thrift.protocol.TField EXECUTOR_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("executor_stats", org.apache.thrift.protocol.TType.MAP, (short)2); - private static final org.apache.thrift.protocol.TField TIME_SECS_FIELD_DESC = new org.apache.thrift.protocol.TField("time_secs", org.apache.thrift.protocol.TType.I32, (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 Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new ClusterWorkerHeartbeatStandardSchemeFactory()); - schemes.put(TupleScheme.class, new ClusterWorkerHeartbeatTupleSchemeFactory()); - } - - private String storm_id; // required - private Map<ExecutorInfo,ExecutorStats> executor_stats; // required - private int time_secs; // required - private int uptime_secs; // 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 { - STORM_ID((short)1, "storm_id"), - EXECUTOR_STATS((short)2, "executor_stats"), - TIME_SECS((short)3, "time_secs"), - UPTIME_SECS((short)4, "uptime_secs"); - - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); - - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } - } - - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 1: // STORM_ID - return STORM_ID; - case 2: // EXECUTOR_STATS - return EXECUTOR_STATS; - case 3: // TIME_SECS - return TIME_SECS; - case 4: // UPTIME_SECS - return UPTIME_SECS; - default: - return null; - } - } - - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ - public static _Fields findByThriftIdOrThrow(int fieldId) { - _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new 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) { - return byName.get(name); - } - - private final short _thriftId; - private final String _fieldName; - - _Fields(short thriftId, String fieldName) { - _thriftId = thriftId; - _fieldName = fieldName; - } - - public short getThriftFieldId() { - return _thriftId; - } - - public String getFieldName() { - return _fieldName; - } - } - - // isset id assignments - private static final int __TIME_SECS_ISSET_ID = 0; - private static final int __UPTIME_SECS_ISSET_ID = 1; - private byte __isset_bitfield = 0; - public static final 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); - tmpMap.put(_Fields.STORM_ID, new org.apache.thrift.meta_data.FieldMetaData("storm_id", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.EXECUTOR_STATS, new org.apache.thrift.meta_data.FieldMetaData("executor_stats", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ExecutorInfo.class), - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ExecutorStats.class)))); - tmpMap.put(_Fields.TIME_SECS, new org.apache.thrift.meta_data.FieldMetaData("time_secs", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.UPTIME_SECS, new org.apache.thrift.meta_data.FieldMetaData("uptime_secs", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ClusterWorkerHeartbeat.class, metaDataMap); - } - - public ClusterWorkerHeartbeat() { - } - - public ClusterWorkerHeartbeat( - String storm_id, - Map<ExecutorInfo,ExecutorStats> executor_stats, - int time_secs, - int uptime_secs) - { - this(); - this.storm_id = storm_id; - this.executor_stats = executor_stats; - this.time_secs = time_secs; - set_time_secs_isSet(true); - this.uptime_secs = uptime_secs; - set_uptime_secs_isSet(true); - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public ClusterWorkerHeartbeat(ClusterWorkerHeartbeat other) { - __isset_bitfield = other.__isset_bitfield; - if (other.is_set_storm_id()) { - this.storm_id = other.storm_id; - } - if (other.is_set_executor_stats()) { - Map<ExecutorInfo,ExecutorStats> __this__executor_stats = new HashMap<ExecutorInfo,ExecutorStats>(other.executor_stats.size()); - for (Map.Entry<ExecutorInfo, ExecutorStats> other_element : other.executor_stats.entrySet()) { - - ExecutorInfo other_element_key = other_element.getKey(); - ExecutorStats other_element_value = other_element.getValue(); - - ExecutorInfo __this__executor_stats_copy_key = new ExecutorInfo(other_element_key); - - ExecutorStats __this__executor_stats_copy_value = new ExecutorStats(other_element_value); - - __this__executor_stats.put(__this__executor_stats_copy_key, __this__executor_stats_copy_value); - } - this.executor_stats = __this__executor_stats; - } - this.time_secs = other.time_secs; - this.uptime_secs = other.uptime_secs; - } - - public ClusterWorkerHeartbeat deepCopy() { - return new ClusterWorkerHeartbeat(this); - } - - @Override - public void clear() { - this.storm_id = null; - this.executor_stats = null; - set_time_secs_isSet(false); - this.time_secs = 0; - set_uptime_secs_isSet(false); - this.uptime_secs = 0; - } - - public String get_storm_id() { - return this.storm_id; - } - - public void set_storm_id(String storm_id) { - this.storm_id = storm_id; - } - - public void unset_storm_id() { - this.storm_id = null; - } - - /** Returns true if field storm_id is set (has been assigned a value) and false otherwise */ - public boolean is_set_storm_id() { - return this.storm_id != null; - } - - public void set_storm_id_isSet(boolean value) { - if (!value) { - this.storm_id = null; - } - } - - public int get_executor_stats_size() { - return (this.executor_stats == null) ? 0 : this.executor_stats.size(); - } - - public void put_to_executor_stats(ExecutorInfo key, ExecutorStats val) { - if (this.executor_stats == null) { - this.executor_stats = new HashMap<ExecutorInfo,ExecutorStats>(); - } - this.executor_stats.put(key, val); - } - - public Map<ExecutorInfo,ExecutorStats> get_executor_stats() { - return this.executor_stats; - } - - public void set_executor_stats(Map<ExecutorInfo,ExecutorStats> executor_stats) { - this.executor_stats = executor_stats; - } - - public void unset_executor_stats() { - this.executor_stats = null; - } - - /** Returns true if field executor_stats is set (has been assigned a value) and false otherwise */ - public boolean is_set_executor_stats() { - return this.executor_stats != null; - } - - public void set_executor_stats_isSet(boolean value) { - if (!value) { - this.executor_stats = null; - } - } - - public int get_time_secs() { - return this.time_secs; - } - - public void set_time_secs(int time_secs) { - this.time_secs = time_secs; - set_time_secs_isSet(true); - } - - public void unset_time_secs() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TIME_SECS_ISSET_ID); - } - - /** Returns true if field time_secs is set (has been assigned a value) and false otherwise */ - public boolean is_set_time_secs() { - return EncodingUtils.testBit(__isset_bitfield, __TIME_SECS_ISSET_ID); - } - - public void set_time_secs_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TIME_SECS_ISSET_ID, value); - } - - public int get_uptime_secs() { - return this.uptime_secs; - } - - public void set_uptime_secs(int uptime_secs) { - this.uptime_secs = uptime_secs; - set_uptime_secs_isSet(true); - } - - public void unset_uptime_secs() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __UPTIME_SECS_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); - } - - public void set_uptime_secs_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __UPTIME_SECS_ISSET_ID, value); - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case STORM_ID: - if (value == null) { - unset_storm_id(); - } else { - set_storm_id((String)value); - } - break; - - case EXECUTOR_STATS: - if (value == null) { - unset_executor_stats(); - } else { - set_executor_stats((Map<ExecutorInfo,ExecutorStats>)value); - } - break; - - case TIME_SECS: - if (value == null) { - unset_time_secs(); - } else { - set_time_secs((Integer)value); - } - break; - - case UPTIME_SECS: - if (value == null) { - unset_uptime_secs(); - } else { - set_uptime_secs((Integer)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case STORM_ID: - return get_storm_id(); - - case EXECUTOR_STATS: - return get_executor_stats(); - - case TIME_SECS: - return get_time_secs(); - - case UPTIME_SECS: - return get_uptime_secs(); - - } - throw new 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(); - } - - switch (field) { - case STORM_ID: - return is_set_storm_id(); - case EXECUTOR_STATS: - return is_set_executor_stats(); - case TIME_SECS: - return is_set_time_secs(); - case UPTIME_SECS: - return is_set_uptime_secs(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof ClusterWorkerHeartbeat) - return this.equals((ClusterWorkerHeartbeat)that); - return false; - } - - public boolean equals(ClusterWorkerHeartbeat that) { - if (that == null) - return false; - - boolean this_present_storm_id = true && this.is_set_storm_id(); - boolean that_present_storm_id = true && that.is_set_storm_id(); - if (this_present_storm_id || that_present_storm_id) { - if (!(this_present_storm_id && that_present_storm_id)) - return false; - if (!this.storm_id.equals(that.storm_id)) - return false; - } - - boolean this_present_executor_stats = true && this.is_set_executor_stats(); - boolean that_present_executor_stats = true && that.is_set_executor_stats(); - if (this_present_executor_stats || that_present_executor_stats) { - if (!(this_present_executor_stats && that_present_executor_stats)) - return false; - if (!this.executor_stats.equals(that.executor_stats)) - return false; - } - - boolean this_present_time_secs = true; - boolean that_present_time_secs = true; - if (this_present_time_secs || that_present_time_secs) { - if (!(this_present_time_secs && that_present_time_secs)) - return false; - if (this.time_secs != that.time_secs) - 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)) - return false; - if (this.uptime_secs != that.uptime_secs) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_storm_id = true && (is_set_storm_id()); - list.add(present_storm_id); - if (present_storm_id) - list.add(storm_id); - - boolean present_executor_stats = true && (is_set_executor_stats()); - list.add(present_executor_stats); - if (present_executor_stats) - list.add(executor_stats); - - boolean present_time_secs = true; - list.add(present_time_secs); - if (present_time_secs) - list.add(time_secs); - - boolean present_uptime_secs = true; - list.add(present_uptime_secs); - if (present_uptime_secs) - list.add(uptime_secs); - - return list.hashCode(); - } - - @Override - public int compareTo(ClusterWorkerHeartbeat other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(is_set_storm_id()).compareTo(other.is_set_storm_id()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_storm_id()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.storm_id, other.storm_id); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_executor_stats()).compareTo(other.is_set_executor_stats()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_executor_stats()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.executor_stats, other.executor_stats); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_time_secs()).compareTo(other.is_set_time_secs()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_time_secs()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.time_secs, other.time_secs); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_uptime_secs()).compareTo(other.is_set_uptime_secs()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_uptime_secs()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.uptime_secs, other.uptime_secs); - if (lastComparison != 0) { - return lastComparison; - } - } - return 0; - } - - public _Fields fieldForId(int fieldId) { - return _Fields.findByThriftId(fieldId); - } - - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().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); - } - - @Override - public String toString() { - StringBuilder sb = new StringBuilder("ClusterWorkerHeartbeat("); - boolean first = true; - - sb.append("storm_id:"); - if (this.storm_id == null) { - sb.append("null"); - } else { - sb.append(this.storm_id); - } - first = false; - if (!first) sb.append(", "); - sb.append("executor_stats:"); - if (this.executor_stats == null) { - sb.append("null"); - } else { - sb.append(this.executor_stats); - } - first = false; - if (!first) sb.append(", "); - sb.append("time_secs:"); - sb.append(this.time_secs); - first = false; - if (!first) sb.append(", "); - sb.append("uptime_secs:"); - sb.append(this.uptime_secs); - first = false; - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (!is_set_storm_id()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'storm_id' is unset! Struct:" + toString()); - } - - if (!is_set_executor_stats()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'executor_stats' is unset! Struct:" + toString()); - } - - if (!is_set_time_secs()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'time_secs' is unset! Struct:" + toString()); - } - - if (!is_set_uptime_secs()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'uptime_secs' is unset! Struct:" + toString()); - } - - // check for sub-struct validity - } - - 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) { - throw new java.io.IOException(te); - } - } - - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { - try { - // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. - __isset_bitfield = 0; - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private static class ClusterWorkerHeartbeatStandardSchemeFactory implements SchemeFactory { - public ClusterWorkerHeartbeatStandardScheme getScheme() { - return new ClusterWorkerHeartbeatStandardScheme(); - } - } - - private static class ClusterWorkerHeartbeatStandardScheme extends StandardScheme<ClusterWorkerHeartbeat> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, ClusterWorkerHeartbeat struct) throws org.apache.thrift.TException { - org.apache.thrift.protocol.TField schemeField; - iprot.readStructBegin(); - while (true) - { - schemeField = iprot.readFieldBegin(); - if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { - break; - } - switch (schemeField.id) { - case 1: // STORM_ID - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.storm_id = iprot.readString(); - struct.set_storm_id_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // EXECUTOR_STATS - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map624 = iprot.readMapBegin(); - struct.executor_stats = new HashMap<ExecutorInfo,ExecutorStats>(2*_map624.size); - ExecutorInfo _key625; - ExecutorStats _val626; - for (int _i627 = 0; _i627 < _map624.size; ++_i627) - { - _key625 = new ExecutorInfo(); - _key625.read(iprot); - _val626 = new ExecutorStats(); - _val626.read(iprot); - struct.executor_stats.put(_key625, _val626); - } - iprot.readMapEnd(); - } - struct.set_executor_stats_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // TIME_SECS - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.time_secs = iprot.readI32(); - struct.set_time_secs_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - 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); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - default: - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - iprot.readFieldEnd(); - } - iprot.readStructEnd(); - struct.validate(); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot, ClusterWorkerHeartbeat struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.storm_id != null) { - oprot.writeFieldBegin(STORM_ID_FIELD_DESC); - oprot.writeString(struct.storm_id); - oprot.writeFieldEnd(); - } - if (struct.executor_stats != null) { - oprot.writeFieldBegin(EXECUTOR_STATS_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.STRUCT, struct.executor_stats.size())); - for (Map.Entry<ExecutorInfo, ExecutorStats> _iter628 : struct.executor_stats.entrySet()) - { - _iter628.getKey().write(oprot); - _iter628.getValue().write(oprot); - } - oprot.writeMapEnd(); - } - oprot.writeFieldEnd(); - } - oprot.writeFieldBegin(TIME_SECS_FIELD_DESC); - oprot.writeI32(struct.time_secs); - oprot.writeFieldEnd(); - oprot.writeFieldBegin(UPTIME_SECS_FIELD_DESC); - oprot.writeI32(struct.uptime_secs); - oprot.writeFieldEnd(); - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class ClusterWorkerHeartbeatTupleSchemeFactory implements SchemeFactory { - public ClusterWorkerHeartbeatTupleScheme getScheme() { - return new ClusterWorkerHeartbeatTupleScheme(); - } - } - - private static class ClusterWorkerHeartbeatTupleScheme extends TupleScheme<ClusterWorkerHeartbeat> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, ClusterWorkerHeartbeat struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - oprot.writeString(struct.storm_id); - { - oprot.writeI32(struct.executor_stats.size()); - for (Map.Entry<ExecutorInfo, ExecutorStats> _iter629 : struct.executor_stats.entrySet()) - { - _iter629.getKey().write(oprot); - _iter629.getValue().write(oprot); - } - } - oprot.writeI32(struct.time_secs); - oprot.writeI32(struct.uptime_secs); - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, ClusterWorkerHeartbeat struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - struct.storm_id = iprot.readString(); - struct.set_storm_id_isSet(true); - { - org.apache.thrift.protocol.TMap _map630 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.executor_stats = new HashMap<ExecutorInfo,ExecutorStats>(2*_map630.size); - ExecutorInfo _key631; - ExecutorStats _val632; - for (int _i633 = 0; _i633 < _map630.size; ++_i633) - { - _key631 = new ExecutorInfo(); - _key631.read(iprot); - _val632 = new ExecutorStats(); - _val632.read(iprot); - struct.executor_stats.put(_key631, _val632); - } - } - struct.set_executor_stats_isSet(true); - struct.time_secs = iprot.readI32(); - struct.set_time_secs_isSet(true); - struct.uptime_secs = iprot.readI32(); - struct.set_uptime_secs_isSet(true); - } - } - -} -
http://git-wip-us.apache.org/repos/asf/storm/blob/d839d1bf/storm-core/src/jvm/backtype/storm/generated/CommonAggregateStats.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/CommonAggregateStats.java b/storm-core/src/jvm/backtype/storm/generated/CommonAggregateStats.java deleted file mode 100644 index f1ff590..0000000 --- a/storm-core/src/jvm/backtype/storm/generated/CommonAggregateStats.java +++ /dev/null @@ -1,902 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package backtype.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)") -public class CommonAggregateStats implements org.apache.thrift.TBase<CommonAggregateStats, CommonAggregateStats._Fields>, java.io.Serializable, Cloneable, Comparable<CommonAggregateStats> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("CommonAggregateStats"); - - private static final org.apache.thrift.protocol.TField NUM_EXECUTORS_FIELD_DESC = new org.apache.thrift.protocol.TField("num_executors", org.apache.thrift.protocol.TType.I32, (short)1); - 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)2); - private static final org.apache.thrift.protocol.TField EMITTED_FIELD_DESC = new org.apache.thrift.protocol.TField("emitted", org.apache.thrift.protocol.TType.I64, (short)3); - private static final org.apache.thrift.protocol.TField TRANSFERRED_FIELD_DESC = new org.apache.thrift.protocol.TField("transferred", org.apache.thrift.protocol.TType.I64, (short)4); - private static final org.apache.thrift.protocol.TField ACKED_FIELD_DESC = new org.apache.thrift.protocol.TField("acked", org.apache.thrift.protocol.TType.I64, (short)5); - private static final org.apache.thrift.protocol.TField FAILED_FIELD_DESC = new org.apache.thrift.protocol.TField("failed", org.apache.thrift.protocol.TType.I64, (short)6); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new CommonAggregateStatsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new CommonAggregateStatsTupleSchemeFactory()); - } - - private int num_executors; // optional - private int num_tasks; // optional - private long emitted; // optional - private long transferred; // optional - private long acked; // optional - private long 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 { - NUM_EXECUTORS((short)1, "num_executors"), - NUM_TASKS((short)2, "num_tasks"), - EMITTED((short)3, "emitted"), - TRANSFERRED((short)4, "transferred"), - ACKED((short)5, "acked"), - FAILED((short)6, "failed"); - - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); - - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } - } - - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 1: // NUM_EXECUTORS - return NUM_EXECUTORS; - case 2: // NUM_TASKS - return NUM_TASKS; - case 3: // EMITTED - return EMITTED; - case 4: // TRANSFERRED - return TRANSFERRED; - case 5: // ACKED - return ACKED; - case 6: // FAILED - return FAILED; - default: - return null; - } - } - - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ - public static _Fields findByThriftIdOrThrow(int fieldId) { - _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new 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) { - return byName.get(name); - } - - private final short _thriftId; - private final String _fieldName; - - _Fields(short thriftId, String fieldName) { - _thriftId = thriftId; - _fieldName = fieldName; - } - - public short getThriftFieldId() { - return _thriftId; - } - - public String getFieldName() { - return _fieldName; - } - } - - // isset id assignments - private static final int __NUM_EXECUTORS_ISSET_ID = 0; - private static final int __NUM_TASKS_ISSET_ID = 1; - private static final int __EMITTED_ISSET_ID = 2; - private static final int __TRANSFERRED_ISSET_ID = 3; - private static final int __ACKED_ISSET_ID = 4; - private static final int __FAILED_ISSET_ID = 5; - private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.NUM_EXECUTORS,_Fields.NUM_TASKS,_Fields.EMITTED,_Fields.TRANSFERRED,_Fields.ACKED,_Fields.FAILED}; - public static final 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); - tmpMap.put(_Fields.NUM_EXECUTORS, new org.apache.thrift.meta_data.FieldMetaData("num_executors", org.apache.thrift.TFieldRequirementType.OPTIONAL, - 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.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.EMITTED, new org.apache.thrift.meta_data.FieldMetaData("emitted", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); - tmpMap.put(_Fields.TRANSFERRED, new org.apache.thrift.meta_data.FieldMetaData("transferred", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); - tmpMap.put(_Fields.ACKED, new org.apache.thrift.meta_data.FieldMetaData("acked", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); - tmpMap.put(_Fields.FAILED, new org.apache.thrift.meta_data.FieldMetaData("failed", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(CommonAggregateStats.class, metaDataMap); - } - - public CommonAggregateStats() { - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public CommonAggregateStats(CommonAggregateStats other) { - __isset_bitfield = other.__isset_bitfield; - this.num_executors = other.num_executors; - this.num_tasks = other.num_tasks; - this.emitted = other.emitted; - this.transferred = other.transferred; - this.acked = other.acked; - this.failed = other.failed; - } - - public CommonAggregateStats deepCopy() { - return new CommonAggregateStats(this); - } - - @Override - public void clear() { - set_num_executors_isSet(false); - this.num_executors = 0; - set_num_tasks_isSet(false); - this.num_tasks = 0; - set_emitted_isSet(false); - this.emitted = 0; - set_transferred_isSet(false); - this.transferred = 0; - set_acked_isSet(false); - this.acked = 0; - set_failed_isSet(false); - this.failed = 0; - } - - public int get_num_executors() { - return this.num_executors; - } - - public void set_num_executors(int num_executors) { - this.num_executors = num_executors; - set_num_executors_isSet(true); - } - - public void unset_num_executors() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUM_EXECUTORS_ISSET_ID); - } - - /** Returns true if field num_executors is set (has been assigned a value) and false otherwise */ - public boolean is_set_num_executors() { - return EncodingUtils.testBit(__isset_bitfield, __NUM_EXECUTORS_ISSET_ID); - } - - public void set_num_executors_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUM_EXECUTORS_ISSET_ID, value); - } - - public int get_num_tasks() { - return this.num_tasks; - } - - public void set_num_tasks(int num_tasks) { - this.num_tasks = num_tasks; - set_num_tasks_isSet(true); - } - - public void unset_num_tasks() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUM_TASKS_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); - } - - public void set_num_tasks_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUM_TASKS_ISSET_ID, value); - } - - public long get_emitted() { - return this.emitted; - } - - public void set_emitted(long emitted) { - this.emitted = emitted; - set_emitted_isSet(true); - } - - public void unset_emitted() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __EMITTED_ISSET_ID); - } - - /** Returns true if field emitted is set (has been assigned a value) and false otherwise */ - public boolean is_set_emitted() { - return EncodingUtils.testBit(__isset_bitfield, __EMITTED_ISSET_ID); - } - - public void set_emitted_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __EMITTED_ISSET_ID, value); - } - - public long get_transferred() { - return this.transferred; - } - - public void set_transferred(long transferred) { - this.transferred = transferred; - set_transferred_isSet(true); - } - - public void unset_transferred() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TRANSFERRED_ISSET_ID); - } - - /** Returns true if field transferred is set (has been assigned a value) and false otherwise */ - public boolean is_set_transferred() { - return EncodingUtils.testBit(__isset_bitfield, __TRANSFERRED_ISSET_ID); - } - - public void set_transferred_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TRANSFERRED_ISSET_ID, value); - } - - public long get_acked() { - return this.acked; - } - - public void set_acked(long acked) { - this.acked = acked; - set_acked_isSet(true); - } - - public void unset_acked() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ACKED_ISSET_ID); - } - - /** Returns true if field acked is set (has been assigned a value) and false otherwise */ - public boolean is_set_acked() { - return EncodingUtils.testBit(__isset_bitfield, __ACKED_ISSET_ID); - } - - public void set_acked_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ACKED_ISSET_ID, value); - } - - public long get_failed() { - return this.failed; - } - - public void set_failed(long failed) { - this.failed = failed; - set_failed_isSet(true); - } - - public void unset_failed() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __FAILED_ISSET_ID); - } - - /** Returns true if field failed is set (has been assigned a value) and false otherwise */ - public boolean is_set_failed() { - return EncodingUtils.testBit(__isset_bitfield, __FAILED_ISSET_ID); - } - - public void set_failed_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __FAILED_ISSET_ID, value); - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case NUM_EXECUTORS: - if (value == null) { - unset_num_executors(); - } else { - set_num_executors((Integer)value); - } - break; - - case NUM_TASKS: - if (value == null) { - unset_num_tasks(); - } else { - set_num_tasks((Integer)value); - } - break; - - case EMITTED: - if (value == null) { - unset_emitted(); - } else { - set_emitted((Long)value); - } - break; - - case TRANSFERRED: - if (value == null) { - unset_transferred(); - } else { - set_transferred((Long)value); - } - break; - - case ACKED: - if (value == null) { - unset_acked(); - } else { - set_acked((Long)value); - } - break; - - case FAILED: - if (value == null) { - unset_failed(); - } else { - set_failed((Long)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case NUM_EXECUTORS: - return get_num_executors(); - - case NUM_TASKS: - return get_num_tasks(); - - case EMITTED: - return get_emitted(); - - case TRANSFERRED: - return get_transferred(); - - case ACKED: - return get_acked(); - - case FAILED: - return get_failed(); - - } - throw new 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(); - } - - switch (field) { - case NUM_EXECUTORS: - return is_set_num_executors(); - case NUM_TASKS: - return is_set_num_tasks(); - case EMITTED: - return is_set_emitted(); - case TRANSFERRED: - return is_set_transferred(); - case ACKED: - return is_set_acked(); - case FAILED: - return is_set_failed(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof CommonAggregateStats) - return this.equals((CommonAggregateStats)that); - return false; - } - - public boolean equals(CommonAggregateStats that) { - if (that == null) - return false; - - boolean this_present_num_executors = true && this.is_set_num_executors(); - boolean that_present_num_executors = true && that.is_set_num_executors(); - if (this_present_num_executors || that_present_num_executors) { - if (!(this_present_num_executors && that_present_num_executors)) - return false; - if (this.num_executors != that.num_executors) - return false; - } - - boolean this_present_num_tasks = true && this.is_set_num_tasks(); - boolean that_present_num_tasks = true && that.is_set_num_tasks(); - if (this_present_num_tasks || that_present_num_tasks) { - if (!(this_present_num_tasks && that_present_num_tasks)) - return false; - if (this.num_tasks != that.num_tasks) - return false; - } - - boolean this_present_emitted = true && this.is_set_emitted(); - boolean that_present_emitted = true && that.is_set_emitted(); - if (this_present_emitted || that_present_emitted) { - if (!(this_present_emitted && that_present_emitted)) - return false; - if (this.emitted != that.emitted) - return false; - } - - boolean this_present_transferred = true && this.is_set_transferred(); - boolean that_present_transferred = true && that.is_set_transferred(); - if (this_present_transferred || that_present_transferred) { - if (!(this_present_transferred && that_present_transferred)) - return false; - if (this.transferred != that.transferred) - return false; - } - - boolean this_present_acked = true && this.is_set_acked(); - boolean that_present_acked = true && that.is_set_acked(); - if (this_present_acked || that_present_acked) { - if (!(this_present_acked && that_present_acked)) - return false; - if (this.acked != that.acked) - return false; - } - - boolean this_present_failed = true && this.is_set_failed(); - boolean that_present_failed = true && that.is_set_failed(); - if (this_present_failed || that_present_failed) { - if (!(this_present_failed && that_present_failed)) - return false; - if (this.failed != that.failed) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_num_executors = true && (is_set_num_executors()); - list.add(present_num_executors); - if (present_num_executors) - list.add(num_executors); - - boolean present_num_tasks = true && (is_set_num_tasks()); - list.add(present_num_tasks); - if (present_num_tasks) - list.add(num_tasks); - - boolean present_emitted = true && (is_set_emitted()); - list.add(present_emitted); - if (present_emitted) - list.add(emitted); - - boolean present_transferred = true && (is_set_transferred()); - list.add(present_transferred); - if (present_transferred) - list.add(transferred); - - boolean present_acked = true && (is_set_acked()); - list.add(present_acked); - if (present_acked) - list.add(acked); - - boolean present_failed = true && (is_set_failed()); - list.add(present_failed); - if (present_failed) - list.add(failed); - - return list.hashCode(); - } - - @Override - public int compareTo(CommonAggregateStats other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(is_set_num_executors()).compareTo(other.is_set_num_executors()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_num_executors()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.num_executors, other.num_executors); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_num_tasks()).compareTo(other.is_set_num_tasks()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_num_tasks()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.num_tasks, other.num_tasks); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_emitted()).compareTo(other.is_set_emitted()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_emitted()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.emitted, other.emitted); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_transferred()).compareTo(other.is_set_transferred()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_transferred()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.transferred, other.transferred); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_acked()).compareTo(other.is_set_acked()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_acked()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.acked, other.acked); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_failed()).compareTo(other.is_set_failed()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_failed()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.failed, other.failed); - if (lastComparison != 0) { - return lastComparison; - } - } - return 0; - } - - public _Fields fieldForId(int fieldId) { - return _Fields.findByThriftId(fieldId); - } - - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().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); - } - - @Override - public String toString() { - StringBuilder sb = new StringBuilder("CommonAggregateStats("); - boolean first = true; - - if (is_set_num_executors()) { - sb.append("num_executors:"); - sb.append(this.num_executors); - first = false; - } - if (is_set_num_tasks()) { - if (!first) sb.append(", "); - sb.append("num_tasks:"); - sb.append(this.num_tasks); - first = false; - } - if (is_set_emitted()) { - if (!first) sb.append(", "); - sb.append("emitted:"); - sb.append(this.emitted); - first = false; - } - if (is_set_transferred()) { - if (!first) sb.append(", "); - sb.append("transferred:"); - sb.append(this.transferred); - first = false; - } - if (is_set_acked()) { - if (!first) sb.append(", "); - sb.append("acked:"); - sb.append(this.acked); - first = false; - } - if (is_set_failed()) { - if (!first) sb.append(", "); - sb.append("failed:"); - sb.append(this.failed); - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - // check for sub-struct validity - } - - 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) { - throw new java.io.IOException(te); - } - } - - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { - try { - // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. - __isset_bitfield = 0; - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private static class CommonAggregateStatsStandardSchemeFactory implements SchemeFactory { - public CommonAggregateStatsStandardScheme getScheme() { - return new CommonAggregateStatsStandardScheme(); - } - } - - private static class CommonAggregateStatsStandardScheme extends StandardScheme<CommonAggregateStats> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, CommonAggregateStats struct) throws org.apache.thrift.TException { - org.apache.thrift.protocol.TField schemeField; - iprot.readStructBegin(); - while (true) - { - schemeField = iprot.readFieldBegin(); - if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { - break; - } - switch (schemeField.id) { - case 1: // NUM_EXECUTORS - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.num_executors = iprot.readI32(); - struct.set_num_executors_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // NUM_TASKS - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.num_tasks = iprot.readI32(); - struct.set_num_tasks_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // EMITTED - if (schemeField.type == org.apache.thrift.protocol.TType.I64) { - struct.emitted = iprot.readI64(); - struct.set_emitted_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 4: // TRANSFERRED - if (schemeField.type == org.apache.thrift.protocol.TType.I64) { - struct.transferred = iprot.readI64(); - struct.set_transferred_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 5: // ACKED - if (schemeField.type == org.apache.thrift.protocol.TType.I64) { - struct.acked = iprot.readI64(); - struct.set_acked_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 6: // FAILED - if (schemeField.type == org.apache.thrift.protocol.TType.I64) { - struct.failed = iprot.readI64(); - struct.set_failed_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - default: - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - iprot.readFieldEnd(); - } - iprot.readStructEnd(); - struct.validate(); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot, CommonAggregateStats struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.is_set_num_executors()) { - oprot.writeFieldBegin(NUM_EXECUTORS_FIELD_DESC); - oprot.writeI32(struct.num_executors); - oprot.writeFieldEnd(); - } - if (struct.is_set_num_tasks()) { - oprot.writeFieldBegin(NUM_TASKS_FIELD_DESC); - oprot.writeI32(struct.num_tasks); - oprot.writeFieldEnd(); - } - if (struct.is_set_emitted()) { - oprot.writeFieldBegin(EMITTED_FIELD_DESC); - oprot.writeI64(struct.emitted); - oprot.writeFieldEnd(); - } - if (struct.is_set_transferred()) { - oprot.writeFieldBegin(TRANSFERRED_FIELD_DESC); - oprot.writeI64(struct.transferred); - oprot.writeFieldEnd(); - } - if (struct.is_set_acked()) { - oprot.writeFieldBegin(ACKED_FIELD_DESC); - oprot.writeI64(struct.acked); - oprot.writeFieldEnd(); - } - if (struct.is_set_failed()) { - oprot.writeFieldBegin(FAILED_FIELD_DESC); - oprot.writeI64(struct.failed); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class CommonAggregateStatsTupleSchemeFactory implements SchemeFactory { - public CommonAggregateStatsTupleScheme getScheme() { - return new CommonAggregateStatsTupleScheme(); - } - } - - private static class CommonAggregateStatsTupleScheme extends TupleScheme<CommonAggregateStats> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, CommonAggregateStats struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.is_set_num_executors()) { - optionals.set(0); - } - if (struct.is_set_num_tasks()) { - optionals.set(1); - } - if (struct.is_set_emitted()) { - optionals.set(2); - } - if (struct.is_set_transferred()) { - optionals.set(3); - } - if (struct.is_set_acked()) { - optionals.set(4); - } - if (struct.is_set_failed()) { - optionals.set(5); - } - oprot.writeBitSet(optionals, 6); - if (struct.is_set_num_executors()) { - oprot.writeI32(struct.num_executors); - } - if (struct.is_set_num_tasks()) { - oprot.writeI32(struct.num_tasks); - } - if (struct.is_set_emitted()) { - oprot.writeI64(struct.emitted); - } - if (struct.is_set_transferred()) { - oprot.writeI64(struct.transferred); - } - if (struct.is_set_acked()) { - oprot.writeI64(struct.acked); - } - if (struct.is_set_failed()) { - oprot.writeI64(struct.failed); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, CommonAggregateStats struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(6); - if (incoming.get(0)) { - struct.num_executors = iprot.readI32(); - struct.set_num_executors_isSet(true); - } - if (incoming.get(1)) { - struct.num_tasks = iprot.readI32(); - struct.set_num_tasks_isSet(true); - } - if (incoming.get(2)) { - struct.emitted = iprot.readI64(); - struct.set_emitted_isSet(true); - } - if (incoming.get(3)) { - struct.transferred = iprot.readI64(); - struct.set_transferred_isSet(true); - } - if (incoming.get(4)) { - struct.acked = iprot.readI64(); - struct.set_acked_isSet(true); - } - if (incoming.get(5)) { - struct.failed = iprot.readI64(); - struct.set_failed_isSet(true); - } - } - } - -} - http://git-wip-us.apache.org/repos/asf/storm/blob/d839d1bf/storm-core/src/jvm/backtype/storm/generated/ComponentAggregateStats.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/ComponentAggregateStats.java b/storm-core/src/jvm/backtype/storm/generated/ComponentAggregateStats.java deleted file mode 100644 index eea060f..0000000 --- a/storm-core/src/jvm/backtype/storm/generated/ComponentAggregateStats.java +++ /dev/null @@ -1,752 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package backtype.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)") -public class ComponentAggregateStats implements org.apache.thrift.TBase<ComponentAggregateStats, ComponentAggregateStats._Fields>, java.io.Serializable, Cloneable, Comparable<ComponentAggregateStats> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ComponentAggregateStats"); - - private static final org.apache.thrift.protocol.TField TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("type", org.apache.thrift.protocol.TType.I32, (short)1); - private static final org.apache.thrift.protocol.TField COMMON_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("common_stats", org.apache.thrift.protocol.TType.STRUCT, (short)2); - private static final org.apache.thrift.protocol.TField SPECIFIC_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("specific_stats", org.apache.thrift.protocol.TType.STRUCT, (short)3); - private static final org.apache.thrift.protocol.TField LAST_ERROR_FIELD_DESC = new org.apache.thrift.protocol.TField("last_error", org.apache.thrift.protocol.TType.STRUCT, (short)4); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new ComponentAggregateStatsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new ComponentAggregateStatsTupleSchemeFactory()); - } - - private ComponentType type; // optional - private CommonAggregateStats common_stats; // optional - private SpecificAggregateStats specific_stats; // optional - private ErrorInfo last_error; // 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 { - /** - * - * @see ComponentType - */ - TYPE((short)1, "type"), - COMMON_STATS((short)2, "common_stats"), - SPECIFIC_STATS((short)3, "specific_stats"), - LAST_ERROR((short)4, "last_error"); - - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); - - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } - } - - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 1: // TYPE - return TYPE; - case 2: // COMMON_STATS - return COMMON_STATS; - case 3: // SPECIFIC_STATS - return SPECIFIC_STATS; - case 4: // LAST_ERROR - return LAST_ERROR; - default: - return null; - } - } - - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ - public static _Fields findByThriftIdOrThrow(int fieldId) { - _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new 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) { - return byName.get(name); - } - - private final short _thriftId; - private final String _fieldName; - - _Fields(short thriftId, String fieldName) { - _thriftId = thriftId; - _fieldName = fieldName; - } - - public short getThriftFieldId() { - return _thriftId; - } - - public String getFieldName() { - return _fieldName; - } - } - - // isset id assignments - private static final _Fields optionals[] = {_Fields.TYPE,_Fields.COMMON_STATS,_Fields.SPECIFIC_STATS,_Fields.LAST_ERROR}; - public static final 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); - tmpMap.put(_Fields.TYPE, new org.apache.thrift.meta_data.FieldMetaData("type", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, ComponentType.class))); - tmpMap.put(_Fields.COMMON_STATS, new org.apache.thrift.meta_data.FieldMetaData("common_stats", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, CommonAggregateStats.class))); - tmpMap.put(_Fields.SPECIFIC_STATS, new org.apache.thrift.meta_data.FieldMetaData("specific_stats", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, SpecificAggregateStats.class))); - tmpMap.put(_Fields.LAST_ERROR, new org.apache.thrift.meta_data.FieldMetaData("last_error", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ErrorInfo.class))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ComponentAggregateStats.class, metaDataMap); - } - - public ComponentAggregateStats() { - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public ComponentAggregateStats(ComponentAggregateStats other) { - if (other.is_set_type()) { - this.type = other.type; - } - if (other.is_set_common_stats()) { - this.common_stats = new CommonAggregateStats(other.common_stats); - } - if (other.is_set_specific_stats()) { - this.specific_stats = new SpecificAggregateStats(other.specific_stats); - } - if (other.is_set_last_error()) { - this.last_error = new ErrorInfo(other.last_error); - } - } - - public ComponentAggregateStats deepCopy() { - return new ComponentAggregateStats(this); - } - - @Override - public void clear() { - this.type = null; - this.common_stats = null; - this.specific_stats = null; - this.last_error = null; - } - - /** - * - * @see ComponentType - */ - public ComponentType get_type() { - return this.type; - } - - /** - * - * @see ComponentType - */ - public void set_type(ComponentType type) { - this.type = type; - } - - public void unset_type() { - this.type = null; - } - - /** Returns true if field type is set (has been assigned a value) and false otherwise */ - public boolean is_set_type() { - return this.type != null; - } - - public void set_type_isSet(boolean value) { - if (!value) { - this.type = null; - } - } - - public CommonAggregateStats get_common_stats() { - return this.common_stats; - } - - public void set_common_stats(CommonAggregateStats common_stats) { - this.common_stats = common_stats; - } - - public void unset_common_stats() { - this.common_stats = null; - } - - /** Returns true if field common_stats is set (has been assigned a value) and false otherwise */ - public boolean is_set_common_stats() { - return this.common_stats != null; - } - - public void set_common_stats_isSet(boolean value) { - if (!value) { - this.common_stats = null; - } - } - - public SpecificAggregateStats get_specific_stats() { - return this.specific_stats; - } - - public void set_specific_stats(SpecificAggregateStats specific_stats) { - this.specific_stats = specific_stats; - } - - public void unset_specific_stats() { - this.specific_stats = null; - } - - /** Returns true if field specific_stats is set (has been assigned a value) and false otherwise */ - public boolean is_set_specific_stats() { - return this.specific_stats != null; - } - - public void set_specific_stats_isSet(boolean value) { - if (!value) { - this.specific_stats = null; - } - } - - public ErrorInfo get_last_error() { - return this.last_error; - } - - public void set_last_error(ErrorInfo last_error) { - this.last_error = last_error; - } - - public void unset_last_error() { - this.last_error = null; - } - - /** Returns true if field last_error is set (has been assigned a value) and false otherwise */ - public boolean is_set_last_error() { - return this.last_error != null; - } - - public void set_last_error_isSet(boolean value) { - if (!value) { - this.last_error = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case TYPE: - if (value == null) { - unset_type(); - } else { - set_type((ComponentType)value); - } - break; - - case COMMON_STATS: - if (value == null) { - unset_common_stats(); - } else { - set_common_stats((CommonAggregateStats)value); - } - break; - - case SPECIFIC_STATS: - if (value == null) { - unset_specific_stats(); - } else { - set_specific_stats((SpecificAggregateStats)value); - } - break; - - case LAST_ERROR: - if (value == null) { - unset_last_error(); - } else { - set_last_error((ErrorInfo)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case TYPE: - return get_type(); - - case COMMON_STATS: - return get_common_stats(); - - case SPECIFIC_STATS: - return get_specific_stats(); - - case LAST_ERROR: - return get_last_error(); - - } - throw new 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(); - } - - switch (field) { - case TYPE: - return is_set_type(); - case COMMON_STATS: - return is_set_common_stats(); - case SPECIFIC_STATS: - return is_set_specific_stats(); - case LAST_ERROR: - return is_set_last_error(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof ComponentAggregateStats) - return this.equals((ComponentAggregateStats)that); - return false; - } - - public boolean equals(ComponentAggregateStats that) { - if (that == null) - return false; - - boolean this_present_type = true && this.is_set_type(); - boolean that_present_type = true && that.is_set_type(); - if (this_present_type || that_present_type) { - if (!(this_present_type && that_present_type)) - return false; - if (!this.type.equals(that.type)) - return false; - } - - boolean this_present_common_stats = true && this.is_set_common_stats(); - boolean that_present_common_stats = true && that.is_set_common_stats(); - if (this_present_common_stats || that_present_common_stats) { - if (!(this_present_common_stats && that_present_common_stats)) - return false; - if (!this.common_stats.equals(that.common_stats)) - return false; - } - - boolean this_present_specific_stats = true && this.is_set_specific_stats(); - boolean that_present_specific_stats = true && that.is_set_specific_stats(); - if (this_present_specific_stats || that_present_specific_stats) { - if (!(this_present_specific_stats && that_present_specific_stats)) - return false; - if (!this.specific_stats.equals(that.specific_stats)) - return false; - } - - boolean this_present_last_error = true && this.is_set_last_error(); - boolean that_present_last_error = true && that.is_set_last_error(); - if (this_present_last_error || that_present_last_error) { - if (!(this_present_last_error && that_present_last_error)) - return false; - if (!this.last_error.equals(that.last_error)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_type = true && (is_set_type()); - list.add(present_type); - if (present_type) - list.add(type.getValue()); - - boolean present_common_stats = true && (is_set_common_stats()); - list.add(present_common_stats); - if (present_common_stats) - list.add(common_stats); - - boolean present_specific_stats = true && (is_set_specific_stats()); - list.add(present_specific_stats); - if (present_specific_stats) - list.add(specific_stats); - - boolean present_last_error = true && (is_set_last_error()); - list.add(present_last_error); - if (present_last_error) - list.add(last_error); - - return list.hashCode(); - } - - @Override - public int compareTo(ComponentAggregateStats other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(is_set_type()).compareTo(other.is_set_type()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_type()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.type, other.type); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_common_stats()).compareTo(other.is_set_common_stats()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_common_stats()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.common_stats, other.common_stats); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_specific_stats()).compareTo(other.is_set_specific_stats()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_specific_stats()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.specific_stats, other.specific_stats); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_last_error()).compareTo(other.is_set_last_error()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_last_error()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.last_error, other.last_error); - if (lastComparison != 0) { - return lastComparison; - } - } - return 0; - } - - public _Fields fieldForId(int fieldId) { - return _Fields.findByThriftId(fieldId); - } - - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().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); - } - - @Override - public String toString() { - StringBuilder sb = new StringBuilder("ComponentAggregateStats("); - boolean first = true; - - if (is_set_type()) { - sb.append("type:"); - if (this.type == null) { - sb.append("null"); - } else { - sb.append(this.type); - } - first = false; - } - if (is_set_common_stats()) { - if (!first) sb.append(", "); - sb.append("common_stats:"); - if (this.common_stats == null) { - sb.append("null"); - } else { - sb.append(this.common_stats); - } - first = false; - } - if (is_set_specific_stats()) { - if (!first) sb.append(", "); - sb.append("specific_stats:"); - if (this.specific_stats == null) { - sb.append("null"); - } else { - sb.append(this.specific_stats); - } - first = false; - } - if (is_set_last_error()) { - if (!first) sb.append(", "); - sb.append("last_error:"); - if (this.last_error == null) { - sb.append("null"); - } else { - sb.append(this.last_error); - } - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - // check for sub-struct validity - if (common_stats != null) { - common_stats.validate(); - } - if (last_error != null) { - last_error.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) { - throw new java.io.IOException(te); - } - } - - 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) { - throw new java.io.IOException(te); - } - } - - private static class ComponentAggregateStatsStandardSchemeFactory implements SchemeFactory { - public ComponentAggregateStatsStandardScheme getScheme() { - return new ComponentAggregateStatsStandardScheme(); - } - } - - private static class ComponentAggregateStatsStandardScheme extends StandardScheme<ComponentAggregateStats> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, ComponentAggregateStats struct) throws org.apache.thrift.TException { - org.apache.thrift.protocol.TField schemeField; - iprot.readStructBegin(); - while (true) - { - schemeField = iprot.readFieldBegin(); - if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { - break; - } - switch (schemeField.id) { - case 1: // TYPE - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.type = backtype.storm.generated.ComponentType.findByValue(iprot.readI32()); - struct.set_type_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // COMMON_STATS - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.common_stats = new CommonAggregateStats(); - struct.common_stats.read(iprot); - struct.set_common_stats_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // SPECIFIC_STATS - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.specific_stats = new SpecificAggregateStats(); - struct.specific_stats.read(iprot); - struct.set_specific_stats_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 4: // LAST_ERROR - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.last_error = new ErrorInfo(); - struct.last_error.read(iprot); - struct.set_last_error_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - default: - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - iprot.readFieldEnd(); - } - iprot.readStructEnd(); - struct.validate(); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot, ComponentAggregateStats struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.type != null) { - if (struct.is_set_type()) { - oprot.writeFieldBegin(TYPE_FIELD_DESC); - oprot.writeI32(struct.type.getValue()); - oprot.writeFieldEnd(); - } - } - if (struct.common_stats != null) { - if (struct.is_set_common_stats()) { - oprot.writeFieldBegin(COMMON_STATS_FIELD_DESC); - struct.common_stats.write(oprot); - oprot.writeFieldEnd(); - } - } - if (struct.specific_stats != null) { - if (struct.is_set_specific_stats()) { - oprot.writeFieldBegin(SPECIFIC_STATS_FIELD_DESC); - struct.specific_stats.write(oprot); - oprot.writeFieldEnd(); - } - } - if (struct.last_error != null) { - if (struct.is_set_last_error()) { - oprot.writeFieldBegin(LAST_ERROR_FIELD_DESC); - struct.last_error.write(oprot); - oprot.writeFieldEnd(); - } - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class ComponentAggregateStatsTupleSchemeFactory implements SchemeFactory { - public ComponentAggregateStatsTupleScheme getScheme() { - return new ComponentAggregateStatsTupleScheme(); - } - } - - private static class ComponentAggregateStatsTupleScheme extends TupleScheme<ComponentAggregateStats> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, ComponentAggregateStats struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.is_set_type()) { - optionals.set(0); - } - if (struct.is_set_common_stats()) { - optionals.set(1); - } - if (struct.is_set_specific_stats()) { - optionals.set(2); - } - if (struct.is_set_last_error()) { - optionals.set(3); - } - oprot.writeBitSet(optionals, 4); - if (struct.is_set_type()) { - oprot.writeI32(struct.type.getValue()); - } - if (struct.is_set_common_stats()) { - struct.common_stats.write(oprot); - } - if (struct.is_set_specific_stats()) { - struct.specific_stats.write(oprot); - } - if (struct.is_set_last_error()) { - struct.last_error.write(oprot); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, ComponentAggregateStats struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(4); - if (incoming.get(0)) { - struct.type = backtype.storm.generated.ComponentType.findByValue(iprot.readI32()); - struct.set_type_isSet(true); - } - if (incoming.get(1)) { - struct.common_stats = new CommonAggregateStats(); - struct.common_stats.read(iprot); - struct.set_common_stats_isSet(true); - } - if (incoming.get(2)) { - struct.specific_stats = new SpecificAggregateStats(); - struct.specific_stats.read(iprot); - struct.set_specific_stats_isSet(true); - } - if (incoming.get(3)) { - struct.last_error = new ErrorInfo(); - struct.last_error.read(iprot); - struct.set_last_error_isSet(true); - } - } - } - -} -
