public final class DefaultAsyncPersistHandler extends Object implements AsyncPersistHandler
AsyncPersistHandler.Factory
Constructor and Description |
---|
DefaultAsyncPersistHandler(FileSystemMasterView view)
Constructs a new instance of
AsyncPersistHandler . |
Modifier and Type | Method and Description |
---|---|
List<PersistFile> |
pollFilesToPersist(long workerId)
Polls the files to send to the given worker for persistence.
|
void |
scheduleAsyncPersistence(AlluxioURI path)
Schedules a file for async persistence.
|
public DefaultAsyncPersistHandler(FileSystemMasterView view)
AsyncPersistHandler
.view
- a view of FileSystemMaster
public void scheduleAsyncPersistence(AlluxioURI path) throws AlluxioException, UnavailableException
AsyncPersistHandler
scheduleAsyncPersistence
in interface AsyncPersistHandler
path
- the path to the fileAlluxioException
UnavailableException
public List<PersistFile> pollFilesToPersist(long workerId) throws FileDoesNotExistException, InvalidPathException, AccessControlException
mWorkerToAsyncPersistFiles
.pollFilesToPersist
in interface AsyncPersistHandler
workerId
- the worker idFileDoesNotExistException
- if the file does not existInvalidPathException
- if the path is invalidAccessControlException
- if permission checking failsCopyright © 2023. All Rights Reserved.