@InterfaceAudience.Private public class OpenRegionHandler extends EventHandler
This is executed after receiving an OPEN RPC from the master or client.
Modifier and Type | Class and Description |
---|---|
(package private) static class |
OpenRegionHandler.PostOpenDeployTasksThread
Thread to run region post open tasks.
|
EventHandler.EventHandlerListener
Modifier and Type | Field and Description |
---|---|
private OpenRegionCoordination |
coordination |
private HTableDescriptor |
htd |
private static org.apache.commons.logging.Log |
LOG |
private long |
masterSystemTime |
private OpenRegionCoordination.OpenRegionDetails |
ord |
private HRegionInfo |
regionInfo |
protected RegionServerServices |
rsServices |
private boolean |
useZKForAssignment |
eventType, seqids, server, waitingTimeForEvents
Modifier | Constructor and Description |
---|---|
protected |
OpenRegionHandler(Server server,
RegionServerServices rsServices,
HRegionInfo regionInfo,
HTableDescriptor htd,
EventType eventType,
long masterSystemTime,
OpenRegionCoordination coordination,
OpenRegionCoordination.OpenRegionDetails ord) |
|
OpenRegionHandler(Server server,
RegionServerServices rsServices,
HRegionInfo regionInfo,
HTableDescriptor htd,
long masterSystemTime,
OpenRegionCoordination coordination,
OpenRegionCoordination.OpenRegionDetails ord) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
cleanupFailedOpen(HRegion region) |
private void |
doCleanUpOnFailedOpen(HRegion region,
boolean transitionedToOpening,
OpenRegionCoordination.OpenRegionDetails ord) |
HRegionInfo |
getRegionInfo() |
private boolean |
isRegionStillOpening() |
private static boolean |
isRegionStillOpening(HRegionInfo regionInfo,
RegionServerServices rsServices) |
(package private) HRegion |
openRegion() |
void |
process()
This method is the main processing loop to be implemented by the various
subclasses.
|
(package private) boolean |
updateMeta(HRegion r,
long masterSystemTime)
Update ZK or META.
|
compareTo, getEventType, getInformativeName, getListener, getPriority, getSeqid, handleException, prepare, run, setListener, toString
private static final org.apache.commons.logging.Log LOG
protected final RegionServerServices rsServices
private final HRegionInfo regionInfo
private final HTableDescriptor htd
private final long masterSystemTime
private OpenRegionCoordination coordination
private OpenRegionCoordination.OpenRegionDetails ord
private final boolean useZKForAssignment
public OpenRegionHandler(Server server, RegionServerServices rsServices, HRegionInfo regionInfo, HTableDescriptor htd, long masterSystemTime, OpenRegionCoordination coordination, OpenRegionCoordination.OpenRegionDetails ord)
protected OpenRegionHandler(Server server, RegionServerServices rsServices, HRegionInfo regionInfo, HTableDescriptor htd, EventType eventType, long masterSystemTime, OpenRegionCoordination coordination, OpenRegionCoordination.OpenRegionDetails ord)
public HRegionInfo getRegionInfo()
public void process() throws IOException
EventHandler
process
in class EventHandler
IOException
private void doCleanUpOnFailedOpen(HRegion region, boolean transitionedToOpening, OpenRegionCoordination.OpenRegionDetails ord) throws IOException
IOException
boolean updateMeta(HRegion r, long masterSystemTime)
HRegion openRegion()
void cleanupFailedOpen(HRegion region) throws IOException
IOException
private static boolean isRegionStillOpening(HRegionInfo regionInfo, RegionServerServices rsServices)
private boolean isRegionStillOpening()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.