edu.iu.dsc.tws.tsched.builder

Class TaskSchedulePlanBuilder

java.lang.Object

edu.iu.dsc.tws.tsched.builder.TaskSchedulePlanBuilder

public class TaskSchedulePlanBuilder
extends java.lang.Object

This class is mainly responsible for building the task schedule plan.

Constructor Summary

Constructors

Constructor and Description
TaskSchedulePlanBuilder(int scheduleId, TaskSchedulePlan previousTaskSchedulePlan)

Method Summary

Modifier and Type	Method and Description
TaskSchedulePlanBuilder	addInstance(java.lang.Integer containerId, java.lang.String taskName)
void	addInstance(Scorer<Container> scorer, java.lang.String taskName) It will add the task instance to the container based on the container score value.
TaskSchedulePlan	build() This method first validates the available resource settings and invoke the build container plans method to build the container based on the task instance ram, disk, and cpu map values.
java.util.Map<java.lang.Integer,Container>	getContainers()
int	getJobId()
TaskSchedulePlanBuilder	setContainerMaximumResourceValue(Resource containerMaxResourceValue)
void	setContainers(java.util.Map<java.lang.Integer,Container> containers)
TaskSchedulePlanBuilder	setInstanceDefaultResourceValue(Resource defaultResourcevalue)
void	setJobId(int jobId)
TaskSchedulePlanBuilder	setRequestedContainerPadding(int reqContainerPadding)
TaskSchedulePlanBuilder	setTaskCpuMap(java.util.Map<java.lang.String,java.lang.Double> taskcpuMap)
TaskSchedulePlanBuilder	setTaskDiskMap(java.util.Map<java.lang.String,java.lang.Double> taskdiskMap)
TaskSchedulePlanBuilder	setTaskRamMap(java.util.Map<java.lang.String,java.lang.Double> taskramMap)
TaskSchedulePlanBuilder	updateNumContainers(int numOfContainers)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TaskSchedulePlanBuilder

public TaskSchedulePlanBuilder(int scheduleId,
                               TaskSchedulePlan previousTaskSchedulePlan)

Method Detail

getContainers

public java.util.Map<java.lang.Integer,Container> getContainers()

setContainers

public void setContainers(java.util.Map<java.lang.Integer,Container> containers)

setTaskRamMap

public TaskSchedulePlanBuilder setTaskRamMap(java.util.Map<java.lang.String,java.lang.Double> taskramMap)

setTaskDiskMap

public TaskSchedulePlanBuilder setTaskDiskMap(java.util.Map<java.lang.String,java.lang.Double> taskdiskMap)

setTaskCpuMap

public TaskSchedulePlanBuilder setTaskCpuMap(java.util.Map<java.lang.String,java.lang.Double> taskcpuMap)

getJobId

public int getJobId()

setJobId

public void setJobId(int jobId)

setInstanceDefaultResourceValue

public TaskSchedulePlanBuilder setInstanceDefaultResourceValue(Resource defaultResourcevalue)

setContainerMaximumResourceValue

public TaskSchedulePlanBuilder setContainerMaximumResourceValue(Resource containerMaxResourceValue)

setRequestedContainerPadding

public TaskSchedulePlanBuilder setRequestedContainerPadding(int reqContainerPadding)

updateNumContainers

public TaskSchedulePlanBuilder updateNumContainers(int numOfContainers)

addInstance

public TaskSchedulePlanBuilder addInstance(java.lang.Integer containerId,
                                           java.lang.String taskName)
                                    throws TaskSchedulerException

Throws:

TaskSchedulerException

addInstance

public void addInstance(Scorer<Container> scorer,
                        java.lang.String taskName)
                 throws TaskSchedulerException

It will add the task instance to the container based on the container score value.

Throws:

TaskSchedulerException

build

public TaskSchedulePlan build()

This method first validates the available resource settings and invoke the build container plans method to build the container based on the task instance ram, disk, and cpu map values.