alluxio.master.file.async

Class DefaultAsyncPersistHandler

java.lang.Object

alluxio.master.file.async.DefaultAsyncPersistHandler

All Implemented Interfaces:

AsyncPersistHandler

public final class DefaultAsyncPersistHandler
extends java.lang.Object
implements AsyncPersistHandler

The default handler for async persistence that schedules the persistence on the workers that contains all the blocks of a given file, and the handler returns the scheduled request whenever the corresponding worker polls.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.master.file.async.AsyncPersistHandler

AsyncPersistHandler.Factory

Constructor Summary

Constructors

Constructor and Description
DefaultAsyncPersistHandler(FileSystemMasterView view) Constructs a new instance of AsyncPersistHandler.

Method Summary

Modifier and Type	Method and Description
java.util.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.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultAsyncPersistHandler

public DefaultAsyncPersistHandler(FileSystemMasterView view)

Constructs a new instance of AsyncPersistHandler.

Parameters:

view - a view of FileSystemMaster

Method Detail

scheduleAsyncPersistence

public void scheduleAsyncPersistence(AlluxioURI path)
                              throws AlluxioException,
                                     UnavailableException

Description copied from interface: AsyncPersistHandler

Schedules a file for async persistence.

Specified by:

scheduleAsyncPersistence in interface AsyncPersistHandler

Parameters:

path - the path to the file

Throws:

AlluxioException

UnavailableException

pollFilesToPersist

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

Polls the files to send to the given worker for persistence. It also removes files from the worker entry in mWorkerToAsyncPersistFiles.

Specified by:

pollFilesToPersist in interface AsyncPersistHandler

Parameters:

workerId - the worker id

Returns:

the list of files

Throws:

FileDoesNotExistException - if the file does not exist

InvalidPathException - if the path is invalid

AccessControlException - if permission checking fails