org.apache.hadoop.hbase.master

Class SplitWALManager.SplitWorkerAssigner

java.lang.Object

org.apache.hadoop.hbase.master.SplitWALManager.SplitWorkerAssigner

All Implemented Interfaces:

ServerListener

Enclosing class:

SplitWALManager

private static final class SplitWALManager.SplitWorkerAssigner
extends Object
implements ServerListener

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
SplitWorkerAssigner(MasterServices master, int maxSplitTasks)

Method Summary

Modifier and Type	Method and Description
Optional<ServerName>	acquire()
void	addUsedWorker(ServerName worker)
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 Detail

maxSplitTasks

private int maxSplitTasks

event

private final ProcedureEvent<?> event

currentWorkers

private Map<ServerName,Integer> currentWorkers

master

private MasterServices master

Constructor Detail

SplitWorkerAssigner

public SplitWorkerAssigner(MasterServices master,
                           int maxSplitTasks)

Method Detail

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)