You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by kn...@apache.org on 2015/10/19 22:07:03 UTC
[06/18] storm git commit: Add resource setting API in WorkerSlot
http://git-wip-us.apache.org/repos/asf/storm/blob/17d70d3b/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
new file mode 100644
index 0000000..4898612
--- /dev/null
+++ b/storm-core/src/jvm/backtype/storm/generated/ReadableBlobMeta.java
@@ -0,0 +1,510 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+/**
+ * Autogenerated by Thrift Compiler (0.9.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package backtype.storm.generated;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-5")
+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 Long.valueOf(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/17d70d3b/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
new file mode 100644
index 0000000..2c7992d
--- /dev/null
+++ b/storm-core/src/jvm/backtype/storm/generated/SettableBlobMeta.java
@@ -0,0 +1,460 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+/**
+ * Autogenerated by Thrift Compiler (0.9.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package backtype.storm.generated;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-5")
+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 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
+
+ /** 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");
+
+ 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;
+ 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.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))));
+ 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) {
+ 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;
+ }
+ }
+
+ public SettableBlobMeta deepCopy() {
+ return new SettableBlobMeta(this);
+ }
+
+ @Override
+ public void clear() {
+ this.acl = null;
+ }
+
+ 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 void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case ACL:
+ if (value == null) {
+ unset_acl();
+ } else {
+ set_acl((List<AccessControl>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case ACL:
+ return get_acl();
+
+ }
+ 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();
+ }
+ 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;
+ }
+
+ 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);
+
+ 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;
+ }
+ }
+ 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;
+ 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 {
+ 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 _list462 = iprot.readListBegin();
+ struct.acl = new ArrayList<AccessControl>(_list462.size);
+ AccessControl _elem463;
+ for (int _i464 = 0; _i464 < _list462.size; ++_i464)
+ {
+ _elem463 = new AccessControl();
+ _elem463.read(iprot);
+ struct.acl.add(_elem463);
+ }
+ iprot.readListEnd();
+ }
+ struct.set_acl_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 _iter465 : struct.acl)
+ {
+ _iter465.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ 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 _iter466 : struct.acl)
+ {
+ _iter466.write(oprot);
+ }
+ }
+ }
+
+ @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 _list467 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.acl = new ArrayList<AccessControl>(_list467.size);
+ AccessControl _elem468;
+ for (int _i469 = 0; _i469 < _list467.size; ++_i469)
+ {
+ _elem468 = new AccessControl();
+ _elem468.read(iprot);
+ struct.acl.add(_elem468);
+ }
+ }
+ struct.set_acl_isSet(true);
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/storm/blob/17d70d3b/storm-core/src/jvm/backtype/storm/generated/TopologyHistoryInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/TopologyHistoryInfo.java b/storm-core/src/jvm/backtype/storm/generated/TopologyHistoryInfo.java
new file mode 100644
index 0000000..ab48272
--- /dev/null
+++ b/storm-core/src/jvm/backtype/storm/generated/TopologyHistoryInfo.java
@@ -0,0 +1,461 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+/**
+ * Autogenerated by Thrift Compiler (0.9.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package backtype.storm.generated;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-5")
+public class TopologyHistoryInfo implements org.apache.thrift.TBase<TopologyHistoryInfo, TopologyHistoryInfo._Fields>, java.io.Serializable, Cloneable, Comparable<TopologyHistoryInfo> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TopologyHistoryInfo");
+
+ private static final org.apache.thrift.protocol.TField TOPO_IDS_FIELD_DESC = new org.apache.thrift.protocol.TField("topo_ids", 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 TopologyHistoryInfoStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new TopologyHistoryInfoTupleSchemeFactory());
+ }
+
+ private List<String> topo_ids; // 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 {
+ TOPO_IDS((short)1, "topo_ids");
+
+ 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: // TOPO_IDS
+ return TOPO_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.TOPO_IDS, new org.apache.thrift.meta_data.FieldMetaData("topo_ids", 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(TopologyHistoryInfo.class, metaDataMap);
+ }
+
+ public TopologyHistoryInfo() {
+ }
+
+ public TopologyHistoryInfo(
+ List<String> topo_ids)
+ {
+ this();
+ this.topo_ids = topo_ids;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public TopologyHistoryInfo(TopologyHistoryInfo other) {
+ if (other.is_set_topo_ids()) {
+ List<String> __this__topo_ids = new ArrayList<String>(other.topo_ids);
+ this.topo_ids = __this__topo_ids;
+ }
+ }
+
+ public TopologyHistoryInfo deepCopy() {
+ return new TopologyHistoryInfo(this);
+ }
+
+ @Override
+ public void clear() {
+ this.topo_ids = null;
+ }
+
+ public int get_topo_ids_size() {
+ return (this.topo_ids == null) ? 0 : this.topo_ids.size();
+ }
+
+ public java.util.Iterator<String> get_topo_ids_iterator() {
+ return (this.topo_ids == null) ? null : this.topo_ids.iterator();
+ }
+
+ public void add_to_topo_ids(String elem) {
+ if (this.topo_ids == null) {
+ this.topo_ids = new ArrayList<String>();
+ }
+ this.topo_ids.add(elem);
+ }
+
+ public List<String> get_topo_ids() {
+ return this.topo_ids;
+ }
+
+ public void set_topo_ids(List<String> topo_ids) {
+ this.topo_ids = topo_ids;
+ }
+
+ public void unset_topo_ids() {
+ this.topo_ids = null;
+ }
+
+ /** Returns true if field topo_ids is set (has been assigned a value) and false otherwise */
+ public boolean is_set_topo_ids() {
+ return this.topo_ids != null;
+ }
+
+ public void set_topo_ids_isSet(boolean value) {
+ if (!value) {
+ this.topo_ids = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case TOPO_IDS:
+ if (value == null) {
+ unset_topo_ids();
+ } else {
+ set_topo_ids((List<String>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case TOPO_IDS:
+ return get_topo_ids();
+
+ }
+ 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 TOPO_IDS:
+ return is_set_topo_ids();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof TopologyHistoryInfo)
+ return this.equals((TopologyHistoryInfo)that);
+ return false;
+ }
+
+ public boolean equals(TopologyHistoryInfo that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_topo_ids = true && this.is_set_topo_ids();
+ boolean that_present_topo_ids = true && that.is_set_topo_ids();
+ if (this_present_topo_ids || that_present_topo_ids) {
+ if (!(this_present_topo_ids && that_present_topo_ids))
+ return false;
+ if (!this.topo_ids.equals(that.topo_ids))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_topo_ids = true && (is_set_topo_ids());
+ list.add(present_topo_ids);
+ if (present_topo_ids)
+ list.add(topo_ids);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(TopologyHistoryInfo other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(is_set_topo_ids()).compareTo(other.is_set_topo_ids());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_topo_ids()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.topo_ids, other.topo_ids);
+ 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("TopologyHistoryInfo(");
+ boolean first = true;
+
+ sb.append("topo_ids:");
+ if (this.topo_ids == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.topo_ids);
+ }
+ 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 TopologyHistoryInfoStandardSchemeFactory implements SchemeFactory {
+ public TopologyHistoryInfoStandardScheme getScheme() {
+ return new TopologyHistoryInfoStandardScheme();
+ }
+ }
+
+ private static class TopologyHistoryInfoStandardScheme extends StandardScheme<TopologyHistoryInfo> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, TopologyHistoryInfo 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: // TOPO_IDS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list488 = iprot.readListBegin();
+ struct.topo_ids = new ArrayList<String>(_list488.size);
+ String _elem489;
+ for (int _i490 = 0; _i490 < _list488.size; ++_i490)
+ {
+ _elem489 = iprot.readString();
+ struct.topo_ids.add(_elem489);
+ }
+ iprot.readListEnd();
+ }
+ struct.set_topo_ids_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, TopologyHistoryInfo struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.topo_ids != null) {
+ oprot.writeFieldBegin(TOPO_IDS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.topo_ids.size()));
+ for (String _iter491 : struct.topo_ids)
+ {
+ oprot.writeString(_iter491);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class TopologyHistoryInfoTupleSchemeFactory implements SchemeFactory {
+ public TopologyHistoryInfoTupleScheme getScheme() {
+ return new TopologyHistoryInfoTupleScheme();
+ }
+ }
+
+ private static class TopologyHistoryInfoTupleScheme extends TupleScheme<TopologyHistoryInfo> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, TopologyHistoryInfo struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.is_set_topo_ids()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.is_set_topo_ids()) {
+ {
+ oprot.writeI32(struct.topo_ids.size());
+ for (String _iter492 : struct.topo_ids)
+ {
+ oprot.writeString(_iter492);
+ }
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, TopologyHistoryInfo struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ {
+ org.apache.thrift.protocol.TList _list493 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.topo_ids = new ArrayList<String>(_list493.size);
+ String _elem494;
+ for (int _i495 = 0; _i495 < _list493.size; ++_i495)
+ {
+ _elem494 = iprot.readString();
+ struct.topo_ids.add(_elem494);
+ }
+ }
+ struct.set_topo_ids_isSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/storm/blob/17d70d3b/storm-core/src/jvm/backtype/storm/generated/WorkerResources.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/WorkerResources.java b/storm-core/src/jvm/backtype/storm/generated/WorkerResources.java
new file mode 100644
index 0000000..0d4a4c7
--- /dev/null
+++ b/storm-core/src/jvm/backtype/storm/generated/WorkerResources.java
@@ -0,0 +1,605 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+/**
+ * Autogenerated by Thrift Compiler (0.9.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package backtype.storm.generated;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-5")
+public class WorkerResources implements org.apache.thrift.TBase<WorkerResources, WorkerResources._Fields>, java.io.Serializable, Cloneable, Comparable<WorkerResources> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WorkerResources");
+
+ private static final org.apache.thrift.protocol.TField MEM_ON_HEAP_FIELD_DESC = new org.apache.thrift.protocol.TField("mem_on_heap", org.apache.thrift.protocol.TType.DOUBLE, (short)1);
+ private static final org.apache.thrift.protocol.TField MEM_OFF_HEAP_FIELD_DESC = new org.apache.thrift.protocol.TField("mem_off_heap", org.apache.thrift.protocol.TType.DOUBLE, (short)2);
+ private static final org.apache.thrift.protocol.TField CPU_FIELD_DESC = new org.apache.thrift.protocol.TField("cpu", org.apache.thrift.protocol.TType.DOUBLE, (short)3);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new WorkerResourcesStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new WorkerResourcesTupleSchemeFactory());
+ }
+
+ private double mem_on_heap; // optional
+ private double mem_off_heap; // optional
+ private double cpu; // 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 {
+ MEM_ON_HEAP((short)1, "mem_on_heap"),
+ MEM_OFF_HEAP((short)2, "mem_off_heap"),
+ CPU((short)3, "cpu");
+
+ 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: // MEM_ON_HEAP
+ return MEM_ON_HEAP;
+ case 2: // MEM_OFF_HEAP
+ return MEM_OFF_HEAP;
+ case 3: // CPU
+ return CPU;
+ 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 __MEM_ON_HEAP_ISSET_ID = 0;
+ private static final int __MEM_OFF_HEAP_ISSET_ID = 1;
+ private static final int __CPU_ISSET_ID = 2;
+ private byte __isset_bitfield = 0;
+ private static final _Fields optionals[] = {_Fields.MEM_ON_HEAP,_Fields.MEM_OFF_HEAP,_Fields.CPU};
+ 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.MEM_ON_HEAP, new org.apache.thrift.meta_data.FieldMetaData("mem_on_heap", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)));
+ tmpMap.put(_Fields.MEM_OFF_HEAP, new org.apache.thrift.meta_data.FieldMetaData("mem_off_heap", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)));
+ tmpMap.put(_Fields.CPU, new org.apache.thrift.meta_data.FieldMetaData("cpu", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(WorkerResources.class, metaDataMap);
+ }
+
+ public WorkerResources() {
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public WorkerResources(WorkerResources other) {
+ __isset_bitfield = other.__isset_bitfield;
+ this.mem_on_heap = other.mem_on_heap;
+ this.mem_off_heap = other.mem_off_heap;
+ this.cpu = other.cpu;
+ }
+
+ public WorkerResources deepCopy() {
+ return new WorkerResources(this);
+ }
+
+ @Override
+ public void clear() {
+ set_mem_on_heap_isSet(false);
+ this.mem_on_heap = 0.0;
+ set_mem_off_heap_isSet(false);
+ this.mem_off_heap = 0.0;
+ set_cpu_isSet(false);
+ this.cpu = 0.0;
+ }
+
+ public double get_mem_on_heap() {
+ return this.mem_on_heap;
+ }
+
+ public void set_mem_on_heap(double mem_on_heap) {
+ this.mem_on_heap = mem_on_heap;
+ set_mem_on_heap_isSet(true);
+ }
+
+ public void unset_mem_on_heap() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MEM_ON_HEAP_ISSET_ID);
+ }
+
+ /** Returns true if field mem_on_heap is set (has been assigned a value) and false otherwise */
+ public boolean is_set_mem_on_heap() {
+ return EncodingUtils.testBit(__isset_bitfield, __MEM_ON_HEAP_ISSET_ID);
+ }
+
+ public void set_mem_on_heap_isSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MEM_ON_HEAP_ISSET_ID, value);
+ }
+
+ public double get_mem_off_heap() {
+ return this.mem_off_heap;
+ }
+
+ public void set_mem_off_heap(double mem_off_heap) {
+ this.mem_off_heap = mem_off_heap;
+ set_mem_off_heap_isSet(true);
+ }
+
+ public void unset_mem_off_heap() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MEM_OFF_HEAP_ISSET_ID);
+ }
+
+ /** Returns true if field mem_off_heap is set (has been assigned a value) and false otherwise */
+ public boolean is_set_mem_off_heap() {
+ return EncodingUtils.testBit(__isset_bitfield, __MEM_OFF_HEAP_ISSET_ID);
+ }
+
+ public void set_mem_off_heap_isSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MEM_OFF_HEAP_ISSET_ID, value);
+ }
+
+ public double get_cpu() {
+ return this.cpu;
+ }
+
+ public void set_cpu(double cpu) {
+ this.cpu = cpu;
+ set_cpu_isSet(true);
+ }
+
+ public void unset_cpu() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __CPU_ISSET_ID);
+ }
+
+ /** Returns true if field cpu is set (has been assigned a value) and false otherwise */
+ public boolean is_set_cpu() {
+ return EncodingUtils.testBit(__isset_bitfield, __CPU_ISSET_ID);
+ }
+
+ public void set_cpu_isSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __CPU_ISSET_ID, value);
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case MEM_ON_HEAP:
+ if (value == null) {
+ unset_mem_on_heap();
+ } else {
+ set_mem_on_heap((Double)value);
+ }
+ break;
+
+ case MEM_OFF_HEAP:
+ if (value == null) {
+ unset_mem_off_heap();
+ } else {
+ set_mem_off_heap((Double)value);
+ }
+ break;
+
+ case CPU:
+ if (value == null) {
+ unset_cpu();
+ } else {
+ set_cpu((Double)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case MEM_ON_HEAP:
+ return Double.valueOf(get_mem_on_heap());
+
+ case MEM_OFF_HEAP:
+ return Double.valueOf(get_mem_off_heap());
+
+ case CPU:
+ return Double.valueOf(get_cpu());
+
+ }
+ 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 MEM_ON_HEAP:
+ return is_set_mem_on_heap();
+ case MEM_OFF_HEAP:
+ return is_set_mem_off_heap();
+ case CPU:
+ return is_set_cpu();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof WorkerResources)
+ return this.equals((WorkerResources)that);
+ return false;
+ }
+
+ public boolean equals(WorkerResources that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_mem_on_heap = true && this.is_set_mem_on_heap();
+ boolean that_present_mem_on_heap = true && that.is_set_mem_on_heap();
+ if (this_present_mem_on_heap || that_present_mem_on_heap) {
+ if (!(this_present_mem_on_heap && that_present_mem_on_heap))
+ return false;
+ if (this.mem_on_heap != that.mem_on_heap)
+ return false;
+ }
+
+ boolean this_present_mem_off_heap = true && this.is_set_mem_off_heap();
+ boolean that_present_mem_off_heap = true && that.is_set_mem_off_heap();
+ if (this_present_mem_off_heap || that_present_mem_off_heap) {
+ if (!(this_present_mem_off_heap && that_present_mem_off_heap))
+ return false;
+ if (this.mem_off_heap != that.mem_off_heap)
+ return false;
+ }
+
+ boolean this_present_cpu = true && this.is_set_cpu();
+ boolean that_present_cpu = true && that.is_set_cpu();
+ if (this_present_cpu || that_present_cpu) {
+ if (!(this_present_cpu && that_present_cpu))
+ return false;
+ if (this.cpu != that.cpu)
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_mem_on_heap = true && (is_set_mem_on_heap());
+ list.add(present_mem_on_heap);
+ if (present_mem_on_heap)
+ list.add(mem_on_heap);
+
+ boolean present_mem_off_heap = true && (is_set_mem_off_heap());
+ list.add(present_mem_off_heap);
+ if (present_mem_off_heap)
+ list.add(mem_off_heap);
+
+ boolean present_cpu = true && (is_set_cpu());
+ list.add(present_cpu);
+ if (present_cpu)
+ list.add(cpu);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(WorkerResources other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(is_set_mem_on_heap()).compareTo(other.is_set_mem_on_heap());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_mem_on_heap()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.mem_on_heap, other.mem_on_heap);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(is_set_mem_off_heap()).compareTo(other.is_set_mem_off_heap());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_mem_off_heap()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.mem_off_heap, other.mem_off_heap);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(is_set_cpu()).compareTo(other.is_set_cpu());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_cpu()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.cpu, other.cpu);
+ 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("WorkerResources(");
+ boolean first = true;
+
+ if (is_set_mem_on_heap()) {
+ sb.append("mem_on_heap:");
+ sb.append(this.mem_on_heap);
+ first = false;
+ }
+ if (is_set_mem_off_heap()) {
+ if (!first) sb.append(", ");
+ sb.append("mem_off_heap:");
+ sb.append(this.mem_off_heap);
+ first = false;
+ }
+ if (is_set_cpu()) {
+ if (!first) sb.append(", ");
+ sb.append("cpu:");
+ sb.append(this.cpu);
+ 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 WorkerResourcesStandardSchemeFactory implements SchemeFactory {
+ public WorkerResourcesStandardScheme getScheme() {
+ return new WorkerResourcesStandardScheme();
+ }
+ }
+
+ private static class WorkerResourcesStandardScheme extends StandardScheme<WorkerResources> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, WorkerResources 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: // MEM_ON_HEAP
+ if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+ struct.mem_on_heap = iprot.readDouble();
+ struct.set_mem_on_heap_isSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // MEM_OFF_HEAP
+ if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+ struct.mem_off_heap = iprot.readDouble();
+ struct.set_mem_off_heap_isSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // CPU
+ if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+ struct.cpu = iprot.readDouble();
+ struct.set_cpu_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, WorkerResources struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.is_set_mem_on_heap()) {
+ oprot.writeFieldBegin(MEM_ON_HEAP_FIELD_DESC);
+ oprot.writeDouble(struct.mem_on_heap);
+ oprot.writeFieldEnd();
+ }
+ if (struct.is_set_mem_off_heap()) {
+ oprot.writeFieldBegin(MEM_OFF_HEAP_FIELD_DESC);
+ oprot.writeDouble(struct.mem_off_heap);
+ oprot.writeFieldEnd();
+ }
+ if (struct.is_set_cpu()) {
+ oprot.writeFieldBegin(CPU_FIELD_DESC);
+ oprot.writeDouble(struct.cpu);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class WorkerResourcesTupleSchemeFactory implements SchemeFactory {
+ public WorkerResourcesTupleScheme getScheme() {
+ return new WorkerResourcesTupleScheme();
+ }
+ }
+
+ private static class WorkerResourcesTupleScheme extends TupleScheme<WorkerResources> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, WorkerResources struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.is_set_mem_on_heap()) {
+ optionals.set(0);
+ }
+ if (struct.is_set_mem_off_heap()) {
+ optionals.set(1);
+ }
+ if (struct.is_set_cpu()) {
+ optionals.set(2);
+ }
+ oprot.writeBitSet(optionals, 3);
+ if (struct.is_set_mem_on_heap()) {
+ oprot.writeDouble(struct.mem_on_heap);
+ }
+ if (struct.is_set_mem_off_heap()) {
+ oprot.writeDouble(struct.mem_off_heap);
+ }
+ if (struct.is_set_cpu()) {
+ oprot.writeDouble(struct.cpu);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, WorkerResources struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(3);
+ if (incoming.get(0)) {
+ struct.mem_on_heap = iprot.readDouble();
+ struct.set_mem_on_heap_isSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.mem_off_heap = iprot.readDouble();
+ struct.set_mem_off_heap_isSet(true);
+ }
+ if (incoming.get(2)) {
+ struct.cpu = iprot.readDouble();
+ struct.set_cpu_isSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/storm/blob/17d70d3b/storm-core/src/jvm/backtype/storm/scheduler/WorkerSlot.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/scheduler/WorkerSlot.java b/storm-core/src/jvm/backtype/storm/scheduler/WorkerSlot.java
index c89b3bc..b8e4420 100644
--- a/storm-core/src/jvm/backtype/storm/scheduler/WorkerSlot.java
+++ b/storm-core/src/jvm/backtype/storm/scheduler/WorkerSlot.java
@@ -20,6 +20,12 @@ package backtype.storm.scheduler;
public class WorkerSlot {
String nodeId;
int port;
+ // amount of on-heap memory allocated to it
+ double memOnHeap = 0.0;
+ // amount of off-heap memory allocated to it
+ double memOffHeap = 0.0;
+ // amount of cpu allocated to it
+ double cpu = 0.0;
public WorkerSlot(String nodeId, Number port) {
this.nodeId = nodeId;
@@ -34,6 +40,24 @@ public class WorkerSlot {
return port;
}
+ public void allocateResource(double memOnHeap, double memOffHeap, double cpu) {
+ this.memOnHeap += memOnHeap;
+ this.memOffHeap += memOffHeap;
+ this.cpu += cpu;
+ }
+
+ public double getAllocatedMemOnHeap() {
+ return memOnHeap;
+ }
+
+ public double getAllocatedMemOffHeap() {
+ return memOffHeap;
+ }
+
+ public double getAllocatedCpu() {
+ return cpu;
+ }
+
@Override
public int hashCode() {
return nodeId.hashCode() + 13 * ((Integer) port).hashCode();
http://git-wip-us.apache.org/repos/asf/storm/blob/17d70d3b/storm-core/src/storm.thrift
----------------------------------------------------------------------
diff --git a/storm-core/src/storm.thrift b/storm-core/src/storm.thrift
index 1b507df..aae851e 100644
--- a/storm-core/src/storm.thrift
+++ b/storm-core/src/storm.thrift
@@ -365,11 +365,17 @@ struct NodeInfo {
2: required set<i64> port;
}
+struct WorkerResources {
+ 1: optional double mem_on_heap;
+ 2: optional double mem_off_heap;
+ 3: optional double cpu;
+}
struct Assignment {
1: required string master_code_dir;
2: optional map<string, string> node_host = {};
3: optional map<list<i64>, NodeInfo> executor_node_port = {};
4: optional map<list<i64>, i64> executor_start_time_secs = {};
+ 5: optional map<NodeInfo, WorkerResources> worker_resources = {};
}
enum TopologyStatus {
@@ -415,6 +421,7 @@ struct LocalStateData {
struct LocalAssignment {
1: required string topology_id;
2: required list<ExecutorInfo> executors;
+ 3: optional WorkerResources resources;
}
struct LSSupervisorId {
http://git-wip-us.apache.org/repos/asf/storm/blob/17d70d3b/storm-core/test/clj/backtype/storm/cluster_test.clj
----------------------------------------------------------------------
diff --git a/storm-core/test/clj/backtype/storm/cluster_test.clj b/storm-core/test/clj/backtype/storm/cluster_test.clj
index c99ee49..198222e 100644
--- a/storm-core/test/clj/backtype/storm/cluster_test.clj
+++ b/storm-core/test/clj/backtype/storm/cluster_test.clj
@@ -170,8 +170,8 @@
(deftest test-storm-cluster-state-basics
(with-inprocess-zookeeper zk-port
(let [state (mk-storm-state zk-port)
- assignment1 (Assignment. "/aaa" {} {[1] ["1" 1001 1]} {})
- assignment2 (Assignment. "/aaa" {} {[2] ["2" 2002]} {})
+ assignment1 (Assignment. "/aaa" {} {[1] ["1" 1001 1]} {} {})
+ assignment2 (Assignment. "/aaa" {} {[2] ["2" 2002]} {} {})
nimbusInfo1 (NimbusInfo. "nimbus1" 6667 false)
nimbusInfo2 (NimbusInfo. "nimbus2" 6667 false)
nimbusSummary1 (NimbusSummary. "nimbus1" 6667 (current-time-secs) false "v1")
http://git-wip-us.apache.org/repos/asf/storm/blob/17d70d3b/storm-core/test/clj/backtype/storm/supervisor_test.clj
----------------------------------------------------------------------
diff --git a/storm-core/test/clj/backtype/storm/supervisor_test.clj b/storm-core/test/clj/backtype/storm/supervisor_test.clj
index bc54d6f..93346d7 100644
--- a/storm-core/test/clj/backtype/storm/supervisor_test.clj
+++ b/storm-core/test/clj/backtype/storm/supervisor_test.clj
@@ -85,23 +85,27 @@
{}))
(bind sup1 (add-supervisor cluster :id "sup1" :ports [1 2 3 4]))
(bind changed (capture-changed-workers
- (submit-mocked-assignment
- (:nimbus cluster)
- "test"
- {TOPOLOGY-WORKERS 3}
- topology
- {1 "1"
- 2 "1"
- 3 "1"
- 4 "1"}
- {[1 1] ["sup1" 1]
- [2 2] ["sup1" 2]
- [3 3] ["sup1" 3]
- [4 4] ["sup1" 3]
- })
- (advance-cluster-time cluster 2)
- (heartbeat-workers cluster "sup1" [1 2 3])
- (advance-cluster-time cluster 10)))
+ (submit-mocked-assignment
+ (:nimbus cluster)
+ (:storm-cluster-state cluster)
+ "test"
+ {TOPOLOGY-WORKERS 3}
+ topology
+ {1 "1"
+ 2 "1"
+ 3 "1"
+ 4 "1"}
+ {[1 1] ["sup1" 1]
+ [2 2] ["sup1" 2]
+ [3 3] ["sup1" 3]
+ [4 4] ["sup1" 3]}
+ {["sup1" 1] [0.0 0.0 0.0]
+ ["sup1" 2] [0.0 0.0 0.0]
+ ["sup1" 3] [0.0 0.0 0.0]
+ })
+ (advance-cluster-time cluster 2)
+ (heartbeat-workers cluster "sup1" [1 2 3])
+ (advance-cluster-time cluster 10)))
(bind storm-id (get-storm-id (:storm-cluster-state cluster) "test"))
(is (empty? (:shutdown changed)))
(validate-launched-once (:launched changed) {"sup1" [1 2 3]} storm-id)
@@ -136,44 +140,51 @@
(bind sup1 (add-supervisor cluster :id "sup1" :ports [1 2 3 4]))
(bind sup2 (add-supervisor cluster :id "sup2" :ports [1 2]))
(bind changed (capture-changed-workers
- (submit-mocked-assignment
- (:nimbus cluster)
- "test"
- {TOPOLOGY-WORKERS 3 TOPOLOGY-MESSAGE-TIMEOUT-SECS 40}
- topology
- {1 "1"
- 2 "1"
- 3 "1"
- 4 "1"}
- {[1 1] ["sup1" 1]
- [2 2] ["sup1" 2]
- [3 3] ["sup2" 1]
- [4 4] ["sup2" 1]
- })
- (advance-cluster-time cluster 2)
- (heartbeat-workers cluster "sup1" [1 2])
- (heartbeat-workers cluster "sup2" [1])
- ))
+ (submit-mocked-assignment
+ (:nimbus cluster)
+ (:storm-cluster-state cluster)
+ "test"
+ {TOPOLOGY-WORKERS 3 TOPOLOGY-MESSAGE-TIMEOUT-SECS 40}
+ topology
+ {1 "1"
+ 2 "1"
+ 3 "1"
+ 4 "1"}
+ {[1 1] ["sup1" 1]
+ [2 2] ["sup1" 2]
+ [3 3] ["sup2" 1]
+ [4 4] ["sup2" 1]}
+ {["sup1" 1] [0.0 0.0 0.0]
+ ["sup1" 2] [0.0 0.0 0.0]
+ ["sup2" 1] [0.0 0.0 0.0]
+ })
+ (advance-cluster-time cluster 2)
+ (heartbeat-workers cluster "sup1" [1 2])
+ (heartbeat-workers cluster "sup2" [1])
+ ))
(bind storm-id (get-storm-id (:storm-cluster-state cluster) "test"))
(is (empty? (:shutdown changed)))
(validate-launched-once (:launched changed) {"sup1" [1 2] "sup2" [1]} storm-id)
(bind changed (capture-changed-workers
- (submit-mocked-assignment
- (:nimbus cluster)
- "test2"
- {TOPOLOGY-WORKERS 2}
- topology2
- {1 "1"
- 2 "1"
- 3 "1"}
- {[1 1] ["sup1" 3]
- [2 2] ["sup1" 3]
- [3 3] ["sup2" 2]
- })
- (advance-cluster-time cluster 2)
- (heartbeat-workers cluster "sup1" [3])
- (heartbeat-workers cluster "sup2" [2])
- ))
+ (submit-mocked-assignment
+ (:nimbus cluster)
+ (:storm-cluster-state cluster)
+ "test2"
+ {TOPOLOGY-WORKERS 2}
+ topology2
+ {1 "1"
+ 2 "1"
+ 3 "1"}
+ {[1 1] ["sup1" 3]
+ [2 2] ["sup1" 3]
+ [3 3] ["sup2" 2]}
+ {["sup1" 3] [0.0 0.0 0.0]
+ ["sup2" 2] [0.0 0.0 0.0]
+ })
+ (advance-cluster-time cluster 2)
+ (heartbeat-workers cluster "sup1" [3])
+ (heartbeat-workers cluster "sup2" [2])
+ ))
(bind storm-id2 (get-storm-id (:storm-cluster-state cluster) "test2"))
(is (empty? (:shutdown changed)))
(validate-launched-once (:launched changed) {"sup1" [3] "sup2" [2]} storm-id2)