http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateInstructions.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateInstructions.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateInstructions.java new file mode 100644 index 0000000..45a7702 --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateInstructions.java @@ -0,0 +1,711 @@ +/** + * 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.airavata.cloud.aurora.client.sdk; + +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"}) +/** + * Update configuration and setting details. + */ +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-10-21") +public class JobUpdateInstructions implements org.apache.thrift.TBase<JobUpdateInstructions, JobUpdateInstructions._Fields>, java.io.Serializable, Cloneable, Comparable<JobUpdateInstructions> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("JobUpdateInstructions"); + + private static final org.apache.thrift.protocol.TField INITIAL_STATE_FIELD_DESC = new org.apache.thrift.protocol.TField("initialState", org.apache.thrift.protocol.TType.SET, (short)1); + private static final org.apache.thrift.protocol.TField DESIRED_STATE_FIELD_DESC = new org.apache.thrift.protocol.TField("desiredState", org.apache.thrift.protocol.TType.STRUCT, (short)2); + private static final org.apache.thrift.protocol.TField SETTINGS_FIELD_DESC = new org.apache.thrift.protocol.TField("settings", org.apache.thrift.protocol.TType.STRUCT, (short)3); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new JobUpdateInstructionsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new JobUpdateInstructionsTupleSchemeFactory()); + } + + /** + * Actual InstanceId -> TaskConfig mapping when the update was requested. + */ + public Set<InstanceTaskConfig> initialState; // required + /** + * Desired configuration when the update completes. + */ + public InstanceTaskConfig desiredState; // required + /** + * Update specific settings. + */ + public JobUpdateSettings settings; // 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 { + /** + * Actual InstanceId -> TaskConfig mapping when the update was requested. + */ + INITIAL_STATE((short)1, "initialState"), + /** + * Desired configuration when the update completes. + */ + DESIRED_STATE((short)2, "desiredState"), + /** + * Update specific settings. + */ + SETTINGS((short)3, "settings"); + + 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: // INITIAL_STATE + return INITIAL_STATE; + case 2: // DESIRED_STATE + return DESIRED_STATE; + case 3: // SETTINGS + return SETTINGS; + 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.INITIAL_STATE, new org.apache.thrift.meta_data.FieldMetaData("initialState", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.SetMetaData(org.apache.thrift.protocol.TType.SET, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, InstanceTaskConfig.class)))); + tmpMap.put(_Fields.DESIRED_STATE, new org.apache.thrift.meta_data.FieldMetaData("desiredState", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, InstanceTaskConfig.class))); + tmpMap.put(_Fields.SETTINGS, new org.apache.thrift.meta_data.FieldMetaData("settings", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, JobUpdateSettings.class))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(JobUpdateInstructions.class, metaDataMap); + } + + public JobUpdateInstructions() { + } + + public JobUpdateInstructions( + Set<InstanceTaskConfig> initialState, + InstanceTaskConfig desiredState, + JobUpdateSettings settings) + { + this(); + this.initialState = initialState; + this.desiredState = desiredState; + this.settings = settings; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public JobUpdateInstructions(JobUpdateInstructions other) { + if (other.isSetInitialState()) { + Set<InstanceTaskConfig> __this__initialState = new HashSet<InstanceTaskConfig>(other.initialState.size()); + for (InstanceTaskConfig other_element : other.initialState) { + __this__initialState.add(new InstanceTaskConfig(other_element)); + } + this.initialState = __this__initialState; + } + if (other.isSetDesiredState()) { + this.desiredState = new InstanceTaskConfig(other.desiredState); + } + if (other.isSetSettings()) { + this.settings = new JobUpdateSettings(other.settings); + } + } + + public JobUpdateInstructions deepCopy() { + return new JobUpdateInstructions(this); + } + + @Override + public void clear() { + this.initialState = null; + this.desiredState = null; + this.settings = null; + } + + public int getInitialStateSize() { + return (this.initialState == null) ? 0 : this.initialState.size(); + } + + public java.util.Iterator<InstanceTaskConfig> getInitialStateIterator() { + return (this.initialState == null) ? null : this.initialState.iterator(); + } + + public void addToInitialState(InstanceTaskConfig elem) { + if (this.initialState == null) { + this.initialState = new HashSet<InstanceTaskConfig>(); + } + this.initialState.add(elem); + } + + /** + * Actual InstanceId -> TaskConfig mapping when the update was requested. + */ + public Set<InstanceTaskConfig> getInitialState() { + return this.initialState; + } + + /** + * Actual InstanceId -> TaskConfig mapping when the update was requested. + */ + public JobUpdateInstructions setInitialState(Set<InstanceTaskConfig> initialState) { + this.initialState = initialState; + return this; + } + + public void unsetInitialState() { + this.initialState = null; + } + + /** Returns true if field initialState is set (has been assigned a value) and false otherwise */ + public boolean isSetInitialState() { + return this.initialState != null; + } + + public void setInitialStateIsSet(boolean value) { + if (!value) { + this.initialState = null; + } + } + + /** + * Desired configuration when the update completes. + */ + public InstanceTaskConfig getDesiredState() { + return this.desiredState; + } + + /** + * Desired configuration when the update completes. + */ + public JobUpdateInstructions setDesiredState(InstanceTaskConfig desiredState) { + this.desiredState = desiredState; + return this; + } + + public void unsetDesiredState() { + this.desiredState = null; + } + + /** Returns true if field desiredState is set (has been assigned a value) and false otherwise */ + public boolean isSetDesiredState() { + return this.desiredState != null; + } + + public void setDesiredStateIsSet(boolean value) { + if (!value) { + this.desiredState = null; + } + } + + /** + * Update specific settings. + */ + public JobUpdateSettings getSettings() { + return this.settings; + } + + /** + * Update specific settings. + */ + public JobUpdateInstructions setSettings(JobUpdateSettings settings) { + this.settings = settings; + return this; + } + + public void unsetSettings() { + this.settings = null; + } + + /** Returns true if field settings is set (has been assigned a value) and false otherwise */ + public boolean isSetSettings() { + return this.settings != null; + } + + public void setSettingsIsSet(boolean value) { + if (!value) { + this.settings = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case INITIAL_STATE: + if (value == null) { + unsetInitialState(); + } else { + setInitialState((Set<InstanceTaskConfig>)value); + } + break; + + case DESIRED_STATE: + if (value == null) { + unsetDesiredState(); + } else { + setDesiredState((InstanceTaskConfig)value); + } + break; + + case SETTINGS: + if (value == null) { + unsetSettings(); + } else { + setSettings((JobUpdateSettings)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case INITIAL_STATE: + return getInitialState(); + + case DESIRED_STATE: + return getDesiredState(); + + case SETTINGS: + return getSettings(); + + } + 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 INITIAL_STATE: + return isSetInitialState(); + case DESIRED_STATE: + return isSetDesiredState(); + case SETTINGS: + return isSetSettings(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof JobUpdateInstructions) + return this.equals((JobUpdateInstructions)that); + return false; + } + + public boolean equals(JobUpdateInstructions that) { + if (that == null) + return false; + + boolean this_present_initialState = true && this.isSetInitialState(); + boolean that_present_initialState = true && that.isSetInitialState(); + if (this_present_initialState || that_present_initialState) { + if (!(this_present_initialState && that_present_initialState)) + return false; + if (!this.initialState.equals(that.initialState)) + return false; + } + + boolean this_present_desiredState = true && this.isSetDesiredState(); + boolean that_present_desiredState = true && that.isSetDesiredState(); + if (this_present_desiredState || that_present_desiredState) { + if (!(this_present_desiredState && that_present_desiredState)) + return false; + if (!this.desiredState.equals(that.desiredState)) + return false; + } + + boolean this_present_settings = true && this.isSetSettings(); + boolean that_present_settings = true && that.isSetSettings(); + if (this_present_settings || that_present_settings) { + if (!(this_present_settings && that_present_settings)) + return false; + if (!this.settings.equals(that.settings)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_initialState = true && (isSetInitialState()); + list.add(present_initialState); + if (present_initialState) + list.add(initialState); + + boolean present_desiredState = true && (isSetDesiredState()); + list.add(present_desiredState); + if (present_desiredState) + list.add(desiredState); + + boolean present_settings = true && (isSetSettings()); + list.add(present_settings); + if (present_settings) + list.add(settings); + + return list.hashCode(); + } + + @Override + public int compareTo(JobUpdateInstructions other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetInitialState()).compareTo(other.isSetInitialState()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetInitialState()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.initialState, other.initialState); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetDesiredState()).compareTo(other.isSetDesiredState()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetDesiredState()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.desiredState, other.desiredState); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetSettings()).compareTo(other.isSetSettings()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetSettings()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.settings, other.settings); + 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("JobUpdateInstructions("); + boolean first = true; + + sb.append("initialState:"); + if (this.initialState == null) { + sb.append("null"); + } else { + sb.append(this.initialState); + } + first = false; + if (!first) sb.append(", "); + sb.append("desiredState:"); + if (this.desiredState == null) { + sb.append("null"); + } else { + sb.append(this.desiredState); + } + first = false; + if (!first) sb.append(", "); + sb.append("settings:"); + if (this.settings == null) { + sb.append("null"); + } else { + sb.append(this.settings); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + // check for sub-struct validity + if (desiredState != null) { + desiredState.validate(); + } + if (settings != null) { + settings.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 { + 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 JobUpdateInstructionsStandardSchemeFactory implements SchemeFactory { + public JobUpdateInstructionsStandardScheme getScheme() { + return new JobUpdateInstructionsStandardScheme(); + } + } + + private static class JobUpdateInstructionsStandardScheme extends StandardScheme<JobUpdateInstructions> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, JobUpdateInstructions 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: // INITIAL_STATE + if (schemeField.type == org.apache.thrift.protocol.TType.SET) { + { + org.apache.thrift.protocol.TSet _set214 = iprot.readSetBegin(); + struct.initialState = new HashSet<InstanceTaskConfig>(2*_set214.size); + InstanceTaskConfig _elem215; + for (int _i216 = 0; _i216 < _set214.size; ++_i216) + { + _elem215 = new InstanceTaskConfig(); + _elem215.read(iprot); + struct.initialState.add(_elem215); + } + iprot.readSetEnd(); + } + struct.setInitialStateIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // DESIRED_STATE + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.desiredState = new InstanceTaskConfig(); + struct.desiredState.read(iprot); + struct.setDesiredStateIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // SETTINGS + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.settings = new JobUpdateSettings(); + struct.settings.read(iprot); + struct.setSettingsIsSet(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(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, JobUpdateInstructions struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.initialState != null) { + oprot.writeFieldBegin(INITIAL_STATE_FIELD_DESC); + { + oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, struct.initialState.size())); + for (InstanceTaskConfig _iter217 : struct.initialState) + { + _iter217.write(oprot); + } + oprot.writeSetEnd(); + } + oprot.writeFieldEnd(); + } + if (struct.desiredState != null) { + oprot.writeFieldBegin(DESIRED_STATE_FIELD_DESC); + struct.desiredState.write(oprot); + oprot.writeFieldEnd(); + } + if (struct.settings != null) { + oprot.writeFieldBegin(SETTINGS_FIELD_DESC); + struct.settings.write(oprot); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class JobUpdateInstructionsTupleSchemeFactory implements SchemeFactory { + public JobUpdateInstructionsTupleScheme getScheme() { + return new JobUpdateInstructionsTupleScheme(); + } + } + + private static class JobUpdateInstructionsTupleScheme extends TupleScheme<JobUpdateInstructions> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, JobUpdateInstructions struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetInitialState()) { + optionals.set(0); + } + if (struct.isSetDesiredState()) { + optionals.set(1); + } + if (struct.isSetSettings()) { + optionals.set(2); + } + oprot.writeBitSet(optionals, 3); + if (struct.isSetInitialState()) { + { + oprot.writeI32(struct.initialState.size()); + for (InstanceTaskConfig _iter218 : struct.initialState) + { + _iter218.write(oprot); + } + } + } + if (struct.isSetDesiredState()) { + struct.desiredState.write(oprot); + } + if (struct.isSetSettings()) { + struct.settings.write(oprot); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, JobUpdateInstructions struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(3); + if (incoming.get(0)) { + { + org.apache.thrift.protocol.TSet _set219 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.initialState = new HashSet<InstanceTaskConfig>(2*_set219.size); + InstanceTaskConfig _elem220; + for (int _i221 = 0; _i221 < _set219.size; ++_i221) + { + _elem220 = new InstanceTaskConfig(); + _elem220.read(iprot); + struct.initialState.add(_elem220); + } + } + struct.setInitialStateIsSet(true); + } + if (incoming.get(1)) { + struct.desiredState = new InstanceTaskConfig(); + struct.desiredState.read(iprot); + struct.setDesiredStateIsSet(true); + } + if (incoming.get(2)) { + struct.settings = new JobUpdateSettings(); + struct.settings.read(iprot); + struct.setSettingsIsSet(true); + } + } + } + +} +
http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateKey.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateKey.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateKey.java new file mode 100644 index 0000000..db0b9cb --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateKey.java @@ -0,0 +1,535 @@ +/** + * 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.airavata.cloud.aurora.client.sdk; + +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"}) +/** + * Job update key. + */ +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-10-21") +public class JobUpdateKey implements org.apache.thrift.TBase<JobUpdateKey, JobUpdateKey._Fields>, java.io.Serializable, Cloneable, Comparable<JobUpdateKey> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("JobUpdateKey"); + + private static final org.apache.thrift.protocol.TField JOB_FIELD_DESC = new org.apache.thrift.protocol.TField("job", org.apache.thrift.protocol.TType.STRUCT, (short)1); + private static final org.apache.thrift.protocol.TField ID_FIELD_DESC = new org.apache.thrift.protocol.TField("id", org.apache.thrift.protocol.TType.STRING, (short)2); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new JobUpdateKeyStandardSchemeFactory()); + schemes.put(TupleScheme.class, new JobUpdateKeyTupleSchemeFactory()); + } + + /** + * Job being updated + */ + public JobKey job; // required + /** + * Update ID. + */ + public String id; // 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 { + /** + * Job being updated + */ + JOB((short)1, "job"), + /** + * Update ID. + */ + ID((short)2, "id"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // JOB + return JOB; + case 2: // ID + return ID; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + 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.JOB, new org.apache.thrift.meta_data.FieldMetaData("job", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, JobKey.class))); + tmpMap.put(_Fields.ID, new org.apache.thrift.meta_data.FieldMetaData("id", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(JobUpdateKey.class, metaDataMap); + } + + public JobUpdateKey() { + } + + public JobUpdateKey( + JobKey job, + String id) + { + this(); + this.job = job; + this.id = id; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public JobUpdateKey(JobUpdateKey other) { + if (other.isSetJob()) { + this.job = new JobKey(other.job); + } + if (other.isSetId()) { + this.id = other.id; + } + } + + public JobUpdateKey deepCopy() { + return new JobUpdateKey(this); + } + + @Override + public void clear() { + this.job = null; + this.id = null; + } + + /** + * Job being updated + */ + public JobKey getJob() { + return this.job; + } + + /** + * Job being updated + */ + public JobUpdateKey setJob(JobKey job) { + this.job = job; + return this; + } + + public void unsetJob() { + this.job = null; + } + + /** Returns true if field job is set (has been assigned a value) and false otherwise */ + public boolean isSetJob() { + return this.job != null; + } + + public void setJobIsSet(boolean value) { + if (!value) { + this.job = null; + } + } + + /** + * Update ID. + */ + public String getId() { + return this.id; + } + + /** + * Update ID. + */ + public JobUpdateKey setId(String id) { + this.id = id; + return this; + } + + public void unsetId() { + this.id = null; + } + + /** Returns true if field id is set (has been assigned a value) and false otherwise */ + public boolean isSetId() { + return this.id != null; + } + + public void setIdIsSet(boolean value) { + if (!value) { + this.id = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case JOB: + if (value == null) { + unsetJob(); + } else { + setJob((JobKey)value); + } + break; + + case ID: + if (value == null) { + unsetId(); + } else { + setId((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case JOB: + return getJob(); + + case ID: + return getId(); + + } + 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 JOB: + return isSetJob(); + case ID: + return isSetId(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof JobUpdateKey) + return this.equals((JobUpdateKey)that); + return false; + } + + public boolean equals(JobUpdateKey that) { + if (that == null) + return false; + + boolean this_present_job = true && this.isSetJob(); + boolean that_present_job = true && that.isSetJob(); + if (this_present_job || that_present_job) { + if (!(this_present_job && that_present_job)) + return false; + if (!this.job.equals(that.job)) + return false; + } + + boolean this_present_id = true && this.isSetId(); + boolean that_present_id = true && that.isSetId(); + if (this_present_id || that_present_id) { + if (!(this_present_id && that_present_id)) + return false; + if (!this.id.equals(that.id)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_job = true && (isSetJob()); + list.add(present_job); + if (present_job) + list.add(job); + + boolean present_id = true && (isSetId()); + list.add(present_id); + if (present_id) + list.add(id); + + return list.hashCode(); + } + + @Override + public int compareTo(JobUpdateKey other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetJob()).compareTo(other.isSetJob()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetJob()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.job, other.job); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetId()).compareTo(other.isSetId()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetId()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.id, other.id); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("JobUpdateKey("); + boolean first = true; + + sb.append("job:"); + if (this.job == null) { + sb.append("null"); + } else { + sb.append(this.job); + } + first = false; + if (!first) sb.append(", "); + sb.append("id:"); + if (this.id == null) { + sb.append("null"); + } else { + sb.append(this.id); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + // check for sub-struct validity + if (job != null) { + job.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 { + 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 JobUpdateKeyStandardSchemeFactory implements SchemeFactory { + public JobUpdateKeyStandardScheme getScheme() { + return new JobUpdateKeyStandardScheme(); + } + } + + private static class JobUpdateKeyStandardScheme extends StandardScheme<JobUpdateKey> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, JobUpdateKey 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: // JOB + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.job = new JobKey(); + struct.job.read(iprot); + struct.setJobIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // ID + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.id = iprot.readString(); + struct.setIdIsSet(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(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, JobUpdateKey struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.job != null) { + oprot.writeFieldBegin(JOB_FIELD_DESC); + struct.job.write(oprot); + oprot.writeFieldEnd(); + } + if (struct.id != null) { + oprot.writeFieldBegin(ID_FIELD_DESC); + oprot.writeString(struct.id); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class JobUpdateKeyTupleSchemeFactory implements SchemeFactory { + public JobUpdateKeyTupleScheme getScheme() { + return new JobUpdateKeyTupleScheme(); + } + } + + private static class JobUpdateKeyTupleScheme extends TupleScheme<JobUpdateKey> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, JobUpdateKey struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetJob()) { + optionals.set(0); + } + if (struct.isSetId()) { + optionals.set(1); + } + oprot.writeBitSet(optionals, 2); + if (struct.isSetJob()) { + struct.job.write(oprot); + } + if (struct.isSetId()) { + oprot.writeString(struct.id); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, JobUpdateKey struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(2); + if (incoming.get(0)) { + struct.job = new JobKey(); + struct.job.read(iprot); + struct.setJobIsSet(true); + } + if (incoming.get(1)) { + struct.id = iprot.readString(); + struct.setIdIsSet(true); + } + } + } + +} + http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdatePulseStatus.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdatePulseStatus.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdatePulseStatus.java new file mode 100644 index 0000000..5311bcf --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdatePulseStatus.java @@ -0,0 +1,55 @@ +/** + * 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.airavata.cloud.aurora.client.sdk; + + +import java.util.Map; +import java.util.HashMap; +import org.apache.thrift.TEnum; + +/** + * Status of the coordinated update. Intended as a response to pulseJobUpdate RPC. + */ +public enum JobUpdatePulseStatus implements org.apache.thrift.TEnum { + /** + * Update is active. See ACTIVE_JOB_UPDATE_STATES for statuses considered active. + */ + OK(1), + /** + * Update has reached terminal state. See TERMINAL_JOB_UPDATE_STATES for statuses + * considered terminal. + */ + FINISHED(2); + + private final int value; + + private JobUpdatePulseStatus(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 JobUpdatePulseStatus findByValue(int value) { + switch (value) { + case 1: + return OK; + case 2: + return FINISHED; + default: + return null; + } + } +} http://git-wip-us.apache.org/repos/asf/airavata/blob/0f781b2e/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateQuery.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateQuery.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateQuery.java new file mode 100644 index 0000000..379f109 --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/JobUpdateQuery.java @@ -0,0 +1,1170 @@ +/** + * 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.airavata.cloud.aurora.client.sdk; + +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"}) +/** + * Contains a set of restrictions on matching job updates where all restrictions must be met + * (terms are AND'ed together). + */ +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-10-21") +public class JobUpdateQuery implements org.apache.thrift.TBase<JobUpdateQuery, JobUpdateQuery._Fields>, java.io.Serializable, Cloneable, Comparable<JobUpdateQuery> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("JobUpdateQuery"); + + private static final org.apache.thrift.protocol.TField ROLE_FIELD_DESC = new org.apache.thrift.protocol.TField("role", org.apache.thrift.protocol.TType.STRING, (short)2); + private static final org.apache.thrift.protocol.TField KEY_FIELD_DESC = new org.apache.thrift.protocol.TField("key", org.apache.thrift.protocol.TType.STRUCT, (short)8); + private static final org.apache.thrift.protocol.TField JOB_KEY_FIELD_DESC = new org.apache.thrift.protocol.TField("jobKey", org.apache.thrift.protocol.TType.STRUCT, (short)3); + private static final org.apache.thrift.protocol.TField USER_FIELD_DESC = new org.apache.thrift.protocol.TField("user", org.apache.thrift.protocol.TType.STRING, (short)4); + private static final org.apache.thrift.protocol.TField UPDATE_STATUSES_FIELD_DESC = new org.apache.thrift.protocol.TField("updateStatuses", org.apache.thrift.protocol.TType.SET, (short)5); + private static final org.apache.thrift.protocol.TField OFFSET_FIELD_DESC = new org.apache.thrift.protocol.TField("offset", org.apache.thrift.protocol.TType.I32, (short)6); + private static final org.apache.thrift.protocol.TField LIMIT_FIELD_DESC = new org.apache.thrift.protocol.TField("limit", org.apache.thrift.protocol.TType.I32, (short)7); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new JobUpdateQueryStandardSchemeFactory()); + schemes.put(TupleScheme.class, new JobUpdateQueryTupleSchemeFactory()); + } + + /** + * Job role. + */ + public String role; // required + /** + * Unique identifier for a job update. + */ + public JobUpdateKey key; // required + /** + * Job key. + */ + public JobKey jobKey; // required + /** + * User who created the update. + */ + public String user; // required + /** + * Set of update statuses. + */ + public Set<JobUpdateStatus> updateStatuses; // required + /** + * Offset to serve data from. Used by pagination. + */ + public int offset; // required + /** + * Number or records to serve. Used by pagination. + */ + public int limit; // 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 { + /** + * Job role. + */ + ROLE((short)2, "role"), + /** + * Unique identifier for a job update. + */ + KEY((short)8, "key"), + /** + * Job key. + */ + JOB_KEY((short)3, "jobKey"), + /** + * User who created the update. + */ + USER((short)4, "user"), + /** + * Set of update statuses. + */ + UPDATE_STATUSES((short)5, "updateStatuses"), + /** + * Offset to serve data from. Used by pagination. + */ + OFFSET((short)6, "offset"), + /** + * Number or records to serve. Used by pagination. + */ + LIMIT((short)7, "limit"); + + 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 2: // ROLE + return ROLE; + case 8: // KEY + return KEY; + case 3: // JOB_KEY + return JOB_KEY; + case 4: // USER + return USER; + case 5: // UPDATE_STATUSES + return UPDATE_STATUSES; + case 6: // OFFSET + return OFFSET; + case 7: // LIMIT + return LIMIT; + 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 __OFFSET_ISSET_ID = 0; + private static final int __LIMIT_ISSET_ID = 1; + 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.ROLE, new org.apache.thrift.meta_data.FieldMetaData("role", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.KEY, new org.apache.thrift.meta_data.FieldMetaData("key", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, JobUpdateKey.class))); + tmpMap.put(_Fields.JOB_KEY, new org.apache.thrift.meta_data.FieldMetaData("jobKey", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, JobKey.class))); + tmpMap.put(_Fields.USER, new org.apache.thrift.meta_data.FieldMetaData("user", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.UPDATE_STATUSES, new org.apache.thrift.meta_data.FieldMetaData("updateStatuses", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.SetMetaData(org.apache.thrift.protocol.TType.SET, + new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, JobUpdateStatus.class)))); + tmpMap.put(_Fields.OFFSET, new org.apache.thrift.meta_data.FieldMetaData("offset", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); + tmpMap.put(_Fields.LIMIT, new org.apache.thrift.meta_data.FieldMetaData("limit", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(JobUpdateQuery.class, metaDataMap); + } + + public JobUpdateQuery() { + } + + public JobUpdateQuery( + String role, + JobUpdateKey key, + JobKey jobKey, + String user, + Set<JobUpdateStatus> updateStatuses, + int offset, + int limit) + { + this(); + this.role = role; + this.key = key; + this.jobKey = jobKey; + this.user = user; + this.updateStatuses = updateStatuses; + this.offset = offset; + setOffsetIsSet(true); + this.limit = limit; + setLimitIsSet(true); + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public JobUpdateQuery(JobUpdateQuery other) { + __isset_bitfield = other.__isset_bitfield; + if (other.isSetRole()) { + this.role = other.role; + } + if (other.isSetKey()) { + this.key = new JobUpdateKey(other.key); + } + if (other.isSetJobKey()) { + this.jobKey = new JobKey(other.jobKey); + } + if (other.isSetUser()) { + this.user = other.user; + } + if (other.isSetUpdateStatuses()) { + Set<JobUpdateStatus> __this__updateStatuses = new HashSet<JobUpdateStatus>(other.updateStatuses.size()); + for (JobUpdateStatus other_element : other.updateStatuses) { + __this__updateStatuses.add(other_element); + } + this.updateStatuses = __this__updateStatuses; + } + this.offset = other.offset; + this.limit = other.limit; + } + + public JobUpdateQuery deepCopy() { + return new JobUpdateQuery(this); + } + + @Override + public void clear() { + this.role = null; + this.key = null; + this.jobKey = null; + this.user = null; + this.updateStatuses = null; + setOffsetIsSet(false); + this.offset = 0; + setLimitIsSet(false); + this.limit = 0; + } + + /** + * Job role. + */ + public String getRole() { + return this.role; + } + + /** + * Job role. + */ + public JobUpdateQuery setRole(String role) { + this.role = role; + return this; + } + + public void unsetRole() { + this.role = null; + } + + /** Returns true if field role is set (has been assigned a value) and false otherwise */ + public boolean isSetRole() { + return this.role != null; + } + + public void setRoleIsSet(boolean value) { + if (!value) { + this.role = null; + } + } + + /** + * Unique identifier for a job update. + */ + public JobUpdateKey getKey() { + return this.key; + } + + /** + * Unique identifier for a job update. + */ + public JobUpdateQuery setKey(JobUpdateKey key) { + this.key = key; + return this; + } + + public void unsetKey() { + this.key = null; + } + + /** Returns true if field key is set (has been assigned a value) and false otherwise */ + public boolean isSetKey() { + return this.key != null; + } + + public void setKeyIsSet(boolean value) { + if (!value) { + this.key = null; + } + } + + /** + * Job key. + */ + public JobKey getJobKey() { + return this.jobKey; + } + + /** + * Job key. + */ + public JobUpdateQuery setJobKey(JobKey jobKey) { + this.jobKey = jobKey; + return this; + } + + public void unsetJobKey() { + this.jobKey = null; + } + + /** Returns true if field jobKey is set (has been assigned a value) and false otherwise */ + public boolean isSetJobKey() { + return this.jobKey != null; + } + + public void setJobKeyIsSet(boolean value) { + if (!value) { + this.jobKey = null; + } + } + + /** + * User who created the update. + */ + public String getUser() { + return this.user; + } + + /** + * User who created the update. + */ + public JobUpdateQuery setUser(String user) { + this.user = user; + return this; + } + + public void unsetUser() { + this.user = null; + } + + /** Returns true if field user is set (has been assigned a value) and false otherwise */ + public boolean isSetUser() { + return this.user != null; + } + + public void setUserIsSet(boolean value) { + if (!value) { + this.user = null; + } + } + + public int getUpdateStatusesSize() { + return (this.updateStatuses == null) ? 0 : this.updateStatuses.size(); + } + + public java.util.Iterator<JobUpdateStatus> getUpdateStatusesIterator() { + return (this.updateStatuses == null) ? null : this.updateStatuses.iterator(); + } + + public void addToUpdateStatuses(JobUpdateStatus elem) { + if (this.updateStatuses == null) { + this.updateStatuses = new HashSet<JobUpdateStatus>(); + } + this.updateStatuses.add(elem); + } + + /** + * Set of update statuses. + */ + public Set<JobUpdateStatus> getUpdateStatuses() { + return this.updateStatuses; + } + + /** + * Set of update statuses. + */ + public JobUpdateQuery setUpdateStatuses(Set<JobUpdateStatus> updateStatuses) { + this.updateStatuses = updateStatuses; + return this; + } + + public void unsetUpdateStatuses() { + this.updateStatuses = null; + } + + /** Returns true if field updateStatuses is set (has been assigned a value) and false otherwise */ + public boolean isSetUpdateStatuses() { + return this.updateStatuses != null; + } + + public void setUpdateStatusesIsSet(boolean value) { + if (!value) { + this.updateStatuses = null; + } + } + + /** + * Offset to serve data from. Used by pagination. + */ + public int getOffset() { + return this.offset; + } + + /** + * Offset to serve data from. Used by pagination. + */ + public JobUpdateQuery setOffset(int offset) { + this.offset = offset; + setOffsetIsSet(true); + return this; + } + + public void unsetOffset() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __OFFSET_ISSET_ID); + } + + /** Returns true if field offset is set (has been assigned a value) and false otherwise */ + public boolean isSetOffset() { + return EncodingUtils.testBit(__isset_bitfield, __OFFSET_ISSET_ID); + } + + public void setOffsetIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __OFFSET_ISSET_ID, value); + } + + /** + * Number or records to serve. Used by pagination. + */ + public int getLimit() { + return this.limit; + } + + /** + * Number or records to serve. Used by pagination. + */ + public JobUpdateQuery setLimit(int limit) { + this.limit = limit; + setLimitIsSet(true); + return this; + } + + public void unsetLimit() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __LIMIT_ISSET_ID); + } + + /** Returns true if field limit is set (has been assigned a value) and false otherwise */ + public boolean isSetLimit() { + return EncodingUtils.testBit(__isset_bitfield, __LIMIT_ISSET_ID); + } + + public void setLimitIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __LIMIT_ISSET_ID, value); + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case ROLE: + if (value == null) { + unsetRole(); + } else { + setRole((String)value); + } + break; + + case KEY: + if (value == null) { + unsetKey(); + } else { + setKey((JobUpdateKey)value); + } + break; + + case JOB_KEY: + if (value == null) { + unsetJobKey(); + } else { + setJobKey((JobKey)value); + } + break; + + case USER: + if (value == null) { + unsetUser(); + } else { + setUser((String)value); + } + break; + + case UPDATE_STATUSES: + if (value == null) { + unsetUpdateStatuses(); + } else { + setUpdateStatuses((Set<JobUpdateStatus>)value); + } + break; + + case OFFSET: + if (value == null) { + unsetOffset(); + } else { + setOffset((Integer)value); + } + break; + + case LIMIT: + if (value == null) { + unsetLimit(); + } else { + setLimit((Integer)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case ROLE: + return getRole(); + + case KEY: + return getKey(); + + case JOB_KEY: + return getJobKey(); + + case USER: + return getUser(); + + case UPDATE_STATUSES: + return getUpdateStatuses(); + + case OFFSET: + return getOffset(); + + case LIMIT: + return getLimit(); + + } + 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 ROLE: + return isSetRole(); + case KEY: + return isSetKey(); + case JOB_KEY: + return isSetJobKey(); + case USER: + return isSetUser(); + case UPDATE_STATUSES: + return isSetUpdateStatuses(); + case OFFSET: + return isSetOffset(); + case LIMIT: + return isSetLimit(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof JobUpdateQuery) + return this.equals((JobUpdateQuery)that); + return false; + } + + public boolean equals(JobUpdateQuery that) { + if (that == null) + return false; + + boolean this_present_role = true && this.isSetRole(); + boolean that_present_role = true && that.isSetRole(); + if (this_present_role || that_present_role) { + if (!(this_present_role && that_present_role)) + return false; + if (!this.role.equals(that.role)) + return false; + } + + boolean this_present_key = true && this.isSetKey(); + boolean that_present_key = true && that.isSetKey(); + if (this_present_key || that_present_key) { + if (!(this_present_key && that_present_key)) + return false; + if (!this.key.equals(that.key)) + return false; + } + + boolean this_present_jobKey = true && this.isSetJobKey(); + boolean that_present_jobKey = true && that.isSetJobKey(); + if (this_present_jobKey || that_present_jobKey) { + if (!(this_present_jobKey && that_present_jobKey)) + return false; + if (!this.jobKey.equals(that.jobKey)) + return false; + } + + boolean this_present_user = true && this.isSetUser(); + boolean that_present_user = true && that.isSetUser(); + if (this_present_user || that_present_user) { + if (!(this_present_user && that_present_user)) + return false; + if (!this.user.equals(that.user)) + return false; + } + + boolean this_present_updateStatuses = true && this.isSetUpdateStatuses(); + boolean that_present_updateStatuses = true && that.isSetUpdateStatuses(); + if (this_present_updateStatuses || that_present_updateStatuses) { + if (!(this_present_updateStatuses && that_present_updateStatuses)) + return false; + if (!this.updateStatuses.equals(that.updateStatuses)) + return false; + } + + boolean this_present_offset = true; + boolean that_present_offset = true; + if (this_present_offset || that_present_offset) { + if (!(this_present_offset && that_present_offset)) + return false; + if (this.offset != that.offset) + return false; + } + + boolean this_present_limit = true; + boolean that_present_limit = true; + if (this_present_limit || that_present_limit) { + if (!(this_present_limit && that_present_limit)) + return false; + if (this.limit != that.limit) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_role = true && (isSetRole()); + list.add(present_role); + if (present_role) + list.add(role); + + boolean present_key = true && (isSetKey()); + list.add(present_key); + if (present_key) + list.add(key); + + boolean present_jobKey = true && (isSetJobKey()); + list.add(present_jobKey); + if (present_jobKey) + list.add(jobKey); + + boolean present_user = true && (isSetUser()); + list.add(present_user); + if (present_user) + list.add(user); + + boolean present_updateStatuses = true && (isSetUpdateStatuses()); + list.add(present_updateStatuses); + if (present_updateStatuses) + list.add(updateStatuses); + + boolean present_offset = true; + list.add(present_offset); + if (present_offset) + list.add(offset); + + boolean present_limit = true; + list.add(present_limit); + if (present_limit) + list.add(limit); + + return list.hashCode(); + } + + @Override + public int compareTo(JobUpdateQuery other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetRole()).compareTo(other.isSetRole()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetRole()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.role, other.role); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetKey()).compareTo(other.isSetKey()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetKey()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.key, other.key); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetJobKey()).compareTo(other.isSetJobKey()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetJobKey()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.jobKey, other.jobKey); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetUser()).compareTo(other.isSetUser()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetUser()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.user, other.user); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetUpdateStatuses()).compareTo(other.isSetUpdateStatuses()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetUpdateStatuses()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.updateStatuses, other.updateStatuses); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetOffset()).compareTo(other.isSetOffset()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetOffset()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.offset, other.offset); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetLimit()).compareTo(other.isSetLimit()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetLimit()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.limit, other.limit); + 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("JobUpdateQuery("); + boolean first = true; + + sb.append("role:"); + if (this.role == null) { + sb.append("null"); + } else { + sb.append(this.role); + } + first = false; + if (!first) sb.append(", "); + sb.append("key:"); + if (this.key == null) { + sb.append("null"); + } else { + sb.append(this.key); + } + first = false; + if (!first) sb.append(", "); + sb.append("jobKey:"); + if (this.jobKey == null) { + sb.append("null"); + } else { + sb.append(this.jobKey); + } + first = false; + if (!first) sb.append(", "); + sb.append("user:"); + if (this.user == null) { + sb.append("null"); + } else { + sb.append(this.user); + } + first = false; + if (!first) sb.append(", "); + sb.append("updateStatuses:"); + if (this.updateStatuses == null) { + sb.append("null"); + } else { + sb.append(this.updateStatuses); + } + first = false; + if (!first) sb.append(", "); + sb.append("offset:"); + sb.append(this.offset); + first = false; + if (!first) sb.append(", "); + sb.append("limit:"); + sb.append(this.limit); + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + // check for sub-struct validity + if (key != null) { + key.validate(); + } + if (jobKey != null) { + jobKey.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 JobUpdateQueryStandardSchemeFactory implements SchemeFactory { + public JobUpdateQueryStandardScheme getScheme() { + return new JobUpdateQueryStandardScheme(); + } + } + + private static class JobUpdateQueryStandardScheme extends StandardScheme<JobUpdateQuery> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, JobUpdateQuery 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 2: // ROLE + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.role = iprot.readString(); + struct.setRoleIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 8: // KEY + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.key = new JobUpdateKey(); + struct.key.read(iprot); + struct.setKeyIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // JOB_KEY + if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { + struct.jobKey = new JobKey(); + struct.jobKey.read(iprot); + struct.setJobKeyIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 4: // USER + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.user = iprot.readString(); + struct.setUserIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 5: // UPDATE_STATUSES + if (schemeField.type == org.apache.thrift.protocol.TType.SET) { + { + org.apache.thrift.protocol.TSet _set246 = iprot.readSetBegin(); + struct.updateStatuses = new HashSet<JobUpdateStatus>(2*_set246.size); + JobUpdateStatus _elem247; + for (int _i248 = 0; _i248 < _set246.size; ++_i248) + { + _elem247 = org.apache.airavata.cloud.aurora.client.sdk.JobUpdateStatus.findByValue(iprot.readI32()); + struct.updateStatuses.add(_elem247); + } + iprot.readSetEnd(); + } + struct.setUpdateStatusesIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 6: // OFFSET + if (schemeField.type == org.apache.thrift.protocol.TType.I32) { + struct.offset = iprot.readI32(); + struct.setOffsetIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 7: // LIMIT + if (schemeField.type == org.apache.thrift.protocol.TType.I32) { + struct.limit = iprot.readI32(); + struct.setLimitIsSet(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(); + + // check for required fields of primitive type, which can't be checked in the validate method + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, JobUpdateQuery struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.role != null) { + oprot.writeFieldBegin(ROLE_FIELD_DESC); + oprot.writeString(struct.role); + oprot.writeFieldEnd(); + } + if (struct.jobKey != null) { + oprot.writeFieldBegin(JOB_KEY_FIELD_DESC); + struct.jobKey.write(oprot); + oprot.writeFieldEnd(); + } + if (struct.user != null) { + oprot.writeFieldBegin(USER_FIELD_DESC); + oprot.writeString(struct.user); + oprot.writeFieldEnd(); + } + if (struct.updateStatuses != null) { + oprot.writeFieldBegin(UPDATE_STATUSES_FIELD_DESC); + { + oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, struct.updateStatuses.size())); + for (JobUpdateStatus _iter249 : struct.updateStatuses) + { + oprot.writeI32(_iter249.getValue()); + } + oprot.writeSetEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldBegin(OFFSET_FIELD_DESC); + oprot.writeI32(struct.offset); + oprot.writeFieldEnd(); + oprot.writeFieldBegin(LIMIT_FIELD_DESC); + oprot.writeI32(struct.limit); + oprot.writeFieldEnd(); + if (struct.key != null) { + oprot.writeFieldBegin(KEY_FIELD_DESC); + struct.key.write(oprot); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class JobUpdateQueryTupleSchemeFactory implements SchemeFactory { + public JobUpdateQueryTupleScheme getScheme() { + return new JobUpdateQueryTupleScheme(); + } + } + + private static class JobUpdateQueryTupleScheme extends TupleScheme<JobUpdateQuery> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, JobUpdateQuery struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetRole()) { + optionals.set(0); + } + if (struct.isSetKey()) { + optionals.set(1); + } + if (struct.isSetJobKey()) { + optionals.set(2); + } + if (struct.isSetUser()) { + optionals.set(3); + } + if (struct.isSetUpdateStatuses()) { + optionals.set(4); + } + if (struct.isSetOffset()) { + optionals.set(5); + } + if (struct.isSetLimit()) { + optionals.set(6); + } + oprot.writeBitSet(optionals, 7); + if (struct.isSetRole()) { + oprot.writeString(struct.role); + } + if (struct.isSetKey()) { + struct.key.write(oprot); + } + if (struct.isSetJobKey()) { + struct.jobKey.write(oprot); + } + if (struct.isSetUser()) { + oprot.writeString(struct.user); + } + if (struct.isSetUpdateStatuses()) { + { + oprot.writeI32(struct.updateStatuses.size()); + for (JobUpdateStatus _iter250 : struct.updateStatuses) + { + oprot.writeI32(_iter250.getValue()); + } + } + } + if (struct.isSetOffset()) { + oprot.writeI32(struct.offset); + } + if (struct.isSetLimit()) { + oprot.writeI32(struct.limit); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, JobUpdateQuery struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(7); + if (incoming.get(0)) { + struct.role = iprot.readString(); + struct.setRoleIsSet(true); + } + if (incoming.get(1)) { + struct.key = new JobUpdateKey(); + struct.key.read(iprot); + struct.setKeyIsSet(true); + } + if (incoming.get(2)) { + struct.jobKey = new JobKey(); + struct.jobKey.read(iprot); + struct.setJobKeyIsSet(true); + } + if (incoming.get(3)) { + struct.user = iprot.readString(); + struct.setUserIsSet(true); + } + if (incoming.get(4)) { + { + org.apache.thrift.protocol.TSet _set251 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32()); + struct.updateStatuses = new HashSet<JobUpdateStatus>(2*_set251.size); + JobUpdateStatus _elem252; + for (int _i253 = 0; _i253 < _set251.size; ++_i253) + { + _elem252 = org.apache.airavata.cloud.aurora.client.sdk.JobUpdateStatus.findByValue(iprot.readI32()); + struct.updateStatuses.add(_elem252); + } + } + struct.setUpdateStatusesIsSet(true); + } + if (incoming.get(5)) { + struct.offset = iprot.readI32(); + struct.setOffsetIsSet(true); + } + if (incoming.get(6)) { + struct.limit = iprot.readI32(); + struct.setLimitIsSet(true); + } + } + } + +} +
