Overview
Package
Class
Use
Tree
Deprecated
Index
Help
PREV LETTER
NEXT LETTER
FRAMES
NO FRAMES
All Classes
A
B
C
D
E
F
G
H
I
J
K
L
M
N
P
Q
R
S
T
U
V
W
X
Z
G
generateAccountingInfo(String, String, long, List<NodeAcct>)
- Method in class tassl.workflow.resources.
Resource
Generate the accounting information of a stage.
generateAccountingInfo(String, String, long, List<NodeAcct>)
- Method in class tassl.workflow.resources.
ResourceCloud
generateAccountingInfo(String, String, long, List<NodeAcct>)
- Method in class tassl.workflow.resources.
ResourceCluster
generatePreviousResultFiles(String, List)
- Method in class tassl.application.cometcloud.
GenerateTasksAbstract
Get result files of the previous stages that had dependencies with the current one This is assuming that ALL Results of previous stages are FileProperties objects
generatePreviousResultFilesStageId(String)
- Method in class tassl.application.cometcloud.
GenerateTasksAbstract
Get result files of a specific previous stage This is assuming that ALL Results of previous stages are FileProperties objects
GenerateTasks
- Class in
tassl.application.cometcloud.sample
This code is a simple map/reduce application.
GenerateTasks()
- Constructor for class tassl.application.cometcloud.sample.
GenerateTasks
GenerateTasks
- Class in
tassl.application.cometcloud.sampleLoop
GenerateTasks()
- Constructor for class tassl.application.cometcloud.sampleLoop.
GenerateTasks
GenerateTasks
- Class in
tassl.application.cometcloud.sampleNonBlocking
This code is an application that has multiple stages.
GenerateTasks()
- Constructor for class tassl.application.cometcloud.sampleNonBlocking.
GenerateTasks
generateTasks()
- Method in class tassl.application.cometcloud.
WorkflowMaster
This method is called to read the application properties and initiate the tasks creation.
GenerateTasksAbstract
- Class in
tassl.application.cometcloud
GenerateTasksAbstract()
- Constructor for class tassl.application.cometcloud.
GenerateTasksAbstract
GenerateTasksMontage
- Class in
tassl.application.cometcloud.sampleMontage
GenerateTasksMontage()
- Constructor for class tassl.application.cometcloud.sampleMontage.
GenerateTasksMontage
GenerateTasksObject
- Class in
tassl.application.cometcloud
GenerateTasksObject()
- Constructor for class tassl.application.cometcloud.
GenerateTasksObject
GenerateTasksObject(List<List>, List<String>, List<Double>, List<Double>, List<List<FileProperties>>, List<List<FileProperties>>)
- Constructor for class tassl.application.cometcloud.
GenerateTasksObject
genStage(List<FileProperties>, FileProperties, String, HashMap, String, String)
- Method in class tassl.application.cometcloud.sampleMontage.
GenerateTasksMontage
genStageConcatModel(List<FileProperties>, FileProperties, String, HashMap, String, String)
- Method in class tassl.application.cometcloud.sampleMontage.
GenerateTasksMontage
genStageFinal(List<FileProperties>, FileProperties, String, HashMap, String, String)
- Method in class tassl.application.cometcloud.sampleMontage.
GenerateTasksMontage
getActiveResourcesWorkflow()
- Method in class tassl.workflow.resources.
Resource
Get the list of active resources organized by workflowid.stageid
getActiveWorkers()
- Method in class tassl.workflow.resources.
Node
getAllAvailableSlots(String, String)
- Method in class tassl.application.workflow.
AutonomicScheduler
Look into available resources and determine the number of slots(workers) available.
getAllDoneTasks(String)
- Method in class tassl.application.cometcloud.
WorkflowMaster
Retrieve the ids of the tasks that have been completed.
getAllTaskProp()
- Method in class tassl.workflow.
WorkflowStage
Return the properties of all tasks composing a stage
getAppName()
- Method in class tassl.application.cometcloud.
WorkflowMeteorGenericWorker
getAppName()
- Method in class tassl.application.cometcloud.
WorkflowTaskTuple
getAssignHours()
- Method in class tassl.application.workflow.
WorkerForScheduler
getAvailableSlotsScheduling(String, String[])
- Method in class tassl.workflow.resources.
Resource
It creates the list of available slots for scheduling considering the workers per machine and the number of available machines.
getAvailableSlotsScheduling(String, String[])
- Method in class tassl.workflow.resources.
ResourceCloud
getAvailableSlotsScheduling(String, String[])
- Method in class tassl.workflow.resources.
ResourceCluster
getBalancedChordIDs(String)
- Method in class tassl.application.
InternalStarter
getCandidateTunnelPort(List)
- Method in class tassl.workflow.resources.
Resource
Return a port to use for the tunnel from Agent to Worker
getCloudScript()
- Method in class tassl.workflow.resources.
ResourceCloud
getCompletedStages()
- Method in class tassl.workflow.
Workflow
getConstraints()
- Method in class tassl.application.cometcloud.
FileProperties
List of sitenames and zones where the dataset can be moved
getCost()
- Method in class tassl.application.workflow.
WorkerForScheduler
getCost()
- Method in class tassl.workflow.resources.
Node
getCost()
- Method in class tassl.workflow.resources.
NodeAcct
getCostDataIn()
- Method in class tassl.workflow.resources.
Resource
getCostDataOut()
- Method in class tassl.workflow.resources.
Resource
getCurrentTasks()
- Method in class tassl.application.cometcloud.
AgentLite
getDataTransferTime()
- Method in class tassl.application.cometcloud.
AgentFileServer
getDefaultImageId()
- Method in class tassl.workflow.resources.
ResourceCloud
getDependencies()
- Method in class tassl.workflow.
WorkflowStage
getDestinationFiles(List<FileProperties>)
- Method in class tassl.application.workflow.
PolicyAbstract
getDoneTasks()
- Method in class tassl.workflow.
WorkflowStage
getDrtsPeer()
- Method in class tassl.application.
InternalStarter
getDurationStage()
- Method in class tassl.workflow.
WorkflowStage
Duration of the stage since it was ready to execute until it was completed
getEndTime()
- Method in class tassl.workflow.
WorkflowStage
Time in milliseconds
getExecutableStages()
- Method in class tassl.workflow.
Workflow
getFile(Boolean, String, List, String)
- Method in class tassl.application.cometcloud.
WorkflowMeteorGenericWorker
Retrieve input files to the local worker.
getFileserver()
- Method in class tassl.application.cometcloud.
AgentLite
getFileServerPort()
- Method in class tassl.application.cometcloud.
AgentLite
getFinalMap(HashMap<Integer, WorkerForScheduler>, String)
- Method in class tassl.application.workflow.
AutonomicScheduler
Return the number of machines and workers per site
getFreePort()
- Method in class tassl.workflow.resources.
Node
getId()
- Method in class tassl.workflow.
Workflow
getId()
- Method in class tassl.workflow.
WorkflowStage
getIdentifier()
- Method in class tassl.workflow.resources.
Resource
getImageId(String)
- Method in class tassl.workflow.resources.
ResourceCloud
Get the imageId of the custom VM image of an Application
getInitialTaskCount()
- Method in class tassl.application.cometcloud.
WorkflowMeteorGenericWorker
getInputList()
- Method in class tassl.application.cometcloud.
GenerateTasksObject
List of input files as objects of FileProperties
getInputs()
- Method in class tassl.application.cometcloud.
TaskProperties
getIp()
- Method in class tassl.workflow.resources.
NodeAcct
getIsUp()
- Method in class tassl.workflow.resources.
Node
getIterNumLoop(String)
- Method in class tassl.workflow.
WorkflowStage
Return the index number of the loop identified by idLoop
getKeyfile()
- Method in class tassl.workflow.resources.
Resource
getListTasks()
- Method in class tassl.application.workflow.
WorkerForScheduler
getListTasksSize()
- Method in class tassl.application.workflow.
WorkerForScheduler
getLocation()
- Method in class tassl.application.cometcloud.
FileProperties
URI of the dataset.
getLoops()
- Method in class tassl.workflow.
Workflow
getLoopsInvolved()
- Method in class tassl.workflow.
WorkflowStage
getLoopsOrder()
- Method in class tassl.workflow.
Workflow
getLoopsOrigName()
- Method in class tassl.workflow.
Workflow
getMachine_index()
- Method in class tassl.application.workflow.
WorkerForScheduler
getMachine_indexType()
- Method in class tassl.application.workflow.
WorkerForScheduler
getMapTask()
- Method in class tassl.application.workflow.
PolicyAbstract
getMasterPort()
- Method in class tassl.application.cometcloud.
WorkflowMeteorGenericWorker
getMaxPort()
- Method in class tassl.workflow.resources.
Node
getMaxTime()
- Method in class tassl.application.cometcloud.
GenerateTasksObject
Maximum time to execute in slowest proc
getMaxTime()
- Method in class tassl.application.cometcloud.
TaskProperties
Maximum time to execute in slowest proc
getMinPort()
- Method in class tassl.workflow.resources.
Node
getMinTime()
- Method in class tassl.application.cometcloud.
GenerateTasksObject
Minimum time to execute in slowest
getMinTime()
- Method in class tassl.application.cometcloud.
TaskProperties
Minimum time to execute in slowest proc
getName()
- Method in class tassl.application.cometcloud.
FileProperties
When the dataset refers to a file, this is the name of the file
getName()
- Method in class tassl.workflow.resources.
Node
getNestedLoops()
- Method in class tassl.workflow.
Workflow
getNewId(List<String>)
- Method in class tassl.workflow.
WorkflowStage
Generate Stage Id based on participant loops We assume that loopsOrder is only renamed at the beginning of workflow creation
getNodeList()
- Method in class tassl.workflow.resources.
Resource
Return the list of nodes of this site in the format "name or ip": Node
getNodeMap()
- Method in class tassl.application.
InternalStarter
getNonBlockingTransitions()
- Method in class tassl.workflow.
WorkflowStage
getNumberActiveWorkers(String)
- Method in class tassl.workflow.resources.
ResourceCluster
getNumCompletedStages()
- Method in class tassl.workflow.
Workflow
getNumStages()
- Method in class tassl.workflow.
Workflow
getObjectiveAddOnFromNonBlockingT()
- Method in class tassl.workflow.
WorkflowStage
Get objectives to be added due to Non-blocking transitions
getObjectiveType()
- Method in class tassl.workflow.
WorkflowStage
Return the objective type of this stage.
getObjectiveValue(String)
- Method in class tassl.workflow.
WorkflowStage
Get the objective value.
getObjectiveValueOriginal(String)
- Method in class tassl.workflow.
WorkflowStage
Get the original objective value.
getOriginFiles(List<FileProperties>)
- Method in class tassl.application.workflow.
PolicyAbstract
getOutput(String, int)
- Static method in class tassl.application.utils.
CommonUtils
Get a socket connection with address and port.
getOutputInput(String, int)
- Static method in class tassl.application.utils.
CommonUtils
Get a socket connection with address and port.
getOutputInput(String, int, boolean)
- Static method in class tassl.application.utils.
CommonUtils
Get a socket connection with address and port.
getOutputList()
- Method in class tassl.application.cometcloud.
GenerateTasksObject
List of output files as objects of FileProperties
getOutputs()
- Method in class tassl.application.cometcloud.
TaskProperties
getOverhead()
- Method in class tassl.application.workflow.
WorkerForScheduler
getOverhead()
- Method in class tassl.workflow.resources.
Resource
getPeer()
- Method in class tassl.application.node.isolate.
RequestHandlerWfl
getPeerIP()
- Method in class tassl.application.cometcloud.
WorkflowMeteorGenericWorker
getPerformance()
- Method in class tassl.application.workflow.
WorkerForScheduler
getPerformance()
- Method in class tassl.workflow.resources.
Node
getPolicies(String)
- Method in class tassl.application.workflow.
AutonomicScheduler
getPortMapWorker(String, int)
- Method in class tassl.workflow.resources.
Resource
getPreviousResults()
- Method in class tassl.application.cometcloud.
GenerateTasksAbstract
Get results from previous stages
getProperties()
- Method in class tassl.workflow.
WorkflowStage
getProperty(String, String)
- Method in class tassl.application.cometcloud.
GenerateTasksAbstract
getProperty(String)
- Method in class tassl.application.cometcloud.
GenerateTasksAbstract
getProviderConfigFile()
- Method in class tassl.workflow.resources.
ResourceCloud
getProviderType()
- Method in class tassl.workflow.resources.
ResourceCloud
getQuery()
- Method in class tassl.application.cometcloud.
WorkflowTaskTuple
getQuery(String, String, String, String, String)
- Method in class tassl.application.cometcloud.
WorkflowTaskTuple
getQuery(String, String, String, String, String, String)
- Method in class tassl.application.cometcloud.
WorkflowTaskTuple
getReadyToExecute()
- Method in class tassl.application.workflow.
WorkerForScheduler
getRegion()
- Method in class tassl.workflow.resources.
ResourceCloud
getRelatedWorkflowsResults(String)
- Method in class tassl.application.cometcloud.
GenerateTasksAbstract
Get results of all stages of a related workflow id
getRequirement()
- Method in class tassl.application.cometcloud.
TaskProperties
getRequirement()
- Method in class tassl.application.cometcloud.
WorkflowMeteorGenericWorker
getRequirement()
- Method in class tassl.application.cometcloud.
WorkflowTaskTuple
getResources()
- Method in class tassl.application.cometcloud.
AgentResourceManager
getResult()
- Method in class tassl.application.cometcloud.
Results
getResultAddress()
- Method in class tassl.application.cometcloud.
WorkflowMeteorGenericWorker
getResultList()
- Method in class tassl.workflow.
Workflow
getResults(String, String, String)
- Method in class tassl.application.workflow.
WorkflowClient
Get list of Result locations and retrieve them
getServiceObject()
- Method in class tassl.application.
InternalStarter
getServPort()
- Method in class tassl.application.cometcloud.
AgentLite
getServSock()
- Method in class tassl.application.node.isolate.
RequestHandlerWfl
getSiteAddress()
- Method in class tassl.application.workflow.
WorkerForScheduler
getSiteIdentifier()
- Method in class tassl.application.workflow.
WorkerForScheduler
getSitename()
- Method in class tassl.application.cometcloud.
FileProperties
Name of the site where the dataset is located
getSiteZone()
- Method in class tassl.application.workflow.
WorkerForScheduler
getSize()
- Method in class tassl.application.cometcloud.
FileProperties
When the dataset refers to a file, this is its size
getStage(String)
- Method in class tassl.workflow.
Workflow
getStageID()
- Method in class tassl.application.cometcloud.
WorkflowMeteorGenericWorker
getStageID()
- Method in class tassl.application.cometcloud.
WorkflowTaskTuple
getStartTime()
- Method in class tassl.workflow.resources.
NodeAcct
getStartTime()
- Method in class tassl.workflow.
WorkflowStage
Time in milliseconds
getStatistics()
- Method in class tassl.application.cometcloud.
AgentFileServer
getStopTime()
- Method in class tassl.workflow.resources.
NodeAcct
getSupportedApps()
- Method in class tassl.application.workflow.
WorkflowClient
getSupportedApps()
- Method in class tassl.application.workflow.
WorkflowManager
getSupportedApps()
- Method in class tassl.workflow.resources.
Resource
getTask(int)
- Method in class tassl.application.workflow.
WorkerForScheduler
getTaskCost()
- Method in class tassl.application.workflow.
WorkerForScheduler
getTaskId()
- Method in class tassl.application.cometcloud.
Results
getTaskidS()
- Method in class tassl.application.cometcloud.
WorkflowTaskTuple
getTaskParam()
- Method in class tassl.application.cometcloud.
TaskProperties
getTaskParams()
- Method in class tassl.application.cometcloud.
GenerateTasksObject
getTaskProp()
- Method in class tassl.workflow.
WorkflowStage
Return the properties of those tasks that need to be scheduled.
getTaskRequirement()
- Method in class tassl.application.cometcloud.
GenerateTasksObject
getTaskTuple(XmlTuple)
- Method in class tassl.application.cometcloud.
WorkflowTaskTuple
getTaskTupleValues()
- Method in class tassl.application.cometcloud.
TaskProperties
getTemplateQuery()
- Method in class tassl.application.cometcloud.
WorkflowMeteorGenericWorker
getTotalWorkers()
- Method in class tassl.workflow.resources.
Node
getType()
- Method in class tassl.workflow.resources.
NodeAcct
getType_name()
- Method in class tassl.application.workflow.
WorkerForScheduler
getTypebyIp(String)
- Method in class tassl.workflow.resources.
ResourceCloud
Return the type of VM that corresponds to the ip or null if not found
getUserWorker()
- Method in class tassl.workflow.resources.
Resource
getVMAddressbyType(String, String, List<String>)
- Method in class tassl.workflow.resources.
ResourceCloud
Return list of addresses corresponding with VMs from those allocated to the specific stage
getVMLimits()
- Method in class tassl.workflow.resources.
ResourceCloud
getWflId()
- Method in class tassl.workflow.
WorkflowStage
getWflNode()
- Method in class tassl.workflow.resources.
Resource
Return nodes assigned to each workflow
getWflStageWorker(String)
- Method in class tassl.workflow.resources.
Resource
Return the workflowId.stageId where the worker is allocated worker ip:port
getWfManagerName()
- Method in class tassl.application.cometcloud.
WorkflowMeteorGenericWorker
getWfManagerName()
- Method in class tassl.application.cometcloud.
WorkflowTaskTuple
getWkfStageId(int)
- Method in class tassl.application.cometcloud.
WorkflowMaster
Find stage that a task is part of
getWorker()
- Method in class tassl.application.node.isolate.
IsolatedWorker
getWorker_index()
- Method in class tassl.application.workflow.
WorkerForScheduler
getWorkerBasePropertyFile()
- Method in class tassl.workflow.resources.
Resource
getWorkerid()
- Method in class tassl.application.cometcloud.
WorkflowMeteorGenericWorker
getWorkersWorkflowStage(String, String)
- Method in class tassl.workflow.resources.
Resource
Return the workers allocated to a specific stage workflow
getWorkflowID()
- Method in class tassl.application.cometcloud.
WorkflowMeteorGenericWorker
getWorkflowID()
- Method in class tassl.application.cometcloud.
WorkflowTaskTuple
getWorkflowStages()
- Method in class tassl.workflow.
Workflow
Get stages that compose the workflow
getZone()
- Method in class tassl.application.cometcloud.
FileProperties
Zone where the dataset is located
getZone()
- Method in class tassl.workflow.resources.
Resource
globalResources
- Variable in class tassl.application.workflow.
PolicyAbstract
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
PREV LETTER
NEXT LETTER
FRAMES
NO FRAMES
All Classes
A
B
C
D
E
F
G
H
I
J
K
L
M
N
P
Q
R
S
T
U
V
W
X
Z