Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 20185200BBE for ; Thu, 27 Oct 2016 23:31:59 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 1ED25160B0D; Thu, 27 Oct 2016 21:31:59 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id E3A96160B10 for ; Thu, 27 Oct 2016 23:31:56 +0200 (CEST) Received: (qmail 19851 invoked by uid 500); 27 Oct 2016 21:31:55 -0000 Mailing-List: contact commits-help@airavata.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airavata.apache.org Delivered-To: mailing list commits@airavata.apache.org Received: (qmail 19308 invoked by uid 99); 27 Oct 2016 21:31:55 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 27 Oct 2016 21:31:55 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 6A1F4F0BF2; Thu, 27 Oct 2016 21:31:55 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: shameera@apache.org To: commits@airavata.apache.org Date: Thu, 27 Oct 2016 21:32:09 -0000 Message-Id: In-Reply-To: <2feb4e6ff2a54e1c9cbf9fae7814a2cf@git.apache.org> References: <2feb4e6ff2a54e1c9cbf9fae7814a2cf@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [16/53] airavata git commit: Adding aurora-client project archived-at: Thu, 27 Oct 2016 21:31:59 -0000 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/TaskQuery.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery.java new file mode 100644 index 0000000..18e9a9c --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery.java @@ -0,0 +1,1592 @@ +/** + * 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 tasks 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 TaskQuery implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TaskQuery"); + + 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)14); + private static final org.apache.thrift.protocol.TField ENVIRONMENT_FIELD_DESC = new org.apache.thrift.protocol.TField("environment", org.apache.thrift.protocol.TType.STRING, (short)9); + private static final org.apache.thrift.protocol.TField JOB_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("jobName", org.apache.thrift.protocol.TType.STRING, (short)2); + private static final org.apache.thrift.protocol.TField TASK_IDS_FIELD_DESC = new org.apache.thrift.protocol.TField("taskIds", org.apache.thrift.protocol.TType.SET, (short)4); + private static final org.apache.thrift.protocol.TField STATUSES_FIELD_DESC = new org.apache.thrift.protocol.TField("statuses", org.apache.thrift.protocol.TType.SET, (short)5); + private static final org.apache.thrift.protocol.TField INSTANCE_IDS_FIELD_DESC = new org.apache.thrift.protocol.TField("instanceIds", org.apache.thrift.protocol.TType.SET, (short)7); + private static final org.apache.thrift.protocol.TField SLAVE_HOSTS_FIELD_DESC = new org.apache.thrift.protocol.TField("slaveHosts", org.apache.thrift.protocol.TType.SET, (short)10); + private static final org.apache.thrift.protocol.TField JOB_KEYS_FIELD_DESC = new org.apache.thrift.protocol.TField("jobKeys", org.apache.thrift.protocol.TType.SET, (short)11); + 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)12); + 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)13); + + private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new TaskQueryStandardSchemeFactory()); + schemes.put(TupleScheme.class, new TaskQueryTupleSchemeFactory()); + } + + public String role; // required + public String environment; // required + public String jobName; // required + public Set taskIds; // required + public Set statuses; // required + public Set instanceIds; // required + public Set slaveHosts; // required + public Set jobKeys; // required + public int offset; // required + 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 { + ROLE((short)14, "role"), + ENVIRONMENT((short)9, "environment"), + JOB_NAME((short)2, "jobName"), + TASK_IDS((short)4, "taskIds"), + STATUSES((short)5, "statuses"), + INSTANCE_IDS((short)7, "instanceIds"), + SLAVE_HOSTS((short)10, "slaveHosts"), + JOB_KEYS((short)11, "jobKeys"), + OFFSET((short)12, "offset"), + LIMIT((short)13, "limit"); + + private static final Map byName = new HashMap(); + + 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 14: // ROLE + return ROLE; + case 9: // ENVIRONMENT + return ENVIRONMENT; + case 2: // JOB_NAME + return JOB_NAME; + case 4: // TASK_IDS + return TASK_IDS; + case 5: // STATUSES + return STATUSES; + case 7: // INSTANCE_IDS + return INSTANCE_IDS; + case 10: // SLAVE_HOSTS + return SLAVE_HOSTS; + case 11: // JOB_KEYS + return JOB_KEYS; + case 12: // OFFSET + return OFFSET; + case 13: // 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.ENVIRONMENT, new org.apache.thrift.meta_data.FieldMetaData("environment", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.JOB_NAME, new org.apache.thrift.meta_data.FieldMetaData("jobName", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.TASK_IDS, new org.apache.thrift.meta_data.FieldMetaData("taskIds", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.SetMetaData(org.apache.thrift.protocol.TType.SET, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))); + tmpMap.put(_Fields.STATUSES, new org.apache.thrift.meta_data.FieldMetaData("statuses", 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, ScheduleStatus.class)))); + tmpMap.put(_Fields.INSTANCE_IDS, new org.apache.thrift.meta_data.FieldMetaData("instanceIds", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.SetMetaData(org.apache.thrift.protocol.TType.SET, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)))); + tmpMap.put(_Fields.SLAVE_HOSTS, new org.apache.thrift.meta_data.FieldMetaData("slaveHosts", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.SetMetaData(org.apache.thrift.protocol.TType.SET, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))); + tmpMap.put(_Fields.JOB_KEYS, new org.apache.thrift.meta_data.FieldMetaData("jobKeys", 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, JobKey.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(TaskQuery.class, metaDataMap); + } + + public TaskQuery() { + } + + public TaskQuery( + String role, + String environment, + String jobName, + Set taskIds, + Set statuses, + Set instanceIds, + Set slaveHosts, + Set jobKeys, + int offset, + int limit) + { + this(); + this.role = role; + this.environment = environment; + this.jobName = jobName; + this.taskIds = taskIds; + this.statuses = statuses; + this.instanceIds = instanceIds; + this.slaveHosts = slaveHosts; + this.jobKeys = jobKeys; + this.offset = offset; + setOffsetIsSet(true); + this.limit = limit; + setLimitIsSet(true); + } + + /** + * Performs a deep copy on other. + */ + public TaskQuery(TaskQuery other) { + __isset_bitfield = other.__isset_bitfield; + if (other.isSetRole()) { + this.role = other.role; + } + if (other.isSetEnvironment()) { + this.environment = other.environment; + } + if (other.isSetJobName()) { + this.jobName = other.jobName; + } + if (other.isSetTaskIds()) { + Set __this__taskIds = new HashSet(other.taskIds); + this.taskIds = __this__taskIds; + } + if (other.isSetStatuses()) { + Set __this__statuses = new HashSet(other.statuses.size()); + for (ScheduleStatus other_element : other.statuses) { + __this__statuses.add(other_element); + } + this.statuses = __this__statuses; + } + if (other.isSetInstanceIds()) { + Set __this__instanceIds = new HashSet(other.instanceIds); + this.instanceIds = __this__instanceIds; + } + if (other.isSetSlaveHosts()) { + Set __this__slaveHosts = new HashSet(other.slaveHosts); + this.slaveHosts = __this__slaveHosts; + } + if (other.isSetJobKeys()) { + Set __this__jobKeys = new HashSet(other.jobKeys.size()); + for (JobKey other_element : other.jobKeys) { + __this__jobKeys.add(new JobKey(other_element)); + } + this.jobKeys = __this__jobKeys; + } + this.offset = other.offset; + this.limit = other.limit; + } + + public TaskQuery deepCopy() { + return new TaskQuery(this); + } + + @Override + public void clear() { + this.role = null; + this.environment = null; + this.jobName = null; + this.taskIds = null; + this.statuses = null; + this.instanceIds = null; + this.slaveHosts = null; + this.jobKeys = null; + setOffsetIsSet(false); + this.offset = 0; + setLimitIsSet(false); + this.limit = 0; + } + + public String getRole() { + return this.role; + } + + public TaskQuery 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; + } + } + + public String getEnvironment() { + return this.environment; + } + + public TaskQuery setEnvironment(String environment) { + this.environment = environment; + return this; + } + + public void unsetEnvironment() { + this.environment = null; + } + + /** Returns true if field environment is set (has been assigned a value) and false otherwise */ + public boolean isSetEnvironment() { + return this.environment != null; + } + + public void setEnvironmentIsSet(boolean value) { + if (!value) { + this.environment = null; + } + } + + public String getJobName() { + return this.jobName; + } + + public TaskQuery setJobName(String jobName) { + this.jobName = jobName; + return this; + } + + public void unsetJobName() { + this.jobName = null; + } + + /** Returns true if field jobName is set (has been assigned a value) and false otherwise */ + public boolean isSetJobName() { + return this.jobName != null; + } + + public void setJobNameIsSet(boolean value) { + if (!value) { + this.jobName = null; + } + } + + public int getTaskIdsSize() { + return (this.taskIds == null) ? 0 : this.taskIds.size(); + } + + public java.util.Iterator getTaskIdsIterator() { + return (this.taskIds == null) ? null : this.taskIds.iterator(); + } + + public void addToTaskIds(String elem) { + if (this.taskIds == null) { + this.taskIds = new HashSet(); + } + this.taskIds.add(elem); + } + + public Set getTaskIds() { + return this.taskIds; + } + + public TaskQuery setTaskIds(Set taskIds) { + this.taskIds = taskIds; + return this; + } + + public void unsetTaskIds() { + this.taskIds = null; + } + + /** Returns true if field taskIds is set (has been assigned a value) and false otherwise */ + public boolean isSetTaskIds() { + return this.taskIds != null; + } + + public void setTaskIdsIsSet(boolean value) { + if (!value) { + this.taskIds = null; + } + } + + public int getStatusesSize() { + return (this.statuses == null) ? 0 : this.statuses.size(); + } + + public java.util.Iterator getStatusesIterator() { + return (this.statuses == null) ? null : this.statuses.iterator(); + } + + public void addToStatuses(ScheduleStatus elem) { + if (this.statuses == null) { + this.statuses = new HashSet(); + } + this.statuses.add(elem); + } + + public Set getStatuses() { + return this.statuses; + } + + public TaskQuery setStatuses(Set statuses) { + this.statuses = statuses; + return this; + } + + public void unsetStatuses() { + this.statuses = null; + } + + /** Returns true if field statuses is set (has been assigned a value) and false otherwise */ + public boolean isSetStatuses() { + return this.statuses != null; + } + + public void setStatusesIsSet(boolean value) { + if (!value) { + this.statuses = null; + } + } + + public int getInstanceIdsSize() { + return (this.instanceIds == null) ? 0 : this.instanceIds.size(); + } + + public java.util.Iterator getInstanceIdsIterator() { + return (this.instanceIds == null) ? null : this.instanceIds.iterator(); + } + + public void addToInstanceIds(int elem) { + if (this.instanceIds == null) { + this.instanceIds = new HashSet(); + } + this.instanceIds.add(elem); + } + + public Set getInstanceIds() { + return this.instanceIds; + } + + public TaskQuery setInstanceIds(Set instanceIds) { + this.instanceIds = instanceIds; + return this; + } + + public void unsetInstanceIds() { + this.instanceIds = null; + } + + /** Returns true if field instanceIds is set (has been assigned a value) and false otherwise */ + public boolean isSetInstanceIds() { + return this.instanceIds != null; + } + + public void setInstanceIdsIsSet(boolean value) { + if (!value) { + this.instanceIds = null; + } + } + + public int getSlaveHostsSize() { + return (this.slaveHosts == null) ? 0 : this.slaveHosts.size(); + } + + public java.util.Iterator getSlaveHostsIterator() { + return (this.slaveHosts == null) ? null : this.slaveHosts.iterator(); + } + + public void addToSlaveHosts(String elem) { + if (this.slaveHosts == null) { + this.slaveHosts = new HashSet(); + } + this.slaveHosts.add(elem); + } + + public Set getSlaveHosts() { + return this.slaveHosts; + } + + public TaskQuery setSlaveHosts(Set slaveHosts) { + this.slaveHosts = slaveHosts; + return this; + } + + public void unsetSlaveHosts() { + this.slaveHosts = null; + } + + /** Returns true if field slaveHosts is set (has been assigned a value) and false otherwise */ + public boolean isSetSlaveHosts() { + return this.slaveHosts != null; + } + + public void setSlaveHostsIsSet(boolean value) { + if (!value) { + this.slaveHosts = null; + } + } + + public int getJobKeysSize() { + return (this.jobKeys == null) ? 0 : this.jobKeys.size(); + } + + public java.util.Iterator getJobKeysIterator() { + return (this.jobKeys == null) ? null : this.jobKeys.iterator(); + } + + public void addToJobKeys(JobKey elem) { + if (this.jobKeys == null) { + this.jobKeys = new HashSet(); + } + this.jobKeys.add(elem); + } + + public Set getJobKeys() { + return this.jobKeys; + } + + public TaskQuery setJobKeys(Set jobKeys) { + this.jobKeys = jobKeys; + return this; + } + + public void unsetJobKeys() { + this.jobKeys = null; + } + + /** Returns true if field jobKeys is set (has been assigned a value) and false otherwise */ + public boolean isSetJobKeys() { + return this.jobKeys != null; + } + + public void setJobKeysIsSet(boolean value) { + if (!value) { + this.jobKeys = null; + } + } + + public int getOffset() { + return this.offset; + } + + public TaskQuery 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); + } + + public int getLimit() { + return this.limit; + } + + public TaskQuery 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 ENVIRONMENT: + if (value == null) { + unsetEnvironment(); + } else { + setEnvironment((String)value); + } + break; + + case JOB_NAME: + if (value == null) { + unsetJobName(); + } else { + setJobName((String)value); + } + break; + + case TASK_IDS: + if (value == null) { + unsetTaskIds(); + } else { + setTaskIds((Set)value); + } + break; + + case STATUSES: + if (value == null) { + unsetStatuses(); + } else { + setStatuses((Set)value); + } + break; + + case INSTANCE_IDS: + if (value == null) { + unsetInstanceIds(); + } else { + setInstanceIds((Set)value); + } + break; + + case SLAVE_HOSTS: + if (value == null) { + unsetSlaveHosts(); + } else { + setSlaveHosts((Set)value); + } + break; + + case JOB_KEYS: + if (value == null) { + unsetJobKeys(); + } else { + setJobKeys((Set)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 ENVIRONMENT: + return getEnvironment(); + + case JOB_NAME: + return getJobName(); + + case TASK_IDS: + return getTaskIds(); + + case STATUSES: + return getStatuses(); + + case INSTANCE_IDS: + return getInstanceIds(); + + case SLAVE_HOSTS: + return getSlaveHosts(); + + case JOB_KEYS: + return getJobKeys(); + + 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 ENVIRONMENT: + return isSetEnvironment(); + case JOB_NAME: + return isSetJobName(); + case TASK_IDS: + return isSetTaskIds(); + case STATUSES: + return isSetStatuses(); + case INSTANCE_IDS: + return isSetInstanceIds(); + case SLAVE_HOSTS: + return isSetSlaveHosts(); + case JOB_KEYS: + return isSetJobKeys(); + 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 TaskQuery) + return this.equals((TaskQuery)that); + return false; + } + + public boolean equals(TaskQuery 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_environment = true && this.isSetEnvironment(); + boolean that_present_environment = true && that.isSetEnvironment(); + if (this_present_environment || that_present_environment) { + if (!(this_present_environment && that_present_environment)) + return false; + if (!this.environment.equals(that.environment)) + return false; + } + + boolean this_present_jobName = true && this.isSetJobName(); + boolean that_present_jobName = true && that.isSetJobName(); + if (this_present_jobName || that_present_jobName) { + if (!(this_present_jobName && that_present_jobName)) + return false; + if (!this.jobName.equals(that.jobName)) + return false; + } + + boolean this_present_taskIds = true && this.isSetTaskIds(); + boolean that_present_taskIds = true && that.isSetTaskIds(); + if (this_present_taskIds || that_present_taskIds) { + if (!(this_present_taskIds && that_present_taskIds)) + return false; + if (!this.taskIds.equals(that.taskIds)) + return false; + } + + boolean this_present_statuses = true && this.isSetStatuses(); + boolean that_present_statuses = true && that.isSetStatuses(); + if (this_present_statuses || that_present_statuses) { + if (!(this_present_statuses && that_present_statuses)) + return false; + if (!this.statuses.equals(that.statuses)) + return false; + } + + boolean this_present_instanceIds = true && this.isSetInstanceIds(); + boolean that_present_instanceIds = true && that.isSetInstanceIds(); + if (this_present_instanceIds || that_present_instanceIds) { + if (!(this_present_instanceIds && that_present_instanceIds)) + return false; + if (!this.instanceIds.equals(that.instanceIds)) + return false; + } + + boolean this_present_slaveHosts = true && this.isSetSlaveHosts(); + boolean that_present_slaveHosts = true && that.isSetSlaveHosts(); + if (this_present_slaveHosts || that_present_slaveHosts) { + if (!(this_present_slaveHosts && that_present_slaveHosts)) + return false; + if (!this.slaveHosts.equals(that.slaveHosts)) + return false; + } + + boolean this_present_jobKeys = true && this.isSetJobKeys(); + boolean that_present_jobKeys = true && that.isSetJobKeys(); + if (this_present_jobKeys || that_present_jobKeys) { + if (!(this_present_jobKeys && that_present_jobKeys)) + return false; + if (!this.jobKeys.equals(that.jobKeys)) + 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 list = new ArrayList(); + + boolean present_role = true && (isSetRole()); + list.add(present_role); + if (present_role) + list.add(role); + + boolean present_environment = true && (isSetEnvironment()); + list.add(present_environment); + if (present_environment) + list.add(environment); + + boolean present_jobName = true && (isSetJobName()); + list.add(present_jobName); + if (present_jobName) + list.add(jobName); + + boolean present_taskIds = true && (isSetTaskIds()); + list.add(present_taskIds); + if (present_taskIds) + list.add(taskIds); + + boolean present_statuses = true && (isSetStatuses()); + list.add(present_statuses); + if (present_statuses) + list.add(statuses); + + boolean present_instanceIds = true && (isSetInstanceIds()); + list.add(present_instanceIds); + if (present_instanceIds) + list.add(instanceIds); + + boolean present_slaveHosts = true && (isSetSlaveHosts()); + list.add(present_slaveHosts); + if (present_slaveHosts) + list.add(slaveHosts); + + boolean present_jobKeys = true && (isSetJobKeys()); + list.add(present_jobKeys); + if (present_jobKeys) + list.add(jobKeys); + + 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(TaskQuery 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(isSetEnvironment()).compareTo(other.isSetEnvironment()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetEnvironment()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.environment, other.environment); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetJobName()).compareTo(other.isSetJobName()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetJobName()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.jobName, other.jobName); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetTaskIds()).compareTo(other.isSetTaskIds()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTaskIds()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.taskIds, other.taskIds); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetStatuses()).compareTo(other.isSetStatuses()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetStatuses()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.statuses, other.statuses); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetInstanceIds()).compareTo(other.isSetInstanceIds()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetInstanceIds()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.instanceIds, other.instanceIds); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetSlaveHosts()).compareTo(other.isSetSlaveHosts()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetSlaveHosts()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.slaveHosts, other.slaveHosts); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetJobKeys()).compareTo(other.isSetJobKeys()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetJobKeys()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.jobKeys, other.jobKeys); + 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("TaskQuery("); + 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("environment:"); + if (this.environment == null) { + sb.append("null"); + } else { + sb.append(this.environment); + } + first = false; + if (!first) sb.append(", "); + sb.append("jobName:"); + if (this.jobName == null) { + sb.append("null"); + } else { + sb.append(this.jobName); + } + first = false; + if (!first) sb.append(", "); + sb.append("taskIds:"); + if (this.taskIds == null) { + sb.append("null"); + } else { + sb.append(this.taskIds); + } + first = false; + if (!first) sb.append(", "); + sb.append("statuses:"); + if (this.statuses == null) { + sb.append("null"); + } else { + sb.append(this.statuses); + } + first = false; + if (!first) sb.append(", "); + sb.append("instanceIds:"); + if (this.instanceIds == null) { + sb.append("null"); + } else { + sb.append(this.instanceIds); + } + first = false; + if (!first) sb.append(", "); + sb.append("slaveHosts:"); + if (this.slaveHosts == null) { + sb.append("null"); + } else { + sb.append(this.slaveHosts); + } + first = false; + if (!first) sb.append(", "); + sb.append("jobKeys:"); + if (this.jobKeys == null) { + sb.append("null"); + } else { + sb.append(this.jobKeys); + } + 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 + } + + 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 TaskQueryStandardSchemeFactory implements SchemeFactory { + public TaskQueryStandardScheme getScheme() { + return new TaskQueryStandardScheme(); + } + } + + private static class TaskQueryStandardScheme extends StandardScheme { + + public void read(org.apache.thrift.protocol.TProtocol iprot, TaskQuery 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 14: // 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 9: // ENVIRONMENT + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.environment = iprot.readString(); + struct.setEnvironmentIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // JOB_NAME + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.jobName = iprot.readString(); + struct.setJobNameIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 4: // TASK_IDS + if (schemeField.type == org.apache.thrift.protocol.TType.SET) { + { + org.apache.thrift.protocol.TSet _set142 = iprot.readSetBegin(); + struct.taskIds = new HashSet(2*_set142.size); + String _elem143; + for (int _i144 = 0; _i144 < _set142.size; ++_i144) + { + _elem143 = iprot.readString(); + struct.taskIds.add(_elem143); + } + iprot.readSetEnd(); + } + struct.setTaskIdsIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 5: // STATUSES + if (schemeField.type == org.apache.thrift.protocol.TType.SET) { + { + org.apache.thrift.protocol.TSet _set145 = iprot.readSetBegin(); + struct.statuses = new HashSet(2*_set145.size); + ScheduleStatus _elem146; + for (int _i147 = 0; _i147 < _set145.size; ++_i147) + { + _elem146 = org.apache.airavata.cloud.aurora.client.sdk.ScheduleStatus.findByValue(iprot.readI32()); + struct.statuses.add(_elem146); + } + iprot.readSetEnd(); + } + struct.setStatusesIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 7: // INSTANCE_IDS + if (schemeField.type == org.apache.thrift.protocol.TType.SET) { + { + org.apache.thrift.protocol.TSet _set148 = iprot.readSetBegin(); + struct.instanceIds = new HashSet(2*_set148.size); + int _elem149; + for (int _i150 = 0; _i150 < _set148.size; ++_i150) + { + _elem149 = iprot.readI32(); + struct.instanceIds.add(_elem149); + } + iprot.readSetEnd(); + } + struct.setInstanceIdsIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 10: // SLAVE_HOSTS + if (schemeField.type == org.apache.thrift.protocol.TType.SET) { + { + org.apache.thrift.protocol.TSet _set151 = iprot.readSetBegin(); + struct.slaveHosts = new HashSet(2*_set151.size); + String _elem152; + for (int _i153 = 0; _i153 < _set151.size; ++_i153) + { + _elem152 = iprot.readString(); + struct.slaveHosts.add(_elem152); + } + iprot.readSetEnd(); + } + struct.setSlaveHostsIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 11: // JOB_KEYS + if (schemeField.type == org.apache.thrift.protocol.TType.SET) { + { + org.apache.thrift.protocol.TSet _set154 = iprot.readSetBegin(); + struct.jobKeys = new HashSet(2*_set154.size); + JobKey _elem155; + for (int _i156 = 0; _i156 < _set154.size; ++_i156) + { + _elem155 = new JobKey(); + _elem155.read(iprot); + struct.jobKeys.add(_elem155); + } + iprot.readSetEnd(); + } + struct.setJobKeysIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 12: // 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 13: // 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, TaskQuery struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.jobName != null) { + oprot.writeFieldBegin(JOB_NAME_FIELD_DESC); + oprot.writeString(struct.jobName); + oprot.writeFieldEnd(); + } + if (struct.taskIds != null) { + oprot.writeFieldBegin(TASK_IDS_FIELD_DESC); + { + oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, struct.taskIds.size())); + for (String _iter157 : struct.taskIds) + { + oprot.writeString(_iter157); + } + oprot.writeSetEnd(); + } + oprot.writeFieldEnd(); + } + if (struct.statuses != null) { + oprot.writeFieldBegin(STATUSES_FIELD_DESC); + { + oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, struct.statuses.size())); + for (ScheduleStatus _iter158 : struct.statuses) + { + oprot.writeI32(_iter158.getValue()); + } + oprot.writeSetEnd(); + } + oprot.writeFieldEnd(); + } + if (struct.instanceIds != null) { + oprot.writeFieldBegin(INSTANCE_IDS_FIELD_DESC); + { + oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, struct.instanceIds.size())); + for (int _iter159 : struct.instanceIds) + { + oprot.writeI32(_iter159); + } + oprot.writeSetEnd(); + } + oprot.writeFieldEnd(); + } + if (struct.environment != null) { + oprot.writeFieldBegin(ENVIRONMENT_FIELD_DESC); + oprot.writeString(struct.environment); + oprot.writeFieldEnd(); + } + if (struct.slaveHosts != null) { + oprot.writeFieldBegin(SLAVE_HOSTS_FIELD_DESC); + { + oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, struct.slaveHosts.size())); + for (String _iter160 : struct.slaveHosts) + { + oprot.writeString(_iter160); + } + oprot.writeSetEnd(); + } + oprot.writeFieldEnd(); + } + if (struct.jobKeys != null) { + oprot.writeFieldBegin(JOB_KEYS_FIELD_DESC); + { + oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, struct.jobKeys.size())); + for (JobKey _iter161 : struct.jobKeys) + { + _iter161.write(oprot); + } + 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.role != null) { + oprot.writeFieldBegin(ROLE_FIELD_DESC); + oprot.writeString(struct.role); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class TaskQueryTupleSchemeFactory implements SchemeFactory { + public TaskQueryTupleScheme getScheme() { + return new TaskQueryTupleScheme(); + } + } + + private static class TaskQueryTupleScheme extends TupleScheme { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, TaskQuery struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetRole()) { + optionals.set(0); + } + if (struct.isSetEnvironment()) { + optionals.set(1); + } + if (struct.isSetJobName()) { + optionals.set(2); + } + if (struct.isSetTaskIds()) { + optionals.set(3); + } + if (struct.isSetStatuses()) { + optionals.set(4); + } + if (struct.isSetInstanceIds()) { + optionals.set(5); + } + if (struct.isSetSlaveHosts()) { + optionals.set(6); + } + if (struct.isSetJobKeys()) { + optionals.set(7); + } + if (struct.isSetOffset()) { + optionals.set(8); + } + if (struct.isSetLimit()) { + optionals.set(9); + } + oprot.writeBitSet(optionals, 10); + if (struct.isSetRole()) { + oprot.writeString(struct.role); + } + if (struct.isSetEnvironment()) { + oprot.writeString(struct.environment); + } + if (struct.isSetJobName()) { + oprot.writeString(struct.jobName); + } + if (struct.isSetTaskIds()) { + { + oprot.writeI32(struct.taskIds.size()); + for (String _iter162 : struct.taskIds) + { + oprot.writeString(_iter162); + } + } + } + if (struct.isSetStatuses()) { + { + oprot.writeI32(struct.statuses.size()); + for (ScheduleStatus _iter163 : struct.statuses) + { + oprot.writeI32(_iter163.getValue()); + } + } + } + if (struct.isSetInstanceIds()) { + { + oprot.writeI32(struct.instanceIds.size()); + for (int _iter164 : struct.instanceIds) + { + oprot.writeI32(_iter164); + } + } + } + if (struct.isSetSlaveHosts()) { + { + oprot.writeI32(struct.slaveHosts.size()); + for (String _iter165 : struct.slaveHosts) + { + oprot.writeString(_iter165); + } + } + } + if (struct.isSetJobKeys()) { + { + oprot.writeI32(struct.jobKeys.size()); + for (JobKey _iter166 : struct.jobKeys) + { + _iter166.write(oprot); + } + } + } + if (struct.isSetOffset()) { + oprot.writeI32(struct.offset); + } + if (struct.isSetLimit()) { + oprot.writeI32(struct.limit); + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, TaskQuery struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(10); + if (incoming.get(0)) { + struct.role = iprot.readString(); + struct.setRoleIsSet(true); + } + if (incoming.get(1)) { + struct.environment = iprot.readString(); + struct.setEnvironmentIsSet(true); + } + if (incoming.get(2)) { + struct.jobName = iprot.readString(); + struct.setJobNameIsSet(true); + } + if (incoming.get(3)) { + { + org.apache.thrift.protocol.TSet _set167 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.taskIds = new HashSet(2*_set167.size); + String _elem168; + for (int _i169 = 0; _i169 < _set167.size; ++_i169) + { + _elem168 = iprot.readString(); + struct.taskIds.add(_elem168); + } + } + struct.setTaskIdsIsSet(true); + } + if (incoming.get(4)) { + { + org.apache.thrift.protocol.TSet _set170 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32()); + struct.statuses = new HashSet(2*_set170.size); + ScheduleStatus _elem171; + for (int _i172 = 0; _i172 < _set170.size; ++_i172) + { + _elem171 = org.apache.airavata.cloud.aurora.client.sdk.ScheduleStatus.findByValue(iprot.readI32()); + struct.statuses.add(_elem171); + } + } + struct.setStatusesIsSet(true); + } + if (incoming.get(5)) { + { + org.apache.thrift.protocol.TSet _set173 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I32, iprot.readI32()); + struct.instanceIds = new HashSet(2*_set173.size); + int _elem174; + for (int _i175 = 0; _i175 < _set173.size; ++_i175) + { + _elem174 = iprot.readI32(); + struct.instanceIds.add(_elem174); + } + } + struct.setInstanceIdsIsSet(true); + } + if (incoming.get(6)) { + { + org.apache.thrift.protocol.TSet _set176 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.slaveHosts = new HashSet(2*_set176.size); + String _elem177; + for (int _i178 = 0; _i178 < _set176.size; ++_i178) + { + _elem177 = iprot.readString(); + struct.slaveHosts.add(_elem177); + } + } + struct.setSlaveHostsIsSet(true); + } + if (incoming.get(7)) { + { + org.apache.thrift.protocol.TSet _set179 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.jobKeys = new HashSet(2*_set179.size); + JobKey _elem180; + for (int _i181 = 0; _i181 < _set179.size; ++_i181) + { + _elem180 = new JobKey(); + _elem180.read(iprot); + struct.jobKeys.add(_elem180); + } + } + struct.setJobKeysIsSet(true); + } + if (incoming.get(8)) { + struct.offset = iprot.readI32(); + struct.setOffsetIsSet(true); + } + if (incoming.get(9)) { + struct.limit = iprot.readI32(); + struct.setLimitIsSet(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/TierConfig.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/TierConfig.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/TierConfig.java new file mode 100644 index 0000000..5f337f3 --- /dev/null +++ b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/TierConfig.java @@ -0,0 +1,582 @@ +/** + * 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"}) +/** + * Tier information. + */ +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-10-21") +public class TierConfig implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TierConfig"); + + 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)1); + private static final org.apache.thrift.protocol.TField SETTINGS_FIELD_DESC = new org.apache.thrift.protocol.TField("settings", org.apache.thrift.protocol.TType.MAP, (short)2); + + private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new TierConfigStandardSchemeFactory()); + schemes.put(TupleScheme.class, new TierConfigTupleSchemeFactory()); + } + + /** + * Name of tier. + */ + public String name; // required + /** + * Tier attributes. + */ + public Map 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 { + /** + * Name of tier. + */ + NAME((short)1, "name"), + /** + * Tier attributes. + */ + SETTINGS((short)2, "settings"); + + private static final Map byName = new HashMap(); + + 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: // NAME + return NAME; + case 2: // 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.NAME, new org.apache.thrift.meta_data.FieldMetaData("name", org.apache.thrift.TFieldRequirementType.DEFAULT, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.SETTINGS, new org.apache.thrift.meta_data.FieldMetaData("settings", org.apache.thrift.TFieldRequirementType.DEFAULT, + 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)))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TierConfig.class, metaDataMap); + } + + public TierConfig() { + } + + public TierConfig( + String name, + Map settings) + { + this(); + this.name = name; + this.settings = settings; + } + + /** + * Performs a deep copy on other. + */ + public TierConfig(TierConfig other) { + if (other.isSetName()) { + this.name = other.name; + } + if (other.isSetSettings()) { + Map __this__settings = new HashMap(other.settings); + this.settings = __this__settings; + } + } + + public TierConfig deepCopy() { + return new TierConfig(this); + } + + @Override + public void clear() { + this.name = null; + this.settings = null; + } + + /** + * Name of tier. + */ + public String getName() { + return this.name; + } + + /** + * Name of tier. + */ + public TierConfig setName(String name) { + this.name = name; + return this; + } + + public void unsetName() { + this.name = null; + } + + /** Returns true if field name is set (has been assigned a value) and false otherwise */ + public boolean isSetName() { + return this.name != null; + } + + public void setNameIsSet(boolean value) { + if (!value) { + this.name = null; + } + } + + public int getSettingsSize() { + return (this.settings == null) ? 0 : this.settings.size(); + } + + public void putToSettings(String key, String val) { + if (this.settings == null) { + this.settings = new HashMap(); + } + this.settings.put(key, val); + } + + /** + * Tier attributes. + */ + public Map getSettings() { + return this.settings; + } + + /** + * Tier attributes. + */ + public TierConfig setSettings(Map 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 NAME: + if (value == null) { + unsetName(); + } else { + setName((String)value); + } + break; + + case SETTINGS: + if (value == null) { + unsetSettings(); + } else { + setSettings((Map)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case NAME: + return getName(); + + 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 NAME: + return isSetName(); + case SETTINGS: + return isSetSettings(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof TierConfig) + return this.equals((TierConfig)that); + return false; + } + + public boolean equals(TierConfig that) { + if (that == null) + return false; + + boolean this_present_name = true && this.isSetName(); + boolean that_present_name = true && that.isSetName(); + 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_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 list = new ArrayList(); + + boolean present_name = true && (isSetName()); + list.add(present_name); + if (present_name) + list.add(name); + + boolean present_settings = true && (isSetSettings()); + list.add(present_settings); + if (present_settings) + list.add(settings); + + return list.hashCode(); + } + + @Override + public int compareTo(TierConfig other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetName()).compareTo(other.isSetName()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetName()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.name, other.name); + 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("TierConfig("); + boolean first = true; + + sb.append("name:"); + if (this.name == null) { + sb.append("null"); + } else { + sb.append(this.name); + } + 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 + } + + 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 TierConfigStandardSchemeFactory implements SchemeFactory { + public TierConfigStandardScheme getScheme() { + return new TierConfigStandardScheme(); + } + } + + private static class TierConfigStandardScheme extends StandardScheme { + + public void read(org.apache.thrift.protocol.TProtocol iprot, TierConfig 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: // NAME + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.name = iprot.readString(); + struct.setNameIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // SETTINGS + if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { + { + org.apache.thrift.protocol.TMap _map374 = iprot.readMapBegin(); + struct.settings = new HashMap(2*_map374.size); + String _key375; + String _val376; + for (int _i377 = 0; _i377 < _map374.size; ++_i377) + { + _key375 = iprot.readString(); + _val376 = iprot.readString(); + struct.settings.put(_key375, _val376); + } + iprot.readMapEnd(); + } + 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, TierConfig struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.name != null) { + oprot.writeFieldBegin(NAME_FIELD_DESC); + oprot.writeString(struct.name); + oprot.writeFieldEnd(); + } + if (struct.settings != null) { + oprot.writeFieldBegin(SETTINGS_FIELD_DESC); + { + oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.settings.size())); + for (Map.Entry _iter378 : struct.settings.entrySet()) + { + oprot.writeString(_iter378.getKey()); + oprot.writeString(_iter378.getValue()); + } + oprot.writeMapEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class TierConfigTupleSchemeFactory implements SchemeFactory { + public TierConfigTupleScheme getScheme() { + return new TierConfigTupleScheme(); + } + } + + private static class TierConfigTupleScheme extends TupleScheme { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, TierConfig struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + BitSet optionals = new BitSet(); + if (struct.isSetName()) { + optionals.set(0); + } + if (struct.isSetSettings()) { + optionals.set(1); + } + oprot.writeBitSet(optionals, 2); + if (struct.isSetName()) { + oprot.writeString(struct.name); + } + if (struct.isSetSettings()) { + { + oprot.writeI32(struct.settings.size()); + for (Map.Entry _iter379 : struct.settings.entrySet()) + { + oprot.writeString(_iter379.getKey()); + oprot.writeString(_iter379.getValue()); + } + } + } + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, TierConfig struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + BitSet incoming = iprot.readBitSet(2); + if (incoming.get(0)) { + struct.name = iprot.readString(); + struct.setNameIsSet(true); + } + if (incoming.get(1)) { + { + org.apache.thrift.protocol.TMap _map380 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.settings = new HashMap(2*_map380.size); + String _key381; + String _val382; + for (int _i383 = 0; _i383 < _map380.size; ++_i383) + { + _key381 = iprot.readString(); + _val382 = iprot.readString(); + struct.settings.put(_key381, _val382); + } + } + struct.setSettingsIsSet(true); + } + } + } + +} +