You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by kn...@apache.org on 2015/11/23 22:07:56 UTC
[17/37] storm git commit: Merge remote-tracking branch 'asf/master'
into STORM-855
http://git-wip-us.apache.org/repos/asf/storm/blob/4645c190/storm-core/src/jvm/backtype/storm/generated/HBNodes.java
----------------------------------------------------------------------
diff --cc storm-core/src/jvm/backtype/storm/generated/HBNodes.java
index a6dc65d,0000000..b6fc526
mode 100644,000000..100644
--- a/storm-core/src/jvm/backtype/storm/generated/HBNodes.java
+++ b/storm-core/src/jvm/backtype/storm/generated/HBNodes.java
@@@ -1,461 -1,0 +1,461 @@@
+/**
+ * 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)
++ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package backtype.storm.generated;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
- @Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
++@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+public class HBNodes implements org.apache.thrift.TBase<HBNodes, HBNodes._Fields>, java.io.Serializable, Cloneable, Comparable<HBNodes> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("HBNodes");
+
+ private static final org.apache.thrift.protocol.TField PULSE_IDS_FIELD_DESC = new org.apache.thrift.protocol.TField("pulseIds", org.apache.thrift.protocol.TType.LIST, (short)1);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new HBNodesStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new HBNodesTupleSchemeFactory());
+ }
+
+ private List<String> pulseIds; // required
+
+ /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+ public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ PULSE_IDS((short)1, "pulseIds");
+
+ 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: // PULSE_IDS
+ return PULSE_IDS;
+ default:
+ return null;
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, throwing an exception
+ * if it is not found.
+ */
+ public static _Fields findByThriftIdOrThrow(int fieldId) {
+ _Fields fields = findByThriftId(fieldId);
+ if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ return fields;
+ }
+
+ /**
+ * Find the _Fields constant that matches name, or null if its not found.
+ */
+ public static _Fields findByName(String name) {
+ return byName.get(name);
+ }
+
+ private final short _thriftId;
+ private final String _fieldName;
+
+ _Fields(short thriftId, String fieldName) {
+ _thriftId = thriftId;
+ _fieldName = fieldName;
+ }
+
+ public short getThriftFieldId() {
+ return _thriftId;
+ }
+
+ public String getFieldName() {
+ return _fieldName;
+ }
+ }
+
+ // isset id assignments
+ public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ static {
+ Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.PULSE_IDS, new org.apache.thrift.meta_data.FieldMetaData("pulseIds", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(HBNodes.class, metaDataMap);
+ }
+
+ public HBNodes() {
+ }
+
+ public HBNodes(
+ List<String> pulseIds)
+ {
+ this();
+ this.pulseIds = pulseIds;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public HBNodes(HBNodes other) {
+ if (other.is_set_pulseIds()) {
+ List<String> __this__pulseIds = new ArrayList<String>(other.pulseIds);
+ this.pulseIds = __this__pulseIds;
+ }
+ }
+
+ public HBNodes deepCopy() {
+ return new HBNodes(this);
+ }
+
+ @Override
+ public void clear() {
+ this.pulseIds = null;
+ }
+
+ public int get_pulseIds_size() {
+ return (this.pulseIds == null) ? 0 : this.pulseIds.size();
+ }
+
+ public java.util.Iterator<String> get_pulseIds_iterator() {
+ return (this.pulseIds == null) ? null : this.pulseIds.iterator();
+ }
+
+ public void add_to_pulseIds(String elem) {
+ if (this.pulseIds == null) {
+ this.pulseIds = new ArrayList<String>();
+ }
+ this.pulseIds.add(elem);
+ }
+
+ public List<String> get_pulseIds() {
+ return this.pulseIds;
+ }
+
+ public void set_pulseIds(List<String> pulseIds) {
+ this.pulseIds = pulseIds;
+ }
+
+ public void unset_pulseIds() {
+ this.pulseIds = null;
+ }
+
+ /** Returns true if field pulseIds is set (has been assigned a value) and false otherwise */
+ public boolean is_set_pulseIds() {
+ return this.pulseIds != null;
+ }
+
+ public void set_pulseIds_isSet(boolean value) {
+ if (!value) {
+ this.pulseIds = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case PULSE_IDS:
+ if (value == null) {
+ unset_pulseIds();
+ } else {
+ set_pulseIds((List<String>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case PULSE_IDS:
+ return get_pulseIds();
+
+ }
+ 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 PULSE_IDS:
+ return is_set_pulseIds();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof HBNodes)
+ return this.equals((HBNodes)that);
+ return false;
+ }
+
+ public boolean equals(HBNodes that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_pulseIds = true && this.is_set_pulseIds();
+ boolean that_present_pulseIds = true && that.is_set_pulseIds();
+ if (this_present_pulseIds || that_present_pulseIds) {
+ if (!(this_present_pulseIds && that_present_pulseIds))
+ return false;
+ if (!this.pulseIds.equals(that.pulseIds))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_pulseIds = true && (is_set_pulseIds());
+ list.add(present_pulseIds);
+ if (present_pulseIds)
+ list.add(pulseIds);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(HBNodes other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(is_set_pulseIds()).compareTo(other.is_set_pulseIds());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_pulseIds()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.pulseIds, other.pulseIds);
+ 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("HBNodes(");
+ boolean first = true;
+
+ sb.append("pulseIds:");
+ if (this.pulseIds == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.pulseIds);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ // check for sub-struct validity
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class HBNodesStandardSchemeFactory implements SchemeFactory {
+ public HBNodesStandardScheme getScheme() {
+ return new HBNodesStandardScheme();
+ }
+ }
+
+ private static class HBNodesStandardScheme extends StandardScheme<HBNodes> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, HBNodes 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: // PULSE_IDS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
- org.apache.thrift.protocol.TList _list674 = iprot.readListBegin();
- struct.pulseIds = new ArrayList<String>(_list674.size);
- String _elem675;
- for (int _i676 = 0; _i676 < _list674.size; ++_i676)
++ org.apache.thrift.protocol.TList _list706 = iprot.readListBegin();
++ struct.pulseIds = new ArrayList<String>(_list706.size);
++ String _elem707;
++ for (int _i708 = 0; _i708 < _list706.size; ++_i708)
+ {
- _elem675 = iprot.readString();
- struct.pulseIds.add(_elem675);
++ _elem707 = iprot.readString();
++ struct.pulseIds.add(_elem707);
+ }
+ iprot.readListEnd();
+ }
+ struct.set_pulseIds_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, HBNodes struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.pulseIds != null) {
+ oprot.writeFieldBegin(PULSE_IDS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.pulseIds.size()));
- for (String _iter677 : struct.pulseIds)
++ for (String _iter709 : struct.pulseIds)
+ {
- oprot.writeString(_iter677);
++ oprot.writeString(_iter709);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class HBNodesTupleSchemeFactory implements SchemeFactory {
+ public HBNodesTupleScheme getScheme() {
+ return new HBNodesTupleScheme();
+ }
+ }
+
+ private static class HBNodesTupleScheme extends TupleScheme<HBNodes> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, HBNodes struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.is_set_pulseIds()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.is_set_pulseIds()) {
+ {
+ oprot.writeI32(struct.pulseIds.size());
- for (String _iter678 : struct.pulseIds)
++ for (String _iter710 : struct.pulseIds)
+ {
- oprot.writeString(_iter678);
++ oprot.writeString(_iter710);
+ }
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, HBNodes struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ {
- org.apache.thrift.protocol.TList _list679 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.pulseIds = new ArrayList<String>(_list679.size);
- String _elem680;
- for (int _i681 = 0; _i681 < _list679.size; ++_i681)
++ org.apache.thrift.protocol.TList _list711 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
++ struct.pulseIds = new ArrayList<String>(_list711.size);
++ String _elem712;
++ for (int _i713 = 0; _i713 < _list711.size; ++_i713)
+ {
- _elem680 = iprot.readString();
- struct.pulseIds.add(_elem680);
++ _elem712 = iprot.readString();
++ struct.pulseIds.add(_elem712);
+ }
+ }
+ struct.set_pulseIds_isSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/storm/blob/4645c190/storm-core/src/jvm/backtype/storm/generated/HBPulse.java
----------------------------------------------------------------------
diff --cc storm-core/src/jvm/backtype/storm/generated/HBPulse.java
index e9afbfc,0000000..aa244f5
mode 100644,000000..100644
--- a/storm-core/src/jvm/backtype/storm/generated/HBPulse.java
+++ b/storm-core/src/jvm/backtype/storm/generated/HBPulse.java
@@@ -1,522 -1,0 +1,522 @@@
+/**
+ * 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)
++ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package backtype.storm.generated;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
- @Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
++@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+public class HBPulse implements org.apache.thrift.TBase<HBPulse, HBPulse._Fields>, java.io.Serializable, Cloneable, Comparable<HBPulse> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("HBPulse");
+
+ private static final org.apache.thrift.protocol.TField ID_FIELD_DESC = new org.apache.thrift.protocol.TField("id", org.apache.thrift.protocol.TType.STRING, (short)1);
+ private static final org.apache.thrift.protocol.TField DETAILS_FIELD_DESC = new org.apache.thrift.protocol.TField("details", org.apache.thrift.protocol.TType.STRING, (short)2);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new HBPulseStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new HBPulseTupleSchemeFactory());
+ }
+
+ private String id; // required
+ private ByteBuffer details; // required
+
+ /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+ public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ ID((short)1, "id"),
+ DETAILS((short)2, "details");
+
+ 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: // ID
+ return ID;
+ case 2: // DETAILS
+ return DETAILS;
+ default:
+ return null;
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, throwing an exception
+ * if it is not found.
+ */
+ public static _Fields findByThriftIdOrThrow(int fieldId) {
+ _Fields fields = findByThriftId(fieldId);
+ if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ return fields;
+ }
+
+ /**
+ * Find the _Fields constant that matches name, or null if its not found.
+ */
+ public static _Fields findByName(String name) {
+ return byName.get(name);
+ }
+
+ private final short _thriftId;
+ private final String _fieldName;
+
+ _Fields(short thriftId, String fieldName) {
+ _thriftId = thriftId;
+ _fieldName = fieldName;
+ }
+
+ public short getThriftFieldId() {
+ return _thriftId;
+ }
+
+ public String getFieldName() {
+ return _fieldName;
+ }
+ }
+
+ // isset id assignments
+ public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ static {
+ Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.ID, new org.apache.thrift.meta_data.FieldMetaData("id", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.DETAILS, new org.apache.thrift.meta_data.FieldMetaData("details", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(HBPulse.class, metaDataMap);
+ }
+
+ public HBPulse() {
+ }
+
+ public HBPulse(
+ String id,
+ ByteBuffer details)
+ {
+ this();
+ this.id = id;
+ this.details = org.apache.thrift.TBaseHelper.copyBinary(details);
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public HBPulse(HBPulse other) {
+ if (other.is_set_id()) {
+ this.id = other.id;
+ }
+ if (other.is_set_details()) {
+ this.details = org.apache.thrift.TBaseHelper.copyBinary(other.details);
+ }
+ }
+
+ public HBPulse deepCopy() {
+ return new HBPulse(this);
+ }
+
+ @Override
+ public void clear() {
+ this.id = null;
+ this.details = null;
+ }
+
+ public String get_id() {
+ return this.id;
+ }
+
+ public void set_id(String id) {
+ this.id = id;
+ }
+
+ public void unset_id() {
+ this.id = null;
+ }
+
+ /** Returns true if field id is set (has been assigned a value) and false otherwise */
+ public boolean is_set_id() {
+ return this.id != null;
+ }
+
+ public void set_id_isSet(boolean value) {
+ if (!value) {
+ this.id = null;
+ }
+ }
+
+ public byte[] get_details() {
+ set_details(org.apache.thrift.TBaseHelper.rightSize(details));
+ return details == null ? null : details.array();
+ }
+
+ public ByteBuffer buffer_for_details() {
+ return org.apache.thrift.TBaseHelper.copyBinary(details);
+ }
+
+ public void set_details(byte[] details) {
+ this.details = details == null ? (ByteBuffer)null : ByteBuffer.wrap(Arrays.copyOf(details, details.length));
+ }
+
+ public void set_details(ByteBuffer details) {
+ this.details = org.apache.thrift.TBaseHelper.copyBinary(details);
+ }
+
+ public void unset_details() {
+ this.details = null;
+ }
+
+ /** Returns true if field details is set (has been assigned a value) and false otherwise */
+ public boolean is_set_details() {
+ return this.details != null;
+ }
+
+ public void set_details_isSet(boolean value) {
+ if (!value) {
+ this.details = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case ID:
+ if (value == null) {
+ unset_id();
+ } else {
+ set_id((String)value);
+ }
+ break;
+
+ case DETAILS:
+ if (value == null) {
+ unset_details();
+ } else {
+ set_details((ByteBuffer)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case ID:
+ return get_id();
+
+ case DETAILS:
+ return get_details();
+
+ }
+ 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 ID:
+ return is_set_id();
+ case DETAILS:
+ return is_set_details();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof HBPulse)
+ return this.equals((HBPulse)that);
+ return false;
+ }
+
+ public boolean equals(HBPulse that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_id = true && this.is_set_id();
+ boolean that_present_id = true && that.is_set_id();
+ if (this_present_id || that_present_id) {
+ if (!(this_present_id && that_present_id))
+ return false;
+ if (!this.id.equals(that.id))
+ return false;
+ }
+
+ boolean this_present_details = true && this.is_set_details();
+ boolean that_present_details = true && that.is_set_details();
+ if (this_present_details || that_present_details) {
+ if (!(this_present_details && that_present_details))
+ return false;
+ if (!this.details.equals(that.details))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_id = true && (is_set_id());
+ list.add(present_id);
+ if (present_id)
+ list.add(id);
+
+ boolean present_details = true && (is_set_details());
+ list.add(present_details);
+ if (present_details)
+ list.add(details);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(HBPulse other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(is_set_id()).compareTo(other.is_set_id());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_id()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.id, other.id);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(is_set_details()).compareTo(other.is_set_details());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_details()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.details, other.details);
+ 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("HBPulse(");
+ boolean first = true;
+
+ sb.append("id:");
+ if (this.id == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.id);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("details:");
+ if (this.details == null) {
+ sb.append("null");
+ } else {
+ org.apache.thrift.TBaseHelper.toString(this.details, sb);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!is_set_id()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'id' is unset! Struct:" + toString());
+ }
+
+ // check for sub-struct validity
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class HBPulseStandardSchemeFactory implements SchemeFactory {
+ public HBPulseStandardScheme getScheme() {
+ return new HBPulseStandardScheme();
+ }
+ }
+
+ private static class HBPulseStandardScheme extends StandardScheme<HBPulse> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, HBPulse 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: // ID
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.id = iprot.readString();
+ struct.set_id_isSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // DETAILS
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.details = iprot.readBinary();
+ struct.set_details_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, HBPulse struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.id != null) {
+ oprot.writeFieldBegin(ID_FIELD_DESC);
+ oprot.writeString(struct.id);
+ oprot.writeFieldEnd();
+ }
+ if (struct.details != null) {
+ oprot.writeFieldBegin(DETAILS_FIELD_DESC);
+ oprot.writeBinary(struct.details);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class HBPulseTupleSchemeFactory implements SchemeFactory {
+ public HBPulseTupleScheme getScheme() {
+ return new HBPulseTupleScheme();
+ }
+ }
+
+ private static class HBPulseTupleScheme extends TupleScheme<HBPulse> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, HBPulse struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeString(struct.id);
+ BitSet optionals = new BitSet();
+ if (struct.is_set_details()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.is_set_details()) {
+ oprot.writeBinary(struct.details);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, HBPulse struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.id = iprot.readString();
+ struct.set_id_isSet(true);
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ struct.details = iprot.readBinary();
+ struct.set_details_isSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/storm/blob/4645c190/storm-core/src/jvm/backtype/storm/generated/HBRecords.java
----------------------------------------------------------------------
diff --cc storm-core/src/jvm/backtype/storm/generated/HBRecords.java
index 90ee8bd,0000000..4767068
mode 100644,000000..100644
--- a/storm-core/src/jvm/backtype/storm/generated/HBRecords.java
+++ b/storm-core/src/jvm/backtype/storm/generated/HBRecords.java
@@@ -1,466 -1,0 +1,466 @@@
+/**
+ * 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)
++ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package backtype.storm.generated;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
- @Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-10-9")
++@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+public class HBRecords implements org.apache.thrift.TBase<HBRecords, HBRecords._Fields>, java.io.Serializable, Cloneable, Comparable<HBRecords> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("HBRecords");
+
+ private static final org.apache.thrift.protocol.TField PULSES_FIELD_DESC = new org.apache.thrift.protocol.TField("pulses", org.apache.thrift.protocol.TType.LIST, (short)1);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new HBRecordsStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new HBRecordsTupleSchemeFactory());
+ }
+
+ private List<HBPulse> pulses; // required
+
+ /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+ public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ PULSES((short)1, "pulses");
+
+ 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: // PULSES
+ return PULSES;
+ default:
+ return null;
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, throwing an exception
+ * if it is not found.
+ */
+ public static _Fields findByThriftIdOrThrow(int fieldId) {
+ _Fields fields = findByThriftId(fieldId);
+ if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ return fields;
+ }
+
+ /**
+ * Find the _Fields constant that matches name, or null if its not found.
+ */
+ public static _Fields findByName(String name) {
+ return byName.get(name);
+ }
+
+ private final short _thriftId;
+ private final String _fieldName;
+
+ _Fields(short thriftId, String fieldName) {
+ _thriftId = thriftId;
+ _fieldName = fieldName;
+ }
+
+ public short getThriftFieldId() {
+ return _thriftId;
+ }
+
+ public String getFieldName() {
+ return _fieldName;
+ }
+ }
+
+ // isset id assignments
+ public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ static {
+ Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.PULSES, new org.apache.thrift.meta_data.FieldMetaData("pulses", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ 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, HBPulse.class))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(HBRecords.class, metaDataMap);
+ }
+
+ public HBRecords() {
+ }
+
+ public HBRecords(
+ List<HBPulse> pulses)
+ {
+ this();
+ this.pulses = pulses;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public HBRecords(HBRecords other) {
+ if (other.is_set_pulses()) {
+ List<HBPulse> __this__pulses = new ArrayList<HBPulse>(other.pulses.size());
+ for (HBPulse other_element : other.pulses) {
+ __this__pulses.add(new HBPulse(other_element));
+ }
+ this.pulses = __this__pulses;
+ }
+ }
+
+ public HBRecords deepCopy() {
+ return new HBRecords(this);
+ }
+
+ @Override
+ public void clear() {
+ this.pulses = null;
+ }
+
+ public int get_pulses_size() {
+ return (this.pulses == null) ? 0 : this.pulses.size();
+ }
+
+ public java.util.Iterator<HBPulse> get_pulses_iterator() {
+ return (this.pulses == null) ? null : this.pulses.iterator();
+ }
+
+ public void add_to_pulses(HBPulse elem) {
+ if (this.pulses == null) {
+ this.pulses = new ArrayList<HBPulse>();
+ }
+ this.pulses.add(elem);
+ }
+
+ public List<HBPulse> get_pulses() {
+ return this.pulses;
+ }
+
+ public void set_pulses(List<HBPulse> pulses) {
+ this.pulses = pulses;
+ }
+
+ public void unset_pulses() {
+ this.pulses = null;
+ }
+
+ /** Returns true if field pulses is set (has been assigned a value) and false otherwise */
+ public boolean is_set_pulses() {
+ return this.pulses != null;
+ }
+
+ public void set_pulses_isSet(boolean value) {
+ if (!value) {
+ this.pulses = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case PULSES:
+ if (value == null) {
+ unset_pulses();
+ } else {
+ set_pulses((List<HBPulse>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case PULSES:
+ return get_pulses();
+
+ }
+ 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 PULSES:
+ return is_set_pulses();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof HBRecords)
+ return this.equals((HBRecords)that);
+ return false;
+ }
+
+ public boolean equals(HBRecords that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_pulses = true && this.is_set_pulses();
+ boolean that_present_pulses = true && that.is_set_pulses();
+ if (this_present_pulses || that_present_pulses) {
+ if (!(this_present_pulses && that_present_pulses))
+ return false;
+ if (!this.pulses.equals(that.pulses))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_pulses = true && (is_set_pulses());
+ list.add(present_pulses);
+ if (present_pulses)
+ list.add(pulses);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(HBRecords other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(is_set_pulses()).compareTo(other.is_set_pulses());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_pulses()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.pulses, other.pulses);
+ 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("HBRecords(");
+ boolean first = true;
+
+ sb.append("pulses:");
+ if (this.pulses == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.pulses);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ // check for sub-struct validity
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class HBRecordsStandardSchemeFactory implements SchemeFactory {
+ public HBRecordsStandardScheme getScheme() {
+ return new HBRecordsStandardScheme();
+ }
+ }
+
+ private static class HBRecordsStandardScheme extends StandardScheme<HBRecords> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, HBRecords 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: // PULSES
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
- org.apache.thrift.protocol.TList _list666 = iprot.readListBegin();
- struct.pulses = new ArrayList<HBPulse>(_list666.size);
- HBPulse _elem667;
- for (int _i668 = 0; _i668 < _list666.size; ++_i668)
++ org.apache.thrift.protocol.TList _list698 = iprot.readListBegin();
++ struct.pulses = new ArrayList<HBPulse>(_list698.size);
++ HBPulse _elem699;
++ for (int _i700 = 0; _i700 < _list698.size; ++_i700)
+ {
- _elem667 = new HBPulse();
- _elem667.read(iprot);
- struct.pulses.add(_elem667);
++ _elem699 = new HBPulse();
++ _elem699.read(iprot);
++ struct.pulses.add(_elem699);
+ }
+ iprot.readListEnd();
+ }
+ struct.set_pulses_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, HBRecords struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.pulses != null) {
+ oprot.writeFieldBegin(PULSES_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.pulses.size()));
- for (HBPulse _iter669 : struct.pulses)
++ for (HBPulse _iter701 : struct.pulses)
+ {
- _iter669.write(oprot);
++ _iter701.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class HBRecordsTupleSchemeFactory implements SchemeFactory {
+ public HBRecordsTupleScheme getScheme() {
+ return new HBRecordsTupleScheme();
+ }
+ }
+
+ private static class HBRecordsTupleScheme extends TupleScheme<HBRecords> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, HBRecords struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.is_set_pulses()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.is_set_pulses()) {
+ {
+ oprot.writeI32(struct.pulses.size());
- for (HBPulse _iter670 : struct.pulses)
++ for (HBPulse _iter702 : struct.pulses)
+ {
- _iter670.write(oprot);
++ _iter702.write(oprot);
+ }
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, HBRecords struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ {
- org.apache.thrift.protocol.TList _list671 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.pulses = new ArrayList<HBPulse>(_list671.size);
- HBPulse _elem672;
- for (int _i673 = 0; _i673 < _list671.size; ++_i673)
++ org.apache.thrift.protocol.TList _list703 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
++ struct.pulses = new ArrayList<HBPulse>(_list703.size);
++ HBPulse _elem704;
++ for (int _i705 = 0; _i705 < _list703.size; ++_i705)
+ {
- _elem672 = new HBPulse();
- _elem672.read(iprot);
- struct.pulses.add(_elem672);
++ _elem704 = new HBPulse();
++ _elem704.read(iprot);
++ struct.pulses.add(_elem704);
+ }
+ }
+ struct.set_pulses_isSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/storm/blob/4645c190/storm-core/src/jvm/backtype/storm/generated/HBServerMessageType.java
----------------------------------------------------------------------
diff --cc storm-core/src/jvm/backtype/storm/generated/HBServerMessageType.java
index 6f940c2,0000000..3cafc14
mode 100644,000000..100644
--- a/storm-core/src/jvm/backtype/storm/generated/HBServerMessageType.java
+++ b/storm-core/src/jvm/backtype/storm/generated/HBServerMessageType.java
@@@ -1,113 -1,0 +1,113 @@@
+/**
+ * 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)
++ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * 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 HBServerMessageType implements org.apache.thrift.TEnum {
+ CREATE_PATH(0),
+ CREATE_PATH_RESPONSE(1),
+ EXISTS(2),
+ EXISTS_RESPONSE(3),
+ SEND_PULSE(4),
+ SEND_PULSE_RESPONSE(5),
+ GET_ALL_PULSE_FOR_PATH(6),
+ GET_ALL_PULSE_FOR_PATH_RESPONSE(7),
+ GET_ALL_NODES_FOR_PATH(8),
+ GET_ALL_NODES_FOR_PATH_RESPONSE(9),
+ GET_PULSE(10),
+ GET_PULSE_RESPONSE(11),
+ DELETE_PATH(12),
+ DELETE_PATH_RESPONSE(13),
+ DELETE_PULSE_ID(14),
+ DELETE_PULSE_ID_RESPONSE(15),
+ CONTROL_MESSAGE(16),
+ SASL_MESSAGE_TOKEN(17),
+ NOT_AUTHORIZED(18);
+
+ private final int value;
+
+ private HBServerMessageType(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 HBServerMessageType findByValue(int value) {
+ switch (value) {
+ case 0:
+ return CREATE_PATH;
+ case 1:
+ return CREATE_PATH_RESPONSE;
+ case 2:
+ return EXISTS;
+ case 3:
+ return EXISTS_RESPONSE;
+ case 4:
+ return SEND_PULSE;
+ case 5:
+ return SEND_PULSE_RESPONSE;
+ case 6:
+ return GET_ALL_PULSE_FOR_PATH;
+ case 7:
+ return GET_ALL_PULSE_FOR_PATH_RESPONSE;
+ case 8:
+ return GET_ALL_NODES_FOR_PATH;
+ case 9:
+ return GET_ALL_NODES_FOR_PATH_RESPONSE;
+ case 10:
+ return GET_PULSE;
+ case 11:
+ return GET_PULSE_RESPONSE;
+ case 12:
+ return DELETE_PATH;
+ case 13:
+ return DELETE_PATH_RESPONSE;
+ case 14:
+ return DELETE_PULSE_ID;
+ case 15:
+ return DELETE_PULSE_ID_RESPONSE;
+ case 16:
+ return CONTROL_MESSAGE;
+ case 17:
+ return SASL_MESSAGE_TOKEN;
+ case 18:
+ return NOT_AUTHORIZED;
+ default:
+ return null;
+ }
+ }
+}
http://git-wip-us.apache.org/repos/asf/storm/blob/4645c190/storm-core/src/jvm/backtype/storm/generated/Nimbus.java
----------------------------------------------------------------------
diff --cc storm-core/src/jvm/backtype/storm/generated/Nimbus.java
index b0d007b,f8a94ab..360dba5
--- a/storm-core/src/jvm/backtype/storm/generated/Nimbus.java
+++ b/storm-core/src/jvm/backtype/storm/generated/Nimbus.java
@@@ -15611,14 -15611,14 +15611,14 @@@ public class Nimbus
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
-- org.apache.thrift.protocol.TList _list698 = iprot.readListBegin();
-- struct.success = new ArrayList<ProfileRequest>(_list698.size);
-- ProfileRequest _elem699;
-- for (int _i700 = 0; _i700 < _list698.size; ++_i700)
++ org.apache.thrift.protocol.TList _list714 = iprot.readListBegin();
++ struct.success = new ArrayList<ProfileRequest>(_list714.size);
++ ProfileRequest _elem715;
++ for (int _i716 = 0; _i716 < _list714.size; ++_i716)
{
-- _elem699 = new ProfileRequest();
-- _elem699.read(iprot);
-- struct.success.add(_elem699);
++ _elem715 = new ProfileRequest();
++ _elem715.read(iprot);
++ struct.success.add(_elem715);
}
iprot.readListEnd();
}
@@@ -15644,9 -15644,9 +15644,9 @@@
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
-- for (ProfileRequest _iter701 : struct.success)
++ for (ProfileRequest _iter717 : struct.success)
{
-- _iter701.write(oprot);
++ _iter717.write(oprot);
}
oprot.writeListEnd();
}
@@@ -15677,9 -15677,9 +15677,9 @@@
if (struct.is_set_success()) {
{
oprot.writeI32(struct.success.size());
-- for (ProfileRequest _iter702 : struct.success)
++ for (ProfileRequest _iter718 : struct.success)
{
-- _iter702.write(oprot);
++ _iter718.write(oprot);
}
}
}
@@@ -15691,14 -15691,14 +15691,14 @@@
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
-- org.apache.thrift.protocol.TList _list703 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-- struct.success = new ArrayList<ProfileRequest>(_list703.size);
-- ProfileRequest _elem704;
-- for (int _i705 = 0; _i705 < _list703.size; ++_i705)
++ org.apache.thrift.protocol.TList _list719 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
++ struct.success = new ArrayList<ProfileRequest>(_list719.size);
++ ProfileRequest _elem720;
++ for (int _i721 = 0; _i721 < _list719.size; ++_i721)
{
-- _elem704 = new ProfileRequest();
-- _elem704.read(iprot);
-- struct.success.add(_elem704);
++ _elem720 = new ProfileRequest();
++ _elem720.read(iprot);
++ struct.success.add(_elem720);
}
}
struct.set_success_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/4645c190/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/4645c190/storm-core/src/jvm/backtype/storm/messaging/netty/Server.java
----------------------------------------------------------------------
diff --cc storm-core/src/jvm/backtype/storm/messaging/netty/Server.java
index 5f23064,bca3936..684e9ea
--- a/storm-core/src/jvm/backtype/storm/messaging/netty/Server.java
+++ b/storm-core/src/jvm/backtype/storm/messaging/netty/Server.java
@@@ -47,8 -32,25 +47,14 @@@ import java.util.concurrent.LinkedBlock
import java.util.concurrent.ThreadFactory;
import java.io.IOException;
-import org.jboss.netty.bootstrap.ServerBootstrap;
-import org.jboss.netty.channel.Channel;
-import org.jboss.netty.channel.ChannelFactory;
-import org.jboss.netty.channel.group.ChannelGroup;
-import org.jboss.netty.channel.group.DefaultChannelGroup;
-import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import backtype.storm.Config;
-import backtype.storm.grouping.Load;
import backtype.storm.messaging.ConnectionWithStatus;
+ import backtype.storm.messaging.IConnection;
+ import backtype.storm.messaging.IConnectionCallback;
+ import backtype.storm.messaging.TaskMessage;
+ import backtype.storm.metric.api.IStatefulObject;
+ import backtype.storm.serialization.KryoValuesSerializer;
+ import backtype.storm.utils.Utils;
class Server extends ConnectionWithStatus implements IStatefulObject, ISaslServer {
@@@ -124,48 -107,7 +111,7 @@@
Channel channel = bootstrap.bind(new InetSocketAddress(port));
allChannels.add(channel);
}
-
- private ArrayList<TaskMessage>[] groupMessages(List<TaskMessage> msgs) {
- ArrayList<TaskMessage> messageGroups[] = new ArrayList[queueCount];
-
- for (TaskMessage message : msgs) {
- int task = message.task();
-
- if (task == -1) {
- closing = true;
- return null;
- }
-
- Integer queueId = getMessageQueueId(task);
-
- if (null == messageGroups[queueId]) {
- messageGroups[queueId] = new ArrayList<>();
- }
- messageGroups[queueId].add(message);
- }
- return messageGroups;
- }
-
- private Integer getMessageQueueId(int task) {
- // try to construct the map from taskId -> queueId in round robin manner.
- Integer queueId = taskToQueueId.get(task);
- if (null == queueId) {
- synchronized (this) {
- queueId = taskToQueueId.get(task);
- if (queueId == null) {
- queueId = roundRobinQueueId++;
- if (roundRobinQueueId == queueCount) {
- roundRobinQueueId = 0;
- }
- HashMap<Integer, Integer> newRef = new HashMap<>(taskToQueueId);
- newRef.put(task, queueId);
- taskToQueueId = newRef;
- }
- }
- }
- return queueId;
- }
-
-
++
private void addReceiveCount(String from, int amount) {
//This is possibly lossy in the case where a value is deleted
// because it has received no messages over the metrics collection
@@@ -208,35 -140,11 +144,11 @@@
}
}
- public Iterator<TaskMessage> recv(int flags, int receiverId) {
- if (closing) {
- return closeMessage.iterator();
- }
-
- ArrayList<TaskMessage> ret;
- int queueId = receiverId % queueCount;
- if ((flags & 0x01) == 0x01) {
- //non-blocking
- ret = message_queue[queueId].poll();
- } else {
- try {
- ArrayList<TaskMessage> request = message_queue[queueId].take();
- LOG.debug("request to be processed: {}", request);
- ret = request;
- } catch (InterruptedException e) {
- LOG.info("exception within msg receiving", e);
- ret = null;
- }
- }
-
- if (null != ret) {
- messagesDequeued.addAndGet(ret.size());
- pendingMessages[queueId].addAndGet(0 - ret.size());
- return ret.iterator();
- }
- return null;
+ @Override
+ public void registerRecv(IConnectionCallback cb) {
+ _cb = cb;
}
-
+
/**
* register a newly created channel
* @param channel newly created channel
http://git-wip-us.apache.org/repos/asf/storm/blob/4645c190/storm-core/src/py/storm/Nimbus.py
----------------------------------------------------------------------
diff --cc storm-core/src/py/storm/Nimbus.py
index a2d4c0b,14e5f2e..c1e1b02
--- a/storm-core/src/py/storm/Nimbus.py
+++ b/storm-core/src/py/storm/Nimbus.py
@@@ -3566,11 -3811,11 +3811,11 @@@ class getComponentPendingProfileActions
if fid == 0:
if ftype == TType.LIST:
self.success = []
-- (_etype627, _size624) = iprot.readListBegin()
-- for _i628 in xrange(_size624):
-- _elem629 = ProfileRequest()
-- _elem629.read(iprot)
-- self.success.append(_elem629)
++ (_etype641, _size638) = iprot.readListBegin()
++ for _i642 in xrange(_size638):
++ _elem643 = ProfileRequest()
++ _elem643.read(iprot)
++ self.success.append(_elem643)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@@ -3587,8 -3832,8 +3832,8 @@@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
-- for iter630 in self.success:
-- iter630.write(oprot)
++ for iter644 in self.success:
++ iter644.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
http://git-wip-us.apache.org/repos/asf/storm/blob/4645c190/storm-core/src/py/storm/ttypes.py
----------------------------------------------------------------------
diff --cc storm-core/src/py/storm/ttypes.py
index c6b2816,23a82e1..4d8120c
--- a/storm-core/src/py/storm/ttypes.py
+++ b/storm-core/src/py/storm/ttypes.py
@@@ -9441,596 -9376,3 +9441,596 @@@ class DRPCExecutionException(TException
def __ne__(self, other):
return not (self == other)
+
+class HBMessageData:
+ """
+ Attributes:
+ - path
+ - pulse
+ - boolval
+ - records
+ - nodes
+ - message_blob
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'path', None, None, ), # 1
+ (2, TType.STRUCT, 'pulse', (HBPulse, HBPulse.thrift_spec), None, ), # 2
+ (3, TType.BOOL, 'boolval', None, None, ), # 3
+ (4, TType.STRUCT, 'records', (HBRecords, HBRecords.thrift_spec), None, ), # 4
+ (5, TType.STRUCT, 'nodes', (HBNodes, HBNodes.thrift_spec), None, ), # 5
+ None, # 6
+ (7, TType.STRING, 'message_blob', None, None, ), # 7
+ )
+
+ def __init__(self, path=None, pulse=None, boolval=None, records=None, nodes=None, message_blob=None,):
+ self.path = path
+ self.pulse = pulse
+ self.boolval = boolval
+ self.records = records
+ self.nodes = nodes
+ self.message_blob = message_blob
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.path = iprot.readString().decode('utf-8')
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRUCT:
+ self.pulse = HBPulse()
+ self.pulse.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.BOOL:
- self.boolval = iprot.readBool();
++ self.boolval = iprot.readBool()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRUCT:
+ self.records = HBRecords()
+ self.records.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.STRUCT:
+ self.nodes = HBNodes()
+ self.nodes.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.STRING:
- self.message_blob = iprot.readString();
++ self.message_blob = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('HBMessageData')
+ if self.path is not None:
+ oprot.writeFieldBegin('path', TType.STRING, 1)
+ oprot.writeString(self.path.encode('utf-8'))
+ oprot.writeFieldEnd()
+ if self.pulse is not None:
+ oprot.writeFieldBegin('pulse', TType.STRUCT, 2)
+ self.pulse.write(oprot)
+ oprot.writeFieldEnd()
+ if self.boolval is not None:
+ oprot.writeFieldBegin('boolval', TType.BOOL, 3)
+ oprot.writeBool(self.boolval)
+ oprot.writeFieldEnd()
+ if self.records is not None:
+ oprot.writeFieldBegin('records', TType.STRUCT, 4)
+ self.records.write(oprot)
+ oprot.writeFieldEnd()
+ if self.nodes is not None:
+ oprot.writeFieldBegin('nodes', TType.STRUCT, 5)
+ self.nodes.write(oprot)
+ oprot.writeFieldEnd()
+ if self.message_blob is not None:
+ oprot.writeFieldBegin('message_blob', TType.STRING, 7)
+ oprot.writeString(self.message_blob)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.path)
+ value = (value * 31) ^ hash(self.pulse)
+ value = (value * 31) ^ hash(self.boolval)
+ value = (value * 31) ^ hash(self.records)
+ value = (value * 31) ^ hash(self.nodes)
+ value = (value * 31) ^ hash(self.message_blob)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class HBMessage:
+ """
+ Attributes:
+ - type
+ - data
+ - message_id
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I32, 'type', None, None, ), # 1
+ (2, TType.STRUCT, 'data', (HBMessageData, HBMessageData.thrift_spec), None, ), # 2
+ (3, TType.I32, 'message_id', None, -1, ), # 3
+ )
+
+ def __init__(self, type=None, data=None, message_id=thrift_spec[3][4],):
+ self.type = type
+ self.data = data
+ self.message_id = message_id
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.I32:
- self.type = iprot.readI32();
++ self.type = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRUCT:
+ self.data = HBMessageData()
+ self.data.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.I32:
- self.message_id = iprot.readI32();
++ self.message_id = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('HBMessage')
+ if self.type is not None:
+ oprot.writeFieldBegin('type', TType.I32, 1)
+ oprot.writeI32(self.type)
+ oprot.writeFieldEnd()
+ if self.data is not None:
+ oprot.writeFieldBegin('data', TType.STRUCT, 2)
+ self.data.write(oprot)
+ oprot.writeFieldEnd()
+ if self.message_id is not None:
+ oprot.writeFieldBegin('message_id', TType.I32, 3)
+ oprot.writeI32(self.message_id)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.type)
+ value = (value * 31) ^ hash(self.data)
+ value = (value * 31) ^ hash(self.message_id)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class HBAuthorizationException(TException):
+ """
+ Attributes:
+ - msg
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'msg', None, None, ), # 1
+ )
+
+ def __init__(self, msg=None,):
+ self.msg = msg
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.msg = iprot.readString().decode('utf-8')
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('HBAuthorizationException')
+ if self.msg is not None:
+ oprot.writeFieldBegin('msg', TType.STRING, 1)
+ oprot.writeString(self.msg.encode('utf-8'))
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.msg is None:
+ raise TProtocol.TProtocolException(message='Required field msg is unset!')
+ return
+
+
+ def __str__(self):
+ return repr(self)
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.msg)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class HBExecutionException(TException):
+ """
+ Attributes:
+ - msg
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'msg', None, None, ), # 1
+ )
+
+ def __init__(self, msg=None,):
+ self.msg = msg
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.msg = iprot.readString().decode('utf-8')
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('HBExecutionException')
+ if self.msg is not None:
+ oprot.writeFieldBegin('msg', TType.STRING, 1)
+ oprot.writeString(self.msg.encode('utf-8'))
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.msg is None:
+ raise TProtocol.TProtocolException(message='Required field msg is unset!')
+ return
+
+
+ def __str__(self):
+ return repr(self)
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.msg)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class HBPulse:
+ """
+ Attributes:
+ - id
+ - details
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'id', None, None, ), # 1
+ (2, TType.STRING, 'details', None, None, ), # 2
+ )
+
+ def __init__(self, id=None, details=None,):
+ self.id = id
+ self.details = details
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.id = iprot.readString().decode('utf-8')
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
- self.details = iprot.readString();
++ self.details = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('HBPulse')
+ if self.id is not None:
+ oprot.writeFieldBegin('id', TType.STRING, 1)
+ oprot.writeString(self.id.encode('utf-8'))
+ oprot.writeFieldEnd()
+ if self.details is not None:
+ oprot.writeFieldBegin('details', TType.STRING, 2)
+ oprot.writeString(self.details)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.id is None:
+ raise TProtocol.TProtocolException(message='Required field id is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.id)
+ value = (value * 31) ^ hash(self.details)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class HBRecords:
+ """
+ Attributes:
+ - pulses
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.LIST, 'pulses', (TType.STRUCT,(HBPulse, HBPulse.thrift_spec)), None, ), # 1
+ )
+
+ def __init__(self, pulses=None,):
+ self.pulses = pulses
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.LIST:
+ self.pulses = []
- (_etype599, _size596) = iprot.readListBegin()
- for _i600 in xrange(_size596):
- _elem601 = HBPulse()
- _elem601.read(iprot)
- self.pulses.append(_elem601)
++ (_etype627, _size624) = iprot.readListBegin()
++ for _i628 in xrange(_size624):
++ _elem629 = HBPulse()
++ _elem629.read(iprot)
++ self.pulses.append(_elem629)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('HBRecords')
+ if self.pulses is not None:
+ oprot.writeFieldBegin('pulses', TType.LIST, 1)
+ oprot.writeListBegin(TType.STRUCT, len(self.pulses))
- for iter602 in self.pulses:
- iter602.write(oprot)
++ for iter630 in self.pulses:
++ iter630.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.pulses)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class HBNodes:
+ """
+ Attributes:
+ - pulseIds
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.LIST, 'pulseIds', (TType.STRING,None), None, ), # 1
+ )
+
+ def __init__(self, pulseIds=None,):
+ self.pulseIds = pulseIds
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.LIST:
+ self.pulseIds = []
- (_etype606, _size603) = iprot.readListBegin()
- for _i607 in xrange(_size603):
- _elem608 = iprot.readString().decode('utf-8')
- self.pulseIds.append(_elem608)
++ (_etype634, _size631) = iprot.readListBegin()
++ for _i635 in xrange(_size631):
++ _elem636 = iprot.readString().decode('utf-8')
++ self.pulseIds.append(_elem636)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('HBNodes')
+ if self.pulseIds is not None:
+ oprot.writeFieldBegin('pulseIds', TType.LIST, 1)
+ oprot.writeListBegin(TType.STRING, len(self.pulseIds))
- for iter609 in self.pulseIds:
- oprot.writeString(iter609.encode('utf-8'))
++ for iter637 in self.pulseIds:
++ oprot.writeString(iter637.encode('utf-8'))
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.pulseIds)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)