tassl.application.cometcloud.sampleNonBlocking
Class GenerateTasks
java.lang.Object
tassl.application.cometcloud.GenerateTasksAbstract
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
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 |
GenerateTasks
public GenerateTasks()
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 xmloutput
- 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 descriptiondependencies
- 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)