Class MemStoreFlusher.FlushRegionEntry
java.lang.Object
org.apache.hadoop.hbase.regionserver.MemStoreFlusher.FlushRegionEntry
- All Implemented Interfaces:
Comparable<Delayed>
,Delayed
,MemStoreFlusher.FlushQueueEntry
- Enclosing class:
- MemStoreFlusher
static class MemStoreFlusher.FlushRegionEntry
extends Object
implements MemStoreFlusher.FlushQueueEntry
Datastructure used in the flush queue. Holds region and retry count. Keeps tabs on how old this
object is. Implements
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.-
Field Summary
Modifier and TypeFieldDescriptionprivate final long
private final List<byte[]>
private final HRegion
private int
private final FlushLifeCycleTracker
private long
-
Constructor Summary
ConstructorDescriptionFlushRegionEntry
(HRegion r, List<byte[]> families, FlushLifeCycleTracker tracker) -
Method Summary
Modifier and TypeMethodDescriptionint
boolean
long
int
int
hashCode()
protected boolean
isDelay()
Returns True if the entry is a delay flush taskboolean
isMaximumWait
(long maximumWait) Returns True if we have been delayed >maximumWait
milliseconds.requeue
(long when) toString()
-
Field Details
-
region
-
createTime
-
whenToExpire
-
requeueCount
-
families
-
tracker
-
-
Constructor Details
-
FlushRegionEntry
FlushRegionEntry(HRegion r, List<byte[]> families, FlushLifeCycleTracker tracker)
-
-
Method Details
-
isMaximumWait
Returns True if we have been delayed >maximumWait
milliseconds. -
isDelay
Returns True if the entry is a delay flush task -
getRequeueCount
- Returns:
- Count of times
requeue(long)
was called; i.e this is number of times we've been requeued.
-
getTracker
-
requeue
- Parameters:
when
- When to expire, when to come up out of the queue. Specify in milliseconds. This method adds EnvironmentEdgeManager.currentTime() to whatever you pass.- Returns:
- This.
-
getDelay
-
compareTo
- Specified by:
compareTo
in interfaceComparable<Delayed>
-
toString
-
hashCode
-
equals
-