@ThreadSafe public final class JobUfsManager extends AbstractUfsManager
AbstractUfsManager.Key
UfsManager.UfsClient
mCloser, mUnderFileSystemMap
Constructor and Description |
---|
JobUfsManager()
Constructs an instance of
JobUfsManager . |
Modifier and Type | Method and Description |
---|---|
protected void |
connectUfs(UnderFileSystem fs)
Takes any necessary actions required to establish a connection to the under file system.
|
UfsManager.UfsClient |
get(long mountId)
Gets UFS information from the manager if this mount ID exists, or throws exception otherwise.
|
addMount, close, getRoot, removeMount
public JobUfsManager()
JobUfsManager
.protected void connectUfs(UnderFileSystem fs) throws IOException
AbstractUfsManager
UnderFileSystem.connectFromMaster(String)
or
UnderFileSystem.connectFromWorker(String)
depending on the running process.connectUfs
in class AbstractUfsManager
IOException
public UfsManager.UfsClient get(long mountId) throws NotFoundException, UnavailableException
UfsManager
get
in interface UfsManager
get
in class AbstractUfsManager
mountId
- the mount idNotFoundException
- if mount id is not found in mount tableUnavailableException
- if master is not available to query for mount tableCopyright © 2023. All Rights Reserved.