edu.iu.dsc.tws.tsched.spi.common

Class TaskSchedulerContext

java.lang.Object

edu.iu.dsc.tws.api.config.Context

edu.iu.dsc.tws.tsched.spi.common.TaskSchedulerContext

public class TaskSchedulerContext
extends Context

This class is to represent the default values for the task instances and task scheduler logical container values.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	TWISTER2_TASK_SCHEDULER_CONTAINER_INSTANCE_LATENCY

Fields inherited from class edu.iu.dsc.tws.api.config.Context

AURORA_SCRIPT, CHECKPOINT_YAML, CLUSTER, CLUSTER_CONF, CLUSTER_HOME, CORE_YAML, DATA_YAML, defaults, GRAPH_TYPE, HOME, JAVA_HOME, JOB, JOB_ARCHIVE_DIRECTORY, JOB_ID, JOB_NAME, JOB_OBJECT, NETWORK_YAML, OPERATION_NAME, OVERRIDE_YAML, RESOURCE_SCHEDULER_YAML, STREAMING, substitutions, TASK_YAML, TWISTER2_BANDWIDTH, TWISTER2_BIN, TWISTER2_CLUSTER_TYPE, TWISTER2_COMMON_CONF_DIR, TWISTER2_CONF, TWISTER2_CONTAINER_ID, TWISTER2_DIRECT_EDGE, TWISTER2_DIST, TWISTER2_GRAPH_JOB, TWISTER2_HOME, TWISTER2_LATENCY, TWISTER2_LIB, TWISTER2_MAX_TASK_INSTANCES_PER_WORKER, TWISTER2_TASK_INSTANCE_ODD_PARALLELISM, TWISTER2_TSET_JOB, TWISTER2_WORKER_INSTANCES, TWISTER2_WORKER_INSTANCES_DEFAULT, USER_NAME, VERBOSE

Constructor Summary

Constructors

Constructor and Description
TaskSchedulerContext()

Method Summary

Modifier and Type	Method and Description
static java.lang.String	batchTaskSchedulingClass(Config cfg)
static java.lang.String	batchTaskSchedulingMode(Config cfg)
static double	containerCpuPadding(Config cfg)
static double	containerDiskPadding(Config cfg)
static double	containerInstanceBandwidth(Config cfg)
static double	containerInstanceCpu(Config cfg)
static double	containerInstanceDisk(Config cfg)
static double	containerInstanceLatency(Config cfg)
static double	containerInstanceNetwork(Config cfg)
static double	containerInstanceRam(Config cfg)
static int	containerPaddingPercentage(Config cfg)
static double	containerRamPadding(Config cfg)
static double	datanodeInstanceBandwidth(Config cfg)
static double	datanodeInstanceLatency(Config cfg)
static int	defaultTaskInstancesPerContainer(Config cfg)
static java.lang.String	streamingTaskSchedulingClass(Config cfg)
static java.lang.String	streamingTaskSchedulingMode(Config cfg)
static double	taskInstanceCpu(Config cfg)
static double	taskInstanceDisk(Config cfg)
static double	taskInstanceNetwork(Config cfg)
static double	taskInstanceRam(Config cfg)
static int	taskParallelism(Config cfg)
static java.lang.String	taskType(Config cfg)

Methods inherited from class edu.iu.dsc.tws.api.config.Context

auroraScript, checkpointCofigurationFile, checkpointConfigurationFile, clusterType, commonConfDir, conf, containerId, dataConfigurationFile, distDirectory, getDefaults, getDoublePropertyValue, getIntPropertyValue, getLongPropertyValue, getStringPropertyValue, isKubernetesCluster, jobId, jobName, libDirectory, networkConfigurationFile, resourceSchedulerConfigurationFile, systemConfigurationFile, taskConfigurationFile, twister2Home, userName, verbose, workerInstances

Methods inherited from class java.lang.Object

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

Field Detail

TWISTER2_TASK_SCHEDULER_CONTAINER_INSTANCE_LATENCY

public static final java.lang.String TWISTER2_TASK_SCHEDULER_CONTAINER_INSTANCE_LATENCY

See Also:

Constant Field Values

Constructor Detail

TaskSchedulerContext

public TaskSchedulerContext()

Method Detail

streamingTaskSchedulingMode

public static java.lang.String streamingTaskSchedulingMode(Config cfg)

batchTaskSchedulingMode

public static java.lang.String batchTaskSchedulingMode(Config cfg)

streamingTaskSchedulingClass

public static java.lang.String streamingTaskSchedulingClass(Config cfg)

batchTaskSchedulingClass

public static java.lang.String batchTaskSchedulingClass(Config cfg)

taskType

public static java.lang.String taskType(Config cfg)

taskInstanceRam

public static double taskInstanceRam(Config cfg)

taskInstanceDisk

public static double taskInstanceDisk(Config cfg)

taskInstanceCpu

public static double taskInstanceCpu(Config cfg)

taskInstanceNetwork

public static double taskInstanceNetwork(Config cfg)

containerInstanceRam

public static double containerInstanceRam(Config cfg)

containerInstanceDisk

public static double containerInstanceDisk(Config cfg)

containerInstanceCpu

public static double containerInstanceCpu(Config cfg)

containerInstanceNetwork

public static double containerInstanceNetwork(Config cfg)

containerInstanceBandwidth

public static double containerInstanceBandwidth(Config cfg)

containerInstanceLatency

public static double containerInstanceLatency(Config cfg)

taskParallelism

public static int taskParallelism(Config cfg)

defaultTaskInstancesPerContainer

public static int defaultTaskInstancesPerContainer(Config cfg)

containerRamPadding

public static double containerRamPadding(Config cfg)

containerDiskPadding

public static double containerDiskPadding(Config cfg)

containerCpuPadding

public static double containerCpuPadding(Config cfg)

containerPaddingPercentage

public static int containerPaddingPercentage(Config cfg)

datanodeInstanceBandwidth

public static double datanodeInstanceBandwidth(Config cfg)

datanodeInstanceLatency

public static double datanodeInstanceLatency(Config cfg)