alluxio.scheduler.job

Interface WorkerProvider

All Known Implementing Classes:

DefaultWorkerProvider

public interface WorkerProvider

Interface for providing worker information and client.

Method Summary

Modifier and Type	Method and Description
CloseableResource<BlockWorkerClient>	getWorkerClient(WorkerNetAddress address) Gets a worker client.
List<WorkerInfo>	getWorkerInfos() Gets a list of worker information.

Method Detail

getWorkerInfos

List<WorkerInfo> getWorkerInfos()

Gets a list of worker information.

Returns:

a list of worker information

Throws:

AlluxioRuntimeException - if failed to get worker information

getWorkerClient

CloseableResource<BlockWorkerClient> getWorkerClient(WorkerNetAddress address)

Gets a worker client.

Parameters:

address - the worker address

Returns:

a worker client

Throws:

AlluxioRuntimeException - if failed to get worker client