alluxio.master.file.async

Interface AsyncPersistHandler

All Known Implementing Classes:

DefaultAsyncPersistHandler

public interface AsyncPersistHandler

The handler that handles the scheduled async persist requests on files, and decides which worker to take the persistence task. The handler carries the strategy of when and where to persist the file.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	AsyncPersistHandler.Factory Factory for AsyncPersistHandler.

Method Summary

Modifier and Type	Method and Description
java.util.List<PersistFile>	pollFilesToPersist(long workerId) Polls the files for persistence on the given worker.
void	scheduleAsyncPersistence(AlluxioURI path) Schedules a file for async persistence.

Method Detail

scheduleAsyncPersistence

void scheduleAsyncPersistence(AlluxioURI path)
                       throws AlluxioException,
                              UnavailableException

Schedules a file for async persistence.

Parameters:

path - the path to the file

Throws:

AlluxioException

UnavailableException

pollFilesToPersist

java.util.List<PersistFile> pollFilesToPersist(long workerId)
                                        throws FileDoesNotExistException,
                                               InvalidPathException,
                                               AccessControlException

Polls the files for persistence on the given worker.

Parameters:

workerId - the id of the worker for persistence

Returns:

the list of files for persistence

Throws:

FileDoesNotExistException - if the file does not exist

InvalidPathException - if the path is invalid

AccessControlException - if permission checking fails