Uses of Interface
alluxio.client.block.stream.BlockWorkerClient

Packages that use BlockWorkerClient

Package	Description
alluxio.client.block.stream
alluxio.client.file
alluxio.master.job
alluxio.master.scheduler
alluxio.scheduler.job

Uses of BlockWorkerClient in alluxio.client.block.stream

Classes in alluxio.client.block.stream that implement BlockWorkerClient

Modifier and Type	Class and Description
class	DefaultBlockWorkerClient Default implementation of BlockWorkerClient.

Methods in alluxio.client.block.stream that return BlockWorkerClient

Modifier and Type	Method and Description
static BlockWorkerClient	BlockWorkerClient.Factory.create(UserState userState, GrpcServerAddress address, AlluxioConfiguration alluxioConf) Creates a new block worker client.
protected BlockWorkerClient	BlockWorkerClientPool.createNewResource()

Methods in alluxio.client.block.stream with parameters of type BlockWorkerClient

Modifier and Type	Method and Description
protected void	BlockWorkerClientPool.closeResource(BlockWorkerClient client)
protected boolean	BlockWorkerClientPool.isHealthy(BlockWorkerClient client) Checks whether a client is healthy.

Method parameters in alluxio.client.block.stream with type arguments of type BlockWorkerClient

Modifier and Type	Method and Description
protected boolean	BlockWorkerClientPool.shouldGc(DynamicResourcePool.ResourceInternal<BlockWorkerClient> clientResourceInternal)

Constructor parameters in alluxio.client.block.stream with type arguments of type BlockWorkerClient

Constructor and Description
BufferCachingGrpcDataReader(WorkerNetAddress address, CloseableResource<BlockWorkerClient> client, long dataTimeoutMs, ReadRequest readRequest, GrpcBlockingStream<ReadRequest,ReadResponse> stream) Creates an instance of BufferCachingGrpcDataReader.

Uses of BlockWorkerClient in alluxio.client.file

Methods in alluxio.client.file that return types with arguments of type BlockWorkerClient

Modifier and Type	Method and Description
CloseableResource<BlockWorkerClient>	FileSystemContext.acquireBlockWorkerClient(WorkerNetAddress workerNetAddress) Acquires a block worker client from the client pools.

Uses of BlockWorkerClient in alluxio.master.job

Methods in alluxio.master.job with parameters of type BlockWorkerClient

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<CopyResponse>	CopyJob.CopyTask.run(BlockWorkerClient workerClient)
com.google.common.util.concurrent.ListenableFuture<LoadResponse>	LoadJob.LoadTask.run(BlockWorkerClient workerClient)
protected com.google.common.util.concurrent.ListenableFuture<LoadFileResponse>	DoraLoadJob.DoraLoadTask.run(BlockWorkerClient workerClient)
com.google.common.util.concurrent.ListenableFuture<MoveResponse>	MoveJob.MoveTask.run(BlockWorkerClient workerClient)

Uses of BlockWorkerClient in alluxio.master.scheduler

Fields in alluxio.master.scheduler with type parameters of type BlockWorkerClient

Modifier and Type	Field and Description
Map<Scheduler.WorkerInfoIdentity,CloseableResource<BlockWorkerClient>>	Scheduler.WorkerInfoHub.mActiveWorkers

Methods in alluxio.master.scheduler that return types with arguments of type BlockWorkerClient

Modifier and Type	Method and Description
CloseableResource<BlockWorkerClient>	MembershipManagerWorkerProvider.getWorkerClient(WorkerNetAddress address)
CloseableResource<BlockWorkerClient>	DefaultWorkerProvider.getWorkerClient(WorkerNetAddress address)
CloseableResource<BlockWorkerClient>	WorkerProvider.getWorkerClient(WorkerNetAddress address) Gets a worker client.

Uses of BlockWorkerClient in alluxio.scheduler.job

Methods in alluxio.scheduler.job with parameters of type BlockWorkerClient

Modifier and Type	Method and Description
void	Task.execute(BlockWorkerClient client, WorkerInfo workerInfo) run the task and set the response future.
protected abstract com.google.common.util.concurrent.ListenableFuture<V>	Task.run(BlockWorkerClient client) run the task.