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 2016/10/11 02:04:08 UTC
[22/55] [abbrv] [partial] storm git commit: Ported successfully.
http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/HBMessage.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/HBMessage.java b/storm-core/src/jvm/backtype/storm/generated/HBMessage.java
deleted file mode 100644
index 29d3b21..0000000
--- a/storm-core/src/jvm/backtype/storm/generated/HBMessage.java
+++ /dev/null
@@ -1,636 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-/**
- * Autogenerated by Thrift Compiler (0.9.3)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-package org.apache.storm.generated;
-
-import org.apache.thrift.scheme.IScheme;
-import org.apache.thrift.scheme.SchemeFactory;
-import org.apache.thrift.scheme.StandardScheme;
-
-import org.apache.thrift.scheme.TupleScheme;
-import org.apache.thrift.protocol.TTupleProtocol;
-import org.apache.thrift.protocol.TProtocolException;
-import org.apache.thrift.EncodingUtils;
-import org.apache.thrift.TException;
-import org.apache.thrift.async.AsyncMethodCallback;
-import org.apache.thrift.server.AbstractNonblockingServer.*;
-import java.util.List;
-import java.util.ArrayList;
-import java.util.Map;
-import java.util.HashMap;
-import java.util.EnumMap;
-import java.util.Set;
-import java.util.HashSet;
-import java.util.EnumSet;
-import java.util.Collections;
-import java.util.BitSet;
-import java.nio.ByteBuffer;
-import java.util.Arrays;
-import javax.annotation.Generated;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
-public class HBMessage implements org.apache.thrift.TBase<HBMessage, HBMessage._Fields>, java.io.Serializable, Cloneable, Comparable<HBMessage> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("HBMessage");
-
- private static final org.apache.thrift.protocol.TField TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("type", org.apache.thrift.protocol.TType.I32, (short)1);
- private static final org.apache.thrift.protocol.TField DATA_FIELD_DESC = new org.apache.thrift.protocol.TField("data", org.apache.thrift.protocol.TType.STRUCT, (short)2);
- private static final org.apache.thrift.protocol.TField MESSAGE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("message_id", org.apache.thrift.protocol.TType.I32, (short)3);
-
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new HBMessageStandardSchemeFactory());
- schemes.put(TupleScheme.class, new HBMessageTupleSchemeFactory());
- }
-
- private HBServerMessageType type; // required
- private HBMessageData data; // required
- private int message_id; // 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 {
- /**
- *
- * @see HBServerMessageType
- */
- TYPE((short)1, "type"),
- DATA((short)2, "data"),
- MESSAGE_ID((short)3, "message_id");
-
- 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: // TYPE
- return TYPE;
- case 2: // DATA
- return DATA;
- case 3: // MESSAGE_ID
- return MESSAGE_ID;
- 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 __MESSAGE_ID_ISSET_ID = 0;
- private byte __isset_bitfield = 0;
- private static final _Fields optionals[] = {_Fields.MESSAGE_ID};
- 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.TYPE, new org.apache.thrift.meta_data.FieldMetaData("type", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, HBServerMessageType.class)));
- tmpMap.put(_Fields.DATA, new org.apache.thrift.meta_data.FieldMetaData("data", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, HBMessageData.class)));
- tmpMap.put(_Fields.MESSAGE_ID, new org.apache.thrift.meta_data.FieldMetaData("message_id", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(HBMessage.class, metaDataMap);
- }
-
- public HBMessage() {
- this.message_id = -1;
-
- }
-
- public HBMessage(
- HBServerMessageType type,
- HBMessageData data)
- {
- this();
- this.type = type;
- this.data = data;
- }
-
- /**
- * Performs a deep copy on <i>other</i>.
- */
- public HBMessage(HBMessage other) {
- __isset_bitfield = other.__isset_bitfield;
- if (other.is_set_type()) {
- this.type = other.type;
- }
- if (other.is_set_data()) {
- this.data = new HBMessageData(other.data);
- }
- this.message_id = other.message_id;
- }
-
- public HBMessage deepCopy() {
- return new HBMessage(this);
- }
-
- @Override
- public void clear() {
- this.type = null;
- this.data = null;
- this.message_id = -1;
-
- }
-
- /**
- *
- * @see HBServerMessageType
- */
- public HBServerMessageType get_type() {
- return this.type;
- }
-
- /**
- *
- * @see HBServerMessageType
- */
- public void set_type(HBServerMessageType type) {
- this.type = type;
- }
-
- public void unset_type() {
- this.type = null;
- }
-
- /** Returns true if field type is set (has been assigned a value) and false otherwise */
- public boolean is_set_type() {
- return this.type != null;
- }
-
- public void set_type_isSet(boolean value) {
- if (!value) {
- this.type = null;
- }
- }
-
- public HBMessageData get_data() {
- return this.data;
- }
-
- public void set_data(HBMessageData data) {
- this.data = data;
- }
-
- public void unset_data() {
- this.data = null;
- }
-
- /** Returns true if field data is set (has been assigned a value) and false otherwise */
- public boolean is_set_data() {
- return this.data != null;
- }
-
- public void set_data_isSet(boolean value) {
- if (!value) {
- this.data = null;
- }
- }
-
- public int get_message_id() {
- return this.message_id;
- }
-
- public void set_message_id(int message_id) {
- this.message_id = message_id;
- set_message_id_isSet(true);
- }
-
- public void unset_message_id() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MESSAGE_ID_ISSET_ID);
- }
-
- /** Returns true if field message_id is set (has been assigned a value) and false otherwise */
- public boolean is_set_message_id() {
- return EncodingUtils.testBit(__isset_bitfield, __MESSAGE_ID_ISSET_ID);
- }
-
- public void set_message_id_isSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MESSAGE_ID_ISSET_ID, value);
- }
-
- public void setFieldValue(_Fields field, Object value) {
- switch (field) {
- case TYPE:
- if (value == null) {
- unset_type();
- } else {
- set_type((HBServerMessageType)value);
- }
- break;
-
- case DATA:
- if (value == null) {
- unset_data();
- } else {
- set_data((HBMessageData)value);
- }
- break;
-
- case MESSAGE_ID:
- if (value == null) {
- unset_message_id();
- } else {
- set_message_id((Integer)value);
- }
- break;
-
- }
- }
-
- public Object getFieldValue(_Fields field) {
- switch (field) {
- case TYPE:
- return get_type();
-
- case DATA:
- return get_data();
-
- case MESSAGE_ID:
- return get_message_id();
-
- }
- 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 TYPE:
- return is_set_type();
- case DATA:
- return is_set_data();
- case MESSAGE_ID:
- return is_set_message_id();
- }
- throw new IllegalStateException();
- }
-
- @Override
- public boolean equals(Object that) {
- if (that == null)
- return false;
- if (that instanceof HBMessage)
- return this.equals((HBMessage)that);
- return false;
- }
-
- public boolean equals(HBMessage that) {
- if (that == null)
- return false;
-
- boolean this_present_type = true && this.is_set_type();
- boolean that_present_type = true && that.is_set_type();
- if (this_present_type || that_present_type) {
- if (!(this_present_type && that_present_type))
- return false;
- if (!this.type.equals(that.type))
- return false;
- }
-
- boolean this_present_data = true && this.is_set_data();
- boolean that_present_data = true && that.is_set_data();
- if (this_present_data || that_present_data) {
- if (!(this_present_data && that_present_data))
- return false;
- if (!this.data.equals(that.data))
- return false;
- }
-
- boolean this_present_message_id = true && this.is_set_message_id();
- boolean that_present_message_id = true && that.is_set_message_id();
- if (this_present_message_id || that_present_message_id) {
- if (!(this_present_message_id && that_present_message_id))
- return false;
- if (this.message_id != that.message_id)
- return false;
- }
-
- return true;
- }
-
- @Override
- public int hashCode() {
- List<Object> list = new ArrayList<Object>();
-
- boolean present_type = true && (is_set_type());
- list.add(present_type);
- if (present_type)
- list.add(type.getValue());
-
- boolean present_data = true && (is_set_data());
- list.add(present_data);
- if (present_data)
- list.add(data);
-
- boolean present_message_id = true && (is_set_message_id());
- list.add(present_message_id);
- if (present_message_id)
- list.add(message_id);
-
- return list.hashCode();
- }
-
- @Override
- public int compareTo(HBMessage other) {
- if (!getClass().equals(other.getClass())) {
- return getClass().getName().compareTo(other.getClass().getName());
- }
-
- int lastComparison = 0;
-
- lastComparison = Boolean.valueOf(is_set_type()).compareTo(other.is_set_type());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_type()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.type, other.type);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(is_set_data()).compareTo(other.is_set_data());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_data()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.data, other.data);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(is_set_message_id()).compareTo(other.is_set_message_id());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (is_set_message_id()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.message_id, other.message_id);
- 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("HBMessage(");
- boolean first = true;
-
- sb.append("type:");
- if (this.type == null) {
- sb.append("null");
- } else {
- sb.append(this.type);
- }
- first = false;
- if (!first) sb.append(", ");
- sb.append("data:");
- if (this.data == null) {
- sb.append("null");
- } else {
- sb.append(this.data);
- }
- first = false;
- if (is_set_message_id()) {
- if (!first) sb.append(", ");
- sb.append("message_id:");
- sb.append(this.message_id);
- 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 {
- // 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 HBMessageStandardSchemeFactory implements SchemeFactory {
- public HBMessageStandardScheme getScheme() {
- return new HBMessageStandardScheme();
- }
- }
-
- private static class HBMessageStandardScheme extends StandardScheme<HBMessage> {
-
- public void read(org.apache.thrift.protocol.TProtocol iprot, HBMessage 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: // TYPE
- if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
- struct.type = org.apache.storm.generated.HBServerMessageType.findByValue(iprot.readI32());
- struct.set_type_isSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 2: // DATA
- if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
- struct.data = new HBMessageData();
- struct.data.read(iprot);
- struct.set_data_isSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 3: // MESSAGE_ID
- if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
- struct.message_id = iprot.readI32();
- struct.set_message_id_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, HBMessage struct) throws org.apache.thrift.TException {
- struct.validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (struct.type != null) {
- oprot.writeFieldBegin(TYPE_FIELD_DESC);
- oprot.writeI32(struct.type.getValue());
- oprot.writeFieldEnd();
- }
- if (struct.data != null) {
- oprot.writeFieldBegin(DATA_FIELD_DESC);
- struct.data.write(oprot);
- oprot.writeFieldEnd();
- }
- if (struct.is_set_message_id()) {
- oprot.writeFieldBegin(MESSAGE_ID_FIELD_DESC);
- oprot.writeI32(struct.message_id);
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
- }
-
- }
-
- private static class HBMessageTupleSchemeFactory implements SchemeFactory {
- public HBMessageTupleScheme getScheme() {
- return new HBMessageTupleScheme();
- }
- }
-
- private static class HBMessageTupleScheme extends TupleScheme<HBMessage> {
-
- @Override
- public void write(org.apache.thrift.protocol.TProtocol prot, HBMessage struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- BitSet optionals = new BitSet();
- if (struct.is_set_type()) {
- optionals.set(0);
- }
- if (struct.is_set_data()) {
- optionals.set(1);
- }
- if (struct.is_set_message_id()) {
- optionals.set(2);
- }
- oprot.writeBitSet(optionals, 3);
- if (struct.is_set_type()) {
- oprot.writeI32(struct.type.getValue());
- }
- if (struct.is_set_data()) {
- struct.data.write(oprot);
- }
- if (struct.is_set_message_id()) {
- oprot.writeI32(struct.message_id);
- }
- }
-
- @Override
- public void read(org.apache.thrift.protocol.TProtocol prot, HBMessage struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(3);
- if (incoming.get(0)) {
- struct.type = org.apache.storm.generated.HBServerMessageType.findByValue(iprot.readI32());
- struct.set_type_isSet(true);
- }
- if (incoming.get(1)) {
- struct.data = new HBMessageData();
- struct.data.read(iprot);
- struct.set_data_isSet(true);
- }
- if (incoming.get(2)) {
- struct.message_id = iprot.readI32();
- struct.set_message_id_isSet(true);
- }
- }
- }
-
-}
-
http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/HBMessageData.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/HBMessageData.java b/storm-core/src/jvm/backtype/storm/generated/HBMessageData.java
deleted file mode 100644
index b100da1..0000000
--- a/storm-core/src/jvm/backtype/storm/generated/HBMessageData.java
+++ /dev/null
@@ -1,640 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-/**
- * Autogenerated by Thrift Compiler (0.9.3)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-package org.apache.storm.generated;
-
-import org.apache.thrift.scheme.IScheme;
-import org.apache.thrift.scheme.SchemeFactory;
-import org.apache.thrift.scheme.StandardScheme;
-
-import org.apache.thrift.scheme.TupleScheme;
-import org.apache.thrift.protocol.TTupleProtocol;
-import org.apache.thrift.protocol.TProtocolException;
-import org.apache.thrift.EncodingUtils;
-import org.apache.thrift.TException;
-import org.apache.thrift.async.AsyncMethodCallback;
-import org.apache.thrift.server.AbstractNonblockingServer.*;
-import java.util.List;
-import java.util.ArrayList;
-import java.util.Map;
-import java.util.HashMap;
-import java.util.EnumMap;
-import java.util.Set;
-import java.util.HashSet;
-import java.util.EnumSet;
-import java.util.Collections;
-import java.util.BitSet;
-import java.nio.ByteBuffer;
-import java.util.Arrays;
-import javax.annotation.Generated;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-public class HBMessageData extends org.apache.thrift.TUnion<HBMessageData, HBMessageData._Fields> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("HBMessageData");
- private static final org.apache.thrift.protocol.TField PATH_FIELD_DESC = new org.apache.thrift.protocol.TField("path", org.apache.thrift.protocol.TType.STRING, (short)1);
- private static final org.apache.thrift.protocol.TField PULSE_FIELD_DESC = new org.apache.thrift.protocol.TField("pulse", org.apache.thrift.protocol.TType.STRUCT, (short)2);
- private static final org.apache.thrift.protocol.TField BOOLVAL_FIELD_DESC = new org.apache.thrift.protocol.TField("boolval", org.apache.thrift.protocol.TType.BOOL, (short)3);
- private static final org.apache.thrift.protocol.TField RECORDS_FIELD_DESC = new org.apache.thrift.protocol.TField("records", org.apache.thrift.protocol.TType.STRUCT, (short)4);
- private static final org.apache.thrift.protocol.TField NODES_FIELD_DESC = new org.apache.thrift.protocol.TField("nodes", org.apache.thrift.protocol.TType.STRUCT, (short)5);
- private static final org.apache.thrift.protocol.TField MESSAGE_BLOB_FIELD_DESC = new org.apache.thrift.protocol.TField("message_blob", org.apache.thrift.protocol.TType.STRING, (short)7);
-
- /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
- public enum _Fields implements org.apache.thrift.TFieldIdEnum {
- PATH((short)1, "path"),
- PULSE((short)2, "pulse"),
- BOOLVAL((short)3, "boolval"),
- RECORDS((short)4, "records"),
- NODES((short)5, "nodes"),
- MESSAGE_BLOB((short)7, "message_blob");
-
- 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: // PATH
- return PATH;
- case 2: // PULSE
- return PULSE;
- case 3: // BOOLVAL
- return BOOLVAL;
- case 4: // RECORDS
- return RECORDS;
- case 5: // NODES
- return NODES;
- case 7: // MESSAGE_BLOB
- return MESSAGE_BLOB;
- 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;
- }
- }
-
- 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.PATH, new org.apache.thrift.meta_data.FieldMetaData("path", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- tmpMap.put(_Fields.PULSE, new org.apache.thrift.meta_data.FieldMetaData("pulse", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, HBPulse.class)));
- tmpMap.put(_Fields.BOOLVAL, new org.apache.thrift.meta_data.FieldMetaData("boolval", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
- tmpMap.put(_Fields.RECORDS, new org.apache.thrift.meta_data.FieldMetaData("records", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, HBRecords.class)));
- tmpMap.put(_Fields.NODES, new org.apache.thrift.meta_data.FieldMetaData("nodes", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, HBNodes.class)));
- tmpMap.put(_Fields.MESSAGE_BLOB, new org.apache.thrift.meta_data.FieldMetaData("message_blob", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- 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(HBMessageData.class, metaDataMap);
- }
-
- public HBMessageData() {
- super();
- }
-
- public HBMessageData(_Fields setField, Object value) {
- super(setField, value);
- }
-
- public HBMessageData(HBMessageData other) {
- super(other);
- }
- public HBMessageData deepCopy() {
- return new HBMessageData(this);
- }
-
- public static HBMessageData path(String value) {
- HBMessageData x = new HBMessageData();
- x.set_path(value);
- return x;
- }
-
- public static HBMessageData pulse(HBPulse value) {
- HBMessageData x = new HBMessageData();
- x.set_pulse(value);
- return x;
- }
-
- public static HBMessageData boolval(boolean value) {
- HBMessageData x = new HBMessageData();
- x.set_boolval(value);
- return x;
- }
-
- public static HBMessageData records(HBRecords value) {
- HBMessageData x = new HBMessageData();
- x.set_records(value);
- return x;
- }
-
- public static HBMessageData nodes(HBNodes value) {
- HBMessageData x = new HBMessageData();
- x.set_nodes(value);
- return x;
- }
-
- public static HBMessageData message_blob(ByteBuffer value) {
- HBMessageData x = new HBMessageData();
- x.set_message_blob(value);
- return x;
- }
-
- public static HBMessageData message_blob(byte[] value) {
- HBMessageData x = new HBMessageData();
- x.set_message_blob(ByteBuffer.wrap(Arrays.copyOf(value, value.length)));
- return x;
- }
-
-
- @Override
- protected void checkType(_Fields setField, Object value) throws ClassCastException {
- switch (setField) {
- case PATH:
- if (value instanceof String) {
- break;
- }
- throw new ClassCastException("Was expecting value of type String for field 'path', but got " + value.getClass().getSimpleName());
- case PULSE:
- if (value instanceof HBPulse) {
- break;
- }
- throw new ClassCastException("Was expecting value of type HBPulse for field 'pulse', but got " + value.getClass().getSimpleName());
- case BOOLVAL:
- if (value instanceof Boolean) {
- break;
- }
- throw new ClassCastException("Was expecting value of type Boolean for field 'boolval', but got " + value.getClass().getSimpleName());
- case RECORDS:
- if (value instanceof HBRecords) {
- break;
- }
- throw new ClassCastException("Was expecting value of type HBRecords for field 'records', but got " + value.getClass().getSimpleName());
- case NODES:
- if (value instanceof HBNodes) {
- break;
- }
- throw new ClassCastException("Was expecting value of type HBNodes for field 'nodes', but got " + value.getClass().getSimpleName());
- case MESSAGE_BLOB:
- if (value instanceof ByteBuffer) {
- break;
- }
- throw new ClassCastException("Was expecting value of type ByteBuffer for field 'message_blob', but got " + value.getClass().getSimpleName());
- default:
- throw new IllegalArgumentException("Unknown field id " + setField);
- }
- }
-
- @Override
- protected Object standardSchemeReadValue(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TField field) throws org.apache.thrift.TException {
- _Fields setField = _Fields.findByThriftId(field.id);
- if (setField != null) {
- switch (setField) {
- case PATH:
- if (field.type == PATH_FIELD_DESC.type) {
- String path;
- path = iprot.readString();
- return path;
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- return null;
- }
- case PULSE:
- if (field.type == PULSE_FIELD_DESC.type) {
- HBPulse pulse;
- pulse = new HBPulse();
- pulse.read(iprot);
- return pulse;
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- return null;
- }
- case BOOLVAL:
- if (field.type == BOOLVAL_FIELD_DESC.type) {
- Boolean boolval;
- boolval = iprot.readBool();
- return boolval;
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- return null;
- }
- case RECORDS:
- if (field.type == RECORDS_FIELD_DESC.type) {
- HBRecords records;
- records = new HBRecords();
- records.read(iprot);
- return records;
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- return null;
- }
- case NODES:
- if (field.type == NODES_FIELD_DESC.type) {
- HBNodes nodes;
- nodes = new HBNodes();
- nodes.read(iprot);
- return nodes;
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- return null;
- }
- case MESSAGE_BLOB:
- if (field.type == MESSAGE_BLOB_FIELD_DESC.type) {
- ByteBuffer message_blob;
- message_blob = iprot.readBinary();
- return message_blob;
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- return null;
- }
- default:
- throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
- }
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- return null;
- }
- }
-
- @Override
- protected void standardSchemeWriteValue(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- switch (setField_) {
- case PATH:
- String path = (String)value_;
- oprot.writeString(path);
- return;
- case PULSE:
- HBPulse pulse = (HBPulse)value_;
- pulse.write(oprot);
- return;
- case BOOLVAL:
- Boolean boolval = (Boolean)value_;
- oprot.writeBool(boolval);
- return;
- case RECORDS:
- HBRecords records = (HBRecords)value_;
- records.write(oprot);
- return;
- case NODES:
- HBNodes nodes = (HBNodes)value_;
- nodes.write(oprot);
- return;
- case MESSAGE_BLOB:
- ByteBuffer message_blob = (ByteBuffer)value_;
- oprot.writeBinary(message_blob);
- return;
- default:
- throw new IllegalStateException("Cannot write union with unknown field " + setField_);
- }
- }
-
- @Override
- protected Object tupleSchemeReadValue(org.apache.thrift.protocol.TProtocol iprot, short fieldID) throws org.apache.thrift.TException {
- _Fields setField = _Fields.findByThriftId(fieldID);
- if (setField != null) {
- switch (setField) {
- case PATH:
- String path;
- path = iprot.readString();
- return path;
- case PULSE:
- HBPulse pulse;
- pulse = new HBPulse();
- pulse.read(iprot);
- return pulse;
- case BOOLVAL:
- Boolean boolval;
- boolval = iprot.readBool();
- return boolval;
- case RECORDS:
- HBRecords records;
- records = new HBRecords();
- records.read(iprot);
- return records;
- case NODES:
- HBNodes nodes;
- nodes = new HBNodes();
- nodes.read(iprot);
- return nodes;
- case MESSAGE_BLOB:
- ByteBuffer message_blob;
- message_blob = iprot.readBinary();
- return message_blob;
- default:
- throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
- }
- } else {
- throw new TProtocolException("Couldn't find a field with field id " + fieldID);
- }
- }
-
- @Override
- protected void tupleSchemeWriteValue(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- switch (setField_) {
- case PATH:
- String path = (String)value_;
- oprot.writeString(path);
- return;
- case PULSE:
- HBPulse pulse = (HBPulse)value_;
- pulse.write(oprot);
- return;
- case BOOLVAL:
- Boolean boolval = (Boolean)value_;
- oprot.writeBool(boolval);
- return;
- case RECORDS:
- HBRecords records = (HBRecords)value_;
- records.write(oprot);
- return;
- case NODES:
- HBNodes nodes = (HBNodes)value_;
- nodes.write(oprot);
- return;
- case MESSAGE_BLOB:
- ByteBuffer message_blob = (ByteBuffer)value_;
- oprot.writeBinary(message_blob);
- return;
- default:
- throw new IllegalStateException("Cannot write union with unknown field " + setField_);
- }
- }
-
- @Override
- protected org.apache.thrift.protocol.TField getFieldDesc(_Fields setField) {
- switch (setField) {
- case PATH:
- return PATH_FIELD_DESC;
- case PULSE:
- return PULSE_FIELD_DESC;
- case BOOLVAL:
- return BOOLVAL_FIELD_DESC;
- case RECORDS:
- return RECORDS_FIELD_DESC;
- case NODES:
- return NODES_FIELD_DESC;
- case MESSAGE_BLOB:
- return MESSAGE_BLOB_FIELD_DESC;
- default:
- throw new IllegalArgumentException("Unknown field id " + setField);
- }
- }
-
- @Override
- protected org.apache.thrift.protocol.TStruct getStructDesc() {
- return STRUCT_DESC;
- }
-
- @Override
- protected _Fields enumForId(short id) {
- return _Fields.findByThriftIdOrThrow(id);
- }
-
- public _Fields fieldForId(int fieldId) {
- return _Fields.findByThriftId(fieldId);
- }
-
-
- public String get_path() {
- if (getSetField() == _Fields.PATH) {
- return (String)getFieldValue();
- } else {
- throw new RuntimeException("Cannot get field 'path' because union is currently set to " + getFieldDesc(getSetField()).name);
- }
- }
-
- public void set_path(String value) {
- if (value == null) throw new NullPointerException();
- setField_ = _Fields.PATH;
- value_ = value;
- }
-
- public HBPulse get_pulse() {
- if (getSetField() == _Fields.PULSE) {
- return (HBPulse)getFieldValue();
- } else {
- throw new RuntimeException("Cannot get field 'pulse' because union is currently set to " + getFieldDesc(getSetField()).name);
- }
- }
-
- public void set_pulse(HBPulse value) {
- if (value == null) throw new NullPointerException();
- setField_ = _Fields.PULSE;
- value_ = value;
- }
-
- public boolean get_boolval() {
- if (getSetField() == _Fields.BOOLVAL) {
- return (Boolean)getFieldValue();
- } else {
- throw new RuntimeException("Cannot get field 'boolval' because union is currently set to " + getFieldDesc(getSetField()).name);
- }
- }
-
- public void set_boolval(boolean value) {
- setField_ = _Fields.BOOLVAL;
- value_ = value;
- }
-
- public HBRecords get_records() {
- if (getSetField() == _Fields.RECORDS) {
- return (HBRecords)getFieldValue();
- } else {
- throw new RuntimeException("Cannot get field 'records' because union is currently set to " + getFieldDesc(getSetField()).name);
- }
- }
-
- public void set_records(HBRecords value) {
- if (value == null) throw new NullPointerException();
- setField_ = _Fields.RECORDS;
- value_ = value;
- }
-
- public HBNodes get_nodes() {
- if (getSetField() == _Fields.NODES) {
- return (HBNodes)getFieldValue();
- } else {
- throw new RuntimeException("Cannot get field 'nodes' because union is currently set to " + getFieldDesc(getSetField()).name);
- }
- }
-
- public void set_nodes(HBNodes value) {
- if (value == null) throw new NullPointerException();
- setField_ = _Fields.NODES;
- value_ = value;
- }
-
- public byte[] get_message_blob() {
- set_message_blob(org.apache.thrift.TBaseHelper.rightSize(buffer_for_message_blob()));
- ByteBuffer b = buffer_for_message_blob();
- return b == null ? null : b.array();
- }
-
- public ByteBuffer buffer_for_message_blob() {
- if (getSetField() == _Fields.MESSAGE_BLOB) {
- return org.apache.thrift.TBaseHelper.copyBinary((ByteBuffer)getFieldValue());
- } else {
- throw new RuntimeException("Cannot get field 'message_blob' because union is currently set to " + getFieldDesc(getSetField()).name);
- }
- }
-
- public void set_message_blob(byte[] value) {
- set_message_blob(ByteBuffer.wrap(Arrays.copyOf(value, value.length)));
- }
-
- public void set_message_blob(ByteBuffer value) {
- if (value == null) throw new NullPointerException();
- setField_ = _Fields.MESSAGE_BLOB;
- value_ = value;
- }
-
- public boolean is_set_path() {
- return setField_ == _Fields.PATH;
- }
-
-
- public boolean is_set_pulse() {
- return setField_ == _Fields.PULSE;
- }
-
-
- public boolean is_set_boolval() {
- return setField_ == _Fields.BOOLVAL;
- }
-
-
- public boolean is_set_records() {
- return setField_ == _Fields.RECORDS;
- }
-
-
- public boolean is_set_nodes() {
- return setField_ == _Fields.NODES;
- }
-
-
- public boolean is_set_message_blob() {
- return setField_ == _Fields.MESSAGE_BLOB;
- }
-
-
- public boolean equals(Object other) {
- if (other instanceof HBMessageData) {
- return equals((HBMessageData)other);
- } else {
- return false;
- }
- }
-
- public boolean equals(HBMessageData other) {
- return other != null && getSetField() == other.getSetField() && getFieldValue().equals(other.getFieldValue());
- }
-
- @Override
- public int compareTo(HBMessageData other) {
- int lastComparison = org.apache.thrift.TBaseHelper.compareTo(getSetField(), other.getSetField());
- if (lastComparison == 0) {
- return org.apache.thrift.TBaseHelper.compareTo(getFieldValue(), other.getFieldValue());
- }
- return lastComparison;
- }
-
-
- @Override
- public int hashCode() {
- List<Object> list = new ArrayList<Object>();
- list.add(this.getClass().getName());
- org.apache.thrift.TFieldIdEnum setField = getSetField();
- if (setField != null) {
- list.add(setField.getThriftFieldId());
- Object value = getFieldValue();
- if (value instanceof org.apache.thrift.TEnum) {
- list.add(((org.apache.thrift.TEnum)getFieldValue()).getValue());
- } else {
- list.add(value);
- }
- }
- return list.hashCode();
- }
- 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);
- }
- }
-
-
-}
http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/HBNodes.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/HBNodes.java b/storm-core/src/jvm/backtype/storm/generated/HBNodes.java
deleted file mode 100644
index c5c7407..0000000
--- a/storm-core/src/jvm/backtype/storm/generated/HBNodes.java
+++ /dev/null
@@ -1,461 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-/**
- * Autogenerated by Thrift Compiler (0.9.3)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-package org.apache.storm.generated;
-
-import org.apache.thrift.scheme.IScheme;
-import org.apache.thrift.scheme.SchemeFactory;
-import org.apache.thrift.scheme.StandardScheme;
-
-import org.apache.thrift.scheme.TupleScheme;
-import org.apache.thrift.protocol.TTupleProtocol;
-import org.apache.thrift.protocol.TProtocolException;
-import org.apache.thrift.EncodingUtils;
-import org.apache.thrift.TException;
-import org.apache.thrift.async.AsyncMethodCallback;
-import org.apache.thrift.server.AbstractNonblockingServer.*;
-import java.util.List;
-import java.util.ArrayList;
-import java.util.Map;
-import java.util.HashMap;
-import java.util.EnumMap;
-import java.util.Set;
-import java.util.HashSet;
-import java.util.EnumSet;
-import java.util.Collections;
-import java.util.BitSet;
-import java.nio.ByteBuffer;
-import java.util.Arrays;
-import javax.annotation.Generated;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
-public class 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 _list800 = iprot.readListBegin();
- struct.pulseIds = new ArrayList<String>(_list800.size);
- String _elem801;
- for (int _i802 = 0; _i802 < _list800.size; ++_i802)
- {
- _elem801 = iprot.readString();
- struct.pulseIds.add(_elem801);
- }
- 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 _iter803 : struct.pulseIds)
- {
- oprot.writeString(_iter803);
- }
- 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 _iter804 : struct.pulseIds)
- {
- oprot.writeString(_iter804);
- }
- }
- }
- }
-
- @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 _list805 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.pulseIds = new ArrayList<String>(_list805.size);
- String _elem806;
- for (int _i807 = 0; _i807 < _list805.size; ++_i807)
- {
- _elem806 = iprot.readString();
- struct.pulseIds.add(_elem806);
- }
- }
- struct.set_pulseIds_isSet(true);
- }
- }
- }
-
-}
-
http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/HBPulse.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/HBPulse.java b/storm-core/src/jvm/backtype/storm/generated/HBPulse.java
deleted file mode 100644
index 574857d..0000000
--- a/storm-core/src/jvm/backtype/storm/generated/HBPulse.java
+++ /dev/null
@@ -1,522 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-/**
- * Autogenerated by Thrift Compiler (0.9.3)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-package org.apache.storm.generated;
-
-import org.apache.thrift.scheme.IScheme;
-import org.apache.thrift.scheme.SchemeFactory;
-import org.apache.thrift.scheme.StandardScheme;
-
-import org.apache.thrift.scheme.TupleScheme;
-import org.apache.thrift.protocol.TTupleProtocol;
-import org.apache.thrift.protocol.TProtocolException;
-import org.apache.thrift.EncodingUtils;
-import org.apache.thrift.TException;
-import org.apache.thrift.async.AsyncMethodCallback;
-import org.apache.thrift.server.AbstractNonblockingServer.*;
-import java.util.List;
-import java.util.ArrayList;
-import java.util.Map;
-import java.util.HashMap;
-import java.util.EnumMap;
-import java.util.Set;
-import java.util.HashSet;
-import java.util.EnumSet;
-import java.util.Collections;
-import java.util.BitSet;
-import java.nio.ByteBuffer;
-import java.util.Arrays;
-import javax.annotation.Generated;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
-public class 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);
- }
- }
- }
-
-}
-