org.apache.hadoop.hbase.regionserver

Class StorefileRefresherChore

java.lang.Object

org.apache.hadoop.hbase.ScheduledChore

org.apache.hadoop.hbase.regionserver.StorefileRefresherChore

All Implemented Interfaces:

Runnable

@InterfaceAudience.Private
public class StorefileRefresherChore
extends ScheduledChore

A chore for refreshing the store files for secondary regions hosted in the region server. This chore should run periodically with a shorter interval than HFile TTL ("hbase.master.hfilecleaner.ttl", default 5 minutes). It ensures that if we cannot refresh files longer than that amount, the region will stop serving read requests because the referenced files might have been deleted (by the primary region).

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static int	DEFAULT_REGIONSERVER_STOREFILE_REFRESH_PERIOD
private long	hfileTtl
private Map<String,Long>	lastRefreshTimes
private static org.slf4j.Logger	LOG
private boolean	onlyMetaRefresh
private int	period
private HRegionServer	regionServer
static String	REGIONSERVER_META_STOREFILE_REFRESH_PERIOD Whether all storefiles should be refreshed, as opposed to just hbase:meta's Meta region doesn't have WAL replication for replicas enabled yet
static String	REGIONSERVER_STOREFILE_REFRESH_PERIOD The period (in milliseconds) for refreshing the store files for the secondary regions.

Constructor Summary

Constructors

Constructor and Description
StorefileRefresherChore(int period, boolean onlyMetaRefresh, HRegionServer regionServer, Stoppable stoppable)

Method Summary

Modifier and Type	Method and Description
protected void	chore() The task to execute on each scheduled execution of the Chore
protected boolean	isRegionStale(String encodedName, long time)

Methods inherited from class org.apache.hadoop.hbase.ScheduledChore

cancel, cancel, choreForTesting, cleanup, getInitialDelay, getName, getPeriod, getStopper, getTimeUnit, initialChore, isInitialChoreComplete, isScheduled, run, toString, triggerNow

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

LOG

private static final org.slf4j.Logger LOG

REGIONSERVER_STOREFILE_REFRESH_PERIOD

public static final String REGIONSERVER_STOREFILE_REFRESH_PERIOD

The period (in milliseconds) for refreshing the store files for the secondary regions.

See Also:

Constant Field Values

DEFAULT_REGIONSERVER_STOREFILE_REFRESH_PERIOD

static final int DEFAULT_REGIONSERVER_STOREFILE_REFRESH_PERIOD

See Also:

Constant Field Values

REGIONSERVER_META_STOREFILE_REFRESH_PERIOD

public static final String REGIONSERVER_META_STOREFILE_REFRESH_PERIOD

Whether all storefiles should be refreshed, as opposed to just hbase:meta's Meta region doesn't have WAL replication for replicas enabled yet

See Also:

Constant Field Values

regionServer

private HRegionServer regionServer

hfileTtl

private long hfileTtl

period

private int period

onlyMetaRefresh

private boolean onlyMetaRefresh

lastRefreshTimes

private Map<String,Long> lastRefreshTimes

Constructor Detail

StorefileRefresherChore

public StorefileRefresherChore(int period,
                               boolean onlyMetaRefresh,
                               HRegionServer regionServer,
                               Stoppable stoppable)

Method Detail

chore

protected void chore()

Description copied from class: ScheduledChore

The task to execute on each scheduled execution of the Chore

Specified by:

chore in class ScheduledChore

isRegionStale

protected boolean isRegionStale(String encodedName,
                                long time)