alluxio.membership

Class StaticMembershipManager

java.lang.Object

alluxio.membership.StaticMembershipManager

All Implemented Interfaces:

MembershipManager, AutoCloseable

public class StaticMembershipManager
extends Object
implements MembershipManager

MembershipManager configured by a static file.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.membership.MembershipManager

MembershipManager.Factory

Field Summary

Fields inherited from interface alluxio.membership.MembershipManager

PATH_SEPARATOR

Method Summary

Modifier and Type	Method and Description
void	close()
static StaticMembershipManager	create(AlluxioConfiguration conf)
void	decommission(WorkerInfo worker) Decommision a worker.
List<WorkerInfo>	getAllMembers() Get all registered worker members.
List<WorkerInfo>	getFailedMembers() Get all failed workers.
List<WorkerInfo>	getLiveMembers() Get healthy workers.
void	join(WorkerInfo worker) An idempotent call to register to join the membership.
String	showAllMembers() Pretty printed members and its liveness status.
void	stopHeartBeat(WorkerInfo worker) Stop heartbeating for liveness for current worker.

Methods inherited from class java.lang.Object

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

Method Detail

create

public static StaticMembershipManager create(AlluxioConfiguration conf)

Parameters:

conf -

Returns:

StaticMembershipManager

join

public void join(WorkerInfo worker)
          throws IOException

Description copied from interface: MembershipManager

An idempotent call to register to join the membership.

Specified by:

join in interface MembershipManager

Throws:

IOException

getAllMembers

public List<WorkerInfo> getAllMembers()
                               throws IOException

Description copied from interface: MembershipManager

Get all registered worker members.

Specified by:

getAllMembers in interface MembershipManager

Returns:

all registered workers

Throws:

IOException

getLiveMembers

public List<WorkerInfo> getLiveMembers()
                                throws IOException

Description copied from interface: MembershipManager

Get healthy workers.

Specified by:

getLiveMembers in interface MembershipManager

Returns:

healthy worker list

Throws:

IOException

getFailedMembers

public List<WorkerInfo> getFailedMembers()
                                  throws IOException

Description copied from interface: MembershipManager

Get all failed workers.

Specified by:

getFailedMembers in interface MembershipManager

Returns:

failed worker list

Throws:

IOException

showAllMembers

public String showAllMembers()

Description copied from interface: MembershipManager

Pretty printed members and its liveness status.

Specified by:

showAllMembers in interface MembershipManager

Returns:

pretty-printed status string

stopHeartBeat

public void stopHeartBeat(WorkerInfo worker)
                   throws IOException

Description copied from interface: MembershipManager

Stop heartbeating for liveness for current worker.

Specified by:

stopHeartBeat in interface MembershipManager

Parameters:

worker - WorkerInfo

Throws:

IOException

decommission

public void decommission(WorkerInfo worker)
                  throws IOException

Description copied from interface: MembershipManager

Decommision a worker.

Specified by:

decommission in interface MembershipManager

Parameters:

worker - WorkerInfo

Throws:

IOException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception