tassl.application.cometcloud.sampleNonBlocking
Class GenerateTasks

java.lang.Object
  extended by tassl.application.cometcloud.GenerateTasksAbstract
      extended by tassl.application.cometcloud.sampleNonBlocking.GenerateTasks

public class GenerateTasks
extends GenerateTasksAbstract

This code is an application that has multiple stages. The first stage reads files from a directory and generate a task per file. The second stage generates a task per result of previous stage The third stage generates a task per result of previous stage The fourth stage generates a task per result of previous stage


Constructor Summary
GenerateTasks()
           
 
Method Summary
 GenerateTasksObject createTasks(java.lang.String stageId, java.util.List<FileProperties> input, FileProperties output, java.lang.String propertyFileValues, java.util.List dependencies, java.lang.String method)
          Create Tasks for the specified stage of the workflow.
 void printTest(java.lang.String method, java.util.List<java.util.List> taskParams, java.util.List<java.util.List<FileProperties>> inputList)
           
 GenerateTasksObject step1(java.util.List<FileProperties> input, FileProperties output, java.lang.String propertyFile, java.lang.String stageId)
           
 GenerateTasksObject step2(java.util.List<FileProperties> input, FileProperties output, java.lang.String propertyFile, java.util.HashMap<java.lang.String,FileProperties> previousResults, java.lang.String stageId)
           
 GenerateTasksObject step3(java.util.List<FileProperties> input, FileProperties output, java.lang.String propertyFile, java.util.HashMap<java.lang.String,FileProperties> previousResults, java.lang.String stageId)
           
 GenerateTasksObject step4(java.util.List<FileProperties> input, FileProperties output, java.lang.String propertyFile, java.util.HashMap<java.lang.String,FileProperties> previousResults, java.lang.String stageId)
           
 
Methods inherited from class tassl.application.cometcloud.GenerateTasksAbstract
addRelatedWorkflowResults, executeSsh, generatePreviousResultFiles, generatePreviousResultFilesStageId, getPreviousResults, getProperty, getProperty, getRelatedWorkflowsResults, loadProperties, setPreviousResults, setProperty
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

GenerateTasks

public GenerateTasks()
Method Detail

createTasks

public GenerateTasksObject createTasks(java.lang.String stageId,
                                       java.util.List<FileProperties> input,
                                       FileProperties output,
                                       java.lang.String propertyFileValues,
                                       java.util.List dependencies,
                                       java.lang.String method)
Description copied from class: GenerateTasksAbstract
Create Tasks for the specified stage of the workflow.

Specified by:
createTasks in class GenerateTasksAbstract
input - list of input FileProperties, which include URI (address:/dir/path/) where you can find input files, and constraints. Correspond to InputData in the input xml
output - a FileProperties object, which includes URI (address:/dir/path/) that should be placed in the task to know where to upload the results. Correspond to Results in the input xml.
propertyFileValues - Values of the propertyFile specified in the XML workflow description
dependencies - Previous stages. This can be use to get results values from those previous stages
Returns:
return an object with requirements and task parameters

step1

public GenerateTasksObject step1(java.util.List<FileProperties> input,
                                 FileProperties output,
                                 java.lang.String propertyFile,
                                 java.lang.String stageId)

printTest

public void printTest(java.lang.String method,
                      java.util.List<java.util.List> taskParams,
                      java.util.List<java.util.List<FileProperties>> inputList)

step2

public GenerateTasksObject step2(java.util.List<FileProperties> input,
                                 FileProperties output,
                                 java.lang.String propertyFile,
                                 java.util.HashMap<java.lang.String,FileProperties> previousResults,
                                 java.lang.String stageId)

step3

public GenerateTasksObject step3(java.util.List<FileProperties> input,
                                 FileProperties output,
                                 java.lang.String propertyFile,
                                 java.util.HashMap<java.lang.String,FileProperties> previousResults,
                                 java.lang.String stageId)

step4

public GenerateTasksObject step4(java.util.List<FileProperties> input,
                                 FileProperties output,
                                 java.lang.String propertyFile,
                                 java.util.HashMap<java.lang.String,FileProperties> previousResults,
                                 java.lang.String stageId)