edu.iu.dsc.tws.tsched.utils

Class TaskAttributes

java.lang.Object

edu.iu.dsc.tws.tsched.utils.TaskAttributes

public class TaskAttributes
extends java.lang.Object

This class is responsible for calculating the required ram, disk, and cpu values. Also, it calculates the total number of task instances in the task graph for each task vertex. And, it is responsible for calculating the parallel task map for the task vertices in the task graph.

Constructor Summary

Constructors

Constructor and Description
TaskAttributes()

Method Summary

Modifier and Type	Method and Description
int	getInstancesPerWorker(java.util.Map<java.lang.String,java.lang.String> graphConstraintsMap)
int	getInstancesPerWorker(Vertex taskVertex, java.util.Map<java.lang.String,java.lang.String> vertexConstraintsMap)
java.util.Map<java.lang.String,java.lang.Integer>	getParallelTaskMap(java.util.Set<Vertex> iTaskSet)
java.util.Map<java.lang.String,java.lang.Integer>	getParallelTaskMap(java.util.Set<Vertex> iTaskSet, java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> nodeConstraintsMap) This method is mainly to generate the parallel task map (maintain order) for the task vertex.
java.util.Map<java.lang.String,java.lang.Integer>	getParallelTaskMap(Vertex taskVertex)
java.util.Map<java.lang.String,java.lang.Integer>	getParallelTaskMap(Vertex taskVertex, java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> nodeConstraintsMap) This method is to generate the parallel task map for the task vertex.
java.util.Map<java.lang.String,java.lang.Double>	getTaskCPUMap(java.util.Set<Vertex> taskVertices) This method retrieve the set of task vertices and check if the task vertex has the user specified cpu value.
java.util.Map<java.lang.String,java.lang.Double>	getTaskDiskMap(java.util.Set<Vertex> taskVertices) This method retrieve the set of task vertices and check if the task vertex has the user specified disk value.
java.util.Map<java.lang.String,java.lang.Double>	getTaskNetworkMap(java.util.Set<Vertex> taskVertices) This method retrieve the set of task vertices and check if the task vertex has the user specified network value.
java.util.Map<java.lang.String,java.lang.Double>	getTaskRamMap(java.util.Set<Vertex> taskVertices) This method retrieve the set of task vertices and check if the task vertex has the user specified ram value.
int	getTotalNumberOfInstances(java.util.Set<Vertex> iTaskSet) This method is to calculate the total number of task instances in the task graph which is based on the parallelism specified in the task graph or else from the task configuration default values.
int	getTotalNumberOfInstances(java.util.Set<Vertex> iTaskSet, java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> nodeConstraintsMap)
int	getTotalNumberOfInstances(Vertex taskVertex)
int	getTotalNumberOfInstances(Vertex taskVertex, java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> nodeConstraintsMap)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskAttributes

public TaskAttributes()

Method Detail

getInstancesPerWorker

public int getInstancesPerWorker(Vertex taskVertex,
                                 java.util.Map<java.lang.String,java.lang.String> vertexConstraintsMap)

getInstancesPerWorker

public int getInstancesPerWorker(java.util.Map<java.lang.String,java.lang.String> graphConstraintsMap)

getTotalNumberOfInstances

public int getTotalNumberOfInstances(java.util.Set<Vertex> iTaskSet)

This method is to calculate the total number of task instances in the task graph which is based on the parallelism specified in the task graph or else from the task configuration default values.

getTotalNumberOfInstances

public int getTotalNumberOfInstances(Vertex taskVertex)

getTotalNumberOfInstances

public int getTotalNumberOfInstances(java.util.Set<Vertex> iTaskSet,
                                     java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> nodeConstraintsMap)

getTotalNumberOfInstances

public int getTotalNumberOfInstances(Vertex taskVertex,
                                     java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> nodeConstraintsMap)

getParallelTaskMap

public java.util.Map<java.lang.String,java.lang.Integer> getParallelTaskMap(java.util.Set<Vertex> iTaskSet,
                                                                            java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> nodeConstraintsMap)

This method is mainly to generate the parallel task map (maintain order) for the task vertex. If the user specifies the parallelism value greater than or equal "1" will be considered as a parallelism value. Otherwise, the system assign the default parallelism value to the task vertex from the task scheduling configuration file.

getParallelTaskMap

public java.util.Map<java.lang.String,java.lang.Integer> getParallelTaskMap(Vertex taskVertex,
                                                                            java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> nodeConstraintsMap)

This method is to generate the parallel task map for the task vertex. If the user specifies the parallelism value greater than or equal "1" will be considered as a parallelism value. Otherwise, the system assign the default parallelism value to the task vertex from the task scheduling configuration file.

getParallelTaskMap

public java.util.Map<java.lang.String,java.lang.Integer> getParallelTaskMap(java.util.Set<Vertex> iTaskSet)

getParallelTaskMap

public java.util.Map<java.lang.String,java.lang.Integer> getParallelTaskMap(Vertex taskVertex)

getTaskRamMap

public java.util.Map<java.lang.String,java.lang.Double> getTaskRamMap(java.util.Set<Vertex> taskVertices)

This method retrieve the set of task vertices and check if the task vertex has the user specified ram value. If the user doesn't specify the required ram configuration it will assign the default ram value from the task configuration file and store it in the map.

getTaskDiskMap

public java.util.Map<java.lang.String,java.lang.Double> getTaskDiskMap(java.util.Set<Vertex> taskVertices)

This method retrieve the set of task vertices and check if the task vertex has the user specified disk value. If the user doesn't specify the required disk configuration it will assign the default disk value from the task configuration file and store it in the map.

getTaskCPUMap

public java.util.Map<java.lang.String,java.lang.Double> getTaskCPUMap(java.util.Set<Vertex> taskVertices)

This method retrieve the set of task vertices and check if the task vertex has the user specified cpu value. If the user doesn't specify the required cpu configuration it will assign the default cpu value from the task configuration file and store it in the map.

getTaskNetworkMap

public java.util.Map<java.lang.String,java.lang.Double> getTaskNetworkMap(java.util.Set<Vertex> taskVertices)

This method retrieve the set of task vertices and check if the task vertex has the user specified network value. If the user doesn't specify the required network configuration it will assign the default network value from the task configuration file and store it in the map.