org.apache.hadoop.hbase.master.handler

Class LogReplayHandler

java.lang.Object

org.apache.hadoop.hbase.executor.EventHandler

org.apache.hadoop.hbase.master.handler.LogReplayHandler

All Implemented Interfaces:

Comparable<Runnable>, Runnable

@InterfaceAudience.Private
public class LogReplayHandler
extends EventHandler

Handle logReplay work from SSH. Having a separate handler is not to block SSH in re-assigning regions from dead servers. Otherwise, available SSH handlers could be blocked by logReplay work (from MasterFileSystem.splitLog(ServerName)). During logReplay, if a receiving RS(say A) fails again, regions on A won't be able to be assigned to another live RS which causes the log replay unable to complete because WAL edits replay depends on receiving RS to be live

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.executor.EventHandler

EventHandler.EventHandlerListener

Field Summary

Fields

Modifier and Type	Field and Description
protected DeadServer	deadServers
protected Server	master
protected MasterServices	services

Fields inherited from class org.apache.hadoop.hbase.executor.EventHandler

eventType, seqids, server, waitingTimeForEvents

Constructor Summary

Constructors

Constructor and Description
LogReplayHandler(Server server, MasterServices services, DeadServer deadServers, ServerName serverName)

Method Summary

Methods

Modifier and Type	Method and Description
void	process() This method is the main processing loop to be implemented by the various subclasses.
String	toString()

Methods inherited from class org.apache.hadoop.hbase.executor.EventHandler

compareTo, getEventType, getInformativeName, getListener, getPriority, getSeqid, handleException, prepare, run, setListener

Methods inherited from class java.lang.Object

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

Field Detail

master

protected final Server master

services

protected final MasterServices services

deadServers

protected final DeadServer deadServers

Constructor Detail

LogReplayHandler

public LogReplayHandler(Server server,
                MasterServices services,
                DeadServer deadServers,
                ServerName serverName)

Method Detail

toString

public String toString()

Overrides:

toString in class EventHandler

process

public void process()
             throws IOException

Description copied from class: EventHandler

This method is the main processing loop to be implemented by the various subclasses.

Specified by:

process in class EventHandler

Throws:

IOException