Class UnassignRegionHandler
java.lang.Object
org.apache.hadoop.hbase.executor.EventHandler
org.apache.hadoop.hbase.regionserver.handler.UnassignRegionHandler
- All Implemented Interfaces:
Comparable<EventHandler>
,Runnable
Handles closing of a region on a region server.
Just done the same thing with the old
CloseRegionHandler
, with some modifications on
fencing and retrying. But we need to keep the CloseRegionHandler
as is to keep compatible
with the zk less assignment for 1.x, otherwise it is not possible to do rolling upgrade.-
Field Summary
Modifier and TypeFieldDescriptionprivate final boolean
private final long
private final ServerName
private final String
private final long
private boolean
private static final org.slf4j.Logger
private final RetryCounter
Fields inherited from class org.apache.hadoop.hbase.executor.EventHandler
eventType, seqids, server, waitingTimeForEvents
-
Constructor Summary
ConstructorDescriptionUnassignRegionHandler
(HRegionServer server, String encodedName, long closeProcId, boolean abort, ServerName destination, EventType eventType, long initiatingMasterActiveTime, boolean isSplit) -
Method Summary
Modifier and TypeMethodDescriptionstatic UnassignRegionHandler
create
(HRegionServer server, String encodedName, long closeProcId, boolean abort, ServerName destination, boolean evictCache, long initiatingMasterActiveTime) private HRegionServer
protected void
Event exception handler, may be overriddenvoid
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
-
Field Details
-
LOG
-
encodedName
-
closeProcId
-
abort
-
destination
-
retryCounter
-
isSplit
-
initiatingMasterActiveTime
-
-
Constructor Details
-
UnassignRegionHandler
public UnassignRegionHandler(HRegionServer server, String encodedName, long closeProcId, boolean abort, @Nullable ServerName destination, EventType eventType, long initiatingMasterActiveTime, boolean isSplit)
-
-
Method Details
-
getServer
-
process
Description copied from class:EventHandler
This method is the main processing loop to be implemented by the various subclasses.- Specified by:
process
in classEventHandler
- Throws:
IOException
-
handleException
Description copied from class:EventHandler
Event exception handler, may be overridden- Overrides:
handleException
in classEventHandler
- Parameters:
t
- Throwable object
-
create
public static UnassignRegionHandler create(HRegionServer server, String encodedName, long closeProcId, boolean abort, @Nullable ServerName destination, boolean evictCache, long initiatingMasterActiveTime)
-