@InterfaceAudience.Private public class UnassignRegionHandler extends EventHandler
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.| Modifier and Type | Field and Description |
|---|---|
private boolean |
abort |
private long |
closeProcId |
private ServerName |
destination |
private String |
encodedName |
private static org.slf4j.Logger |
LOG |
private RetryCounter |
retryCounter |
eventType, seqids, server, waitingTimeForEvents| Constructor and Description |
|---|
UnassignRegionHandler(HRegionServer server,
String encodedName,
long closeProcId,
boolean abort,
ServerName destination,
EventType eventType) |
| Modifier and Type | Method and Description |
|---|---|
static UnassignRegionHandler |
create(HRegionServer server,
String encodedName,
long closeProcId,
boolean abort,
ServerName destination) |
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.
|
compareTo, getEventType, getInformativeName, getPriority, getSeqid, prepare, run, toStringprivate static final org.slf4j.Logger LOG
private final String encodedName
private final long closeProcId
private final boolean abort
private final ServerName destination
private final RetryCounter retryCounter
public UnassignRegionHandler(HRegionServer server, String encodedName, long closeProcId, boolean abort, @Nullable ServerName destination, EventType eventType)
private HRegionServer getServer()
public void process() throws IOException
EventHandlerprocess in class EventHandlerIOExceptionprotected void handleException(Throwable t)
EventHandlerhandleException in class EventHandlert - Throwable objectpublic static UnassignRegionHandler create(HRegionServer server, String encodedName, long closeProcId, boolean abort, @Nullable ServerName destination)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.