alluxio.worker.block

Class CacheRequestManager

java.lang.Object

alluxio.worker.block.CacheRequestManager

@ThreadSafe
public class CacheRequestManager
extends Object

Handles client requests to synchronously/asynchronously cache blocks. Responsible for managing the local worker resources and intelligent pruning of duplicate or meaningless requests.

Constructor Summary

Constructors

Constructor and Description
CacheRequestManager(ExecutorService service, DefaultBlockWorker blockWorker, FileSystemContext fsContext)

Method Summary

Modifier and Type	Method and Description
RemoteBlockReader	getRemoteBlockReader(long blockId, long blockSize, InetSocketAddress sourceAddress, Protocol.OpenUfsBlockOptions openUfsBlockOptions) only public to test since we want to mock remoteBlockReader.
void	submitRequest(CacheRequest request) Handles a request to cache a block.

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheRequestManager

public CacheRequestManager(ExecutorService service,
                           DefaultBlockWorker blockWorker,
                           FileSystemContext fsContext)

Parameters:

service - thread pool to run the background caching work

blockWorker - handler to the block worker

fsContext - context

Method Detail

submitRequest

public void submitRequest(CacheRequest request)
                   throws AlluxioException,
                          IOException

Handles a request to cache a block. If it's async cache, it wouldn't throw exception.

Parameters:

request - the cache request fields will be available

Throws:

AlluxioException

IOException

getRemoteBlockReader

public RemoteBlockReader getRemoteBlockReader(long blockId,
                                              long blockSize,
                                              InetSocketAddress sourceAddress,
                                              Protocol.OpenUfsBlockOptions openUfsBlockOptions)

only public to test since we want to mock remoteBlockReader.

Parameters:

blockId - block ID

blockSize - block size

sourceAddress - remote source address

openUfsBlockOptions - options to open the UFS file

Returns:

remote block reader