Return-Path: X-Original-To: apmail-airavata-commits-archive@www.apache.org Delivered-To: apmail-airavata-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 256D118586 for ; Fri, 12 Jun 2015 23:16:32 +0000 (UTC) Received: (qmail 5480 invoked by uid 500); 12 Jun 2015 23:16:32 -0000 Delivered-To: apmail-airavata-commits-archive@airavata.apache.org Received: (qmail 5441 invoked by uid 500); 12 Jun 2015 23:16:32 -0000 Mailing-List: contact commits-help@airavata.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airavata.apache.org Delivered-To: mailing list commits@airavata.apache.org Received: (qmail 5355 invoked by uid 99); 12 Jun 2015 23:16:32 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 12 Jun 2015 23:16:32 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id E2B60E005D; Fri, 12 Jun 2015 23:16:31 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: shameera@apache.org To: commits@airavata.apache.org Date: Fri, 12 Jun 2015 23:16:41 -0000 Message-Id: In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [12/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/AdvancedInputDataHandling.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/AdvancedInputDataHandling.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/AdvancedInputDataHandling.java deleted file mode 100644 index bd3549b..0000000 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/AdvancedInputDataHandling.java +++ /dev/null @@ -1,726 +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 specified input data handling. - * - */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-6-11") -public class AdvancedInputDataHandling implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AdvancedInputDataHandling"); - - private static final org.apache.thrift.protocol.TField STAGE_INPUT_FILES_TO_WORKING_DIR_FIELD_DESC = new org.apache.thrift.protocol.TField("stageInputFilesToWorkingDir", org.apache.thrift.protocol.TType.BOOL, (short)1); - private static final org.apache.thrift.protocol.TField PARENT_WORKING_DIRECTORY_FIELD_DESC = new org.apache.thrift.protocol.TField("parentWorkingDirectory", org.apache.thrift.protocol.TType.STRING, (short)2); - private static final org.apache.thrift.protocol.TField UNIQUE_WORKING_DIRECTORY_FIELD_DESC = new org.apache.thrift.protocol.TField("uniqueWorkingDirectory", org.apache.thrift.protocol.TType.STRING, (short)3); - private static final org.apache.thrift.protocol.TField CLEAN_UP_WORKING_DIR_AFTER_JOB_FIELD_DESC = new org.apache.thrift.protocol.TField("cleanUpWorkingDirAfterJob", org.apache.thrift.protocol.TType.BOOL, (short)4); - - private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new AdvancedInputDataHandlingStandardSchemeFactory()); - schemes.put(TupleScheme.class, new AdvancedInputDataHandlingTupleSchemeFactory()); - } - - private boolean stageInputFilesToWorkingDir; // optional - private String parentWorkingDirectory; // optional - private String uniqueWorkingDirectory; // optional - private boolean cleanUpWorkingDirAfterJob; // 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 { - STAGE_INPUT_FILES_TO_WORKING_DIR((short)1, "stageInputFilesToWorkingDir"), - PARENT_WORKING_DIRECTORY((short)2, "parentWorkingDirectory"), - UNIQUE_WORKING_DIRECTORY((short)3, "uniqueWorkingDirectory"), - CLEAN_UP_WORKING_DIR_AFTER_JOB((short)4, "cleanUpWorkingDirAfterJob"); - - private static final Map byName = new HashMap(); - - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } - } - - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 1: // STAGE_INPUT_FILES_TO_WORKING_DIR - return STAGE_INPUT_FILES_TO_WORKING_DIR; - case 2: // PARENT_WORKING_DIRECTORY - return PARENT_WORKING_DIRECTORY; - case 3: // UNIQUE_WORKING_DIRECTORY - return UNIQUE_WORKING_DIRECTORY; - case 4: // CLEAN_UP_WORKING_DIR_AFTER_JOB - return CLEAN_UP_WORKING_DIR_AFTER_JOB; - 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 __STAGEINPUTFILESTOWORKINGDIR_ISSET_ID = 0; - private static final int __CLEANUPWORKINGDIRAFTERJOB_ISSET_ID = 1; - private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.STAGE_INPUT_FILES_TO_WORKING_DIR,_Fields.PARENT_WORKING_DIRECTORY,_Fields.UNIQUE_WORKING_DIRECTORY,_Fields.CLEAN_UP_WORKING_DIR_AFTER_JOB}; - 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.STAGE_INPUT_FILES_TO_WORKING_DIR, new org.apache.thrift.meta_data.FieldMetaData("stageInputFilesToWorkingDir", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL))); - tmpMap.put(_Fields.PARENT_WORKING_DIRECTORY, new org.apache.thrift.meta_data.FieldMetaData("parentWorkingDirectory", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.UNIQUE_WORKING_DIRECTORY, new org.apache.thrift.meta_data.FieldMetaData("uniqueWorkingDirectory", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.CLEAN_UP_WORKING_DIR_AFTER_JOB, new org.apache.thrift.meta_data.FieldMetaData("cleanUpWorkingDirAfterJob", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AdvancedInputDataHandling.class, metaDataMap); - } - - public AdvancedInputDataHandling() { - this.stageInputFilesToWorkingDir = false; - - this.cleanUpWorkingDirAfterJob = false; - - } - - /** - * Performs a deep copy on other. - */ - public AdvancedInputDataHandling(AdvancedInputDataHandling other) { - __isset_bitfield = other.__isset_bitfield; - this.stageInputFilesToWorkingDir = other.stageInputFilesToWorkingDir; - if (other.isSetParentWorkingDirectory()) { - this.parentWorkingDirectory = other.parentWorkingDirectory; - } - if (other.isSetUniqueWorkingDirectory()) { - this.uniqueWorkingDirectory = other.uniqueWorkingDirectory; - } - this.cleanUpWorkingDirAfterJob = other.cleanUpWorkingDirAfterJob; - } - - public AdvancedInputDataHandling deepCopy() { - return new AdvancedInputDataHandling(this); - } - - @Override - public void clear() { - this.stageInputFilesToWorkingDir = false; - - this.parentWorkingDirectory = null; - this.uniqueWorkingDirectory = null; - this.cleanUpWorkingDirAfterJob = false; - - } - - public boolean isStageInputFilesToWorkingDir() { - return this.stageInputFilesToWorkingDir; - } - - public void setStageInputFilesToWorkingDir(boolean stageInputFilesToWorkingDir) { - this.stageInputFilesToWorkingDir = stageInputFilesToWorkingDir; - setStageInputFilesToWorkingDirIsSet(true); - } - - public void unsetStageInputFilesToWorkingDir() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __STAGEINPUTFILESTOWORKINGDIR_ISSET_ID); - } - - /** Returns true if field stageInputFilesToWorkingDir is set (has been assigned a value) and false otherwise */ - public boolean isSetStageInputFilesToWorkingDir() { - return EncodingUtils.testBit(__isset_bitfield, __STAGEINPUTFILESTOWORKINGDIR_ISSET_ID); - } - - public void setStageInputFilesToWorkingDirIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __STAGEINPUTFILESTOWORKINGDIR_ISSET_ID, value); - } - - public String getParentWorkingDirectory() { - return this.parentWorkingDirectory; - } - - public void setParentWorkingDirectory(String parentWorkingDirectory) { - this.parentWorkingDirectory = parentWorkingDirectory; - } - - public void unsetParentWorkingDirectory() { - this.parentWorkingDirectory = null; - } - - /** Returns true if field parentWorkingDirectory is set (has been assigned a value) and false otherwise */ - public boolean isSetParentWorkingDirectory() { - return this.parentWorkingDirectory != null; - } - - public void setParentWorkingDirectoryIsSet(boolean value) { - if (!value) { - this.parentWorkingDirectory = null; - } - } - - public String getUniqueWorkingDirectory() { - return this.uniqueWorkingDirectory; - } - - public void setUniqueWorkingDirectory(String uniqueWorkingDirectory) { - this.uniqueWorkingDirectory = uniqueWorkingDirectory; - } - - public void unsetUniqueWorkingDirectory() { - this.uniqueWorkingDirectory = null; - } - - /** Returns true if field uniqueWorkingDirectory is set (has been assigned a value) and false otherwise */ - public boolean isSetUniqueWorkingDirectory() { - return this.uniqueWorkingDirectory != null; - } - - public void setUniqueWorkingDirectoryIsSet(boolean value) { - if (!value) { - this.uniqueWorkingDirectory = null; - } - } - - public boolean isCleanUpWorkingDirAfterJob() { - return this.cleanUpWorkingDirAfterJob; - } - - public void setCleanUpWorkingDirAfterJob(boolean cleanUpWorkingDirAfterJob) { - this.cleanUpWorkingDirAfterJob = cleanUpWorkingDirAfterJob; - setCleanUpWorkingDirAfterJobIsSet(true); - } - - public void unsetCleanUpWorkingDirAfterJob() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __CLEANUPWORKINGDIRAFTERJOB_ISSET_ID); - } - - /** Returns true if field cleanUpWorkingDirAfterJob is set (has been assigned a value) and false otherwise */ - public boolean isSetCleanUpWorkingDirAfterJob() { - return EncodingUtils.testBit(__isset_bitfield, __CLEANUPWORKINGDIRAFTERJOB_ISSET_ID); - } - - public void setCleanUpWorkingDirAfterJobIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __CLEANUPWORKINGDIRAFTERJOB_ISSET_ID, value); - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case STAGE_INPUT_FILES_TO_WORKING_DIR: - if (value == null) { - unsetStageInputFilesToWorkingDir(); - } else { - setStageInputFilesToWorkingDir((Boolean)value); - } - break; - - case PARENT_WORKING_DIRECTORY: - if (value == null) { - unsetParentWorkingDirectory(); - } else { - setParentWorkingDirectory((String)value); - } - break; - - case UNIQUE_WORKING_DIRECTORY: - if (value == null) { - unsetUniqueWorkingDirectory(); - } else { - setUniqueWorkingDirectory((String)value); - } - break; - - case CLEAN_UP_WORKING_DIR_AFTER_JOB: - if (value == null) { - unsetCleanUpWorkingDirAfterJob(); - } else { - setCleanUpWorkingDirAfterJob((Boolean)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case STAGE_INPUT_FILES_TO_WORKING_DIR: - return Boolean.valueOf(isStageInputFilesToWorkingDir()); - - case PARENT_WORKING_DIRECTORY: - return getParentWorkingDirectory(); - - case UNIQUE_WORKING_DIRECTORY: - return getUniqueWorkingDirectory(); - - case CLEAN_UP_WORKING_DIR_AFTER_JOB: - return Boolean.valueOf(isCleanUpWorkingDirAfterJob()); - - } - 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 STAGE_INPUT_FILES_TO_WORKING_DIR: - return isSetStageInputFilesToWorkingDir(); - case PARENT_WORKING_DIRECTORY: - return isSetParentWorkingDirectory(); - case UNIQUE_WORKING_DIRECTORY: - return isSetUniqueWorkingDirectory(); - case CLEAN_UP_WORKING_DIR_AFTER_JOB: - return isSetCleanUpWorkingDirAfterJob(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof AdvancedInputDataHandling) - return this.equals((AdvancedInputDataHandling)that); - return false; - } - - public boolean equals(AdvancedInputDataHandling that) { - if (that == null) - return false; - - boolean this_present_stageInputFilesToWorkingDir = true && this.isSetStageInputFilesToWorkingDir(); - boolean that_present_stageInputFilesToWorkingDir = true && that.isSetStageInputFilesToWorkingDir(); - if (this_present_stageInputFilesToWorkingDir || that_present_stageInputFilesToWorkingDir) { - if (!(this_present_stageInputFilesToWorkingDir && that_present_stageInputFilesToWorkingDir)) - return false; - if (this.stageInputFilesToWorkingDir != that.stageInputFilesToWorkingDir) - return false; - } - - boolean this_present_parentWorkingDirectory = true && this.isSetParentWorkingDirectory(); - boolean that_present_parentWorkingDirectory = true && that.isSetParentWorkingDirectory(); - if (this_present_parentWorkingDirectory || that_present_parentWorkingDirectory) { - if (!(this_present_parentWorkingDirectory && that_present_parentWorkingDirectory)) - return false; - if (!this.parentWorkingDirectory.equals(that.parentWorkingDirectory)) - return false; - } - - boolean this_present_uniqueWorkingDirectory = true && this.isSetUniqueWorkingDirectory(); - boolean that_present_uniqueWorkingDirectory = true && that.isSetUniqueWorkingDirectory(); - if (this_present_uniqueWorkingDirectory || that_present_uniqueWorkingDirectory) { - if (!(this_present_uniqueWorkingDirectory && that_present_uniqueWorkingDirectory)) - return false; - if (!this.uniqueWorkingDirectory.equals(that.uniqueWorkingDirectory)) - return false; - } - - boolean this_present_cleanUpWorkingDirAfterJob = true && this.isSetCleanUpWorkingDirAfterJob(); - boolean that_present_cleanUpWorkingDirAfterJob = true && that.isSetCleanUpWorkingDirAfterJob(); - if (this_present_cleanUpWorkingDirAfterJob || that_present_cleanUpWorkingDirAfterJob) { - if (!(this_present_cleanUpWorkingDirAfterJob && that_present_cleanUpWorkingDirAfterJob)) - return false; - if (this.cleanUpWorkingDirAfterJob != that.cleanUpWorkingDirAfterJob) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List list = new ArrayList(); - - boolean present_stageInputFilesToWorkingDir = true && (isSetStageInputFilesToWorkingDir()); - list.add(present_stageInputFilesToWorkingDir); - if (present_stageInputFilesToWorkingDir) - list.add(stageInputFilesToWorkingDir); - - boolean present_parentWorkingDirectory = true && (isSetParentWorkingDirectory()); - list.add(present_parentWorkingDirectory); - if (present_parentWorkingDirectory) - list.add(parentWorkingDirectory); - - boolean present_uniqueWorkingDirectory = true && (isSetUniqueWorkingDirectory()); - list.add(present_uniqueWorkingDirectory); - if (present_uniqueWorkingDirectory) - list.add(uniqueWorkingDirectory); - - boolean present_cleanUpWorkingDirAfterJob = true && (isSetCleanUpWorkingDirAfterJob()); - list.add(present_cleanUpWorkingDirAfterJob); - if (present_cleanUpWorkingDirAfterJob) - list.add(cleanUpWorkingDirAfterJob); - - return list.hashCode(); - } - - @Override - public int compareTo(AdvancedInputDataHandling other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetStageInputFilesToWorkingDir()).compareTo(other.isSetStageInputFilesToWorkingDir()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetStageInputFilesToWorkingDir()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.stageInputFilesToWorkingDir, other.stageInputFilesToWorkingDir); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetParentWorkingDirectory()).compareTo(other.isSetParentWorkingDirectory()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetParentWorkingDirectory()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.parentWorkingDirectory, other.parentWorkingDirectory); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetUniqueWorkingDirectory()).compareTo(other.isSetUniqueWorkingDirectory()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetUniqueWorkingDirectory()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.uniqueWorkingDirectory, other.uniqueWorkingDirectory); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetCleanUpWorkingDirAfterJob()).compareTo(other.isSetCleanUpWorkingDirAfterJob()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetCleanUpWorkingDirAfterJob()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.cleanUpWorkingDirAfterJob, other.cleanUpWorkingDirAfterJob); - 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("AdvancedInputDataHandling("); - boolean first = true; - - if (isSetStageInputFilesToWorkingDir()) { - sb.append("stageInputFilesToWorkingDir:"); - sb.append(this.stageInputFilesToWorkingDir); - first = false; - } - if (isSetParentWorkingDirectory()) { - if (!first) sb.append(", "); - sb.append("parentWorkingDirectory:"); - if (this.parentWorkingDirectory == null) { - sb.append("null"); - } else { - sb.append(this.parentWorkingDirectory); - } - first = false; - } - if (isSetUniqueWorkingDirectory()) { - if (!first) sb.append(", "); - sb.append("uniqueWorkingDirectory:"); - if (this.uniqueWorkingDirectory == null) { - sb.append("null"); - } else { - sb.append(this.uniqueWorkingDirectory); - } - first = false; - } - if (isSetCleanUpWorkingDirAfterJob()) { - if (!first) sb.append(", "); - sb.append("cleanUpWorkingDirAfterJob:"); - sb.append(this.cleanUpWorkingDirAfterJob); - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - // check for sub-struct validity - } - - private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { - try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { - try { - // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. - __isset_bitfield = 0; - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private static class AdvancedInputDataHandlingStandardSchemeFactory implements SchemeFactory { - public AdvancedInputDataHandlingStandardScheme getScheme() { - return new AdvancedInputDataHandlingStandardScheme(); - } - } - - private static class AdvancedInputDataHandlingStandardScheme extends StandardScheme { - - public void read(org.apache.thrift.protocol.TProtocol iprot, AdvancedInputDataHandling 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: // STAGE_INPUT_FILES_TO_WORKING_DIR - if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) { - struct.stageInputFilesToWorkingDir = iprot.readBool(); - struct.setStageInputFilesToWorkingDirIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // PARENT_WORKING_DIRECTORY - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.parentWorkingDirectory = iprot.readString(); - struct.setParentWorkingDirectoryIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // UNIQUE_WORKING_DIRECTORY - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.uniqueWorkingDirectory = iprot.readString(); - struct.setUniqueWorkingDirectoryIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 4: // CLEAN_UP_WORKING_DIR_AFTER_JOB - if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) { - struct.cleanUpWorkingDirAfterJob = iprot.readBool(); - struct.setCleanUpWorkingDirAfterJobIsSet(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, AdvancedInputDataHandling struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.isSetStageInputFilesToWorkingDir()) { - oprot.writeFieldBegin(STAGE_INPUT_FILES_TO_WORKING_DIR_FIELD_DESC); - oprot.writeBool(struct.stageInputFilesToWorkingDir); - oprot.writeFieldEnd(); - } - if (struct.parentWorkingDirectory != null) { - if (struct.isSetParentWorkingDirectory()) { - oprot.writeFieldBegin(PARENT_WORKING_DIRECTORY_FIELD_DESC); - oprot.writeString(struct.parentWorkingDirectory); - oprot.writeFieldEnd(); - } - } - if (struct.uniqueWorkingDirectory != null) { - if (struct.isSetUniqueWorkingDirectory()) { - oprot.writeFieldBegin(UNIQUE_WORKING_DIRECTORY_FIELD_DESC); - oprot.writeString(struct.uniqueWorkingDirectory); - oprot.writeFieldEnd(); - } - } - if (struct.isSetCleanUpWorkingDirAfterJob()) { - oprot.writeFieldBegin(CLEAN_UP_WORKING_DIR_AFTER_JOB_FIELD_DESC); - oprot.writeBool(struct.cleanUpWorkingDirAfterJob); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class AdvancedInputDataHandlingTupleSchemeFactory implements SchemeFactory { - public AdvancedInputDataHandlingTupleScheme getScheme() { - return new AdvancedInputDataHandlingTupleScheme(); - } - } - - private static class AdvancedInputDataHandlingTupleScheme extends TupleScheme { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, AdvancedInputDataHandling struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetStageInputFilesToWorkingDir()) { - optionals.set(0); - } - if (struct.isSetParentWorkingDirectory()) { - optionals.set(1); - } - if (struct.isSetUniqueWorkingDirectory()) { - optionals.set(2); - } - if (struct.isSetCleanUpWorkingDirAfterJob()) { - optionals.set(3); - } - oprot.writeBitSet(optionals, 4); - if (struct.isSetStageInputFilesToWorkingDir()) { - oprot.writeBool(struct.stageInputFilesToWorkingDir); - } - if (struct.isSetParentWorkingDirectory()) { - oprot.writeString(struct.parentWorkingDirectory); - } - if (struct.isSetUniqueWorkingDirectory()) { - oprot.writeString(struct.uniqueWorkingDirectory); - } - if (struct.isSetCleanUpWorkingDirAfterJob()) { - oprot.writeBool(struct.cleanUpWorkingDirAfterJob); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, AdvancedInputDataHandling struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(4); - if (incoming.get(0)) { - struct.stageInputFilesToWorkingDir = iprot.readBool(); - struct.setStageInputFilesToWorkingDirIsSet(true); - } - if (incoming.get(1)) { - struct.parentWorkingDirectory = iprot.readString(); - struct.setParentWorkingDirectoryIsSet(true); - } - if (incoming.get(2)) { - struct.uniqueWorkingDirectory = iprot.readString(); - struct.setUniqueWorkingDirectoryIsSet(true); - } - if (incoming.get(3)) { - struct.cleanUpWorkingDirAfterJob = iprot.readBool(); - struct.setCleanUpWorkingDirAfterJobIsSet(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/AdvancedOutputDataHandling.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/AdvancedOutputDataHandling.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/AdvancedOutputDataHandling.java deleted file mode 100644 index d0c6604..0000000 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/AdvancedOutputDataHandling.java +++ /dev/null @@ -1,625 +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 specified output data handling. - * - */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-6-11") -public class AdvancedOutputDataHandling implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AdvancedOutputDataHandling"); - - private static final org.apache.thrift.protocol.TField OUTPUT_DATA_DIR_FIELD_DESC = new org.apache.thrift.protocol.TField("outputDataDir", org.apache.thrift.protocol.TType.STRING, (short)2); - private static final org.apache.thrift.protocol.TField DATA_REGISTRY_URL_FIELD_DESC = new org.apache.thrift.protocol.TField("dataRegistryURL", org.apache.thrift.protocol.TType.STRING, (short)3); - private static final org.apache.thrift.protocol.TField PERSIST_OUTPUT_DATA_FIELD_DESC = new org.apache.thrift.protocol.TField("persistOutputData", org.apache.thrift.protocol.TType.BOOL, (short)4); - - private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new AdvancedOutputDataHandlingStandardSchemeFactory()); - schemes.put(TupleScheme.class, new AdvancedOutputDataHandlingTupleSchemeFactory()); - } - - private String outputDataDir; // optional - private String dataRegistryURL; // optional - private boolean persistOutputData; // 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 { - OUTPUT_DATA_DIR((short)2, "outputDataDir"), - DATA_REGISTRY_URL((short)3, "dataRegistryURL"), - PERSIST_OUTPUT_DATA((short)4, "persistOutputData"); - - private static final Map byName = new HashMap(); - - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } - } - - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 2: // OUTPUT_DATA_DIR - return OUTPUT_DATA_DIR; - case 3: // DATA_REGISTRY_URL - return DATA_REGISTRY_URL; - case 4: // PERSIST_OUTPUT_DATA - return PERSIST_OUTPUT_DATA; - 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 __PERSISTOUTPUTDATA_ISSET_ID = 0; - private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.OUTPUT_DATA_DIR,_Fields.DATA_REGISTRY_URL,_Fields.PERSIST_OUTPUT_DATA}; - 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.OUTPUT_DATA_DIR, new org.apache.thrift.meta_data.FieldMetaData("outputDataDir", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.DATA_REGISTRY_URL, new org.apache.thrift.meta_data.FieldMetaData("dataRegistryURL", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.PERSIST_OUTPUT_DATA, new org.apache.thrift.meta_data.FieldMetaData("persistOutputData", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(AdvancedOutputDataHandling.class, metaDataMap); - } - - public AdvancedOutputDataHandling() { - this.persistOutputData = true; - - } - - /** - * Performs a deep copy on other. - */ - public AdvancedOutputDataHandling(AdvancedOutputDataHandling other) { - __isset_bitfield = other.__isset_bitfield; - if (other.isSetOutputDataDir()) { - this.outputDataDir = other.outputDataDir; - } - if (other.isSetDataRegistryURL()) { - this.dataRegistryURL = other.dataRegistryURL; - } - this.persistOutputData = other.persistOutputData; - } - - public AdvancedOutputDataHandling deepCopy() { - return new AdvancedOutputDataHandling(this); - } - - @Override - public void clear() { - this.outputDataDir = null; - this.dataRegistryURL = null; - this.persistOutputData = true; - - } - - public String getOutputDataDir() { - return this.outputDataDir; - } - - public void setOutputDataDir(String outputDataDir) { - this.outputDataDir = outputDataDir; - } - - public void unsetOutputDataDir() { - this.outputDataDir = null; - } - - /** Returns true if field outputDataDir is set (has been assigned a value) and false otherwise */ - public boolean isSetOutputDataDir() { - return this.outputDataDir != null; - } - - public void setOutputDataDirIsSet(boolean value) { - if (!value) { - this.outputDataDir = null; - } - } - - public String getDataRegistryURL() { - return this.dataRegistryURL; - } - - public void setDataRegistryURL(String dataRegistryURL) { - this.dataRegistryURL = dataRegistryURL; - } - - public void unsetDataRegistryURL() { - this.dataRegistryURL = null; - } - - /** Returns true if field dataRegistryURL is set (has been assigned a value) and false otherwise */ - public boolean isSetDataRegistryURL() { - return this.dataRegistryURL != null; - } - - public void setDataRegistryURLIsSet(boolean value) { - if (!value) { - this.dataRegistryURL = null; - } - } - - public boolean isPersistOutputData() { - return this.persistOutputData; - } - - public void setPersistOutputData(boolean persistOutputData) { - this.persistOutputData = persistOutputData; - setPersistOutputDataIsSet(true); - } - - public void unsetPersistOutputData() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __PERSISTOUTPUTDATA_ISSET_ID); - } - - /** Returns true if field persistOutputData is set (has been assigned a value) and false otherwise */ - public boolean isSetPersistOutputData() { - return EncodingUtils.testBit(__isset_bitfield, __PERSISTOUTPUTDATA_ISSET_ID); - } - - public void setPersistOutputDataIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __PERSISTOUTPUTDATA_ISSET_ID, value); - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case OUTPUT_DATA_DIR: - if (value == null) { - unsetOutputDataDir(); - } else { - setOutputDataDir((String)value); - } - break; - - case DATA_REGISTRY_URL: - if (value == null) { - unsetDataRegistryURL(); - } else { - setDataRegistryURL((String)value); - } - break; - - case PERSIST_OUTPUT_DATA: - if (value == null) { - unsetPersistOutputData(); - } else { - setPersistOutputData((Boolean)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case OUTPUT_DATA_DIR: - return getOutputDataDir(); - - case DATA_REGISTRY_URL: - return getDataRegistryURL(); - - case PERSIST_OUTPUT_DATA: - return Boolean.valueOf(isPersistOutputData()); - - } - 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 OUTPUT_DATA_DIR: - return isSetOutputDataDir(); - case DATA_REGISTRY_URL: - return isSetDataRegistryURL(); - case PERSIST_OUTPUT_DATA: - return isSetPersistOutputData(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof AdvancedOutputDataHandling) - return this.equals((AdvancedOutputDataHandling)that); - return false; - } - - public boolean equals(AdvancedOutputDataHandling that) { - if (that == null) - return false; - - boolean this_present_outputDataDir = true && this.isSetOutputDataDir(); - boolean that_present_outputDataDir = true && that.isSetOutputDataDir(); - if (this_present_outputDataDir || that_present_outputDataDir) { - if (!(this_present_outputDataDir && that_present_outputDataDir)) - return false; - if (!this.outputDataDir.equals(that.outputDataDir)) - return false; - } - - boolean this_present_dataRegistryURL = true && this.isSetDataRegistryURL(); - boolean that_present_dataRegistryURL = true && that.isSetDataRegistryURL(); - if (this_present_dataRegistryURL || that_present_dataRegistryURL) { - if (!(this_present_dataRegistryURL && that_present_dataRegistryURL)) - return false; - if (!this.dataRegistryURL.equals(that.dataRegistryURL)) - return false; - } - - boolean this_present_persistOutputData = true && this.isSetPersistOutputData(); - boolean that_present_persistOutputData = true && that.isSetPersistOutputData(); - if (this_present_persistOutputData || that_present_persistOutputData) { - if (!(this_present_persistOutputData && that_present_persistOutputData)) - return false; - if (this.persistOutputData != that.persistOutputData) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List list = new ArrayList(); - - boolean present_outputDataDir = true && (isSetOutputDataDir()); - list.add(present_outputDataDir); - if (present_outputDataDir) - list.add(outputDataDir); - - boolean present_dataRegistryURL = true && (isSetDataRegistryURL()); - list.add(present_dataRegistryURL); - if (present_dataRegistryURL) - list.add(dataRegistryURL); - - boolean present_persistOutputData = true && (isSetPersistOutputData()); - list.add(present_persistOutputData); - if (present_persistOutputData) - list.add(persistOutputData); - - return list.hashCode(); - } - - @Override - public int compareTo(AdvancedOutputDataHandling other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetOutputDataDir()).compareTo(other.isSetOutputDataDir()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetOutputDataDir()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.outputDataDir, other.outputDataDir); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetDataRegistryURL()).compareTo(other.isSetDataRegistryURL()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetDataRegistryURL()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.dataRegistryURL, other.dataRegistryURL); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetPersistOutputData()).compareTo(other.isSetPersistOutputData()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetPersistOutputData()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.persistOutputData, other.persistOutputData); - 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("AdvancedOutputDataHandling("); - boolean first = true; - - if (isSetOutputDataDir()) { - sb.append("outputDataDir:"); - if (this.outputDataDir == null) { - sb.append("null"); - } else { - sb.append(this.outputDataDir); - } - first = false; - } - if (isSetDataRegistryURL()) { - if (!first) sb.append(", "); - sb.append("dataRegistryURL:"); - if (this.dataRegistryURL == null) { - sb.append("null"); - } else { - sb.append(this.dataRegistryURL); - } - first = false; - } - if (isSetPersistOutputData()) { - if (!first) sb.append(", "); - sb.append("persistOutputData:"); - sb.append(this.persistOutputData); - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - // check for sub-struct validity - } - - private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { - try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { - try { - // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. - __isset_bitfield = 0; - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private static class AdvancedOutputDataHandlingStandardSchemeFactory implements SchemeFactory { - public AdvancedOutputDataHandlingStandardScheme getScheme() { - return new AdvancedOutputDataHandlingStandardScheme(); - } - } - - private static class AdvancedOutputDataHandlingStandardScheme extends StandardScheme { - - public void read(org.apache.thrift.protocol.TProtocol iprot, AdvancedOutputDataHandling struct) throws org.apache.thrift.TException { - org.apache.thrift.protocol.TField schemeField; - iprot.readStructBegin(); - while (true) - { - schemeField = iprot.readFieldBegin(); - if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { - break; - } - switch (schemeField.id) { - case 2: // OUTPUT_DATA_DIR - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.outputDataDir = iprot.readString(); - struct.setOutputDataDirIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // DATA_REGISTRY_URL - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.dataRegistryURL = iprot.readString(); - struct.setDataRegistryURLIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 4: // PERSIST_OUTPUT_DATA - if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) { - struct.persistOutputData = iprot.readBool(); - struct.setPersistOutputDataIsSet(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, AdvancedOutputDataHandling struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.outputDataDir != null) { - if (struct.isSetOutputDataDir()) { - oprot.writeFieldBegin(OUTPUT_DATA_DIR_FIELD_DESC); - oprot.writeString(struct.outputDataDir); - oprot.writeFieldEnd(); - } - } - if (struct.dataRegistryURL != null) { - if (struct.isSetDataRegistryURL()) { - oprot.writeFieldBegin(DATA_REGISTRY_URL_FIELD_DESC); - oprot.writeString(struct.dataRegistryURL); - oprot.writeFieldEnd(); - } - } - if (struct.isSetPersistOutputData()) { - oprot.writeFieldBegin(PERSIST_OUTPUT_DATA_FIELD_DESC); - oprot.writeBool(struct.persistOutputData); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class AdvancedOutputDataHandlingTupleSchemeFactory implements SchemeFactory { - public AdvancedOutputDataHandlingTupleScheme getScheme() { - return new AdvancedOutputDataHandlingTupleScheme(); - } - } - - private static class AdvancedOutputDataHandlingTupleScheme extends TupleScheme { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, AdvancedOutputDataHandling struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetOutputDataDir()) { - optionals.set(0); - } - if (struct.isSetDataRegistryURL()) { - optionals.set(1); - } - if (struct.isSetPersistOutputData()) { - optionals.set(2); - } - oprot.writeBitSet(optionals, 3); - if (struct.isSetOutputDataDir()) { - oprot.writeString(struct.outputDataDir); - } - if (struct.isSetDataRegistryURL()) { - oprot.writeString(struct.dataRegistryURL); - } - if (struct.isSetPersistOutputData()) { - oprot.writeBool(struct.persistOutputData); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, AdvancedOutputDataHandling struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(3); - if (incoming.get(0)) { - struct.outputDataDir = iprot.readString(); - struct.setOutputDataDirIsSet(true); - } - if (incoming.get(1)) { - struct.dataRegistryURL = iprot.readString(); - struct.setDataRegistryURLIsSet(true); - } - if (incoming.get(2)) { - struct.persistOutputData = iprot.readBool(); - struct.setPersistOutputDataIsSet(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/ApplicationStatus.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/ApplicationStatus.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/ApplicationStatus.java deleted file mode 100644 index d6dcf2f..0000000 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/workspace/experiment/ApplicationStatus.java +++ /dev/null @@ -1,513 +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"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-6-11") -public class ApplicationStatus implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ApplicationStatus"); - - private static final org.apache.thrift.protocol.TField APPLICATION_STATE_FIELD_DESC = new org.apache.thrift.protocol.TField("applicationState", org.apache.thrift.protocol.TType.STRING, (short)1); - private static final org.apache.thrift.protocol.TField TIME_OF_STATE_CHANGE_FIELD_DESC = new org.apache.thrift.protocol.TField("timeOfStateChange", org.apache.thrift.protocol.TType.I64, (short)2); - - private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new ApplicationStatusStandardSchemeFactory()); - schemes.put(TupleScheme.class, new ApplicationStatusTupleSchemeFactory()); - } - - private String applicationState; // required - private long timeOfStateChange; // 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 { - APPLICATION_STATE((short)1, "applicationState"), - TIME_OF_STATE_CHANGE((short)2, "timeOfStateChange"); - - private static final Map byName = new HashMap(); - - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } - } - - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 1: // APPLICATION_STATE - return APPLICATION_STATE; - case 2: // TIME_OF_STATE_CHANGE - return TIME_OF_STATE_CHANGE; - 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 __TIMEOFSTATECHANGE_ISSET_ID = 0; - private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.TIME_OF_STATE_CHANGE}; - 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.APPLICATION_STATE, new org.apache.thrift.meta_data.FieldMetaData("applicationState", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.TIME_OF_STATE_CHANGE, new org.apache.thrift.meta_data.FieldMetaData("timeOfStateChange", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ApplicationStatus.class, metaDataMap); - } - - public ApplicationStatus() { - } - - public ApplicationStatus( - String applicationState) - { - this(); - this.applicationState = applicationState; - } - - /** - * Performs a deep copy on other. - */ - public ApplicationStatus(ApplicationStatus other) { - __isset_bitfield = other.__isset_bitfield; - if (other.isSetApplicationState()) { - this.applicationState = other.applicationState; - } - this.timeOfStateChange = other.timeOfStateChange; - } - - public ApplicationStatus deepCopy() { - return new ApplicationStatus(this); - } - - @Override - public void clear() { - this.applicationState = null; - setTimeOfStateChangeIsSet(false); - this.timeOfStateChange = 0; - } - - public String getApplicationState() { - return this.applicationState; - } - - public void setApplicationState(String applicationState) { - this.applicationState = applicationState; - } - - public void unsetApplicationState() { - this.applicationState = null; - } - - /** Returns true if field applicationState is set (has been assigned a value) and false otherwise */ - public boolean isSetApplicationState() { - return this.applicationState != null; - } - - public void setApplicationStateIsSet(boolean value) { - if (!value) { - this.applicationState = null; - } - } - - public long getTimeOfStateChange() { - return this.timeOfStateChange; - } - - public void setTimeOfStateChange(long timeOfStateChange) { - this.timeOfStateChange = timeOfStateChange; - setTimeOfStateChangeIsSet(true); - } - - public void unsetTimeOfStateChange() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TIMEOFSTATECHANGE_ISSET_ID); - } - - /** Returns true if field timeOfStateChange is set (has been assigned a value) and false otherwise */ - public boolean isSetTimeOfStateChange() { - return EncodingUtils.testBit(__isset_bitfield, __TIMEOFSTATECHANGE_ISSET_ID); - } - - public void setTimeOfStateChangeIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TIMEOFSTATECHANGE_ISSET_ID, value); - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case APPLICATION_STATE: - if (value == null) { - unsetApplicationState(); - } else { - setApplicationState((String)value); - } - break; - - case TIME_OF_STATE_CHANGE: - if (value == null) { - unsetTimeOfStateChange(); - } else { - setTimeOfStateChange((Long)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case APPLICATION_STATE: - return getApplicationState(); - - case TIME_OF_STATE_CHANGE: - return Long.valueOf(getTimeOfStateChange()); - - } - 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 APPLICATION_STATE: - return isSetApplicationState(); - case TIME_OF_STATE_CHANGE: - return isSetTimeOfStateChange(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof ApplicationStatus) - return this.equals((ApplicationStatus)that); - return false; - } - - public boolean equals(ApplicationStatus that) { - if (that == null) - return false; - - boolean this_present_applicationState = true && this.isSetApplicationState(); - boolean that_present_applicationState = true && that.isSetApplicationState(); - if (this_present_applicationState || that_present_applicationState) { - if (!(this_present_applicationState && that_present_applicationState)) - return false; - if (!this.applicationState.equals(that.applicationState)) - return false; - } - - boolean this_present_timeOfStateChange = true && this.isSetTimeOfStateChange(); - boolean that_present_timeOfStateChange = true && that.isSetTimeOfStateChange(); - if (this_present_timeOfStateChange || that_present_timeOfStateChange) { - if (!(this_present_timeOfStateChange && that_present_timeOfStateChange)) - return false; - if (this.timeOfStateChange != that.timeOfStateChange) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List list = new ArrayList(); - - boolean present_applicationState = true && (isSetApplicationState()); - list.add(present_applicationState); - if (present_applicationState) - list.add(applicationState); - - boolean present_timeOfStateChange = true && (isSetTimeOfStateChange()); - list.add(present_timeOfStateChange); - if (present_timeOfStateChange) - list.add(timeOfStateChange); - - return list.hashCode(); - } - - @Override - public int compareTo(ApplicationStatus other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetApplicationState()).compareTo(other.isSetApplicationState()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetApplicationState()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.applicationState, other.applicationState); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetTimeOfStateChange()).compareTo(other.isSetTimeOfStateChange()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetTimeOfStateChange()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.timeOfStateChange, other.timeOfStateChange); - 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("ApplicationStatus("); - boolean first = true; - - sb.append("applicationState:"); - if (this.applicationState == null) { - sb.append("null"); - } else { - sb.append(this.applicationState); - } - first = false; - if (isSetTimeOfStateChange()) { - if (!first) sb.append(", "); - sb.append("timeOfStateChange:"); - sb.append(this.timeOfStateChange); - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (!isSetApplicationState()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'applicationState' 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 ApplicationStatusStandardSchemeFactory implements SchemeFactory { - public ApplicationStatusStandardScheme getScheme() { - return new ApplicationStatusStandardScheme(); - } - } - - private static class ApplicationStatusStandardScheme extends StandardScheme { - - public void read(org.apache.thrift.protocol.TProtocol iprot, ApplicationStatus 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: // APPLICATION_STATE - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.applicationState = iprot.readString(); - struct.setApplicationStateIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // TIME_OF_STATE_CHANGE - if (schemeField.type == org.apache.thrift.protocol.TType.I64) { - struct.timeOfStateChange = iprot.readI64(); - struct.setTimeOfStateChangeIsSet(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, ApplicationStatus struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.applicationState != null) { - oprot.writeFieldBegin(APPLICATION_STATE_FIELD_DESC); - oprot.writeString(struct.applicationState); - oprot.writeFieldEnd(); - } - if (struct.isSetTimeOfStateChange()) { - oprot.writeFieldBegin(TIME_OF_STATE_CHANGE_FIELD_DESC); - oprot.writeI64(struct.timeOfStateChange); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class ApplicationStatusTupleSchemeFactory implements SchemeFactory { - public ApplicationStatusTupleScheme getScheme() { - return new ApplicationStatusTupleScheme(); - } - } - - private static class ApplicationStatusTupleScheme extends TupleScheme { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, ApplicationStatus struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - oprot.writeString(struct.applicationState); - BitSet optionals = new BitSet(); - if (struct.isSetTimeOfStateChange()) { - optionals.set(0); - } - oprot.writeBitSet(optionals, 1); - if (struct.isSetTimeOfStateChange()) { - oprot.writeI64(struct.timeOfStateChange); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, ApplicationStatus struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - struct.applicationState = iprot.readString(); - struct.setApplicationStateIsSet(true); - BitSet incoming = iprot.readBitSet(1); - if (incoming.get(0)) { - struct.timeOfStateChange = iprot.readI64(); - struct.setTimeOfStateChangeIsSet(true); - } - } - } - -} -