edu.iu.dsc.tws.api.compute.executor

Class ExecutorContext

java.lang.Object

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

edu.iu.dsc.tws.api.compute.executor.ExecutorContext

public class ExecutorContext
extends Context

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	BATCH_EXECUTOR
static java.lang.String	BATCH_EXECUTOR_SHARING
static java.lang.String	BATCH_EXECUTOR_SHARING_SEP_COMM
static java.lang.String	INSTANCE_QUEUE_HIGH_WATERMARK
static java.lang.String	INSTANCE_QUEUE_LOW_WATERMARK
static java.lang.String	STREAM_EXECUTOR
static java.lang.String	STREAM_EXECUTOR_ALL_SHARING
static java.lang.String	STREAM_EXECUTOR_DEDICATED_COMM
static java.lang.String	THREADS_PER_WORKER
static java.lang.String	TWISTER2_RUNTIME_OBJECT

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

Method Summary

Modifier and Type	Method and Description
static java.lang.String	getBatchExecutor(Config cfg)
static java.lang.String	getStreamExecutor(Config cfg)
static int	instanceQueueHighWaterMark(Config cfg)
static int	instanceQueueLowWaterMark(Config cfg)
static int	threadsPerContainer(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

THREADS_PER_WORKER

public static final java.lang.String THREADS_PER_WORKER

See Also:

Constant Field Values

INSTANCE_QUEUE_LOW_WATERMARK

public static final java.lang.String INSTANCE_QUEUE_LOW_WATERMARK

See Also:

Constant Field Values

INSTANCE_QUEUE_HIGH_WATERMARK

public static final java.lang.String INSTANCE_QUEUE_HIGH_WATERMARK

See Also:

Constant Field Values

BATCH_EXECUTOR

public static final java.lang.String BATCH_EXECUTOR

See Also:

Constant Field Values

STREAM_EXECUTOR

public static final java.lang.String STREAM_EXECUTOR

See Also:

Constant Field Values

BATCH_EXECUTOR_SHARING_SEP_COMM

public static final java.lang.String BATCH_EXECUTOR_SHARING_SEP_COMM

See Also:

Constant Field Values

BATCH_EXECUTOR_SHARING

public static final java.lang.String BATCH_EXECUTOR_SHARING

See Also:

Constant Field Values

STREAM_EXECUTOR_ALL_SHARING

public static final java.lang.String STREAM_EXECUTOR_ALL_SHARING

See Also:

Constant Field Values

STREAM_EXECUTOR_DEDICATED_COMM

public static final java.lang.String STREAM_EXECUTOR_DEDICATED_COMM

See Also:

Constant Field Values

TWISTER2_RUNTIME_OBJECT

public static final java.lang.String TWISTER2_RUNTIME_OBJECT

See Also:

Constant Field Values

Constructor Detail

ExecutorContext

public ExecutorContext()

Method Detail

threadsPerContainer

public static int threadsPerContainer(Config cfg)

instanceQueueLowWaterMark

public static int instanceQueueLowWaterMark(Config cfg)

instanceQueueHighWaterMark

public static int instanceQueueHighWaterMark(Config cfg)

getBatchExecutor

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

getStreamExecutor

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