http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/ProfileRequest.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/ProfileRequest.java b/storm-core/src/jvm/backtype/storm/generated/ProfileRequest.java deleted file mode 100644 index 1189175..0000000 --- a/storm-core/src/jvm/backtype/storm/generated/ProfileRequest.java +++ /dev/null @@ -1,631 +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 ProfileRequest implements org.apache.thrift.TBase<ProfileRequest, ProfileRequest._Fields>, java.io.Serializable, Cloneable, Comparable<ProfileRequest> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ProfileRequest"); - - private static final org.apache.thrift.protocol.TField NODE_INFO_FIELD_DESC = new org.apache.thrift.protocol.TField("nodeInfo", org.apache.thrift.protocol.TType.STRUCT, (short)1); - private static final org.apache.thrift.protocol.TField ACTION_FIELD_DESC = new org.apache.thrift.protocol.TField("action", org.apache.thrift.protocol.TType.I32, (short)2); - private static final org.apache.thrift.protocol.TField TIME_STAMP_FIELD_DESC = new org.apache.thrift.protocol.TField("time_stamp", org.apache.thrift.protocol.TType.I64, (short)3); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new ProfileRequestStandardSchemeFactory()); - schemes.put(TupleScheme.class, new ProfileRequestTupleSchemeFactory()); - } - - private NodeInfo nodeInfo; // required - private ProfileAction action; // required - private long time_stamp; // 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 { - NODE_INFO((short)1, "nodeInfo"), - /** - * - * @see ProfileAction - */ - ACTION((short)2, "action"), - TIME_STAMP((short)3, "time_stamp"); - - 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: // NODE_INFO - return NODE_INFO; - case 2: // ACTION - return ACTION; - case 3: // TIME_STAMP - return TIME_STAMP; - 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 __TIME_STAMP_ISSET_ID = 0; - private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.TIME_STAMP}; - 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.NODE_INFO, new org.apache.thrift.meta_data.FieldMetaData("nodeInfo", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, NodeInfo.class))); - tmpMap.put(_Fields.ACTION, new org.apache.thrift.meta_data.FieldMetaData("action", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, ProfileAction.class))); - tmpMap.put(_Fields.TIME_STAMP, new org.apache.thrift.meta_data.FieldMetaData("time_stamp", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ProfileRequest.class, metaDataMap); - } - - public ProfileRequest() { - } - - public ProfileRequest( - NodeInfo nodeInfo, - ProfileAction action) - { - this(); - this.nodeInfo = nodeInfo; - this.action = action; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public ProfileRequest(ProfileRequest other) { - __isset_bitfield = other.__isset_bitfield; - if (other.is_set_nodeInfo()) { - this.nodeInfo = new NodeInfo(other.nodeInfo); - } - if (other.is_set_action()) { - this.action = other.action; - } - this.time_stamp = other.time_stamp; - } - - public ProfileRequest deepCopy() { - return new ProfileRequest(this); - } - - @Override - public void clear() { - this.nodeInfo = null; - this.action = null; - set_time_stamp_isSet(false); - this.time_stamp = 0; - } - - public NodeInfo get_nodeInfo() { - return this.nodeInfo; - } - - public void set_nodeInfo(NodeInfo nodeInfo) { - this.nodeInfo = nodeInfo; - } - - public void unset_nodeInfo() { - this.nodeInfo = null; - } - - /** Returns true if field nodeInfo is set (has been assigned a value) and false otherwise */ - public boolean is_set_nodeInfo() { - return this.nodeInfo != null; - } - - public void set_nodeInfo_isSet(boolean value) { - if (!value) { - this.nodeInfo = null; - } - } - - /** - * - * @see ProfileAction - */ - public ProfileAction get_action() { - return this.action; - } - - /** - * - * @see ProfileAction - */ - public void set_action(ProfileAction action) { - this.action = action; - } - - public void unset_action() { - this.action = null; - } - - /** Returns true if field action is set (has been assigned a value) and false otherwise */ - public boolean is_set_action() { - return this.action != null; - } - - public void set_action_isSet(boolean value) { - if (!value) { - this.action = null; - } - } - - public long get_time_stamp() { - return this.time_stamp; - } - - public void set_time_stamp(long time_stamp) { - this.time_stamp = time_stamp; - set_time_stamp_isSet(true); - } - - public void unset_time_stamp() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TIME_STAMP_ISSET_ID); - } - - /** Returns true if field time_stamp is set (has been assigned a value) and false otherwise */ - public boolean is_set_time_stamp() { - return EncodingUtils.testBit(__isset_bitfield, __TIME_STAMP_ISSET_ID); - } - - public void set_time_stamp_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TIME_STAMP_ISSET_ID, value); - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case NODE_INFO: - if (value == null) { - unset_nodeInfo(); - } else { - set_nodeInfo((NodeInfo)value); - } - break; - - case ACTION: - if (value == null) { - unset_action(); - } else { - set_action((ProfileAction)value); - } - break; - - case TIME_STAMP: - if (value == null) { - unset_time_stamp(); - } else { - set_time_stamp((Long)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case NODE_INFO: - return get_nodeInfo(); - - case ACTION: - return get_action(); - - case TIME_STAMP: - return get_time_stamp(); - - } - 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 NODE_INFO: - return is_set_nodeInfo(); - case ACTION: - return is_set_action(); - case TIME_STAMP: - return is_set_time_stamp(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof ProfileRequest) - return this.equals((ProfileRequest)that); - return false; - } - - public boolean equals(ProfileRequest that) { - if (that == null) - return false; - - boolean this_present_nodeInfo = true && this.is_set_nodeInfo(); - boolean that_present_nodeInfo = true && that.is_set_nodeInfo(); - if (this_present_nodeInfo || that_present_nodeInfo) { - if (!(this_present_nodeInfo && that_present_nodeInfo)) - return false; - if (!this.nodeInfo.equals(that.nodeInfo)) - return false; - } - - boolean this_present_action = true && this.is_set_action(); - boolean that_present_action = true && that.is_set_action(); - if (this_present_action || that_present_action) { - if (!(this_present_action && that_present_action)) - return false; - if (!this.action.equals(that.action)) - return false; - } - - boolean this_present_time_stamp = true && this.is_set_time_stamp(); - boolean that_present_time_stamp = true && that.is_set_time_stamp(); - if (this_present_time_stamp || that_present_time_stamp) { - if (!(this_present_time_stamp && that_present_time_stamp)) - return false; - if (this.time_stamp != that.time_stamp) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_nodeInfo = true && (is_set_nodeInfo()); - list.add(present_nodeInfo); - if (present_nodeInfo) - list.add(nodeInfo); - - boolean present_action = true && (is_set_action()); - list.add(present_action); - if (present_action) - list.add(action.getValue()); - - boolean present_time_stamp = true && (is_set_time_stamp()); - list.add(present_time_stamp); - if (present_time_stamp) - list.add(time_stamp); - - return list.hashCode(); - } - - @Override - public int compareTo(ProfileRequest other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(is_set_nodeInfo()).compareTo(other.is_set_nodeInfo()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_nodeInfo()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.nodeInfo, other.nodeInfo); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_action()).compareTo(other.is_set_action()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_action()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.action, other.action); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_time_stamp()).compareTo(other.is_set_time_stamp()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_time_stamp()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.time_stamp, other.time_stamp); - 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("ProfileRequest("); - boolean first = true; - - sb.append("nodeInfo:"); - if (this.nodeInfo == null) { - sb.append("null"); - } else { - sb.append(this.nodeInfo); - } - first = false; - if (!first) sb.append(", "); - sb.append("action:"); - if (this.action == null) { - sb.append("null"); - } else { - sb.append(this.action); - } - first = false; - if (is_set_time_stamp()) { - if (!first) sb.append(", "); - sb.append("time_stamp:"); - sb.append(this.time_stamp); - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (!is_set_nodeInfo()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'nodeInfo' is unset! Struct:" + toString()); - } - - if (!is_set_action()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'action' is unset! Struct:" + toString()); - } - - // check for sub-struct validity - if (nodeInfo != null) { - nodeInfo.validate(); - } - } - - private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { - try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { - try { - // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. - __isset_bitfield = 0; - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private static class ProfileRequestStandardSchemeFactory implements SchemeFactory { - public ProfileRequestStandardScheme getScheme() { - return new ProfileRequestStandardScheme(); - } - } - - private static class ProfileRequestStandardScheme extends StandardScheme<ProfileRequest> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, ProfileRequest 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: // NODE_INFO - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.nodeInfo = new NodeInfo(); - struct.nodeInfo.read(iprot); - struct.set_nodeInfo_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // ACTION - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.action = org.apache.storm.generated.ProfileAction.findByValue(iprot.readI32()); - struct.set_action_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // TIME_STAMP - if (schemeField.type == org.apache.thrift.protocol.TType.I64) { - struct.time_stamp = iprot.readI64(); - struct.set_time_stamp_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, ProfileRequest struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.nodeInfo != null) { - oprot.writeFieldBegin(NODE_INFO_FIELD_DESC); - struct.nodeInfo.write(oprot); - oprot.writeFieldEnd(); - } - if (struct.action != null) { - oprot.writeFieldBegin(ACTION_FIELD_DESC); - oprot.writeI32(struct.action.getValue()); - oprot.writeFieldEnd(); - } - if (struct.is_set_time_stamp()) { - oprot.writeFieldBegin(TIME_STAMP_FIELD_DESC); - oprot.writeI64(struct.time_stamp); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class ProfileRequestTupleSchemeFactory implements SchemeFactory { - public ProfileRequestTupleScheme getScheme() { - return new ProfileRequestTupleScheme(); - } - } - - private static class ProfileRequestTupleScheme extends TupleScheme<ProfileRequest> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, ProfileRequest struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - struct.nodeInfo.write(oprot); - oprot.writeI32(struct.action.getValue()); - BitSet optionals = new BitSet(); - if (struct.is_set_time_stamp()) { - optionals.set(0); - } - oprot.writeBitSet(optionals, 1); - if (struct.is_set_time_stamp()) { - oprot.writeI64(struct.time_stamp); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, ProfileRequest struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - struct.nodeInfo = new NodeInfo(); - struct.nodeInfo.read(iprot); - struct.set_nodeInfo_isSet(true); - struct.action = org.apache.storm.generated.ProfileAction.findByValue(iprot.readI32()); - struct.set_action_isSet(true); - BitSet incoming = iprot.readBitSet(1); - if (incoming.get(0)) { - struct.time_stamp = iprot.readI64(); - struct.set_time_stamp_isSet(true); - } - } - } - -} -
http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/ReadableBlobMeta.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/ReadableBlobMeta.java b/storm-core/src/jvm/backtype/storm/generated/ReadableBlobMeta.java deleted file mode 100644 index 0cbd3b8..0000000 --- a/storm-core/src/jvm/backtype/storm/generated/ReadableBlobMeta.java +++ /dev/null @@ -1,510 +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 ReadableBlobMeta implements org.apache.thrift.TBase<ReadableBlobMeta, ReadableBlobMeta._Fields>, java.io.Serializable, Cloneable, Comparable<ReadableBlobMeta> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ReadableBlobMeta"); - - private static final org.apache.thrift.protocol.TField SETTABLE_FIELD_DESC = new org.apache.thrift.protocol.TField("settable", org.apache.thrift.protocol.TType.STRUCT, (short)1); - private static final org.apache.thrift.protocol.TField VERSION_FIELD_DESC = new org.apache.thrift.protocol.TField("version", org.apache.thrift.protocol.TType.I64, (short)2); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new ReadableBlobMetaStandardSchemeFactory()); - schemes.put(TupleScheme.class, new ReadableBlobMetaTupleSchemeFactory()); - } - - private SettableBlobMeta settable; // required - private long version; // 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 { - SETTABLE((short)1, "settable"), - VERSION((short)2, "version"); - - 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: // SETTABLE - return SETTABLE; - case 2: // VERSION - return VERSION; - 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 __VERSION_ISSET_ID = 0; - private byte __isset_bitfield = 0; - 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.SETTABLE, new org.apache.thrift.meta_data.FieldMetaData("settable", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, SettableBlobMeta.class))); - tmpMap.put(_Fields.VERSION, new org.apache.thrift.meta_data.FieldMetaData("version", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ReadableBlobMeta.class, metaDataMap); - } - - public ReadableBlobMeta() { - } - - public ReadableBlobMeta( - SettableBlobMeta settable, - long version) - { - this(); - this.settable = settable; - this.version = version; - set_version_isSet(true); - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public ReadableBlobMeta(ReadableBlobMeta other) { - __isset_bitfield = other.__isset_bitfield; - if (other.is_set_settable()) { - this.settable = new SettableBlobMeta(other.settable); - } - this.version = other.version; - } - - public ReadableBlobMeta deepCopy() { - return new ReadableBlobMeta(this); - } - - @Override - public void clear() { - this.settable = null; - set_version_isSet(false); - this.version = 0; - } - - public SettableBlobMeta get_settable() { - return this.settable; - } - - public void set_settable(SettableBlobMeta settable) { - this.settable = settable; - } - - public void unset_settable() { - this.settable = null; - } - - /** Returns true if field settable is set (has been assigned a value) and false otherwise */ - public boolean is_set_settable() { - return this.settable != null; - } - - public void set_settable_isSet(boolean value) { - if (!value) { - this.settable = null; - } - } - - public long get_version() { - return this.version; - } - - public void set_version(long version) { - this.version = version; - set_version_isSet(true); - } - - public void unset_version() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __VERSION_ISSET_ID); - } - - /** Returns true if field version is set (has been assigned a value) and false otherwise */ - public boolean is_set_version() { - return EncodingUtils.testBit(__isset_bitfield, __VERSION_ISSET_ID); - } - - public void set_version_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __VERSION_ISSET_ID, value); - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case SETTABLE: - if (value == null) { - unset_settable(); - } else { - set_settable((SettableBlobMeta)value); - } - break; - - case VERSION: - if (value == null) { - unset_version(); - } else { - set_version((Long)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case SETTABLE: - return get_settable(); - - case VERSION: - return get_version(); - - } - 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 SETTABLE: - return is_set_settable(); - case VERSION: - return is_set_version(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof ReadableBlobMeta) - return this.equals((ReadableBlobMeta)that); - return false; - } - - public boolean equals(ReadableBlobMeta that) { - if (that == null) - return false; - - boolean this_present_settable = true && this.is_set_settable(); - boolean that_present_settable = true && that.is_set_settable(); - if (this_present_settable || that_present_settable) { - if (!(this_present_settable && that_present_settable)) - return false; - if (!this.settable.equals(that.settable)) - return false; - } - - boolean this_present_version = true; - boolean that_present_version = true; - if (this_present_version || that_present_version) { - if (!(this_present_version && that_present_version)) - return false; - if (this.version != that.version) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_settable = true && (is_set_settable()); - list.add(present_settable); - if (present_settable) - list.add(settable); - - boolean present_version = true; - list.add(present_version); - if (present_version) - list.add(version); - - return list.hashCode(); - } - - @Override - public int compareTo(ReadableBlobMeta other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(is_set_settable()).compareTo(other.is_set_settable()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_settable()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.settable, other.settable); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_version()).compareTo(other.is_set_version()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_version()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.version, other.version); - 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("ReadableBlobMeta("); - boolean first = true; - - sb.append("settable:"); - if (this.settable == null) { - sb.append("null"); - } else { - sb.append(this.settable); - } - first = false; - if (!first) sb.append(", "); - sb.append("version:"); - sb.append(this.version); - first = false; - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (!is_set_settable()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'settable' is unset! Struct:" + toString()); - } - - if (!is_set_version()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'version' is unset! Struct:" + toString()); - } - - // check for sub-struct validity - if (settable != null) { - settable.validate(); - } - } - - private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { - try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { - try { - // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. - __isset_bitfield = 0; - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private static class ReadableBlobMetaStandardSchemeFactory implements SchemeFactory { - public ReadableBlobMetaStandardScheme getScheme() { - return new ReadableBlobMetaStandardScheme(); - } - } - - private static class ReadableBlobMetaStandardScheme extends StandardScheme<ReadableBlobMeta> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, ReadableBlobMeta 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: // SETTABLE - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.settable = new SettableBlobMeta(); - struct.settable.read(iprot); - struct.set_settable_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // VERSION - if (schemeField.type == org.apache.thrift.protocol.TType.I64) { - struct.version = iprot.readI64(); - struct.set_version_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, ReadableBlobMeta struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.settable != null) { - oprot.writeFieldBegin(SETTABLE_FIELD_DESC); - struct.settable.write(oprot); - oprot.writeFieldEnd(); - } - oprot.writeFieldBegin(VERSION_FIELD_DESC); - oprot.writeI64(struct.version); - oprot.writeFieldEnd(); - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class ReadableBlobMetaTupleSchemeFactory implements SchemeFactory { - public ReadableBlobMetaTupleScheme getScheme() { - return new ReadableBlobMetaTupleScheme(); - } - } - - private static class ReadableBlobMetaTupleScheme extends TupleScheme<ReadableBlobMeta> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, ReadableBlobMeta struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - struct.settable.write(oprot); - oprot.writeI64(struct.version); - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, ReadableBlobMeta struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - struct.settable = new SettableBlobMeta(); - struct.settable.read(iprot); - struct.set_settable_isSet(true); - struct.version = iprot.readI64(); - struct.set_version_isSet(true); - } - } - -} - http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/RebalanceOptions.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/RebalanceOptions.java b/storm-core/src/jvm/backtype/storm/generated/RebalanceOptions.java deleted file mode 100644 index bbb8f91..0000000 --- a/storm-core/src/jvm/backtype/storm/generated/RebalanceOptions.java +++ /dev/null @@ -1,664 +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 RebalanceOptions implements org.apache.thrift.TBase<RebalanceOptions, RebalanceOptions._Fields>, java.io.Serializable, Cloneable, Comparable<RebalanceOptions> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("RebalanceOptions"); - - private static final org.apache.thrift.protocol.TField WAIT_SECS_FIELD_DESC = new org.apache.thrift.protocol.TField("wait_secs", org.apache.thrift.protocol.TType.I32, (short)1); - private static final org.apache.thrift.protocol.TField NUM_WORKERS_FIELD_DESC = new org.apache.thrift.protocol.TField("num_workers", org.apache.thrift.protocol.TType.I32, (short)2); - private static final org.apache.thrift.protocol.TField NUM_EXECUTORS_FIELD_DESC = new org.apache.thrift.protocol.TField("num_executors", org.apache.thrift.protocol.TType.MAP, (short)3); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new RebalanceOptionsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new RebalanceOptionsTupleSchemeFactory()); - } - - private int wait_secs; // optional - private int num_workers; // optional - private Map<String,Integer> num_executors; // 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 { - WAIT_SECS((short)1, "wait_secs"), - NUM_WORKERS((short)2, "num_workers"), - NUM_EXECUTORS((short)3, "num_executors"); - - 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: // WAIT_SECS - return WAIT_SECS; - case 2: // NUM_WORKERS - return NUM_WORKERS; - case 3: // NUM_EXECUTORS - return NUM_EXECUTORS; - 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 __WAIT_SECS_ISSET_ID = 0; - private static final int __NUM_WORKERS_ISSET_ID = 1; - private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.WAIT_SECS,_Fields.NUM_WORKERS,_Fields.NUM_EXECUTORS}; - 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.WAIT_SECS, new org.apache.thrift.meta_data.FieldMetaData("wait_secs", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.NUM_WORKERS, new org.apache.thrift.meta_data.FieldMetaData("num_workers", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.NUM_EXECUTORS, new org.apache.thrift.meta_data.FieldMetaData("num_executors", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING), - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(RebalanceOptions.class, metaDataMap); - } - - public RebalanceOptions() { - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public RebalanceOptions(RebalanceOptions other) { - __isset_bitfield = other.__isset_bitfield; - this.wait_secs = other.wait_secs; - this.num_workers = other.num_workers; - if (other.is_set_num_executors()) { - Map<String,Integer> __this__num_executors = new HashMap<String,Integer>(other.num_executors); - this.num_executors = __this__num_executors; - } - } - - public RebalanceOptions deepCopy() { - return new RebalanceOptions(this); - } - - @Override - public void clear() { - set_wait_secs_isSet(false); - this.wait_secs = 0; - set_num_workers_isSet(false); - this.num_workers = 0; - this.num_executors = null; - } - - public int get_wait_secs() { - return this.wait_secs; - } - - public void set_wait_secs(int wait_secs) { - this.wait_secs = wait_secs; - set_wait_secs_isSet(true); - } - - public void unset_wait_secs() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __WAIT_SECS_ISSET_ID); - } - - /** Returns true if field wait_secs is set (has been assigned a value) and false otherwise */ - public boolean is_set_wait_secs() { - return EncodingUtils.testBit(__isset_bitfield, __WAIT_SECS_ISSET_ID); - } - - public void set_wait_secs_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __WAIT_SECS_ISSET_ID, value); - } - - public int get_num_workers() { - return this.num_workers; - } - - public void set_num_workers(int num_workers) { - this.num_workers = num_workers; - set_num_workers_isSet(true); - } - - public void unset_num_workers() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUM_WORKERS_ISSET_ID); - } - - /** Returns true if field num_workers is set (has been assigned a value) and false otherwise */ - public boolean is_set_num_workers() { - return EncodingUtils.testBit(__isset_bitfield, __NUM_WORKERS_ISSET_ID); - } - - public void set_num_workers_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUM_WORKERS_ISSET_ID, value); - } - - public int get_num_executors_size() { - return (this.num_executors == null) ? 0 : this.num_executors.size(); - } - - public void put_to_num_executors(String key, int val) { - if (this.num_executors == null) { - this.num_executors = new HashMap<String,Integer>(); - } - this.num_executors.put(key, val); - } - - public Map<String,Integer> get_num_executors() { - return this.num_executors; - } - - public void set_num_executors(Map<String,Integer> num_executors) { - this.num_executors = num_executors; - } - - public void unset_num_executors() { - this.num_executors = null; - } - - /** Returns true if field num_executors is set (has been assigned a value) and false otherwise */ - public boolean is_set_num_executors() { - return this.num_executors != null; - } - - public void set_num_executors_isSet(boolean value) { - if (!value) { - this.num_executors = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case WAIT_SECS: - if (value == null) { - unset_wait_secs(); - } else { - set_wait_secs((Integer)value); - } - break; - - case NUM_WORKERS: - if (value == null) { - unset_num_workers(); - } else { - set_num_workers((Integer)value); - } - break; - - case NUM_EXECUTORS: - if (value == null) { - unset_num_executors(); - } else { - set_num_executors((Map<String,Integer>)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case WAIT_SECS: - return get_wait_secs(); - - case NUM_WORKERS: - return get_num_workers(); - - case NUM_EXECUTORS: - return get_num_executors(); - - } - 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 WAIT_SECS: - return is_set_wait_secs(); - case NUM_WORKERS: - return is_set_num_workers(); - case NUM_EXECUTORS: - return is_set_num_executors(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof RebalanceOptions) - return this.equals((RebalanceOptions)that); - return false; - } - - public boolean equals(RebalanceOptions that) { - if (that == null) - return false; - - boolean this_present_wait_secs = true && this.is_set_wait_secs(); - boolean that_present_wait_secs = true && that.is_set_wait_secs(); - if (this_present_wait_secs || that_present_wait_secs) { - if (!(this_present_wait_secs && that_present_wait_secs)) - return false; - if (this.wait_secs != that.wait_secs) - return false; - } - - boolean this_present_num_workers = true && this.is_set_num_workers(); - boolean that_present_num_workers = true && that.is_set_num_workers(); - if (this_present_num_workers || that_present_num_workers) { - if (!(this_present_num_workers && that_present_num_workers)) - return false; - if (this.num_workers != that.num_workers) - return false; - } - - boolean this_present_num_executors = true && this.is_set_num_executors(); - boolean that_present_num_executors = true && that.is_set_num_executors(); - if (this_present_num_executors || that_present_num_executors) { - if (!(this_present_num_executors && that_present_num_executors)) - return false; - if (!this.num_executors.equals(that.num_executors)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_wait_secs = true && (is_set_wait_secs()); - list.add(present_wait_secs); - if (present_wait_secs) - list.add(wait_secs); - - boolean present_num_workers = true && (is_set_num_workers()); - list.add(present_num_workers); - if (present_num_workers) - list.add(num_workers); - - boolean present_num_executors = true && (is_set_num_executors()); - list.add(present_num_executors); - if (present_num_executors) - list.add(num_executors); - - return list.hashCode(); - } - - @Override - public int compareTo(RebalanceOptions other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(is_set_wait_secs()).compareTo(other.is_set_wait_secs()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_wait_secs()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.wait_secs, other.wait_secs); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_num_workers()).compareTo(other.is_set_num_workers()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_num_workers()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.num_workers, other.num_workers); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_num_executors()).compareTo(other.is_set_num_executors()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_num_executors()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.num_executors, other.num_executors); - if (lastComparison != 0) { - return lastComparison; - } - } - 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("RebalanceOptions("); - boolean first = true; - - if (is_set_wait_secs()) { - sb.append("wait_secs:"); - sb.append(this.wait_secs); - first = false; - } - if (is_set_num_workers()) { - if (!first) sb.append(", "); - sb.append("num_workers:"); - sb.append(this.num_workers); - first = false; - } - if (is_set_num_executors()) { - if (!first) sb.append(", "); - sb.append("num_executors:"); - if (this.num_executors == null) { - sb.append("null"); - } else { - sb.append(this.num_executors); - } - 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 RebalanceOptionsStandardSchemeFactory implements SchemeFactory { - public RebalanceOptionsStandardScheme getScheme() { - return new RebalanceOptionsStandardScheme(); - } - } - - private static class RebalanceOptionsStandardScheme extends StandardScheme<RebalanceOptions> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, RebalanceOptions 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: // WAIT_SECS - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.wait_secs = iprot.readI32(); - struct.set_wait_secs_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // NUM_WORKERS - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.num_workers = iprot.readI32(); - struct.set_num_workers_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // NUM_EXECUTORS - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map538 = iprot.readMapBegin(); - struct.num_executors = new HashMap<String,Integer>(2*_map538.size); - String _key539; - int _val540; - for (int _i541 = 0; _i541 < _map538.size; ++_i541) - { - _key539 = iprot.readString(); - _val540 = iprot.readI32(); - struct.num_executors.put(_key539, _val540); - } - iprot.readMapEnd(); - } - struct.set_num_executors_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, RebalanceOptions struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.is_set_wait_secs()) { - oprot.writeFieldBegin(WAIT_SECS_FIELD_DESC); - oprot.writeI32(struct.wait_secs); - oprot.writeFieldEnd(); - } - if (struct.is_set_num_workers()) { - oprot.writeFieldBegin(NUM_WORKERS_FIELD_DESC); - oprot.writeI32(struct.num_workers); - oprot.writeFieldEnd(); - } - if (struct.num_executors != null) { - if (struct.is_set_num_executors()) { - oprot.writeFieldBegin(NUM_EXECUTORS_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, struct.num_executors.size())); - for (Map.Entry<String, Integer> _iter542 : struct.num_executors.entrySet()) - { - oprot.writeString(_iter542.getKey()); - oprot.writeI32(_iter542.getValue()); - } - oprot.writeMapEnd(); - } - oprot.writeFieldEnd(); - } - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class RebalanceOptionsTupleSchemeFactory implements SchemeFactory { - public RebalanceOptionsTupleScheme getScheme() { - return new RebalanceOptionsTupleScheme(); - } - } - - private static class RebalanceOptionsTupleScheme extends TupleScheme<RebalanceOptions> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, RebalanceOptions struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.is_set_wait_secs()) { - optionals.set(0); - } - if (struct.is_set_num_workers()) { - optionals.set(1); - } - if (struct.is_set_num_executors()) { - optionals.set(2); - } - oprot.writeBitSet(optionals, 3); - if (struct.is_set_wait_secs()) { - oprot.writeI32(struct.wait_secs); - } - if (struct.is_set_num_workers()) { - oprot.writeI32(struct.num_workers); - } - if (struct.is_set_num_executors()) { - { - oprot.writeI32(struct.num_executors.size()); - for (Map.Entry<String, Integer> _iter543 : struct.num_executors.entrySet()) - { - oprot.writeString(_iter543.getKey()); - oprot.writeI32(_iter543.getValue()); - } - } - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, RebalanceOptions struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(3); - if (incoming.get(0)) { - struct.wait_secs = iprot.readI32(); - struct.set_wait_secs_isSet(true); - } - if (incoming.get(1)) { - struct.num_workers = iprot.readI32(); - struct.set_num_workers_isSet(true); - } - if (incoming.get(2)) { - { - org.apache.thrift.protocol.TMap _map544 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32()); - struct.num_executors = new HashMap<String,Integer>(2*_map544.size); - String _key545; - int _val546; - for (int _i547 = 0; _i547 < _map544.size; ++_i547) - { - _key545 = iprot.readString(); - _val546 = iprot.readI32(); - struct.num_executors.put(_key545, _val546); - } - } - struct.set_num_executors_isSet(true); - } - } - } - -} - http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/SettableBlobMeta.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/SettableBlobMeta.java b/storm-core/src/jvm/backtype/storm/generated/SettableBlobMeta.java deleted file mode 100644 index 349e045..0000000 --- a/storm-core/src/jvm/backtype/storm/generated/SettableBlobMeta.java +++ /dev/null @@ -1,567 +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 SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMeta, SettableBlobMeta._Fields>, java.io.Serializable, Cloneable, Comparable<SettableBlobMeta> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("SettableBlobMeta"); - - private static final org.apache.thrift.protocol.TField ACL_FIELD_DESC = new org.apache.thrift.protocol.TField("acl", org.apache.thrift.protocol.TType.LIST, (short)1); - private static final org.apache.thrift.protocol.TField REPLICATION_FACTOR_FIELD_DESC = new org.apache.thrift.protocol.TField("replication_factor", org.apache.thrift.protocol.TType.I32, (short)2); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new SettableBlobMetaStandardSchemeFactory()); - schemes.put(TupleScheme.class, new SettableBlobMetaTupleSchemeFactory()); - } - - private List<AccessControl> acl; // required - private int replication_factor; // 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 { - ACL((short)1, "acl"), - REPLICATION_FACTOR((short)2, "replication_factor"); - - 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: // ACL - return ACL; - case 2: // REPLICATION_FACTOR - return REPLICATION_FACTOR; - 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 __REPLICATION_FACTOR_ISSET_ID = 0; - private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.REPLICATION_FACTOR}; - 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.ACL, new org.apache.thrift.meta_data.FieldMetaData("acl", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, AccessControl.class)))); - tmpMap.put(_Fields.REPLICATION_FACTOR, new org.apache.thrift.meta_data.FieldMetaData("replication_factor", 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(SettableBlobMeta.class, metaDataMap); - } - - public SettableBlobMeta() { - } - - public SettableBlobMeta( - List<AccessControl> acl) - { - this(); - this.acl = acl; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public SettableBlobMeta(SettableBlobMeta other) { - __isset_bitfield = other.__isset_bitfield; - if (other.is_set_acl()) { - List<AccessControl> __this__acl = new ArrayList<AccessControl>(other.acl.size()); - for (AccessControl other_element : other.acl) { - __this__acl.add(new AccessControl(other_element)); - } - this.acl = __this__acl; - } - this.replication_factor = other.replication_factor; - } - - public SettableBlobMeta deepCopy() { - return new SettableBlobMeta(this); - } - - @Override - public void clear() { - this.acl = null; - set_replication_factor_isSet(false); - this.replication_factor = 0; - } - - public int get_acl_size() { - return (this.acl == null) ? 0 : this.acl.size(); - } - - public java.util.Iterator<AccessControl> get_acl_iterator() { - return (this.acl == null) ? null : this.acl.iterator(); - } - - public void add_to_acl(AccessControl elem) { - if (this.acl == null) { - this.acl = new ArrayList<AccessControl>(); - } - this.acl.add(elem); - } - - public List<AccessControl> get_acl() { - return this.acl; - } - - public void set_acl(List<AccessControl> acl) { - this.acl = acl; - } - - public void unset_acl() { - this.acl = null; - } - - /** Returns true if field acl is set (has been assigned a value) and false otherwise */ - public boolean is_set_acl() { - return this.acl != null; - } - - public void set_acl_isSet(boolean value) { - if (!value) { - this.acl = null; - } - } - - public int get_replication_factor() { - return this.replication_factor; - } - - public void set_replication_factor(int replication_factor) { - this.replication_factor = replication_factor; - set_replication_factor_isSet(true); - } - - public void unset_replication_factor() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __REPLICATION_FACTOR_ISSET_ID); - } - - /** Returns true if field replication_factor is set (has been assigned a value) and false otherwise */ - public boolean is_set_replication_factor() { - return EncodingUtils.testBit(__isset_bitfield, __REPLICATION_FACTOR_ISSET_ID); - } - - public void set_replication_factor_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __REPLICATION_FACTOR_ISSET_ID, value); - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case ACL: - if (value == null) { - unset_acl(); - } else { - set_acl((List<AccessControl>)value); - } - break; - - case REPLICATION_FACTOR: - if (value == null) { - unset_replication_factor(); - } else { - set_replication_factor((Integer)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case ACL: - return get_acl(); - - case REPLICATION_FACTOR: - return get_replication_factor(); - - } - 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 ACL: - return is_set_acl(); - case REPLICATION_FACTOR: - return is_set_replication_factor(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof SettableBlobMeta) - return this.equals((SettableBlobMeta)that); - return false; - } - - public boolean equals(SettableBlobMeta that) { - if (that == null) - return false; - - boolean this_present_acl = true && this.is_set_acl(); - boolean that_present_acl = true && that.is_set_acl(); - if (this_present_acl || that_present_acl) { - if (!(this_present_acl && that_present_acl)) - return false; - if (!this.acl.equals(that.acl)) - return false; - } - - boolean this_present_replication_factor = true && this.is_set_replication_factor(); - boolean that_present_replication_factor = true && that.is_set_replication_factor(); - if (this_present_replication_factor || that_present_replication_factor) { - if (!(this_present_replication_factor && that_present_replication_factor)) - return false; - if (this.replication_factor != that.replication_factor) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_acl = true && (is_set_acl()); - list.add(present_acl); - if (present_acl) - list.add(acl); - - boolean present_replication_factor = true && (is_set_replication_factor()); - list.add(present_replication_factor); - if (present_replication_factor) - list.add(replication_factor); - - return list.hashCode(); - } - - @Override - public int compareTo(SettableBlobMeta other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(is_set_acl()).compareTo(other.is_set_acl()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_acl()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.acl, other.acl); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_replication_factor()).compareTo(other.is_set_replication_factor()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_replication_factor()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.replication_factor, other.replication_factor); - 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("SettableBlobMeta("); - boolean first = true; - - sb.append("acl:"); - if (this.acl == null) { - sb.append("null"); - } else { - sb.append(this.acl); - } - first = false; - if (is_set_replication_factor()) { - if (!first) sb.append(", "); - sb.append("replication_factor:"); - sb.append(this.replication_factor); - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (!is_set_acl()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'acl' is unset! Struct:" + toString()); - } - - // check for sub-struct validity - } - - private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { - try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { - try { - // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. - __isset_bitfield = 0; - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private static class SettableBlobMetaStandardSchemeFactory implements SchemeFactory { - public SettableBlobMetaStandardScheme getScheme() { - return new SettableBlobMetaStandardScheme(); - } - } - - private static class SettableBlobMetaStandardScheme extends StandardScheme<SettableBlobMeta> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, SettableBlobMeta 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: // ACL - if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { - { - org.apache.thrift.protocol.TList _list558 = iprot.readListBegin(); - struct.acl = new ArrayList<AccessControl>(_list558.size); - AccessControl _elem559; - for (int _i560 = 0; _i560 < _list558.size; ++_i560) - { - _elem559 = new AccessControl(); - _elem559.read(iprot); - struct.acl.add(_elem559); - } - iprot.readListEnd(); - } - struct.set_acl_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // REPLICATION_FACTOR - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.replication_factor = iprot.readI32(); - struct.set_replication_factor_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, SettableBlobMeta struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.acl != null) { - oprot.writeFieldBegin(ACL_FIELD_DESC); - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.acl.size())); - for (AccessControl _iter561 : struct.acl) - { - _iter561.write(oprot); - } - oprot.writeListEnd(); - } - oprot.writeFieldEnd(); - } - if (struct.is_set_replication_factor()) { - oprot.writeFieldBegin(REPLICATION_FACTOR_FIELD_DESC); - oprot.writeI32(struct.replication_factor); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class SettableBlobMetaTupleSchemeFactory implements SchemeFactory { - public SettableBlobMetaTupleScheme getScheme() { - return new SettableBlobMetaTupleScheme(); - } - } - - private static class SettableBlobMetaTupleScheme extends TupleScheme<SettableBlobMeta> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, SettableBlobMeta struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - { - oprot.writeI32(struct.acl.size()); - for (AccessControl _iter562 : struct.acl) - { - _iter562.write(oprot); - } - } - BitSet optionals = new BitSet(); - if (struct.is_set_replication_factor()) { - optionals.set(0); - } - oprot.writeBitSet(optionals, 1); - if (struct.is_set_replication_factor()) { - oprot.writeI32(struct.replication_factor); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, SettableBlobMeta struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - { - org.apache.thrift.protocol.TList _list563 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.acl = new ArrayList<AccessControl>(_list563.size); - AccessControl _elem564; - for (int _i565 = 0; _i565 < _list563.size; ++_i565) - { - _elem564 = new AccessControl(); - _elem564.read(iprot); - struct.acl.add(_elem564); - } - } - struct.set_acl_isSet(true); - BitSet incoming = iprot.readBitSet(1); - if (incoming.get(0)) { - struct.replication_factor = iprot.readI32(); - struct.set_replication_factor_isSet(true); - } - } - } - -} -
