@InterfaceAudience.Private class RegionReplicationFlushRequester extends Object
Modifier and Type | Field and Description |
---|---|
private Runnable |
flushRequester |
private long |
lastFlushedSequenceId |
private long |
lastRequestNanos |
static String |
MIN_INTERVAL_SECS
The minimum interval between two flush requests
|
static int |
MIN_INTERVAL_SECS_DEFAULT |
private long |
minIntervalSecs |
private org.apache.hbase.thirdparty.io.netty.util.Timeout |
pendingFlushRequest |
private long |
pendingFlushRequestSequenceId |
private static org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer |
TIMER
The timer for executing delayed flush request task.
|
Constructor and Description |
---|
RegionReplicationFlushRequester(org.apache.hadoop.conf.Configuration conf,
Runnable flushRequester) |
Modifier and Type | Method and Description |
---|---|
private void |
flush(org.apache.hbase.thirdparty.io.netty.util.Timeout timeout) |
private static org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer |
getTimer() |
(package private) void |
recordFlush(long sequenceId)
Record that we have already finished a flush with the given
sequenceId . |
private void |
request() |
(package private) void |
requestFlush(long sequenceId)
Request a flush for the given region.
|
private static volatile org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer TIMER
RegionReplicationFlushRequester
. Created on
demand to save one extra thread as not every user uses region replication.public static final String MIN_INTERVAL_SECS
public static final int MIN_INTERVAL_SECS_DEFAULT
private final Runnable flushRequester
private final long minIntervalSecs
private long lastRequestNanos
private long pendingFlushRequestSequenceId
private long lastFlushedSequenceId
private org.apache.hbase.thirdparty.io.netty.util.Timeout pendingFlushRequest
RegionReplicationFlushRequester(org.apache.hadoop.conf.Configuration conf, Runnable flushRequester)
private static org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer getTimer()
private void request()
private void flush(org.apache.hbase.thirdparty.io.netty.util.Timeout timeout)
void requestFlush(long sequenceId)
void recordFlush(long sequenceId)
sequenceId
.
We can cancel the pending flush request if the failed sequence id is less than the given
sequenceId
.Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.