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