alluxio.master.scheduler

Class DefaultWorkerProvider

java.lang.Object

alluxio.master.scheduler.DefaultWorkerProvider

All Implemented Interfaces:

WorkerProvider

public class DefaultWorkerProvider
extends Object
implements WorkerProvider

Default worker provider that get worker information from Alluxio master.

Constructor Summary

Constructors

Constructor and Description
DefaultWorkerProvider(FileSystemMaster fileSystemMaster, FileSystemContext context) Creates a new instance of DefaultWorkerProvider.

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultWorkerProvider

public DefaultWorkerProvider(FileSystemMaster fileSystemMaster,
                             FileSystemContext context)

Creates a new instance of DefaultWorkerProvider.

Parameters:

fileSystemMaster - the file system master

context - the file system context

Method Detail

getWorkerInfos

public List<WorkerInfo> getWorkerInfos()

Description copied from interface: WorkerProvider

Gets a list of worker information.

Specified by:

getWorkerInfos in interface WorkerProvider

Returns:

a list of worker information

getLiveWorkerInfos

public List<WorkerInfo> getLiveWorkerInfos()
                                    throws UnavailableException

Description copied from interface: WorkerProvider

Get live workerInfo list.

Specified by:

getLiveWorkerInfos in interface WorkerProvider

Returns:

list of WorkerInfos who are alive

Throws:

UnavailableException

getWorkerClient

public CloseableResource<BlockWorkerClient> getWorkerClient(WorkerNetAddress address)

Description copied from interface: WorkerProvider

Gets a worker client.

Specified by:

getWorkerClient in interface WorkerProvider

Parameters:

address - the worker address

Returns:

a worker client