static class MemStoreFlusher.FlushRegionEntry extends Object implements MemStoreFlusher.FlushQueueEntry
Delayed
. On
construction, the delay is zero. When added to a delay queue, we'll come
out near immediately. Call requeue(long)
passing delay in
milliseconds before readding to delay queue if you want it to stay there
a while.Modifier and Type | Field and Description |
---|---|
private long |
createTime |
private boolean |
forceFlushAllStores |
private Region |
region |
private int |
requeueCount |
private long |
whenToExpire |
Constructor and Description |
---|
MemStoreFlusher.FlushRegionEntry(Region r,
boolean forceFlushAllStores) |
Modifier and Type | Method and Description |
---|---|
int |
compareTo(Delayed other) |
boolean |
equals(Object obj) |
long |
getDelay(TimeUnit unit) |
int |
getRequeueCount() |
int |
hashCode() |
boolean |
isForceFlushAllStores() |
boolean |
isMaximumWait(long maximumWait) |
MemStoreFlusher.FlushRegionEntry |
requeue(long when) |
String |
toString() |
private final Region region
private final long createTime
private long whenToExpire
private int requeueCount
private boolean forceFlushAllStores
MemStoreFlusher.FlushRegionEntry(Region r, boolean forceFlushAllStores)
public boolean isMaximumWait(long maximumWait)
maximumWait
- maximumWait
milliseconds.public int getRequeueCount()
requeue(long)
was called; i.e this is
number of times we've been requeued.public boolean isForceFlushAllStores()
public MemStoreFlusher.FlushRegionEntry requeue(long when)
when
- When to expire, when to come up out of the queue.
Specify in milliseconds. This method adds EnvironmentEdgeManager.currentTime()
to whatever you pass.public int compareTo(Delayed other)
compareTo
in interface Comparable<Delayed>
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.