Regenerated NimbusSummary using thrift-0.9.2
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/f7205d29 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/f7205d29 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/f7205d29 Branch: refs/heads/0.11.x-branch Commit: f7205d29f7afeb9e4cf03a31be0ac5737652b07c Parents: 85e4d5e Author: Parth Brahmbhatt <[email protected]> Authored: Mon Mar 2 15:26:41 2015 -0800 Committer: Parth Brahmbhatt <[email protected]> Committed: Mon Mar 2 15:52:00 2015 -0800 ---------------------------------------------------------------------- storm-core/src/clj/backtype/storm/ui/core.clj | 8 +- .../backtype/storm/generated/NimbusSummary.java | 381 +++++++++++-------- 2 files changed, 231 insertions(+), 158 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/f7205d29/storm-core/src/clj/backtype/storm/ui/core.clj ---------------------------------------------------------------------- diff --git a/storm-core/src/clj/backtype/storm/ui/core.clj b/storm-core/src/clj/backtype/storm/ui/core.clj index 7fc9273..0f93f23 100644 --- a/storm-core/src/clj/backtype/storm/ui/core.clj +++ b/storm-core/src/clj/backtype/storm/ui/core.clj @@ -25,7 +25,8 @@ ACKER-FAIL-STREAM-ID system-id? mk-authorization-handler]]]) (:use [ring.middleware.anti-forgery]) (:use [clojure.string :only [blank? lower-case trim]]) - (:import [backtype.storm.utils Utils]) + (:import [backtype.storm.utils Utils] + [backtype.storm.generated NimbusSummary]) (:import [backtype.storm.generated ExecutorSpecificStats ExecutorStats ExecutorSummary TopologyInfo SpoutStats BoltStats ErrorInfo ClusterSummary SupervisorSummary TopologySummary @@ -41,7 +42,6 @@ [ring.util.response :as resp] [backtype.storm [thrift :as thrift]]) (:import [org.apache.commons.lang StringEscapeUtils]) - (:import [backtype.storm.nimbus NimbusInfo]) (:gen-class)) (def ^:dynamic *STORM-CONF* (read-storm-config)) @@ -520,14 +520,14 @@ (.get_nimbuses (.getClusterInfo ^Nimbus$Client nimbus))))) ([nimbuses] {"nimbuses" - (for [^NimbusInfo n nimbuses] + (for [^NimbusSummary n nimbuses] { "host" (.get_host n) "port" (.get_port n) "nimbusLogLink" (nimbus-log-link (.get_host n) (.get_port n)) "isLeader" (.is_isLeader n) "version" (.get_version n) - "nimbusUpTime" (pretty-uptime-sec (.get_uptimeSecs n))})})) + "nimbusUpTime" (pretty-uptime-sec (.get_uptime_secs n))})})) (defn supervisor-summary ([] http://git-wip-us.apache.org/repos/asf/storm/blob/f7205d29/storm-core/src/jvm/backtype/storm/generated/NimbusSummary.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/NimbusSummary.java b/storm-core/src/jvm/backtype/storm/generated/NimbusSummary.java index 195048a..1d0f3fb 100644 --- a/storm-core/src/jvm/backtype/storm/generated/NimbusSummary.java +++ b/storm-core/src/jvm/backtype/storm/generated/NimbusSummary.java @@ -16,13 +16,24 @@ * limitations under the License. */ /** - * Autogenerated by Thrift Compiler (0.7.0) + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated */ package backtype.storm.generated; -import org.apache.commons.lang.builder.HashCodeBuilder; +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; @@ -35,21 +46,30 @@ 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; -public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, NimbusSummary._Fields>, java.io.Serializable, Cloneable { +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-3-2") +public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, NimbusSummary._Fields>, java.io.Serializable, Cloneable, Comparable<NimbusSummary> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("NimbusSummary"); private static final org.apache.thrift.protocol.TField HOST_FIELD_DESC = new org.apache.thrift.protocol.TField("host", org.apache.thrift.protocol.TType.STRING, (short)1); private static final org.apache.thrift.protocol.TField PORT_FIELD_DESC = new org.apache.thrift.protocol.TField("port", org.apache.thrift.protocol.TType.I32, (short)2); - 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)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)3); private static final org.apache.thrift.protocol.TField IS_LEADER_FIELD_DESC = new org.apache.thrift.protocol.TField("isLeader", org.apache.thrift.protocol.TType.BOOL, (short)4); private static final org.apache.thrift.protocol.TField VERSION_FIELD_DESC = new org.apache.thrift.protocol.TField("version", org.apache.thrift.protocol.TType.STRING, (short)5); + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new NimbusSummaryStandardSchemeFactory()); + schemes.put(TupleScheme.class, new NimbusSummaryTupleSchemeFactory()); + } + private String host; // required private int port; // required - private int uptimeSecs; // required + private int uptime_secs; // required private boolean isLeader; // required private String version; // required @@ -57,7 +77,7 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim public enum _Fields implements org.apache.thrift.TFieldIdEnum { HOST((short)1, "host"), PORT((short)2, "port"), - UPTIME_SECS((short)3, "uptimeSecs"), + UPTIME_SECS((short)3, "uptime_secs"), IS_LEADER((short)4, "isLeader"), VERSION((short)5, "version"); @@ -125,10 +145,9 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim // isset id assignments private static final int __PORT_ISSET_ID = 0; - private static final int __UPTIMESECS_ISSET_ID = 1; + private static final int __UPTIME_SECS_ISSET_ID = 1; private static final int __ISLEADER_ISSET_ID = 2; - private BitSet __isset_bit_vector = new BitSet(3); - + 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); @@ -136,7 +155,7 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); tmpMap.put(_Fields.PORT, new org.apache.thrift.meta_data.FieldMetaData("port", 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("uptimeSecs", org.apache.thrift.TFieldRequirementType.REQUIRED, + 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))); tmpMap.put(_Fields.IS_LEADER, new org.apache.thrift.meta_data.FieldMetaData("isLeader", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL))); @@ -152,7 +171,7 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim public NimbusSummary( String host, int port, - int uptimeSecs, + int uptime_secs, boolean isLeader, String version) { @@ -160,8 +179,8 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim this.host = host; this.port = port; set_port_isSet(true); - this.uptimeSecs = uptimeSecs; - set_uptimeSecs_isSet(true); + this.uptime_secs = uptime_secs; + set_uptime_secs_isSet(true); this.isLeader = isLeader; set_isLeader_isSet(true); this.version = version; @@ -171,13 +190,12 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim * Performs a deep copy on <i>other</i>. */ public NimbusSummary(NimbusSummary other) { - __isset_bit_vector.clear(); - __isset_bit_vector.or(other.__isset_bit_vector); + __isset_bitfield = other.__isset_bitfield; if (other.is_set_host()) { this.host = other.host; } this.port = other.port; - this.uptimeSecs = other.uptimeSecs; + this.uptime_secs = other.uptime_secs; this.isLeader = other.isLeader; if (other.is_set_version()) { this.version = other.version; @@ -193,8 +211,8 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim this.host = null; set_port_isSet(false); this.port = 0; - set_uptimeSecs_isSet(false); - this.uptimeSecs = 0; + set_uptime_secs_isSet(false); + this.uptime_secs = 0; set_isLeader_isSet(false); this.isLeader = false; this.version = null; @@ -233,38 +251,38 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim } public void unset_port() { - __isset_bit_vector.clear(__PORT_ISSET_ID); + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __PORT_ISSET_ID); } /** Returns true if field port is set (has been assigned a value) and false otherwise */ public boolean is_set_port() { - return __isset_bit_vector.get(__PORT_ISSET_ID); + return EncodingUtils.testBit(__isset_bitfield, __PORT_ISSET_ID); } public void set_port_isSet(boolean value) { - __isset_bit_vector.set(__PORT_ISSET_ID, value); + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __PORT_ISSET_ID, value); } - public int get_uptimeSecs() { - return this.uptimeSecs; + public int get_uptime_secs() { + return this.uptime_secs; } - public void set_uptimeSecs(int uptimeSecs) { - this.uptimeSecs = uptimeSecs; - set_uptimeSecs_isSet(true); + public void set_uptime_secs(int uptime_secs) { + this.uptime_secs = uptime_secs; + set_uptime_secs_isSet(true); } - public void unset_uptimeSecs() { - __isset_bit_vector.clear(__UPTIMESECS_ISSET_ID); + public void unset_uptime_secs() { + __isset_bitfield = EncodingUtils.clearBit(__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 __isset_bit_vector.get(__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); } - public void set_uptimeSecs_isSet(boolean value) { - __isset_bit_vector.set(__UPTIMESECS_ISSET_ID, value); + public void set_uptime_secs_isSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __UPTIME_SECS_ISSET_ID, value); } public boolean is_isLeader() { @@ -277,16 +295,16 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim } public void unset_isLeader() { - __isset_bit_vector.clear(__ISLEADER_ISSET_ID); + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ISLEADER_ISSET_ID); } /** Returns true if field isLeader is set (has been assigned a value) and false otherwise */ public boolean is_set_isLeader() { - return __isset_bit_vector.get(__ISLEADER_ISSET_ID); + return EncodingUtils.testBit(__isset_bitfield, __ISLEADER_ISSET_ID); } public void set_isLeader_isSet(boolean value) { - __isset_bit_vector.set(__ISLEADER_ISSET_ID, value); + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ISLEADER_ISSET_ID, value); } public String get_version() { @@ -332,9 +350,9 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim case UPTIME_SECS: if (value == null) { - unset_uptimeSecs(); + unset_uptime_secs(); } else { - set_uptimeSecs((Integer)value); + set_uptime_secs((Integer)value); } break; @@ -366,7 +384,7 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim return Integer.valueOf(get_port()); case UPTIME_SECS: - return Integer.valueOf(get_uptimeSecs()); + return Integer.valueOf(get_uptime_secs()); case IS_LEADER: return Boolean.valueOf(is_isLeader()); @@ -390,7 +408,7 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim case PORT: return is_set_port(); case UPTIME_SECS: - return is_set_uptimeSecs(); + return is_set_uptime_secs(); case IS_LEADER: return is_set_isLeader(); case VERSION: @@ -430,12 +448,12 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim return false; } - boolean this_present_uptimeSecs = true; - boolean that_present_uptimeSecs = true; - if (this_present_uptimeSecs || that_present_uptimeSecs) { - if (!(this_present_uptimeSecs && that_present_uptimeSecs)) + 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.uptimeSecs != that.uptimeSecs) + if (this.uptime_secs != that.uptime_secs) return false; } @@ -462,90 +480,90 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim @Override public int hashCode() { - HashCodeBuilder builder = new HashCodeBuilder(); + List<Object> list = new ArrayList<Object>(); boolean present_host = true && (is_set_host()); - builder.append(present_host); + list.add(present_host); if (present_host) - builder.append(host); + list.add(host); boolean present_port = true; - builder.append(present_port); + list.add(present_port); if (present_port) - builder.append(port); + list.add(port); - boolean present_uptimeSecs = true; - builder.append(present_uptimeSecs); - if (present_uptimeSecs) - builder.append(uptimeSecs); + boolean present_uptime_secs = true; + list.add(present_uptime_secs); + if (present_uptime_secs) + list.add(uptime_secs); boolean present_isLeader = true; - builder.append(present_isLeader); + list.add(present_isLeader); if (present_isLeader) - builder.append(isLeader); + list.add(isLeader); boolean present_version = true && (is_set_version()); - builder.append(present_version); + list.add(present_version); if (present_version) - builder.append(version); + list.add(version); - return builder.toHashCode(); + return list.hashCode(); } + @Override public int compareTo(NimbusSummary other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - NimbusSummary typedOther = (NimbusSummary)other; - lastComparison = Boolean.valueOf(is_set_host()).compareTo(typedOther.is_set_host()); + lastComparison = Boolean.valueOf(is_set_host()).compareTo(other.is_set_host()); if (lastComparison != 0) { return lastComparison; } if (is_set_host()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.host, typedOther.host); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.host, other.host); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_port()).compareTo(typedOther.is_set_port()); + lastComparison = Boolean.valueOf(is_set_port()).compareTo(other.is_set_port()); if (lastComparison != 0) { return lastComparison; } if (is_set_port()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.port, typedOther.port); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.port, other.port); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_uptimeSecs()).compareTo(typedOther.is_set_uptimeSecs()); + lastComparison = Boolean.valueOf(is_set_uptime_secs()).compareTo(other.is_set_uptime_secs()); if (lastComparison != 0) { return lastComparison; } - if (is_set_uptimeSecs()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.uptimeSecs, typedOther.uptimeSecs); + if (is_set_uptime_secs()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.uptime_secs, other.uptime_secs); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_isLeader()).compareTo(typedOther.is_set_isLeader()); + lastComparison = Boolean.valueOf(is_set_isLeader()).compareTo(other.is_set_isLeader()); if (lastComparison != 0) { return lastComparison; } if (is_set_isLeader()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.isLeader, typedOther.isLeader); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.isLeader, other.isLeader); if (lastComparison != 0) { return lastComparison; } } - lastComparison = Boolean.valueOf(is_set_version()).compareTo(typedOther.is_set_version()); + lastComparison = Boolean.valueOf(is_set_version()).compareTo(other.is_set_version()); if (lastComparison != 0) { return lastComparison; } if (is_set_version()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.version, typedOther.version); + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.version, other.version); if (lastComparison != 0) { return lastComparison; } @@ -558,87 +576,11 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim } public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - org.apache.thrift.protocol.TField field; - iprot.readStructBegin(); - while (true) - { - field = iprot.readFieldBegin(); - if (field.type == org.apache.thrift.protocol.TType.STOP) { - break; - } - switch (field.id) { - case 1: // HOST - if (field.type == org.apache.thrift.protocol.TType.STRING) { - this.host = iprot.readString(); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type); - } - break; - case 2: // PORT - if (field.type == org.apache.thrift.protocol.TType.I32) { - this.port = iprot.readI32(); - set_port_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type); - } - break; - case 3: // UPTIME_SECS - if (field.type == org.apache.thrift.protocol.TType.I32) { - this.uptimeSecs = iprot.readI32(); - set_uptimeSecs_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type); - } - break; - case 4: // IS_LEADER - if (field.type == org.apache.thrift.protocol.TType.BOOL) { - this.isLeader = iprot.readBool(); - set_isLeader_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type); - } - break; - case 5: // VERSION - if (field.type == org.apache.thrift.protocol.TType.STRING) { - this.version = iprot.readString(); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type); - } - break; - default: - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type); - } - iprot.readFieldEnd(); - } - iprot.readStructEnd(); - validate(); + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (this.host != null) { - oprot.writeFieldBegin(HOST_FIELD_DESC); - oprot.writeString(this.host); - oprot.writeFieldEnd(); - } - oprot.writeFieldBegin(PORT_FIELD_DESC); - oprot.writeI32(this.port); - oprot.writeFieldEnd(); - oprot.writeFieldBegin(UPTIME_SECS_FIELD_DESC); - oprot.writeI32(this.uptimeSecs); - oprot.writeFieldEnd(); - oprot.writeFieldBegin(IS_LEADER_FIELD_DESC); - oprot.writeBool(this.isLeader); - oprot.writeFieldEnd(); - if (this.version != null) { - oprot.writeFieldBegin(VERSION_FIELD_DESC); - oprot.writeString(this.version); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @Override @@ -658,8 +600,8 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim sb.append(this.port); first = false; if (!first) sb.append(", "); - sb.append("uptimeSecs:"); - sb.append(this.uptimeSecs); + sb.append("uptime_secs:"); + sb.append(this.uptime_secs); first = false; if (!first) sb.append(", "); sb.append("isLeader:"); @@ -687,8 +629,8 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim throw new org.apache.thrift.protocol.TProtocolException("Required field 'port' is unset! Struct:" + toString()); } - if (!is_set_uptimeSecs()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'uptimeSecs' 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_isLeader()) { @@ -699,6 +641,7 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim throw new org.apache.thrift.protocol.TProtocolException("Required field 'version' is unset! Struct:" + toString()); } + // check for sub-struct validity } private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { @@ -712,12 +655,142 @@ public class NimbusSummary implements org.apache.thrift.TBase<NimbusSummary, Nim 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_bit_vector = new BitSet(1); + __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 NimbusSummaryStandardSchemeFactory implements SchemeFactory { + public NimbusSummaryStandardScheme getScheme() { + return new NimbusSummaryStandardScheme(); + } + } + + private static class NimbusSummaryStandardScheme extends StandardScheme<NimbusSummary> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, NimbusSummary 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: // HOST + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.host = iprot.readString(); + struct.set_host_isSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // PORT + if (schemeField.type == org.apache.thrift.protocol.TType.I32) { + struct.port = iprot.readI32(); + struct.set_port_isSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // 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; + case 4: // IS_LEADER + if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) { + struct.isLeader = iprot.readBool(); + struct.set_isLeader_isSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 5: // VERSION + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.version = iprot.readString(); + struct.set_version_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, NimbusSummary struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.host != null) { + oprot.writeFieldBegin(HOST_FIELD_DESC); + oprot.writeString(struct.host); + oprot.writeFieldEnd(); + } + oprot.writeFieldBegin(PORT_FIELD_DESC); + oprot.writeI32(struct.port); + oprot.writeFieldEnd(); + oprot.writeFieldBegin(UPTIME_SECS_FIELD_DESC); + oprot.writeI32(struct.uptime_secs); + oprot.writeFieldEnd(); + oprot.writeFieldBegin(IS_LEADER_FIELD_DESC); + oprot.writeBool(struct.isLeader); + oprot.writeFieldEnd(); + if (struct.version != null) { + oprot.writeFieldBegin(VERSION_FIELD_DESC); + oprot.writeString(struct.version); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class NimbusSummaryTupleSchemeFactory implements SchemeFactory { + public NimbusSummaryTupleScheme getScheme() { + return new NimbusSummaryTupleScheme(); + } + } + + private static class NimbusSummaryTupleScheme extends TupleScheme<NimbusSummary> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, NimbusSummary struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + oprot.writeString(struct.host); + oprot.writeI32(struct.port); + oprot.writeI32(struct.uptime_secs); + oprot.writeBool(struct.isLeader); + oprot.writeString(struct.version); + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, NimbusSummary struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + struct.host = iprot.readString(); + struct.set_host_isSet(true); + struct.port = iprot.readI32(); + struct.set_port_isSet(true); + struct.uptime_secs = iprot.readI32(); + struct.set_uptime_secs_isSet(true); + struct.isLeader = iprot.readBool(); + struct.set_isLeader_isSet(true); + struct.version = iprot.readString(); + struct.set_version_isSet(true); + } + } + }
