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 and Description
private long	createTime
private List<byte[]>	families
private HRegion	region
private int	requeueCount
private FlushLifeCycleTracker	tracker
private long	whenToExpire

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
int	compareTo(Delayed other)
boolean	equals(Object obj)
long	getDelay(TimeUnit unit)
int	getRequeueCount()
FlushLifeCycleTracker	getTracker()
int	hashCode()
boolean	isMaximumWait(long maximumWait)
MemStoreFlusher.FlushRegionEntry	requeue(long when)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

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 Detail

FlushRegionEntry

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

Method Detail

isMaximumWait

public boolean isMaximumWait(long maximumWait)

Parameters:

maximumWait -

Returns:

True if we have been delayed > maximumWait milliseconds.

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