edu.iu.dsc.tws.common.zk

Class ZKContext

java.lang.Object

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

edu.iu.dsc.tws.common.zk.ZKContext

public final class ZKContext
extends Context

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ROOT_NODE
static java.lang.String	ROOT_NODE_DEFAULT
static java.lang.String	SERVER_ADDRESSES

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

Method Summary

Modifier and Type	Method and Description
static boolean	isZooKeeperServerUsed(Config cfg) return true if the job is fault tolerant or ZK based group management is used
static java.lang.String	rootNode(Config cfg)
static java.lang.String	serverAddresses(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

ROOT_NODE

public static final java.lang.String ROOT_NODE

See Also:

Constant Field Values

ROOT_NODE_DEFAULT

public static final java.lang.String ROOT_NODE_DEFAULT

See Also:

Constant Field Values

SERVER_ADDRESSES

public static final java.lang.String SERVER_ADDRESSES

See Also:

Constant Field Values

Method Detail

rootNode

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

serverAddresses

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

isZooKeeperServerUsed

public static boolean isZooKeeperServerUsed(Config cfg)

return true if the job is fault tolerant or ZK based group management is used

Parameters:

cfg -

Returns: