edu.iu.dsc.tws.api.config

Class Context

java.lang.Object

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

Direct Known Subclasses:

CommunicationContext, DataContext, ExecutorContext, FaultToleranceContext, HdfsDataContext, JobMasterContext, LMDBMemoryManagerContext, MemoryManagerContext, SchedulerContext, TaskSchedulerContext, TCPContext, ZKContext

public class Context
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigEntry	AURORA_SCRIPT
static ConfigEntry	CHECKPOINT_YAML
static ConfigEntry	CLUSTER
static ConfigEntry	CLUSTER_CONF
static ConfigEntry	CLUSTER_HOME
static ConfigEntry	CORE_YAML
static ConfigEntry	DATA_YAML
protected static java.util.Map<java.lang.String,java.lang.Object>	defaults
static java.lang.String	GRAPH_TYPE
static ConfigEntry	HOME
static ConfigEntry	JAVA_HOME
static ConfigEntry	JOB
static java.lang.String	JOB_ARCHIVE_DIRECTORY
static java.lang.String	JOB_ID
static java.lang.String	JOB_NAME
static java.lang.String	JOB_OBJECT
static ConfigEntry	NETWORK_YAML
static java.lang.String	OPERATION_NAME Name of the operation in the current configuration
static ConfigEntry	OVERRIDE_YAML
static ConfigEntry	RESOURCE_SCHEDULER_YAML
static java.lang.String	STREAMING If it is streaming environment, this property will be set
protected static java.util.Map<java.lang.String,ConfigEntry>	substitutions
static ConfigEntry	TASK_YAML
static java.lang.String	TWISTER2_BANDWIDTH
static ConfigEntry	TWISTER2_BIN
static java.lang.String	TWISTER2_CLUSTER_TYPE
static java.lang.String	TWISTER2_COMMON_CONF_DIR
static ConfigEntry	TWISTER2_CONF
static java.lang.String	TWISTER2_CONTAINER_ID
static java.lang.String	TWISTER2_DIRECT_EDGE
static ConfigEntry	TWISTER2_DIST
static java.lang.String	TWISTER2_GRAPH_JOB
static ConfigEntry	TWISTER2_HOME
static java.lang.String	TWISTER2_LATENCY
static ConfigEntry	TWISTER2_LIB
static java.lang.String	TWISTER2_MAX_TASK_INSTANCES_PER_WORKER
static java.lang.String	TWISTER2_TASK_INSTANCE_ODD_PARALLELISM
static java.lang.String	TWISTER2_TSET_JOB
static java.lang.String	TWISTER2_WORKER_INSTANCES
static int	TWISTER2_WORKER_INSTANCES_DEFAULT
static java.lang.String	USER_NAME
static ConfigEntry	VERBOSE

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Context()

Method Summary

Modifier and Type	Method and Description
static java.lang.String	auroraScript(Config cfg)
static java.lang.String	checkpointCofigurationFile(Config cfg)
static java.lang.String	checkpointConfigurationFile(Config cfg)
static java.lang.String	clusterType(Config cfg)
static java.lang.String	commonConfDir(Config cfg)
static java.lang.String	conf(Config cfg)
static java.lang.String	containerId(Config cfg)
static java.lang.String	dataConfigurationFile(Config cfg)
static java.lang.String	distDirectory(Config cfg)
static java.util.Map<java.lang.String,java.lang.Object>	getDefaults()
static double	getDoublePropertyValue(Config cfg, java.lang.String name, double def)
static int	getIntPropertyValue(Config cfg, java.lang.String name, int def)
static long	getLongPropertyValue(Config cfg, java.lang.String name, long def)
static java.lang.String	getStringPropertyValue(Config cfg, java.lang.String name, java.lang.String def)
static boolean	isKubernetesCluster(Config cfg)
static java.lang.String	jobId(Config cfg)
static java.lang.String	jobName(Config cfg)
static java.lang.String	libDirectory(Config cfg)
static java.lang.String	networkConfigurationFile(Config cfg)
static java.lang.String	resourceSchedulerConfigurationFile(Config cfg)
static java.lang.String	systemConfigurationFile(Config cfg)
static java.lang.String	taskConfigurationFile(Config cfg)
static java.lang.String	twister2Home(Config cfg)
static java.lang.String	userName(Config cfg)
static java.lang.Boolean	verbose(Config cfg)
static int	workerInstances(Config cfg)

Methods inherited from class java.lang.Object

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

Field Detail

substitutions

protected static java.util.Map<java.lang.String,ConfigEntry> substitutions

defaults

protected static java.util.Map<java.lang.String,java.lang.Object> defaults

TWISTER2_HOME

public static final ConfigEntry TWISTER2_HOME

HOME

public static final ConfigEntry HOME

TWISTER2_BIN

public static final ConfigEntry TWISTER2_BIN

TWISTER2_CONF

public static final ConfigEntry TWISTER2_CONF

TWISTER2_COMMON_CONF_DIR

public static final java.lang.String TWISTER2_COMMON_CONF_DIR

See Also:

Constant Field Values

TWISTER2_LIB

public static final ConfigEntry TWISTER2_LIB

TWISTER2_DIST

public static final ConfigEntry TWISTER2_DIST

JAVA_HOME

public static final ConfigEntry JAVA_HOME

TASK_YAML

public static final ConfigEntry TASK_YAML

RESOURCE_SCHEDULER_YAML

public static final ConfigEntry RESOURCE_SCHEDULER_YAML

NETWORK_YAML

public static final ConfigEntry NETWORK_YAML

CORE_YAML

public static final ConfigEntry CORE_YAML

OVERRIDE_YAML

public static final ConfigEntry OVERRIDE_YAML

CLUSTER_HOME

public static final ConfigEntry CLUSTER_HOME

CLUSTER_CONF

public static final ConfigEntry CLUSTER_CONF

VERBOSE

public static final ConfigEntry VERBOSE

JOB

public static final ConfigEntry JOB

CLUSTER

public static final ConfigEntry CLUSTER

AURORA_SCRIPT

public static final ConfigEntry AURORA_SCRIPT

CHECKPOINT_YAML

public static final ConfigEntry CHECKPOINT_YAML

DATA_YAML

public static final ConfigEntry DATA_YAML

JOB_NAME

public static final java.lang.String JOB_NAME

See Also:

Constant Field Values

JOB_OBJECT

public static final java.lang.String JOB_OBJECT

See Also:

Constant Field Values

JOB_ID

public static final java.lang.String JOB_ID

See Also:

Constant Field Values

USER_NAME

public static final java.lang.String USER_NAME

See Also:

Constant Field Values

TWISTER2_CONTAINER_ID

public static final java.lang.String TWISTER2_CONTAINER_ID

See Also:

Constant Field Values

TWISTER2_CLUSTER_TYPE

public static final java.lang.String TWISTER2_CLUSTER_TYPE

See Also:

Constant Field Values

JOB_ARCHIVE_DIRECTORY

public static final java.lang.String JOB_ARCHIVE_DIRECTORY

See Also:

Constant Field Values

TWISTER2_WORKER_INSTANCES_DEFAULT

public static final int TWISTER2_WORKER_INSTANCES_DEFAULT

See Also:

Constant Field Values

TWISTER2_WORKER_INSTANCES

public static final java.lang.String TWISTER2_WORKER_INSTANCES

See Also:

Constant Field Values

TWISTER2_DIRECT_EDGE

public static final java.lang.String TWISTER2_DIRECT_EDGE

See Also:

Constant Field Values

TWISTER2_BANDWIDTH

public static final java.lang.String TWISTER2_BANDWIDTH

See Also:

Constant Field Values

TWISTER2_LATENCY

public static final java.lang.String TWISTER2_LATENCY

See Also:

Constant Field Values

TWISTER2_MAX_TASK_INSTANCES_PER_WORKER

public static final java.lang.String TWISTER2_MAX_TASK_INSTANCES_PER_WORKER

See Also:

Constant Field Values

TWISTER2_TASK_INSTANCE_ODD_PARALLELISM

public static final java.lang.String TWISTER2_TASK_INSTANCE_ODD_PARALLELISM

See Also:

Constant Field Values

OPERATION_NAME

public static final java.lang.String OPERATION_NAME

Name of the operation in the current configuration

See Also:

Constant Field Values

STREAMING

public static final java.lang.String STREAMING

If it is streaming environment, this property will be set

See Also:

Constant Field Values

TWISTER2_GRAPH_JOB

public static final java.lang.String TWISTER2_GRAPH_JOB

See Also:

Constant Field Values

TWISTER2_TSET_JOB

public static final java.lang.String TWISTER2_TSET_JOB

See Also:

Constant Field Values

GRAPH_TYPE

public static final java.lang.String GRAPH_TYPE

See Also:

Constant Field Values

Constructor Detail

Context

protected Context()

Method Detail

taskConfigurationFile

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

networkConfigurationFile

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

resourceSchedulerConfigurationFile

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

systemConfigurationFile

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

jobName

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

jobId

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

userName

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

dataConfigurationFile

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

checkpointCofigurationFile

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

clusterType

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

containerId

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

verbose

public static java.lang.Boolean verbose(Config cfg)

conf

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

commonConfDir

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

distDirectory

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

libDirectory

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

auroraScript

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

twister2Home

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

checkpointConfigurationFile

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

workerInstances

public static int workerInstances(Config cfg)

isKubernetesCluster

public static boolean isKubernetesCluster(Config cfg)

getDefaults

public static java.util.Map<java.lang.String,java.lang.Object> getDefaults()

getStringPropertyValue

public static java.lang.String getStringPropertyValue(Config cfg,
                                                      java.lang.String name,
                                                      java.lang.String def)

getLongPropertyValue

public static long getLongPropertyValue(Config cfg,
                                        java.lang.String name,
                                        long def)

getDoublePropertyValue

public static double getDoublePropertyValue(Config cfg,
                                            java.lang.String name,
                                            double def)

getIntPropertyValue

public static int getIntPropertyValue(Config cfg,
                                      java.lang.String name,
                                      int def)