@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, 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
public UnassignRegionHandler(HRegionServer server, String encodedName, long closeProcId, boolean abort, @Nullable ServerName destination, EventType eventType)
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)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.