http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/488b772f/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 deleted file mode 100644 index f739bf5..0000000 --- a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/TaskQuery.java +++ /dev/null @@ -1,1611 +0,0 @@ -/** - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.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<TaskQuery, TaskQuery._Fields>, java.io.Serializable, Cloneable, Comparable<TaskQuery> { - 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<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, 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<String> taskIds; // required - public Set<ScheduleStatus> statuses; // required - public Set<Integer> instanceIds; // required - public Set<String> slaveHosts; // required - public Set<JobKey> 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<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 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<String> taskIds, - Set<ScheduleStatus> statuses, - Set<Integer> instanceIds, - Set<String> slaveHosts, - Set<JobKey> 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 <i>other</i>. - */ - 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<String> __this__taskIds = new HashSet<String>(other.taskIds); - this.taskIds = __this__taskIds; - } - if (other.isSetStatuses()) { - Set<ScheduleStatus> __this__statuses = new HashSet<ScheduleStatus>(other.statuses.size()); - for (ScheduleStatus other_element : other.statuses) { - __this__statuses.add(other_element); - } - this.statuses = __this__statuses; - } - if (other.isSetInstanceIds()) { - Set<Integer> __this__instanceIds = new HashSet<Integer>(other.instanceIds); - this.instanceIds = __this__instanceIds; - } - if (other.isSetSlaveHosts()) { - Set<String> __this__slaveHosts = new HashSet<String>(other.slaveHosts); - this.slaveHosts = __this__slaveHosts; - } - if (other.isSetJobKeys()) { - Set<JobKey> __this__jobKeys = new HashSet<JobKey>(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<String> getTaskIdsIterator() { - return (this.taskIds == null) ? null : this.taskIds.iterator(); - } - - public void addToTaskIds(String elem) { - if (this.taskIds == null) { - this.taskIds = new HashSet<String>(); - } - this.taskIds.add(elem); - } - - public Set<String> getTaskIds() { - return this.taskIds; - } - - public TaskQuery setTaskIds(Set<String> 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<ScheduleStatus> getStatusesIterator() { - return (this.statuses == null) ? null : this.statuses.iterator(); - } - - public void addToStatuses(ScheduleStatus elem) { - if (this.statuses == null) { - this.statuses = new HashSet<ScheduleStatus>(); - } - this.statuses.add(elem); - } - - public Set<ScheduleStatus> getStatuses() { - return this.statuses; - } - - public TaskQuery setStatuses(Set<ScheduleStatus> 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<Integer> getInstanceIdsIterator() { - return (this.instanceIds == null) ? null : this.instanceIds.iterator(); - } - - public void addToInstanceIds(int elem) { - if (this.instanceIds == null) { - this.instanceIds = new HashSet<Integer>(); - } - this.instanceIds.add(elem); - } - - public Set<Integer> getInstanceIds() { - return this.instanceIds; - } - - public TaskQuery setInstanceIds(Set<Integer> 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<String> getSlaveHostsIterator() { - return (this.slaveHosts == null) ? null : this.slaveHosts.iterator(); - } - - public void addToSlaveHosts(String elem) { - if (this.slaveHosts == null) { - this.slaveHosts = new HashSet<String>(); - } - this.slaveHosts.add(elem); - } - - public Set<String> getSlaveHosts() { - return this.slaveHosts; - } - - public TaskQuery setSlaveHosts(Set<String> 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<JobKey> getJobKeysIterator() { - return (this.jobKeys == null) ? null : this.jobKeys.iterator(); - } - - public void addToJobKeys(JobKey elem) { - if (this.jobKeys == null) { - this.jobKeys = new HashSet<JobKey>(); - } - this.jobKeys.add(elem); - } - - public Set<JobKey> getJobKeys() { - return this.jobKeys; - } - - public TaskQuery setJobKeys(Set<JobKey> 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<String>)value); - } - break; - - case STATUSES: - if (value == null) { - unsetStatuses(); - } else { - setStatuses((Set<ScheduleStatus>)value); - } - break; - - case INSTANCE_IDS: - if (value == null) { - unsetInstanceIds(); - } else { - setInstanceIds((Set<Integer>)value); - } - break; - - case SLAVE_HOSTS: - if (value == null) { - unsetSlaveHosts(); - } else { - setSlaveHosts((Set<String>)value); - } - break; - - case JOB_KEYS: - if (value == null) { - unsetJobKeys(); - } else { - setJobKeys((Set<JobKey>)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<Object> list = new ArrayList<Object>(); - - 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<TaskQuery> { - - 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<String>(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<ScheduleStatus>(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<Integer>(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<String>(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<JobKey>(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<TaskQuery> { - - @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<String>(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<ScheduleStatus>(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<Integer>(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<String>(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<JobKey>(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-php-gateway/blob/488b772f/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 deleted file mode 100644 index 52f9475..0000000 --- a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/TierConfig.java +++ /dev/null @@ -1,601 +0,0 @@ -/** - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.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<TierConfig, TierConfig._Fields>, java.io.Serializable, Cloneable, Comparable<TierConfig> { - 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<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, 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<String,String> 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<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: // 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<String,String> settings) - { - this(); - this.name = name; - this.settings = settings; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public TierConfig(TierConfig other) { - if (other.isSetName()) { - this.name = other.name; - } - if (other.isSetSettings()) { - Map<String,String> __this__settings = new HashMap<String,String>(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<String,String>(); - } - this.settings.put(key, val); - } - - /** - * Tier attributes. - */ - public Map<String,String> getSettings() { - return this.settings; - } - - /** - * Tier attributes. - */ - public TierConfig setSettings(Map<String,String> 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<String,String>)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<Object> list = new ArrayList<Object>(); - - 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<TierConfig> { - - 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<String,String>(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<String, String> _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<TierConfig> { - - @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<String, String> _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<String,String>(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); - } - } - } - -} -
