edu.iu.dsc.tws.master

Class JobMasterContext

java.lang.Object

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

edu.iu.dsc.tws.master.JobMasterContext

public class JobMasterContext
extends Context

Configuration parameters for JobMaster

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DASHBOARD_HOST
static java.lang.String	JM_TO_DASHBOARD_CONNECTIONS
static int	JM_TO_DASHBOARD_CONNECTIONS_DEFAULT
static java.lang.String	JOB_MASTER_CPU
static double	JOB_MASTER_CPU_DEFAULT
static java.lang.String	JOB_MASTER_IP
static java.lang.String	JOB_MASTER_PORT
static int	JOB_MASTER_PORT_DEFAULT
static java.lang.String	JOB_MASTER_RAM
static int	JOB_MASTER_RAM_DEFAULT
static java.lang.String	JOB_MASTER_RUNS_IN_CLIENT
static boolean	JOB_MASTER_RUNS_IN_CLIENT_DEFAULT
static java.lang.String	JOB_MASTER_USED
static java.lang.String	PERSISTENT_VOLUME
static double	PERSISTENT_VOLUME_DEFAULT
static java.lang.String	VOLATILE_VOLUME
static double	VOLATILE_VOLUME_DEFAULT
static java.lang.String	WORKER_TO_JOB_MASTER_RESPONSE_WAIT_DURATION
static long	WORKER_TO_JOB_MASTER_RESPONSE_WAIT_DURATION_DEFAULT

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
JobMasterContext()

Method Summary

Modifier and Type	Method and Description
static java.lang.String	dashboardHost(Config cfg)
static boolean	isJobMasterUsed(Config cfg)
static int	jmToDashboardConnections(Config cfg)
static double	jobMasterCpu(Config cfg)
static java.lang.String	jobMasterIP(Config cfg)
static int	jobMasterPort(Config cfg)
static int	jobMasterRAM(Config cfg)
static boolean	jobMasterRunsInClient(Config cfg)
static boolean	persistentVolumeRequested(Config cfg)
static double	persistentVolumeSize(Config cfg)
static long	responseWaitDuration(Config cfg)
static Config	updateDashboardHost(Config cfg, java.lang.String dashAddress)
static boolean	volatileVolumeRequested(Config cfg)
static double	volatileVolumeSize(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

JOB_MASTER_USED

public static final java.lang.String JOB_MASTER_USED

See Also:

Constant Field Values

JOB_MASTER_RUNS_IN_CLIENT_DEFAULT

public static final boolean JOB_MASTER_RUNS_IN_CLIENT_DEFAULT

See Also:

Constant Field Values

JOB_MASTER_RUNS_IN_CLIENT

public static final java.lang.String JOB_MASTER_RUNS_IN_CLIENT

See Also:

Constant Field Values

JOB_MASTER_PORT_DEFAULT

public static final int JOB_MASTER_PORT_DEFAULT

See Also:

Constant Field Values

JOB_MASTER_PORT

public static final java.lang.String JOB_MASTER_PORT

See Also:

Constant Field Values

JOB_MASTER_IP

public static final java.lang.String JOB_MASTER_IP

See Also:

Constant Field Values

DASHBOARD_HOST

public static final java.lang.String DASHBOARD_HOST

See Also:

Constant Field Values

WORKER_TO_JOB_MASTER_RESPONSE_WAIT_DURATION_DEFAULT

public static final long WORKER_TO_JOB_MASTER_RESPONSE_WAIT_DURATION_DEFAULT

See Also:

Constant Field Values

WORKER_TO_JOB_MASTER_RESPONSE_WAIT_DURATION

public static final java.lang.String WORKER_TO_JOB_MASTER_RESPONSE_WAIT_DURATION

See Also:

Constant Field Values

JOB_MASTER_CPU_DEFAULT

public static final double JOB_MASTER_CPU_DEFAULT

See Also:

Constant Field Values

JOB_MASTER_CPU

public static final java.lang.String JOB_MASTER_CPU

See Also:

Constant Field Values

JOB_MASTER_RAM_DEFAULT

public static final int JOB_MASTER_RAM_DEFAULT

See Also:

Constant Field Values

JOB_MASTER_RAM

public static final java.lang.String JOB_MASTER_RAM

See Also:

Constant Field Values

VOLATILE_VOLUME_DEFAULT

public static final double VOLATILE_VOLUME_DEFAULT

See Also:

Constant Field Values

VOLATILE_VOLUME

public static final java.lang.String VOLATILE_VOLUME

See Also:

Constant Field Values

PERSISTENT_VOLUME_DEFAULT

public static final double PERSISTENT_VOLUME_DEFAULT

See Also:

Constant Field Values

PERSISTENT_VOLUME

public static final java.lang.String PERSISTENT_VOLUME

See Also:

Constant Field Values

JM_TO_DASHBOARD_CONNECTIONS_DEFAULT

public static final int JM_TO_DASHBOARD_CONNECTIONS_DEFAULT

See Also:

Constant Field Values

JM_TO_DASHBOARD_CONNECTIONS

public static final java.lang.String JM_TO_DASHBOARD_CONNECTIONS

See Also:

Constant Field Values

Constructor Detail

JobMasterContext

public JobMasterContext()

Method Detail

jobMasterRunsInClient

public static boolean jobMasterRunsInClient(Config cfg)

jobMasterPort

public static int jobMasterPort(Config cfg)

jobMasterIP

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

responseWaitDuration

public static long responseWaitDuration(Config cfg)

volatileVolumeSize

public static double volatileVolumeSize(Config cfg)

volatileVolumeRequested

public static boolean volatileVolumeRequested(Config cfg)

persistentVolumeSize

public static double persistentVolumeSize(Config cfg)

persistentVolumeRequested

public static boolean persistentVolumeRequested(Config cfg)

jobMasterCpu

public static double jobMasterCpu(Config cfg)

jobMasterRAM

public static int jobMasterRAM(Config cfg)

dashboardHost

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

jmToDashboardConnections

public static int jmToDashboardConnections(Config cfg)

isJobMasterUsed

public static boolean isJobMasterUsed(Config cfg)

updateDashboardHost

public static Config updateDashboardHost(Config cfg,
                                         java.lang.String dashAddress)