RegionServerFlushTableProcedureManager (Apache HBase 1.2.12 API)

java.lang.Object
- org.apache.hadoop.hbase.procedure.ProcedureManager
- - org.apache.hadoop.hbase.procedure.RegionServerProcedureManager
  - - org.apache.hadoop.hbase.procedure.flush.RegionServerFlushTableProcedureManager

@InterfaceAudience.LimitedPrivate(value="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 and 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 and Description
`private static String`	`CONCURENT_FLUSH_TASKS_KEY`
`private static int`	`DEFAULT_CONCURRENT_FLUSH_TASKS`
`static int`	`FLUSH_REQUEST_THREADS_DEFAULT`
`static String`	`FLUSH_REQUEST_THREADS_KEY`
`private static long`	`FLUSH_REQUEST_WAKE_MILLIS_DEFAULT`
`static String`	`FLUSH_REQUEST_WAKE_MILLIS_KEY`
`static long`	`FLUSH_TIMEOUT_MILLIS_DEFAULT`
`static String`	`FLUSH_TIMEOUT_MILLIS_KEY`
`private static org.apache.commons.logging.Log`	`LOG`
`private ProcedureMember`	`member`
`private ProcedureMemberRpcs`	`memberRpcs`
`private RegionServerServices`	`rss`

Constructor Summary

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

Method Summary

Methods
Modifier and Type	Method and Description
`Subprocedure`	`buildSubprocedure(String table)` If in a running state, creates the specified subprocedure to flush table regions.
`String`	`getProcedureSignature()` Return the unique signature of the procedure.
`private List<Region>`	`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 Detail
  - LOG
```
private static final org.apache.commons.logging.Log 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 Detail
  - 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 Detail
  - 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)
```
    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 -
    
    Returns:
    Subprocedure to submit to the ProcedureMemeber.
  - getRegionsToFlush
```
private List<Region> 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.
    
    Parameters:
    table -
    
    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

Class RegionServerFlushTableProcedureManager

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Object

Field Detail

LOG

CONCURENT_FLUSH_TASKS_KEY

DEFAULT_CONCURRENT_FLUSH_TASKS

FLUSH_REQUEST_THREADS_KEY

FLUSH_REQUEST_THREADS_DEFAULT

FLUSH_TIMEOUT_MILLIS_KEY

FLUSH_TIMEOUT_MILLIS_DEFAULT

FLUSH_REQUEST_WAKE_MILLIS_KEY

FLUSH_REQUEST_WAKE_MILLIS_DEFAULT

rss

memberRpcs

member

Constructor Detail

RegionServerFlushTableProcedureManager

RegionServerFlushTableProcedureManager

Method Detail

start

stop

buildSubprocedure

getRegionsToFlush

initialize

getProcedureSignature