@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 boolean |
evictCache |
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) |
UnassignRegionHandler(HRegionServer server,
String encodedName,
long closeProcId,
boolean abort,
ServerName destination,
EventType eventType,
boolean evictCache) |
Modifier and Type | Method and Description |
---|---|
static UnassignRegionHandler |
create(HRegionServer server,
String encodedName,
long closeProcId,
boolean abort,
ServerName destination,
boolean evictCache) |
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, toString
private 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
private boolean evictCache
public UnassignRegionHandler(HRegionServer server, String encodedName, long closeProcId, boolean abort, @Nullable ServerName destination, EventType eventType)
public UnassignRegionHandler(HRegionServer server, String encodedName, long closeProcId, boolean abort, @Nullable ServerName destination, EventType eventType, boolean evictCache)
private HRegionServer getServer()
public void process() throws IOException
EventHandler
process
in class EventHandler
IOException
protected void handleException(Throwable t)
EventHandler
handleException
in class EventHandler
t
- Throwable objectpublic static UnassignRegionHandler create(HRegionServer server, String encodedName, long closeProcId, boolean abort, @Nullable ServerName destination, boolean evictCache)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.