tassl.application.workflow.policysample
Class Deadline

java.lang.Object
  tassl.application.workflow.PolicyAbstract
      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)