Package org.apache.hadoop.hbase.master

Class WorkerAssigner

java.lang.Object

org.apache.hadoop.hbase.master.WorkerAssigner

All Implemented Interfaces:

ServerListener

@Private
public class WorkerAssigner
extends Object
implements ServerListener

help assign and release a worker for each remote task. For each worker, concurrent running task should be no more than maxTasks. If a task failed to acquire a worker, it will suspend and wait for workers available.

Field Summary

Fields

Modifier and Type	Field	Description
private final Map<ServerName,Integer>	currentWorkers
private final ProcedureEvent<?>	event
private final MasterServices	master
private final int	maxTasks

Constructor Summary

Constructors

Constructor	Description
WorkerAssigner(MasterServices master, int maxTasks, ProcedureEvent<?> event)

Method Summary

Modifier and Type	Method	Description
Optional<ServerName>	acquire()
void	addUsedWorker(ServerName worker)
Integer	getAvailableWorker(ServerName serverName)
void	release(ServerName serverName)
void	serverAdded(ServerName worker)	The server has joined the cluster.
void	suspend(Procedure<?> proc)
void	wake(MasterProcedureScheduler scheduler)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.master.ServerListener

serverRemoved, waiting

Field Details

currentWorkers

private final Map<ServerName,Integer> currentWorkers

master

private final MasterServices master

event

private final ProcedureEvent<?> event

maxTasks

private final int maxTasks

Constructor Details

WorkerAssigner

public WorkerAssigner(MasterServices master,
 int maxTasks,
 ProcedureEvent<?> event)

Method Details

acquire

public Optional<ServerName> acquire()

release

public void release(ServerName serverName)

suspend

public void suspend(Procedure<?> proc)

wake

public void wake(MasterProcedureScheduler scheduler)

serverAdded

public void serverAdded(ServerName worker)

Description copied from interface: ServerListener

The server has joined the cluster.

Specified by:

serverAdded in interface ServerListener

Parameters:

worker - The remote servers name.

addUsedWorker

public void addUsedWorker(ServerName worker)

getAvailableWorker

public Integer getAvailableWorker(ServerName serverName)