Class SliderFileSystem
java.lang.Object
org.apache.hadoop.yarn.service.utils.CoreFileSystem
org.apache.hadoop.yarn.service.utils.SliderFileSystem
Extends Core Filesystem with operations to manipulate ClusterDescription
persistent state
-
Field Summary
Fields inherited from class org.apache.hadoop.yarn.service.utils.CoreFileSystem
configuration, fileSystem -
Constructor Summary
ConstructorsConstructorDescriptionSliderFileSystem(org.apache.hadoop.conf.Configuration configuration) SliderFileSystem(org.apache.hadoop.fs.FileSystem fileSystem, org.apache.hadoop.conf.Configuration configuration) -
Method Summary
Modifier and TypeMethodDescriptionvoiddeleteComponentDir(String serviceVersion, String compName) Deletes the component directory.voiddeleteComponentsVersionDirIfEmpty(String serviceVersion) Deletes the components version directory.org.apache.hadoop.fs.Pathorg.apache.hadoop.fs.Pathorg.apache.hadoop.fs.PathgetComponentDir(String serviceVersion, String compName) Returns the component directory path.org.apache.hadoop.fs.PathgetComponentPublicResourceDir(String serviceVersion, String compName) Returns the component public resource directory path.voidsetAppDir(org.apache.hadoop.fs.Path appDir) Methods inherited from class org.apache.hadoop.yarn.service.utils.CoreFileSystem
buildClusterDirPath, buildClusterUpgradeDirPath, buildKeytabInstallationDirPath, buildKeytabPath, buildResourcePath, buildResourcePath, cat, copyHdfsFileToLocal, copyLocalFileToHdfs, createAmResource, createWithPermissions, deleteClusterUpgradeDir, getBaseApplicationPath, getDependencyTarGzip, getFileSystem, getHomeDirectory, getTempPathForCluster, isFile, listFSDir, submitDirectory, submitFile, submitJarWithClass, submitTarGzipAndUpdate, toString, verifyClusterDirectoryNonexistent, verifyDirectoryNonexistent, verifyDirectoryWriteAccess, verifyFileExists, verifyPathExists
-
Constructor Details
-
SliderFileSystem
public SliderFileSystem(org.apache.hadoop.fs.FileSystem fileSystem, org.apache.hadoop.conf.Configuration configuration) -
SliderFileSystem
- Throws:
IOException
-
-
Method Details
-
setAppDir
public void setAppDir(org.apache.hadoop.fs.Path appDir) -
getAppDir
public org.apache.hadoop.fs.Path getAppDir() -
getComponentDir
Returns the component directory path.- Parameters:
serviceVersion- service versioncompName- component name- Returns:
- component directory
-
getBasePath
public org.apache.hadoop.fs.Path getBasePath() -
getComponentPublicResourceDir
public org.apache.hadoop.fs.Path getComponentPublicResourceDir(String serviceVersion, String compName) Returns the component public resource directory path.- Parameters:
serviceVersion- service versioncompName- component name- Returns:
- component public resource directory
-
deleteComponentDir
Deletes the component directory.- Parameters:
serviceVersion-compName-- Throws:
IOException
-
deleteComponentsVersionDirIfEmpty
Deletes the components version directory.- Parameters:
serviceVersion-- Throws:
IOException
-