tassl.application.workflow.policysample
Class MinRun

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