alluxio.hub.manager.util

Class AlluxioCluster

java.lang.Object

alluxio.hub.manager.util.AlluxioCluster

All Implemented Interfaces:

ProtoConverter<AlluxioCluster>

public class AlluxioCluster
extends Object
implements ProtoConverter<AlluxioCluster>

A class representing the state of a running Alluxio cluster.

Constructor Summary

Constructors

Constructor and Description
AlluxioCluster(ExecutorService svc) Creates a new instance of AlluxioCluster.

Method Summary

Modifier and Type	Method and Description
Set<String>	getNodeType(AlluxioNodeType type) Gets a set of node hostnames which correspond to a given AlluxioNodeType.
Map<AlluxioNodeType,ProcessState>	heartbeat(AlluxioNodeStatusOrBuilder addr) Add a new node to the cluster.
Map<AlluxioNodeType,ProcessState>	remove(AlluxioNodeStatusOrBuilder addr) Remove a node from the cluster with the address's hostname.
Map<AlluxioNodeType,ProcessState>	remove(String hostname) Remove a node from the cluster.
void	setContext(ManagerProcessContext ctx) Sets ManagerProcessContext and registers an event to send heartbeats.
int	size()
AlluxioCluster	toProto() Converts an objects representation into a protobuf type.

Methods inherited from class java.lang.Object

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

Constructor Detail

AlluxioCluster

public AlluxioCluster(ExecutorService svc)

Creates a new instance of AlluxioCluster.

Parameters:

svc - the executor service used to run event handlers

Method Detail

setContext

public void setContext(ManagerProcessContext ctx)

Sets ManagerProcessContext and registers an event to send heartbeats.

Parameters:

ctx - Manager process context

heartbeat

public Map<AlluxioNodeType,ProcessState> heartbeat(AlluxioNodeStatusOrBuilder addr)

Add a new node to the cluster.

Parameters:

addr - the alluxio node address to add

Returns:

true if this set did not already include this process

remove

public Map<AlluxioNodeType,ProcessState> remove(AlluxioNodeStatusOrBuilder addr)

Remove a node from the cluster with the address's hostname.

Parameters:

addr - the node of the Alluxio cluster to remove statuses for

Returns:

the most recent status of the Alluxio processes known on that node

remove

public Map<AlluxioNodeType,ProcessState> remove(String hostname)

Remove a node from the cluster.

Parameters:

hostname - the node to remove with the given hostname

Returns:

the most recent status of the Alluxio processes known on that node

getNodeType

public Set<String> getNodeType(AlluxioNodeType type)

Gets a set of node hostnames which correspond to a given AlluxioNodeType.

Parameters:

type - the type to query for

Returns:

a set of hosts containing running the desired node

size

public int size()

Returns:

the total number of nodes in the cluster (masters + workers)

toProto

public AlluxioCluster toProto()

Description copied from interface: ProtoConverter

Converts an objects representation into a protobuf type.

Specified by:

toProto in interface ProtoConverter<AlluxioCluster>

Returns:

the object as a proto representation