@InterfaceAudience.Private public class RegionReplicaFlushHandler extends EventHandler
Modifier and Type | Field and Description |
---|---|
private AsyncClusterConnection |
connection |
private static org.slf4j.Logger |
LOG |
private HRegion |
region |
eventType, seqids, server, waitingTimeForEvents
Constructor and Description |
---|
RegionReplicaFlushHandler(Server server,
HRegion region) |
Modifier and Type | Method and Description |
---|---|
private int |
getRetriesCount(org.apache.hadoop.conf.Configuration conf) |
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.
|
(package private) void |
triggerFlushInPrimaryRegion(HRegion region) |
compareTo, getEventType, getInformativeName, getPriority, getSeqid, prepare, run, toString
private static final org.slf4j.Logger LOG
private final AsyncClusterConnection connection
public RegionReplicaFlushHandler(Server server, HRegion region)
public void process() throws IOException
EventHandler
process
in class EventHandler
IOException
protected void handleException(Throwable t)
EventHandler
handleException
in class EventHandler
t
- Throwable objectprivate int getRetriesCount(org.apache.hadoop.conf.Configuration conf)
void triggerFlushInPrimaryRegion(HRegion region) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.