http://git-wip-us.apache.org/repos/asf/storm/blob/7eaf0651/jstorm-core/src/main/java/backtype/storm/generated/TaskHeartbeat.java ---------------------------------------------------------------------- diff --git a/jstorm-core/src/main/java/backtype/storm/generated/TaskHeartbeat.java b/jstorm-core/src/main/java/backtype/storm/generated/TaskHeartbeat.java new file mode 100644 index 0000000..6afb70a --- /dev/null +++ b/jstorm-core/src/main/java/backtype/storm/generated/TaskHeartbeat.java @@ -0,0 +1,482 @@ +/** + * 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.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.2)", date = "2015-10-20") +public class TaskHeartbeat implements org.apache.thrift.TBase<TaskHeartbeat, TaskHeartbeat._Fields>, java.io.Serializable, Cloneable, Comparable<TaskHeartbeat> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TaskHeartbeat"); + + private static final org.apache.thrift.protocol.TField TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("time", org.apache.thrift.protocol.TType.I32, (short)1); + private static final org.apache.thrift.protocol.TField UPTIME_FIELD_DESC = new org.apache.thrift.protocol.TField("uptime", org.apache.thrift.protocol.TType.I32, (short)2); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new TaskHeartbeatStandardSchemeFactory()); + schemes.put(TupleScheme.class, new TaskHeartbeatTupleSchemeFactory()); + } + + private int time; // required + private int uptime; // 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 { + TIME((short)1, "time"), + UPTIME((short)2, "uptime"); + + 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: // TIME + return TIME; + case 2: // UPTIME + return UPTIME; + 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_ISSET_ID = 0; + private static final int __UPTIME_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.TIME, new org.apache.thrift.meta_data.FieldMetaData("time", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); + tmpMap.put(_Fields.UPTIME, new org.apache.thrift.meta_data.FieldMetaData("uptime", 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(TaskHeartbeat.class, metaDataMap); + } + + public TaskHeartbeat() { + } + + public TaskHeartbeat( + int time, + int uptime) + { + this(); + this.time = time; + set_time_isSet(true); + this.uptime = uptime; + set_uptime_isSet(true); + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public TaskHeartbeat(TaskHeartbeat other) { + __isset_bitfield = other.__isset_bitfield; + this.time = other.time; + this.uptime = other.uptime; + } + + public TaskHeartbeat deepCopy() { + return new TaskHeartbeat(this); + } + + @Override + public void clear() { + set_time_isSet(false); + this.time = 0; + set_uptime_isSet(false); + this.uptime = 0; + } + + public int get_time() { + return this.time; + } + + public void set_time(int time) { + this.time = time; + set_time_isSet(true); + } + + public void unset_time() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TIME_ISSET_ID); + } + + /** Returns true if field time is set (has been assigned a value) and false otherwise */ + public boolean is_set_time() { + return EncodingUtils.testBit(__isset_bitfield, __TIME_ISSET_ID); + } + + public void set_time_isSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TIME_ISSET_ID, value); + } + + public int get_uptime() { + return this.uptime; + } + + public void set_uptime(int uptime) { + this.uptime = uptime; + set_uptime_isSet(true); + } + + public void unset_uptime() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __UPTIME_ISSET_ID); + } + + /** Returns true if field uptime is set (has been assigned a value) and false otherwise */ + public boolean is_set_uptime() { + return EncodingUtils.testBit(__isset_bitfield, __UPTIME_ISSET_ID); + } + + public void set_uptime_isSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __UPTIME_ISSET_ID, value); + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case TIME: + if (value == null) { + unset_time(); + } else { + set_time((Integer)value); + } + break; + + case UPTIME: + if (value == null) { + unset_uptime(); + } else { + set_uptime((Integer)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case TIME: + return Integer.valueOf(get_time()); + + case UPTIME: + return Integer.valueOf(get_uptime()); + + } + 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 TIME: + return is_set_time(); + case UPTIME: + return is_set_uptime(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof TaskHeartbeat) + return this.equals((TaskHeartbeat)that); + return false; + } + + public boolean equals(TaskHeartbeat that) { + if (that == null) + return false; + + boolean this_present_time = true; + boolean that_present_time = true; + if (this_present_time || that_present_time) { + if (!(this_present_time && that_present_time)) + return false; + if (this.time != that.time) + return false; + } + + boolean this_present_uptime = true; + boolean that_present_uptime = true; + if (this_present_uptime || that_present_uptime) { + if (!(this_present_uptime && that_present_uptime)) + return false; + if (this.uptime != that.uptime) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_time = true; + list.add(present_time); + if (present_time) + list.add(time); + + boolean present_uptime = true; + list.add(present_uptime); + if (present_uptime) + list.add(uptime); + + return list.hashCode(); + } + + @Override + public int compareTo(TaskHeartbeat other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(is_set_time()).compareTo(other.is_set_time()); + if (lastComparison != 0) { + return lastComparison; + } + if (is_set_time()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.time, other.time); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(is_set_uptime()).compareTo(other.is_set_uptime()); + if (lastComparison != 0) { + return lastComparison; + } + if (is_set_uptime()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.uptime, other.uptime); + 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 TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("TaskHeartbeat("); + boolean first = true; + + sb.append("time:"); + sb.append(this.time); + first = false; + if (!first) sb.append(", "); + sb.append("uptime:"); + sb.append(this.uptime); + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws TException { + // check for required fields + if (!is_set_time()) { + throw new TProtocolException("Required field 'time' is unset! Struct:" + toString()); + } + + if (!is_set_uptime()) { + throw new TProtocolException("Required field 'uptime' 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 (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 (TException te) { + throw new java.io.IOException(te); + } + } + + private static class TaskHeartbeatStandardSchemeFactory implements SchemeFactory { + public TaskHeartbeatStandardScheme getScheme() { + return new TaskHeartbeatStandardScheme(); + } + } + + private static class TaskHeartbeatStandardScheme extends StandardScheme<TaskHeartbeat> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, TaskHeartbeat struct) throws 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: // TIME + if (schemeField.type == org.apache.thrift.protocol.TType.I32) { + struct.time = iprot.readI32(); + struct.set_time_isSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // UPTIME + if (schemeField.type == org.apache.thrift.protocol.TType.I32) { + struct.uptime = iprot.readI32(); + struct.set_uptime_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, TaskHeartbeat struct) throws TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + oprot.writeFieldBegin(TIME_FIELD_DESC); + oprot.writeI32(struct.time); + oprot.writeFieldEnd(); + oprot.writeFieldBegin(UPTIME_FIELD_DESC); + oprot.writeI32(struct.uptime); + oprot.writeFieldEnd(); + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class TaskHeartbeatTupleSchemeFactory implements SchemeFactory { + public TaskHeartbeatTupleScheme getScheme() { + return new TaskHeartbeatTupleScheme(); + } + } + + private static class TaskHeartbeatTupleScheme extends TupleScheme<TaskHeartbeat> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, TaskHeartbeat struct) throws TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + oprot.writeI32(struct.time); + oprot.writeI32(struct.uptime); + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, TaskHeartbeat struct) throws TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + struct.time = iprot.readI32(); + struct.set_time_isSet(true); + struct.uptime = iprot.readI32(); + struct.set_uptime_isSet(true); + } + } + +} +
http://git-wip-us.apache.org/repos/asf/storm/blob/7eaf0651/jstorm-core/src/main/java/backtype/storm/generated/TaskSummary.java ---------------------------------------------------------------------- diff --git a/jstorm-core/src/main/java/backtype/storm/generated/TaskSummary.java b/jstorm-core/src/main/java/backtype/storm/generated/TaskSummary.java index 9abf197..fa2765c 100644 --- a/jstorm-core/src/main/java/backtype/storm/generated/TaskSummary.java +++ b/jstorm-core/src/main/java/backtype/storm/generated/TaskSummary.java @@ -34,11 +34,11 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-27") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-20") public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSummary._Fields>, java.io.Serializable, Cloneable, Comparable<TaskSummary> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TaskSummary"); - private static final org.apache.thrift.protocol.TField TASK_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("task_id", org.apache.thrift.protocol.TType.I32, (short)1); + private static final org.apache.thrift.protocol.TField TASK_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("taskId", org.apache.thrift.protocol.TType.I32, (short)1); private static final org.apache.thrift.protocol.TField UPTIME_FIELD_DESC = new org.apache.thrift.protocol.TField("uptime", org.apache.thrift.protocol.TType.I32, (short)2); private static final org.apache.thrift.protocol.TField STATUS_FIELD_DESC = new org.apache.thrift.protocol.TField("status", org.apache.thrift.protocol.TType.STRING, (short)3); private static final org.apache.thrift.protocol.TField HOST_FIELD_DESC = new org.apache.thrift.protocol.TField("host", org.apache.thrift.protocol.TType.STRING, (short)4); @@ -51,7 +51,7 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum schemes.put(TupleScheme.class, new TaskSummaryTupleSchemeFactory()); } - private int task_id; // required + private int taskId; // required private int uptime; // required private String status; // required private String host; // required @@ -60,7 +60,7 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { - TASK_ID((short)1, "task_id"), + TASK_ID((short)1, "taskId"), UPTIME((short)2, "uptime"), STATUS((short)3, "status"), HOST((short)4, "host"), @@ -132,7 +132,7 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum } // isset id assignments - private static final int __TASK_ID_ISSET_ID = 0; + private static final int __TASKID_ISSET_ID = 0; private static final int __UPTIME_ISSET_ID = 1; private static final int __PORT_ISSET_ID = 2; private byte __isset_bitfield = 0; @@ -140,7 +140,7 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum 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.TASK_ID, new org.apache.thrift.meta_data.FieldMetaData("task_id", org.apache.thrift.TFieldRequirementType.REQUIRED, + tmpMap.put(_Fields.TASK_ID, new org.apache.thrift.meta_data.FieldMetaData("taskId", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); tmpMap.put(_Fields.UPTIME, new org.apache.thrift.meta_data.FieldMetaData("uptime", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); @@ -161,15 +161,15 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum } public TaskSummary( - int task_id, + int taskId, int uptime, String status, String host, int port) { this(); - this.task_id = task_id; - set_task_id_isSet(true); + this.taskId = taskId; + set_taskId_isSet(true); this.uptime = uptime; set_uptime_isSet(true); this.status = status; @@ -183,7 +183,7 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum */ public TaskSummary(TaskSummary other) { __isset_bitfield = other.__isset_bitfield; - this.task_id = other.task_id; + this.taskId = other.taskId; this.uptime = other.uptime; if (other.is_set_status()) { this.status = other.status; @@ -207,8 +207,8 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum @Override public void clear() { - set_task_id_isSet(false); - this.task_id = 0; + set_taskId_isSet(false); + this.taskId = 0; set_uptime_isSet(false); this.uptime = 0; this.status = null; @@ -218,26 +218,26 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum this.errors = null; } - public int get_task_id() { - return this.task_id; + public int get_taskId() { + return this.taskId; } - public void set_task_id(int task_id) { - this.task_id = task_id; - set_task_id_isSet(true); + public void set_taskId(int taskId) { + this.taskId = taskId; + set_taskId_isSet(true); } - public void unset_task_id() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TASK_ID_ISSET_ID); + public void unset_taskId() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TASKID_ISSET_ID); } - /** Returns true if field task_id is set (has been assigned a value) and false otherwise */ - public boolean is_set_task_id() { - return EncodingUtils.testBit(__isset_bitfield, __TASK_ID_ISSET_ID); + /** Returns true if field taskId is set (has been assigned a value) and false otherwise */ + public boolean is_set_taskId() { + return EncodingUtils.testBit(__isset_bitfield, __TASKID_ISSET_ID); } - public void set_task_id_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TASK_ID_ISSET_ID, value); + public void set_taskId_isSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TASKID_ISSET_ID, value); } public int get_uptime() { @@ -372,9 +372,9 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum switch (field) { case TASK_ID: if (value == null) { - unset_task_id(); + unset_taskId(); } else { - set_task_id((Integer)value); + set_taskId((Integer)value); } break; @@ -424,7 +424,7 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum public Object getFieldValue(_Fields field) { switch (field) { case TASK_ID: - return Integer.valueOf(get_task_id()); + return Integer.valueOf(get_taskId()); case UPTIME: return Integer.valueOf(get_uptime()); @@ -453,7 +453,7 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum switch (field) { case TASK_ID: - return is_set_task_id(); + return is_set_taskId(); case UPTIME: return is_set_uptime(); case STATUS: @@ -481,12 +481,12 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum if (that == null) return false; - boolean this_present_task_id = true; - boolean that_present_task_id = true; - if (this_present_task_id || that_present_task_id) { - if (!(this_present_task_id && that_present_task_id)) + boolean this_present_taskId = true; + boolean that_present_taskId = true; + if (this_present_taskId || that_present_taskId) { + if (!(this_present_taskId && that_present_taskId)) return false; - if (this.task_id != that.task_id) + if (this.taskId != that.taskId) return false; } @@ -542,10 +542,10 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum public int hashCode() { List<Object> list = new ArrayList<Object>(); - boolean present_task_id = true; - list.add(present_task_id); - if (present_task_id) - list.add(task_id); + boolean present_taskId = true; + list.add(present_taskId); + if (present_taskId) + list.add(taskId); boolean present_uptime = true; list.add(present_uptime); @@ -583,12 +583,12 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum int lastComparison = 0; - lastComparison = Boolean.valueOf(is_set_task_id()).compareTo(other.is_set_task_id()); + lastComparison = Boolean.valueOf(is_set_taskId()).compareTo(other.is_set_taskId()); if (lastComparison != 0) { return lastComparison; } - if (is_set_task_id()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.task_id, other.task_id); + if (is_set_taskId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.taskId, other.taskId); if (lastComparison != 0) { return lastComparison; } @@ -650,11 +650,11 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -663,8 +663,8 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum StringBuilder sb = new StringBuilder("TaskSummary("); boolean first = true; - sb.append("task_id:"); - sb.append(this.task_id); + sb.append("taskId:"); + sb.append(this.taskId); first = false; if (!first) sb.append(", "); sb.append("uptime:"); @@ -704,26 +704,26 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields - if (!is_set_task_id()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'task_id' is unset! Struct:" + toString()); + if (!is_set_taskId()) { + throw new TProtocolException("Required field 'taskId' is unset! Struct:" + toString()); } if (!is_set_uptime()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'uptime' is unset! Struct:" + toString()); + throw new TProtocolException("Required field 'uptime' is unset! Struct:" + toString()); } if (!is_set_status()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'status' is unset! Struct:" + toString()); + throw new TProtocolException("Required field 'status' is unset! Struct:" + toString()); } if (!is_set_host()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'host' is unset! Struct:" + toString()); + throw new TProtocolException("Required field 'host' is unset! Struct:" + toString()); } if (!is_set_port()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'port' is unset! Struct:" + toString()); + throw new TProtocolException("Required field 'port' is unset! Struct:" + toString()); } // check for sub-struct validity @@ -732,7 +732,7 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { try { write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -742,7 +742,7 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. __isset_bitfield = 0; read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -755,7 +755,7 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum private static class TaskSummaryStandardScheme extends StandardScheme<TaskSummary> { - public void read(org.apache.thrift.protocol.TProtocol iprot, TaskSummary struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, TaskSummary struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -767,8 +767,8 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum switch (schemeField.id) { case 1: // TASK_ID if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.task_id = iprot.readI32(); - struct.set_task_id_isSet(true); + struct.taskId = iprot.readI32(); + struct.set_taskId_isSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -808,14 +808,14 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum case 6: // ERRORS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list230 = iprot.readListBegin(); - struct.errors = new ArrayList<ErrorInfo>(_list230.size); - ErrorInfo _elem231; - for (int _i232 = 0; _i232 < _list230.size; ++_i232) + org.apache.thrift.protocol.TList _list178 = iprot.readListBegin(); + struct.errors = new ArrayList<ErrorInfo>(_list178.size); + ErrorInfo _elem179; + for (int _i180 = 0; _i180 < _list178.size; ++_i180) { - _elem231 = new ErrorInfo(); - _elem231.read(iprot); - struct.errors.add(_elem231); + _elem179 = new ErrorInfo(); + _elem179.read(iprot); + struct.errors.add(_elem179); } iprot.readListEnd(); } @@ -833,12 +833,12 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, TaskSummary struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, TaskSummary struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); oprot.writeFieldBegin(TASK_ID_FIELD_DESC); - oprot.writeI32(struct.task_id); + oprot.writeI32(struct.taskId); oprot.writeFieldEnd(); oprot.writeFieldBegin(UPTIME_FIELD_DESC); oprot.writeI32(struct.uptime); @@ -861,9 +861,9 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum oprot.writeFieldBegin(ERRORS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.errors.size())); - for (ErrorInfo _iter233 : struct.errors) + for (ErrorInfo _iter181 : struct.errors) { - _iter233.write(oprot); + _iter181.write(oprot); } oprot.writeListEnd(); } @@ -885,9 +885,9 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum private static class TaskSummaryTupleScheme extends TupleScheme<TaskSummary> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, TaskSummary struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, TaskSummary struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; - oprot.writeI32(struct.task_id); + oprot.writeI32(struct.taskId); oprot.writeI32(struct.uptime); oprot.writeString(struct.status); oprot.writeString(struct.host); @@ -900,19 +900,19 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum if (struct.is_set_errors()) { { oprot.writeI32(struct.errors.size()); - for (ErrorInfo _iter234 : struct.errors) + for (ErrorInfo _iter182 : struct.errors) { - _iter234.write(oprot); + _iter182.write(oprot); } } } } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, TaskSummary struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, TaskSummary struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; - struct.task_id = iprot.readI32(); - struct.set_task_id_isSet(true); + struct.taskId = iprot.readI32(); + struct.set_taskId_isSet(true); struct.uptime = iprot.readI32(); struct.set_uptime_isSet(true); struct.status = iprot.readString(); @@ -924,14 +924,14 @@ public class TaskSummary implements org.apache.thrift.TBase<TaskSummary, TaskSum BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list235 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.errors = new ArrayList<ErrorInfo>(_list235.size); - ErrorInfo _elem236; - for (int _i237 = 0; _i237 < _list235.size; ++_i237) + org.apache.thrift.protocol.TList _list183 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.errors = new ArrayList<ErrorInfo>(_list183.size); + ErrorInfo _elem184; + for (int _i185 = 0; _i185 < _list183.size; ++_i185) { - _elem236 = new ErrorInfo(); - _elem236.read(iprot); - struct.errors.add(_elem236); + _elem184 = new ErrorInfo(); + _elem184.read(iprot); + struct.errors.add(_elem184); } } struct.set_errors_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/7eaf0651/jstorm-core/src/main/java/backtype/storm/generated/ThriftSerializedObject.java ---------------------------------------------------------------------- diff --git a/jstorm-core/src/main/java/backtype/storm/generated/ThriftSerializedObject.java b/jstorm-core/src/main/java/backtype/storm/generated/ThriftSerializedObject.java index a753d7f..f3156e7 100644 --- a/jstorm-core/src/main/java/backtype/storm/generated/ThriftSerializedObject.java +++ b/jstorm-core/src/main/java/backtype/storm/generated/ThriftSerializedObject.java @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-27") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-20") public class ThriftSerializedObject implements org.apache.thrift.TBase<ThriftSerializedObject, ThriftSerializedObject._Fields>, java.io.Serializable, Cloneable, Comparable<ThriftSerializedObject> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ThriftSerializedObject"); @@ -346,11 +346,11 @@ public class ThriftSerializedObject implements org.apache.thrift.TBase<ThriftSer return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -378,14 +378,14 @@ public class ThriftSerializedObject implements org.apache.thrift.TBase<ThriftSer return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields if (!is_set_name()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'name' is unset! Struct:" + toString()); + throw new TProtocolException("Required field 'name' is unset! Struct:" + toString()); } if (!is_set_bits()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'bits' is unset! Struct:" + toString()); + throw new TProtocolException("Required field 'bits' is unset! Struct:" + toString()); } // check for sub-struct validity @@ -394,7 +394,7 @@ public class ThriftSerializedObject implements org.apache.thrift.TBase<ThriftSer private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { try { write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -402,7 +402,7 @@ public class ThriftSerializedObject implements org.apache.thrift.TBase<ThriftSer private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { try { read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -415,7 +415,7 @@ public class ThriftSerializedObject implements org.apache.thrift.TBase<ThriftSer private static class ThriftSerializedObjectStandardScheme extends StandardScheme<ThriftSerializedObject> { - public void read(org.apache.thrift.protocol.TProtocol iprot, ThriftSerializedObject struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, ThriftSerializedObject struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -450,7 +450,7 @@ public class ThriftSerializedObject implements org.apache.thrift.TBase<ThriftSer struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, ThriftSerializedObject struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, ThriftSerializedObject struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -479,14 +479,14 @@ public class ThriftSerializedObject implements org.apache.thrift.TBase<ThriftSer private static class ThriftSerializedObjectTupleScheme extends TupleScheme<ThriftSerializedObject> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, ThriftSerializedObject struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, ThriftSerializedObject struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; oprot.writeString(struct.name); oprot.writeBinary(struct.bits); } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, ThriftSerializedObject struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, ThriftSerializedObject struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; struct.name = iprot.readString(); struct.set_name_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/7eaf0651/jstorm-core/src/main/java/backtype/storm/generated/TopologyAssignException.java ---------------------------------------------------------------------- diff --git a/jstorm-core/src/main/java/backtype/storm/generated/TopologyAssignException.java b/jstorm-core/src/main/java/backtype/storm/generated/TopologyAssignException.java index 8c95876..13887cc 100644 --- a/jstorm-core/src/main/java/backtype/storm/generated/TopologyAssignException.java +++ b/jstorm-core/src/main/java/backtype/storm/generated/TopologyAssignException.java @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-27") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-20") public class TopologyAssignException extends TException implements org.apache.thrift.TBase<TopologyAssignException, TopologyAssignException._Fields>, java.io.Serializable, Cloneable, Comparable<TopologyAssignException> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TopologyAssignException"); @@ -264,11 +264,11 @@ public class TopologyAssignException extends TException implements org.apache.th return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -288,10 +288,10 @@ public class TopologyAssignException extends TException implements org.apache.th return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields if (!is_set_msg()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'msg' is unset! Struct:" + toString()); + throw new TProtocolException("Required field 'msg' is unset! Struct:" + toString()); } // check for sub-struct validity @@ -300,7 +300,7 @@ public class TopologyAssignException extends TException implements org.apache.th private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { try { write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -308,7 +308,7 @@ public class TopologyAssignException extends TException implements org.apache.th private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { try { read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -321,7 +321,7 @@ public class TopologyAssignException extends TException implements org.apache.th private static class TopologyAssignExceptionStandardScheme extends StandardScheme<TopologyAssignException> { - public void read(org.apache.thrift.protocol.TProtocol iprot, TopologyAssignException struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, TopologyAssignException struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -348,7 +348,7 @@ public class TopologyAssignException extends TException implements org.apache.th struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, TopologyAssignException struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, TopologyAssignException struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -372,13 +372,13 @@ public class TopologyAssignException extends TException implements org.apache.th private static class TopologyAssignExceptionTupleScheme extends TupleScheme<TopologyAssignException> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, TopologyAssignException struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, TopologyAssignException struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; oprot.writeString(struct.msg); } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, TopologyAssignException struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, TopologyAssignException struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; struct.msg = iprot.readString(); struct.set_msg_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/7eaf0651/jstorm-core/src/main/java/backtype/storm/generated/TopologyInfo.java ---------------------------------------------------------------------- diff --git a/jstorm-core/src/main/java/backtype/storm/generated/TopologyInfo.java b/jstorm-core/src/main/java/backtype/storm/generated/TopologyInfo.java index 1da8e98..4b4793d 100644 --- a/jstorm-core/src/main/java/backtype/storm/generated/TopologyInfo.java +++ b/jstorm-core/src/main/java/backtype/storm/generated/TopologyInfo.java @@ -34,7 +34,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-27") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-20") public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, TopologyInfo._Fields>, java.io.Serializable, Cloneable, Comparable<TopologyInfo> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TopologyInfo"); @@ -523,11 +523,11 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -571,22 +571,22 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields if (!is_set_topology()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'topology' is unset! Struct:" + toString()); + throw new TProtocolException("Required field 'topology' is unset! Struct:" + toString()); } if (!is_set_components()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'components' is unset! Struct:" + toString()); + throw new TProtocolException("Required field 'components' is unset! Struct:" + toString()); } if (!is_set_tasks()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'tasks' is unset! Struct:" + toString()); + throw new TProtocolException("Required field 'tasks' is unset! Struct:" + toString()); } if (!is_set_metrics()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'metrics' is unset! Struct:" + toString()); + throw new TProtocolException("Required field 'metrics' is unset! Struct:" + toString()); } // check for sub-struct validity @@ -601,7 +601,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { try { write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -609,7 +609,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { try { read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -622,7 +622,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol private static class TopologyInfoStandardScheme extends StandardScheme<TopologyInfo> { - public void read(org.apache.thrift.protocol.TProtocol iprot, TopologyInfo struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, TopologyInfo struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -644,14 +644,14 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol case 2: // COMPONENTS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list238 = iprot.readListBegin(); - struct.components = new ArrayList<ComponentSummary>(_list238.size); - ComponentSummary _elem239; - for (int _i240 = 0; _i240 < _list238.size; ++_i240) + org.apache.thrift.protocol.TList _list186 = iprot.readListBegin(); + struct.components = new ArrayList<ComponentSummary>(_list186.size); + ComponentSummary _elem187; + for (int _i188 = 0; _i188 < _list186.size; ++_i188) { - _elem239 = new ComponentSummary(); - _elem239.read(iprot); - struct.components.add(_elem239); + _elem187 = new ComponentSummary(); + _elem187.read(iprot); + struct.components.add(_elem187); } iprot.readListEnd(); } @@ -663,14 +663,14 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol case 3: // TASKS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list241 = iprot.readListBegin(); - struct.tasks = new ArrayList<TaskSummary>(_list241.size); - TaskSummary _elem242; - for (int _i243 = 0; _i243 < _list241.size; ++_i243) + org.apache.thrift.protocol.TList _list189 = iprot.readListBegin(); + struct.tasks = new ArrayList<TaskSummary>(_list189.size); + TaskSummary _elem190; + for (int _i191 = 0; _i191 < _list189.size; ++_i191) { - _elem242 = new TaskSummary(); - _elem242.read(iprot); - struct.tasks.add(_elem242); + _elem190 = new TaskSummary(); + _elem190.read(iprot); + struct.tasks.add(_elem190); } iprot.readListEnd(); } @@ -697,7 +697,7 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, TopologyInfo struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, TopologyInfo struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -710,9 +710,9 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol oprot.writeFieldBegin(COMPONENTS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.components.size())); - for (ComponentSummary _iter244 : struct.components) + for (ComponentSummary _iter192 : struct.components) { - _iter244.write(oprot); + _iter192.write(oprot); } oprot.writeListEnd(); } @@ -722,9 +722,9 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol oprot.writeFieldBegin(TASKS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.tasks.size())); - for (TaskSummary _iter245 : struct.tasks) + for (TaskSummary _iter193 : struct.tasks) { - _iter245.write(oprot); + _iter193.write(oprot); } oprot.writeListEnd(); } @@ -750,53 +750,53 @@ public class TopologyInfo implements org.apache.thrift.TBase<TopologyInfo, Topol private static class TopologyInfoTupleScheme extends TupleScheme<TopologyInfo> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, TopologyInfo struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, TopologyInfo struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; struct.topology.write(oprot); { oprot.writeI32(struct.components.size()); - for (ComponentSummary _iter246 : struct.components) + for (ComponentSummary _iter194 : struct.components) { - _iter246.write(oprot); + _iter194.write(oprot); } } { oprot.writeI32(struct.tasks.size()); - for (TaskSummary _iter247 : struct.tasks) + for (TaskSummary _iter195 : struct.tasks) { - _iter247.write(oprot); + _iter195.write(oprot); } } struct.metrics.write(oprot); } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, TopologyInfo struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, TopologyInfo struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; struct.topology = new TopologySummary(); struct.topology.read(iprot); struct.set_topology_isSet(true); { - org.apache.thrift.protocol.TList _list248 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.components = new ArrayList<ComponentSummary>(_list248.size); - ComponentSummary _elem249; - for (int _i250 = 0; _i250 < _list248.size; ++_i250) + org.apache.thrift.protocol.TList _list196 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.components = new ArrayList<ComponentSummary>(_list196.size); + ComponentSummary _elem197; + for (int _i198 = 0; _i198 < _list196.size; ++_i198) { - _elem249 = new ComponentSummary(); - _elem249.read(iprot); - struct.components.add(_elem249); + _elem197 = new ComponentSummary(); + _elem197.read(iprot); + struct.components.add(_elem197); } } struct.set_components_isSet(true); { - org.apache.thrift.protocol.TList _list251 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.tasks = new ArrayList<TaskSummary>(_list251.size); - TaskSummary _elem252; - for (int _i253 = 0; _i253 < _list251.size; ++_i253) + org.apache.thrift.protocol.TList _list199 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.tasks = new ArrayList<TaskSummary>(_list199.size); + TaskSummary _elem200; + for (int _i201 = 0; _i201 < _list199.size; ++_i201) { - _elem252 = new TaskSummary(); - _elem252.read(iprot); - struct.tasks.add(_elem252); + _elem200 = new TaskSummary(); + _elem200.read(iprot); + struct.tasks.add(_elem200); } } struct.set_tasks_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/7eaf0651/jstorm-core/src/main/java/backtype/storm/generated/TopologyInitialStatus.java ---------------------------------------------------------------------- diff --git a/jstorm-core/src/main/java/backtype/storm/generated/TopologyInitialStatus.java b/jstorm-core/src/main/java/backtype/storm/generated/TopologyInitialStatus.java index 0d87ee1..8930060 100755 --- a/jstorm-core/src/main/java/backtype/storm/generated/TopologyInitialStatus.java +++ b/jstorm-core/src/main/java/backtype/storm/generated/TopologyInitialStatus.java @@ -11,7 +11,7 @@ import java.util.Map; import java.util.HashMap; import org.apache.thrift.TEnum; -public enum TopologyInitialStatus implements org.apache.thrift.TEnum { +public enum TopologyInitialStatus implements TEnum { ACTIVE(1), INACTIVE(2);
