Package org.apache.hadoop.hbase.regionserver

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

Fields

Modifier and Type	Field	Description
private final long	createTime
private final List<byte[]>	families
private final HRegion	region
private int	requeueCount
private final FlushLifeCycleTracker	tracker
private long	whenToExpire

Constructor Summary

Constructors

Constructor	Description
FlushRegionEntry(HRegion r, List<byte[]> families, FlushLifeCycleTracker tracker)

Method Summary

Modifier and Type	Method	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)	Returns True if we have been delayed > maximumWait milliseconds.
MemStoreFlusher.FlushRegionEntry	requeue(long when)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

region

private final HRegion region

createTime

private final long createTime

whenToExpire

private long whenToExpire

requeueCount

private int requeueCount

families

private final List<byte[]> families

tracker

private final FlushLifeCycleTracker tracker

Constructor Details

FlushRegionEntry

FlushRegionEntry(HRegion r,
 List<byte[]> families,
 FlushLifeCycleTracker tracker)

Method Details

isMaximumWait

public boolean isMaximumWait(long maximumWait)

Returns True if we have been delayed > maximumWait milliseconds.

isDelay

protected boolean isDelay()

Returns True if the entry is a delay flush task

getRequeueCount

public int getRequeueCount()

Returns:

Count of times requeue(long) was called; i.e this is number of times we've been requeued.

getTracker

public FlushLifeCycleTracker getTracker()

requeue

public MemStoreFlusher.FlushRegionEntry requeue(long when)

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

public long getDelay(TimeUnit unit)

Specified by:

getDelay in interface Delayed

compareTo

public int compareTo(Delayed other)

Specified by:

compareTo in interface Comparable<Delayed>

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object