tassl.application.workflow.policysample
Class MinRun

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

public class MinRun
extends PolicyAbstract


Field Summary
 
Fields inherited from class tassl.application.workflow.PolicyAbstract
AgentList, globalResources, MapTask
 
Constructor Summary
MinRun()
           
 
Method Summary
protected  java.util.HashMap MinRunningTime(java.lang.String wflId, WorkflowStage stage, java.lang.Object properties, java.util.HashMap<java.lang.String,java.util.List<WorkerForScheduler>> globalSlots)
          This assign each task to the resource that gives the minimum completion time.
protected  java.util.HashMap MinRunningTimeLimit(java.lang.String wflId, WorkflowStage stage, java.lang.Object properties, java.util.HashMap<java.lang.String,java.util.List<WorkerForScheduler>> globalSlots)
          This assign each task to the resource that gives the minimum completion time.
protected  java.util.HashMap MinRunningTimeNoData(java.lang.String wflId, WorkflowStage stage, java.lang.Object properties, java.util.HashMap<java.lang.String,java.util.List<WorkerForScheduler>> globalSlots)
          This assign each task to the resource that gives the minimum completion time.
 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

MinRun

public MinRun()
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

MinRunningTimeNoData

protected java.util.HashMap MinRunningTimeNoData(java.lang.String wflId,
                                                 WorkflowStage stage,
                                                 java.lang.Object properties,
                                                 java.util.HashMap<java.lang.String,java.util.List<WorkerForScheduler>> globalSlots)
This assign each task to the resource that gives the minimum completion time. Data is not considered. This is going to use all VMs

Parameters:
wflId -
stage -
properties - we use it here to be data aware or not. for experiments
Returns:

MinRunningTime

protected java.util.HashMap MinRunningTime(java.lang.String wflId,
                                           WorkflowStage stage,
                                           java.lang.Object properties,
                                           java.util.HashMap<java.lang.String,java.util.List<WorkerForScheduler>> globalSlots)
This assign each task to the resource that gives the minimum completion time. This is going to use all VMs

Parameters:
wflId -
stage -
properties - we use it here to be data aware or not. for experiments
Returns:

MinRunningTimeLimit

protected java.util.HashMap MinRunningTimeLimit(java.lang.String wflId,
                                                WorkflowStage stage,
                                                java.lang.Object properties,
                                                java.util.HashMap<java.lang.String,java.util.List<WorkerForScheduler>> globalSlots)
This assign each task to the resource that gives the minimum completion time. This version uses a maximum of machines specified in the value field

Parameters:
wflId -
stage -
properties - we use it here to be data aware or not. for experiments
Returns: