edu.iu.dsc.tws.data.utils

Class HdfsDataContext

java.lang.Object

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

edu.iu.dsc.tws.data.utils.HdfsDataContext

public final class HdfsDataContext
extends Context

Field Summary

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 java.lang.String	getHadoopHome(Config config)
static java.lang.String	getHdfsConfigDirectory(Config config)
static java.lang.String	getHdfsDataDirectory(Config config)
static java.lang.String	getHdfsNamenodeDefault(Config cfg)
static java.lang.Integer	getHdfsNamenodePortDefault(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

Method Detail

getHdfsNamenodeDefault

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

getHdfsNamenodePortDefault

public static java.lang.Integer getHdfsNamenodePortDefault(Config cfg)

getHdfsConfigDirectory

public static java.lang.String getHdfsConfigDirectory(Config config)

getHdfsDataDirectory

public static java.lang.String getHdfsDataDirectory(Config config)

getHadoopHome

public static java.lang.String getHadoopHome(Config config)