blob: 95a52ad168bf24aa0db8df2a424a4ba4d2c7f4d9 [file] [log] [blame]
/**
* 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.18.1)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
package org.apache.airavata.model.workflow;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.18.1)")
public class WorkflowApplication implements org.apache.thrift.TBase<WorkflowApplication, WorkflowApplication._Fields>, java.io.Serializable, Cloneable, Comparable<WorkflowApplication> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WorkflowApplication");
private static final org.apache.thrift.protocol.TField ID_FIELD_DESC = new org.apache.thrift.protocol.TField("id", org.apache.thrift.protocol.TType.STRING, (short)1);
private static final org.apache.thrift.protocol.TField PROCESS_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("processId", org.apache.thrift.protocol.TType.STRING, (short)2);
private static final org.apache.thrift.protocol.TField APPLICATION_INTERFACE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("applicationInterfaceId", org.apache.thrift.protocol.TType.STRING, (short)3);
private static final org.apache.thrift.protocol.TField COMPUTE_RESOURCE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("computeResourceId", org.apache.thrift.protocol.TType.STRING, (short)4);
private static final org.apache.thrift.protocol.TField QUEUE_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("queueName", org.apache.thrift.protocol.TType.STRING, (short)5);
private static final org.apache.thrift.protocol.TField NODE_COUNT_FIELD_DESC = new org.apache.thrift.protocol.TField("nodeCount", org.apache.thrift.protocol.TType.I32, (short)6);
private static final org.apache.thrift.protocol.TField CORE_COUNT_FIELD_DESC = new org.apache.thrift.protocol.TField("coreCount", org.apache.thrift.protocol.TType.I32, (short)7);
private static final org.apache.thrift.protocol.TField WALL_TIME_LIMIT_FIELD_DESC = new org.apache.thrift.protocol.TField("wallTimeLimit", org.apache.thrift.protocol.TType.I32, (short)8);
private static final org.apache.thrift.protocol.TField PHYSICAL_MEMORY_FIELD_DESC = new org.apache.thrift.protocol.TField("physicalMemory", org.apache.thrift.protocol.TType.I32, (short)9);
private static final org.apache.thrift.protocol.TField STATUSES_FIELD_DESC = new org.apache.thrift.protocol.TField("statuses", org.apache.thrift.protocol.TType.LIST, (short)10);
private static final org.apache.thrift.protocol.TField ERRORS_FIELD_DESC = new org.apache.thrift.protocol.TField("errors", org.apache.thrift.protocol.TType.LIST, (short)11);
private static final org.apache.thrift.protocol.TField CREATED_AT_FIELD_DESC = new org.apache.thrift.protocol.TField("createdAt", org.apache.thrift.protocol.TType.I64, (short)12);
private static final org.apache.thrift.protocol.TField UPDATED_AT_FIELD_DESC = new org.apache.thrift.protocol.TField("updatedAt", org.apache.thrift.protocol.TType.I64, (short)13);
private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new WorkflowApplicationStandardSchemeFactory();
private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new WorkflowApplicationTupleSchemeFactory();
private @org.apache.thrift.annotation.Nullable java.lang.String id; // required
private @org.apache.thrift.annotation.Nullable java.lang.String processId; // optional
private @org.apache.thrift.annotation.Nullable java.lang.String applicationInterfaceId; // optional
private @org.apache.thrift.annotation.Nullable java.lang.String computeResourceId; // optional
private @org.apache.thrift.annotation.Nullable java.lang.String queueName; // optional
private int nodeCount; // optional
private int coreCount; // optional
private int wallTimeLimit; // optional
private int physicalMemory; // optional
private @org.apache.thrift.annotation.Nullable java.util.List<ApplicationStatus> statuses; // optional
private @org.apache.thrift.annotation.Nullable java.util.List<org.apache.airavata.model.commons.ErrorModel> errors; // optional
private long createdAt; // optional
private long updatedAt; // optional
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
ID((short)1, "id"),
PROCESS_ID((short)2, "processId"),
APPLICATION_INTERFACE_ID((short)3, "applicationInterfaceId"),
COMPUTE_RESOURCE_ID((short)4, "computeResourceId"),
QUEUE_NAME((short)5, "queueName"),
NODE_COUNT((short)6, "nodeCount"),
CORE_COUNT((short)7, "coreCount"),
WALL_TIME_LIMIT((short)8, "wallTimeLimit"),
PHYSICAL_MEMORY((short)9, "physicalMemory"),
STATUSES((short)10, "statuses"),
ERRORS((short)11, "errors"),
CREATED_AT((short)12, "createdAt"),
UPDATED_AT((short)13, "updatedAt");
private static final java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>();
static {
for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) {
byName.put(field.getFieldName(), field);
}
}
/**
* Find the _Fields constant that matches fieldId, or null if its not found.
*/
@org.apache.thrift.annotation.Nullable
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
case 1: // ID
return ID;
case 2: // PROCESS_ID
return PROCESS_ID;
case 3: // APPLICATION_INTERFACE_ID
return APPLICATION_INTERFACE_ID;
case 4: // COMPUTE_RESOURCE_ID
return COMPUTE_RESOURCE_ID;
case 5: // QUEUE_NAME
return QUEUE_NAME;
case 6: // NODE_COUNT
return NODE_COUNT;
case 7: // CORE_COUNT
return CORE_COUNT;
case 8: // WALL_TIME_LIMIT
return WALL_TIME_LIMIT;
case 9: // PHYSICAL_MEMORY
return PHYSICAL_MEMORY;
case 10: // STATUSES
return STATUSES;
case 11: // ERRORS
return ERRORS;
case 12: // CREATED_AT
return CREATED_AT;
case 13: // UPDATED_AT
return UPDATED_AT;
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 java.lang.IllegalArgumentException("Field " + fieldId + " doesn't exist!");
return fields;
}
/**
* Find the _Fields constant that matches name, or null if its not found.
*/
@org.apache.thrift.annotation.Nullable
public static _Fields findByName(java.lang.String name) {
return byName.get(name);
}
private final short _thriftId;
private final java.lang.String _fieldName;
_Fields(short thriftId, java.lang.String fieldName) {
_thriftId = thriftId;
_fieldName = fieldName;
}
@Override
public short getThriftFieldId() {
return _thriftId;
}
@Override
public java.lang.String getFieldName() {
return _fieldName;
}
}
// isset id assignments
private static final int __NODECOUNT_ISSET_ID = 0;
private static final int __CORECOUNT_ISSET_ID = 1;
private static final int __WALLTIMELIMIT_ISSET_ID = 2;
private static final int __PHYSICALMEMORY_ISSET_ID = 3;
private static final int __CREATEDAT_ISSET_ID = 4;
private static final int __UPDATEDAT_ISSET_ID = 5;
private byte __isset_bitfield = 0;
private static final _Fields optionals[] = {_Fields.PROCESS_ID,_Fields.APPLICATION_INTERFACE_ID,_Fields.COMPUTE_RESOURCE_ID,_Fields.QUEUE_NAME,_Fields.NODE_COUNT,_Fields.CORE_COUNT,_Fields.WALL_TIME_LIMIT,_Fields.PHYSICAL_MEMORY,_Fields.STATUSES,_Fields.ERRORS,_Fields.CREATED_AT,_Fields.UPDATED_AT};
public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.ID, new org.apache.thrift.meta_data.FieldMetaData("id", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.PROCESS_ID, new org.apache.thrift.meta_data.FieldMetaData("processId", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.APPLICATION_INTERFACE_ID, new org.apache.thrift.meta_data.FieldMetaData("applicationInterfaceId", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.COMPUTE_RESOURCE_ID, new org.apache.thrift.meta_data.FieldMetaData("computeResourceId", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.QUEUE_NAME, new org.apache.thrift.meta_data.FieldMetaData("queueName", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.NODE_COUNT, new org.apache.thrift.meta_data.FieldMetaData("nodeCount", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
tmpMap.put(_Fields.CORE_COUNT, new org.apache.thrift.meta_data.FieldMetaData("coreCount", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
tmpMap.put(_Fields.WALL_TIME_LIMIT, new org.apache.thrift.meta_data.FieldMetaData("wallTimeLimit", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
tmpMap.put(_Fields.PHYSICAL_MEMORY, new org.apache.thrift.meta_data.FieldMetaData("physicalMemory", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
tmpMap.put(_Fields.STATUSES, new org.apache.thrift.meta_data.FieldMetaData("statuses", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ApplicationStatus.class))));
tmpMap.put(_Fields.ERRORS, new org.apache.thrift.meta_data.FieldMetaData("errors", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.airavata.model.commons.ErrorModel.class))));
tmpMap.put(_Fields.CREATED_AT, new org.apache.thrift.meta_data.FieldMetaData("createdAt", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
tmpMap.put(_Fields.UPDATED_AT, new org.apache.thrift.meta_data.FieldMetaData("updatedAt", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(WorkflowApplication.class, metaDataMap);
}
public WorkflowApplication() {
}
public WorkflowApplication(
java.lang.String id)
{
this();
this.id = id;
}
/**
* Performs a deep copy on <i>other</i>.
*/
public WorkflowApplication(WorkflowApplication other) {
__isset_bitfield = other.__isset_bitfield;
if (other.isSetId()) {
this.id = other.id;
}
if (other.isSetProcessId()) {
this.processId = other.processId;
}
if (other.isSetApplicationInterfaceId()) {
this.applicationInterfaceId = other.applicationInterfaceId;
}
if (other.isSetComputeResourceId()) {
this.computeResourceId = other.computeResourceId;
}
if (other.isSetQueueName()) {
this.queueName = other.queueName;
}
this.nodeCount = other.nodeCount;
this.coreCount = other.coreCount;
this.wallTimeLimit = other.wallTimeLimit;
this.physicalMemory = other.physicalMemory;
if (other.isSetStatuses()) {
java.util.List<ApplicationStatus> __this__statuses = new java.util.ArrayList<ApplicationStatus>(other.statuses.size());
for (ApplicationStatus other_element : other.statuses) {
__this__statuses.add(new ApplicationStatus(other_element));
}
this.statuses = __this__statuses;
}
if (other.isSetErrors()) {
java.util.List<org.apache.airavata.model.commons.ErrorModel> __this__errors = new java.util.ArrayList<org.apache.airavata.model.commons.ErrorModel>(other.errors.size());
for (org.apache.airavata.model.commons.ErrorModel other_element : other.errors) {
__this__errors.add(new org.apache.airavata.model.commons.ErrorModel(other_element));
}
this.errors = __this__errors;
}
this.createdAt = other.createdAt;
this.updatedAt = other.updatedAt;
}
@Override
public WorkflowApplication deepCopy() {
return new WorkflowApplication(this);
}
@Override
public void clear() {
this.id = null;
this.processId = null;
this.applicationInterfaceId = null;
this.computeResourceId = null;
this.queueName = null;
setNodeCountIsSet(false);
this.nodeCount = 0;
setCoreCountIsSet(false);
this.coreCount = 0;
setWallTimeLimitIsSet(false);
this.wallTimeLimit = 0;
setPhysicalMemoryIsSet(false);
this.physicalMemory = 0;
this.statuses = null;
this.errors = null;
setCreatedAtIsSet(false);
this.createdAt = 0;
setUpdatedAtIsSet(false);
this.updatedAt = 0;
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getId() {
return this.id;
}
public void setId(@org.apache.thrift.annotation.Nullable java.lang.String id) {
this.id = id;
}
public void unsetId() {
this.id = null;
}
/** Returns true if field id is set (has been assigned a value) and false otherwise */
public boolean isSetId() {
return this.id != null;
}
public void setIdIsSet(boolean value) {
if (!value) {
this.id = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getProcessId() {
return this.processId;
}
public void setProcessId(@org.apache.thrift.annotation.Nullable java.lang.String processId) {
this.processId = processId;
}
public void unsetProcessId() {
this.processId = null;
}
/** Returns true if field processId is set (has been assigned a value) and false otherwise */
public boolean isSetProcessId() {
return this.processId != null;
}
public void setProcessIdIsSet(boolean value) {
if (!value) {
this.processId = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getApplicationInterfaceId() {
return this.applicationInterfaceId;
}
public void setApplicationInterfaceId(@org.apache.thrift.annotation.Nullable java.lang.String applicationInterfaceId) {
this.applicationInterfaceId = applicationInterfaceId;
}
public void unsetApplicationInterfaceId() {
this.applicationInterfaceId = null;
}
/** Returns true if field applicationInterfaceId is set (has been assigned a value) and false otherwise */
public boolean isSetApplicationInterfaceId() {
return this.applicationInterfaceId != null;
}
public void setApplicationInterfaceIdIsSet(boolean value) {
if (!value) {
this.applicationInterfaceId = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getComputeResourceId() {
return this.computeResourceId;
}
public void setComputeResourceId(@org.apache.thrift.annotation.Nullable java.lang.String computeResourceId) {
this.computeResourceId = computeResourceId;
}
public void unsetComputeResourceId() {
this.computeResourceId = null;
}
/** Returns true if field computeResourceId is set (has been assigned a value) and false otherwise */
public boolean isSetComputeResourceId() {
return this.computeResourceId != null;
}
public void setComputeResourceIdIsSet(boolean value) {
if (!value) {
this.computeResourceId = null;
}
}
@org.apache.thrift.annotation.Nullable
public java.lang.String getQueueName() {
return this.queueName;
}
public void setQueueName(@org.apache.thrift.annotation.Nullable java.lang.String queueName) {
this.queueName = queueName;
}
public void unsetQueueName() {
this.queueName = null;
}
/** Returns true if field queueName is set (has been assigned a value) and false otherwise */
public boolean isSetQueueName() {
return this.queueName != null;
}
public void setQueueNameIsSet(boolean value) {
if (!value) {
this.queueName = null;
}
}
public int getNodeCount() {
return this.nodeCount;
}
public void setNodeCount(int nodeCount) {
this.nodeCount = nodeCount;
setNodeCountIsSet(true);
}
public void unsetNodeCount() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __NODECOUNT_ISSET_ID);
}
/** Returns true if field nodeCount is set (has been assigned a value) and false otherwise */
public boolean isSetNodeCount() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __NODECOUNT_ISSET_ID);
}
public void setNodeCountIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __NODECOUNT_ISSET_ID, value);
}
public int getCoreCount() {
return this.coreCount;
}
public void setCoreCount(int coreCount) {
this.coreCount = coreCount;
setCoreCountIsSet(true);
}
public void unsetCoreCount() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __CORECOUNT_ISSET_ID);
}
/** Returns true if field coreCount is set (has been assigned a value) and false otherwise */
public boolean isSetCoreCount() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __CORECOUNT_ISSET_ID);
}
public void setCoreCountIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __CORECOUNT_ISSET_ID, value);
}
public int getWallTimeLimit() {
return this.wallTimeLimit;
}
public void setWallTimeLimit(int wallTimeLimit) {
this.wallTimeLimit = wallTimeLimit;
setWallTimeLimitIsSet(true);
}
public void unsetWallTimeLimit() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __WALLTIMELIMIT_ISSET_ID);
}
/** Returns true if field wallTimeLimit is set (has been assigned a value) and false otherwise */
public boolean isSetWallTimeLimit() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __WALLTIMELIMIT_ISSET_ID);
}
public void setWallTimeLimitIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __WALLTIMELIMIT_ISSET_ID, value);
}
public int getPhysicalMemory() {
return this.physicalMemory;
}
public void setPhysicalMemory(int physicalMemory) {
this.physicalMemory = physicalMemory;
setPhysicalMemoryIsSet(true);
}
public void unsetPhysicalMemory() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __PHYSICALMEMORY_ISSET_ID);
}
/** Returns true if field physicalMemory is set (has been assigned a value) and false otherwise */
public boolean isSetPhysicalMemory() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __PHYSICALMEMORY_ISSET_ID);
}
public void setPhysicalMemoryIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __PHYSICALMEMORY_ISSET_ID, value);
}
public int getStatusesSize() {
return (this.statuses == null) ? 0 : this.statuses.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<ApplicationStatus> getStatusesIterator() {
return (this.statuses == null) ? null : this.statuses.iterator();
}
public void addToStatuses(ApplicationStatus elem) {
if (this.statuses == null) {
this.statuses = new java.util.ArrayList<ApplicationStatus>();
}
this.statuses.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<ApplicationStatus> getStatuses() {
return this.statuses;
}
public void setStatuses(@org.apache.thrift.annotation.Nullable java.util.List<ApplicationStatus> statuses) {
this.statuses = statuses;
}
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 getErrorsSize() {
return (this.errors == null) ? 0 : this.errors.size();
}
@org.apache.thrift.annotation.Nullable
public java.util.Iterator<org.apache.airavata.model.commons.ErrorModel> getErrorsIterator() {
return (this.errors == null) ? null : this.errors.iterator();
}
public void addToErrors(org.apache.airavata.model.commons.ErrorModel elem) {
if (this.errors == null) {
this.errors = new java.util.ArrayList<org.apache.airavata.model.commons.ErrorModel>();
}
this.errors.add(elem);
}
@org.apache.thrift.annotation.Nullable
public java.util.List<org.apache.airavata.model.commons.ErrorModel> getErrors() {
return this.errors;
}
public void setErrors(@org.apache.thrift.annotation.Nullable java.util.List<org.apache.airavata.model.commons.ErrorModel> errors) {
this.errors = errors;
}
public void unsetErrors() {
this.errors = null;
}
/** Returns true if field errors is set (has been assigned a value) and false otherwise */
public boolean isSetErrors() {
return this.errors != null;
}
public void setErrorsIsSet(boolean value) {
if (!value) {
this.errors = null;
}
}
public long getCreatedAt() {
return this.createdAt;
}
public void setCreatedAt(long createdAt) {
this.createdAt = createdAt;
setCreatedAtIsSet(true);
}
public void unsetCreatedAt() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __CREATEDAT_ISSET_ID);
}
/** Returns true if field createdAt is set (has been assigned a value) and false otherwise */
public boolean isSetCreatedAt() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __CREATEDAT_ISSET_ID);
}
public void setCreatedAtIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __CREATEDAT_ISSET_ID, value);
}
public long getUpdatedAt() {
return this.updatedAt;
}
public void setUpdatedAt(long updatedAt) {
this.updatedAt = updatedAt;
setUpdatedAtIsSet(true);
}
public void unsetUpdatedAt() {
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __UPDATEDAT_ISSET_ID);
}
/** Returns true if field updatedAt is set (has been assigned a value) and false otherwise */
public boolean isSetUpdatedAt() {
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __UPDATEDAT_ISSET_ID);
}
public void setUpdatedAtIsSet(boolean value) {
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __UPDATEDAT_ISSET_ID, value);
}
@Override
public void setFieldValue(_Fields field, @org.apache.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
case ID:
if (value == null) {
unsetId();
} else {
setId((java.lang.String)value);
}
break;
case PROCESS_ID:
if (value == null) {
unsetProcessId();
} else {
setProcessId((java.lang.String)value);
}
break;
case APPLICATION_INTERFACE_ID:
if (value == null) {
unsetApplicationInterfaceId();
} else {
setApplicationInterfaceId((java.lang.String)value);
}
break;
case COMPUTE_RESOURCE_ID:
if (value == null) {
unsetComputeResourceId();
} else {
setComputeResourceId((java.lang.String)value);
}
break;
case QUEUE_NAME:
if (value == null) {
unsetQueueName();
} else {
setQueueName((java.lang.String)value);
}
break;
case NODE_COUNT:
if (value == null) {
unsetNodeCount();
} else {
setNodeCount((java.lang.Integer)value);
}
break;
case CORE_COUNT:
if (value == null) {
unsetCoreCount();
} else {
setCoreCount((java.lang.Integer)value);
}
break;
case WALL_TIME_LIMIT:
if (value == null) {
unsetWallTimeLimit();
} else {
setWallTimeLimit((java.lang.Integer)value);
}
break;
case PHYSICAL_MEMORY:
if (value == null) {
unsetPhysicalMemory();
} else {
setPhysicalMemory((java.lang.Integer)value);
}
break;
case STATUSES:
if (value == null) {
unsetStatuses();
} else {
setStatuses((java.util.List<ApplicationStatus>)value);
}
break;
case ERRORS:
if (value == null) {
unsetErrors();
} else {
setErrors((java.util.List<org.apache.airavata.model.commons.ErrorModel>)value);
}
break;
case CREATED_AT:
if (value == null) {
unsetCreatedAt();
} else {
setCreatedAt((java.lang.Long)value);
}
break;
case UPDATED_AT:
if (value == null) {
unsetUpdatedAt();
} else {
setUpdatedAt((java.lang.Long)value);
}
break;
}
}
@org.apache.thrift.annotation.Nullable
@Override
public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case ID:
return getId();
case PROCESS_ID:
return getProcessId();
case APPLICATION_INTERFACE_ID:
return getApplicationInterfaceId();
case COMPUTE_RESOURCE_ID:
return getComputeResourceId();
case QUEUE_NAME:
return getQueueName();
case NODE_COUNT:
return getNodeCount();
case CORE_COUNT:
return getCoreCount();
case WALL_TIME_LIMIT:
return getWallTimeLimit();
case PHYSICAL_MEMORY:
return getPhysicalMemory();
case STATUSES:
return getStatuses();
case ERRORS:
return getErrors();
case CREATED_AT:
return getCreatedAt();
case UPDATED_AT:
return getUpdatedAt();
}
throw new java.lang.IllegalStateException();
}
/** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
@Override
public boolean isSet(_Fields field) {
if (field == null) {
throw new java.lang.IllegalArgumentException();
}
switch (field) {
case ID:
return isSetId();
case PROCESS_ID:
return isSetProcessId();
case APPLICATION_INTERFACE_ID:
return isSetApplicationInterfaceId();
case COMPUTE_RESOURCE_ID:
return isSetComputeResourceId();
case QUEUE_NAME:
return isSetQueueName();
case NODE_COUNT:
return isSetNodeCount();
case CORE_COUNT:
return isSetCoreCount();
case WALL_TIME_LIMIT:
return isSetWallTimeLimit();
case PHYSICAL_MEMORY:
return isSetPhysicalMemory();
case STATUSES:
return isSetStatuses();
case ERRORS:
return isSetErrors();
case CREATED_AT:
return isSetCreatedAt();
case UPDATED_AT:
return isSetUpdatedAt();
}
throw new java.lang.IllegalStateException();
}
@Override
public boolean equals(java.lang.Object that) {
if (that instanceof WorkflowApplication)
return this.equals((WorkflowApplication)that);
return false;
}
public boolean equals(WorkflowApplication that) {
if (that == null)
return false;
if (this == that)
return true;
boolean this_present_id = true && this.isSetId();
boolean that_present_id = true && that.isSetId();
if (this_present_id || that_present_id) {
if (!(this_present_id && that_present_id))
return false;
if (!this.id.equals(that.id))
return false;
}
boolean this_present_processId = true && this.isSetProcessId();
boolean that_present_processId = true && that.isSetProcessId();
if (this_present_processId || that_present_processId) {
if (!(this_present_processId && that_present_processId))
return false;
if (!this.processId.equals(that.processId))
return false;
}
boolean this_present_applicationInterfaceId = true && this.isSetApplicationInterfaceId();
boolean that_present_applicationInterfaceId = true && that.isSetApplicationInterfaceId();
if (this_present_applicationInterfaceId || that_present_applicationInterfaceId) {
if (!(this_present_applicationInterfaceId && that_present_applicationInterfaceId))
return false;
if (!this.applicationInterfaceId.equals(that.applicationInterfaceId))
return false;
}
boolean this_present_computeResourceId = true && this.isSetComputeResourceId();
boolean that_present_computeResourceId = true && that.isSetComputeResourceId();
if (this_present_computeResourceId || that_present_computeResourceId) {
if (!(this_present_computeResourceId && that_present_computeResourceId))
return false;
if (!this.computeResourceId.equals(that.computeResourceId))
return false;
}
boolean this_present_queueName = true && this.isSetQueueName();
boolean that_present_queueName = true && that.isSetQueueName();
if (this_present_queueName || that_present_queueName) {
if (!(this_present_queueName && that_present_queueName))
return false;
if (!this.queueName.equals(that.queueName))
return false;
}
boolean this_present_nodeCount = true && this.isSetNodeCount();
boolean that_present_nodeCount = true && that.isSetNodeCount();
if (this_present_nodeCount || that_present_nodeCount) {
if (!(this_present_nodeCount && that_present_nodeCount))
return false;
if (this.nodeCount != that.nodeCount)
return false;
}
boolean this_present_coreCount = true && this.isSetCoreCount();
boolean that_present_coreCount = true && that.isSetCoreCount();
if (this_present_coreCount || that_present_coreCount) {
if (!(this_present_coreCount && that_present_coreCount))
return false;
if (this.coreCount != that.coreCount)
return false;
}
boolean this_present_wallTimeLimit = true && this.isSetWallTimeLimit();
boolean that_present_wallTimeLimit = true && that.isSetWallTimeLimit();
if (this_present_wallTimeLimit || that_present_wallTimeLimit) {
if (!(this_present_wallTimeLimit && that_present_wallTimeLimit))
return false;
if (this.wallTimeLimit != that.wallTimeLimit)
return false;
}
boolean this_present_physicalMemory = true && this.isSetPhysicalMemory();
boolean that_present_physicalMemory = true && that.isSetPhysicalMemory();
if (this_present_physicalMemory || that_present_physicalMemory) {
if (!(this_present_physicalMemory && that_present_physicalMemory))
return false;
if (this.physicalMemory != that.physicalMemory)
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_errors = true && this.isSetErrors();
boolean that_present_errors = true && that.isSetErrors();
if (this_present_errors || that_present_errors) {
if (!(this_present_errors && that_present_errors))
return false;
if (!this.errors.equals(that.errors))
return false;
}
boolean this_present_createdAt = true && this.isSetCreatedAt();
boolean that_present_createdAt = true && that.isSetCreatedAt();
if (this_present_createdAt || that_present_createdAt) {
if (!(this_present_createdAt && that_present_createdAt))
return false;
if (this.createdAt != that.createdAt)
return false;
}
boolean this_present_updatedAt = true && this.isSetUpdatedAt();
boolean that_present_updatedAt = true && that.isSetUpdatedAt();
if (this_present_updatedAt || that_present_updatedAt) {
if (!(this_present_updatedAt && that_present_updatedAt))
return false;
if (this.updatedAt != that.updatedAt)
return false;
}
return true;
}
@Override
public int hashCode() {
int hashCode = 1;
hashCode = hashCode * 8191 + ((isSetId()) ? 131071 : 524287);
if (isSetId())
hashCode = hashCode * 8191 + id.hashCode();
hashCode = hashCode * 8191 + ((isSetProcessId()) ? 131071 : 524287);
if (isSetProcessId())
hashCode = hashCode * 8191 + processId.hashCode();
hashCode = hashCode * 8191 + ((isSetApplicationInterfaceId()) ? 131071 : 524287);
if (isSetApplicationInterfaceId())
hashCode = hashCode * 8191 + applicationInterfaceId.hashCode();
hashCode = hashCode * 8191 + ((isSetComputeResourceId()) ? 131071 : 524287);
if (isSetComputeResourceId())
hashCode = hashCode * 8191 + computeResourceId.hashCode();
hashCode = hashCode * 8191 + ((isSetQueueName()) ? 131071 : 524287);
if (isSetQueueName())
hashCode = hashCode * 8191 + queueName.hashCode();
hashCode = hashCode * 8191 + ((isSetNodeCount()) ? 131071 : 524287);
if (isSetNodeCount())
hashCode = hashCode * 8191 + nodeCount;
hashCode = hashCode * 8191 + ((isSetCoreCount()) ? 131071 : 524287);
if (isSetCoreCount())
hashCode = hashCode * 8191 + coreCount;
hashCode = hashCode * 8191 + ((isSetWallTimeLimit()) ? 131071 : 524287);
if (isSetWallTimeLimit())
hashCode = hashCode * 8191 + wallTimeLimit;
hashCode = hashCode * 8191 + ((isSetPhysicalMemory()) ? 131071 : 524287);
if (isSetPhysicalMemory())
hashCode = hashCode * 8191 + physicalMemory;
hashCode = hashCode * 8191 + ((isSetStatuses()) ? 131071 : 524287);
if (isSetStatuses())
hashCode = hashCode * 8191 + statuses.hashCode();
hashCode = hashCode * 8191 + ((isSetErrors()) ? 131071 : 524287);
if (isSetErrors())
hashCode = hashCode * 8191 + errors.hashCode();
hashCode = hashCode * 8191 + ((isSetCreatedAt()) ? 131071 : 524287);
if (isSetCreatedAt())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(createdAt);
hashCode = hashCode * 8191 + ((isSetUpdatedAt()) ? 131071 : 524287);
if (isSetUpdatedAt())
hashCode = hashCode * 8191 + org.apache.thrift.TBaseHelper.hashCode(updatedAt);
return hashCode;
}
@Override
public int compareTo(WorkflowApplication other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
lastComparison = java.lang.Boolean.compare(isSetId(), other.isSetId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.id, other.id);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetProcessId(), other.isSetProcessId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetProcessId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.processId, other.processId);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetApplicationInterfaceId(), other.isSetApplicationInterfaceId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetApplicationInterfaceId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.applicationInterfaceId, other.applicationInterfaceId);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetComputeResourceId(), other.isSetComputeResourceId());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetComputeResourceId()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.computeResourceId, other.computeResourceId);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetQueueName(), other.isSetQueueName());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetQueueName()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.queueName, other.queueName);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetNodeCount(), other.isSetNodeCount());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetNodeCount()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.nodeCount, other.nodeCount);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetCoreCount(), other.isSetCoreCount());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetCoreCount()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.coreCount, other.coreCount);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetWallTimeLimit(), other.isSetWallTimeLimit());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetWallTimeLimit()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.wallTimeLimit, other.wallTimeLimit);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetPhysicalMemory(), other.isSetPhysicalMemory());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetPhysicalMemory()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.physicalMemory, other.physicalMemory);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetStatuses(), 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 = java.lang.Boolean.compare(isSetErrors(), other.isSetErrors());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetErrors()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.errors, other.errors);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetCreatedAt(), other.isSetCreatedAt());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetCreatedAt()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.createdAt, other.createdAt);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = java.lang.Boolean.compare(isSetUpdatedAt(), other.isSetUpdatedAt());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetUpdatedAt()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.updatedAt, other.updatedAt);
if (lastComparison != 0) {
return lastComparison;
}
}
return 0;
}
@org.apache.thrift.annotation.Nullable
@Override
public _Fields fieldForId(int fieldId) {
return _Fields.findByThriftId(fieldId);
}
@Override
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
scheme(iprot).read(iprot, this);
}
@Override
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
scheme(oprot).write(oprot, this);
}
@Override
public java.lang.String toString() {
java.lang.StringBuilder sb = new java.lang.StringBuilder("WorkflowApplication(");
boolean first = true;
sb.append("id:");
if (this.id == null) {
sb.append("null");
} else {
sb.append(this.id);
}
first = false;
if (isSetProcessId()) {
if (!first) sb.append(", ");
sb.append("processId:");
if (this.processId == null) {
sb.append("null");
} else {
sb.append(this.processId);
}
first = false;
}
if (isSetApplicationInterfaceId()) {
if (!first) sb.append(", ");
sb.append("applicationInterfaceId:");
if (this.applicationInterfaceId == null) {
sb.append("null");
} else {
sb.append(this.applicationInterfaceId);
}
first = false;
}
if (isSetComputeResourceId()) {
if (!first) sb.append(", ");
sb.append("computeResourceId:");
if (this.computeResourceId == null) {
sb.append("null");
} else {
sb.append(this.computeResourceId);
}
first = false;
}
if (isSetQueueName()) {
if (!first) sb.append(", ");
sb.append("queueName:");
if (this.queueName == null) {
sb.append("null");
} else {
sb.append(this.queueName);
}
first = false;
}
if (isSetNodeCount()) {
if (!first) sb.append(", ");
sb.append("nodeCount:");
sb.append(this.nodeCount);
first = false;
}
if (isSetCoreCount()) {
if (!first) sb.append(", ");
sb.append("coreCount:");
sb.append(this.coreCount);
first = false;
}
if (isSetWallTimeLimit()) {
if (!first) sb.append(", ");
sb.append("wallTimeLimit:");
sb.append(this.wallTimeLimit);
first = false;
}
if (isSetPhysicalMemory()) {
if (!first) sb.append(", ");
sb.append("physicalMemory:");
sb.append(this.physicalMemory);
first = false;
}
if (isSetStatuses()) {
if (!first) sb.append(", ");
sb.append("statuses:");
if (this.statuses == null) {
sb.append("null");
} else {
sb.append(this.statuses);
}
first = false;
}
if (isSetErrors()) {
if (!first) sb.append(", ");
sb.append("errors:");
if (this.errors == null) {
sb.append("null");
} else {
sb.append(this.errors);
}
first = false;
}
if (isSetCreatedAt()) {
if (!first) sb.append(", ");
sb.append("createdAt:");
sb.append(this.createdAt);
first = false;
}
if (isSetUpdatedAt()) {
if (!first) sb.append(", ");
sb.append("updatedAt:");
sb.append(this.updatedAt);
first = false;
}
sb.append(")");
return sb.toString();
}
public void validate() throws org.apache.thrift.TException {
// check for required fields
if (!isSetId()) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'id' is unset! Struct:" + toString());
}
// check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
try {
write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
}
}
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.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 WorkflowApplicationStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
@Override
public WorkflowApplicationStandardScheme getScheme() {
return new WorkflowApplicationStandardScheme();
}
}
private static class WorkflowApplicationStandardScheme extends org.apache.thrift.scheme.StandardScheme<WorkflowApplication> {
@Override
public void read(org.apache.thrift.protocol.TProtocol iprot, WorkflowApplication 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: // ID
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.id = iprot.readString();
struct.setIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 2: // PROCESS_ID
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.processId = iprot.readString();
struct.setProcessIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // APPLICATION_INTERFACE_ID
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.applicationInterfaceId = iprot.readString();
struct.setApplicationInterfaceIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 4: // COMPUTE_RESOURCE_ID
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.computeResourceId = iprot.readString();
struct.setComputeResourceIdIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 5: // QUEUE_NAME
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.queueName = iprot.readString();
struct.setQueueNameIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 6: // NODE_COUNT
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.nodeCount = iprot.readI32();
struct.setNodeCountIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 7: // CORE_COUNT
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.coreCount = iprot.readI32();
struct.setCoreCountIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 8: // WALL_TIME_LIMIT
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.wallTimeLimit = iprot.readI32();
struct.setWallTimeLimitIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 9: // PHYSICAL_MEMORY
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
struct.physicalMemory = iprot.readI32();
struct.setPhysicalMemoryIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 10: // STATUSES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list0 = iprot.readListBegin();
struct.statuses = new java.util.ArrayList<ApplicationStatus>(_list0.size);
@org.apache.thrift.annotation.Nullable ApplicationStatus _elem1;
for (int _i2 = 0; _i2 < _list0.size; ++_i2)
{
_elem1 = new ApplicationStatus();
_elem1.read(iprot);
struct.statuses.add(_elem1);
}
iprot.readListEnd();
}
struct.setStatusesIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 11: // ERRORS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
org.apache.thrift.protocol.TList _list3 = iprot.readListBegin();
struct.errors = new java.util.ArrayList<org.apache.airavata.model.commons.ErrorModel>(_list3.size);
@org.apache.thrift.annotation.Nullable org.apache.airavata.model.commons.ErrorModel _elem4;
for (int _i5 = 0; _i5 < _list3.size; ++_i5)
{
_elem4 = new org.apache.airavata.model.commons.ErrorModel();
_elem4.read(iprot);
struct.errors.add(_elem4);
}
iprot.readListEnd();
}
struct.setErrorsIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 12: // CREATED_AT
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.createdAt = iprot.readI64();
struct.setCreatedAtIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 13: // UPDATED_AT
if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
struct.updatedAt = iprot.readI64();
struct.setUpdatedAtIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
iprot.readFieldEnd();
}
iprot.readStructEnd();
struct.validate();
}
@Override
public void write(org.apache.thrift.protocol.TProtocol oprot, WorkflowApplication struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
if (struct.id != null) {
oprot.writeFieldBegin(ID_FIELD_DESC);
oprot.writeString(struct.id);
oprot.writeFieldEnd();
}
if (struct.processId != null) {
if (struct.isSetProcessId()) {
oprot.writeFieldBegin(PROCESS_ID_FIELD_DESC);
oprot.writeString(struct.processId);
oprot.writeFieldEnd();
}
}
if (struct.applicationInterfaceId != null) {
if (struct.isSetApplicationInterfaceId()) {
oprot.writeFieldBegin(APPLICATION_INTERFACE_ID_FIELD_DESC);
oprot.writeString(struct.applicationInterfaceId);
oprot.writeFieldEnd();
}
}
if (struct.computeResourceId != null) {
if (struct.isSetComputeResourceId()) {
oprot.writeFieldBegin(COMPUTE_RESOURCE_ID_FIELD_DESC);
oprot.writeString(struct.computeResourceId);
oprot.writeFieldEnd();
}
}
if (struct.queueName != null) {
if (struct.isSetQueueName()) {
oprot.writeFieldBegin(QUEUE_NAME_FIELD_DESC);
oprot.writeString(struct.queueName);
oprot.writeFieldEnd();
}
}
if (struct.isSetNodeCount()) {
oprot.writeFieldBegin(NODE_COUNT_FIELD_DESC);
oprot.writeI32(struct.nodeCount);
oprot.writeFieldEnd();
}
if (struct.isSetCoreCount()) {
oprot.writeFieldBegin(CORE_COUNT_FIELD_DESC);
oprot.writeI32(struct.coreCount);
oprot.writeFieldEnd();
}
if (struct.isSetWallTimeLimit()) {
oprot.writeFieldBegin(WALL_TIME_LIMIT_FIELD_DESC);
oprot.writeI32(struct.wallTimeLimit);
oprot.writeFieldEnd();
}
if (struct.isSetPhysicalMemory()) {
oprot.writeFieldBegin(PHYSICAL_MEMORY_FIELD_DESC);
oprot.writeI32(struct.physicalMemory);
oprot.writeFieldEnd();
}
if (struct.statuses != null) {
if (struct.isSetStatuses()) {
oprot.writeFieldBegin(STATUSES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.statuses.size()));
for (ApplicationStatus _iter6 : struct.statuses)
{
_iter6.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.errors != null) {
if (struct.isSetErrors()) {
oprot.writeFieldBegin(ERRORS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.errors.size()));
for (org.apache.airavata.model.commons.ErrorModel _iter7 : struct.errors)
{
_iter7.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.isSetCreatedAt()) {
oprot.writeFieldBegin(CREATED_AT_FIELD_DESC);
oprot.writeI64(struct.createdAt);
oprot.writeFieldEnd();
}
if (struct.isSetUpdatedAt()) {
oprot.writeFieldBegin(UPDATED_AT_FIELD_DESC);
oprot.writeI64(struct.updatedAt);
oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
private static class WorkflowApplicationTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory {
@Override
public WorkflowApplicationTupleScheme getScheme() {
return new WorkflowApplicationTupleScheme();
}
}
private static class WorkflowApplicationTupleScheme extends org.apache.thrift.scheme.TupleScheme<WorkflowApplication> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, WorkflowApplication struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
oprot.writeString(struct.id);
java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetProcessId()) {
optionals.set(0);
}
if (struct.isSetApplicationInterfaceId()) {
optionals.set(1);
}
if (struct.isSetComputeResourceId()) {
optionals.set(2);
}
if (struct.isSetQueueName()) {
optionals.set(3);
}
if (struct.isSetNodeCount()) {
optionals.set(4);
}
if (struct.isSetCoreCount()) {
optionals.set(5);
}
if (struct.isSetWallTimeLimit()) {
optionals.set(6);
}
if (struct.isSetPhysicalMemory()) {
optionals.set(7);
}
if (struct.isSetStatuses()) {
optionals.set(8);
}
if (struct.isSetErrors()) {
optionals.set(9);
}
if (struct.isSetCreatedAt()) {
optionals.set(10);
}
if (struct.isSetUpdatedAt()) {
optionals.set(11);
}
oprot.writeBitSet(optionals, 12);
if (struct.isSetProcessId()) {
oprot.writeString(struct.processId);
}
if (struct.isSetApplicationInterfaceId()) {
oprot.writeString(struct.applicationInterfaceId);
}
if (struct.isSetComputeResourceId()) {
oprot.writeString(struct.computeResourceId);
}
if (struct.isSetQueueName()) {
oprot.writeString(struct.queueName);
}
if (struct.isSetNodeCount()) {
oprot.writeI32(struct.nodeCount);
}
if (struct.isSetCoreCount()) {
oprot.writeI32(struct.coreCount);
}
if (struct.isSetWallTimeLimit()) {
oprot.writeI32(struct.wallTimeLimit);
}
if (struct.isSetPhysicalMemory()) {
oprot.writeI32(struct.physicalMemory);
}
if (struct.isSetStatuses()) {
{
oprot.writeI32(struct.statuses.size());
for (ApplicationStatus _iter8 : struct.statuses)
{
_iter8.write(oprot);
}
}
}
if (struct.isSetErrors()) {
{
oprot.writeI32(struct.errors.size());
for (org.apache.airavata.model.commons.ErrorModel _iter9 : struct.errors)
{
_iter9.write(oprot);
}
}
}
if (struct.isSetCreatedAt()) {
oprot.writeI64(struct.createdAt);
}
if (struct.isSetUpdatedAt()) {
oprot.writeI64(struct.updatedAt);
}
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, WorkflowApplication struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot;
struct.id = iprot.readString();
struct.setIdIsSet(true);
java.util.BitSet incoming = iprot.readBitSet(12);
if (incoming.get(0)) {
struct.processId = iprot.readString();
struct.setProcessIdIsSet(true);
}
if (incoming.get(1)) {
struct.applicationInterfaceId = iprot.readString();
struct.setApplicationInterfaceIdIsSet(true);
}
if (incoming.get(2)) {
struct.computeResourceId = iprot.readString();
struct.setComputeResourceIdIsSet(true);
}
if (incoming.get(3)) {
struct.queueName = iprot.readString();
struct.setQueueNameIsSet(true);
}
if (incoming.get(4)) {
struct.nodeCount = iprot.readI32();
struct.setNodeCountIsSet(true);
}
if (incoming.get(5)) {
struct.coreCount = iprot.readI32();
struct.setCoreCountIsSet(true);
}
if (incoming.get(6)) {
struct.wallTimeLimit = iprot.readI32();
struct.setWallTimeLimitIsSet(true);
}
if (incoming.get(7)) {
struct.physicalMemory = iprot.readI32();
struct.setPhysicalMemoryIsSet(true);
}
if (incoming.get(8)) {
{
org.apache.thrift.protocol.TList _list10 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.statuses = new java.util.ArrayList<ApplicationStatus>(_list10.size);
@org.apache.thrift.annotation.Nullable ApplicationStatus _elem11;
for (int _i12 = 0; _i12 < _list10.size; ++_i12)
{
_elem11 = new ApplicationStatus();
_elem11.read(iprot);
struct.statuses.add(_elem11);
}
}
struct.setStatusesIsSet(true);
}
if (incoming.get(9)) {
{
org.apache.thrift.protocol.TList _list13 = iprot.readListBegin(org.apache.thrift.protocol.TType.STRUCT);
struct.errors = new java.util.ArrayList<org.apache.airavata.model.commons.ErrorModel>(_list13.size);
@org.apache.thrift.annotation.Nullable org.apache.airavata.model.commons.ErrorModel _elem14;
for (int _i15 = 0; _i15 < _list13.size; ++_i15)
{
_elem14 = new org.apache.airavata.model.commons.ErrorModel();
_elem14.read(iprot);
struct.errors.add(_elem14);
}
}
struct.setErrorsIsSet(true);
}
if (incoming.get(10)) {
struct.createdAt = iprot.readI64();
struct.setCreatedAtIsSet(true);
}
if (incoming.get(11)) {
struct.updatedAt = iprot.readI64();
struct.setUpdatedAtIsSet(true);
}
}
}
private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) {
return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme();
}
}