http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/ComponentPageInfo.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/ComponentPageInfo.java b/storm-core/src/jvm/backtype/storm/generated/ComponentPageInfo.java deleted file mode 100644 index 7fcebcc..0000000 --- a/storm-core/src/jvm/backtype/storm/generated/ComponentPageInfo.java +++ /dev/null @@ -1,2352 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package 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 ComponentPageInfo implements org.apache.thrift.TBase<ComponentPageInfo, ComponentPageInfo._Fields>, java.io.Serializable, Cloneable, Comparable<ComponentPageInfo> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ComponentPageInfo"); - - private static final org.apache.thrift.protocol.TField COMPONENT_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("component_id", org.apache.thrift.protocol.TType.STRING, (short)1); - private static final org.apache.thrift.protocol.TField COMPONENT_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("component_type", org.apache.thrift.protocol.TType.I32, (short)2); - private static final org.apache.thrift.protocol.TField TOPOLOGY_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("topology_id", org.apache.thrift.protocol.TType.STRING, (short)3); - private static final org.apache.thrift.protocol.TField TOPOLOGY_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("topology_name", org.apache.thrift.protocol.TType.STRING, (short)4); - private static final org.apache.thrift.protocol.TField NUM_EXECUTORS_FIELD_DESC = new org.apache.thrift.protocol.TField("num_executors", org.apache.thrift.protocol.TType.I32, (short)5); - 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)6); - private static final org.apache.thrift.protocol.TField WINDOW_TO_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("window_to_stats", org.apache.thrift.protocol.TType.MAP, (short)7); - private static final org.apache.thrift.protocol.TField GSID_TO_INPUT_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("gsid_to_input_stats", org.apache.thrift.protocol.TType.MAP, (short)8); - private static final org.apache.thrift.protocol.TField SID_TO_OUTPUT_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("sid_to_output_stats", org.apache.thrift.protocol.TType.MAP, (short)9); - private static final org.apache.thrift.protocol.TField EXEC_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("exec_stats", org.apache.thrift.protocol.TType.LIST, (short)10); - private static final org.apache.thrift.protocol.TField ERRORS_FIELD_DESC = new org.apache.thrift.protocol.TField("errors", org.apache.thrift.protocol.TType.LIST, (short)11); - private static final org.apache.thrift.protocol.TField EVENTLOG_HOST_FIELD_DESC = new org.apache.thrift.protocol.TField("eventlog_host", org.apache.thrift.protocol.TType.STRING, (short)12); - private static final org.apache.thrift.protocol.TField EVENTLOG_PORT_FIELD_DESC = new org.apache.thrift.protocol.TField("eventlog_port", org.apache.thrift.protocol.TType.I32, (short)13); - private static final org.apache.thrift.protocol.TField DEBUG_OPTIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("debug_options", org.apache.thrift.protocol.TType.STRUCT, (short)14); - private static final org.apache.thrift.protocol.TField TOPOLOGY_STATUS_FIELD_DESC = new org.apache.thrift.protocol.TField("topology_status", org.apache.thrift.protocol.TType.STRING, (short)15); - private static final org.apache.thrift.protocol.TField RESOURCES_MAP_FIELD_DESC = new org.apache.thrift.protocol.TField("resources_map", org.apache.thrift.protocol.TType.MAP, (short)16); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new ComponentPageInfoStandardSchemeFactory()); - schemes.put(TupleScheme.class, new ComponentPageInfoTupleSchemeFactory()); - } - - private String component_id; // required - private ComponentType component_type; // required - private String topology_id; // optional - private String topology_name; // optional - private int num_executors; // optional - private int num_tasks; // optional - private Map<String,ComponentAggregateStats> window_to_stats; // optional - private Map<GlobalStreamId,ComponentAggregateStats> gsid_to_input_stats; // optional - private Map<String,ComponentAggregateStats> sid_to_output_stats; // optional - private List<ExecutorAggregateStats> exec_stats; // optional - private List<ErrorInfo> errors; // optional - private String eventlog_host; // optional - private int eventlog_port; // optional - private DebugOptions debug_options; // optional - private String topology_status; // optional - private Map<String,Double> resources_map; // 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 { - COMPONENT_ID((short)1, "component_id"), - /** - * - * @see ComponentType - */ - COMPONENT_TYPE((short)2, "component_type"), - TOPOLOGY_ID((short)3, "topology_id"), - TOPOLOGY_NAME((short)4, "topology_name"), - NUM_EXECUTORS((short)5, "num_executors"), - NUM_TASKS((short)6, "num_tasks"), - WINDOW_TO_STATS((short)7, "window_to_stats"), - GSID_TO_INPUT_STATS((short)8, "gsid_to_input_stats"), - SID_TO_OUTPUT_STATS((short)9, "sid_to_output_stats"), - EXEC_STATS((short)10, "exec_stats"), - ERRORS((short)11, "errors"), - EVENTLOG_HOST((short)12, "eventlog_host"), - EVENTLOG_PORT((short)13, "eventlog_port"), - DEBUG_OPTIONS((short)14, "debug_options"), - TOPOLOGY_STATUS((short)15, "topology_status"), - RESOURCES_MAP((short)16, "resources_map"); - - 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: // COMPONENT_ID - return COMPONENT_ID; - case 2: // COMPONENT_TYPE - return COMPONENT_TYPE; - case 3: // TOPOLOGY_ID - return TOPOLOGY_ID; - case 4: // TOPOLOGY_NAME - return TOPOLOGY_NAME; - case 5: // NUM_EXECUTORS - return NUM_EXECUTORS; - case 6: // NUM_TASKS - return NUM_TASKS; - case 7: // WINDOW_TO_STATS - return WINDOW_TO_STATS; - case 8: // GSID_TO_INPUT_STATS - return GSID_TO_INPUT_STATS; - case 9: // SID_TO_OUTPUT_STATS - return SID_TO_OUTPUT_STATS; - case 10: // EXEC_STATS - return EXEC_STATS; - case 11: // ERRORS - return ERRORS; - case 12: // EVENTLOG_HOST - return EVENTLOG_HOST; - case 13: // EVENTLOG_PORT - return EVENTLOG_PORT; - case 14: // DEBUG_OPTIONS - return DEBUG_OPTIONS; - case 15: // TOPOLOGY_STATUS - return TOPOLOGY_STATUS; - case 16: // RESOURCES_MAP - return RESOURCES_MAP; - default: - return null; - } - } - - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ - public static _Fields findByThriftIdOrThrow(int fieldId) { - _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); - return fields; - } - - /** - * Find the _Fields constant that matches name, or null if its not found. - */ - public static _Fields findByName(String name) { - return byName.get(name); - } - - private final short _thriftId; - private final String _fieldName; - - _Fields(short thriftId, String fieldName) { - _thriftId = thriftId; - _fieldName = fieldName; - } - - public short getThriftFieldId() { - return _thriftId; - } - - public String getFieldName() { - return _fieldName; - } - } - - // isset id assignments - private static final int __NUM_EXECUTORS_ISSET_ID = 0; - private static final int __NUM_TASKS_ISSET_ID = 1; - private static final int __EVENTLOG_PORT_ISSET_ID = 2; - private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.TOPOLOGY_ID,_Fields.TOPOLOGY_NAME,_Fields.NUM_EXECUTORS,_Fields.NUM_TASKS,_Fields.WINDOW_TO_STATS,_Fields.GSID_TO_INPUT_STATS,_Fields.SID_TO_OUTPUT_STATS,_Fields.EXEC_STATS,_Fields.ERRORS,_Fields.EVENTLOG_HOST,_Fields.EVENTLOG_PORT,_Fields.DEBUG_OPTIONS,_Fields.TOPOLOGY_STATUS,_Fields.RESOURCES_MAP}; - 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.COMPONENT_ID, new org.apache.thrift.meta_data.FieldMetaData("component_id", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.COMPONENT_TYPE, new org.apache.thrift.meta_data.FieldMetaData("component_type", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, ComponentType.class))); - tmpMap.put(_Fields.TOPOLOGY_ID, new org.apache.thrift.meta_data.FieldMetaData("topology_id", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.TOPOLOGY_NAME, new org.apache.thrift.meta_data.FieldMetaData("topology_name", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.NUM_EXECUTORS, new org.apache.thrift.meta_data.FieldMetaData("num_executors", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.NUM_TASKS, new org.apache.thrift.meta_data.FieldMetaData("num_tasks", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.WINDOW_TO_STATS, new org.apache.thrift.meta_data.FieldMetaData("window_to_stats", org.apache.thrift.TFieldRequirementType.OPTIONAL, - 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, ComponentAggregateStats.class)))); - tmpMap.put(_Fields.GSID_TO_INPUT_STATS, new org.apache.thrift.meta_data.FieldMetaData("gsid_to_input_stats", org.apache.thrift.TFieldRequirementType.OPTIONAL, - 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.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ComponentAggregateStats.class)))); - tmpMap.put(_Fields.SID_TO_OUTPUT_STATS, new org.apache.thrift.meta_data.FieldMetaData("sid_to_output_stats", org.apache.thrift.TFieldRequirementType.OPTIONAL, - 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, ComponentAggregateStats.class)))); - tmpMap.put(_Fields.EXEC_STATS, new org.apache.thrift.meta_data.FieldMetaData("exec_stats", org.apache.thrift.TFieldRequirementType.OPTIONAL, - 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, ExecutorAggregateStats.class)))); - tmpMap.put(_Fields.ERRORS, new org.apache.thrift.meta_data.FieldMetaData("errors", org.apache.thrift.TFieldRequirementType.OPTIONAL, - 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, ErrorInfo.class)))); - tmpMap.put(_Fields.EVENTLOG_HOST, new org.apache.thrift.meta_data.FieldMetaData("eventlog_host", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.EVENTLOG_PORT, new org.apache.thrift.meta_data.FieldMetaData("eventlog_port", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.DEBUG_OPTIONS, new org.apache.thrift.meta_data.FieldMetaData("debug_options", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, DebugOptions.class))); - tmpMap.put(_Fields.TOPOLOGY_STATUS, new org.apache.thrift.meta_data.FieldMetaData("topology_status", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.RESOURCES_MAP, new org.apache.thrift.meta_data.FieldMetaData("resources_map", org.apache.thrift.TFieldRequirementType.OPTIONAL, - 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.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ComponentPageInfo.class, metaDataMap); - } - - public ComponentPageInfo() { - } - - public ComponentPageInfo( - String component_id, - ComponentType component_type) - { - this(); - this.component_id = component_id; - this.component_type = component_type; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public ComponentPageInfo(ComponentPageInfo other) { - __isset_bitfield = other.__isset_bitfield; - if (other.is_set_component_id()) { - this.component_id = other.component_id; - } - if (other.is_set_component_type()) { - this.component_type = other.component_type; - } - if (other.is_set_topology_id()) { - this.topology_id = other.topology_id; - } - if (other.is_set_topology_name()) { - this.topology_name = other.topology_name; - } - this.num_executors = other.num_executors; - this.num_tasks = other.num_tasks; - if (other.is_set_window_to_stats()) { - Map<String,ComponentAggregateStats> __this__window_to_stats = new HashMap<String,ComponentAggregateStats>(other.window_to_stats.size()); - for (Map.Entry<String, ComponentAggregateStats> other_element : other.window_to_stats.entrySet()) { - - String other_element_key = other_element.getKey(); - ComponentAggregateStats other_element_value = other_element.getValue(); - - String __this__window_to_stats_copy_key = other_element_key; - - ComponentAggregateStats __this__window_to_stats_copy_value = new ComponentAggregateStats(other_element_value); - - __this__window_to_stats.put(__this__window_to_stats_copy_key, __this__window_to_stats_copy_value); - } - this.window_to_stats = __this__window_to_stats; - } - if (other.is_set_gsid_to_input_stats()) { - Map<GlobalStreamId,ComponentAggregateStats> __this__gsid_to_input_stats = new HashMap<GlobalStreamId,ComponentAggregateStats>(other.gsid_to_input_stats.size()); - for (Map.Entry<GlobalStreamId, ComponentAggregateStats> other_element : other.gsid_to_input_stats.entrySet()) { - - GlobalStreamId other_element_key = other_element.getKey(); - ComponentAggregateStats other_element_value = other_element.getValue(); - - GlobalStreamId __this__gsid_to_input_stats_copy_key = new GlobalStreamId(other_element_key); - - ComponentAggregateStats __this__gsid_to_input_stats_copy_value = new ComponentAggregateStats(other_element_value); - - __this__gsid_to_input_stats.put(__this__gsid_to_input_stats_copy_key, __this__gsid_to_input_stats_copy_value); - } - this.gsid_to_input_stats = __this__gsid_to_input_stats; - } - if (other.is_set_sid_to_output_stats()) { - Map<String,ComponentAggregateStats> __this__sid_to_output_stats = new HashMap<String,ComponentAggregateStats>(other.sid_to_output_stats.size()); - for (Map.Entry<String, ComponentAggregateStats> other_element : other.sid_to_output_stats.entrySet()) { - - String other_element_key = other_element.getKey(); - ComponentAggregateStats other_element_value = other_element.getValue(); - - String __this__sid_to_output_stats_copy_key = other_element_key; - - ComponentAggregateStats __this__sid_to_output_stats_copy_value = new ComponentAggregateStats(other_element_value); - - __this__sid_to_output_stats.put(__this__sid_to_output_stats_copy_key, __this__sid_to_output_stats_copy_value); - } - this.sid_to_output_stats = __this__sid_to_output_stats; - } - if (other.is_set_exec_stats()) { - List<ExecutorAggregateStats> __this__exec_stats = new ArrayList<ExecutorAggregateStats>(other.exec_stats.size()); - for (ExecutorAggregateStats other_element : other.exec_stats) { - __this__exec_stats.add(new ExecutorAggregateStats(other_element)); - } - this.exec_stats = __this__exec_stats; - } - if (other.is_set_errors()) { - List<ErrorInfo> __this__errors = new ArrayList<ErrorInfo>(other.errors.size()); - for (ErrorInfo other_element : other.errors) { - __this__errors.add(new ErrorInfo(other_element)); - } - this.errors = __this__errors; - } - if (other.is_set_eventlog_host()) { - this.eventlog_host = other.eventlog_host; - } - this.eventlog_port = other.eventlog_port; - if (other.is_set_debug_options()) { - this.debug_options = new DebugOptions(other.debug_options); - } - if (other.is_set_topology_status()) { - this.topology_status = other.topology_status; - } - if (other.is_set_resources_map()) { - Map<String,Double> __this__resources_map = new HashMap<String,Double>(other.resources_map); - this.resources_map = __this__resources_map; - } - } - - public ComponentPageInfo deepCopy() { - return new ComponentPageInfo(this); - } - - @Override - public void clear() { - this.component_id = null; - this.component_type = null; - this.topology_id = null; - this.topology_name = null; - set_num_executors_isSet(false); - this.num_executors = 0; - set_num_tasks_isSet(false); - this.num_tasks = 0; - this.window_to_stats = null; - this.gsid_to_input_stats = null; - this.sid_to_output_stats = null; - this.exec_stats = null; - this.errors = null; - this.eventlog_host = null; - set_eventlog_port_isSet(false); - this.eventlog_port = 0; - this.debug_options = null; - this.topology_status = null; - this.resources_map = null; - } - - public String get_component_id() { - return this.component_id; - } - - public void set_component_id(String component_id) { - this.component_id = component_id; - } - - public void unset_component_id() { - this.component_id = null; - } - - /** Returns true if field component_id is set (has been assigned a value) and false otherwise */ - public boolean is_set_component_id() { - return this.component_id != null; - } - - public void set_component_id_isSet(boolean value) { - if (!value) { - this.component_id = null; - } - } - - /** - * - * @see ComponentType - */ - public ComponentType get_component_type() { - return this.component_type; - } - - /** - * - * @see ComponentType - */ - public void set_component_type(ComponentType component_type) { - this.component_type = component_type; - } - - public void unset_component_type() { - this.component_type = null; - } - - /** Returns true if field component_type is set (has been assigned a value) and false otherwise */ - public boolean is_set_component_type() { - return this.component_type != null; - } - - public void set_component_type_isSet(boolean value) { - if (!value) { - this.component_type = null; - } - } - - public String get_topology_id() { - return this.topology_id; - } - - public void set_topology_id(String topology_id) { - this.topology_id = topology_id; - } - - public void unset_topology_id() { - this.topology_id = null; - } - - /** Returns true if field topology_id is set (has been assigned a value) and false otherwise */ - public boolean is_set_topology_id() { - return this.topology_id != null; - } - - public void set_topology_id_isSet(boolean value) { - if (!value) { - this.topology_id = null; - } - } - - public String get_topology_name() { - return this.topology_name; - } - - public void set_topology_name(String topology_name) { - this.topology_name = topology_name; - } - - public void unset_topology_name() { - this.topology_name = null; - } - - /** Returns true if field topology_name is set (has been assigned a value) and false otherwise */ - public boolean is_set_topology_name() { - return this.topology_name != null; - } - - public void set_topology_name_isSet(boolean value) { - if (!value) { - this.topology_name = null; - } - } - - public int get_num_executors() { - return this.num_executors; - } - - public void set_num_executors(int num_executors) { - this.num_executors = num_executors; - set_num_executors_isSet(true); - } - - public void unset_num_executors() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUM_EXECUTORS_ISSET_ID); - } - - /** Returns true if field num_executors is set (has been assigned a value) and false otherwise */ - public boolean is_set_num_executors() { - return EncodingUtils.testBit(__isset_bitfield, __NUM_EXECUTORS_ISSET_ID); - } - - public void set_num_executors_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUM_EXECUTORS_ISSET_ID, value); - } - - public int get_num_tasks() { - return this.num_tasks; - } - - public void set_num_tasks(int num_tasks) { - this.num_tasks = num_tasks; - set_num_tasks_isSet(true); - } - - public void unset_num_tasks() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUM_TASKS_ISSET_ID); - } - - /** Returns true if field num_tasks is set (has been assigned a value) and false otherwise */ - public boolean is_set_num_tasks() { - return EncodingUtils.testBit(__isset_bitfield, __NUM_TASKS_ISSET_ID); - } - - public void set_num_tasks_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUM_TASKS_ISSET_ID, value); - } - - public int get_window_to_stats_size() { - return (this.window_to_stats == null) ? 0 : this.window_to_stats.size(); - } - - public void put_to_window_to_stats(String key, ComponentAggregateStats val) { - if (this.window_to_stats == null) { - this.window_to_stats = new HashMap<String,ComponentAggregateStats>(); - } - this.window_to_stats.put(key, val); - } - - public Map<String,ComponentAggregateStats> get_window_to_stats() { - return this.window_to_stats; - } - - public void set_window_to_stats(Map<String,ComponentAggregateStats> window_to_stats) { - this.window_to_stats = window_to_stats; - } - - public void unset_window_to_stats() { - this.window_to_stats = null; - } - - /** Returns true if field window_to_stats is set (has been assigned a value) and false otherwise */ - public boolean is_set_window_to_stats() { - return this.window_to_stats != null; - } - - public void set_window_to_stats_isSet(boolean value) { - if (!value) { - this.window_to_stats = null; - } - } - - public int get_gsid_to_input_stats_size() { - return (this.gsid_to_input_stats == null) ? 0 : this.gsid_to_input_stats.size(); - } - - public void put_to_gsid_to_input_stats(GlobalStreamId key, ComponentAggregateStats val) { - if (this.gsid_to_input_stats == null) { - this.gsid_to_input_stats = new HashMap<GlobalStreamId,ComponentAggregateStats>(); - } - this.gsid_to_input_stats.put(key, val); - } - - public Map<GlobalStreamId,ComponentAggregateStats> get_gsid_to_input_stats() { - return this.gsid_to_input_stats; - } - - public void set_gsid_to_input_stats(Map<GlobalStreamId,ComponentAggregateStats> gsid_to_input_stats) { - this.gsid_to_input_stats = gsid_to_input_stats; - } - - public void unset_gsid_to_input_stats() { - this.gsid_to_input_stats = null; - } - - /** Returns true if field gsid_to_input_stats is set (has been assigned a value) and false otherwise */ - public boolean is_set_gsid_to_input_stats() { - return this.gsid_to_input_stats != null; - } - - public void set_gsid_to_input_stats_isSet(boolean value) { - if (!value) { - this.gsid_to_input_stats = null; - } - } - - public int get_sid_to_output_stats_size() { - return (this.sid_to_output_stats == null) ? 0 : this.sid_to_output_stats.size(); - } - - public void put_to_sid_to_output_stats(String key, ComponentAggregateStats val) { - if (this.sid_to_output_stats == null) { - this.sid_to_output_stats = new HashMap<String,ComponentAggregateStats>(); - } - this.sid_to_output_stats.put(key, val); - } - - public Map<String,ComponentAggregateStats> get_sid_to_output_stats() { - return this.sid_to_output_stats; - } - - public void set_sid_to_output_stats(Map<String,ComponentAggregateStats> sid_to_output_stats) { - this.sid_to_output_stats = sid_to_output_stats; - } - - public void unset_sid_to_output_stats() { - this.sid_to_output_stats = null; - } - - /** Returns true if field sid_to_output_stats is set (has been assigned a value) and false otherwise */ - public boolean is_set_sid_to_output_stats() { - return this.sid_to_output_stats != null; - } - - public void set_sid_to_output_stats_isSet(boolean value) { - if (!value) { - this.sid_to_output_stats = null; - } - } - - public int get_exec_stats_size() { - return (this.exec_stats == null) ? 0 : this.exec_stats.size(); - } - - public java.util.Iterator<ExecutorAggregateStats> get_exec_stats_iterator() { - return (this.exec_stats == null) ? null : this.exec_stats.iterator(); - } - - public void add_to_exec_stats(ExecutorAggregateStats elem) { - if (this.exec_stats == null) { - this.exec_stats = new ArrayList<ExecutorAggregateStats>(); - } - this.exec_stats.add(elem); - } - - public List<ExecutorAggregateStats> get_exec_stats() { - return this.exec_stats; - } - - public void set_exec_stats(List<ExecutorAggregateStats> exec_stats) { - this.exec_stats = exec_stats; - } - - public void unset_exec_stats() { - this.exec_stats = null; - } - - /** Returns true if field exec_stats is set (has been assigned a value) and false otherwise */ - public boolean is_set_exec_stats() { - return this.exec_stats != null; - } - - public void set_exec_stats_isSet(boolean value) { - if (!value) { - this.exec_stats = null; - } - } - - public int get_errors_size() { - return (this.errors == null) ? 0 : this.errors.size(); - } - - public java.util.Iterator<ErrorInfo> get_errors_iterator() { - return (this.errors == null) ? null : this.errors.iterator(); - } - - public void add_to_errors(ErrorInfo elem) { - if (this.errors == null) { - this.errors = new ArrayList<ErrorInfo>(); - } - this.errors.add(elem); - } - - public List<ErrorInfo> get_errors() { - return this.errors; - } - - public void set_errors(List<ErrorInfo> errors) { - this.errors = errors; - } - - public void unset_errors() { - this.errors = null; - } - - /** Returns true if field errors is set (has been assigned a value) and false otherwise */ - public boolean is_set_errors() { - return this.errors != null; - } - - public void set_errors_isSet(boolean value) { - if (!value) { - this.errors = null; - } - } - - public String get_eventlog_host() { - return this.eventlog_host; - } - - public void set_eventlog_host(String eventlog_host) { - this.eventlog_host = eventlog_host; - } - - public void unset_eventlog_host() { - this.eventlog_host = null; - } - - /** Returns true if field eventlog_host is set (has been assigned a value) and false otherwise */ - public boolean is_set_eventlog_host() { - return this.eventlog_host != null; - } - - public void set_eventlog_host_isSet(boolean value) { - if (!value) { - this.eventlog_host = null; - } - } - - public int get_eventlog_port() { - return this.eventlog_port; - } - - public void set_eventlog_port(int eventlog_port) { - this.eventlog_port = eventlog_port; - set_eventlog_port_isSet(true); - } - - public void unset_eventlog_port() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __EVENTLOG_PORT_ISSET_ID); - } - - /** Returns true if field eventlog_port is set (has been assigned a value) and false otherwise */ - public boolean is_set_eventlog_port() { - return EncodingUtils.testBit(__isset_bitfield, __EVENTLOG_PORT_ISSET_ID); - } - - public void set_eventlog_port_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __EVENTLOG_PORT_ISSET_ID, value); - } - - public DebugOptions get_debug_options() { - return this.debug_options; - } - - public void set_debug_options(DebugOptions debug_options) { - this.debug_options = debug_options; - } - - public void unset_debug_options() { - this.debug_options = null; - } - - /** Returns true if field debug_options is set (has been assigned a value) and false otherwise */ - public boolean is_set_debug_options() { - return this.debug_options != null; - } - - public void set_debug_options_isSet(boolean value) { - if (!value) { - this.debug_options = null; - } - } - - public String get_topology_status() { - return this.topology_status; - } - - public void set_topology_status(String topology_status) { - this.topology_status = topology_status; - } - - public void unset_topology_status() { - this.topology_status = null; - } - - /** Returns true if field topology_status is set (has been assigned a value) and false otherwise */ - public boolean is_set_topology_status() { - return this.topology_status != null; - } - - public void set_topology_status_isSet(boolean value) { - if (!value) { - this.topology_status = null; - } - } - - public int get_resources_map_size() { - return (this.resources_map == null) ? 0 : this.resources_map.size(); - } - - public void put_to_resources_map(String key, double val) { - if (this.resources_map == null) { - this.resources_map = new HashMap<String,Double>(); - } - this.resources_map.put(key, val); - } - - public Map<String,Double> get_resources_map() { - return this.resources_map; - } - - public void set_resources_map(Map<String,Double> resources_map) { - this.resources_map = resources_map; - } - - public void unset_resources_map() { - this.resources_map = null; - } - - /** Returns true if field resources_map is set (has been assigned a value) and false otherwise */ - public boolean is_set_resources_map() { - return this.resources_map != null; - } - - public void set_resources_map_isSet(boolean value) { - if (!value) { - this.resources_map = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case COMPONENT_ID: - if (value == null) { - unset_component_id(); - } else { - set_component_id((String)value); - } - break; - - case COMPONENT_TYPE: - if (value == null) { - unset_component_type(); - } else { - set_component_type((ComponentType)value); - } - break; - - case TOPOLOGY_ID: - if (value == null) { - unset_topology_id(); - } else { - set_topology_id((String)value); - } - break; - - case TOPOLOGY_NAME: - if (value == null) { - unset_topology_name(); - } else { - set_topology_name((String)value); - } - break; - - case NUM_EXECUTORS: - if (value == null) { - unset_num_executors(); - } else { - set_num_executors((Integer)value); - } - break; - - case NUM_TASKS: - if (value == null) { - unset_num_tasks(); - } else { - set_num_tasks((Integer)value); - } - break; - - case WINDOW_TO_STATS: - if (value == null) { - unset_window_to_stats(); - } else { - set_window_to_stats((Map<String,ComponentAggregateStats>)value); - } - break; - - case GSID_TO_INPUT_STATS: - if (value == null) { - unset_gsid_to_input_stats(); - } else { - set_gsid_to_input_stats((Map<GlobalStreamId,ComponentAggregateStats>)value); - } - break; - - case SID_TO_OUTPUT_STATS: - if (value == null) { - unset_sid_to_output_stats(); - } else { - set_sid_to_output_stats((Map<String,ComponentAggregateStats>)value); - } - break; - - case EXEC_STATS: - if (value == null) { - unset_exec_stats(); - } else { - set_exec_stats((List<ExecutorAggregateStats>)value); - } - break; - - case ERRORS: - if (value == null) { - unset_errors(); - } else { - set_errors((List<ErrorInfo>)value); - } - break; - - case EVENTLOG_HOST: - if (value == null) { - unset_eventlog_host(); - } else { - set_eventlog_host((String)value); - } - break; - - case EVENTLOG_PORT: - if (value == null) { - unset_eventlog_port(); - } else { - set_eventlog_port((Integer)value); - } - break; - - case DEBUG_OPTIONS: - if (value == null) { - unset_debug_options(); - } else { - set_debug_options((DebugOptions)value); - } - break; - - case TOPOLOGY_STATUS: - if (value == null) { - unset_topology_status(); - } else { - set_topology_status((String)value); - } - break; - - case RESOURCES_MAP: - if (value == null) { - unset_resources_map(); - } else { - set_resources_map((Map<String,Double>)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case COMPONENT_ID: - return get_component_id(); - - case COMPONENT_TYPE: - return get_component_type(); - - case TOPOLOGY_ID: - return get_topology_id(); - - case TOPOLOGY_NAME: - return get_topology_name(); - - case NUM_EXECUTORS: - return get_num_executors(); - - case NUM_TASKS: - return get_num_tasks(); - - case WINDOW_TO_STATS: - return get_window_to_stats(); - - case GSID_TO_INPUT_STATS: - return get_gsid_to_input_stats(); - - case SID_TO_OUTPUT_STATS: - return get_sid_to_output_stats(); - - case EXEC_STATS: - return get_exec_stats(); - - case ERRORS: - return get_errors(); - - case EVENTLOG_HOST: - return get_eventlog_host(); - - case EVENTLOG_PORT: - return get_eventlog_port(); - - case DEBUG_OPTIONS: - return get_debug_options(); - - case TOPOLOGY_STATUS: - return get_topology_status(); - - case RESOURCES_MAP: - return get_resources_map(); - - } - 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 COMPONENT_ID: - return is_set_component_id(); - case COMPONENT_TYPE: - return is_set_component_type(); - case TOPOLOGY_ID: - return is_set_topology_id(); - case TOPOLOGY_NAME: - return is_set_topology_name(); - case NUM_EXECUTORS: - return is_set_num_executors(); - case NUM_TASKS: - return is_set_num_tasks(); - case WINDOW_TO_STATS: - return is_set_window_to_stats(); - case GSID_TO_INPUT_STATS: - return is_set_gsid_to_input_stats(); - case SID_TO_OUTPUT_STATS: - return is_set_sid_to_output_stats(); - case EXEC_STATS: - return is_set_exec_stats(); - case ERRORS: - return is_set_errors(); - case EVENTLOG_HOST: - return is_set_eventlog_host(); - case EVENTLOG_PORT: - return is_set_eventlog_port(); - case DEBUG_OPTIONS: - return is_set_debug_options(); - case TOPOLOGY_STATUS: - return is_set_topology_status(); - case RESOURCES_MAP: - return is_set_resources_map(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof ComponentPageInfo) - return this.equals((ComponentPageInfo)that); - return false; - } - - public boolean equals(ComponentPageInfo that) { - if (that == null) - return false; - - boolean this_present_component_id = true && this.is_set_component_id(); - boolean that_present_component_id = true && that.is_set_component_id(); - if (this_present_component_id || that_present_component_id) { - if (!(this_present_component_id && that_present_component_id)) - return false; - if (!this.component_id.equals(that.component_id)) - return false; - } - - boolean this_present_component_type = true && this.is_set_component_type(); - boolean that_present_component_type = true && that.is_set_component_type(); - if (this_present_component_type || that_present_component_type) { - if (!(this_present_component_type && that_present_component_type)) - return false; - if (!this.component_type.equals(that.component_type)) - return false; - } - - boolean this_present_topology_id = true && this.is_set_topology_id(); - boolean that_present_topology_id = true && that.is_set_topology_id(); - if (this_present_topology_id || that_present_topology_id) { - if (!(this_present_topology_id && that_present_topology_id)) - return false; - if (!this.topology_id.equals(that.topology_id)) - return false; - } - - boolean this_present_topology_name = true && this.is_set_topology_name(); - boolean that_present_topology_name = true && that.is_set_topology_name(); - if (this_present_topology_name || that_present_topology_name) { - if (!(this_present_topology_name && that_present_topology_name)) - return false; - if (!this.topology_name.equals(that.topology_name)) - return false; - } - - boolean this_present_num_executors = true && this.is_set_num_executors(); - boolean that_present_num_executors = true && that.is_set_num_executors(); - if (this_present_num_executors || that_present_num_executors) { - if (!(this_present_num_executors && that_present_num_executors)) - return false; - if (this.num_executors != that.num_executors) - return false; - } - - boolean this_present_num_tasks = true && this.is_set_num_tasks(); - boolean that_present_num_tasks = true && that.is_set_num_tasks(); - if (this_present_num_tasks || that_present_num_tasks) { - if (!(this_present_num_tasks && that_present_num_tasks)) - return false; - if (this.num_tasks != that.num_tasks) - return false; - } - - boolean this_present_window_to_stats = true && this.is_set_window_to_stats(); - boolean that_present_window_to_stats = true && that.is_set_window_to_stats(); - if (this_present_window_to_stats || that_present_window_to_stats) { - if (!(this_present_window_to_stats && that_present_window_to_stats)) - return false; - if (!this.window_to_stats.equals(that.window_to_stats)) - return false; - } - - boolean this_present_gsid_to_input_stats = true && this.is_set_gsid_to_input_stats(); - boolean that_present_gsid_to_input_stats = true && that.is_set_gsid_to_input_stats(); - if (this_present_gsid_to_input_stats || that_present_gsid_to_input_stats) { - if (!(this_present_gsid_to_input_stats && that_present_gsid_to_input_stats)) - return false; - if (!this.gsid_to_input_stats.equals(that.gsid_to_input_stats)) - return false; - } - - boolean this_present_sid_to_output_stats = true && this.is_set_sid_to_output_stats(); - boolean that_present_sid_to_output_stats = true && that.is_set_sid_to_output_stats(); - if (this_present_sid_to_output_stats || that_present_sid_to_output_stats) { - if (!(this_present_sid_to_output_stats && that_present_sid_to_output_stats)) - return false; - if (!this.sid_to_output_stats.equals(that.sid_to_output_stats)) - return false; - } - - boolean this_present_exec_stats = true && this.is_set_exec_stats(); - boolean that_present_exec_stats = true && that.is_set_exec_stats(); - if (this_present_exec_stats || that_present_exec_stats) { - if (!(this_present_exec_stats && that_present_exec_stats)) - return false; - if (!this.exec_stats.equals(that.exec_stats)) - return false; - } - - boolean this_present_errors = true && this.is_set_errors(); - boolean that_present_errors = true && that.is_set_errors(); - if (this_present_errors || that_present_errors) { - if (!(this_present_errors && that_present_errors)) - return false; - if (!this.errors.equals(that.errors)) - return false; - } - - boolean this_present_eventlog_host = true && this.is_set_eventlog_host(); - boolean that_present_eventlog_host = true && that.is_set_eventlog_host(); - if (this_present_eventlog_host || that_present_eventlog_host) { - if (!(this_present_eventlog_host && that_present_eventlog_host)) - return false; - if (!this.eventlog_host.equals(that.eventlog_host)) - return false; - } - - boolean this_present_eventlog_port = true && this.is_set_eventlog_port(); - boolean that_present_eventlog_port = true && that.is_set_eventlog_port(); - if (this_present_eventlog_port || that_present_eventlog_port) { - if (!(this_present_eventlog_port && that_present_eventlog_port)) - return false; - if (this.eventlog_port != that.eventlog_port) - return false; - } - - boolean this_present_debug_options = true && this.is_set_debug_options(); - boolean that_present_debug_options = true && that.is_set_debug_options(); - if (this_present_debug_options || that_present_debug_options) { - if (!(this_present_debug_options && that_present_debug_options)) - return false; - if (!this.debug_options.equals(that.debug_options)) - return false; - } - - boolean this_present_topology_status = true && this.is_set_topology_status(); - boolean that_present_topology_status = true && that.is_set_topology_status(); - if (this_present_topology_status || that_present_topology_status) { - if (!(this_present_topology_status && that_present_topology_status)) - return false; - if (!this.topology_status.equals(that.topology_status)) - return false; - } - - boolean this_present_resources_map = true && this.is_set_resources_map(); - boolean that_present_resources_map = true && that.is_set_resources_map(); - if (this_present_resources_map || that_present_resources_map) { - if (!(this_present_resources_map && that_present_resources_map)) - return false; - if (!this.resources_map.equals(that.resources_map)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_component_id = true && (is_set_component_id()); - list.add(present_component_id); - if (present_component_id) - list.add(component_id); - - boolean present_component_type = true && (is_set_component_type()); - list.add(present_component_type); - if (present_component_type) - list.add(component_type.getValue()); - - boolean present_topology_id = true && (is_set_topology_id()); - list.add(present_topology_id); - if (present_topology_id) - list.add(topology_id); - - boolean present_topology_name = true && (is_set_topology_name()); - list.add(present_topology_name); - if (present_topology_name) - list.add(topology_name); - - boolean present_num_executors = true && (is_set_num_executors()); - list.add(present_num_executors); - if (present_num_executors) - list.add(num_executors); - - boolean present_num_tasks = true && (is_set_num_tasks()); - list.add(present_num_tasks); - if (present_num_tasks) - list.add(num_tasks); - - boolean present_window_to_stats = true && (is_set_window_to_stats()); - list.add(present_window_to_stats); - if (present_window_to_stats) - list.add(window_to_stats); - - boolean present_gsid_to_input_stats = true && (is_set_gsid_to_input_stats()); - list.add(present_gsid_to_input_stats); - if (present_gsid_to_input_stats) - list.add(gsid_to_input_stats); - - boolean present_sid_to_output_stats = true && (is_set_sid_to_output_stats()); - list.add(present_sid_to_output_stats); - if (present_sid_to_output_stats) - list.add(sid_to_output_stats); - - boolean present_exec_stats = true && (is_set_exec_stats()); - list.add(present_exec_stats); - if (present_exec_stats) - list.add(exec_stats); - - boolean present_errors = true && (is_set_errors()); - list.add(present_errors); - if (present_errors) - list.add(errors); - - boolean present_eventlog_host = true && (is_set_eventlog_host()); - list.add(present_eventlog_host); - if (present_eventlog_host) - list.add(eventlog_host); - - boolean present_eventlog_port = true && (is_set_eventlog_port()); - list.add(present_eventlog_port); - if (present_eventlog_port) - list.add(eventlog_port); - - boolean present_debug_options = true && (is_set_debug_options()); - list.add(present_debug_options); - if (present_debug_options) - list.add(debug_options); - - boolean present_topology_status = true && (is_set_topology_status()); - list.add(present_topology_status); - if (present_topology_status) - list.add(topology_status); - - boolean present_resources_map = true && (is_set_resources_map()); - list.add(present_resources_map); - if (present_resources_map) - list.add(resources_map); - - return list.hashCode(); - } - - @Override - public int compareTo(ComponentPageInfo other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(is_set_component_id()).compareTo(other.is_set_component_id()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_component_id()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.component_id, other.component_id); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_component_type()).compareTo(other.is_set_component_type()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_component_type()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.component_type, other.component_type); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_topology_id()).compareTo(other.is_set_topology_id()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_topology_id()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.topology_id, other.topology_id); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_topology_name()).compareTo(other.is_set_topology_name()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_topology_name()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.topology_name, other.topology_name); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_num_executors()).compareTo(other.is_set_num_executors()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_num_executors()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.num_executors, other.num_executors); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_num_tasks()).compareTo(other.is_set_num_tasks()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_num_tasks()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.num_tasks, other.num_tasks); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_window_to_stats()).compareTo(other.is_set_window_to_stats()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_window_to_stats()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.window_to_stats, other.window_to_stats); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_gsid_to_input_stats()).compareTo(other.is_set_gsid_to_input_stats()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_gsid_to_input_stats()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.gsid_to_input_stats, other.gsid_to_input_stats); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_sid_to_output_stats()).compareTo(other.is_set_sid_to_output_stats()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_sid_to_output_stats()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sid_to_output_stats, other.sid_to_output_stats); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_exec_stats()).compareTo(other.is_set_exec_stats()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_exec_stats()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.exec_stats, other.exec_stats); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_errors()).compareTo(other.is_set_errors()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_errors()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.errors, other.errors); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_eventlog_host()).compareTo(other.is_set_eventlog_host()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_eventlog_host()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.eventlog_host, other.eventlog_host); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_eventlog_port()).compareTo(other.is_set_eventlog_port()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_eventlog_port()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.eventlog_port, other.eventlog_port); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_debug_options()).compareTo(other.is_set_debug_options()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_debug_options()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.debug_options, other.debug_options); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_topology_status()).compareTo(other.is_set_topology_status()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_topology_status()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.topology_status, other.topology_status); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_resources_map()).compareTo(other.is_set_resources_map()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_resources_map()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.resources_map, other.resources_map); - 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("ComponentPageInfo("); - boolean first = true; - - sb.append("component_id:"); - if (this.component_id == null) { - sb.append("null"); - } else { - sb.append(this.component_id); - } - first = false; - if (!first) sb.append(", "); - sb.append("component_type:"); - if (this.component_type == null) { - sb.append("null"); - } else { - sb.append(this.component_type); - } - first = false; - if (is_set_topology_id()) { - if (!first) sb.append(", "); - sb.append("topology_id:"); - if (this.topology_id == null) { - sb.append("null"); - } else { - sb.append(this.topology_id); - } - first = false; - } - if (is_set_topology_name()) { - if (!first) sb.append(", "); - sb.append("topology_name:"); - if (this.topology_name == null) { - sb.append("null"); - } else { - sb.append(this.topology_name); - } - first = false; - } - if (is_set_num_executors()) { - if (!first) sb.append(", "); - sb.append("num_executors:"); - sb.append(this.num_executors); - first = false; - } - if (is_set_num_tasks()) { - if (!first) sb.append(", "); - sb.append("num_tasks:"); - sb.append(this.num_tasks); - first = false; - } - if (is_set_window_to_stats()) { - if (!first) sb.append(", "); - sb.append("window_to_stats:"); - if (this.window_to_stats == null) { - sb.append("null"); - } else { - sb.append(this.window_to_stats); - } - first = false; - } - if (is_set_gsid_to_input_stats()) { - if (!first) sb.append(", "); - sb.append("gsid_to_input_stats:"); - if (this.gsid_to_input_stats == null) { - sb.append("null"); - } else { - sb.append(this.gsid_to_input_stats); - } - first = false; - } - if (is_set_sid_to_output_stats()) { - if (!first) sb.append(", "); - sb.append("sid_to_output_stats:"); - if (this.sid_to_output_stats == null) { - sb.append("null"); - } else { - sb.append(this.sid_to_output_stats); - } - first = false; - } - if (is_set_exec_stats()) { - if (!first) sb.append(", "); - sb.append("exec_stats:"); - if (this.exec_stats == null) { - sb.append("null"); - } else { - sb.append(this.exec_stats); - } - first = false; - } - if (is_set_errors()) { - if (!first) sb.append(", "); - sb.append("errors:"); - if (this.errors == null) { - sb.append("null"); - } else { - sb.append(this.errors); - } - first = false; - } - if (is_set_eventlog_host()) { - if (!first) sb.append(", "); - sb.append("eventlog_host:"); - if (this.eventlog_host == null) { - sb.append("null"); - } else { - sb.append(this.eventlog_host); - } - first = false; - } - if (is_set_eventlog_port()) { - if (!first) sb.append(", "); - sb.append("eventlog_port:"); - sb.append(this.eventlog_port); - first = false; - } - if (is_set_debug_options()) { - if (!first) sb.append(", "); - sb.append("debug_options:"); - if (this.debug_options == null) { - sb.append("null"); - } else { - sb.append(this.debug_options); - } - first = false; - } - if (is_set_topology_status()) { - if (!first) sb.append(", "); - sb.append("topology_status:"); - if (this.topology_status == null) { - sb.append("null"); - } else { - sb.append(this.topology_status); - } - first = false; - } - if (is_set_resources_map()) { - if (!first) sb.append(", "); - sb.append("resources_map:"); - if (this.resources_map == null) { - sb.append("null"); - } else { - sb.append(this.resources_map); - } - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (!is_set_component_id()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'component_id' is unset! Struct:" + toString()); - } - - if (!is_set_component_type()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'component_type' is unset! Struct:" + toString()); - } - - // check for sub-struct validity - if (debug_options != null) { - debug_options.validate(); - } - } - - private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { - try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { - try { - // 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 ComponentPageInfoStandardSchemeFactory implements SchemeFactory { - public ComponentPageInfoStandardScheme getScheme() { - return new ComponentPageInfoStandardScheme(); - } - } - - private static class ComponentPageInfoStandardScheme extends StandardScheme<ComponentPageInfo> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, ComponentPageInfo 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: // COMPONENT_ID - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.component_id = iprot.readString(); - struct.set_component_id_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // COMPONENT_TYPE - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.component_type = org.apache.storm.generated.ComponentType.findByValue(iprot.readI32()); - struct.set_component_type_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // TOPOLOGY_ID - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.topology_id = iprot.readString(); - struct.set_topology_id_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 4: // TOPOLOGY_NAME - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.topology_name = iprot.readString(); - struct.set_topology_name_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 5: // NUM_EXECUTORS - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.num_executors = iprot.readI32(); - struct.set_num_executors_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 6: // NUM_TASKS - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.num_tasks = iprot.readI32(); - struct.set_num_tasks_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 7: // WINDOW_TO_STATS - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map482 = iprot.readMapBegin(); - struct.window_to_stats = new HashMap<String,ComponentAggregateStats>(2*_map482.size); - String _key483; - ComponentAggregateStats _val484; - for (int _i485 = 0; _i485 < _map482.size; ++_i485) - { - _key483 = iprot.readString(); - _val484 = new ComponentAggregateStats(); - _val484.read(iprot); - struct.window_to_stats.put(_key483, _val484); - } - iprot.readMapEnd(); - } - struct.set_window_to_stats_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 8: // GSID_TO_INPUT_STATS - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map486 = iprot.readMapBegin(); - struct.gsid_to_input_stats = new HashMap<GlobalStreamId,ComponentAggregateStats>(2*_map486.size); - GlobalStreamId _key487; - ComponentAggregateStats _val488; - for (int _i489 = 0; _i489 < _map486.size; ++_i489) - { - _key487 = new GlobalStreamId(); - _key487.read(iprot); - _val488 = new ComponentAggregateStats(); - _val488.read(iprot); - struct.gsid_to_input_stats.put(_key487, _val488); - } - iprot.readMapEnd(); - } - struct.set_gsid_to_input_stats_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 9: // SID_TO_OUTPUT_STATS - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map490 = iprot.readMapBegin(); - struct.sid_to_output_stats = new HashMap<String,ComponentAggregateStats>(2*_map490.size); - String _key491; - ComponentAggregateStats _val492; - for (int _i493 = 0; _i493 < _map490.size; ++_i493) - { - _key491 = iprot.readString(); - _val492 = new ComponentAggregateStats(); - _val492.read(iprot); - struct.sid_to_output_stats.put(_key491, _val492); - } - iprot.readMapEnd(); - } - struct.set_sid_to_output_stats_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 10: // EXEC_STATS - if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { - { - org.apache.thrift.protocol.TList _list494 = iprot.readListBegin(); - struct.exec_stats = new ArrayList<ExecutorAggregateStats>(_list494.size); - ExecutorAggregateStats _elem495; - for (int _i496 = 0; _i496 < _list494.size; ++_i496) - { - _elem495 = new ExecutorAggregateStats(); - _elem495.read(iprot); - struct.exec_stats.add(_elem495); - } - iprot.readListEnd(); - } - struct.set_exec_stats_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 11: // ERRORS - if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { - { - org.apache.thrift.protocol.TList _list497 = iprot.readListBegin(); - struct.errors = new ArrayList<ErrorInfo>(_list497.size); - ErrorInfo _elem498; - for (int _i499 = 0; _i499 < _list497.size; ++_i499) - { - _elem498 = new ErrorInfo(); - _elem498.read(iprot); - struct.errors.add(_elem498); - } - iprot.readListEnd(); - } - struct.set_errors_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 12: // EVENTLOG_HOST - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.eventlog_host = iprot.readString(); - struct.set_eventlog_host_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 13: // EVENTLOG_PORT - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.eventlog_port = iprot.readI32(); - struct.set_eventlog_port_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 14: // DEBUG_OPTIONS - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.debug_options = new DebugOptions(); - struct.debug_options.read(iprot); - struct.set_debug_options_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 15: // TOPOLOGY_STATUS - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.topology_status = iprot.readString(); - struct.set_topology_status_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 16: // RESOURCES_MAP - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map500 = iprot.readMapBegin(); - struct.resources_map = new HashMap<String,Double>(2*_map500.size); - String _key501; - double _val502; - for (int _i503 = 0; _i503 < _map500.size; ++_i503) - { - _key501 = iprot.readString(); - _val502 = iprot.readDouble(); - struct.resources_map.put(_key501, _val502); - } - iprot.readMapEnd(); - } - struct.set_resources_map_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, ComponentPageInfo struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.component_id != null) { - oprot.writeFieldBegin(COMPONENT_ID_FIELD_DESC); - oprot.writeString(struct.component_id); - oprot.writeFieldEnd(); - } - if (struct.component_type != null) { - oprot.writeFieldBegin(COMPONENT_TYPE_FIELD_DESC); - oprot.writeI32(struct.component_type.getValue()); - oprot.writeFieldEnd(); - } - if (struct.topology_id != null) { - if (struct.is_set_topology_id()) { - oprot.writeFieldBegin(TOPOLOGY_ID_FIELD_DESC); - oprot.writeString(struct.topology_id); - oprot.writeFieldEnd(); - } - } - if (struct.topology_name != null) { - if (struct.is_set_topology_name()) { - oprot.writeFieldBegin(TOPOLOGY_NAME_FIELD_DESC); - oprot.writeString(struct.topology_name); - oprot.writeFieldEnd(); - } - } - if (struct.is_set_num_executors()) { - oprot.writeFieldBegin(NUM_EXECUTORS_FIELD_DESC); - oprot.writeI32(struct.num_executors); - oprot.writeFieldEnd(); - } - if (struct.is_set_num_tasks()) { - oprot.writeFieldBegin(NUM_TASKS_FIELD_DESC); - oprot.writeI32(struct.num_tasks); - oprot.writeFieldEnd(); - } - if (struct.window_to_stats != null) { - if (struct.is_set_window_to_stats()) { - oprot.writeFieldBegin(WINDOW_TO_STATS_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.window_to_stats.size())); - for (Map.Entry<String, ComponentAggregateStats> _iter504 : struct.window_to_stats.entrySet()) - { - oprot.writeString(_iter504.getKey()); - _iter504.getValue().write(oprot); - } - oprot.writeMapEnd(); - } - oprot.writeFieldEnd(); - } - } - if (struct.gsid_to_input_stats != null) { - if (struct.is_set_gsid_to_input_stats()) { - oprot.writeFieldBegin(GSID_TO_INPUT_STATS_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.STRUCT, struct.gsid_to_input_stats.size())); - for (Map.Entry<GlobalStreamId, ComponentAggregateStats> _iter505 : struct.gsid_to_input_stats.entrySet()) - { - _iter505.getKey().write(oprot); - _iter505.getValue().write(oprot); - } - oprot.writeMapEnd(); - } - oprot.writeFieldEnd(); - } - } - if (struct.sid_to_output_stats != null) { - if (struct.is_set_sid_to_output_stats()) { - oprot.writeFieldBegin(SID_TO_OUTPUT_STATS_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.sid_to_output_stats.size())); - for (Map.Entry<String, ComponentAggregateStats> _iter506 : struct.sid_to_output_stats.entrySet()) - { - oprot.writeString(_iter506.getKey()); - _iter506.getValue().write(oprot); - } - oprot.writeMapEnd(); - } - oprot.writeFieldEnd(); - } - } - if (struct.exec_stats != null) { - if (struct.is_set_exec_stats()) { - oprot.writeFieldBegin(EXEC_STATS_FIELD_DESC); - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.exec_stats.size())); - for (ExecutorAggregateStats _iter507 : struct.exec_stats) - { - _iter507.write(oprot); - } - oprot.writeListEnd(); - } - oprot.writeFieldEnd(); - } - } - if (struct.errors != null) { - if (struct.is_set_errors()) { - oprot.writeFieldBegin(ERRORS_FIELD_DESC); - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.errors.size())); - for (ErrorInfo _iter508 : struct.errors) - { - _iter508.write(oprot); - } - oprot.writeListEnd(); - } - oprot.writeFieldEnd(); - } - } - if (struct.eventlog_host != null) { - if (struct.is_set_eventlog_host()) { - oprot.writeFieldBegin(EVENTLOG_HOST_FIELD_DESC); - oprot.writeString(struct.eventlog_host); - oprot.writeFieldEnd(); - } - } - if (struct.is_set_eventlog_port()) { - oprot.writeFieldBegin(EVENTLOG_PORT_FIELD_DESC); - oprot.writeI32(struct.eventlog_port); - oprot.writeFieldEnd(); - } - if (struct.debug_options != null) { - if (struct.is_set_debug_options()) { - oprot.writeFieldBegin(DEBUG_OPTIONS_FIELD_DESC); - struct.debug_options.write(oprot); - oprot.writeFieldEnd(); - } - } - if (struct.topology_status != null) { - if (struct.is_set_topology_status()) { - oprot.writeFieldBegin(TOPOLOGY_STATUS_FIELD_DESC); - oprot.writeString(struct.topology_status); - oprot.writeFieldEnd(); - } - } - if (struct.resources_map != null) { - if (struct.is_set_resources_map()) { - oprot.writeFieldBegin(RESOURCES_MAP_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.DOUBLE, struct.resources_map.size())); - for (Map.Entry<String, Double> _iter509 : struct.resources_map.entrySet()) - { - oprot.writeString(_iter509.getKey()); - oprot.writeDouble(_iter509.getValue()); - } - oprot.writeMapEnd(); - } - oprot.writeFieldEnd(); - } - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class ComponentPageInfoTupleSchemeFactory implements SchemeFactory { - public ComponentPageInfoTupleScheme getScheme() { - return new ComponentPageInfoTupleScheme(); - } - } - - private static class ComponentPageInfoTupleScheme extends TupleScheme<ComponentPageInfo> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, ComponentPageInfo struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - oprot.writeString(struct.component_id); - oprot.writeI32(struct.component_type.getValue()); - BitSet optionals = new BitSet(); - if (struct.is_set_topology_id()) { - optionals.set(0); - } - if (struct.is_set_topology_name()) { - optionals.set(1); - } - if (struct.is_set_num_executors()) { - optionals.set(2); - } - if (struct.is_set_num_tasks()) { - optionals.set(3); - } - if (struct.is_set_window_to_stats()) { - optionals.set(4); - } - if (struct.is_set_gsid_to_input_stats()) { - optionals.set(5); - } - if (struct.is_set_sid_to_output_stats()) { - optionals.set(6); - } - if (struct.is_set_exec_stats()) { - optionals.set(7); - } - if (struct.is_set_errors()) { - optionals.set(8); - } - if (struct.is_set_eventlog_host()) { - optionals.set(9); - } - if (struct.is_set_eventlog_port()) { - optionals.set(10); - } - if (struct.is_set_debug_options()) { - optionals.set(11); - } - if (struct.is_set_topology_status()) { - optionals.set(12); - } - if (struct.is_set_resources_map()) { - optionals.set(13); - } - oprot.writeBitSet(optionals, 14); - if (struct.is_set_topology_id()) { - oprot.writeString(struct.topology_id); - } - if (struct.is_set_topology_name()) { - oprot.writeString(struct.topology_name); - } - if (struct.is_set_num_executors()) { - oprot.writeI32(struct.num_executors); - } - if (struct.is_set_num_tasks()) { - oprot.writeI32(struct.num_tasks); - } - if (struct.is_set_window_to_stats()) { - { - oprot.writeI32(struct.window_to_stats.size()); - for (Map.Entry<String, ComponentAggregateStats> _iter510 : struct.window_to_stats.entrySet()) - { - oprot.writeString(_iter510.getKey()); - _iter510.getValue().write(oprot); - } - } - } - if (struct.is_set_gsid_to_input_stats()) { - { - oprot.writeI32(struct.gsid_to_input_stats.size()); - for (Map.Entry<GlobalStreamId, ComponentAggregateStats> _iter511 : struct.gsid_to_input_stats.entrySet()) - { - _iter511.getKey().write(oprot); - _iter511.getValue().write(oprot); - } - } - } - if (struct.is_set_sid_to_output_stats()) { - { - oprot.writeI32(struct.sid_to_output_stats.size()); - for (Map.Entry<String, ComponentAggregateStats> _iter512 : struct.sid_to_output_stats.entrySet()) - { - oprot.writeString(_iter512.getKey()); - _iter512.getValue().write(oprot); - } - } - } - if (struct.is_set_exec_stats()) { - { - oprot.writeI32(struct.exec_stats.size()); - for (ExecutorAggregateStats _iter513 : struct.exec_stats) - { - _iter513.write(oprot); - } - } - } - if (struct.is_set_errors()) { - { - oprot.writeI32(struct.errors.size()); - for (ErrorInfo _iter514 : struct.errors) - { - _iter514.write(oprot); - } - } - } - if (struct.is_set_eventlog_host()) { - oprot.writeString(struct.eventlog_host); - } - if (struct.is_set_eventlog_port()) { - oprot.writeI32(struct.eventlog_port); - } - if (struct.is_set_debug_options()) { - struct.debug_options.write(oprot); - } - if (struct.is_set_topology_status()) { - oprot.writeString(struct.topology_status); - } - if (struct.is_set_resources_map()) { - { - oprot.writeI32(struct.resources_map.size()); - for (Map.Entry<String, Double> _iter515 : struct.resources_map.entrySet()) - { - oprot.writeString(_iter515.getKey()); - oprot.writeDouble(_iter515.getValue()); - } - } - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, ComponentPageInfo struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - struct.component_id = iprot.readString(); - struct.set_component_id_isSet(true); - struct.component_type = org.apache.storm.generated.ComponentType.findByValue(iprot.readI32()); - struct.set_component_type_isSet(true); - BitSet incoming = iprot.readBitSet(14); - if (incoming.get(0)) { - struct.topology_id = iprot.readString(); - struct.set_topology_id_isSet(true); - } - if (incoming.get(1)) { - struct.topology_name = iprot.readString(); - struct.set_topology_name_isSet(true); - } - if (incoming.get(2)) { - struct.num_executors = iprot.readI32(); - struct.set_num_executors_isSet(true); - } - if (incoming.get(3)) { - struct.num_tasks = iprot.readI32(); - struct.set_num_tasks_isSet(true); - } - if (incoming.get(4)) { - { - org.apache.thrift.protocol.TMap _map516 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.window_to_stats = new HashMap<String,ComponentAggregateStats>(2*_map516.size); - String _key517; - ComponentAggregateStats _val518; - for (int _i519 = 0; _i519 < _map516.size; ++_i519) - { - _key517 = iprot.readString(); - _val518 = new ComponentAggregateStats(); - _val518.read(iprot); - struct.window_to_stats.put(_key517, _val518); - } - } - struct.set_window_to_stats_isSet(true); - } - if (incoming.get(5)) { - { - org.apache.thrift.protocol.TMap _map520 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.gsid_to_input_stats = new HashMap<GlobalStreamId,ComponentAggregateStats>(2*_map520.size); - GlobalStreamId _key521; - ComponentAggregateStats _val522; - for (int _i523 = 0; _i523 < _map520.size; ++_i523) - { - _key521 = new GlobalStreamId(); - _key521.read(iprot); - _val522 = new ComponentAggregateStats(); - _val522.read(iprot); - struct.gsid_to_input_stats.put(_key521, _val522); - } - } - struct.set_gsid_to_input_stats_isSet(true); - } - if (incoming.get(6)) { - { - org.apache.thrift.protocol.TMap _map524 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.sid_to_output_stats = new HashMap<String,ComponentAggregateStats>(2*_map524.size); - String _key525; - ComponentAggregateStats _val526; - for (int _i527 = 0; _i527 < _map524.size; ++_i527) - { - _key525 = iprot.readString(); - _val526 = new ComponentAggregateStats(); - _val526.read(iprot); - struct.sid_to_output_stats.put(_key525, _val526); - } - } - struct.set_sid_to_output_stats_isSet(true); - } - if (incoming.get(7)) { - { - org.apache.thrift.protocol.TList _list528 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.exec_stats = new ArrayList<ExecutorAggregateStats>(_list528.size); - ExecutorAggregateStats _elem529; - for (int _i530 = 0; _i530 < _list528.size; ++_i530) - { - _elem529 = new ExecutorAggregateStats(); - _elem529.read(iprot); - struct.exec_stats.add(_elem529); - } - } - struct.set_exec_stats_isSet(true); - } - if (incoming.get(8)) { - { - org.apache.thrift.protocol.TList _list531 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.errors = new ArrayList<ErrorInfo>(_list531.size); - ErrorInfo _elem532; - for (int _i533 = 0; _i533 < _list531.size; ++_i533) - { - _elem532 = new ErrorInfo(); - _elem532.read(iprot); - struct.errors.add(_elem532); - } - } - struct.set_errors_isSet(true); - } - if (incoming.get(9)) { - struct.eventlog_host = iprot.readString(); - struct.set_eventlog_host_isSet(true); - } - if (incoming.get(10)) { - struct.eventlog_port = iprot.readI32(); - struct.set_eventlog_port_isSet(true); - } - if (incoming.get(11)) { - struct.debug_options = new DebugOptions(); - struct.debug_options.read(iprot); - struct.set_debug_options_isSet(true); - } - if (incoming.get(12)) { - struct.topology_status = iprot.readString(); - struct.set_topology_status_isSet(true); - } - if (incoming.get(13)) { - { - org.apache.thrift.protocol.TMap _map534 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.DOUBLE, iprot.readI32()); - struct.resources_map = new HashMap<String,Double>(2*_map534.size); - String _key535; - double _val536; - for (int _i537 = 0; _i537 < _map534.size; ++_i537) - { - _key535 = iprot.readString(); - _val536 = iprot.readDouble(); - struct.resources_map.put(_key535, _val536); - } - } - struct.set_resou
<TRUNCATED>
