alluxio.worker.block

Class AsyncCacheRequestManager

java.lang.Object

alluxio.worker.block.AsyncCacheRequestManager

@ThreadSafe
public class AsyncCacheRequestManager
extends Object

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

Constructor Summary

Constructors

Constructor and Description
AsyncCacheRequestManager(ExecutorService service, BlockWorker blockWorker, FileSystemContext fsContext)

Method Summary

Modifier and Type	Method and Description
void	submitRequest(AsyncCacheRequest request) Handles a request to cache a block asynchronously.

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncCacheRequestManager

public AsyncCacheRequestManager(ExecutorService service,
                                BlockWorker blockWorker,
                                FileSystemContext fsContext)

Parameters:

service - thread pool to run the background caching work

blockWorker - handler to the block worker

fsContext - context used to instantiate RemoteBlockReader

Method Detail

submitRequest

public void submitRequest(AsyncCacheRequest request)

Handles a request to cache a block asynchronously. This is a non-blocking call.

Parameters:

request - the async cache request fields will be available