Field Detail

• 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

Constructor Detail

• 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.

• 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