edu.iu.dsc.tws.tsched.spi.taskschedule

Class TaskInstanceMapCalculation

java.lang.Object

edu.iu.dsc.tws.tsched.spi.taskschedule.TaskInstanceMapCalculation

public class TaskInstanceMapCalculation
extends java.lang.Object

This class constructs the task instance map which is based on the required ram, disk, and cpu values of the task graph.

Constructor Summary

Constructors

Constructor and Description
TaskInstanceMapCalculation(java.lang.Double instanceRam, java.lang.Double instanceDisk, java.lang.Double instanceCPU)

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.Integer,java.util.Map<TaskInstanceId,java.lang.Double>>	getInstancesCPUMapInContainer(java.util.Map<java.lang.Integer,java.util.List<TaskInstanceId>> containerInstanceAllocationMap, java.util.Set<Vertex> taskVertexSet) It receives the container instance allocation map and calculate the required number of task instances with cpu values.
java.util.Map<java.lang.Integer,java.util.Map<TaskInstanceId,java.lang.Double>>	getInstancesDiskMapInContainer(java.util.Map<java.lang.Integer,java.util.List<TaskInstanceId>> containerInstanceAllocationMap, java.util.Set<Vertex> taskVertexSet) It receives the container instance allocation map and calculate the required number of instances with disk values.
java.util.Map<java.lang.Integer,java.util.Map<TaskInstanceId,java.lang.Double>>	getInstancesRamMapInContainer(java.util.Map<java.lang.Integer,java.util.List<TaskInstanceId>> containerInstanceAllocationMap, java.util.Set<Vertex> taskVertexSet) It receives the container instance allocation map and calculate the required number of task instances with ram values.

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskInstanceMapCalculation

public TaskInstanceMapCalculation(java.lang.Double instanceRam,
                                  java.lang.Double instanceDisk,
                                  java.lang.Double instanceCPU)

Method Detail

getInstancesRamMapInContainer

public java.util.Map<java.lang.Integer,java.util.Map<TaskInstanceId,java.lang.Double>> getInstancesRamMapInContainer(java.util.Map<java.lang.Integer,java.util.List<TaskInstanceId>> containerInstanceAllocationMap,
                                                                                                                     java.util.Set<Vertex> taskVertexSet)

It receives the container instance allocation map and calculate the required number of task instances with ram values.

Parameters:

containerInstanceAllocationMap -

taskVertexSet -

Returns:

getInstancesDiskMapInContainer

public java.util.Map<java.lang.Integer,java.util.Map<TaskInstanceId,java.lang.Double>> getInstancesDiskMapInContainer(java.util.Map<java.lang.Integer,java.util.List<TaskInstanceId>> containerInstanceAllocationMap,
                                                                                                                      java.util.Set<Vertex> taskVertexSet)

It receives the container instance allocation map and calculate the required number of instances with disk values.

Parameters:

containerInstanceAllocationMap -

taskVertexSet -

Returns:

getInstancesCPUMapInContainer

public java.util.Map<java.lang.Integer,java.util.Map<TaskInstanceId,java.lang.Double>> getInstancesCPUMapInContainer(java.util.Map<java.lang.Integer,java.util.List<TaskInstanceId>> containerInstanceAllocationMap,
                                                                                                                     java.util.Set<Vertex> taskVertexSet)

It receives the container instance allocation map and calculate the required number of task instances with cpu values.

Parameters:

containerInstanceAllocationMap -

taskVertexSet -

Returns: