removing duplicate copy of data models
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/b490671e Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/b490671e Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/b490671e Branch: refs/heads/master Commit: b490671ec110d8e82591c2531b2d863eadb29f87 Parents: f4aafbf Author: scnakandala <[email protected]> Authored: Thu Dec 17 10:45:25 2015 -0500 Committer: scnakandala <[email protected]> Committed: Thu Dec 17 10:45:28 2015 -0500 ---------------------------------------------------------------------- .../java/org/apache/airavata/api/Airavata.java | 162 +- .../airavata/api/airavata_apiConstants.java | 2 +- .../org/apache/airavata/model/Workflow.java | 1062 -- .../ApplicationDeploymentDescription.java | 1937 --- .../appdeployment/ApplicationModule.java | 745 - .../ApplicationParallelismType.java | 90 - .../appcatalog/appdeployment/CommandObject.java | 525 - .../appcatalog/appdeployment/SetEnvPaths.java | 629 - .../ApplicationInterfaceDescription.java | 1114 -- .../appcatalog/computeresource/BatchQueue.java | 1029 -- .../computeresource/CloudJobSubmission.java | 953 -- .../ComputeResourceDescription.java | 1821 -- .../appcatalog/computeresource/FileSystems.java | 87 - .../computeresource/GlobusJobSubmission.java | 688 - .../computeresource/JobManagerCommand.java | 102 - .../computeresource/JobSubmissionInterface.java | 637 - .../computeresource/JobSubmissionProtocol.java | 90 - .../computeresource/LOCALSubmission.java | 643 - .../appcatalog/computeresource/MonitorMode.java | 79 - .../computeresource/ProviderName.java | 69 - .../computeresource/ResourceJobManager.java | 933 - .../computeresource/ResourceJobManagerType.java | 90 - .../computeresource/SSHJobSubmission.java | 1146 -- .../computeresource/UnicoreJobSubmission.java | 637 - .../ComputeResourcePreference.java | 1329 -- .../gatewayprofile/GatewayResourceProfile.java | 854 - .../gatewayprofile/StoragePreference.java | 733 - .../StorageResourceDescription.java | 905 - .../airavata/model/application/io/DataType.java | 78 - .../application/io/InputDataObjectType.java | 1493 -- .../application/io/OutputDataObjectType.java | 1393 -- .../airavata/model/commons/ErrorModel.java | 991 -- .../model/commons/ValidationResults.java | 562 - .../airavata/model/commons/ValidatorResult.java | 525 - .../commons/airavata_commonsConstants.java | 58 - .../airavata/model/data/movement/DMType.java | 62 - .../data/movement/DataMovementInterface.java | 637 - .../data/movement/DataMovementProtocol.java | 87 - .../data/movement/GridFTPDataMovement.java | 687 - .../model/data/movement/LOCALDataMovement.java | 420 - .../model/data/movement/SCPDataMovement.java | 754 - .../model/data/movement/SecurityProtocol.java | 88 - .../data/movement/UnicoreDataMovement.java | 635 - .../data/resource/ReplicaLocationModel.java | 462 - .../model/data/resource/ResourceModel.java | 684 - .../model/error/AiravataClientException.java | 550 - .../airavata/model/error/AiravataErrorType.java | 99 - .../model/error/AiravataSystemException.java | 545 - .../model/error/AuthenticationException.java | 413 - .../model/error/AuthorizationException.java | 413 - .../error/ExperimentNotFoundException.java | 415 - .../model/error/InvalidRequestException.java | 414 - .../model/error/LaunchValidationException.java | 524 - .../model/error/ProjectNotFoundException.java | 413 - .../airavata/model/error/TimedOutException.java | 305 - .../airavata/model/error/ValidationResults.java | 562 - .../airavata/model/error/ValidatorResult.java | 518 - .../model/experiment/ExperimentModel.java | 2504 --- .../experiment/ExperimentSearchFields.java | 77 - .../model/experiment/ExperimentStatistics.java | 1855 -- .../experiment/ExperimentSummaryModel.java | 1448 -- .../model/experiment/ExperimentType.java | 62 - .../experiment/UserConfigurationDataModel.java | 1148 -- .../org/apache/airavata/model/job/JobModel.java | 1566 -- .../event/ExperimentStatusChangeEvent.java | 626 - .../model/messaging/event/JobIdentifier.java | 812 - .../messaging/event/JobStatusChangeEvent.java | 530 - .../event/JobStatusChangeRequestEvent.java | 530 - .../airavata/model/messaging/event/Message.java | 870 - .../model/messaging/event/MessageLevel.java | 68 - .../model/messaging/event/MessageType.java | 77 - .../messaging/event/ProcessIdentifier.java | 610 - .../event/ProcessStatusChangeEvent.java | 530 - .../event/ProcessStatusChangeRequestEvent.java | 530 - .../messaging/event/ProcessSubmitEvent.java | 711 - .../messaging/event/ProcessTerminateEvent.java | 610 - .../model/messaging/event/TaskIdentifier.java | 711 - .../messaging/event/TaskOutputChangeEvent.java | 568 - .../messaging/event/TaskStatusChangeEvent.java | 530 - .../event/TaskStatusChangeRequestEvent.java | 530 - .../airavata/model/process/ProcessModel.java | 2553 --- .../ComputationalResourceSchedulingModel.java | 1243 -- .../airavata/model/security/AuthzToken.java | 571 - .../airavata/model/status/ExperimentState.java | 83 - .../airavata/model/status/ExperimentStatus.java | 652 - .../apache/airavata/model/status/JobState.java | 80 - .../apache/airavata/model/status/JobStatus.java | 639 - .../airavata/model/status/ProcessState.java | 98 - .../airavata/model/status/ProcessStatus.java | 639 - .../apache/airavata/model/status/TaskState.java | 71 - .../airavata/model/status/TaskStatus.java | 639 - .../airavata/model/task/DataStageType.java | 69 - .../model/task/DataStagingTaskModel.java | 1165 -- .../model/task/EnvironmentSetupTaskModel.java | 529 - .../model/task/JobSubmissionTaskModel.java | 649 - .../airavata/model/task/MonitorTaskModel.java | 424 - .../apache/airavata/model/task/TaskModel.java | 1441 -- .../apache/airavata/model/task/TaskTypes.java | 78 - .../airavata/model/workspace/Gateway.java | 733 - .../apache/airavata/model/workspace/Group.java | 519 - .../airavata/model/workspace/Project.java | 1140 -- .../apache/airavata/model/workspace/User.java | 573 - .../main/resources/lib/airavata/Airavata.cpp | 15139 ++++++++++++++++- .../src/main/resources/lib/airavata/Airavata.h | 2651 +-- .../lib/airavata/airavata_api_constants.cpp | 2 +- .../lib/airavata/airavata_api_constants.h | 2 +- .../lib/airavata/airavata_api_types.cpp | 2 +- .../resources/lib/airavata/airavata_api_types.h | 2 +- .../lib/airavata/airavata_commons_constants.cpp | 2 +- .../lib/airavata/airavata_commons_constants.h | 2 +- .../lib/airavata/airavata_commons_types.cpp | 58 +- .../lib/airavata/airavata_commons_types.h | 35 +- .../airavata/airavata_data_models_constants.cpp | 2 +- .../airavata/airavata_data_models_constants.h | 2 +- .../lib/airavata/airavata_data_models_types.cpp | 2 +- .../lib/airavata/airavata_data_models_types.h | 2 +- .../lib/airavata/airavata_errors_constants.cpp | 2 +- .../lib/airavata/airavata_errors_constants.h | 2 +- .../lib/airavata/airavata_errors_types.cpp | 264 +- .../lib/airavata/airavata_errors_types.h | 141 +- .../application_deployment_model_constants.cpp | 2 +- .../application_deployment_model_constants.h | 2 +- .../application_deployment_model_types.cpp | 92 +- .../application_deployment_model_types.h | 46 +- .../application_interface_model_constants.cpp | 2 +- .../application_interface_model_constants.h | 2 +- .../application_interface_model_types.cpp | 26 +- .../application_interface_model_types.h | 13 +- .../application_io_models_constants.cpp | 2 +- .../airavata/application_io_models_constants.h | 2 +- .../airavata/application_io_models_types.cpp | 68 +- .../lib/airavata/application_io_models_types.h | 24 +- .../compute_resource_model_constants.cpp | 2 +- .../airavata/compute_resource_model_constants.h | 2 +- .../airavata/compute_resource_model_types.cpp | 206 +- .../lib/airavata/compute_resource_model_types.h | 101 +- .../airavata/data_movement_models_constants.cpp | 2 +- .../airavata/data_movement_models_constants.h | 2 +- .../lib/airavata/data_movement_models_types.cpp | 90 +- .../lib/airavata/data_movement_models_types.h | 57 +- .../lib/airavata/experiment_model_constants.cpp | 2 +- .../lib/airavata/experiment_model_constants.h | 2 +- .../lib/airavata/experiment_model_types.cpp | 148 +- .../lib/airavata/experiment_model_types.h | 46 +- ...gateway_resource_profile_model_constants.cpp | 2 +- .../gateway_resource_profile_model_constants.h | 2 +- .../gateway_resource_profile_model_types.cpp | 72 +- .../gateway_resource_profile_model_types.h | 35 +- .../lib/airavata/job_model_constants.cpp | 2 +- .../lib/airavata/job_model_constants.h | 2 +- .../resources/lib/airavata/job_model_types.cpp | 38 +- .../resources/lib/airavata/job_model_types.h | 13 +- .../lib/airavata/messaging_events_constants.cpp | 2 +- .../lib/airavata/messaging_events_constants.h | 2 +- .../lib/airavata/messaging_events_types.cpp | 252 +- .../lib/airavata/messaging_events_types.h | 156 +- .../lib/airavata/process_model_constants.cpp | 2 +- .../lib/airavata/process_model_constants.h | 2 +- .../lib/airavata/process_model_types.cpp | 56 +- .../lib/airavata/process_model_types.h | 13 +- .../replica_catalog_models_constants.cpp | 2 +- .../airavata/replica_catalog_models_constants.h | 2 +- .../airavata/replica_catalog_models_types.cpp | 76 +- .../lib/airavata/replica_catalog_models_types.h | 24 +- .../lib/airavata/scheduling_model_constants.cpp | 2 +- .../lib/airavata/scheduling_model_constants.h | 2 +- .../lib/airavata/scheduling_model_types.cpp | 32 +- .../lib/airavata/scheduling_model_types.h | 13 +- .../lib/airavata/security_model_constants.cpp | 2 +- .../lib/airavata/security_model_constants.h | 2 +- .../lib/airavata/security_model_types.cpp | 18 +- .../lib/airavata/security_model_types.h | 13 +- .../lib/airavata/status_models_constants.cpp | 2 +- .../lib/airavata/status_models_constants.h | 2 +- .../lib/airavata/status_models_types.cpp | 74 +- .../lib/airavata/status_models_types.h | 46 +- .../storage_resource_model_constants.cpp | 2 +- .../airavata/storage_resource_model_constants.h | 2 +- .../airavata/storage_resource_model_types.cpp | 24 +- .../lib/airavata/storage_resource_model_types.h | 13 +- .../lib/airavata/task_model_constants.cpp | 2 +- .../lib/airavata/task_model_constants.h | 2 +- .../resources/lib/airavata/task_model_types.cpp | 110 +- .../resources/lib/airavata/task_model_types.h | 57 +- .../airavata/workflow_data_model_constants.cpp | 2 +- .../airavata/workflow_data_model_constants.h | 2 +- .../lib/airavata/workflow_data_model_types.cpp | 26 +- .../lib/airavata/workflow_data_model_types.h | 13 +- .../lib/airavata/workspace_model_constants.cpp | 2 +- .../lib/airavata/workspace_model_constants.h | 2 +- .../lib/airavata/workspace_model_types.cpp | 80 +- .../lib/airavata/workspace_model_types.h | 46 +- .../resources/lib/Airavata/API/Airavata.php | 2 +- .../resources/lib/Airavata/API/Error/Types.php | 2 +- .../main/resources/lib/Airavata/API/Types.php | 2 +- .../Model/AppCatalog/AppDeployment/Types.php | 2 +- .../Model/AppCatalog/AppInterface/Types.php | 2 +- .../Model/AppCatalog/ComputeResource/Types.php | 2 +- .../Model/AppCatalog/GatewayProfile/Types.php | 2 +- .../Model/AppCatalog/StorageResource/Types.php | 2 +- .../lib/Airavata/Model/Application/Io/Types.php | 2 +- .../lib/Airavata/Model/Commons/Types.php | 2 +- .../lib/Airavata/Model/Data/Movement/Types.php | 2 +- .../lib/Airavata/Model/Data/Resource/Types.php | 2 +- .../lib/Airavata/Model/Experiment/Types.php | 2 +- .../Airavata/Model/Messaging/Event/Types.php | 2 +- .../lib/Airavata/Model/Process/Types.php | 2 +- .../lib/Airavata/Model/Scheduling/Types.php | 2 +- .../lib/Airavata/Model/Security/Types.php | 2 +- .../lib/Airavata/Model/Status/Types.php | 2 +- .../resources/lib/Airavata/Model/Task/Types.php | 2 +- .../main/resources/lib/Airavata/Model/Types.php | 2 +- .../lib/Airavata/Model/Workspace/Types.php | 2 +- .../resources/lib/Airavata/Model/job/Types.php | 2 +- .../src/main/resources/lib/Types.php | 4 +- .../lib/apache/airavata/api/Airavata-remote | 2 +- .../lib/apache/airavata/api/Airavata.py | 3725 ++-- .../lib/apache/airavata/api/constants.py | 2 +- .../lib/apache/airavata/api/error/constants.py | 2 +- .../lib/apache/airavata/api/error/ttypes.py | 28 +- .../resources/lib/apache/airavata/api/ttypes.py | 2 +- .../model/appcatalog/appdeployment/constants.py | 2 +- .../model/appcatalog/appdeployment/ttypes.py | 32 +- .../model/appcatalog/appinterface/constants.py | 2 +- .../model/appcatalog/appinterface/ttypes.py | 10 +- .../appcatalog/computeresource/constants.py | 2 +- .../model/appcatalog/computeresource/ttypes.py | 92 +- .../appcatalog/gatewayprofile/constants.py | 2 +- .../model/appcatalog/gatewayprofile/ttypes.py | 32 +- .../appcatalog/storageresource/constants.py | 2 +- .../model/appcatalog/storageresource/ttypes.py | 10 +- .../airavata/model/application/io/constants.py | 2 +- .../airavata/model/application/io/ttypes.py | 44 +- .../apache/airavata/model/commons/constants.py | 2 +- .../lib/apache/airavata/model/commons/ttypes.py | 20 +- .../lib/apache/airavata/model/constants.py | 2 +- .../airavata/model/data/movement/constants.py | 2 +- .../airavata/model/data/movement/ttypes.py | 30 +- .../airavata/model/data/resource/constants.py | 2 +- .../airavata/model/data/resource/ttypes.py | 52 +- .../airavata/model/experiment/constants.py | 2 +- .../apache/airavata/model/experiment/ttypes.py | 74 +- .../lib/apache/airavata/model/job/constants.py | 2 +- .../lib/apache/airavata/model/job/ttypes.py | 24 +- .../airavata/model/messaging/event/constants.py | 2 +- .../airavata/model/messaging/event/ttypes.py | 68 +- .../apache/airavata/model/process/constants.py | 2 +- .../lib/apache/airavata/model/process/ttypes.py | 32 +- .../airavata/model/scheduling/constants.py | 2 +- .../apache/airavata/model/scheduling/ttypes.py | 20 +- .../apache/airavata/model/security/constants.py | 2 +- .../apache/airavata/model/security/ttypes.py | 8 +- .../apache/airavata/model/status/constants.py | 2 +- .../lib/apache/airavata/model/status/ttypes.py | 26 +- .../lib/apache/airavata/model/task/constants.py | 2 +- .../lib/apache/airavata/model/task/ttypes.py | 40 +- .../lib/apache/airavata/model/ttypes.py | 2 +- .../apache/airavata/model/workflow/constants.py | 2 +- .../apache/airavata/model/workflow/ttypes.py | 10 +- .../airavata/model/workspace/constants.py | 2 +- .../apache/airavata/model/workspace/ttypes.py | 30 +- .../client/samples/DataManagerSample.java | 6 +- .../org/apache/airavata/model/Workflow.java | 4 +- .../ApplicationDeploymentDescription.java | 4 +- .../appdeployment/ApplicationModule.java | 4 +- .../ApplicationParallelismType.java | 2 +- .../appcatalog/appdeployment/CommandObject.java | 6 +- .../appcatalog/appdeployment/SetEnvPaths.java | 6 +- .../ApplicationInterfaceDescription.java | 4 +- .../appcatalog/computeresource/BatchQueue.java | 14 +- .../computeresource/CloudJobSubmission.java | 4 +- .../ComputeResourceDescription.java | 8 +- .../appcatalog/computeresource/DMType.java | 2 +- .../appcatalog/computeresource/FileSystems.java | 2 +- .../computeresource/GlobusJobSubmission.java | 4 +- .../computeresource/JobManagerCommand.java | 2 +- .../computeresource/JobSubmissionInterface.java | 6 +- .../computeresource/JobSubmissionProtocol.java | 2 +- .../computeresource/LOCALSubmission.java | 4 +- .../appcatalog/computeresource/MonitorMode.java | 2 +- .../computeresource/ProviderName.java | 2 +- .../computeresource/ResourceJobManager.java | 4 +- .../computeresource/ResourceJobManagerType.java | 2 +- .../computeresource/SSHJobSubmission.java | 6 +- .../computeresource/UnicoreJobSubmission.java | 4 +- .../ComputeResourcePreference.java | 6 +- .../gatewayprofile/GatewayResourceProfile.java | 4 +- .../gatewayprofile/StoragePreference.java | 4 +- .../StorageResourceDescription.java | 6 +- .../airavata/model/application/io/DataType.java | 2 +- .../application/io/InputDataObjectType.java | 14 +- .../application/io/OutputDataObjectType.java | 12 +- .../airavata/model/commons/ErrorModel.java | 8 +- .../model/commons/ValidationResults.java | 6 +- .../airavata/model/commons/ValidatorResult.java | 6 +- .../commons/airavata_commonsConstants.java | 2 +- .../airavata/model/data/movement/DMType.java | 2 +- .../data/movement/DataMovementInterface.java | 6 +- .../data/movement/DataMovementProtocol.java | 2 +- .../data/movement/GridFTPDataMovement.java | 4 +- .../model/data/movement/LOCALDataMovement.java | 4 +- .../model/data/movement/SCPDataMovement.java | 6 +- .../model/data/movement/SecurityProtocol.java | 2 +- .../data/movement/UnicoreDataMovement.java | 4 +- .../data/resource/DataReplicaLocationModel.java | 10 +- .../model/data/resource/DataResourceModel.java | 10 +- .../model/data/resource/DataResourceType.java | 2 +- .../data/resource/ReplicaLocationCategory.java | 2 +- .../data/resource/ReplicaPersistentType.java | 2 +- .../model/error/AiravataClientException.java | 4 +- .../airavata/model/error/AiravataErrorType.java | 2 +- .../model/error/AiravataSystemException.java | 4 +- .../model/error/AuthenticationException.java | 4 +- .../model/error/AuthorizationException.java | 4 +- .../error/ExperimentNotFoundException.java | 4 +- .../model/error/InvalidRequestException.java | 4 +- .../model/error/LaunchValidationException.java | 4 +- .../model/error/ProjectNotFoundException.java | 4 +- .../airavata/model/error/TimedOutException.java | 4 +- .../airavata/model/error/ValidationResults.java | 6 +- .../airavata/model/error/ValidatorResult.java | 6 +- .../model/experiment/ExperimentModel.java | 8 +- .../experiment/ExperimentSearchFields.java | 2 +- .../model/experiment/ExperimentStatistics.java | 16 +- .../experiment/ExperimentSummaryModel.java | 8 +- .../model/experiment/ExperimentType.java | 2 +- .../experiment/UserConfigurationDataModel.java | 14 +- .../org/apache/airavata/model/job/JobModel.java | 8 +- .../event/ExperimentStatusChangeEvent.java | 4 +- .../model/messaging/event/JobIdentifier.java | 4 +- .../messaging/event/JobStatusChangeEvent.java | 4 +- .../event/JobStatusChangeRequestEvent.java | 4 +- .../airavata/model/messaging/event/Message.java | 6 +- .../model/messaging/event/MessageLevel.java | 2 +- .../model/messaging/event/MessageType.java | 2 +- .../messaging/event/ProcessIdentifier.java | 4 +- .../event/ProcessStatusChangeEvent.java | 4 +- .../event/ProcessStatusChangeRequestEvent.java | 4 +- .../messaging/event/ProcessSubmitEvent.java | 4 +- .../messaging/event/ProcessTerminateEvent.java | 4 +- .../model/messaging/event/TaskIdentifier.java | 4 +- .../messaging/event/TaskOutputChangeEvent.java | 4 +- .../messaging/event/TaskStatusChangeEvent.java | 4 +- .../event/TaskStatusChangeRequestEvent.java | 4 +- .../airavata/model/process/ProcessModel.java | 12 +- .../ComputationalResourceSchedulingModel.java | 14 +- .../airavata/model/security/AuthzToken.java | 4 +- .../airavata/model/status/ExperimentState.java | 2 +- .../airavata/model/status/ExperimentStatus.java | 6 +- .../apache/airavata/model/status/JobState.java | 2 +- .../apache/airavata/model/status/JobStatus.java | 6 +- .../airavata/model/status/ProcessState.java | 2 +- .../airavata/model/status/ProcessStatus.java | 6 +- .../apache/airavata/model/status/TaskState.java | 2 +- .../airavata/model/status/TaskStatus.java | 6 +- .../airavata/model/task/DataStageType.java | 2 +- .../model/task/DataStagingTaskModel.java | 8 +- .../model/task/EnvironmentSetupTaskModel.java | 4 +- .../model/task/JobSubmissionTaskModel.java | 6 +- .../airavata/model/task/MonitorTaskModel.java | 4 +- .../apache/airavata/model/task/TaskModel.java | 8 +- .../apache/airavata/model/task/TaskTypes.java | 2 +- .../airavata/model/workspace/Gateway.java | 4 +- .../apache/airavata/model/workspace/Group.java | 4 +- .../airavata/model/workspace/Project.java | 6 +- .../apache/airavata/model/workspace/User.java | 4 +- pom.xml | 2 +- .../generate-thrift-stubs.sh | 2 +- 368 files changed, 19823 insertions(+), 71770 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/b490671e/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java index e37eb19..b3f5890 100644 --- a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java +++ b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java @@ -16,7 +16,7 @@ */ /** - * Autogenerated by Thrift Compiler (0.9.2) + * Autogenerated by Thrift Compiler (0.9.3) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -51,7 +51,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-17") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-17") public class Airavata { public interface Iface { @@ -32888,7 +32888,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -35339,7 +35339,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -41518,7 +41518,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -46823,7 +46823,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -47683,10 +47683,10 @@ public class Airavata { return getUserName(); case LIMIT: - return Integer.valueOf(getLimit()); + return getLimit(); case OFFSET: - return Integer.valueOf(getOffset()); + return getOffset(); } throw new IllegalStateException(); @@ -49331,10 +49331,10 @@ public class Airavata { return getProjectName(); case LIMIT: - return Integer.valueOf(getLimit()); + return getLimit(); case OFFSET: - return Integer.valueOf(getOffset()); + return getOffset(); } throw new IllegalStateException(); @@ -51032,10 +51032,10 @@ public class Airavata { return getDescription(); case LIMIT: - return Integer.valueOf(getLimit()); + return getLimit(); case OFFSET: - return Integer.valueOf(getOffset()); + return getOffset(); } throw new IllegalStateException(); @@ -52733,10 +52733,10 @@ public class Airavata { return getExpName(); case LIMIT: - return Integer.valueOf(getLimit()); + return getLimit(); case OFFSET: - return Integer.valueOf(getOffset()); + return getOffset(); } throw new IllegalStateException(); @@ -54434,10 +54434,10 @@ public class Airavata { return getDescription(); case LIMIT: - return Integer.valueOf(getLimit()); + return getLimit(); case OFFSET: - return Integer.valueOf(getOffset()); + return getOffset(); } throw new IllegalStateException(); @@ -56135,10 +56135,10 @@ public class Airavata { return getApplicationId(); case LIMIT: - return Integer.valueOf(getLimit()); + return getLimit(); case OFFSET: - return Integer.valueOf(getOffset()); + return getOffset(); } throw new IllegalStateException(); @@ -57852,10 +57852,10 @@ public class Airavata { return getExperimentState(); case LIMIT: - return Integer.valueOf(getLimit()); + return getLimit(); case OFFSET: - return Integer.valueOf(getOffset()); + return getOffset(); } throw new IllegalStateException(); @@ -59595,16 +59595,16 @@ public class Airavata { return getUserName(); case FROM_TIME: - return Long.valueOf(getFromTime()); + return getFromTime(); case TO_TIME: - return Long.valueOf(getToTime()); + return getToTime(); case LIMIT: - return Integer.valueOf(getLimit()); + return getLimit(); case OFFSET: - return Integer.valueOf(getOffset()); + return getOffset(); } throw new IllegalStateException(); @@ -61370,10 +61370,10 @@ public class Airavata { return getFilters(); case LIMIT: - return Integer.valueOf(getLimit()); + return getLimit(); case OFFSET: - return Integer.valueOf(getOffset()); + return getOffset(); } throw new IllegalStateException(); @@ -63020,10 +63020,10 @@ public class Airavata { return getGatewayId(); case FROM_TIME: - return Long.valueOf(getFromTime()); + return getFromTime(); case TO_TIME: - return Long.valueOf(getToTime()); + return getToTime(); } throw new IllegalStateException(); @@ -64470,10 +64470,10 @@ public class Airavata { return getProjectId(); case LIMIT: - return Integer.valueOf(getLimit()); + return getLimit(); case OFFSET: - return Integer.valueOf(getOffset()); + return getOffset(); } throw new IllegalStateException(); @@ -66124,10 +66124,10 @@ public class Airavata { return getUserName(); case LIMIT: - return Integer.valueOf(getLimit()); + return getLimit(); case OFFSET: - return Integer.valueOf(getOffset()); + return getOffset(); } throw new IllegalStateException(); @@ -69530,7 +69530,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -76761,7 +76761,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -91982,7 +91982,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -94534,7 +94534,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -98498,7 +98498,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -99747,7 +99747,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -106312,7 +106312,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -107561,7 +107561,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -119135,7 +119135,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -120384,7 +120384,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -125447,7 +125447,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -126696,7 +126696,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -127446,7 +127446,7 @@ public class Airavata { return getComputeResourceId(); case PRIORITY_ORDER: - return Integer.valueOf(getPriorityOrder()); + return getPriorityOrder(); case LOCAL_SUBMISSION: return getLocalSubmission(); @@ -129506,7 +129506,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -131510,7 +131510,7 @@ public class Airavata { return getComputeResourceId(); case PRIORITY_ORDER: - return Integer.valueOf(getPriorityOrder()); + return getPriorityOrder(); case SSH_JOB_SUBMISSION: return getSshJobSubmission(); @@ -132965,7 +132965,7 @@ public class Airavata { return getComputeResourceId(); case PRIORITY_ORDER: - return Integer.valueOf(getPriorityOrder()); + return getPriorityOrder(); case SSH_JOB_SUBMISSION: return getSshJobSubmission(); @@ -135674,7 +135674,7 @@ public class Airavata { return getComputeResourceId(); case PRIORITY_ORDER: - return Integer.valueOf(getPriorityOrder()); + return getPriorityOrder(); case UNICORE_JOB_SUBMISSION: return getUnicoreJobSubmission(); @@ -138383,7 +138383,7 @@ public class Airavata { return getComputeResourceId(); case PRIORITY_ORDER: - return Integer.valueOf(getPriorityOrder()); + return getPriorityOrder(); case CLOUD_SUBMISSION: return getCloudSubmission(); @@ -141697,7 +141697,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -143052,7 +143052,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -144407,7 +144407,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -145221,7 +145221,7 @@ public class Airavata { return getDataMoveType(); case PRIORITY_ORDER: - return Integer.valueOf(getPriorityOrder()); + return getPriorityOrder(); case LOCAL_DATA_MOVEMENT: return getLocalDataMovement(); @@ -147334,7 +147334,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -149402,7 +149402,7 @@ public class Airavata { return getDataMoveType(); case PRIORITY_ORDER: - return Integer.valueOf(getPriorityOrder()); + return getPriorityOrder(); case SCP_DATA_MOVEMENT: return getScpDataMovement(); @@ -151515,7 +151515,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -153583,7 +153583,7 @@ public class Airavata { return getDataMoveType(); case PRIORITY_ORDER: - return Integer.valueOf(getPriorityOrder()); + return getPriorityOrder(); case UNICORE_DATA_MOVEMENT: return getUnicoreDataMovement(); @@ -155696,7 +155696,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -157764,7 +157764,7 @@ public class Airavata { return getDataMoveType(); case PRIORITY_ORDER: - return Integer.valueOf(getPriorityOrder()); + return getPriorityOrder(); case GRID_FTPDATA_MOVEMENT: return getGridFTPDataMovement(); @@ -159877,7 +159877,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -161836,7 +161836,7 @@ public class Airavata { return getJobSubmissionInterfaceId(); case NEW_PRIORITY_ORDER: - return Integer.valueOf(getNewPriorityOrder()); + return getNewPriorityOrder(); } throw new IllegalStateException(); @@ -162480,7 +162480,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -163185,7 +163185,7 @@ public class Airavata { return getDataMovementInterfaceId(); case NEW_PRIORITY_ORDER: - return Integer.valueOf(getNewPriorityOrder()); + return getNewPriorityOrder(); } throw new IllegalStateException(); @@ -163829,7 +163829,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -165130,7 +165130,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -166431,7 +166431,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -167781,7 +167781,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -169131,7 +169131,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -171740,7 +171740,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -174243,7 +174243,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -175593,7 +175593,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -179456,7 +179456,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -180705,7 +180705,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -182161,7 +182161,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -183617,7 +183617,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -191591,7 +191591,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -193047,7 +193047,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -194397,7 +194397,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -195747,7 +195747,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); @@ -204546,7 +204546,7 @@ public class Airavata { public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: - return Boolean.valueOf(isSuccess()); + return isSuccess(); case IRE: return getIre(); http://git-wip-us.apache.org/repos/asf/airavata/blob/b490671e/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/airavata_apiConstants.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/airavata_apiConstants.java b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/airavata_apiConstants.java index 4e340cf..31116cb 100644 --- a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/airavata_apiConstants.java +++ b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/airavata_apiConstants.java @@ -16,7 +16,7 @@ */ /** - * Autogenerated by Thrift Compiler (0.9.2) + * Autogenerated by Thrift Compiler (0.9.3) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated http://git-wip-us.apache.org/repos/asf/airavata/blob/b490671e/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/Workflow.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/Workflow.java b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/Workflow.java deleted file mode 100644 index 47422e2..0000000 --- a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/model/Workflow.java +++ /dev/null @@ -1,1062 +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; - -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-12-2") -public class Workflow implements org.apache.thrift.TBase<Workflow, Workflow._Fields>, java.io.Serializable, Cloneable, Comparable<Workflow> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Workflow"); - - private static final org.apache.thrift.protocol.TField TEMPLATE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("templateId", org.apache.thrift.protocol.TType.STRING, (short)1); - private static final org.apache.thrift.protocol.TField NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("name", org.apache.thrift.protocol.TType.STRING, (short)2); - private static final org.apache.thrift.protocol.TField GRAPH_FIELD_DESC = new org.apache.thrift.protocol.TField("graph", org.apache.thrift.protocol.TType.STRING, (short)3); - private static final org.apache.thrift.protocol.TField IMAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("image", org.apache.thrift.protocol.TType.STRING, (short)4); - private static final org.apache.thrift.protocol.TField WORKFLOW_INPUTS_FIELD_DESC = new org.apache.thrift.protocol.TField("workflowInputs", org.apache.thrift.protocol.TType.LIST, (short)5); - private static final org.apache.thrift.protocol.TField WORKFLOW_OUTPUTS_FIELD_DESC = new org.apache.thrift.protocol.TField("workflowOutputs", org.apache.thrift.protocol.TType.LIST, (short)6); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new WorkflowStandardSchemeFactory()); - schemes.put(TupleScheme.class, new WorkflowTupleSchemeFactory()); - } - - public String templateId; // required - public String name; // required - public String graph; // optional - public ByteBuffer image; // optional - public List<org.apache.airavata.model.application.io.InputDataObjectType> workflowInputs; // optional - public List<org.apache.airavata.model.application.io.OutputDataObjectType> workflowOutputs; // 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 { - TEMPLATE_ID((short)1, "templateId"), - NAME((short)2, "name"), - GRAPH((short)3, "graph"), - IMAGE((short)4, "image"), - WORKFLOW_INPUTS((short)5, "workflowInputs"), - WORKFLOW_OUTPUTS((short)6, "workflowOutputs"); - - 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: // TEMPLATE_ID - return TEMPLATE_ID; - case 2: // NAME - return NAME; - case 3: // GRAPH - return GRAPH; - case 4: // IMAGE - return IMAGE; - case 5: // WORKFLOW_INPUTS - return WORKFLOW_INPUTS; - case 6: // WORKFLOW_OUTPUTS - return WORKFLOW_OUTPUTS; - 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 _Fields optionals[] = {_Fields.GRAPH,_Fields.IMAGE,_Fields.WORKFLOW_INPUTS,_Fields.WORKFLOW_OUTPUTS}; - 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.TEMPLATE_ID, new org.apache.thrift.meta_data.FieldMetaData("templateId", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.NAME, new org.apache.thrift.meta_data.FieldMetaData("name", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.GRAPH, new org.apache.thrift.meta_data.FieldMetaData("graph", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.IMAGE, new org.apache.thrift.meta_data.FieldMetaData("image", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true))); - tmpMap.put(_Fields.WORKFLOW_INPUTS, new org.apache.thrift.meta_data.FieldMetaData("workflowInputs", 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.application.io.InputDataObjectType.class)))); - tmpMap.put(_Fields.WORKFLOW_OUTPUTS, new org.apache.thrift.meta_data.FieldMetaData("workflowOutputs", 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.application.io.OutputDataObjectType.class)))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(Workflow.class, metaDataMap); - } - - public Workflow() { - this.templateId = "DO_NOT_SET_AT_CLIENTS"; - - } - - public Workflow( - String templateId, - String name) - { - this(); - this.templateId = templateId; - this.name = name; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public Workflow(Workflow other) { - if (other.isSetTemplateId()) { - this.templateId = other.templateId; - } - if (other.isSetName()) { - this.name = other.name; - } - if (other.isSetGraph()) { - this.graph = other.graph; - } - if (other.isSetImage()) { - this.image = org.apache.thrift.TBaseHelper.copyBinary(other.image); - } - if (other.isSetWorkflowInputs()) { - List<org.apache.airavata.model.application.io.InputDataObjectType> __this__workflowInputs = new ArrayList<org.apache.airavata.model.application.io.InputDataObjectType>(other.workflowInputs.size()); - for (org.apache.airavata.model.application.io.InputDataObjectType other_element : other.workflowInputs) { - __this__workflowInputs.add(new org.apache.airavata.model.application.io.InputDataObjectType(other_element)); - } - this.workflowInputs = __this__workflowInputs; - } - if (other.isSetWorkflowOutputs()) { - List<org.apache.airavata.model.application.io.OutputDataObjectType> __this__workflowOutputs = new ArrayList<org.apache.airavata.model.application.io.OutputDataObjectType>(other.workflowOutputs.size()); - for (org.apache.airavata.model.application.io.OutputDataObjectType other_element : other.workflowOutputs) { - __this__workflowOutputs.add(new org.apache.airavata.model.application.io.OutputDataObjectType(other_element)); - } - this.workflowOutputs = __this__workflowOutputs; - } - } - - public Workflow deepCopy() { - return new Workflow(this); - } - - @Override - public void clear() { - this.templateId = "DO_NOT_SET_AT_CLIENTS"; - - this.name = null; - this.graph = null; - this.image = null; - this.workflowInputs = null; - this.workflowOutputs = null; - } - - public String getTemplateId() { - return this.templateId; - } - - public Workflow setTemplateId(String templateId) { - this.templateId = templateId; - return this; - } - - public void unsetTemplateId() { - this.templateId = null; - } - - /** Returns true if field templateId is set (has been assigned a value) and false otherwise */ - public boolean isSetTemplateId() { - return this.templateId != null; - } - - public void setTemplateIdIsSet(boolean value) { - if (!value) { - this.templateId = null; - } - } - - public String getName() { - return this.name; - } - - public Workflow setName(String name) { - this.name = name; - return this; - } - - public void unsetName() { - this.name = null; - } - - /** Returns true if field name is set (has been assigned a value) and false otherwise */ - public boolean isSetName() { - return this.name != null; - } - - public void setNameIsSet(boolean value) { - if (!value) { - this.name = null; - } - } - - public String getGraph() { - return this.graph; - } - - public Workflow setGraph(String graph) { - this.graph = graph; - return this; - } - - public void unsetGraph() { - this.graph = null; - } - - /** Returns true if field graph is set (has been assigned a value) and false otherwise */ - public boolean isSetGraph() { - return this.graph != null; - } - - public void setGraphIsSet(boolean value) { - if (!value) { - this.graph = null; - } - } - - public byte[] getImage() { - setImage(org.apache.thrift.TBaseHelper.rightSize(image)); - return image == null ? null : image.array(); - } - - public ByteBuffer bufferForImage() { - return org.apache.thrift.TBaseHelper.copyBinary(image); - } - - public Workflow setImage(byte[] image) { - this.image = image == null ? (ByteBuffer)null : ByteBuffer.wrap(Arrays.copyOf(image, image.length)); - return this; - } - - public Workflow setImage(ByteBuffer image) { - this.image = org.apache.thrift.TBaseHelper.copyBinary(image); - return this; - } - - public void unsetImage() { - this.image = null; - } - - /** Returns true if field image is set (has been assigned a value) and false otherwise */ - public boolean isSetImage() { - return this.image != null; - } - - public void setImageIsSet(boolean value) { - if (!value) { - this.image = null; - } - } - - public int getWorkflowInputsSize() { - return (this.workflowInputs == null) ? 0 : this.workflowInputs.size(); - } - - public java.util.Iterator<org.apache.airavata.model.application.io.InputDataObjectType> getWorkflowInputsIterator() { - return (this.workflowInputs == null) ? null : this.workflowInputs.iterator(); - } - - public void addToWorkflowInputs(org.apache.airavata.model.application.io.InputDataObjectType elem) { - if (this.workflowInputs == null) { - this.workflowInputs = new ArrayList<org.apache.airavata.model.application.io.InputDataObjectType>(); - } - this.workflowInputs.add(elem); - } - - public List<org.apache.airavata.model.application.io.InputDataObjectType> getWorkflowInputs() { - return this.workflowInputs; - } - - public Workflow setWorkflowInputs(List<org.apache.airavata.model.application.io.InputDataObjectType> workflowInputs) { - this.workflowInputs = workflowInputs; - return this; - } - - public void unsetWorkflowInputs() { - this.workflowInputs = null; - } - - /** Returns true if field workflowInputs is set (has been assigned a value) and false otherwise */ - public boolean isSetWorkflowInputs() { - return this.workflowInputs != null; - } - - public void setWorkflowInputsIsSet(boolean value) { - if (!value) { - this.workflowInputs = null; - } - } - - public int getWorkflowOutputsSize() { - return (this.workflowOutputs == null) ? 0 : this.workflowOutputs.size(); - } - - public java.util.Iterator<org.apache.airavata.model.application.io.OutputDataObjectType> getWorkflowOutputsIterator() { - return (this.workflowOutputs == null) ? null : this.workflowOutputs.iterator(); - } - - public void addToWorkflowOutputs(org.apache.airavata.model.application.io.OutputDataObjectType elem) { - if (this.workflowOutputs == null) { - this.workflowOutputs = new ArrayList<org.apache.airavata.model.application.io.OutputDataObjectType>(); - } - this.workflowOutputs.add(elem); - } - - public List<org.apache.airavata.model.application.io.OutputDataObjectType> getWorkflowOutputs() { - return this.workflowOutputs; - } - - public Workflow setWorkflowOutputs(List<org.apache.airavata.model.application.io.OutputDataObjectType> workflowOutputs) { - this.workflowOutputs = workflowOutputs; - return this; - } - - public void unsetWorkflowOutputs() { - this.workflowOutputs = null; - } - - /** Returns true if field workflowOutputs is set (has been assigned a value) and false otherwise */ - public boolean isSetWorkflowOutputs() { - return this.workflowOutputs != null; - } - - public void setWorkflowOutputsIsSet(boolean value) { - if (!value) { - this.workflowOutputs = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case TEMPLATE_ID: - if (value == null) { - unsetTemplateId(); - } else { - setTemplateId((String)value); - } - break; - - case NAME: - if (value == null) { - unsetName(); - } else { - setName((String)value); - } - break; - - case GRAPH: - if (value == null) { - unsetGraph(); - } else { - setGraph((String)value); - } - break; - - case IMAGE: - if (value == null) { - unsetImage(); - } else { - setImage((ByteBuffer)value); - } - break; - - case WORKFLOW_INPUTS: - if (value == null) { - unsetWorkflowInputs(); - } else { - setWorkflowInputs((List<org.apache.airavata.model.application.io.InputDataObjectType>)value); - } - break; - - case WORKFLOW_OUTPUTS: - if (value == null) { - unsetWorkflowOutputs(); - } else { - setWorkflowOutputs((List<org.apache.airavata.model.application.io.OutputDataObjectType>)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case TEMPLATE_ID: - return getTemplateId(); - - case NAME: - return getName(); - - case GRAPH: - return getGraph(); - - case IMAGE: - return getImage(); - - case WORKFLOW_INPUTS: - return getWorkflowInputs(); - - case WORKFLOW_OUTPUTS: - return getWorkflowOutputs(); - - } - 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 TEMPLATE_ID: - return isSetTemplateId(); - case NAME: - return isSetName(); - case GRAPH: - return isSetGraph(); - case IMAGE: - return isSetImage(); - case WORKFLOW_INPUTS: - return isSetWorkflowInputs(); - case WORKFLOW_OUTPUTS: - return isSetWorkflowOutputs(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof Workflow) - return this.equals((Workflow)that); - return false; - } - - public boolean equals(Workflow that) { - if (that == null) - return false; - - boolean this_present_templateId = true && this.isSetTemplateId(); - boolean that_present_templateId = true && that.isSetTemplateId(); - if (this_present_templateId || that_present_templateId) { - if (!(this_present_templateId && that_present_templateId)) - return false; - if (!this.templateId.equals(that.templateId)) - return false; - } - - boolean this_present_name = true && this.isSetName(); - boolean that_present_name = true && that.isSetName(); - if (this_present_name || that_present_name) { - if (!(this_present_name && that_present_name)) - return false; - if (!this.name.equals(that.name)) - return false; - } - - boolean this_present_graph = true && this.isSetGraph(); - boolean that_present_graph = true && that.isSetGraph(); - if (this_present_graph || that_present_graph) { - if (!(this_present_graph && that_present_graph)) - return false; - if (!this.graph.equals(that.graph)) - return false; - } - - boolean this_present_image = true && this.isSetImage(); - boolean that_present_image = true && that.isSetImage(); - if (this_present_image || that_present_image) { - if (!(this_present_image && that_present_image)) - return false; - if (!this.image.equals(that.image)) - return false; - } - - boolean this_present_workflowInputs = true && this.isSetWorkflowInputs(); - boolean that_present_workflowInputs = true && that.isSetWorkflowInputs(); - if (this_present_workflowInputs || that_present_workflowInputs) { - if (!(this_present_workflowInputs && that_present_workflowInputs)) - return false; - if (!this.workflowInputs.equals(that.workflowInputs)) - return false; - } - - boolean this_present_workflowOutputs = true && this.isSetWorkflowOutputs(); - boolean that_present_workflowOutputs = true && that.isSetWorkflowOutputs(); - if (this_present_workflowOutputs || that_present_workflowOutputs) { - if (!(this_present_workflowOutputs && that_present_workflowOutputs)) - return false; - if (!this.workflowOutputs.equals(that.workflowOutputs)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_templateId = true && (isSetTemplateId()); - list.add(present_templateId); - if (present_templateId) - list.add(templateId); - - boolean present_name = true && (isSetName()); - list.add(present_name); - if (present_name) - list.add(name); - - boolean present_graph = true && (isSetGraph()); - list.add(present_graph); - if (present_graph) - list.add(graph); - - boolean present_image = true && (isSetImage()); - list.add(present_image); - if (present_image) - list.add(image); - - boolean present_workflowInputs = true && (isSetWorkflowInputs()); - list.add(present_workflowInputs); - if (present_workflowInputs) - list.add(workflowInputs); - - boolean present_workflowOutputs = true && (isSetWorkflowOutputs()); - list.add(present_workflowOutputs); - if (present_workflowOutputs) - list.add(workflowOutputs); - - return list.hashCode(); - } - - @Override - public int compareTo(Workflow other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetTemplateId()).compareTo(other.isSetTemplateId()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetTemplateId()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.templateId, other.templateId); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetName()).compareTo(other.isSetName()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetName()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.name, other.name); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetGraph()).compareTo(other.isSetGraph()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetGraph()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.graph, other.graph); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetImage()).compareTo(other.isSetImage()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetImage()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.image, other.image); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetWorkflowInputs()).compareTo(other.isSetWorkflowInputs()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetWorkflowInputs()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.workflowInputs, other.workflowInputs); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetWorkflowOutputs()).compareTo(other.isSetWorkflowOutputs()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetWorkflowOutputs()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.workflowOutputs, other.workflowOutputs); - 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("Workflow("); - boolean first = true; - - sb.append("templateId:"); - if (this.templateId == null) { - sb.append("null"); - } else { - sb.append(this.templateId); - } - first = false; - if (!first) sb.append(", "); - sb.append("name:"); - if (this.name == null) { - sb.append("null"); - } else { - sb.append(this.name); - } - first = false; - if (isSetGraph()) { - if (!first) sb.append(", "); - sb.append("graph:"); - if (this.graph == null) { - sb.append("null"); - } else { - sb.append(this.graph); - } - first = false; - } - if (isSetImage()) { - if (!first) sb.append(", "); - sb.append("image:"); - if (this.image == null) { - sb.append("null"); - } else { - org.apache.thrift.TBaseHelper.toString(this.image, sb); - } - first = false; - } - if (isSetWorkflowInputs()) { - if (!first) sb.append(", "); - sb.append("workflowInputs:"); - if (this.workflowInputs == null) { - sb.append("null"); - } else { - sb.append(this.workflowInputs); - } - first = false; - } - if (isSetWorkflowOutputs()) { - if (!first) sb.append(", "); - sb.append("workflowOutputs:"); - if (this.workflowOutputs == null) { - sb.append("null"); - } else { - sb.append(this.workflowOutputs); - } - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (templateId == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'templateId' was not present! Struct: " + toString()); - } - if (name == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'name' was not present! 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 { - 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 WorkflowStandardSchemeFactory implements SchemeFactory { - public WorkflowStandardScheme getScheme() { - return new WorkflowStandardScheme(); - } - } - - private static class WorkflowStandardScheme extends StandardScheme<Workflow> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, Workflow 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: // TEMPLATE_ID - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.templateId = iprot.readString(); - struct.setTemplateIdIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // NAME - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.name = iprot.readString(); - struct.setNameIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // GRAPH - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.graph = iprot.readString(); - struct.setGraphIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 4: // IMAGE - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.image = iprot.readBinary(); - struct.setImageIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 5: // WORKFLOW_INPUTS - if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { - { - org.apache.thrift.protocol.TList _list0 = iprot.readListBegin(); - struct.workflowInputs = new ArrayList<org.apache.airavata.model.application.io.InputDataObjectType>(_list0.size); - org.apache.airavata.model.application.io.InputDataObjectType _elem1; - for (int _i2 = 0; _i2 < _list0.size; ++_i2) - { - _elem1 = new org.apache.airavata.model.application.io.InputDataObjectType(); - _elem1.read(iprot); - struct.workflowInputs.add(_elem1); - } - iprot.readListEnd(); - } - struct.setWorkflowInputsIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 6: // WORKFLOW_OUTPUTS - if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { - { - org.apache.thrift.protocol.TList _list3 = iprot.readListBegin(); - struct.workflowOutputs = new ArrayList<org.apache.airavata.model.application.io.OutputDataObjectType>(_list3.size); - org.apache.airavata.model.application.io.OutputDataObjectType _elem4; - for (int _i5 = 0; _i5 < _list3.size; ++_i5) - { - _elem4 = new org.apache.airavata.model.application.io.OutputDataObjectType(); - _elem4.read(iprot); - struct.workflowOutputs.add(_elem4); - } - iprot.readListEnd(); - } - struct.setWorkflowOutputsIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - default: - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - iprot.readFieldEnd(); - } - iprot.readStructEnd(); - - // check for required fields of primitive type, which can't be checked in the validate method - struct.validate(); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot, Workflow struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.templateId != null) { - oprot.writeFieldBegin(TEMPLATE_ID_FIELD_DESC); - oprot.writeString(struct.templateId); - oprot.writeFieldEnd(); - } - if (struct.name != null) { - oprot.writeFieldBegin(NAME_FIELD_DESC); - oprot.writeString(struct.name); - oprot.writeFieldEnd(); - } - if (struct.graph != null) { - if (struct.isSetGraph()) { - oprot.writeFieldBegin(GRAPH_FIELD_DESC); - oprot.writeString(struct.graph); - oprot.writeFieldEnd(); - } - } - if (struct.image != null) { - if (struct.isSetImage()) { - oprot.writeFieldBegin(IMAGE_FIELD_DESC); - oprot.writeBinary(struct.image); - oprot.writeFieldEnd(); - } - } - if (struct.workflowInputs != null) { - if (struct.isSetWorkflowInputs()) { - oprot.writeFieldBegin(WORKFLOW_INPUTS_FIELD_DESC); - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.workflowInputs.size())); - for (org.apache.airavata.model.application.io.InputDataObjectType _iter6 : struct.workflowInputs) - { - _iter6.write(oprot); - } - oprot.writeListEnd(); - } - oprot.writeFieldEnd(); - } - } - if (struct.workflowOutputs != null) { - if (struct.isSetWorkflowOutputs()) { - oprot.writeFieldBegin(WORKFLOW_OUTPUTS_FIELD_DESC); - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.workflowOutputs.size())); - for (org.apache.airavata.model.application.io.OutputDataObjectType _iter7 : struct.workflowOutputs) - { - _iter7.write(oprot); - } - oprot.writeListEnd(); - } - oprot.writeFieldEnd(); - } - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class WorkflowTupleSchemeFactory implements SchemeFactory { - public WorkflowTupleScheme getScheme() { - return new WorkflowTupleScheme(); - } - } - - private static class WorkflowTupleScheme extends TupleScheme<Workflow> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, Workflow struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - oprot.writeString(struct.templateId); - oprot.writeString(struct.name); - BitSet optionals = new BitSet(); - if (struct.isSetGraph()) { - optionals.set(0); - } - if (struct.isSetImage()) { - optionals.set(1); - } - if (struct.isSetWorkflowInputs()) { - optionals.set(2); - } - if (struct.isSetWorkflowOutputs()) { - optionals.set(3); - } - oprot.writeBitSet(optionals, 4); - if (struct.isSetGraph()) { - oprot.writeString(struct.graph); - } - if (struct.isSetImage()) { - oprot.writeBinary(struct.image); - } - if (struct.isSetWorkflowInputs()) { - { - oprot.writeI32(struct.workflowInputs.size()); - for (org.apache.airavata.model.application.io.InputDataObjectType _iter8 : struct.workflowInputs) - { - _iter8.write(oprot); - } - } - } - if (struct.isSetWorkflowOutputs()) { - { - oprot.writeI32(struct.workflowOutputs.size()); - for (org.apache.airavata.model.application.io.OutputDataObjectType _iter9 : struct.workflowOutputs) - { - _iter9.write(oprot); - } - } - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, Workflow struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - struct.templateId = iprot.readString(); - struct.setTemplateIdIsSet(true); - struct.name = iprot.readString(); - struct.setNameIsSet(true); - BitSet incoming = iprot.readBitSet(4); - if (incoming.get(0)) { - struct.graph = iprot.readString(); - struct.setGraphIsSet(true); - } - if (incoming.get(1)) { - struct.image = iprot.readBinary(); - struct.setImageIsSet(true); - } - if (incoming.get(2)) { - { - org.apache.thrift.protocol.TList _list10 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.workflowInputs = new ArrayList<org.apache.airavata.model.application.io.InputDataObjectType>(_list10.size); - org.apache.airavata.model.application.io.InputDataObjectType _elem11; - for (int _i12 = 0; _i12 < _list10.size; ++_i12) - { - _elem11 = new org.apache.airavata.model.application.io.InputDataObjectType(); - _elem11.read(iprot); - struct.workflowInputs.add(_elem11); - } - } - struct.setWorkflowInputsIsSet(true); - } - if (incoming.get(3)) { - { - org.apache.thrift.protocol.TList _list13 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.workflowOutputs = new ArrayList<org.apache.airavata.model.application.io.OutputDataObjectType>(_list13.size); - org.apache.airavata.model.application.io.OutputDataObjectType _elem14; - for (int _i15 = 0; _i15 < _list13.size; ++_i15) - { - _elem14 = new org.apache.airavata.model.application.io.OutputDataObjectType(); - _elem14.read(iprot); - struct.workflowOutputs.add(_elem14); - } - } - struct.setWorkflowOutputsIsSet(true); - } - } - } - -} -
