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 List<byte[]> |
families |
private HRegion |
region |
private int |
requeueCount |
private FlushLifeCycleTracker |
tracker |
private long |
whenToExpire |
Constructor and Description |
---|
FlushRegionEntry(HRegion r,
List<byte[]> families,
FlushLifeCycleTracker tracker) |
Modifier and Type | Method and Description |
---|---|
int |
compareTo(Delayed other) |
boolean |
equals(Object obj) |
long |
getDelay(TimeUnit unit) |
int |
getRequeueCount() |
FlushLifeCycleTracker |
getTracker() |
int |
hashCode() |
protected boolean |
isDelay()
Returns True if the entry is a delay flush task
|
boolean |
isMaximumWait(long maximumWait)
n * @return True if we have been delayed >
maximumWait milliseconds. |
MemStoreFlusher.FlushRegionEntry |
requeue(long when) |
String |
toString() |
private final long createTime
private long whenToExpire
private int requeueCount
private final FlushLifeCycleTracker tracker
FlushRegionEntry(HRegion r, List<byte[]> families, FlushLifeCycleTracker tracker)
public boolean isMaximumWait(long maximumWait)
maximumWait
milliseconds.protected boolean isDelay()
public int getRequeueCount()
requeue(long)
was called; i.e this is number of times we've
been requeued.public FlushLifeCycleTracker getTracker()
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–2020 The Apache Software Foundation. All rights reserved.