You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2017/04/06 17:33:24 UTC
[35/52] [partial] storm git commit: STORM-2441 Break down
'storm-core' to extract client (worker) artifacts
http://git-wip-us.apache.org/repos/asf/storm/blob/4de339a8/storm-client/src/jvm/org/apache/storm/generated/BoltStats.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/generated/BoltStats.java b/storm-client/src/jvm/org/apache/storm/generated/BoltStats.java
new file mode 100644
index 0000000..cd5a497
--- /dev/null
+++ b/storm-client/src/jvm/org/apache/storm/generated/BoltStats.java
@@ -0,0 +1,1390 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.storm.generated;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+public class BoltStats implements org.apache.thrift.TBase<BoltStats, BoltStats._Fields>, java.io.Serializable, Cloneable, Comparable<BoltStats> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("BoltStats");
+
+ private static final org.apache.thrift.protocol.TField ACKED_FIELD_DESC = new org.apache.thrift.protocol.TField("acked", org.apache.thrift.protocol.TType.MAP, (short)1);
+ private static final org.apache.thrift.protocol.TField FAILED_FIELD_DESC = new org.apache.thrift.protocol.TField("failed", org.apache.thrift.protocol.TType.MAP, (short)2);
+ private static final org.apache.thrift.protocol.TField PROCESS_MS_AVG_FIELD_DESC = new org.apache.thrift.protocol.TField("process_ms_avg", org.apache.thrift.protocol.TType.MAP, (short)3);
+ private static final org.apache.thrift.protocol.TField EXECUTED_FIELD_DESC = new org.apache.thrift.protocol.TField("executed", org.apache.thrift.protocol.TType.MAP, (short)4);
+ private static final org.apache.thrift.protocol.TField EXECUTE_MS_AVG_FIELD_DESC = new org.apache.thrift.protocol.TField("execute_ms_avg", org.apache.thrift.protocol.TType.MAP, (short)5);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new BoltStatsStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new BoltStatsTupleSchemeFactory());
+ }
+
+ private Map<String,Map<GlobalStreamId,Long>> acked; // required
+ private Map<String,Map<GlobalStreamId,Long>> failed; // required
+ private Map<String,Map<GlobalStreamId,Double>> process_ms_avg; // required
+ private Map<String,Map<GlobalStreamId,Long>> executed; // required
+ private Map<String,Map<GlobalStreamId,Double>> execute_ms_avg; // 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 {
+ ACKED((short)1, "acked"),
+ FAILED((short)2, "failed"),
+ PROCESS_MS_AVG((short)3, "process_ms_avg"),
+ EXECUTED((short)4, "executed"),
+ EXECUTE_MS_AVG((short)5, "execute_ms_avg");
+
+ 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: // ACKED
+ return ACKED;
+ case 2: // FAILED
+ return FAILED;
+ case 3: // PROCESS_MS_AVG
+ return PROCESS_MS_AVG;
+ case 4: // EXECUTED
+ return EXECUTED;
+ case 5: // EXECUTE_MS_AVG
+ return EXECUTE_MS_AVG;
+ 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
+ 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.ACKED, new org.apache.thrift.meta_data.FieldMetaData("acked", 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.MapMetaData(org.apache.thrift.protocol.TType.MAP,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, GlobalStreamId.class),
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)))));
+ tmpMap.put(_Fields.FAILED, new org.apache.thrift.meta_data.FieldMetaData("failed", org.apache.thrift.TFieldRequirementType.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.MapMetaData(org.apache.thrift.protocol.TType.MAP,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, GlobalStreamId.class),
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)))));
+ tmpMap.put(_Fields.PROCESS_MS_AVG, new org.apache.thrift.meta_data.FieldMetaData("process_ms_avg", 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.MapMetaData(org.apache.thrift.protocol.TType.MAP,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, GlobalStreamId.class),
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)))));
+ tmpMap.put(_Fields.EXECUTED, new org.apache.thrift.meta_data.FieldMetaData("executed", 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.MapMetaData(org.apache.thrift.protocol.TType.MAP,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, GlobalStreamId.class),
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)))));
+ tmpMap.put(_Fields.EXECUTE_MS_AVG, new org.apache.thrift.meta_data.FieldMetaData("execute_ms_avg", 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.MapMetaData(org.apache.thrift.protocol.TType.MAP,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, GlobalStreamId.class),
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(BoltStats.class, metaDataMap);
+ }
+
+ public BoltStats() {
+ }
+
+ public BoltStats(
+ Map<String,Map<GlobalStreamId,Long>> acked,
+ Map<String,Map<GlobalStreamId,Long>> failed,
+ Map<String,Map<GlobalStreamId,Double>> process_ms_avg,
+ Map<String,Map<GlobalStreamId,Long>> executed,
+ Map<String,Map<GlobalStreamId,Double>> execute_ms_avg)
+ {
+ this();
+ this.acked = acked;
+ this.failed = failed;
+ this.process_ms_avg = process_ms_avg;
+ this.executed = executed;
+ this.execute_ms_avg = execute_ms_avg;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public BoltStats(BoltStats other) {
+ if (other.is_set_acked()) {
+ Map<String,Map<GlobalStreamId,Long>> __this__acked = new HashMap<String,Map<GlobalStreamId,Long>>(other.acked.size());
+ for (Map.Entry<String, Map<GlobalStreamId,Long>> other_element : other.acked.entrySet()) {
+
+ String other_element_key = other_element.getKey();
+ Map<GlobalStreamId,Long> other_element_value = other_element.getValue();
+
+ String __this__acked_copy_key = other_element_key;
+
+ Map<GlobalStreamId,Long> __this__acked_copy_value = new HashMap<GlobalStreamId,Long>(other_element_value.size());
+ for (Map.Entry<GlobalStreamId, Long> other_element_value_element : other_element_value.entrySet()) {
+
+ GlobalStreamId other_element_value_element_key = other_element_value_element.getKey();
+ Long other_element_value_element_value = other_element_value_element.getValue();
+
+ GlobalStreamId __this__acked_copy_value_copy_key = new GlobalStreamId(other_element_value_element_key);
+
+ Long __this__acked_copy_value_copy_value = other_element_value_element_value;
+
+ __this__acked_copy_value.put(__this__acked_copy_value_copy_key, __this__acked_copy_value_copy_value);
+ }
+
+ __this__acked.put(__this__acked_copy_key, __this__acked_copy_value);
+ }
+ this.acked = __this__acked;
+ }
+ if (other.is_set_failed()) {
+ Map<String,Map<GlobalStreamId,Long>> __this__failed = new HashMap<String,Map<GlobalStreamId,Long>>(other.failed.size());
+ for (Map.Entry<String, Map<GlobalStreamId,Long>> other_element : other.failed.entrySet()) {
+
+ String other_element_key = other_element.getKey();
+ Map<GlobalStreamId,Long> other_element_value = other_element.getValue();
+
+ String __this__failed_copy_key = other_element_key;
+
+ Map<GlobalStreamId,Long> __this__failed_copy_value = new HashMap<GlobalStreamId,Long>(other_element_value.size());
+ for (Map.Entry<GlobalStreamId, Long> other_element_value_element : other_element_value.entrySet()) {
+
+ GlobalStreamId other_element_value_element_key = other_element_value_element.getKey();
+ Long other_element_value_element_value = other_element_value_element.getValue();
+
+ GlobalStreamId __this__failed_copy_value_copy_key = new GlobalStreamId(other_element_value_element_key);
+
+ Long __this__failed_copy_value_copy_value = other_element_value_element_value;
+
+ __this__failed_copy_value.put(__this__failed_copy_value_copy_key, __this__failed_copy_value_copy_value);
+ }
+
+ __this__failed.put(__this__failed_copy_key, __this__failed_copy_value);
+ }
+ this.failed = __this__failed;
+ }
+ if (other.is_set_process_ms_avg()) {
+ Map<String,Map<GlobalStreamId,Double>> __this__process_ms_avg = new HashMap<String,Map<GlobalStreamId,Double>>(other.process_ms_avg.size());
+ for (Map.Entry<String, Map<GlobalStreamId,Double>> other_element : other.process_ms_avg.entrySet()) {
+
+ String other_element_key = other_element.getKey();
+ Map<GlobalStreamId,Double> other_element_value = other_element.getValue();
+
+ String __this__process_ms_avg_copy_key = other_element_key;
+
+ Map<GlobalStreamId,Double> __this__process_ms_avg_copy_value = new HashMap<GlobalStreamId,Double>(other_element_value.size());
+ for (Map.Entry<GlobalStreamId, Double> other_element_value_element : other_element_value.entrySet()) {
+
+ GlobalStreamId other_element_value_element_key = other_element_value_element.getKey();
+ Double other_element_value_element_value = other_element_value_element.getValue();
+
+ GlobalStreamId __this__process_ms_avg_copy_value_copy_key = new GlobalStreamId(other_element_value_element_key);
+
+ Double __this__process_ms_avg_copy_value_copy_value = other_element_value_element_value;
+
+ __this__process_ms_avg_copy_value.put(__this__process_ms_avg_copy_value_copy_key, __this__process_ms_avg_copy_value_copy_value);
+ }
+
+ __this__process_ms_avg.put(__this__process_ms_avg_copy_key, __this__process_ms_avg_copy_value);
+ }
+ this.process_ms_avg = __this__process_ms_avg;
+ }
+ if (other.is_set_executed()) {
+ Map<String,Map<GlobalStreamId,Long>> __this__executed = new HashMap<String,Map<GlobalStreamId,Long>>(other.executed.size());
+ for (Map.Entry<String, Map<GlobalStreamId,Long>> other_element : other.executed.entrySet()) {
+
+ String other_element_key = other_element.getKey();
+ Map<GlobalStreamId,Long> other_element_value = other_element.getValue();
+
+ String __this__executed_copy_key = other_element_key;
+
+ Map<GlobalStreamId,Long> __this__executed_copy_value = new HashMap<GlobalStreamId,Long>(other_element_value.size());
+ for (Map.Entry<GlobalStreamId, Long> other_element_value_element : other_element_value.entrySet()) {
+
+ GlobalStreamId other_element_value_element_key = other_element_value_element.getKey();
+ Long other_element_value_element_value = other_element_value_element.getValue();
+
+ GlobalStreamId __this__executed_copy_value_copy_key = new GlobalStreamId(other_element_value_element_key);
+
+ Long __this__executed_copy_value_copy_value = other_element_value_element_value;
+
+ __this__executed_copy_value.put(__this__executed_copy_value_copy_key, __this__executed_copy_value_copy_value);
+ }
+
+ __this__executed.put(__this__executed_copy_key, __this__executed_copy_value);
+ }
+ this.executed = __this__executed;
+ }
+ if (other.is_set_execute_ms_avg()) {
+ Map<String,Map<GlobalStreamId,Double>> __this__execute_ms_avg = new HashMap<String,Map<GlobalStreamId,Double>>(other.execute_ms_avg.size());
+ for (Map.Entry<String, Map<GlobalStreamId,Double>> other_element : other.execute_ms_avg.entrySet()) {
+
+ String other_element_key = other_element.getKey();
+ Map<GlobalStreamId,Double> other_element_value = other_element.getValue();
+
+ String __this__execute_ms_avg_copy_key = other_element_key;
+
+ Map<GlobalStreamId,Double> __this__execute_ms_avg_copy_value = new HashMap<GlobalStreamId,Double>(other_element_value.size());
+ for (Map.Entry<GlobalStreamId, Double> other_element_value_element : other_element_value.entrySet()) {
+
+ GlobalStreamId other_element_value_element_key = other_element_value_element.getKey();
+ Double other_element_value_element_value = other_element_value_element.getValue();
+
+ GlobalStreamId __this__execute_ms_avg_copy_value_copy_key = new GlobalStreamId(other_element_value_element_key);
+
+ Double __this__execute_ms_avg_copy_value_copy_value = other_element_value_element_value;
+
+ __this__execute_ms_avg_copy_value.put(__this__execute_ms_avg_copy_value_copy_key, __this__execute_ms_avg_copy_value_copy_value);
+ }
+
+ __this__execute_ms_avg.put(__this__execute_ms_avg_copy_key, __this__execute_ms_avg_copy_value);
+ }
+ this.execute_ms_avg = __this__execute_ms_avg;
+ }
+ }
+
+ public BoltStats deepCopy() {
+ return new BoltStats(this);
+ }
+
+ @Override
+ public void clear() {
+ this.acked = null;
+ this.failed = null;
+ this.process_ms_avg = null;
+ this.executed = null;
+ this.execute_ms_avg = null;
+ }
+
+ public int get_acked_size() {
+ return (this.acked == null) ? 0 : this.acked.size();
+ }
+
+ public void put_to_acked(String key, Map<GlobalStreamId,Long> val) {
+ if (this.acked == null) {
+ this.acked = new HashMap<String,Map<GlobalStreamId,Long>>();
+ }
+ this.acked.put(key, val);
+ }
+
+ public Map<String,Map<GlobalStreamId,Long>> get_acked() {
+ return this.acked;
+ }
+
+ public void set_acked(Map<String,Map<GlobalStreamId,Long>> acked) {
+ this.acked = acked;
+ }
+
+ public void unset_acked() {
+ this.acked = null;
+ }
+
+ /** Returns true if field acked is set (has been assigned a value) and false otherwise */
+ public boolean is_set_acked() {
+ return this.acked != null;
+ }
+
+ public void set_acked_isSet(boolean value) {
+ if (!value) {
+ this.acked = null;
+ }
+ }
+
+ public int get_failed_size() {
+ return (this.failed == null) ? 0 : this.failed.size();
+ }
+
+ public void put_to_failed(String key, Map<GlobalStreamId,Long> val) {
+ if (this.failed == null) {
+ this.failed = new HashMap<String,Map<GlobalStreamId,Long>>();
+ }
+ this.failed.put(key, val);
+ }
+
+ public Map<String,Map<GlobalStreamId,Long>> get_failed() {
+ return this.failed;
+ }
+
+ public void set_failed(Map<String,Map<GlobalStreamId,Long>> failed) {
+ this.failed = failed;
+ }
+
+ public void unset_failed() {
+ this.failed = null;
+ }
+
+ /** Returns true if field failed is set (has been assigned a value) and false otherwise */
+ public boolean is_set_failed() {
+ return this.failed != null;
+ }
+
+ public void set_failed_isSet(boolean value) {
+ if (!value) {
+ this.failed = null;
+ }
+ }
+
+ public int get_process_ms_avg_size() {
+ return (this.process_ms_avg == null) ? 0 : this.process_ms_avg.size();
+ }
+
+ public void put_to_process_ms_avg(String key, Map<GlobalStreamId,Double> val) {
+ if (this.process_ms_avg == null) {
+ this.process_ms_avg = new HashMap<String,Map<GlobalStreamId,Double>>();
+ }
+ this.process_ms_avg.put(key, val);
+ }
+
+ public Map<String,Map<GlobalStreamId,Double>> get_process_ms_avg() {
+ return this.process_ms_avg;
+ }
+
+ public void set_process_ms_avg(Map<String,Map<GlobalStreamId,Double>> process_ms_avg) {
+ this.process_ms_avg = process_ms_avg;
+ }
+
+ public void unset_process_ms_avg() {
+ this.process_ms_avg = null;
+ }
+
+ /** Returns true if field process_ms_avg is set (has been assigned a value) and false otherwise */
+ public boolean is_set_process_ms_avg() {
+ return this.process_ms_avg != null;
+ }
+
+ public void set_process_ms_avg_isSet(boolean value) {
+ if (!value) {
+ this.process_ms_avg = null;
+ }
+ }
+
+ public int get_executed_size() {
+ return (this.executed == null) ? 0 : this.executed.size();
+ }
+
+ public void put_to_executed(String key, Map<GlobalStreamId,Long> val) {
+ if (this.executed == null) {
+ this.executed = new HashMap<String,Map<GlobalStreamId,Long>>();
+ }
+ this.executed.put(key, val);
+ }
+
+ public Map<String,Map<GlobalStreamId,Long>> get_executed() {
+ return this.executed;
+ }
+
+ public void set_executed(Map<String,Map<GlobalStreamId,Long>> executed) {
+ this.executed = executed;
+ }
+
+ public void unset_executed() {
+ this.executed = null;
+ }
+
+ /** Returns true if field executed is set (has been assigned a value) and false otherwise */
+ public boolean is_set_executed() {
+ return this.executed != null;
+ }
+
+ public void set_executed_isSet(boolean value) {
+ if (!value) {
+ this.executed = null;
+ }
+ }
+
+ public int get_execute_ms_avg_size() {
+ return (this.execute_ms_avg == null) ? 0 : this.execute_ms_avg.size();
+ }
+
+ public void put_to_execute_ms_avg(String key, Map<GlobalStreamId,Double> val) {
+ if (this.execute_ms_avg == null) {
+ this.execute_ms_avg = new HashMap<String,Map<GlobalStreamId,Double>>();
+ }
+ this.execute_ms_avg.put(key, val);
+ }
+
+ public Map<String,Map<GlobalStreamId,Double>> get_execute_ms_avg() {
+ return this.execute_ms_avg;
+ }
+
+ public void set_execute_ms_avg(Map<String,Map<GlobalStreamId,Double>> execute_ms_avg) {
+ this.execute_ms_avg = execute_ms_avg;
+ }
+
+ public void unset_execute_ms_avg() {
+ this.execute_ms_avg = null;
+ }
+
+ /** Returns true if field execute_ms_avg is set (has been assigned a value) and false otherwise */
+ public boolean is_set_execute_ms_avg() {
+ return this.execute_ms_avg != null;
+ }
+
+ public void set_execute_ms_avg_isSet(boolean value) {
+ if (!value) {
+ this.execute_ms_avg = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case ACKED:
+ if (value == null) {
+ unset_acked();
+ } else {
+ set_acked((Map<String,Map<GlobalStreamId,Long>>)value);
+ }
+ break;
+
+ case FAILED:
+ if (value == null) {
+ unset_failed();
+ } else {
+ set_failed((Map<String,Map<GlobalStreamId,Long>>)value);
+ }
+ break;
+
+ case PROCESS_MS_AVG:
+ if (value == null) {
+ unset_process_ms_avg();
+ } else {
+ set_process_ms_avg((Map<String,Map<GlobalStreamId,Double>>)value);
+ }
+ break;
+
+ case EXECUTED:
+ if (value == null) {
+ unset_executed();
+ } else {
+ set_executed((Map<String,Map<GlobalStreamId,Long>>)value);
+ }
+ break;
+
+ case EXECUTE_MS_AVG:
+ if (value == null) {
+ unset_execute_ms_avg();
+ } else {
+ set_execute_ms_avg((Map<String,Map<GlobalStreamId,Double>>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case ACKED:
+ return get_acked();
+
+ case FAILED:
+ return get_failed();
+
+ case PROCESS_MS_AVG:
+ return get_process_ms_avg();
+
+ case EXECUTED:
+ return get_executed();
+
+ case EXECUTE_MS_AVG:
+ return get_execute_ms_avg();
+
+ }
+ 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 ACKED:
+ return is_set_acked();
+ case FAILED:
+ return is_set_failed();
+ case PROCESS_MS_AVG:
+ return is_set_process_ms_avg();
+ case EXECUTED:
+ return is_set_executed();
+ case EXECUTE_MS_AVG:
+ return is_set_execute_ms_avg();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof BoltStats)
+ return this.equals((BoltStats)that);
+ return false;
+ }
+
+ public boolean equals(BoltStats that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_acked = true && this.is_set_acked();
+ boolean that_present_acked = true && that.is_set_acked();
+ if (this_present_acked || that_present_acked) {
+ if (!(this_present_acked && that_present_acked))
+ return false;
+ if (!this.acked.equals(that.acked))
+ return false;
+ }
+
+ boolean this_present_failed = true && this.is_set_failed();
+ boolean that_present_failed = true && that.is_set_failed();
+ if (this_present_failed || that_present_failed) {
+ if (!(this_present_failed && that_present_failed))
+ return false;
+ if (!this.failed.equals(that.failed))
+ return false;
+ }
+
+ boolean this_present_process_ms_avg = true && this.is_set_process_ms_avg();
+ boolean that_present_process_ms_avg = true && that.is_set_process_ms_avg();
+ if (this_present_process_ms_avg || that_present_process_ms_avg) {
+ if (!(this_present_process_ms_avg && that_present_process_ms_avg))
+ return false;
+ if (!this.process_ms_avg.equals(that.process_ms_avg))
+ return false;
+ }
+
+ boolean this_present_executed = true && this.is_set_executed();
+ boolean that_present_executed = true && that.is_set_executed();
+ if (this_present_executed || that_present_executed) {
+ if (!(this_present_executed && that_present_executed))
+ return false;
+ if (!this.executed.equals(that.executed))
+ return false;
+ }
+
+ boolean this_present_execute_ms_avg = true && this.is_set_execute_ms_avg();
+ boolean that_present_execute_ms_avg = true && that.is_set_execute_ms_avg();
+ if (this_present_execute_ms_avg || that_present_execute_ms_avg) {
+ if (!(this_present_execute_ms_avg && that_present_execute_ms_avg))
+ return false;
+ if (!this.execute_ms_avg.equals(that.execute_ms_avg))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_acked = true && (is_set_acked());
+ list.add(present_acked);
+ if (present_acked)
+ list.add(acked);
+
+ boolean present_failed = true && (is_set_failed());
+ list.add(present_failed);
+ if (present_failed)
+ list.add(failed);
+
+ boolean present_process_ms_avg = true && (is_set_process_ms_avg());
+ list.add(present_process_ms_avg);
+ if (present_process_ms_avg)
+ list.add(process_ms_avg);
+
+ boolean present_executed = true && (is_set_executed());
+ list.add(present_executed);
+ if (present_executed)
+ list.add(executed);
+
+ boolean present_execute_ms_avg = true && (is_set_execute_ms_avg());
+ list.add(present_execute_ms_avg);
+ if (present_execute_ms_avg)
+ list.add(execute_ms_avg);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(BoltStats other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(is_set_acked()).compareTo(other.is_set_acked());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_acked()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.acked, other.acked);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(is_set_failed()).compareTo(other.is_set_failed());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_failed()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.failed, other.failed);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(is_set_process_ms_avg()).compareTo(other.is_set_process_ms_avg());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_process_ms_avg()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.process_ms_avg, other.process_ms_avg);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(is_set_executed()).compareTo(other.is_set_executed());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_executed()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.executed, other.executed);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(is_set_execute_ms_avg()).compareTo(other.is_set_execute_ms_avg());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_execute_ms_avg()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.execute_ms_avg, other.execute_ms_avg);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ return 0;
+ }
+
+ public _Fields fieldForId(int fieldId) {
+ return _Fields.findByThriftId(fieldId);
+ }
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("BoltStats(");
+ boolean first = true;
+
+ sb.append("acked:");
+ if (this.acked == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.acked);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("failed:");
+ if (this.failed == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.failed);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("process_ms_avg:");
+ if (this.process_ms_avg == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.process_ms_avg);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("executed:");
+ if (this.executed == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.executed);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("execute_ms_avg:");
+ if (this.execute_ms_avg == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.execute_ms_avg);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!is_set_acked()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'acked' is unset! Struct:" + toString());
+ }
+
+ if (!is_set_failed()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'failed' is unset! Struct:" + toString());
+ }
+
+ if (!is_set_process_ms_avg()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'process_ms_avg' is unset! Struct:" + toString());
+ }
+
+ if (!is_set_executed()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'executed' is unset! Struct:" + toString());
+ }
+
+ if (!is_set_execute_ms_avg()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'execute_ms_avg' is unset! Struct:" + toString());
+ }
+
+ // check for sub-struct validity
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class BoltStatsStandardSchemeFactory implements SchemeFactory {
+ public BoltStatsStandardScheme getScheme() {
+ return new BoltStatsStandardScheme();
+ }
+ }
+
+ private static class BoltStatsStandardScheme extends StandardScheme<BoltStats> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, BoltStats struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // ACKED
+ if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
+ {
+ org.apache.thrift.protocol.TMap _map132 = iprot.readMapBegin();
+ struct.acked = new HashMap<String,Map<GlobalStreamId,Long>>(2*_map132.size);
+ String _key133;
+ Map<GlobalStreamId,Long> _val134;
+ for (int _i135 = 0; _i135 < _map132.size; ++_i135)
+ {
+ _key133 = iprot.readString();
+ {
+ org.apache.thrift.protocol.TMap _map136 = iprot.readMapBegin();
+ _val134 = new HashMap<GlobalStreamId,Long>(2*_map136.size);
+ GlobalStreamId _key137;
+ long _val138;
+ for (int _i139 = 0; _i139 < _map136.size; ++_i139)
+ {
+ _key137 = new GlobalStreamId();
+ _key137.read(iprot);
+ _val138 = iprot.readI64();
+ _val134.put(_key137, _val138);
+ }
+ iprot.readMapEnd();
+ }
+ struct.acked.put(_key133, _val134);
+ }
+ iprot.readMapEnd();
+ }
+ struct.set_acked_isSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // FAILED
+ if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
+ {
+ org.apache.thrift.protocol.TMap _map140 = iprot.readMapBegin();
+ struct.failed = new HashMap<String,Map<GlobalStreamId,Long>>(2*_map140.size);
+ String _key141;
+ Map<GlobalStreamId,Long> _val142;
+ for (int _i143 = 0; _i143 < _map140.size; ++_i143)
+ {
+ _key141 = iprot.readString();
+ {
+ org.apache.thrift.protocol.TMap _map144 = iprot.readMapBegin();
+ _val142 = new HashMap<GlobalStreamId,Long>(2*_map144.size);
+ GlobalStreamId _key145;
+ long _val146;
+ for (int _i147 = 0; _i147 < _map144.size; ++_i147)
+ {
+ _key145 = new GlobalStreamId();
+ _key145.read(iprot);
+ _val146 = iprot.readI64();
+ _val142.put(_key145, _val146);
+ }
+ iprot.readMapEnd();
+ }
+ struct.failed.put(_key141, _val142);
+ }
+ iprot.readMapEnd();
+ }
+ struct.set_failed_isSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // PROCESS_MS_AVG
+ if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
+ {
+ org.apache.thrift.protocol.TMap _map148 = iprot.readMapBegin();
+ struct.process_ms_avg = new HashMap<String,Map<GlobalStreamId,Double>>(2*_map148.size);
+ String _key149;
+ Map<GlobalStreamId,Double> _val150;
+ for (int _i151 = 0; _i151 < _map148.size; ++_i151)
+ {
+ _key149 = iprot.readString();
+ {
+ org.apache.thrift.protocol.TMap _map152 = iprot.readMapBegin();
+ _val150 = new HashMap<GlobalStreamId,Double>(2*_map152.size);
+ GlobalStreamId _key153;
+ double _val154;
+ for (int _i155 = 0; _i155 < _map152.size; ++_i155)
+ {
+ _key153 = new GlobalStreamId();
+ _key153.read(iprot);
+ _val154 = iprot.readDouble();
+ _val150.put(_key153, _val154);
+ }
+ iprot.readMapEnd();
+ }
+ struct.process_ms_avg.put(_key149, _val150);
+ }
+ iprot.readMapEnd();
+ }
+ struct.set_process_ms_avg_isSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 4: // EXECUTED
+ if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
+ {
+ org.apache.thrift.protocol.TMap _map156 = iprot.readMapBegin();
+ struct.executed = new HashMap<String,Map<GlobalStreamId,Long>>(2*_map156.size);
+ String _key157;
+ Map<GlobalStreamId,Long> _val158;
+ for (int _i159 = 0; _i159 < _map156.size; ++_i159)
+ {
+ _key157 = iprot.readString();
+ {
+ org.apache.thrift.protocol.TMap _map160 = iprot.readMapBegin();
+ _val158 = new HashMap<GlobalStreamId,Long>(2*_map160.size);
+ GlobalStreamId _key161;
+ long _val162;
+ for (int _i163 = 0; _i163 < _map160.size; ++_i163)
+ {
+ _key161 = new GlobalStreamId();
+ _key161.read(iprot);
+ _val162 = iprot.readI64();
+ _val158.put(_key161, _val162);
+ }
+ iprot.readMapEnd();
+ }
+ struct.executed.put(_key157, _val158);
+ }
+ iprot.readMapEnd();
+ }
+ struct.set_executed_isSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 5: // EXECUTE_MS_AVG
+ if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
+ {
+ org.apache.thrift.protocol.TMap _map164 = iprot.readMapBegin();
+ struct.execute_ms_avg = new HashMap<String,Map<GlobalStreamId,Double>>(2*_map164.size);
+ String _key165;
+ Map<GlobalStreamId,Double> _val166;
+ for (int _i167 = 0; _i167 < _map164.size; ++_i167)
+ {
+ _key165 = iprot.readString();
+ {
+ org.apache.thrift.protocol.TMap _map168 = iprot.readMapBegin();
+ _val166 = new HashMap<GlobalStreamId,Double>(2*_map168.size);
+ GlobalStreamId _key169;
+ double _val170;
+ for (int _i171 = 0; _i171 < _map168.size; ++_i171)
+ {
+ _key169 = new GlobalStreamId();
+ _key169.read(iprot);
+ _val170 = iprot.readDouble();
+ _val166.put(_key169, _val170);
+ }
+ iprot.readMapEnd();
+ }
+ struct.execute_ms_avg.put(_key165, _val166);
+ }
+ iprot.readMapEnd();
+ }
+ struct.set_execute_ms_avg_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, BoltStats struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.acked != null) {
+ oprot.writeFieldBegin(ACKED_FIELD_DESC);
+ {
+ oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, struct.acked.size()));
+ for (Map.Entry<String, Map<GlobalStreamId,Long>> _iter172 : struct.acked.entrySet())
+ {
+ oprot.writeString(_iter172.getKey());
+ {
+ oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.I64, _iter172.getValue().size()));
+ for (Map.Entry<GlobalStreamId, Long> _iter173 : _iter172.getValue().entrySet())
+ {
+ _iter173.getKey().write(oprot);
+ oprot.writeI64(_iter173.getValue());
+ }
+ oprot.writeMapEnd();
+ }
+ }
+ oprot.writeMapEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ if (struct.failed != null) {
+ oprot.writeFieldBegin(FAILED_FIELD_DESC);
+ {
+ oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, struct.failed.size()));
+ for (Map.Entry<String, Map<GlobalStreamId,Long>> _iter174 : struct.failed.entrySet())
+ {
+ oprot.writeString(_iter174.getKey());
+ {
+ oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.I64, _iter174.getValue().size()));
+ for (Map.Entry<GlobalStreamId, Long> _iter175 : _iter174.getValue().entrySet())
+ {
+ _iter175.getKey().write(oprot);
+ oprot.writeI64(_iter175.getValue());
+ }
+ oprot.writeMapEnd();
+ }
+ }
+ oprot.writeMapEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ if (struct.process_ms_avg != null) {
+ oprot.writeFieldBegin(PROCESS_MS_AVG_FIELD_DESC);
+ {
+ oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, struct.process_ms_avg.size()));
+ for (Map.Entry<String, Map<GlobalStreamId,Double>> _iter176 : struct.process_ms_avg.entrySet())
+ {
+ oprot.writeString(_iter176.getKey());
+ {
+ oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.DOUBLE, _iter176.getValue().size()));
+ for (Map.Entry<GlobalStreamId, Double> _iter177 : _iter176.getValue().entrySet())
+ {
+ _iter177.getKey().write(oprot);
+ oprot.writeDouble(_iter177.getValue());
+ }
+ oprot.writeMapEnd();
+ }
+ }
+ oprot.writeMapEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ if (struct.executed != null) {
+ oprot.writeFieldBegin(EXECUTED_FIELD_DESC);
+ {
+ oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, struct.executed.size()));
+ for (Map.Entry<String, Map<GlobalStreamId,Long>> _iter178 : struct.executed.entrySet())
+ {
+ oprot.writeString(_iter178.getKey());
+ {
+ oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.I64, _iter178.getValue().size()));
+ for (Map.Entry<GlobalStreamId, Long> _iter179 : _iter178.getValue().entrySet())
+ {
+ _iter179.getKey().write(oprot);
+ oprot.writeI64(_iter179.getValue());
+ }
+ oprot.writeMapEnd();
+ }
+ }
+ oprot.writeMapEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ if (struct.execute_ms_avg != null) {
+ oprot.writeFieldBegin(EXECUTE_MS_AVG_FIELD_DESC);
+ {
+ oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, struct.execute_ms_avg.size()));
+ for (Map.Entry<String, Map<GlobalStreamId,Double>> _iter180 : struct.execute_ms_avg.entrySet())
+ {
+ oprot.writeString(_iter180.getKey());
+ {
+ oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.DOUBLE, _iter180.getValue().size()));
+ for (Map.Entry<GlobalStreamId, Double> _iter181 : _iter180.getValue().entrySet())
+ {
+ _iter181.getKey().write(oprot);
+ oprot.writeDouble(_iter181.getValue());
+ }
+ oprot.writeMapEnd();
+ }
+ }
+ oprot.writeMapEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class BoltStatsTupleSchemeFactory implements SchemeFactory {
+ public BoltStatsTupleScheme getScheme() {
+ return new BoltStatsTupleScheme();
+ }
+ }
+
+ private static class BoltStatsTupleScheme extends TupleScheme<BoltStats> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, BoltStats struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ {
+ oprot.writeI32(struct.acked.size());
+ for (Map.Entry<String, Map<GlobalStreamId,Long>> _iter182 : struct.acked.entrySet())
+ {
+ oprot.writeString(_iter182.getKey());
+ {
+ oprot.writeI32(_iter182.getValue().size());
+ for (Map.Entry<GlobalStreamId, Long> _iter183 : _iter182.getValue().entrySet())
+ {
+ _iter183.getKey().write(oprot);
+ oprot.writeI64(_iter183.getValue());
+ }
+ }
+ }
+ }
+ {
+ oprot.writeI32(struct.failed.size());
+ for (Map.Entry<String, Map<GlobalStreamId,Long>> _iter184 : struct.failed.entrySet())
+ {
+ oprot.writeString(_iter184.getKey());
+ {
+ oprot.writeI32(_iter184.getValue().size());
+ for (Map.Entry<GlobalStreamId, Long> _iter185 : _iter184.getValue().entrySet())
+ {
+ _iter185.getKey().write(oprot);
+ oprot.writeI64(_iter185.getValue());
+ }
+ }
+ }
+ }
+ {
+ oprot.writeI32(struct.process_ms_avg.size());
+ for (Map.Entry<String, Map<GlobalStreamId,Double>> _iter186 : struct.process_ms_avg.entrySet())
+ {
+ oprot.writeString(_iter186.getKey());
+ {
+ oprot.writeI32(_iter186.getValue().size());
+ for (Map.Entry<GlobalStreamId, Double> _iter187 : _iter186.getValue().entrySet())
+ {
+ _iter187.getKey().write(oprot);
+ oprot.writeDouble(_iter187.getValue());
+ }
+ }
+ }
+ }
+ {
+ oprot.writeI32(struct.executed.size());
+ for (Map.Entry<String, Map<GlobalStreamId,Long>> _iter188 : struct.executed.entrySet())
+ {
+ oprot.writeString(_iter188.getKey());
+ {
+ oprot.writeI32(_iter188.getValue().size());
+ for (Map.Entry<GlobalStreamId, Long> _iter189 : _iter188.getValue().entrySet())
+ {
+ _iter189.getKey().write(oprot);
+ oprot.writeI64(_iter189.getValue());
+ }
+ }
+ }
+ }
+ {
+ oprot.writeI32(struct.execute_ms_avg.size());
+ for (Map.Entry<String, Map<GlobalStreamId,Double>> _iter190 : struct.execute_ms_avg.entrySet())
+ {
+ oprot.writeString(_iter190.getKey());
+ {
+ oprot.writeI32(_iter190.getValue().size());
+ for (Map.Entry<GlobalStreamId, Double> _iter191 : _iter190.getValue().entrySet())
+ {
+ _iter191.getKey().write(oprot);
+ oprot.writeDouble(_iter191.getValue());
+ }
+ }
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, BoltStats struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ {
+ org.apache.thrift.protocol.TMap _map192 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, iprot.readI32());
+ struct.acked = new HashMap<String,Map<GlobalStreamId,Long>>(2*_map192.size);
+ String _key193;
+ Map<GlobalStreamId,Long> _val194;
+ for (int _i195 = 0; _i195 < _map192.size; ++_i195)
+ {
+ _key193 = iprot.readString();
+ {
+ org.apache.thrift.protocol.TMap _map196 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ _val194 = new HashMap<GlobalStreamId,Long>(2*_map196.size);
+ GlobalStreamId _key197;
+ long _val198;
+ for (int _i199 = 0; _i199 < _map196.size; ++_i199)
+ {
+ _key197 = new GlobalStreamId();
+ _key197.read(iprot);
+ _val198 = iprot.readI64();
+ _val194.put(_key197, _val198);
+ }
+ }
+ struct.acked.put(_key193, _val194);
+ }
+ }
+ struct.set_acked_isSet(true);
+ {
+ org.apache.thrift.protocol.TMap _map200 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, iprot.readI32());
+ struct.failed = new HashMap<String,Map<GlobalStreamId,Long>>(2*_map200.size);
+ String _key201;
+ Map<GlobalStreamId,Long> _val202;
+ for (int _i203 = 0; _i203 < _map200.size; ++_i203)
+ {
+ _key201 = iprot.readString();
+ {
+ org.apache.thrift.protocol.TMap _map204 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ _val202 = new HashMap<GlobalStreamId,Long>(2*_map204.size);
+ GlobalStreamId _key205;
+ long _val206;
+ for (int _i207 = 0; _i207 < _map204.size; ++_i207)
+ {
+ _key205 = new GlobalStreamId();
+ _key205.read(iprot);
+ _val206 = iprot.readI64();
+ _val202.put(_key205, _val206);
+ }
+ }
+ struct.failed.put(_key201, _val202);
+ }
+ }
+ struct.set_failed_isSet(true);
+ {
+ org.apache.thrift.protocol.TMap _map208 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, iprot.readI32());
+ struct.process_ms_avg = new HashMap<String,Map<GlobalStreamId,Double>>(2*_map208.size);
+ String _key209;
+ Map<GlobalStreamId,Double> _val210;
+ for (int _i211 = 0; _i211 < _map208.size; ++_i211)
+ {
+ _key209 = iprot.readString();
+ {
+ org.apache.thrift.protocol.TMap _map212 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.DOUBLE, iprot.readI32());
+ _val210 = new HashMap<GlobalStreamId,Double>(2*_map212.size);
+ GlobalStreamId _key213;
+ double _val214;
+ for (int _i215 = 0; _i215 < _map212.size; ++_i215)
+ {
+ _key213 = new GlobalStreamId();
+ _key213.read(iprot);
+ _val214 = iprot.readDouble();
+ _val210.put(_key213, _val214);
+ }
+ }
+ struct.process_ms_avg.put(_key209, _val210);
+ }
+ }
+ struct.set_process_ms_avg_isSet(true);
+ {
+ org.apache.thrift.protocol.TMap _map216 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, iprot.readI32());
+ struct.executed = new HashMap<String,Map<GlobalStreamId,Long>>(2*_map216.size);
+ String _key217;
+ Map<GlobalStreamId,Long> _val218;
+ for (int _i219 = 0; _i219 < _map216.size; ++_i219)
+ {
+ _key217 = iprot.readString();
+ {
+ org.apache.thrift.protocol.TMap _map220 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ _val218 = new HashMap<GlobalStreamId,Long>(2*_map220.size);
+ GlobalStreamId _key221;
+ long _val222;
+ for (int _i223 = 0; _i223 < _map220.size; ++_i223)
+ {
+ _key221 = new GlobalStreamId();
+ _key221.read(iprot);
+ _val222 = iprot.readI64();
+ _val218.put(_key221, _val222);
+ }
+ }
+ struct.executed.put(_key217, _val218);
+ }
+ }
+ struct.set_executed_isSet(true);
+ {
+ org.apache.thrift.protocol.TMap _map224 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, iprot.readI32());
+ struct.execute_ms_avg = new HashMap<String,Map<GlobalStreamId,Double>>(2*_map224.size);
+ String _key225;
+ Map<GlobalStreamId,Double> _val226;
+ for (int _i227 = 0; _i227 < _map224.size; ++_i227)
+ {
+ _key225 = iprot.readString();
+ {
+ org.apache.thrift.protocol.TMap _map228 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.DOUBLE, iprot.readI32());
+ _val226 = new HashMap<GlobalStreamId,Double>(2*_map228.size);
+ GlobalStreamId _key229;
+ double _val230;
+ for (int _i231 = 0; _i231 < _map228.size; ++_i231)
+ {
+ _key229 = new GlobalStreamId();
+ _key229.read(iprot);
+ _val230 = iprot.readDouble();
+ _val226.put(_key229, _val230);
+ }
+ }
+ struct.execute_ms_avg.put(_key225, _val226);
+ }
+ }
+ struct.set_execute_ms_avg_isSet(true);
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/storm/blob/4de339a8/storm-client/src/jvm/org/apache/storm/generated/ClusterSummary.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/generated/ClusterSummary.java b/storm-client/src/jvm/org/apache/storm/generated/ClusterSummary.java
new file mode 100644
index 0000000..8adc3f5
--- /dev/null
+++ b/storm-client/src/jvm/org/apache/storm/generated/ClusterSummary.java
@@ -0,0 +1,879 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.storm.generated;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+public class ClusterSummary implements org.apache.thrift.TBase<ClusterSummary, ClusterSummary._Fields>, java.io.Serializable, Cloneable, Comparable<ClusterSummary> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ClusterSummary");
+
+ private static final org.apache.thrift.protocol.TField SUPERVISORS_FIELD_DESC = new org.apache.thrift.protocol.TField("supervisors", org.apache.thrift.protocol.TType.LIST, (short)1);
+ private static final org.apache.thrift.protocol.TField NIMBUS_UPTIME_SECS_FIELD_DESC = new org.apache.thrift.protocol.TField("nimbus_uptime_secs", org.apache.thrift.protocol.TType.I32, (short)2);
+ private static final org.apache.thrift.protocol.TField TOPOLOGIES_FIELD_DESC = new org.apache.thrift.protocol.TField("topologies", org.apache.thrift.protocol.TType.LIST, (short)3);
+ private static final org.apache.thrift.protocol.TField NIMBUSES_FIELD_DESC = new org.apache.thrift.protocol.TField("nimbuses", org.apache.thrift.protocol.TType.LIST, (short)4);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new ClusterSummaryStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new ClusterSummaryTupleSchemeFactory());
+ }
+
+ private List<SupervisorSummary> supervisors; // required
+ private int nimbus_uptime_secs; // optional
+ private List<TopologySummary> topologies; // required
+ private List<NimbusSummary> nimbuses; // 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 {
+ SUPERVISORS((short)1, "supervisors"),
+ NIMBUS_UPTIME_SECS((short)2, "nimbus_uptime_secs"),
+ TOPOLOGIES((short)3, "topologies"),
+ NIMBUSES((short)4, "nimbuses");
+
+ 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: // SUPERVISORS
+ return SUPERVISORS;
+ case 2: // NIMBUS_UPTIME_SECS
+ return NIMBUS_UPTIME_SECS;
+ case 3: // TOPOLOGIES
+ return TOPOLOGIES;
+ case 4: // NIMBUSES
+ return NIMBUSES;
+ 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 __NIMBUS_UPTIME_SECS_ISSET_ID = 0;
+ private byte __isset_bitfield = 0;
+ private static final _Fields optionals[] = {_Fields.NIMBUS_UPTIME_SECS};
+ 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.SUPERVISORS, new org.apache.thrift.meta_data.FieldMetaData("supervisors", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, SupervisorSummary.class))));
+ tmpMap.put(_Fields.NIMBUS_UPTIME_SECS, new org.apache.thrift.meta_data.FieldMetaData("nimbus_uptime_secs", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
+ tmpMap.put(_Fields.TOPOLOGIES, new org.apache.thrift.meta_data.FieldMetaData("topologies", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TopologySummary.class))));
+ tmpMap.put(_Fields.NIMBUSES, new org.apache.thrift.meta_data.FieldMetaData("nimbuses", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, NimbusSummary.class))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ClusterSummary.class, metaDataMap);
+ }
+
+ public ClusterSummary() {
+ this.nimbus_uptime_secs = 0;
+
+ }
+
+ public ClusterSummary(
+ List<SupervisorSummary> supervisors,
+ List<TopologySummary> topologies,
+ List<NimbusSummary> nimbuses)
+ {
+ this();
+ this.supervisors = supervisors;
+ this.topologies = topologies;
+ this.nimbuses = nimbuses;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public ClusterSummary(ClusterSummary other) {
+ __isset_bitfield = other.__isset_bitfield;
+ if (other.is_set_supervisors()) {
+ List<SupervisorSummary> __this__supervisors = new ArrayList<SupervisorSummary>(other.supervisors.size());
+ for (SupervisorSummary other_element : other.supervisors) {
+ __this__supervisors.add(new SupervisorSummary(other_element));
+ }
+ this.supervisors = __this__supervisors;
+ }
+ this.nimbus_uptime_secs = other.nimbus_uptime_secs;
+ if (other.is_set_topologies()) {
+ List<TopologySummary> __this__topologies = new ArrayList<TopologySummary>(other.topologies.size());
+ for (TopologySummary other_element : other.topologies) {
+ __this__topologies.add(new TopologySummary(other_element));
+ }
+ this.topologies = __this__topologies;
+ }
+ if (other.is_set_nimbuses()) {
+ List<NimbusSummary> __this__nimbuses = new ArrayList<NimbusSummary>(other.nimbuses.size());
+ for (NimbusSummary other_element : other.nimbuses) {
+ __this__nimbuses.add(new NimbusSummary(other_element));
+ }
+ this.nimbuses = __this__nimbuses;
+ }
+ }
+
+ public ClusterSummary deepCopy() {
+ return new ClusterSummary(this);
+ }
+
+ @Override
+ public void clear() {
+ this.supervisors = null;
+ this.nimbus_uptime_secs = 0;
+
+ this.topologies = null;
+ this.nimbuses = null;
+ }
+
+ public int get_supervisors_size() {
+ return (this.supervisors == null) ? 0 : this.supervisors.size();
+ }
+
+ public java.util.Iterator<SupervisorSummary> get_supervisors_iterator() {
+ return (this.supervisors == null) ? null : this.supervisors.iterator();
+ }
+
+ public void add_to_supervisors(SupervisorSummary elem) {
+ if (this.supervisors == null) {
+ this.supervisors = new ArrayList<SupervisorSummary>();
+ }
+ this.supervisors.add(elem);
+ }
+
+ public List<SupervisorSummary> get_supervisors() {
+ return this.supervisors;
+ }
+
+ public void set_supervisors(List<SupervisorSummary> supervisors) {
+ this.supervisors = supervisors;
+ }
+
+ public void unset_supervisors() {
+ this.supervisors = null;
+ }
+
+ /** Returns true if field supervisors is set (has been assigned a value) and false otherwise */
+ public boolean is_set_supervisors() {
+ return this.supervisors != null;
+ }
+
+ public void set_supervisors_isSet(boolean value) {
+ if (!value) {
+ this.supervisors = null;
+ }
+ }
+
+ public int get_nimbus_uptime_secs() {
+ return this.nimbus_uptime_secs;
+ }
+
+ public void set_nimbus_uptime_secs(int nimbus_uptime_secs) {
+ this.nimbus_uptime_secs = nimbus_uptime_secs;
+ set_nimbus_uptime_secs_isSet(true);
+ }
+
+ public void unset_nimbus_uptime_secs() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NIMBUS_UPTIME_SECS_ISSET_ID);
+ }
+
+ /** Returns true if field nimbus_uptime_secs is set (has been assigned a value) and false otherwise */
+ public boolean is_set_nimbus_uptime_secs() {
+ return EncodingUtils.testBit(__isset_bitfield, __NIMBUS_UPTIME_SECS_ISSET_ID);
+ }
+
+ public void set_nimbus_uptime_secs_isSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NIMBUS_UPTIME_SECS_ISSET_ID, value);
+ }
+
+ public int get_topologies_size() {
+ return (this.topologies == null) ? 0 : this.topologies.size();
+ }
+
+ public java.util.Iterator<TopologySummary> get_topologies_iterator() {
+ return (this.topologies == null) ? null : this.topologies.iterator();
+ }
+
+ public void add_to_topologies(TopologySummary elem) {
+ if (this.topologies == null) {
+ this.topologies = new ArrayList<TopologySummary>();
+ }
+ this.topologies.add(elem);
+ }
+
+ public List<TopologySummary> get_topologies() {
+ return this.topologies;
+ }
+
+ public void set_topologies(List<TopologySummary> topologies) {
+ this.topologies = topologies;
+ }
+
+ public void unset_topologies() {
+ this.topologies = null;
+ }
+
+ /** Returns true if field topologies is set (has been assigned a value) and false otherwise */
+ public boolean is_set_topologies() {
+ return this.topologies != null;
+ }
+
+ public void set_topologies_isSet(boolean value) {
+ if (!value) {
+ this.topologies = null;
+ }
+ }
+
+ public int get_nimbuses_size() {
+ return (this.nimbuses == null) ? 0 : this.nimbuses.size();
+ }
+
+ public java.util.Iterator<NimbusSummary> get_nimbuses_iterator() {
+ return (this.nimbuses == null) ? null : this.nimbuses.iterator();
+ }
+
+ public void add_to_nimbuses(NimbusSummary elem) {
+ if (this.nimbuses == null) {
+ this.nimbuses = new ArrayList<NimbusSummary>();
+ }
+ this.nimbuses.add(elem);
+ }
+
+ public List<NimbusSummary> get_nimbuses() {
+ return this.nimbuses;
+ }
+
+ public void set_nimbuses(List<NimbusSummary> nimbuses) {
+ this.nimbuses = nimbuses;
+ }
+
+ public void unset_nimbuses() {
+ this.nimbuses = null;
+ }
+
+ /** Returns true if field nimbuses is set (has been assigned a value) and false otherwise */
+ public boolean is_set_nimbuses() {
+ return this.nimbuses != null;
+ }
+
+ public void set_nimbuses_isSet(boolean value) {
+ if (!value) {
+ this.nimbuses = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case SUPERVISORS:
+ if (value == null) {
+ unset_supervisors();
+ } else {
+ set_supervisors((List<SupervisorSummary>)value);
+ }
+ break;
+
+ case NIMBUS_UPTIME_SECS:
+ if (value == null) {
+ unset_nimbus_uptime_secs();
+ } else {
+ set_nimbus_uptime_secs((Integer)value);
+ }
+ break;
+
+ case TOPOLOGIES:
+ if (value == null) {
+ unset_topologies();
+ } else {
+ set_topologies((List<TopologySummary>)value);
+ }
+ break;
+
+ case NIMBUSES:
+ if (value == null) {
+ unset_nimbuses();
+ } else {
+ set_nimbuses((List<NimbusSummary>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case SUPERVISORS:
+ return get_supervisors();
+
+ case NIMBUS_UPTIME_SECS:
+ return get_nimbus_uptime_secs();
+
+ case TOPOLOGIES:
+ return get_topologies();
+
+ case NIMBUSES:
+ return get_nimbuses();
+
+ }
+ 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 SUPERVISORS:
+ return is_set_supervisors();
+ case NIMBUS_UPTIME_SECS:
+ return is_set_nimbus_uptime_secs();
+ case TOPOLOGIES:
+ return is_set_topologies();
+ case NIMBUSES:
+ return is_set_nimbuses();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof ClusterSummary)
+ return this.equals((ClusterSummary)that);
+ return false;
+ }
+
+ public boolean equals(ClusterSummary that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_supervisors = true && this.is_set_supervisors();
+ boolean that_present_supervisors = true && that.is_set_supervisors();
+ if (this_present_supervisors || that_present_supervisors) {
+ if (!(this_present_supervisors && that_present_supervisors))
+ return false;
+ if (!this.supervisors.equals(that.supervisors))
+ return false;
+ }
+
+ boolean this_present_nimbus_uptime_secs = true && this.is_set_nimbus_uptime_secs();
+ boolean that_present_nimbus_uptime_secs = true && that.is_set_nimbus_uptime_secs();
+ if (this_present_nimbus_uptime_secs || that_present_nimbus_uptime_secs) {
+ if (!(this_present_nimbus_uptime_secs && that_present_nimbus_uptime_secs))
+ return false;
+ if (this.nimbus_uptime_secs != that.nimbus_uptime_secs)
+ return false;
+ }
+
+ boolean this_present_topologies = true && this.is_set_topologies();
+ boolean that_present_topologies = true && that.is_set_topologies();
+ if (this_present_topologies || that_present_topologies) {
+ if (!(this_present_topologies && that_present_topologies))
+ return false;
+ if (!this.topologies.equals(that.topologies))
+ return false;
+ }
+
+ boolean this_present_nimbuses = true && this.is_set_nimbuses();
+ boolean that_present_nimbuses = true && that.is_set_nimbuses();
+ if (this_present_nimbuses || that_present_nimbuses) {
+ if (!(this_present_nimbuses && that_present_nimbuses))
+ return false;
+ if (!this.nimbuses.equals(that.nimbuses))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_supervisors = true && (is_set_supervisors());
+ list.add(present_supervisors);
+ if (present_supervisors)
+ list.add(supervisors);
+
+ boolean present_nimbus_uptime_secs = true && (is_set_nimbus_uptime_secs());
+ list.add(present_nimbus_uptime_secs);
+ if (present_nimbus_uptime_secs)
+ list.add(nimbus_uptime_secs);
+
+ boolean present_topologies = true && (is_set_topologies());
+ list.add(present_topologies);
+ if (present_topologies)
+ list.add(topologies);
+
+ boolean present_nimbuses = true && (is_set_nimbuses());
+ list.add(present_nimbuses);
+ if (present_nimbuses)
+ list.add(nimbuses);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(ClusterSummary other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(is_set_supervisors()).compareTo(other.is_set_supervisors());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_supervisors()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.supervisors, other.supervisors);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(is_set_nimbus_uptime_secs()).compareTo(other.is_set_nimbus_uptime_secs());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_nimbus_uptime_secs()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.nimbus_uptime_secs, other.nimbus_uptime_secs);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(is_set_topologies()).compareTo(other.is_set_topologies());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_topologies()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.topologies, other.topologies);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(is_set_nimbuses()).compareTo(other.is_set_nimbuses());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_nimbuses()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.nimbuses, other.nimbuses);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ return 0;
+ }
+
+ public _Fields fieldForId(int fieldId) {
+ return _Fields.findByThriftId(fieldId);
+ }
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("ClusterSummary(");
+ boolean first = true;
+
+ sb.append("supervisors:");
+ if (this.supervisors == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.supervisors);
+ }
+ first = false;
+ if (is_set_nimbus_uptime_secs()) {
+ if (!first) sb.append(", ");
+ sb.append("nimbus_uptime_secs:");
+ sb.append(this.nimbus_uptime_secs);
+ first = false;
+ }
+ if (!first) sb.append(", ");
+ sb.append("topologies:");
+ if (this.topologies == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.topologies);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("nimbuses:");
+ if (this.nimbuses == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.nimbuses);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!is_set_supervisors()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'supervisors' is unset! Struct:" + toString());
+ }
+
+ if (!is_set_topologies()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'topologies' is unset! Struct:" + toString());
+ }
+
+ if (!is_set_nimbuses()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'nimbuses' is unset! Struct:" + toString());
+ }
+
+ // check for sub-struct validity
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+ __isset_bitfield = 0;
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class ClusterSummaryStandardSchemeFactory implements SchemeFactory {
+ public ClusterSummaryStandardScheme getScheme() {
+ return new ClusterSummaryStandardScheme();
+ }
+ }
+
+ private static class ClusterSummaryStandardScheme extends StandardScheme<ClusterSummary> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, ClusterSummary struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // SUPERVISORS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list108 = iprot.readListBegin();
+ struct.supervisors = new ArrayList<SupervisorSummary>(_list108.size);
+ SupervisorSummary _elem109;
+ for (int _i110 = 0; _i110 < _list108.size; ++_i110)
+ {
+ _elem109 = new SupervisorSummary();
+ _elem109.read(iprot);
+ struct.supervisors.add(_elem109);
+ }
+ iprot.readListEnd();
+ }
+ struct.set_supervisors_isSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // NIMBUS_UPTIME_SECS
+ if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+ struct.nimbus_uptime_secs = iprot.readI32();
+ struct.set_nimbus_uptime_secs_isSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // TOPOLOGIES
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list111 = iprot.readListBegin();
+ struct.topologies = new ArrayList<TopologySummary>(_list111.size);
+ TopologySummary _elem112;
+ for (int _i113 = 0; _i113 < _list111.size; ++_i113)
+ {
+ _elem112 = new TopologySummary();
+ _elem112.read(iprot);
+ struct.topologies.add(_elem112);
+ }
+ iprot.readListEnd();
+ }
+ struct.set_topologies_isSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 4: // NIMBUSES
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list114 = iprot.readListBegin();
+ struct.nimbuses = new ArrayList<NimbusSummary>(_list114.size);
+ NimbusSummary _elem115;
+ for (int _i116 = 0; _i116 < _list114.size; ++_i116)
+ {
+ _elem115 = new NimbusSummary();
+ _elem115.read(iprot);
+ struct.nimbuses.add(_elem115);
+ }
+ iprot.readListEnd();
+ }
+ struct.set_nimbuses_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, ClusterSummary struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.supervisors != null) {
+ oprot.writeFieldBegin(SUPERVISORS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.supervisors.size()));
+ for (SupervisorSummary _iter117 : struct.supervisors)
+ {
+ _iter117.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ if (struct.is_set_nimbus_uptime_secs()) {
+ oprot.writeFieldBegin(NIMBUS_UPTIME_SECS_FIELD_DESC);
+ oprot.writeI32(struct.nimbus_uptime_secs);
+ oprot.writeFieldEnd();
+ }
+ if (struct.topologies != null) {
+ oprot.writeFieldBegin(TOPOLOGIES_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.topologies.size()));
+ for (TopologySummary _iter118 : struct.topologies)
+ {
+ _iter118.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ if (struct.nimbuses != null) {
+ oprot.writeFieldBegin(NIMBUSES_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.nimbuses.size()));
+ for (NimbusSummary _iter119 : struct.nimbuses)
+ {
+ _iter119.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class ClusterSummaryTupleSchemeFactory implements SchemeFactory {
+ public ClusterSummaryTupleScheme getScheme() {
+ return new ClusterSummaryTupleScheme();
+ }
+ }
+
+ private static class ClusterSummaryTupleScheme extends TupleScheme<ClusterSummary> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, ClusterSummary struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ {
+ oprot.writeI32(struct.supervisors.size());
+ for (SupervisorSummary _iter120 : struct.supervisors)
+ {
+ _iter120.write(oprot);
+ }
+ }
+ {
+ oprot.writeI32(struct.topologies.size());
+ for (TopologySummary _iter121 : struct.topologies)
+ {
+ _iter121.write(oprot);
+ }
+ }
+ {
+ oprot.writeI32(struct.nimbuses.size());
+ for (NimbusSummary _iter122 : struct.nimbuses)
+ {
+ _iter122.write(oprot);
+ }
+ }
+ BitSet optionals = new BitSet();
+ if (struct.is_set_nimbus_uptime_secs()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.is_set_nimbus_uptime_secs()) {
+ oprot.writeI32(struct.nimbus_uptime_secs);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, ClusterSummary struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ {
+ org.apache.thrift.protocol.TList _list123 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.supervisors = new ArrayList<SupervisorSummary>(_list123.size);
+ SupervisorSummary _elem124;
+ for (int _i125 = 0; _i125 < _list123.size; ++_i125)
+ {
+ _elem124 = new SupervisorSummary();
+ _elem124.read(iprot);
+ struct.supervisors.add(_elem124);
+ }
+ }
+ struct.set_supervisors_isSet(true);
+ {
+ org.apache.thrift.protocol.TList _list126 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.topologies = new ArrayList<TopologySummary>(_list126.size);
+ TopologySummary _elem127;
+ for (int _i128 = 0; _i128 < _list126.size; ++_i128)
+ {
+ _elem127 = new TopologySummary();
+ _elem127.read(iprot);
+ struct.topologies.add(_elem127);
+ }
+ }
+ struct.set_topologies_isSet(true);
+ {
+ org.apache.thrift.protocol.TList _list129 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.nimbuses = new ArrayList<NimbusSummary>(_list129.size);
+ NimbusSummary _elem130;
+ for (int _i131 = 0; _i131 < _list129.size; ++_i131)
+ {
+ _elem130 = new NimbusSummary();
+ _elem130.read(iprot);
+ struct.nimbuses.add(_elem130);
+ }
+ }
+ struct.set_nimbuses_isSet(true);
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ struct.nimbus_uptime_secs = iprot.readI32();
+ struct.set_nimbus_uptime_secs_isSet(true);
+ }
+ }
+ }
+
+}
+