You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sh...@apache.org on 2015/06/13 01:16:31 UTC
[02/31] airavata git commit: generated new data model classes.
http://git-wip-us.apache.org/repos/asf/airavata/blob/51fa27b8/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/ValidatorResult.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/ValidatorResult.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/ValidatorResult.java
deleted file mode 100644
index 9655c4a..0000000
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/ValidatorResult.java
+++ /dev/null
@@ -1,521 +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.2)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-package org.apache.airavata.model.workspace.experiment;
-
-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"})
-/**
- * This data structure can be used to store the validation results
- * captured during validation step and during the launchExperiment
- * operation it can be easilly checked to see the errors occured
- * during the experiment launch operation
- *
- */
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-6-11")
-public class ValidatorResult implements org.apache.thrift.TBase<ValidatorResult, ValidatorResult._Fields>, java.io.Serializable, Cloneable, Comparable<ValidatorResult> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ValidatorResult");
-
- private static final org.apache.thrift.protocol.TField RESULT_FIELD_DESC = new org.apache.thrift.protocol.TField("result", org.apache.thrift.protocol.TType.BOOL, (short)1);
- private static final org.apache.thrift.protocol.TField ERROR_DETAILS_FIELD_DESC = new org.apache.thrift.protocol.TField("errorDetails", org.apache.thrift.protocol.TType.STRING, (short)2);
-
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new ValidatorResultStandardSchemeFactory());
- schemes.put(TupleScheme.class, new ValidatorResultTupleSchemeFactory());
- }
-
- private boolean result; // required
- private String errorDetails; // 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 {
- RESULT((short)1, "result"),
- ERROR_DETAILS((short)2, "errorDetails");
-
- 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: // RESULT
- return RESULT;
- case 2: // ERROR_DETAILS
- return ERROR_DETAILS;
- 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 __RESULT_ISSET_ID = 0;
- private byte __isset_bitfield = 0;
- private static final _Fields optionals[] = {_Fields.ERROR_DETAILS};
- 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.RESULT, new org.apache.thrift.meta_data.FieldMetaData("result", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
- tmpMap.put(_Fields.ERROR_DETAILS, new org.apache.thrift.meta_data.FieldMetaData("errorDetails", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ValidatorResult.class, metaDataMap);
- }
-
- public ValidatorResult() {
- }
-
- public ValidatorResult(
- boolean result)
- {
- this();
- this.result = result;
- setResultIsSet(true);
- }
-
- /**
- * Performs a deep copy on <i>other</i>.
- */
- public ValidatorResult(ValidatorResult other) {
- __isset_bitfield = other.__isset_bitfield;
- this.result = other.result;
- if (other.isSetErrorDetails()) {
- this.errorDetails = other.errorDetails;
- }
- }
-
- public ValidatorResult deepCopy() {
- return new ValidatorResult(this);
- }
-
- @Override
- public void clear() {
- setResultIsSet(false);
- this.result = false;
- this.errorDetails = null;
- }
-
- public boolean isResult() {
- return this.result;
- }
-
- public void setResult(boolean result) {
- this.result = result;
- setResultIsSet(true);
- }
-
- public void unsetResult() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __RESULT_ISSET_ID);
- }
-
- /** Returns true if field result is set (has been assigned a value) and false otherwise */
- public boolean isSetResult() {
- return EncodingUtils.testBit(__isset_bitfield, __RESULT_ISSET_ID);
- }
-
- public void setResultIsSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __RESULT_ISSET_ID, value);
- }
-
- public String getErrorDetails() {
- return this.errorDetails;
- }
-
- public void setErrorDetails(String errorDetails) {
- this.errorDetails = errorDetails;
- }
-
- public void unsetErrorDetails() {
- this.errorDetails = null;
- }
-
- /** Returns true if field errorDetails is set (has been assigned a value) and false otherwise */
- public boolean isSetErrorDetails() {
- return this.errorDetails != null;
- }
-
- public void setErrorDetailsIsSet(boolean value) {
- if (!value) {
- this.errorDetails = null;
- }
- }
-
- public void setFieldValue(_Fields field, Object value) {
- switch (field) {
- case RESULT:
- if (value == null) {
- unsetResult();
- } else {
- setResult((Boolean)value);
- }
- break;
-
- case ERROR_DETAILS:
- if (value == null) {
- unsetErrorDetails();
- } else {
- setErrorDetails((String)value);
- }
- break;
-
- }
- }
-
- public Object getFieldValue(_Fields field) {
- switch (field) {
- case RESULT:
- return Boolean.valueOf(isResult());
-
- case ERROR_DETAILS:
- return getErrorDetails();
-
- }
- 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 RESULT:
- return isSetResult();
- case ERROR_DETAILS:
- return isSetErrorDetails();
- }
- throw new IllegalStateException();
- }
-
- @Override
- public boolean equals(Object that) {
- if (that == null)
- return false;
- if (that instanceof ValidatorResult)
- return this.equals((ValidatorResult)that);
- return false;
- }
-
- public boolean equals(ValidatorResult that) {
- if (that == null)
- return false;
-
- boolean this_present_result = true;
- boolean that_present_result = true;
- if (this_present_result || that_present_result) {
- if (!(this_present_result && that_present_result))
- return false;
- if (this.result != that.result)
- return false;
- }
-
- boolean this_present_errorDetails = true && this.isSetErrorDetails();
- boolean that_present_errorDetails = true && that.isSetErrorDetails();
- if (this_present_errorDetails || that_present_errorDetails) {
- if (!(this_present_errorDetails && that_present_errorDetails))
- return false;
- if (!this.errorDetails.equals(that.errorDetails))
- return false;
- }
-
- return true;
- }
-
- @Override
- public int hashCode() {
- List<Object> list = new ArrayList<Object>();
-
- boolean present_result = true;
- list.add(present_result);
- if (present_result)
- list.add(result);
-
- boolean present_errorDetails = true && (isSetErrorDetails());
- list.add(present_errorDetails);
- if (present_errorDetails)
- list.add(errorDetails);
-
- return list.hashCode();
- }
-
- @Override
- public int compareTo(ValidatorResult other) {
- if (!getClass().equals(other.getClass())) {
- return getClass().getName().compareTo(other.getClass().getName());
- }
-
- int lastComparison = 0;
-
- lastComparison = Boolean.valueOf(isSetResult()).compareTo(other.isSetResult());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetResult()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.result, other.result);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetErrorDetails()).compareTo(other.isSetErrorDetails());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetErrorDetails()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.errorDetails, other.errorDetails);
- 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("ValidatorResult(");
- boolean first = true;
-
- sb.append("result:");
- sb.append(this.result);
- first = false;
- if (isSetErrorDetails()) {
- if (!first) sb.append(", ");
- sb.append("errorDetails:");
- if (this.errorDetails == null) {
- sb.append("null");
- } else {
- sb.append(this.errorDetails);
- }
- first = false;
- }
- sb.append(")");
- return sb.toString();
- }
-
- public void validate() throws org.apache.thrift.TException {
- // check for required fields
- if (!isSetResult()) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'result' is unset! Struct:" + toString());
- }
-
- // check for sub-struct validity
- }
-
- private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
- try {
- write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
- } catch (org.apache.thrift.TException te) {
- throw new java.io.IOException(te);
- }
- }
-
- private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
- try {
- // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
- __isset_bitfield = 0;
- read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
- } catch (org.apache.thrift.TException te) {
- throw new java.io.IOException(te);
- }
- }
-
- private static class ValidatorResultStandardSchemeFactory implements SchemeFactory {
- public ValidatorResultStandardScheme getScheme() {
- return new ValidatorResultStandardScheme();
- }
- }
-
- private static class ValidatorResultStandardScheme extends StandardScheme<ValidatorResult> {
-
- public void read(org.apache.thrift.protocol.TProtocol iprot, ValidatorResult 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: // RESULT
- if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
- struct.result = iprot.readBool();
- struct.setResultIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 2: // ERROR_DETAILS
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
- struct.errorDetails = iprot.readString();
- struct.setErrorDetailsIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- struct.validate();
- }
-
- public void write(org.apache.thrift.protocol.TProtocol oprot, ValidatorResult struct) throws org.apache.thrift.TException {
- struct.validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- oprot.writeFieldBegin(RESULT_FIELD_DESC);
- oprot.writeBool(struct.result);
- oprot.writeFieldEnd();
- if (struct.errorDetails != null) {
- if (struct.isSetErrorDetails()) {
- oprot.writeFieldBegin(ERROR_DETAILS_FIELD_DESC);
- oprot.writeString(struct.errorDetails);
- oprot.writeFieldEnd();
- }
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
- }
-
- }
-
- private static class ValidatorResultTupleSchemeFactory implements SchemeFactory {
- public ValidatorResultTupleScheme getScheme() {
- return new ValidatorResultTupleScheme();
- }
- }
-
- private static class ValidatorResultTupleScheme extends TupleScheme<ValidatorResult> {
-
- @Override
- public void write(org.apache.thrift.protocol.TProtocol prot, ValidatorResult struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- oprot.writeBool(struct.result);
- BitSet optionals = new BitSet();
- if (struct.isSetErrorDetails()) {
- optionals.set(0);
- }
- oprot.writeBitSet(optionals, 1);
- if (struct.isSetErrorDetails()) {
- oprot.writeString(struct.errorDetails);
- }
- }
-
- @Override
- public void read(org.apache.thrift.protocol.TProtocol prot, ValidatorResult struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- struct.result = iprot.readBool();
- struct.setResultIsSet(true);
- BitSet incoming = iprot.readBitSet(1);
- if (incoming.get(0)) {
- struct.errorDetails = iprot.readString();
- struct.setErrorDetailsIsSet(true);
- }
- }
- }
-
-}
-
http://git-wip-us.apache.org/repos/asf/airavata/blob/51fa27b8/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/WorkflowNodeDetails.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/WorkflowNodeDetails.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/WorkflowNodeDetails.java
deleted file mode 100644
index 2bc47a1..0000000
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/WorkflowNodeDetails.java
+++ /dev/null
@@ -1,1597 +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.2)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-package org.apache.airavata.model.workspace.experiment;
-
-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"})
-/**
- * A structure holding the node data.
- * nodeInstanceId - unique node identifier for each run
- */
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-6-11")
-public class WorkflowNodeDetails implements org.apache.thrift.TBase<WorkflowNodeDetails, WorkflowNodeDetails._Fields>, java.io.Serializable, Cloneable, Comparable<WorkflowNodeDetails> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WorkflowNodeDetails");
-
- private static final org.apache.thrift.protocol.TField NODE_INSTANCE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("nodeInstanceId", org.apache.thrift.protocol.TType.STRING, (short)1);
- private static final org.apache.thrift.protocol.TField CREATION_TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("creationTime", org.apache.thrift.protocol.TType.I64, (short)2);
- private static final org.apache.thrift.protocol.TField NODE_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("nodeName", org.apache.thrift.protocol.TType.STRING, (short)3);
- private static final org.apache.thrift.protocol.TField EXECUTION_UNIT_FIELD_DESC = new org.apache.thrift.protocol.TField("executionUnit", org.apache.thrift.protocol.TType.I32, (short)4);
- private static final org.apache.thrift.protocol.TField EXECUTION_UNIT_DATA_FIELD_DESC = new org.apache.thrift.protocol.TField("executionUnitData", org.apache.thrift.protocol.TType.STRING, (short)5);
- private static final org.apache.thrift.protocol.TField NODE_INPUTS_FIELD_DESC = new org.apache.thrift.protocol.TField("nodeInputs", org.apache.thrift.protocol.TType.LIST, (short)6);
- private static final org.apache.thrift.protocol.TField NODE_OUTPUTS_FIELD_DESC = new org.apache.thrift.protocol.TField("nodeOutputs", org.apache.thrift.protocol.TType.LIST, (short)7);
- private static final org.apache.thrift.protocol.TField WORKFLOW_NODE_STATUS_FIELD_DESC = new org.apache.thrift.protocol.TField("workflowNodeStatus", org.apache.thrift.protocol.TType.STRUCT, (short)8);
- private static final org.apache.thrift.protocol.TField TASK_DETAILS_LIST_FIELD_DESC = new org.apache.thrift.protocol.TField("taskDetailsList", org.apache.thrift.protocol.TType.LIST, (short)9);
- 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)10);
-
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new WorkflowNodeDetailsStandardSchemeFactory());
- schemes.put(TupleScheme.class, new WorkflowNodeDetailsTupleSchemeFactory());
- }
-
- private String nodeInstanceId; // required
- private long creationTime; // optional
- private String nodeName; // required
- private ExecutionUnit executionUnit; // required
- private String executionUnitData; // optional
- private List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType> nodeInputs; // optional
- private List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> nodeOutputs; // optional
- private WorkflowNodeStatus workflowNodeStatus; // optional
- private List<TaskDetails> taskDetailsList; // optional
- private List<ErrorDetails> errors; // 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 {
- NODE_INSTANCE_ID((short)1, "nodeInstanceId"),
- CREATION_TIME((short)2, "creationTime"),
- NODE_NAME((short)3, "nodeName"),
- /**
- *
- * @see ExecutionUnit
- */
- EXECUTION_UNIT((short)4, "executionUnit"),
- EXECUTION_UNIT_DATA((short)5, "executionUnitData"),
- NODE_INPUTS((short)6, "nodeInputs"),
- NODE_OUTPUTS((short)7, "nodeOutputs"),
- WORKFLOW_NODE_STATUS((short)8, "workflowNodeStatus"),
- TASK_DETAILS_LIST((short)9, "taskDetailsList"),
- ERRORS((short)10, "errors");
-
- 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: // NODE_INSTANCE_ID
- return NODE_INSTANCE_ID;
- case 2: // CREATION_TIME
- return CREATION_TIME;
- case 3: // NODE_NAME
- return NODE_NAME;
- case 4: // EXECUTION_UNIT
- return EXECUTION_UNIT;
- case 5: // EXECUTION_UNIT_DATA
- return EXECUTION_UNIT_DATA;
- case 6: // NODE_INPUTS
- return NODE_INPUTS;
- case 7: // NODE_OUTPUTS
- return NODE_OUTPUTS;
- case 8: // WORKFLOW_NODE_STATUS
- return WORKFLOW_NODE_STATUS;
- case 9: // TASK_DETAILS_LIST
- return TASK_DETAILS_LIST;
- case 10: // ERRORS
- return ERRORS;
- 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 __CREATIONTIME_ISSET_ID = 0;
- private byte __isset_bitfield = 0;
- private static final _Fields optionals[] = {_Fields.CREATION_TIME,_Fields.EXECUTION_UNIT_DATA,_Fields.NODE_INPUTS,_Fields.NODE_OUTPUTS,_Fields.WORKFLOW_NODE_STATUS,_Fields.TASK_DETAILS_LIST,_Fields.ERRORS};
- 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.NODE_INSTANCE_ID, new org.apache.thrift.meta_data.FieldMetaData("nodeInstanceId", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- tmpMap.put(_Fields.CREATION_TIME, new org.apache.thrift.meta_data.FieldMetaData("creationTime", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
- tmpMap.put(_Fields.NODE_NAME, new org.apache.thrift.meta_data.FieldMetaData("nodeName", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- tmpMap.put(_Fields.EXECUTION_UNIT, new org.apache.thrift.meta_data.FieldMetaData("executionUnit", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, ExecutionUnit.class)));
- tmpMap.put(_Fields.EXECUTION_UNIT_DATA, new org.apache.thrift.meta_data.FieldMetaData("executionUnitData", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- tmpMap.put(_Fields.NODE_INPUTS, new org.apache.thrift.meta_data.FieldMetaData("nodeInputs", 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.appcatalog.appinterface.InputDataObjectType.class))));
- tmpMap.put(_Fields.NODE_OUTPUTS, new org.apache.thrift.meta_data.FieldMetaData("nodeOutputs", 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.appcatalog.appinterface.OutputDataObjectType.class))));
- tmpMap.put(_Fields.WORKFLOW_NODE_STATUS, new org.apache.thrift.meta_data.FieldMetaData("workflowNodeStatus", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, WorkflowNodeStatus.class)));
- tmpMap.put(_Fields.TASK_DETAILS_LIST, new org.apache.thrift.meta_data.FieldMetaData("taskDetailsList", 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, TaskDetails.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, ErrorDetails.class))));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(WorkflowNodeDetails.class, metaDataMap);
- }
-
- public WorkflowNodeDetails() {
- this.nodeInstanceId = "DO_NOT_SET_AT_CLIENTS";
-
- this.nodeName = "SINGLE_APP_NODE";
-
- this.executionUnit = org.apache.airavata.model.workspace.experiment.ExecutionUnit.APPLICATION;
-
- }
-
- public WorkflowNodeDetails(
- String nodeInstanceId,
- String nodeName,
- ExecutionUnit executionUnit)
- {
- this();
- this.nodeInstanceId = nodeInstanceId;
- this.nodeName = nodeName;
- this.executionUnit = executionUnit;
- }
-
- /**
- * Performs a deep copy on <i>other</i>.
- */
- public WorkflowNodeDetails(WorkflowNodeDetails other) {
- __isset_bitfield = other.__isset_bitfield;
- if (other.isSetNodeInstanceId()) {
- this.nodeInstanceId = other.nodeInstanceId;
- }
- this.creationTime = other.creationTime;
- if (other.isSetNodeName()) {
- this.nodeName = other.nodeName;
- }
- if (other.isSetExecutionUnit()) {
- this.executionUnit = other.executionUnit;
- }
- if (other.isSetExecutionUnitData()) {
- this.executionUnitData = other.executionUnitData;
- }
- if (other.isSetNodeInputs()) {
- List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType> __this__nodeInputs = new ArrayList<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType>(other.nodeInputs.size());
- for (org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType other_element : other.nodeInputs) {
- __this__nodeInputs.add(new org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType(other_element));
- }
- this.nodeInputs = __this__nodeInputs;
- }
- if (other.isSetNodeOutputs()) {
- List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> __this__nodeOutputs = new ArrayList<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>(other.nodeOutputs.size());
- for (org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType other_element : other.nodeOutputs) {
- __this__nodeOutputs.add(new org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType(other_element));
- }
- this.nodeOutputs = __this__nodeOutputs;
- }
- if (other.isSetWorkflowNodeStatus()) {
- this.workflowNodeStatus = new WorkflowNodeStatus(other.workflowNodeStatus);
- }
- if (other.isSetTaskDetailsList()) {
- List<TaskDetails> __this__taskDetailsList = new ArrayList<TaskDetails>(other.taskDetailsList.size());
- for (TaskDetails other_element : other.taskDetailsList) {
- __this__taskDetailsList.add(new TaskDetails(other_element));
- }
- this.taskDetailsList = __this__taskDetailsList;
- }
- if (other.isSetErrors()) {
- List<ErrorDetails> __this__errors = new ArrayList<ErrorDetails>(other.errors.size());
- for (ErrorDetails other_element : other.errors) {
- __this__errors.add(new ErrorDetails(other_element));
- }
- this.errors = __this__errors;
- }
- }
-
- public WorkflowNodeDetails deepCopy() {
- return new WorkflowNodeDetails(this);
- }
-
- @Override
- public void clear() {
- this.nodeInstanceId = "DO_NOT_SET_AT_CLIENTS";
-
- setCreationTimeIsSet(false);
- this.creationTime = 0;
- this.nodeName = "SINGLE_APP_NODE";
-
- this.executionUnit = org.apache.airavata.model.workspace.experiment.ExecutionUnit.APPLICATION;
-
- this.executionUnitData = null;
- this.nodeInputs = null;
- this.nodeOutputs = null;
- this.workflowNodeStatus = null;
- this.taskDetailsList = null;
- this.errors = null;
- }
-
- public String getNodeInstanceId() {
- return this.nodeInstanceId;
- }
-
- public void setNodeInstanceId(String nodeInstanceId) {
- this.nodeInstanceId = nodeInstanceId;
- }
-
- public void unsetNodeInstanceId() {
- this.nodeInstanceId = null;
- }
-
- /** Returns true if field nodeInstanceId is set (has been assigned a value) and false otherwise */
- public boolean isSetNodeInstanceId() {
- return this.nodeInstanceId != null;
- }
-
- public void setNodeInstanceIdIsSet(boolean value) {
- if (!value) {
- this.nodeInstanceId = null;
- }
- }
-
- public long getCreationTime() {
- return this.creationTime;
- }
-
- public void setCreationTime(long creationTime) {
- this.creationTime = creationTime;
- setCreationTimeIsSet(true);
- }
-
- public void unsetCreationTime() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __CREATIONTIME_ISSET_ID);
- }
-
- /** Returns true if field creationTime is set (has been assigned a value) and false otherwise */
- public boolean isSetCreationTime() {
- return EncodingUtils.testBit(__isset_bitfield, __CREATIONTIME_ISSET_ID);
- }
-
- public void setCreationTimeIsSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __CREATIONTIME_ISSET_ID, value);
- }
-
- public String getNodeName() {
- return this.nodeName;
- }
-
- public void setNodeName(String nodeName) {
- this.nodeName = nodeName;
- }
-
- public void unsetNodeName() {
- this.nodeName = null;
- }
-
- /** Returns true if field nodeName is set (has been assigned a value) and false otherwise */
- public boolean isSetNodeName() {
- return this.nodeName != null;
- }
-
- public void setNodeNameIsSet(boolean value) {
- if (!value) {
- this.nodeName = null;
- }
- }
-
- /**
- *
- * @see ExecutionUnit
- */
- public ExecutionUnit getExecutionUnit() {
- return this.executionUnit;
- }
-
- /**
- *
- * @see ExecutionUnit
- */
- public void setExecutionUnit(ExecutionUnit executionUnit) {
- this.executionUnit = executionUnit;
- }
-
- public void unsetExecutionUnit() {
- this.executionUnit = null;
- }
-
- /** Returns true if field executionUnit is set (has been assigned a value) and false otherwise */
- public boolean isSetExecutionUnit() {
- return this.executionUnit != null;
- }
-
- public void setExecutionUnitIsSet(boolean value) {
- if (!value) {
- this.executionUnit = null;
- }
- }
-
- public String getExecutionUnitData() {
- return this.executionUnitData;
- }
-
- public void setExecutionUnitData(String executionUnitData) {
- this.executionUnitData = executionUnitData;
- }
-
- public void unsetExecutionUnitData() {
- this.executionUnitData = null;
- }
-
- /** Returns true if field executionUnitData is set (has been assigned a value) and false otherwise */
- public boolean isSetExecutionUnitData() {
- return this.executionUnitData != null;
- }
-
- public void setExecutionUnitDataIsSet(boolean value) {
- if (!value) {
- this.executionUnitData = null;
- }
- }
-
- public int getNodeInputsSize() {
- return (this.nodeInputs == null) ? 0 : this.nodeInputs.size();
- }
-
- public java.util.Iterator<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType> getNodeInputsIterator() {
- return (this.nodeInputs == null) ? null : this.nodeInputs.iterator();
- }
-
- public void addToNodeInputs(org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType elem) {
- if (this.nodeInputs == null) {
- this.nodeInputs = new ArrayList<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType>();
- }
- this.nodeInputs.add(elem);
- }
-
- public List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType> getNodeInputs() {
- return this.nodeInputs;
- }
-
- public void setNodeInputs(List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType> nodeInputs) {
- this.nodeInputs = nodeInputs;
- }
-
- public void unsetNodeInputs() {
- this.nodeInputs = null;
- }
-
- /** Returns true if field nodeInputs is set (has been assigned a value) and false otherwise */
- public boolean isSetNodeInputs() {
- return this.nodeInputs != null;
- }
-
- public void setNodeInputsIsSet(boolean value) {
- if (!value) {
- this.nodeInputs = null;
- }
- }
-
- public int getNodeOutputsSize() {
- return (this.nodeOutputs == null) ? 0 : this.nodeOutputs.size();
- }
-
- public java.util.Iterator<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> getNodeOutputsIterator() {
- return (this.nodeOutputs == null) ? null : this.nodeOutputs.iterator();
- }
-
- public void addToNodeOutputs(org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType elem) {
- if (this.nodeOutputs == null) {
- this.nodeOutputs = new ArrayList<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>();
- }
- this.nodeOutputs.add(elem);
- }
-
- public List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> getNodeOutputs() {
- return this.nodeOutputs;
- }
-
- public void setNodeOutputs(List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType> nodeOutputs) {
- this.nodeOutputs = nodeOutputs;
- }
-
- public void unsetNodeOutputs() {
- this.nodeOutputs = null;
- }
-
- /** Returns true if field nodeOutputs is set (has been assigned a value) and false otherwise */
- public boolean isSetNodeOutputs() {
- return this.nodeOutputs != null;
- }
-
- public void setNodeOutputsIsSet(boolean value) {
- if (!value) {
- this.nodeOutputs = null;
- }
- }
-
- public WorkflowNodeStatus getWorkflowNodeStatus() {
- return this.workflowNodeStatus;
- }
-
- public void setWorkflowNodeStatus(WorkflowNodeStatus workflowNodeStatus) {
- this.workflowNodeStatus = workflowNodeStatus;
- }
-
- public void unsetWorkflowNodeStatus() {
- this.workflowNodeStatus = null;
- }
-
- /** Returns true if field workflowNodeStatus is set (has been assigned a value) and false otherwise */
- public boolean isSetWorkflowNodeStatus() {
- return this.workflowNodeStatus != null;
- }
-
- public void setWorkflowNodeStatusIsSet(boolean value) {
- if (!value) {
- this.workflowNodeStatus = null;
- }
- }
-
- public int getTaskDetailsListSize() {
- return (this.taskDetailsList == null) ? 0 : this.taskDetailsList.size();
- }
-
- public java.util.Iterator<TaskDetails> getTaskDetailsListIterator() {
- return (this.taskDetailsList == null) ? null : this.taskDetailsList.iterator();
- }
-
- public void addToTaskDetailsList(TaskDetails elem) {
- if (this.taskDetailsList == null) {
- this.taskDetailsList = new ArrayList<TaskDetails>();
- }
- this.taskDetailsList.add(elem);
- }
-
- public List<TaskDetails> getTaskDetailsList() {
- return this.taskDetailsList;
- }
-
- public void setTaskDetailsList(List<TaskDetails> taskDetailsList) {
- this.taskDetailsList = taskDetailsList;
- }
-
- public void unsetTaskDetailsList() {
- this.taskDetailsList = null;
- }
-
- /** Returns true if field taskDetailsList is set (has been assigned a value) and false otherwise */
- public boolean isSetTaskDetailsList() {
- return this.taskDetailsList != null;
- }
-
- public void setTaskDetailsListIsSet(boolean value) {
- if (!value) {
- this.taskDetailsList = null;
- }
- }
-
- public int getErrorsSize() {
- return (this.errors == null) ? 0 : this.errors.size();
- }
-
- public java.util.Iterator<ErrorDetails> getErrorsIterator() {
- return (this.errors == null) ? null : this.errors.iterator();
- }
-
- public void addToErrors(ErrorDetails elem) {
- if (this.errors == null) {
- this.errors = new ArrayList<ErrorDetails>();
- }
- this.errors.add(elem);
- }
-
- public List<ErrorDetails> getErrors() {
- return this.errors;
- }
-
- public void setErrors(List<ErrorDetails> 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 void setFieldValue(_Fields field, Object value) {
- switch (field) {
- case NODE_INSTANCE_ID:
- if (value == null) {
- unsetNodeInstanceId();
- } else {
- setNodeInstanceId((String)value);
- }
- break;
-
- case CREATION_TIME:
- if (value == null) {
- unsetCreationTime();
- } else {
- setCreationTime((Long)value);
- }
- break;
-
- case NODE_NAME:
- if (value == null) {
- unsetNodeName();
- } else {
- setNodeName((String)value);
- }
- break;
-
- case EXECUTION_UNIT:
- if (value == null) {
- unsetExecutionUnit();
- } else {
- setExecutionUnit((ExecutionUnit)value);
- }
- break;
-
- case EXECUTION_UNIT_DATA:
- if (value == null) {
- unsetExecutionUnitData();
- } else {
- setExecutionUnitData((String)value);
- }
- break;
-
- case NODE_INPUTS:
- if (value == null) {
- unsetNodeInputs();
- } else {
- setNodeInputs((List<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType>)value);
- }
- break;
-
- case NODE_OUTPUTS:
- if (value == null) {
- unsetNodeOutputs();
- } else {
- setNodeOutputs((List<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>)value);
- }
- break;
-
- case WORKFLOW_NODE_STATUS:
- if (value == null) {
- unsetWorkflowNodeStatus();
- } else {
- setWorkflowNodeStatus((WorkflowNodeStatus)value);
- }
- break;
-
- case TASK_DETAILS_LIST:
- if (value == null) {
- unsetTaskDetailsList();
- } else {
- setTaskDetailsList((List<TaskDetails>)value);
- }
- break;
-
- case ERRORS:
- if (value == null) {
- unsetErrors();
- } else {
- setErrors((List<ErrorDetails>)value);
- }
- break;
-
- }
- }
-
- public Object getFieldValue(_Fields field) {
- switch (field) {
- case NODE_INSTANCE_ID:
- return getNodeInstanceId();
-
- case CREATION_TIME:
- return Long.valueOf(getCreationTime());
-
- case NODE_NAME:
- return getNodeName();
-
- case EXECUTION_UNIT:
- return getExecutionUnit();
-
- case EXECUTION_UNIT_DATA:
- return getExecutionUnitData();
-
- case NODE_INPUTS:
- return getNodeInputs();
-
- case NODE_OUTPUTS:
- return getNodeOutputs();
-
- case WORKFLOW_NODE_STATUS:
- return getWorkflowNodeStatus();
-
- case TASK_DETAILS_LIST:
- return getTaskDetailsList();
-
- case ERRORS:
- return getErrors();
-
- }
- 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 NODE_INSTANCE_ID:
- return isSetNodeInstanceId();
- case CREATION_TIME:
- return isSetCreationTime();
- case NODE_NAME:
- return isSetNodeName();
- case EXECUTION_UNIT:
- return isSetExecutionUnit();
- case EXECUTION_UNIT_DATA:
- return isSetExecutionUnitData();
- case NODE_INPUTS:
- return isSetNodeInputs();
- case NODE_OUTPUTS:
- return isSetNodeOutputs();
- case WORKFLOW_NODE_STATUS:
- return isSetWorkflowNodeStatus();
- case TASK_DETAILS_LIST:
- return isSetTaskDetailsList();
- case ERRORS:
- return isSetErrors();
- }
- throw new IllegalStateException();
- }
-
- @Override
- public boolean equals(Object that) {
- if (that == null)
- return false;
- if (that instanceof WorkflowNodeDetails)
- return this.equals((WorkflowNodeDetails)that);
- return false;
- }
-
- public boolean equals(WorkflowNodeDetails that) {
- if (that == null)
- return false;
-
- boolean this_present_nodeInstanceId = true && this.isSetNodeInstanceId();
- boolean that_present_nodeInstanceId = true && that.isSetNodeInstanceId();
- if (this_present_nodeInstanceId || that_present_nodeInstanceId) {
- if (!(this_present_nodeInstanceId && that_present_nodeInstanceId))
- return false;
- if (!this.nodeInstanceId.equals(that.nodeInstanceId))
- return false;
- }
-
- boolean this_present_creationTime = true && this.isSetCreationTime();
- boolean that_present_creationTime = true && that.isSetCreationTime();
- if (this_present_creationTime || that_present_creationTime) {
- if (!(this_present_creationTime && that_present_creationTime))
- return false;
- if (this.creationTime != that.creationTime)
- return false;
- }
-
- boolean this_present_nodeName = true && this.isSetNodeName();
- boolean that_present_nodeName = true && that.isSetNodeName();
- if (this_present_nodeName || that_present_nodeName) {
- if (!(this_present_nodeName && that_present_nodeName))
- return false;
- if (!this.nodeName.equals(that.nodeName))
- return false;
- }
-
- boolean this_present_executionUnit = true && this.isSetExecutionUnit();
- boolean that_present_executionUnit = true && that.isSetExecutionUnit();
- if (this_present_executionUnit || that_present_executionUnit) {
- if (!(this_present_executionUnit && that_present_executionUnit))
- return false;
- if (!this.executionUnit.equals(that.executionUnit))
- return false;
- }
-
- boolean this_present_executionUnitData = true && this.isSetExecutionUnitData();
- boolean that_present_executionUnitData = true && that.isSetExecutionUnitData();
- if (this_present_executionUnitData || that_present_executionUnitData) {
- if (!(this_present_executionUnitData && that_present_executionUnitData))
- return false;
- if (!this.executionUnitData.equals(that.executionUnitData))
- return false;
- }
-
- boolean this_present_nodeInputs = true && this.isSetNodeInputs();
- boolean that_present_nodeInputs = true && that.isSetNodeInputs();
- if (this_present_nodeInputs || that_present_nodeInputs) {
- if (!(this_present_nodeInputs && that_present_nodeInputs))
- return false;
- if (!this.nodeInputs.equals(that.nodeInputs))
- return false;
- }
-
- boolean this_present_nodeOutputs = true && this.isSetNodeOutputs();
- boolean that_present_nodeOutputs = true && that.isSetNodeOutputs();
- if (this_present_nodeOutputs || that_present_nodeOutputs) {
- if (!(this_present_nodeOutputs && that_present_nodeOutputs))
- return false;
- if (!this.nodeOutputs.equals(that.nodeOutputs))
- return false;
- }
-
- boolean this_present_workflowNodeStatus = true && this.isSetWorkflowNodeStatus();
- boolean that_present_workflowNodeStatus = true && that.isSetWorkflowNodeStatus();
- if (this_present_workflowNodeStatus || that_present_workflowNodeStatus) {
- if (!(this_present_workflowNodeStatus && that_present_workflowNodeStatus))
- return false;
- if (!this.workflowNodeStatus.equals(that.workflowNodeStatus))
- return false;
- }
-
- boolean this_present_taskDetailsList = true && this.isSetTaskDetailsList();
- boolean that_present_taskDetailsList = true && that.isSetTaskDetailsList();
- if (this_present_taskDetailsList || that_present_taskDetailsList) {
- if (!(this_present_taskDetailsList && that_present_taskDetailsList))
- return false;
- if (!this.taskDetailsList.equals(that.taskDetailsList))
- 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;
- }
-
- return true;
- }
-
- @Override
- public int hashCode() {
- List<Object> list = new ArrayList<Object>();
-
- boolean present_nodeInstanceId = true && (isSetNodeInstanceId());
- list.add(present_nodeInstanceId);
- if (present_nodeInstanceId)
- list.add(nodeInstanceId);
-
- boolean present_creationTime = true && (isSetCreationTime());
- list.add(present_creationTime);
- if (present_creationTime)
- list.add(creationTime);
-
- boolean present_nodeName = true && (isSetNodeName());
- list.add(present_nodeName);
- if (present_nodeName)
- list.add(nodeName);
-
- boolean present_executionUnit = true && (isSetExecutionUnit());
- list.add(present_executionUnit);
- if (present_executionUnit)
- list.add(executionUnit.getValue());
-
- boolean present_executionUnitData = true && (isSetExecutionUnitData());
- list.add(present_executionUnitData);
- if (present_executionUnitData)
- list.add(executionUnitData);
-
- boolean present_nodeInputs = true && (isSetNodeInputs());
- list.add(present_nodeInputs);
- if (present_nodeInputs)
- list.add(nodeInputs);
-
- boolean present_nodeOutputs = true && (isSetNodeOutputs());
- list.add(present_nodeOutputs);
- if (present_nodeOutputs)
- list.add(nodeOutputs);
-
- boolean present_workflowNodeStatus = true && (isSetWorkflowNodeStatus());
- list.add(present_workflowNodeStatus);
- if (present_workflowNodeStatus)
- list.add(workflowNodeStatus);
-
- boolean present_taskDetailsList = true && (isSetTaskDetailsList());
- list.add(present_taskDetailsList);
- if (present_taskDetailsList)
- list.add(taskDetailsList);
-
- boolean present_errors = true && (isSetErrors());
- list.add(present_errors);
- if (present_errors)
- list.add(errors);
-
- return list.hashCode();
- }
-
- @Override
- public int compareTo(WorkflowNodeDetails other) {
- if (!getClass().equals(other.getClass())) {
- return getClass().getName().compareTo(other.getClass().getName());
- }
-
- int lastComparison = 0;
-
- lastComparison = Boolean.valueOf(isSetNodeInstanceId()).compareTo(other.isSetNodeInstanceId());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetNodeInstanceId()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.nodeInstanceId, other.nodeInstanceId);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetCreationTime()).compareTo(other.isSetCreationTime());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetCreationTime()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.creationTime, other.creationTime);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetNodeName()).compareTo(other.isSetNodeName());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetNodeName()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.nodeName, other.nodeName);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetExecutionUnit()).compareTo(other.isSetExecutionUnit());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetExecutionUnit()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.executionUnit, other.executionUnit);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetExecutionUnitData()).compareTo(other.isSetExecutionUnitData());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetExecutionUnitData()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.executionUnitData, other.executionUnitData);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetNodeInputs()).compareTo(other.isSetNodeInputs());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetNodeInputs()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.nodeInputs, other.nodeInputs);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetNodeOutputs()).compareTo(other.isSetNodeOutputs());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetNodeOutputs()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.nodeOutputs, other.nodeOutputs);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetWorkflowNodeStatus()).compareTo(other.isSetWorkflowNodeStatus());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetWorkflowNodeStatus()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.workflowNodeStatus, other.workflowNodeStatus);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetTaskDetailsList()).compareTo(other.isSetTaskDetailsList());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetTaskDetailsList()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.taskDetailsList, other.taskDetailsList);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetErrors()).compareTo(other.isSetErrors());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetErrors()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.errors, other.errors);
- 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("WorkflowNodeDetails(");
- boolean first = true;
-
- sb.append("nodeInstanceId:");
- if (this.nodeInstanceId == null) {
- sb.append("null");
- } else {
- sb.append(this.nodeInstanceId);
- }
- first = false;
- if (isSetCreationTime()) {
- if (!first) sb.append(", ");
- sb.append("creationTime:");
- sb.append(this.creationTime);
- first = false;
- }
- if (!first) sb.append(", ");
- sb.append("nodeName:");
- if (this.nodeName == null) {
- sb.append("null");
- } else {
- sb.append(this.nodeName);
- }
- first = false;
- if (!first) sb.append(", ");
- sb.append("executionUnit:");
- if (this.executionUnit == null) {
- sb.append("null");
- } else {
- sb.append(this.executionUnit);
- }
- first = false;
- if (isSetExecutionUnitData()) {
- if (!first) sb.append(", ");
- sb.append("executionUnitData:");
- if (this.executionUnitData == null) {
- sb.append("null");
- } else {
- sb.append(this.executionUnitData);
- }
- first = false;
- }
- if (isSetNodeInputs()) {
- if (!first) sb.append(", ");
- sb.append("nodeInputs:");
- if (this.nodeInputs == null) {
- sb.append("null");
- } else {
- sb.append(this.nodeInputs);
- }
- first = false;
- }
- if (isSetNodeOutputs()) {
- if (!first) sb.append(", ");
- sb.append("nodeOutputs:");
- if (this.nodeOutputs == null) {
- sb.append("null");
- } else {
- sb.append(this.nodeOutputs);
- }
- first = false;
- }
- if (isSetWorkflowNodeStatus()) {
- if (!first) sb.append(", ");
- sb.append("workflowNodeStatus:");
- if (this.workflowNodeStatus == null) {
- sb.append("null");
- } else {
- sb.append(this.workflowNodeStatus);
- }
- first = false;
- }
- if (isSetTaskDetailsList()) {
- if (!first) sb.append(", ");
- sb.append("taskDetailsList:");
- if (this.taskDetailsList == null) {
- sb.append("null");
- } else {
- sb.append(this.taskDetailsList);
- }
- 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;
- }
- sb.append(")");
- return sb.toString();
- }
-
- public void validate() throws org.apache.thrift.TException {
- // check for required fields
- if (!isSetNodeInstanceId()) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'nodeInstanceId' is unset! Struct:" + toString());
- }
-
- if (!isSetNodeName()) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'nodeName' is unset! Struct:" + toString());
- }
-
- if (!isSetExecutionUnit()) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'executionUnit' is unset! Struct:" + toString());
- }
-
- // check for sub-struct validity
- if (workflowNodeStatus != null) {
- workflowNodeStatus.validate();
- }
- }
-
- private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
- try {
- write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
- } catch (org.apache.thrift.TException te) {
- throw new java.io.IOException(te);
- }
- }
-
- private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
- try {
- // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
- __isset_bitfield = 0;
- read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
- } catch (org.apache.thrift.TException te) {
- throw new java.io.IOException(te);
- }
- }
-
- private static class WorkflowNodeDetailsStandardSchemeFactory implements SchemeFactory {
- public WorkflowNodeDetailsStandardScheme getScheme() {
- return new WorkflowNodeDetailsStandardScheme();
- }
- }
-
- private static class WorkflowNodeDetailsStandardScheme extends StandardScheme<WorkflowNodeDetails> {
-
- public void read(org.apache.thrift.protocol.TProtocol iprot, WorkflowNodeDetails 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: // NODE_INSTANCE_ID
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
- struct.nodeInstanceId = iprot.readString();
- struct.setNodeInstanceIdIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 2: // CREATION_TIME
- if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
- struct.creationTime = iprot.readI64();
- struct.setCreationTimeIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 3: // NODE_NAME
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
- struct.nodeName = iprot.readString();
- struct.setNodeNameIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 4: // EXECUTION_UNIT
- if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
- struct.executionUnit = org.apache.airavata.model.workspace.experiment.ExecutionUnit.findByValue(iprot.readI32());
- struct.setExecutionUnitIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 5: // EXECUTION_UNIT_DATA
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
- struct.executionUnitData = iprot.readString();
- struct.setExecutionUnitDataIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 6: // NODE_INPUTS
- if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
- {
- org.apache.thrift.protocol.TList _list64 = iprot.readListBegin();
- struct.nodeInputs = new ArrayList<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType>(_list64.size);
- org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType _elem65;
- for (int _i66 = 0; _i66 < _list64.size; ++_i66)
- {
- _elem65 = new org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType();
- _elem65.read(iprot);
- struct.nodeInputs.add(_elem65);
- }
- iprot.readListEnd();
- }
- struct.setNodeInputsIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 7: // NODE_OUTPUTS
- if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
- {
- org.apache.thrift.protocol.TList _list67 = iprot.readListBegin();
- struct.nodeOutputs = new ArrayList<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>(_list67.size);
- org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType _elem68;
- for (int _i69 = 0; _i69 < _list67.size; ++_i69)
- {
- _elem68 = new org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType();
- _elem68.read(iprot);
- struct.nodeOutputs.add(_elem68);
- }
- iprot.readListEnd();
- }
- struct.setNodeOutputsIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 8: // WORKFLOW_NODE_STATUS
- if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
- struct.workflowNodeStatus = new WorkflowNodeStatus();
- struct.workflowNodeStatus.read(iprot);
- struct.setWorkflowNodeStatusIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 9: // TASK_DETAILS_LIST
- if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
- {
- org.apache.thrift.protocol.TList _list70 = iprot.readListBegin();
- struct.taskDetailsList = new ArrayList<TaskDetails>(_list70.size);
- TaskDetails _elem71;
- for (int _i72 = 0; _i72 < _list70.size; ++_i72)
- {
- _elem71 = new TaskDetails();
- _elem71.read(iprot);
- struct.taskDetailsList.add(_elem71);
- }
- iprot.readListEnd();
- }
- struct.setTaskDetailsListIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 10: // ERRORS
- if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
- {
- org.apache.thrift.protocol.TList _list73 = iprot.readListBegin();
- struct.errors = new ArrayList<ErrorDetails>(_list73.size);
- ErrorDetails _elem74;
- for (int _i75 = 0; _i75 < _list73.size; ++_i75)
- {
- _elem74 = new ErrorDetails();
- _elem74.read(iprot);
- struct.errors.add(_elem74);
- }
- iprot.readListEnd();
- }
- struct.setErrorsIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- struct.validate();
- }
-
- public void write(org.apache.thrift.protocol.TProtocol oprot, WorkflowNodeDetails struct) throws org.apache.thrift.TException {
- struct.validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (struct.nodeInstanceId != null) {
- oprot.writeFieldBegin(NODE_INSTANCE_ID_FIELD_DESC);
- oprot.writeString(struct.nodeInstanceId);
- oprot.writeFieldEnd();
- }
- if (struct.isSetCreationTime()) {
- oprot.writeFieldBegin(CREATION_TIME_FIELD_DESC);
- oprot.writeI64(struct.creationTime);
- oprot.writeFieldEnd();
- }
- if (struct.nodeName != null) {
- oprot.writeFieldBegin(NODE_NAME_FIELD_DESC);
- oprot.writeString(struct.nodeName);
- oprot.writeFieldEnd();
- }
- if (struct.executionUnit != null) {
- oprot.writeFieldBegin(EXECUTION_UNIT_FIELD_DESC);
- oprot.writeI32(struct.executionUnit.getValue());
- oprot.writeFieldEnd();
- }
- if (struct.executionUnitData != null) {
- if (struct.isSetExecutionUnitData()) {
- oprot.writeFieldBegin(EXECUTION_UNIT_DATA_FIELD_DESC);
- oprot.writeString(struct.executionUnitData);
- oprot.writeFieldEnd();
- }
- }
- if (struct.nodeInputs != null) {
- if (struct.isSetNodeInputs()) {
- oprot.writeFieldBegin(NODE_INPUTS_FIELD_DESC);
- {
- oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.nodeInputs.size()));
- for (org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType _iter76 : struct.nodeInputs)
- {
- _iter76.write(oprot);
- }
- oprot.writeListEnd();
- }
- oprot.writeFieldEnd();
- }
- }
- if (struct.nodeOutputs != null) {
- if (struct.isSetNodeOutputs()) {
- oprot.writeFieldBegin(NODE_OUTPUTS_FIELD_DESC);
- {
- oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.nodeOutputs.size()));
- for (org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType _iter77 : struct.nodeOutputs)
- {
- _iter77.write(oprot);
- }
- oprot.writeListEnd();
- }
- oprot.writeFieldEnd();
- }
- }
- if (struct.workflowNodeStatus != null) {
- if (struct.isSetWorkflowNodeStatus()) {
- oprot.writeFieldBegin(WORKFLOW_NODE_STATUS_FIELD_DESC);
- struct.workflowNodeStatus.write(oprot);
- oprot.writeFieldEnd();
- }
- }
- if (struct.taskDetailsList != null) {
- if (struct.isSetTaskDetailsList()) {
- oprot.writeFieldBegin(TASK_DETAILS_LIST_FIELD_DESC);
- {
- oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.taskDetailsList.size()));
- for (TaskDetails _iter78 : struct.taskDetailsList)
- {
- _iter78.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 (ErrorDetails _iter79 : struct.errors)
- {
- _iter79.write(oprot);
- }
- oprot.writeListEnd();
- }
- oprot.writeFieldEnd();
- }
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
- }
-
- }
-
- private static class WorkflowNodeDetailsTupleSchemeFactory implements SchemeFactory {
- public WorkflowNodeDetailsTupleScheme getScheme() {
- return new WorkflowNodeDetailsTupleScheme();
- }
- }
-
- private static class WorkflowNodeDetailsTupleScheme extends TupleScheme<WorkflowNodeDetails> {
-
- @Override
- public void write(org.apache.thrift.protocol.TProtocol prot, WorkflowNodeDetails struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- oprot.writeString(struct.nodeInstanceId);
- oprot.writeString(struct.nodeName);
- oprot.writeI32(struct.executionUnit.getValue());
- BitSet optionals = new BitSet();
- if (struct.isSetCreationTime()) {
- optionals.set(0);
- }
- if (struct.isSetExecutionUnitData()) {
- optionals.set(1);
- }
- if (struct.isSetNodeInputs()) {
- optionals.set(2);
- }
- if (struct.isSetNodeOutputs()) {
- optionals.set(3);
- }
- if (struct.isSetWorkflowNodeStatus()) {
- optionals.set(4);
- }
- if (struct.isSetTaskDetailsList()) {
- optionals.set(5);
- }
- if (struct.isSetErrors()) {
- optionals.set(6);
- }
- oprot.writeBitSet(optionals, 7);
- if (struct.isSetCreationTime()) {
- oprot.writeI64(struct.creationTime);
- }
- if (struct.isSetExecutionUnitData()) {
- oprot.writeString(struct.executionUnitData);
- }
- if (struct.isSetNodeInputs()) {
- {
- oprot.writeI32(struct.nodeInputs.size());
- for (org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType _iter80 : struct.nodeInputs)
- {
- _iter80.write(oprot);
- }
- }
- }
- if (struct.isSetNodeOutputs()) {
- {
- oprot.writeI32(struct.nodeOutputs.size());
- for (org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType _iter81 : struct.nodeOutputs)
- {
- _iter81.write(oprot);
- }
- }
- }
- if (struct.isSetWorkflowNodeStatus()) {
- struct.workflowNodeStatus.write(oprot);
- }
- if (struct.isSetTaskDetailsList()) {
- {
- oprot.writeI32(struct.taskDetailsList.size());
- for (TaskDetails _iter82 : struct.taskDetailsList)
- {
- _iter82.write(oprot);
- }
- }
- }
- if (struct.isSetErrors()) {
- {
- oprot.writeI32(struct.errors.size());
- for (ErrorDetails _iter83 : struct.errors)
- {
- _iter83.write(oprot);
- }
- }
- }
- }
-
- @Override
- public void read(org.apache.thrift.protocol.TProtocol prot, WorkflowNodeDetails struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- struct.nodeInstanceId = iprot.readString();
- struct.setNodeInstanceIdIsSet(true);
- struct.nodeName = iprot.readString();
- struct.setNodeNameIsSet(true);
- struct.executionUnit = org.apache.airavata.model.workspace.experiment.ExecutionUnit.findByValue(iprot.readI32());
- struct.setExecutionUnitIsSet(true);
- BitSet incoming = iprot.readBitSet(7);
- if (incoming.get(0)) {
- struct.creationTime = iprot.readI64();
- struct.setCreationTimeIsSet(true);
- }
- if (incoming.get(1)) {
- struct.executionUnitData = iprot.readString();
- struct.setExecutionUnitDataIsSet(true);
- }
- if (incoming.get(2)) {
- {
- org.apache.thrift.protocol.TList _list84 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.nodeInputs = new ArrayList<org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType>(_list84.size);
- org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType _elem85;
- for (int _i86 = 0; _i86 < _list84.size; ++_i86)
- {
- _elem85 = new org.apache.airavata.model.appcatalog.appinterface.InputDataObjectType();
- _elem85.read(iprot);
- struct.nodeInputs.add(_elem85);
- }
- }
- struct.setNodeInputsIsSet(true);
- }
- if (incoming.get(3)) {
- {
- org.apache.thrift.protocol.TList _list87 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.nodeOutputs = new ArrayList<org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType>(_list87.size);
- org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType _elem88;
- for (int _i89 = 0; _i89 < _list87.size; ++_i89)
- {
- _elem88 = new org.apache.airavata.model.appcatalog.appinterface.OutputDataObjectType();
- _elem88.read(iprot);
- struct.nodeOutputs.add(_elem88);
- }
- }
- struct.setNodeOutputsIsSet(true);
- }
- if (incoming.get(4)) {
- struct.workflowNodeStatus = new WorkflowNodeStatus();
- struct.workflowNodeStatus.read(iprot);
- struct.setWorkflowNodeStatusIsSet(true);
- }
- if (incoming.get(5)) {
- {
- org.apache.thrift.protocol.TList _list90 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.taskDetailsList = new ArrayList<TaskDetails>(_list90.size);
- TaskDetails _elem91;
- for (int _i92 = 0; _i92 < _list90.size; ++_i92)
- {
- _elem91 = new TaskDetails();
- _elem91.read(iprot);
- struct.taskDetailsList.add(_elem91);
- }
- }
- struct.setTaskDetailsListIsSet(true);
- }
- if (incoming.get(6)) {
- {
- org.apache.thrift.protocol.TList _list93 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.errors = new ArrayList<ErrorDetails>(_list93.size);
- ErrorDetails _elem94;
- for (int _i95 = 0; _i95 < _list93.size; ++_i95)
- {
- _elem94 = new ErrorDetails();
- _elem94.read(iprot);
- struct.errors.add(_elem94);
- }
- }
- struct.setErrorsIsSet(true);
- }
- }
- }
-
-}
-
http://git-wip-us.apache.org/repos/asf/airavata/blob/51fa27b8/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/WorkflowNodeState.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/WorkflowNodeState.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/WorkflowNodeState.java
deleted file mode 100644
index 88182e2..0000000
--- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/WorkflowNodeState.java
+++ /dev/null
@@ -1,80 +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.2)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-package org.apache.airavata.model.workspace.experiment;
-
-
-import java.util.Map;
-import java.util.HashMap;
-import org.apache.thrift.TEnum;
-
-public enum WorkflowNodeState implements org.apache.thrift.TEnum {
- INVOKED(0),
- EXECUTING(1),
- CANCELING(2),
- CANCELED(3),
- SUSPENDED(4),
- COMPLETED(5),
- FAILED(6),
- UNKNOWN(7);
-
- private final int value;
-
- private WorkflowNodeState(int value) {
- this.value = value;
- }
-
- /**
- * Get the integer value of this enum value, as defined in the Thrift IDL.
- */
- public int getValue() {
- return value;
- }
-
- /**
- * Find a the enum type by its integer value, as defined in the Thrift IDL.
- * @return null if the value is not found.
- */
- public static WorkflowNodeState findByValue(int value) {
- switch (value) {
- case 0:
- return INVOKED;
- case 1:
- return EXECUTING;
- case 2:
- return CANCELING;
- case 3:
- return CANCELED;
- case 4:
- return SUSPENDED;
- case 5:
- return COMPLETED;
- case 6:
- return FAILED;
- case 7:
- return UNKNOWN;
- default:
- return null;
- }
- }
-}