Package org.apache.hadoop.hbase.regionserver.handler

Class AssignRegionHandler

java.lang.Object

org.apache.hadoop.hbase.executor.EventHandler

org.apache.hadoop.hbase.regionserver.handler.AssignRegionHandler

All Implemented Interfaces:

Comparable<EventHandler>, Runnable

@Private
public class AssignRegionHandler
extends EventHandler

Handles opening of a region on a region server.

Just done the same thing with the old OpenRegionHandler, with some modifications on fencing and retrying. But we need to keep the OpenRegionHandler as is to keep compatible with the zk less assignment for 1.x, otherwise it is not possible to do rolling upgrade.

Field Summary

Fields

Modifier and Type	Field	Description
private final long	initiatingMasterActiveTime
private static final org.slf4j.Logger	LOG
private final long	masterSystemTime
private final long	openProcId
private final RegionInfo	regionInfo
private final RetryCounter	retryCounter
private final TableDescriptor	tableDesc

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

eventType, seqids, server, waitingTimeForEvents

Constructor Summary

Constructors

Constructor	Description
AssignRegionHandler(HRegionServer server, RegionInfo regionInfo, long openProcId, TableDescriptor tableDesc, long masterSystemTime, long initiatingMasterActiveTime, EventType eventType)

Method Summary

Modifier and Type	Method	Description
private void	cleanUpAndReportFailure(IOException error)
static AssignRegionHandler	create(HRegionServer server, RegionInfo regionInfo, long openProcId, TableDescriptor tableDesc, long masterSystemTime, long initiatingMasterActiveTime)
private HRegionServer	getServer()
protected void	handleException(Throwable t)	Event exception handler, may be overridden
void	process()	This method is the main processing loop to be implemented by the various subclasses.

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

compareTo, getEventType, getInformativeName, getPriority, getSeqid, prepare, run, toString

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

regionInfo

private final RegionInfo regionInfo

openProcId

private final long openProcId

tableDesc

private final TableDescriptor tableDesc

masterSystemTime

private final long masterSystemTime

initiatingMasterActiveTime

private final long initiatingMasterActiveTime

retryCounter

private final RetryCounter retryCounter

Constructor Details

AssignRegionHandler

public AssignRegionHandler(HRegionServer server,
 RegionInfo regionInfo,
 long openProcId,
 @Nullable
 TableDescriptor tableDesc,
 long masterSystemTime,
 long initiatingMasterActiveTime,
 EventType eventType)

Method Details

getServer

private HRegionServer getServer()

cleanUpAndReportFailure

private void cleanUpAndReportFailure(IOException error)
                              throws IOException

Throws:

IOException

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

handleException

protected void handleException(Throwable t)

Description copied from class: EventHandler

Event exception handler, may be overridden

Overrides:

handleException in class EventHandler

Parameters:

t - Throwable object

create

public static AssignRegionHandler create(HRegionServer server,
 RegionInfo regionInfo,
 long openProcId,
 TableDescriptor tableDesc,
 long masterSystemTime,
 long initiatingMasterActiveTime)