tassl.application.workflow.policysample
Class Deadline

java.lang.Object
  extended by tassl.application.workflow.PolicyAbstract
      extended by tassl.application.workflow.policysample.Deadline

public class Deadline
extends PolicyAbstract


Field Summary
 
Fields inherited from class tassl.application.workflow.PolicyAbstract
AgentList, globalResources, MapTask
 
Constructor Summary
Deadline()
           
 
Method Summary
protected  java.util.HashMap DeadlineLocalityAware(java.lang.String wflId, WorkflowStage stage, java.lang.Object properties, java.util.HashMap<java.lang.String,java.util.List<WorkerForScheduler>> globalSlots)
           
protected  java.util.HashMap DeadlineLocalityAwareCost(java.lang.String wflId, WorkflowStage stage, java.lang.String properties, java.util.HashMap<java.lang.String,java.util.List<WorkerForScheduler>> globalSlots)
           
protected  java.util.HashMap DeadlineLocalityAwareData(java.lang.String wflId, WorkflowStage stage, java.lang.String properties, java.util.HashMap<java.lang.String,java.util.List<WorkerForScheduler>> globalSlots)
           
protected  java.util.HashMap DeadlineLocalityAwareProc(java.lang.String wflId, WorkflowStage stage, java.lang.String properties, java.util.HashMap<java.lang.String,java.util.List<WorkerForScheduler>> globalSlots)
           
 java.util.HashMap scheduleStage(java.lang.String wkflId, WorkflowStage stage, java.util.HashMap<java.lang.String,java.util.List<WorkerForScheduler>> globalSlots)
           
 
Methods inherited from class tassl.application.workflow.PolicyAbstract
calculateInputTransfer, calculateOutputTransfer, checkInputConstraints, getDestinationFiles, getMapTask, getOriginFiles, initialize
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Deadline

public Deadline()
Method Detail

scheduleStage

public java.util.HashMap scheduleStage(java.lang.String wkflId,
                                       WorkflowStage stage,
                                       java.util.HashMap<java.lang.String,java.util.List<WorkerForScheduler>> globalSlots)
Specified by:
scheduleStage in class PolicyAbstract
globalSlots - available scheduling slots (workers)
Returns:
mapTasks. It will be empty if something failed

DeadlineLocalityAware

protected java.util.HashMap DeadlineLocalityAware(java.lang.String wflId,
                                                  WorkflowStage stage,
                                                  java.lang.Object properties,
                                                  java.util.HashMap<java.lang.String,java.util.List<WorkerForScheduler>> globalSlots)

DeadlineLocalityAwareProc

protected java.util.HashMap DeadlineLocalityAwareProc(java.lang.String wflId,
                                                      WorkflowStage stage,
                                                      java.lang.String properties,
                                                      java.util.HashMap<java.lang.String,java.util.List<WorkerForScheduler>> globalSlots)

DeadlineLocalityAwareCost

protected java.util.HashMap DeadlineLocalityAwareCost(java.lang.String wflId,
                                                      WorkflowStage stage,
                                                      java.lang.String properties,
                                                      java.util.HashMap<java.lang.String,java.util.List<WorkerForScheduler>> globalSlots)

DeadlineLocalityAwareData

protected java.util.HashMap DeadlineLocalityAwareData(java.lang.String wflId,
                                                      WorkflowStage stage,
                                                      java.lang.String properties,
                                                      java.util.HashMap<java.lang.String,java.util.List<WorkerForScheduler>> globalSlots)