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 2015/10/05 23:00:40 UTC
[08/37] storm git commit: Aggregate topo stats on nimbus, not ui
http://git-wip-us.apache.org/repos/asf/storm/blob/a16b50c9/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
new file mode 100644
index 0000000..bb7c30b
--- /dev/null
+++ b/storm-core/src/jvm/backtype/storm/generated/ComponentPageInfo.java
@@ -0,0 +1,1772 @@
+/**
+ * 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.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package backtype.storm.generated;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-5-14")
+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)513);
+ 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)514);
+ 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)515);
+ 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)516);
+ 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)517);
+ 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)518);
+ 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)519);
+ 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)520);
+ 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)521);
+
+ 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
+
+ /** 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)513, "topology_id"),
+ TOPOLOGY_NAME((short)514, "topology_name"),
+ NUM_EXECUTORS((short)515, "num_executors"),
+ NUM_TASKS((short)516, "num_tasks"),
+ WINDOW_TO_STATS((short)517, "window_to_stats"),
+ GSID_TO_INPUT_STATS((short)518, "gsid_to_input_stats"),
+ SID_TO_OUTPUT_STATS((short)519, "sid_to_output_stats"),
+ EXEC_STATS((short)520, "exec_stats"),
+ ERRORS((short)521, "errors");
+
+ 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 513: // TOPOLOGY_ID
+ return TOPOLOGY_ID;
+ case 514: // TOPOLOGY_NAME
+ return TOPOLOGY_NAME;
+ case 515: // NUM_EXECUTORS
+ return NUM_EXECUTORS;
+ case 516: // NUM_TASKS
+ return NUM_TASKS;
+ case 517: // WINDOW_TO_STATS
+ return WINDOW_TO_STATS;
+ case 518: // GSID_TO_INPUT_STATS
+ return GSID_TO_INPUT_STATS;
+ case 519: // SID_TO_OUTPUT_STATS
+ return SID_TO_OUTPUT_STATS;
+ case 520: // EXEC_STATS
+ return EXEC_STATS;
+ case 521: // ERRORS
+ return ERRORS;
+ 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 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};
+ 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))));
+ 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;
+ }
+ }
+
+ 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;
+ }
+
+ 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 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;
+
+ }
+ }
+
+ 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 Integer.valueOf(get_num_executors());
+
+ case NUM_TASKS:
+ return Integer.valueOf(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();
+
+ }
+ 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();
+ }
+ 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;
+ }
+
+ 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);
+
+ 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;
+ }
+ }
+ 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;
+ }
+ 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
+ }
+
+ 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 = backtype.storm.generated.ComponentType.findByValue(iprot.readI32());
+ struct.set_component_type_isSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 513: // 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 514: // 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 515: // 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 516: // 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 517: // WINDOW_TO_STATS
+ if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
+ {
+ org.apache.thrift.protocol.TMap _map386 = iprot.readMapBegin();
+ struct.window_to_stats = new HashMap<String,ComponentAggregateStats>(2*_map386.size);
+ String _key387;
+ ComponentAggregateStats _val388;
+ for (int _i389 = 0; _i389 < _map386.size; ++_i389)
+ {
+ _key387 = iprot.readString();
+ _val388 = new ComponentAggregateStats();
+ _val388.read(iprot);
+ struct.window_to_stats.put(_key387, _val388);
+ }
+ iprot.readMapEnd();
+ }
+ struct.set_window_to_stats_isSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 518: // GSID_TO_INPUT_STATS
+ if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
+ {
+ org.apache.thrift.protocol.TMap _map390 = iprot.readMapBegin();
+ struct.gsid_to_input_stats = new HashMap<GlobalStreamId,ComponentAggregateStats>(2*_map390.size);
+ GlobalStreamId _key391;
+ ComponentAggregateStats _val392;
+ for (int _i393 = 0; _i393 < _map390.size; ++_i393)
+ {
+ _key391 = new GlobalStreamId();
+ _key391.read(iprot);
+ _val392 = new ComponentAggregateStats();
+ _val392.read(iprot);
+ struct.gsid_to_input_stats.put(_key391, _val392);
+ }
+ iprot.readMapEnd();
+ }
+ struct.set_gsid_to_input_stats_isSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 519: // SID_TO_OUTPUT_STATS
+ if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
+ {
+ org.apache.thrift.protocol.TMap _map394 = iprot.readMapBegin();
+ struct.sid_to_output_stats = new HashMap<String,ComponentAggregateStats>(2*_map394.size);
+ String _key395;
+ ComponentAggregateStats _val396;
+ for (int _i397 = 0; _i397 < _map394.size; ++_i397)
+ {
+ _key395 = iprot.readString();
+ _val396 = new ComponentAggregateStats();
+ _val396.read(iprot);
+ struct.sid_to_output_stats.put(_key395, _val396);
+ }
+ iprot.readMapEnd();
+ }
+ struct.set_sid_to_output_stats_isSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 520: // EXEC_STATS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list398 = iprot.readListBegin();
+ struct.exec_stats = new ArrayList<ExecutorAggregateStats>(_list398.size);
+ ExecutorAggregateStats _elem399;
+ for (int _i400 = 0; _i400 < _list398.size; ++_i400)
+ {
+ _elem399 = new ExecutorAggregateStats();
+ _elem399.read(iprot);
+ struct.exec_stats.add(_elem399);
+ }
+ iprot.readListEnd();
+ }
+ struct.set_exec_stats_isSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 521: // ERRORS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list401 = iprot.readListBegin();
+ struct.errors = new ArrayList<ErrorInfo>(_list401.size);
+ ErrorInfo _elem402;
+ for (int _i403 = 0; _i403 < _list401.size; ++_i403)
+ {
+ _elem402 = new ErrorInfo();
+ _elem402.read(iprot);
+ struct.errors.add(_elem402);
+ }
+ iprot.readListEnd();
+ }
+ struct.set_errors_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> _iter404 : struct.window_to_stats.entrySet())
+ {
+ oprot.writeString(_iter404.getKey());
+ _iter404.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> _iter405 : struct.gsid_to_input_stats.entrySet())
+ {
+ _iter405.getKey().write(oprot);
+ _iter405.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> _iter406 : struct.sid_to_output_stats.entrySet())
+ {
+ oprot.writeString(_iter406.getKey());
+ _iter406.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 _iter407 : struct.exec_stats)
+ {
+ _iter407.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 _iter408 : struct.errors)
+ {
+ _iter408.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ 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);
+ }
+ oprot.writeBitSet(optionals, 9);
+ 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> _iter409 : struct.window_to_stats.entrySet())
+ {
+ oprot.writeString(_iter409.getKey());
+ _iter409.getValue().write(oprot);
+ }
+ }
+ }
+ if (struct.is_set_gsid_to_input_stats()) {
+ {
+ oprot.writeI32(struct.gsid_to_input_stats.size());
+ for (Map.Entry<GlobalStreamId, ComponentAggregateStats> _iter410 : struct.gsid_to_input_stats.entrySet())
+ {
+ _iter410.getKey().write(oprot);
+ _iter410.getValue().write(oprot);
+ }
+ }
+ }
+ if (struct.is_set_sid_to_output_stats()) {
+ {
+ oprot.writeI32(struct.sid_to_output_stats.size());
+ for (Map.Entry<String, ComponentAggregateStats> _iter411 : struct.sid_to_output_stats.entrySet())
+ {
+ oprot.writeString(_iter411.getKey());
+ _iter411.getValue().write(oprot);
+ }
+ }
+ }
+ if (struct.is_set_exec_stats()) {
+ {
+ oprot.writeI32(struct.exec_stats.size());
+ for (ExecutorAggregateStats _iter412 : struct.exec_stats)
+ {
+ _iter412.write(oprot);
+ }
+ }
+ }
+ if (struct.is_set_errors()) {
+ {
+ oprot.writeI32(struct.errors.size());
+ for (ErrorInfo _iter413 : struct.errors)
+ {
+ _iter413.write(oprot);
+ }
+ }
+ }
+ }
+
+ @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 = backtype.storm.generated.ComponentType.findByValue(iprot.readI32());
+ struct.set_component_type_isSet(true);
+ BitSet incoming = iprot.readBitSet(9);
+ 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 _map414 = 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*_map414.size);
+ String _key415;
+ ComponentAggregateStats _val416;
+ for (int _i417 = 0; _i417 < _map414.size; ++_i417)
+ {
+ _key415 = iprot.readString();
+ _val416 = new ComponentAggregateStats();
+ _val416.read(iprot);
+ struct.window_to_stats.put(_key415, _val416);
+ }
+ }
+ struct.set_window_to_stats_isSet(true);
+ }
+ if (incoming.get(5)) {
+ {
+ org.apache.thrift.protocol.TMap _map418 = 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*_map418.size);
+ GlobalStreamId _key419;
+ ComponentAggregateStats _val420;
+ for (int _i421 = 0; _i421 < _map418.size; ++_i421)
+ {
+ _key419 = new GlobalStreamId();
+ _key419.read(iprot);
+ _val420 = new ComponentAggregateStats();
+ _val420.read(iprot);
+ struct.gsid_to_input_stats.put(_key419, _val420);
+ }
+ }
+ struct.set_gsid_to_input_stats_isSet(true);
+ }
+ if (incoming.get(6)) {
+ {
+ org.apache.thrift.protocol.TMap _map422 = 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*_map422.size);
+ String _key423;
+ ComponentAggregateStats _val424;
+ for (int _i425 = 0; _i425 < _map422.size; ++_i425)
+ {
+ _key423 = iprot.readString();
+ _val424 = new ComponentAggregateStats();
+ _val424.read(iprot);
+ struct.sid_to_output_stats.put(_key423, _val424);
+ }
+ }
+ struct.set_sid_to_output_stats_isSet(true);
+ }
+ if (incoming.get(7)) {
+ {
+ org.apache.thrift.protocol.TList _list426 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.exec_stats = new ArrayList<ExecutorAggregateStats>(_list426.size);
+ ExecutorAggregateStats _elem427;
+ for (int _i428 = 0; _i428 < _list426.size; ++_i428)
+ {
+ _elem427 = new ExecutorAggregateStats();
+ _elem427.read(iprot);
+ struct.exec_stats.add(_elem427);
+ }
+ }
+ struct.set_exec_stats_isSet(true);
+ }
+ if (incoming.get(8)) {
+ {
+ org.apache.thrift.protocol.TList _list429 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.errors = new ArrayList<ErrorInfo>(_list429.size);
+ ErrorInfo _elem430;
+ for (int _i431 = 0; _i431 < _list429.size; ++_i431)
+ {
+ _elem430 = new ErrorInfo();
+ _elem430.read(iprot);
+ struct.errors.add(_elem430);
+ }
+ }
+ struct.set_errors_isSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/storm/blob/a16b50c9/storm-core/src/jvm/backtype/storm/generated/ComponentType.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ComponentType.java b/storm-core/src/jvm/backtype/storm/generated/ComponentType.java
new file mode 100644
index 0000000..9efdba4
--- /dev/null
+++ b/storm-core/src/jvm/backtype/storm/generated/ComponentType.java
@@ -0,0 +1,62 @@
+/**
+ * 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.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package backtype.storm.generated;
+
+
+import java.util.Map;
+import java.util.HashMap;
+import org.apache.thrift.TEnum;
+
+public enum ComponentType implements org.apache.thrift.TEnum {
+ BOLT(1),
+ SPOUT(2);
+
+ private final int value;
+
+ private ComponentType(int value) {
+ this.value = value;
+ }
+
+ /**
+ * Get the integer value of this enum value, as defined in the Thrift IDL.
+ */
+ public int getValue() {
+ return value;
+ }
+
+ /**
+ * Find a the enum type by its integer value, as defined in the Thrift IDL.
+ * @return null if the value is not found.
+ */
+ public static ComponentType findByValue(int value) {
+ switch (value) {
+ case 1:
+ return BOLT;
+ case 2:
+ return SPOUT;
+ default:
+ return null;
+ }
+ }
+}
http://git-wip-us.apache.org/repos/asf/storm/blob/a16b50c9/storm-core/src/jvm/backtype/storm/generated/Credentials.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/Credentials.java b/storm-core/src/jvm/backtype/storm/generated/Credentials.java
index c1ef293..0578d45 100644
--- a/storm-core/src/jvm/backtype/storm/generated/Credentials.java
+++ b/storm-core/src/jvm/backtype/storm/generated/Credentials.java
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-2-6")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-5-14")
public class Credentials implements org.apache.thrift.TBase<Credentials, Credentials._Fields>, java.io.Serializable, Cloneable, Comparable<Credentials> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Credentials");
@@ -365,15 +365,15 @@ public class Credentials implements org.apache.thrift.TBase<Credentials, Credent
case 1: // CREDS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map326 = iprot.readMapBegin();
- struct.creds = new HashMap<String,String>(2*_map326.size);
- String _key327;
- String _val328;
- for (int _i329 = 0; _i329 < _map326.size; ++_i329)
+ org.apache.thrift.protocol.TMap _map442 = iprot.readMapBegin();
+ struct.creds = new HashMap<String,String>(2*_map442.size);
+ String _key443;
+ String _val444;
+ for (int _i445 = 0; _i445 < _map442.size; ++_i445)
{
- _key327 = iprot.readString();
- _val328 = iprot.readString();
- struct.creds.put(_key327, _val328);
+ _key443 = iprot.readString();
+ _val444 = iprot.readString();
+ struct.creds.put(_key443, _val444);
}
iprot.readMapEnd();
}
@@ -399,10 +399,10 @@ public class Credentials implements org.apache.thrift.TBase<Credentials, Credent
oprot.writeFieldBegin(CREDS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.creds.size()));
- for (Map.Entry<String, String> _iter330 : struct.creds.entrySet())
+ for (Map.Entry<String, String> _iter446 : struct.creds.entrySet())
{
- oprot.writeString(_iter330.getKey());
- oprot.writeString(_iter330.getValue());
+ oprot.writeString(_iter446.getKey());
+ oprot.writeString(_iter446.getValue());
}
oprot.writeMapEnd();
}
@@ -427,10 +427,10 @@ public class Credentials implements org.apache.thrift.TBase<Credentials, Credent
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.creds.size());
- for (Map.Entry<String, String> _iter331 : struct.creds.entrySet())
+ for (Map.Entry<String, String> _iter447 : struct.creds.entrySet())
{
- oprot.writeString(_iter331.getKey());
- oprot.writeString(_iter331.getValue());
+ oprot.writeString(_iter447.getKey());
+ oprot.writeString(_iter447.getValue());
}
}
}
@@ -439,15 +439,15 @@ public class Credentials implements org.apache.thrift.TBase<Credentials, Credent
public void read(org.apache.thrift.protocol.TProtocol prot, Credentials struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TMap _map332 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.creds = new HashMap<String,String>(2*_map332.size);
- String _key333;
- String _val334;
- for (int _i335 = 0; _i335 < _map332.size; ++_i335)
+ org.apache.thrift.protocol.TMap _map448 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.creds = new HashMap<String,String>(2*_map448.size);
+ String _key449;
+ String _val450;
+ for (int _i451 = 0; _i451 < _map448.size; ++_i451)
{
- _key333 = iprot.readString();
- _val334 = iprot.readString();
- struct.creds.put(_key333, _val334);
+ _key449 = iprot.readString();
+ _val450 = iprot.readString();
+ struct.creds.put(_key449, _val450);
}
}
struct.set_creds_isSet(true);