edu.iu.dsc.tws.api.resource

Class FSPersistentVolume

java.lang.Object

edu.iu.dsc.tws.api.resource.FSPersistentVolume

All Implemented Interfaces:

IPersistentVolume

Direct Known Subclasses:

K8sPersistentVolume

public class FSPersistentVolume
extends java.lang.Object
implements IPersistentVolume

todo could move to common

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	LOG_DIR_NAME
static java.lang.String	WORKER_DIR_NAME_PREFIX
static java.lang.String	WORKER_LOG_FILE_NAME_PREFIX

Constructor Summary

Constructors

Constructor and Description
FSPersistentVolume(java.lang.String jobDirPath, int workerID)

Method Summary

Modifier and Type	Method and Description
java.io.File	getJobDir() get the job directory as a File object
java.lang.String	getJobDirPath() get the path of the shared persistent job directory as a string
java.lang.String	getLogDirPath()
java.lang.String	getLogFileName() get logfile name for this worker
java.io.File	getWorkerDir() get the worker directory as a File object this method creates the directory if it is not already created
java.lang.String	getWorkerDirPath() get the directory path of this worker as a string
boolean	jobDirExists() check whether job directory exists
boolean	workerDirExists() check whether worker directory exist

Methods inherited from class java.lang.Object

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

Field Detail

WORKER_DIR_NAME_PREFIX

public static final java.lang.String WORKER_DIR_NAME_PREFIX

See Also:

Constant Field Values

WORKER_LOG_FILE_NAME_PREFIX

public static final java.lang.String WORKER_LOG_FILE_NAME_PREFIX

See Also:

Constant Field Values

LOG_DIR_NAME

public static final java.lang.String LOG_DIR_NAME

See Also:

Constant Field Values

Constructor Detail

FSPersistentVolume

public FSPersistentVolume(java.lang.String jobDirPath,
                          int workerID)

Method Detail

getJobDirPath

public java.lang.String getJobDirPath()

Description copied from interface: IPersistentVolume

get the path of the shared persistent job directory as a string

Specified by:

getJobDirPath in interface IPersistentVolume

Returns:

getLogDirPath

public java.lang.String getLogDirPath()

getWorkerDirPath

public java.lang.String getWorkerDirPath()

Description copied from interface: IPersistentVolume

get the directory path of this worker as a string

Specified by:

getWorkerDirPath in interface IPersistentVolume

Returns:

jobDirExists

public boolean jobDirExists()

Description copied from interface: IPersistentVolume

check whether job directory exists

Specified by:

jobDirExists in interface IPersistentVolume

Returns:

workerDirExists

public boolean workerDirExists()

Description copied from interface: IPersistentVolume

check whether worker directory exist

Specified by:

workerDirExists in interface IPersistentVolume

Returns:

getJobDir

public java.io.File getJobDir()

Description copied from interface: IPersistentVolume

get the job directory as a File object

Specified by:

getJobDir in interface IPersistentVolume

Returns:

getWorkerDir

public java.io.File getWorkerDir()

Description copied from interface: IPersistentVolume

get the worker directory as a File object this method creates the directory if it is not already created

Specified by:

getWorkerDir in interface IPersistentVolume

Returns:

getLogFileName

public java.lang.String getLogFileName()

Description copied from interface: IPersistentVolume

get logfile name for this worker

Specified by:

getLogFileName in interface IPersistentVolume

Returns: