http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/AccessControl.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/AccessControl.java b/storm-core/src/jvm/backtype/storm/generated/AccessControl.java deleted file mode 100644 index c1c072a..0000000 --- a/storm-core/src/jvm/backtype/storm/generated/AccessControl.java +++ /dev/null @@ -1,627 +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 AccessControl implements org.apache.thrift.TBase<AccessControl, AccessControl._Fields>, java.io.Serializable, Cloneable, Comparable<AccessControl> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AccessControl"); - - private static final org.apache.thrift.protocol.TField TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("type", org.apache.thrift.protocol.TType.I32, (short)1); - private static final org.apache.thrift.protocol.TField NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("name", org.apache.thrift.protocol.TType.STRING, (short)2); - private static final org.apache.thrift.protocol.TField ACCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("access", org.apache.thrift.protocol.TType.I32, (short)3); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new AccessControlStandardSchemeFactory()); - schemes.put(TupleScheme.class, new AccessControlTupleSchemeFactory()); - } - - private AccessControlType type; // required - private String name; // optional - private int access; // 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 { - /** - * - * @see AccessControlType - */ - TYPE((short)1, "type"), - NAME((short)2, "name"), - ACCESS((short)3, "access"); - - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); - - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } - } - - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 1: // TYPE - return TYPE; - case 2: // NAME - return NAME; - case 3: // ACCESS - return ACCESS; - 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 __ACCESS_ISSET_ID = 0; - private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.NAME}; - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; - static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.TYPE, new org.apache.thrift.meta_data.FieldMetaData("type", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, AccessControlType.class))); - tmpMap.put(_Fields.NAME, new org.apache.thrift.meta_data.FieldMetaData("name", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.ACCESS, new org.apache.thrift.meta_data.FieldMetaData("access", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AccessControl.class, metaDataMap); - } - - public AccessControl() { - } - - public AccessControl( - AccessControlType type, - int access) - { - this(); - this.type = type; - this.access = access; - set_access_isSet(true); - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public AccessControl(AccessControl other) { - __isset_bitfield = other.__isset_bitfield; - if (other.is_set_type()) { - this.type = other.type; - } - if (other.is_set_name()) { - this.name = other.name; - } - this.access = other.access; - } - - public AccessControl deepCopy() { - return new AccessControl(this); - } - - @Override - public void clear() { - this.type = null; - this.name = null; - set_access_isSet(false); - this.access = 0; - } - - /** - * - * @see AccessControlType - */ - public AccessControlType get_type() { - return this.type; - } - - /** - * - * @see AccessControlType - */ - public void set_type(AccessControlType type) { - this.type = type; - } - - public void unset_type() { - this.type = null; - } - - /** Returns true if field type is set (has been assigned a value) and false otherwise */ - public boolean is_set_type() { - return this.type != null; - } - - public void set_type_isSet(boolean value) { - if (!value) { - this.type = null; - } - } - - public String get_name() { - return this.name; - } - - public void set_name(String name) { - this.name = name; - } - - public void unset_name() { - this.name = null; - } - - /** Returns true if field name is set (has been assigned a value) and false otherwise */ - public boolean is_set_name() { - return this.name != null; - } - - public void set_name_isSet(boolean value) { - if (!value) { - this.name = null; - } - } - - public int get_access() { - return this.access; - } - - public void set_access(int access) { - this.access = access; - set_access_isSet(true); - } - - public void unset_access() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ACCESS_ISSET_ID); - } - - /** Returns true if field access is set (has been assigned a value) and false otherwise */ - public boolean is_set_access() { - return EncodingUtils.testBit(__isset_bitfield, __ACCESS_ISSET_ID); - } - - public void set_access_isSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ACCESS_ISSET_ID, value); - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case TYPE: - if (value == null) { - unset_type(); - } else { - set_type((AccessControlType)value); - } - break; - - case NAME: - if (value == null) { - unset_name(); - } else { - set_name((String)value); - } - break; - - case ACCESS: - if (value == null) { - unset_access(); - } else { - set_access((Integer)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case TYPE: - return get_type(); - - case NAME: - return get_name(); - - case ACCESS: - return get_access(); - - } - throw new IllegalStateException(); - } - - /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ - public boolean isSet(_Fields field) { - if (field == null) { - throw new IllegalArgumentException(); - } - - switch (field) { - case TYPE: - return is_set_type(); - case NAME: - return is_set_name(); - case ACCESS: - return is_set_access(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof AccessControl) - return this.equals((AccessControl)that); - return false; - } - - public boolean equals(AccessControl that) { - if (that == null) - return false; - - boolean this_present_type = true && this.is_set_type(); - boolean that_present_type = true && that.is_set_type(); - if (this_present_type || that_present_type) { - if (!(this_present_type && that_present_type)) - return false; - if (!this.type.equals(that.type)) - return false; - } - - boolean this_present_name = true && this.is_set_name(); - boolean that_present_name = true && that.is_set_name(); - if (this_present_name || that_present_name) { - if (!(this_present_name && that_present_name)) - return false; - if (!this.name.equals(that.name)) - return false; - } - - boolean this_present_access = true; - boolean that_present_access = true; - if (this_present_access || that_present_access) { - if (!(this_present_access && that_present_access)) - return false; - if (this.access != that.access) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_type = true && (is_set_type()); - list.add(present_type); - if (present_type) - list.add(type.getValue()); - - boolean present_name = true && (is_set_name()); - list.add(present_name); - if (present_name) - list.add(name); - - boolean present_access = true; - list.add(present_access); - if (present_access) - list.add(access); - - return list.hashCode(); - } - - @Override - public int compareTo(AccessControl other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(is_set_type()).compareTo(other.is_set_type()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_type()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.type, other.type); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_name()).compareTo(other.is_set_name()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_name()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.name, other.name); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_access()).compareTo(other.is_set_access()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_access()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.access, other.access); - 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("AccessControl("); - boolean first = true; - - sb.append("type:"); - if (this.type == null) { - sb.append("null"); - } else { - sb.append(this.type); - } - first = false; - if (is_set_name()) { - if (!first) sb.append(", "); - sb.append("name:"); - if (this.name == null) { - sb.append("null"); - } else { - sb.append(this.name); - } - first = false; - } - if (!first) sb.append(", "); - sb.append("access:"); - sb.append(this.access); - first = false; - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (!is_set_type()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'type' is unset! Struct:" + toString()); - } - - if (!is_set_access()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'access' 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 AccessControlStandardSchemeFactory implements SchemeFactory { - public AccessControlStandardScheme getScheme() { - return new AccessControlStandardScheme(); - } - } - - private static class AccessControlStandardScheme extends StandardScheme<AccessControl> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, AccessControl struct) throws org.apache.thrift.TException { - org.apache.thrift.protocol.TField schemeField; - iprot.readStructBegin(); - while (true) - { - schemeField = iprot.readFieldBegin(); - if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { - break; - } - switch (schemeField.id) { - case 1: // TYPE - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.type = org.apache.storm.generated.AccessControlType.findByValue(iprot.readI32()); - struct.set_type_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // NAME - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.name = iprot.readString(); - struct.set_name_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // ACCESS - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.access = iprot.readI32(); - struct.set_access_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, AccessControl struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.type != null) { - oprot.writeFieldBegin(TYPE_FIELD_DESC); - oprot.writeI32(struct.type.getValue()); - oprot.writeFieldEnd(); - } - if (struct.name != null) { - if (struct.is_set_name()) { - oprot.writeFieldBegin(NAME_FIELD_DESC); - oprot.writeString(struct.name); - oprot.writeFieldEnd(); - } - } - oprot.writeFieldBegin(ACCESS_FIELD_DESC); - oprot.writeI32(struct.access); - oprot.writeFieldEnd(); - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class AccessControlTupleSchemeFactory implements SchemeFactory { - public AccessControlTupleScheme getScheme() { - return new AccessControlTupleScheme(); - } - } - - private static class AccessControlTupleScheme extends TupleScheme<AccessControl> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, AccessControl struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - oprot.writeI32(struct.type.getValue()); - oprot.writeI32(struct.access); - BitSet optionals = new BitSet(); - if (struct.is_set_name()) { - optionals.set(0); - } - oprot.writeBitSet(optionals, 1); - if (struct.is_set_name()) { - oprot.writeString(struct.name); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, AccessControl struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - struct.type = org.apache.storm.generated.AccessControlType.findByValue(iprot.readI32()); - struct.set_type_isSet(true); - struct.access = iprot.readI32(); - struct.set_access_isSet(true); - BitSet incoming = iprot.readBitSet(1); - if (incoming.get(0)) { - struct.name = iprot.readString(); - struct.set_name_isSet(true); - } - } - } - -} -
http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/AccessControlType.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/AccessControlType.java b/storm-core/src/jvm/backtype/storm/generated/AccessControlType.java deleted file mode 100644 index cb75b9b..0000000 --- a/storm-core/src/jvm/backtype/storm/generated/AccessControlType.java +++ /dev/null @@ -1,62 +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 java.util.Map; -import java.util.HashMap; -import org.apache.thrift.TEnum; - -public enum AccessControlType implements org.apache.thrift.TEnum { - OTHER(1), - USER(2); - - private final int value; - - private AccessControlType(int value) { - this.value = value; - } - - /** - * Get the integer value of this enum value, as defined in the Thrift IDL. - */ - public int getValue() { - return value; - } - - /** - * Find a the enum type by its integer value, as defined in the Thrift IDL. - * @return null if the value is not found. - */ - public static AccessControlType findByValue(int value) { - switch (value) { - case 1: - return OTHER; - case 2: - return USER; - default: - return null; - } - } -} http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/AlreadyAliveException.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/AlreadyAliveException.java b/storm-core/src/jvm/backtype/storm/generated/AlreadyAliveException.java deleted file mode 100644 index 4e635fb..0000000 --- a/storm-core/src/jvm/backtype/storm/generated/AlreadyAliveException.java +++ /dev/null @@ -1,406 +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 AlreadyAliveException extends TException implements org.apache.thrift.TBase<AlreadyAliveException, AlreadyAliveException._Fields>, java.io.Serializable, Cloneable, Comparable<AlreadyAliveException> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AlreadyAliveException"); - - private static final org.apache.thrift.protocol.TField MSG_FIELD_DESC = new org.apache.thrift.protocol.TField("msg", org.apache.thrift.protocol.TType.STRING, (short)1); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new AlreadyAliveExceptionStandardSchemeFactory()); - schemes.put(TupleScheme.class, new AlreadyAliveExceptionTupleSchemeFactory()); - } - - private String msg; // 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 { - MSG((short)1, "msg"); - - 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: // MSG - return MSG; - 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.MSG, new org.apache.thrift.meta_data.FieldMetaData("msg", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AlreadyAliveException.class, metaDataMap); - } - - public AlreadyAliveException() { - } - - public AlreadyAliveException( - String msg) - { - this(); - this.msg = msg; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public AlreadyAliveException(AlreadyAliveException other) { - if (other.is_set_msg()) { - this.msg = other.msg; - } - } - - public AlreadyAliveException deepCopy() { - return new AlreadyAliveException(this); - } - - @Override - public void clear() { - this.msg = null; - } - - public String get_msg() { - return this.msg; - } - - public void set_msg(String msg) { - this.msg = msg; - } - - public void unset_msg() { - this.msg = null; - } - - /** Returns true if field msg is set (has been assigned a value) and false otherwise */ - public boolean is_set_msg() { - return this.msg != null; - } - - public void set_msg_isSet(boolean value) { - if (!value) { - this.msg = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case MSG: - if (value == null) { - unset_msg(); - } else { - set_msg((String)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case MSG: - return get_msg(); - - } - 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 MSG: - return is_set_msg(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof AlreadyAliveException) - return this.equals((AlreadyAliveException)that); - return false; - } - - public boolean equals(AlreadyAliveException that) { - if (that == null) - return false; - - boolean this_present_msg = true && this.is_set_msg(); - boolean that_present_msg = true && that.is_set_msg(); - if (this_present_msg || that_present_msg) { - if (!(this_present_msg && that_present_msg)) - return false; - if (!this.msg.equals(that.msg)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_msg = true && (is_set_msg()); - list.add(present_msg); - if (present_msg) - list.add(msg); - - return list.hashCode(); - } - - @Override - public int compareTo(AlreadyAliveException other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(is_set_msg()).compareTo(other.is_set_msg()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_msg()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.msg, other.msg); - 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("AlreadyAliveException("); - boolean first = true; - - sb.append("msg:"); - if (this.msg == null) { - sb.append("null"); - } else { - sb.append(this.msg); - } - first = false; - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (!is_set_msg()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'msg' 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 AlreadyAliveExceptionStandardSchemeFactory implements SchemeFactory { - public AlreadyAliveExceptionStandardScheme getScheme() { - return new AlreadyAliveExceptionStandardScheme(); - } - } - - private static class AlreadyAliveExceptionStandardScheme extends StandardScheme<AlreadyAliveException> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, AlreadyAliveException 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: // MSG - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.msg = iprot.readString(); - struct.set_msg_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, AlreadyAliveException struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.msg != null) { - oprot.writeFieldBegin(MSG_FIELD_DESC); - oprot.writeString(struct.msg); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class AlreadyAliveExceptionTupleSchemeFactory implements SchemeFactory { - public AlreadyAliveExceptionTupleScheme getScheme() { - return new AlreadyAliveExceptionTupleScheme(); - } - } - - private static class AlreadyAliveExceptionTupleScheme extends TupleScheme<AlreadyAliveException> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, AlreadyAliveException struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - oprot.writeString(struct.msg); - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, AlreadyAliveException struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - struct.msg = iprot.readString(); - struct.set_msg_isSet(true); - } - } - -} - http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/Assignment.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/Assignment.java b/storm-core/src/jvm/backtype/storm/generated/Assignment.java deleted file mode 100644 index 4c973d5..0000000 --- a/storm-core/src/jvm/backtype/storm/generated/Assignment.java +++ /dev/null @@ -1,1159 +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 Assignment implements org.apache.thrift.TBase<Assignment, Assignment._Fields>, java.io.Serializable, Cloneable, Comparable<Assignment> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Assignment"); - - private static final org.apache.thrift.protocol.TField MASTER_CODE_DIR_FIELD_DESC = new org.apache.thrift.protocol.TField("master_code_dir", org.apache.thrift.protocol.TType.STRING, (short)1); - private static final org.apache.thrift.protocol.TField NODE_HOST_FIELD_DESC = new org.apache.thrift.protocol.TField("node_host", org.apache.thrift.protocol.TType.MAP, (short)2); - private static final org.apache.thrift.protocol.TField EXECUTOR_NODE_PORT_FIELD_DESC = new org.apache.thrift.protocol.TField("executor_node_port", org.apache.thrift.protocol.TType.MAP, (short)3); - private static final org.apache.thrift.protocol.TField EXECUTOR_START_TIME_SECS_FIELD_DESC = new org.apache.thrift.protocol.TField("executor_start_time_secs", org.apache.thrift.protocol.TType.MAP, (short)4); - private static final org.apache.thrift.protocol.TField WORKER_RESOURCES_FIELD_DESC = new org.apache.thrift.protocol.TField("worker_resources", org.apache.thrift.protocol.TType.MAP, (short)5); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new AssignmentStandardSchemeFactory()); - schemes.put(TupleScheme.class, new AssignmentTupleSchemeFactory()); - } - - private String master_code_dir; // required - private Map<String,String> node_host; // optional - private Map<List<Long>,NodeInfo> executor_node_port; // optional - private Map<List<Long>,Long> executor_start_time_secs; // optional - private Map<NodeInfo,WorkerResources> worker_resources; // 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 { - MASTER_CODE_DIR((short)1, "master_code_dir"), - NODE_HOST((short)2, "node_host"), - EXECUTOR_NODE_PORT((short)3, "executor_node_port"), - EXECUTOR_START_TIME_SECS((short)4, "executor_start_time_secs"), - WORKER_RESOURCES((short)5, "worker_resources"); - - 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: // MASTER_CODE_DIR - return MASTER_CODE_DIR; - case 2: // NODE_HOST - return NODE_HOST; - case 3: // EXECUTOR_NODE_PORT - return EXECUTOR_NODE_PORT; - case 4: // EXECUTOR_START_TIME_SECS - return EXECUTOR_START_TIME_SECS; - case 5: // WORKER_RESOURCES - return WORKER_RESOURCES; - 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 _Fields optionals[] = {_Fields.NODE_HOST,_Fields.EXECUTOR_NODE_PORT,_Fields.EXECUTOR_START_TIME_SECS,_Fields.WORKER_RESOURCES}; - 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.MASTER_CODE_DIR, new org.apache.thrift.meta_data.FieldMetaData("master_code_dir", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.NODE_HOST, new org.apache.thrift.meta_data.FieldMetaData("node_host", 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.STRING)))); - tmpMap.put(_Fields.EXECUTOR_NODE_PORT, new org.apache.thrift.meta_data.FieldMetaData("executor_node_port", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, - 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.I64)), - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, NodeInfo.class)))); - tmpMap.put(_Fields.EXECUTOR_START_TIME_SECS, new org.apache.thrift.meta_data.FieldMetaData("executor_start_time_secs", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, - 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.I64)), - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)))); - tmpMap.put(_Fields.WORKER_RESOURCES, new org.apache.thrift.meta_data.FieldMetaData("worker_resources", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, NodeInfo.class), - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, WorkerResources.class)))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(Assignment.class, metaDataMap); - } - - public Assignment() { - this.node_host = new HashMap<String,String>(); - - this.executor_node_port = new HashMap<List<Long>,NodeInfo>(); - - this.executor_start_time_secs = new HashMap<List<Long>,Long>(); - - this.worker_resources = new HashMap<NodeInfo,WorkerResources>(); - - } - - public Assignment( - String master_code_dir) - { - this(); - this.master_code_dir = master_code_dir; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public Assignment(Assignment other) { - if (other.is_set_master_code_dir()) { - this.master_code_dir = other.master_code_dir; - } - if (other.is_set_node_host()) { - Map<String,String> __this__node_host = new HashMap<String,String>(other.node_host); - this.node_host = __this__node_host; - } - if (other.is_set_executor_node_port()) { - Map<List<Long>,NodeInfo> __this__executor_node_port = new HashMap<List<Long>,NodeInfo>(other.executor_node_port.size()); - for (Map.Entry<List<Long>, NodeInfo> other_element : other.executor_node_port.entrySet()) { - - List<Long> other_element_key = other_element.getKey(); - NodeInfo other_element_value = other_element.getValue(); - - List<Long> __this__executor_node_port_copy_key = new ArrayList<Long>(other_element_key); - - NodeInfo __this__executor_node_port_copy_value = new NodeInfo(other_element_value); - - __this__executor_node_port.put(__this__executor_node_port_copy_key, __this__executor_node_port_copy_value); - } - this.executor_node_port = __this__executor_node_port; - } - if (other.is_set_executor_start_time_secs()) { - Map<List<Long>,Long> __this__executor_start_time_secs = new HashMap<List<Long>,Long>(other.executor_start_time_secs.size()); - for (Map.Entry<List<Long>, Long> other_element : other.executor_start_time_secs.entrySet()) { - - List<Long> other_element_key = other_element.getKey(); - Long other_element_value = other_element.getValue(); - - List<Long> __this__executor_start_time_secs_copy_key = new ArrayList<Long>(other_element_key); - - Long __this__executor_start_time_secs_copy_value = other_element_value; - - __this__executor_start_time_secs.put(__this__executor_start_time_secs_copy_key, __this__executor_start_time_secs_copy_value); - } - this.executor_start_time_secs = __this__executor_start_time_secs; - } - if (other.is_set_worker_resources()) { - Map<NodeInfo,WorkerResources> __this__worker_resources = new HashMap<NodeInfo,WorkerResources>(other.worker_resources.size()); - for (Map.Entry<NodeInfo, WorkerResources> other_element : other.worker_resources.entrySet()) { - - NodeInfo other_element_key = other_element.getKey(); - WorkerResources other_element_value = other_element.getValue(); - - NodeInfo __this__worker_resources_copy_key = new NodeInfo(other_element_key); - - WorkerResources __this__worker_resources_copy_value = new WorkerResources(other_element_value); - - __this__worker_resources.put(__this__worker_resources_copy_key, __this__worker_resources_copy_value); - } - this.worker_resources = __this__worker_resources; - } - } - - public Assignment deepCopy() { - return new Assignment(this); - } - - @Override - public void clear() { - this.master_code_dir = null; - this.node_host = new HashMap<String,String>(); - - this.executor_node_port = new HashMap<List<Long>,NodeInfo>(); - - this.executor_start_time_secs = new HashMap<List<Long>,Long>(); - - this.worker_resources = new HashMap<NodeInfo,WorkerResources>(); - - } - - public String get_master_code_dir() { - return this.master_code_dir; - } - - public void set_master_code_dir(String master_code_dir) { - this.master_code_dir = master_code_dir; - } - - public void unset_master_code_dir() { - this.master_code_dir = null; - } - - /** Returns true if field master_code_dir is set (has been assigned a value) and false otherwise */ - public boolean is_set_master_code_dir() { - return this.master_code_dir != null; - } - - public void set_master_code_dir_isSet(boolean value) { - if (!value) { - this.master_code_dir = null; - } - } - - public int get_node_host_size() { - return (this.node_host == null) ? 0 : this.node_host.size(); - } - - public void put_to_node_host(String key, String val) { - if (this.node_host == null) { - this.node_host = new HashMap<String,String>(); - } - this.node_host.put(key, val); - } - - public Map<String,String> get_node_host() { - return this.node_host; - } - - public void set_node_host(Map<String,String> node_host) { - this.node_host = node_host; - } - - public void unset_node_host() { - this.node_host = null; - } - - /** Returns true if field node_host is set (has been assigned a value) and false otherwise */ - public boolean is_set_node_host() { - return this.node_host != null; - } - - public void set_node_host_isSet(boolean value) { - if (!value) { - this.node_host = null; - } - } - - public int get_executor_node_port_size() { - return (this.executor_node_port == null) ? 0 : this.executor_node_port.size(); - } - - public void put_to_executor_node_port(List<Long> key, NodeInfo val) { - if (this.executor_node_port == null) { - this.executor_node_port = new HashMap<List<Long>,NodeInfo>(); - } - this.executor_node_port.put(key, val); - } - - public Map<List<Long>,NodeInfo> get_executor_node_port() { - return this.executor_node_port; - } - - public void set_executor_node_port(Map<List<Long>,NodeInfo> executor_node_port) { - this.executor_node_port = executor_node_port; - } - - public void unset_executor_node_port() { - this.executor_node_port = null; - } - - /** Returns true if field executor_node_port is set (has been assigned a value) and false otherwise */ - public boolean is_set_executor_node_port() { - return this.executor_node_port != null; - } - - public void set_executor_node_port_isSet(boolean value) { - if (!value) { - this.executor_node_port = null; - } - } - - public int get_executor_start_time_secs_size() { - return (this.executor_start_time_secs == null) ? 0 : this.executor_start_time_secs.size(); - } - - public void put_to_executor_start_time_secs(List<Long> key, long val) { - if (this.executor_start_time_secs == null) { - this.executor_start_time_secs = new HashMap<List<Long>,Long>(); - } - this.executor_start_time_secs.put(key, val); - } - - public Map<List<Long>,Long> get_executor_start_time_secs() { - return this.executor_start_time_secs; - } - - public void set_executor_start_time_secs(Map<List<Long>,Long> executor_start_time_secs) { - this.executor_start_time_secs = executor_start_time_secs; - } - - public void unset_executor_start_time_secs() { - this.executor_start_time_secs = null; - } - - /** Returns true if field executor_start_time_secs is set (has been assigned a value) and false otherwise */ - public boolean is_set_executor_start_time_secs() { - return this.executor_start_time_secs != null; - } - - public void set_executor_start_time_secs_isSet(boolean value) { - if (!value) { - this.executor_start_time_secs = null; - } - } - - public int get_worker_resources_size() { - return (this.worker_resources == null) ? 0 : this.worker_resources.size(); - } - - public void put_to_worker_resources(NodeInfo key, WorkerResources val) { - if (this.worker_resources == null) { - this.worker_resources = new HashMap<NodeInfo,WorkerResources>(); - } - this.worker_resources.put(key, val); - } - - public Map<NodeInfo,WorkerResources> get_worker_resources() { - return this.worker_resources; - } - - public void set_worker_resources(Map<NodeInfo,WorkerResources> worker_resources) { - this.worker_resources = worker_resources; - } - - public void unset_worker_resources() { - this.worker_resources = null; - } - - /** Returns true if field worker_resources is set (has been assigned a value) and false otherwise */ - public boolean is_set_worker_resources() { - return this.worker_resources != null; - } - - public void set_worker_resources_isSet(boolean value) { - if (!value) { - this.worker_resources = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case MASTER_CODE_DIR: - if (value == null) { - unset_master_code_dir(); - } else { - set_master_code_dir((String)value); - } - break; - - case NODE_HOST: - if (value == null) { - unset_node_host(); - } else { - set_node_host((Map<String,String>)value); - } - break; - - case EXECUTOR_NODE_PORT: - if (value == null) { - unset_executor_node_port(); - } else { - set_executor_node_port((Map<List<Long>,NodeInfo>)value); - } - break; - - case EXECUTOR_START_TIME_SECS: - if (value == null) { - unset_executor_start_time_secs(); - } else { - set_executor_start_time_secs((Map<List<Long>,Long>)value); - } - break; - - case WORKER_RESOURCES: - if (value == null) { - unset_worker_resources(); - } else { - set_worker_resources((Map<NodeInfo,WorkerResources>)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case MASTER_CODE_DIR: - return get_master_code_dir(); - - case NODE_HOST: - return get_node_host(); - - case EXECUTOR_NODE_PORT: - return get_executor_node_port(); - - case EXECUTOR_START_TIME_SECS: - return get_executor_start_time_secs(); - - case WORKER_RESOURCES: - return get_worker_resources(); - - } - 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 MASTER_CODE_DIR: - return is_set_master_code_dir(); - case NODE_HOST: - return is_set_node_host(); - case EXECUTOR_NODE_PORT: - return is_set_executor_node_port(); - case EXECUTOR_START_TIME_SECS: - return is_set_executor_start_time_secs(); - case WORKER_RESOURCES: - return is_set_worker_resources(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof Assignment) - return this.equals((Assignment)that); - return false; - } - - public boolean equals(Assignment that) { - if (that == null) - return false; - - boolean this_present_master_code_dir = true && this.is_set_master_code_dir(); - boolean that_present_master_code_dir = true && that.is_set_master_code_dir(); - if (this_present_master_code_dir || that_present_master_code_dir) { - if (!(this_present_master_code_dir && that_present_master_code_dir)) - return false; - if (!this.master_code_dir.equals(that.master_code_dir)) - return false; - } - - boolean this_present_node_host = true && this.is_set_node_host(); - boolean that_present_node_host = true && that.is_set_node_host(); - if (this_present_node_host || that_present_node_host) { - if (!(this_present_node_host && that_present_node_host)) - return false; - if (!this.node_host.equals(that.node_host)) - return false; - } - - boolean this_present_executor_node_port = true && this.is_set_executor_node_port(); - boolean that_present_executor_node_port = true && that.is_set_executor_node_port(); - if (this_present_executor_node_port || that_present_executor_node_port) { - if (!(this_present_executor_node_port && that_present_executor_node_port)) - return false; - if (!this.executor_node_port.equals(that.executor_node_port)) - return false; - } - - boolean this_present_executor_start_time_secs = true && this.is_set_executor_start_time_secs(); - boolean that_present_executor_start_time_secs = true && that.is_set_executor_start_time_secs(); - if (this_present_executor_start_time_secs || that_present_executor_start_time_secs) { - if (!(this_present_executor_start_time_secs && that_present_executor_start_time_secs)) - return false; - if (!this.executor_start_time_secs.equals(that.executor_start_time_secs)) - return false; - } - - boolean this_present_worker_resources = true && this.is_set_worker_resources(); - boolean that_present_worker_resources = true && that.is_set_worker_resources(); - if (this_present_worker_resources || that_present_worker_resources) { - if (!(this_present_worker_resources && that_present_worker_resources)) - return false; - if (!this.worker_resources.equals(that.worker_resources)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_master_code_dir = true && (is_set_master_code_dir()); - list.add(present_master_code_dir); - if (present_master_code_dir) - list.add(master_code_dir); - - boolean present_node_host = true && (is_set_node_host()); - list.add(present_node_host); - if (present_node_host) - list.add(node_host); - - boolean present_executor_node_port = true && (is_set_executor_node_port()); - list.add(present_executor_node_port); - if (present_executor_node_port) - list.add(executor_node_port); - - boolean present_executor_start_time_secs = true && (is_set_executor_start_time_secs()); - list.add(present_executor_start_time_secs); - if (present_executor_start_time_secs) - list.add(executor_start_time_secs); - - boolean present_worker_resources = true && (is_set_worker_resources()); - list.add(present_worker_resources); - if (present_worker_resources) - list.add(worker_resources); - - return list.hashCode(); - } - - @Override - public int compareTo(Assignment other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(is_set_master_code_dir()).compareTo(other.is_set_master_code_dir()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_master_code_dir()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.master_code_dir, other.master_code_dir); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_node_host()).compareTo(other.is_set_node_host()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_node_host()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.node_host, other.node_host); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_executor_node_port()).compareTo(other.is_set_executor_node_port()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_executor_node_port()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.executor_node_port, other.executor_node_port); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_executor_start_time_secs()).compareTo(other.is_set_executor_start_time_secs()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_executor_start_time_secs()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.executor_start_time_secs, other.executor_start_time_secs); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(is_set_worker_resources()).compareTo(other.is_set_worker_resources()); - if (lastComparison != 0) { - return lastComparison; - } - if (is_set_worker_resources()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.worker_resources, other.worker_resources); - 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("Assignment("); - boolean first = true; - - sb.append("master_code_dir:"); - if (this.master_code_dir == null) { - sb.append("null"); - } else { - sb.append(this.master_code_dir); - } - first = false; - if (is_set_node_host()) { - if (!first) sb.append(", "); - sb.append("node_host:"); - if (this.node_host == null) { - sb.append("null"); - } else { - sb.append(this.node_host); - } - first = false; - } - if (is_set_executor_node_port()) { - if (!first) sb.append(", "); - sb.append("executor_node_port:"); - if (this.executor_node_port == null) { - sb.append("null"); - } else { - sb.append(this.executor_node_port); - } - first = false; - } - if (is_set_executor_start_time_secs()) { - if (!first) sb.append(", "); - sb.append("executor_start_time_secs:"); - if (this.executor_start_time_secs == null) { - sb.append("null"); - } else { - sb.append(this.executor_start_time_secs); - } - first = false; - } - if (is_set_worker_resources()) { - if (!first) sb.append(", "); - sb.append("worker_resources:"); - if (this.worker_resources == null) { - sb.append("null"); - } else { - sb.append(this.worker_resources); - } - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (!is_set_master_code_dir()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'master_code_dir' 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 AssignmentStandardSchemeFactory implements SchemeFactory { - public AssignmentStandardScheme getScheme() { - return new AssignmentStandardScheme(); - } - } - - private static class AssignmentStandardScheme extends StandardScheme<Assignment> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, Assignment 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: // MASTER_CODE_DIR - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.master_code_dir = iprot.readString(); - struct.set_master_code_dir_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // NODE_HOST - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map618 = iprot.readMapBegin(); - struct.node_host = new HashMap<String,String>(2*_map618.size); - String _key619; - String _val620; - for (int _i621 = 0; _i621 < _map618.size; ++_i621) - { - _key619 = iprot.readString(); - _val620 = iprot.readString(); - struct.node_host.put(_key619, _val620); - } - iprot.readMapEnd(); - } - struct.set_node_host_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // EXECUTOR_NODE_PORT - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map622 = iprot.readMapBegin(); - struct.executor_node_port = new HashMap<List<Long>,NodeInfo>(2*_map622.size); - List<Long> _key623; - NodeInfo _val624; - for (int _i625 = 0; _i625 < _map622.size; ++_i625) - { - { - org.apache.thrift.protocol.TList _list626 = iprot.readListBegin(); - _key623 = new ArrayList<Long>(_list626.size); - long _elem627; - for (int _i628 = 0; _i628 < _list626.size; ++_i628) - { - _elem627 = iprot.readI64(); - _key623.add(_elem627); - } - iprot.readListEnd(); - } - _val624 = new NodeInfo(); - _val624.read(iprot); - struct.executor_node_port.put(_key623, _val624); - } - iprot.readMapEnd(); - } - struct.set_executor_node_port_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 4: // EXECUTOR_START_TIME_SECS - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map629 = iprot.readMapBegin(); - struct.executor_start_time_secs = new HashMap<List<Long>,Long>(2*_map629.size); - List<Long> _key630; - long _val631; - for (int _i632 = 0; _i632 < _map629.size; ++_i632) - { - { - org.apache.thrift.protocol.TList _list633 = iprot.readListBegin(); - _key630 = new ArrayList<Long>(_list633.size); - long _elem634; - for (int _i635 = 0; _i635 < _list633.size; ++_i635) - { - _elem634 = iprot.readI64(); - _key630.add(_elem634); - } - iprot.readListEnd(); - } - _val631 = iprot.readI64(); - struct.executor_start_time_secs.put(_key630, _val631); - } - iprot.readMapEnd(); - } - struct.set_executor_start_time_secs_isSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 5: // WORKER_RESOURCES - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map636 = iprot.readMapBegin(); - struct.worker_resources = new HashMap<NodeInfo,WorkerResources>(2*_map636.size); - NodeInfo _key637; - WorkerResources _val638; - for (int _i639 = 0; _i639 < _map636.size; ++_i639) - { - _key637 = new NodeInfo(); - _key637.read(iprot); - _val638 = new WorkerResources(); - _val638.read(iprot); - struct.worker_resources.put(_key637, _val638); - } - iprot.readMapEnd(); - } - struct.set_worker_resources_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, Assignment struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.master_code_dir != null) { - oprot.writeFieldBegin(MASTER_CODE_DIR_FIELD_DESC); - oprot.writeString(struct.master_code_dir); - oprot.writeFieldEnd(); - } - if (struct.node_host != null) { - if (struct.is_set_node_host()) { - oprot.writeFieldBegin(NODE_HOST_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.node_host.size())); - for (Map.Entry<String, String> _iter640 : struct.node_host.entrySet()) - { - oprot.writeString(_iter640.getKey()); - oprot.writeString(_iter640.getValue()); - } - oprot.writeMapEnd(); - } - oprot.writeFieldEnd(); - } - } - if (struct.executor_node_port != null) { - if (struct.is_set_executor_node_port()) { - oprot.writeFieldBegin(EXECUTOR_NODE_PORT_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.LIST, org.apache.thrift.protocol.TType.STRUCT, struct.executor_node_port.size())); - for (Map.Entry<List<Long>, NodeInfo> _iter641 : struct.executor_node_port.entrySet()) - { - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, _iter641.getKey().size())); - for (long _iter642 : _iter641.getKey()) - { - oprot.writeI64(_iter642); - } - oprot.writeListEnd(); - } - _iter641.getValue().write(oprot); - } - oprot.writeMapEnd(); - } - oprot.writeFieldEnd(); - } - } - if (struct.executor_start_time_secs != null) { - if (struct.is_set_executor_start_time_secs()) { - oprot.writeFieldBegin(EXECUTOR_START_TIME_SECS_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.LIST, org.apache.thrift.protocol.TType.I64, struct.executor_start_time_secs.size())); - for (Map.Entry<List<Long>, Long> _iter643 : struct.executor_start_time_secs.entrySet()) - { - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, _iter643.getKey().size())); - for (long _iter644 : _iter643.getKey()) - { - oprot.writeI64(_iter644); - } - oprot.writeListEnd(); - } - oprot.writeI64(_iter643.getValue()); - } - oprot.writeMapEnd(); - } - oprot.writeFieldEnd(); - } - } - if (struct.worker_resources != null) { - if (struct.is_set_worker_resources()) { - oprot.writeFieldBegin(WORKER_RESOURCES_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.STRUCT, struct.worker_resources.size())); - for (Map.Entry<NodeInfo, WorkerResources> _iter645 : struct.worker_resources.entrySet()) - { - _iter645.getKey().write(oprot); - _iter645.getValue().write(oprot); - } - oprot.writeMapEnd(); - } - oprot.writeFieldEnd(); - } - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class AssignmentTupleSchemeFactory implements SchemeFactory { - public AssignmentTupleScheme getScheme() { - return new AssignmentTupleScheme(); - } - } - - private static class AssignmentTupleScheme extends TupleScheme<Assignment> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, Assignment struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - oprot.writeString(struct.master_code_dir); - BitSet optionals = new BitSet(); - if (struct.is_set_node_host()) { - optionals.set(0); - } - if (struct.is_set_executor_node_port()) { - optionals.set(1); - } - if (struct.is_set_executor_start_time_secs()) { - optionals.set(2); - } - if (struct.is_set_worker_resources()) { - optionals.set(3); - } - oprot.writeBitSet(optionals, 4); - if (struct.is_set_node_host()) { - { - oprot.writeI32(struct.node_host.size()); - for (Map.Entry<String, String> _iter646 : struct.node_host.entrySet()) - { - oprot.writeString(_iter646.getKey()); - oprot.writeString(_iter646.getValue()); - } - } - } - if (struct.is_set_executor_node_port()) { - { - oprot.writeI32(struct.executor_node_port.size()); - for (Map.Entry<List<Long>, NodeInfo> _iter647 : struct.executor_node_port.entrySet()) - { - { - oprot.writeI32(_iter647.getKey().size()); - for (long _iter648 : _iter647.getKey()) - { - oprot.writeI64(_iter648); - } - } - _iter647.getValue().write(oprot); - } - } - } - if (struct.is_set_executor_start_time_secs()) { - { - oprot.writeI32(struct.executor_start_time_secs.size()); - for (Map.Entry<List<Long>, Long> _iter649 : struct.executor_start_time_secs.entrySet()) - { - { - oprot.writeI32(_iter649.getKey().size()); - for (long _iter650 : _iter649.getKey()) - { - oprot.writeI64(_iter650); - } - } - oprot.writeI64(_iter649.getValue()); - } - } - } - if (struct.is_set_worker_resources()) { - { - oprot.writeI32(struct.worker_resources.size()); - for (Map.Entry<NodeInfo, WorkerResources> _iter651 : struct.worker_resources.entrySet()) - { - _iter651.getKey().write(oprot); - _iter651.getValue().write(oprot); - } - } - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, Assignment struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - struct.master_code_dir = iprot.readString(); - struct.set_master_code_dir_isSet(true); - BitSet incoming = iprot.readBitSet(4); - if (incoming.get(0)) { - { - org.apache.thrift.protocol.TMap _map652 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.node_host = new HashMap<String,String>(2*_map652.size); - String _key653; - String _val654; - for (int _i655 = 0; _i655 < _map652.size; ++_i655) - { - _key653 = iprot.readString(); - _val654 = iprot.readString(); - struct.node_host.put(_key653, _val654); - } - } - struct.set_node_host_isSet(true); - } - if (incoming.get(1)) { - { - org.apache.thrift.protocol.TMap _map656 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.LIST, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.executor_node_port = new HashMap<List<Long>,NodeInfo>(2*_map656.size); - List<Long> _key657; - NodeInfo _val658; - for (int _i659 = 0; _i659 < _map656.size; ++_i659) - { - { - org.apache.thrift.protocol.TList _list660 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - _key657 = new ArrayList<Long>(_list660.size); - long _elem661; - for (int _i662 = 0; _i662 < _list660.size; ++_i662) - { - _elem661 = iprot.readI64(); - _key657.add(_elem661); - } - } - _val658 = new NodeInfo(); - _val658.read(iprot); - struct.executor_node_port.put(_key657, _val658); - } - } - struct.set_executor_node_port_isSet(true); - } - if (incoming.get(2)) { - { - org.apache.thrift.protocol.TMap _map663 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.LIST, org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.executor_start_time_secs = new HashMap<List<Long>,Long>(2*_map663.size); - List<Long> _key664; - long _val665; - for (int _i666 = 0; _i666 < _map663.size; ++_i666) - { - { - org.apache.thrift.protocol.TList _list667 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - _key664 = new ArrayList<Long>(_list667.size); - long _elem668; - for (int _i669 = 0; _i669 < _list667.size; ++_i669) - { - _elem668 = iprot.readI64(); - _key664.add(_elem668); - } - } - _val665 = iprot.readI64(); - struct.executor_start_time_secs.put(_key664, _val665); - } - } - struct.set_executor_start_time_secs_isSet(true); - } - if (incoming.get(3)) { - { - org.apache.thrift.protocol.TMap _map670 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.worker_resources = new HashMap<NodeInfo,WorkerResources>(2*_map670.size); - NodeInfo _key671; - WorkerResources _val672; - for (int _i673 = 0; _i673 < _map670.size; ++_i673) - { - _key671 = new NodeInfo(); - _key671.read(iprot); - _val672 = new WorkerResources(); - _val672.read(iprot); - struct.worker_resources.put(_key671, _val672); - } - } - struct.set_worker_resources_isSet(true); - } - } - } - -} -
