alluxio.master.scheduler

Class MembershipManagerWorkerProvider

java.lang.Object

alluxio.master.scheduler.MembershipManagerWorkerProvider

All Implemented Interfaces:

WorkerProvider

public class MembershipManagerWorkerProvider
extends Object
implements WorkerProvider

MembershipManager backed WorkerProvider for Scheduler.

Constructor Summary

Constructors

Constructor and Description
MembershipManagerWorkerProvider(MembershipManager membershipMgr, FileSystemContext context) CTOR for MembershipManagerWorkerProvider.

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

MembershipManagerWorkerProvider

public MembershipManagerWorkerProvider(MembershipManager membershipMgr,
                                       FileSystemContext context)

CTOR for MembershipManagerWorkerProvider.

Parameters:

membershipMgr -

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()

Description copied from interface: WorkerProvider

Get live workerInfo list.

Specified by:

getLiveWorkerInfos in interface WorkerProvider

Returns:

list of WorkerInfos who are alive

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