Package org.apache.hadoop.hbase.procedure.flush

Class RegionServerFlushTableProcedureManager

java.lang.Object

org.apache.hadoop.hbase.procedure.ProcedureManager

org.apache.hadoop.hbase.procedure.RegionServerProcedureManager

org.apache.hadoop.hbase.procedure.flush.RegionServerFlushTableProcedureManager

@LimitedPrivate("Configuration")
public class RegionServerFlushTableProcedureManager
extends RegionServerProcedureManager

This manager class handles flushing of the regions for table on a HRegionServer.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	RegionServerFlushTableProcedureManager.FlushTableSubprocedureBuilder
(package private) static class	RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool	We use the FlushTableSubprocedurePool, a class specific thread pool instead of ExecutorService.

Field Summary

Fields

Modifier and Type	Field	Description
private static final String	CONCURENT_FLUSH_TASKS_KEY
private static final int	DEFAULT_CONCURRENT_FLUSH_TASKS
static final int	FLUSH_REQUEST_THREADS_DEFAULT
static final String	FLUSH_REQUEST_THREADS_KEY
private static final long	FLUSH_REQUEST_WAKE_MILLIS_DEFAULT
static final String	FLUSH_REQUEST_WAKE_MILLIS_KEY
static final long	FLUSH_TIMEOUT_MILLIS_DEFAULT
static final String	FLUSH_TIMEOUT_MILLIS_KEY
private static final org.slf4j.Logger	LOG
private ProcedureMember	member
private ProcedureMemberRpcs	memberRpcs
private RegionServerServices	rss

Constructor Summary

Constructors

Constructor	Description
RegionServerFlushTableProcedureManager()
RegionServerFlushTableProcedureManager(org.apache.hadoop.conf.Configuration conf, HRegionServer server, ProcedureMemberRpcs memberRpc, ProcedureMember procMember)	Exposed for testing.

Method Summary

Modifier and Type	Method	Description
Subprocedure	buildSubprocedure(String table, List<String> families)	If in a running state, creates the specified subprocedure to flush table regions.
String	getProcedureSignature()	Return the unique signature of the procedure.
private List<HRegion>	getRegionsToFlush(String table)	Get the list of regions to flush for the table on this server It is possible that if a region moves somewhere between the calls we'll miss the region.
void	initialize(RegionServerServices rss)	Initialize this region server flush procedure manager Uses a zookeeper based member controller.
void	start()	Start accepting flush table requests.
void	stop(boolean force)	Close this and all running tasks

Methods inherited from class org.apache.hadoop.hbase.procedure.ProcedureManager

equals, hashCode

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

CONCURENT_FLUSH_TASKS_KEY

private static final String CONCURENT_FLUSH_TASKS_KEY

See Also:

• Constant Field Values

DEFAULT_CONCURRENT_FLUSH_TASKS

private static final int DEFAULT_CONCURRENT_FLUSH_TASKS

See Also:

• Constant Field Values

FLUSH_REQUEST_THREADS_KEY

public static final String FLUSH_REQUEST_THREADS_KEY

See Also:

• Constant Field Values

FLUSH_REQUEST_THREADS_DEFAULT

public static final int FLUSH_REQUEST_THREADS_DEFAULT

See Also:

• Constant Field Values

FLUSH_TIMEOUT_MILLIS_KEY

public static final String FLUSH_TIMEOUT_MILLIS_KEY

See Also:

• Constant Field Values

FLUSH_TIMEOUT_MILLIS_DEFAULT

public static final long FLUSH_TIMEOUT_MILLIS_DEFAULT

See Also:

• Constant Field Values

FLUSH_REQUEST_WAKE_MILLIS_KEY

public static final String FLUSH_REQUEST_WAKE_MILLIS_KEY

See Also:

• Constant Field Values

FLUSH_REQUEST_WAKE_MILLIS_DEFAULT

private static final long FLUSH_REQUEST_WAKE_MILLIS_DEFAULT

See Also:

• Constant Field Values

rss

private RegionServerServices rss

memberRpcs

private ProcedureMemberRpcs memberRpcs

member

private ProcedureMember member

Constructor Details

RegionServerFlushTableProcedureManager

RegionServerFlushTableProcedureManager(org.apache.hadoop.conf.Configuration conf,
 HRegionServer server,
 ProcedureMemberRpcs memberRpc,
 ProcedureMember procMember)

Exposed for testing.

Parameters:

conf - HBase configuration.

server - region server.

memberRpc - use specified memberRpc instance

procMember - use specified ProcedureMember

RegionServerFlushTableProcedureManager

public RegionServerFlushTableProcedureManager()

Method Details

start

public void start()

Start accepting flush table requests.

Specified by:

start in class RegionServerProcedureManager

stop

public void stop(boolean force)
          throws IOException

Close this and all running tasks

Specified by:

stop in class RegionServerProcedureManager

Parameters:

force - forcefully stop all running tasks

Throws:

IOException

buildSubprocedure

public Subprocedure buildSubprocedure(String table,
 List<String> families)

If in a running state, creates the specified subprocedure to flush table regions. Because this gets the local list of regions to flush and not the set the master had, there is a possibility of a race where regions may be missed.

Parameters:

table - table to flush

families - column families within a table

Returns:

Subprocedure to submit to the ProcedureMember.

getRegionsToFlush

private List<HRegion> getRegionsToFlush(String table)
                                 throws IOException

Get the list of regions to flush for the table on this server It is possible that if a region moves somewhere between the calls we'll miss the region.

Returns:

the list of online regions. Empty list is returned if no regions.

Throws:

IOException

initialize

public void initialize(RegionServerServices rss)
                throws org.apache.zookeeper.KeeperException

Initialize this region server flush procedure manager Uses a zookeeper based member controller.

Specified by:

initialize in class RegionServerProcedureManager

Parameters:

rss - region server

Throws:

org.apache.zookeeper.KeeperException - if the zookeeper cannot be reached

getProcedureSignature

public String getProcedureSignature()

Description copied from class: ProcedureManager

Return the unique signature of the procedure. This signature uniquely identifies the procedure. By default, this signature is the string used in the procedure controller (i.e., the root ZK node name for the procedure)

Specified by:

getProcedureSignature in class ProcedureManager