Field Detail

• FLUSH_TABLE_PROCEDURE_SIGNATURE

  public static final String FLUSH_TABLE_PROCEDURE_SIGNATURE

  See Also:

  Constant Field Values

• FLUSH_TIMEOUT_MILLIS_KEY

  private static final String FLUSH_TIMEOUT_MILLIS_KEY

  See Also:

  Constant Field Values

• FLUSH_TIMEOUT_MILLIS_DEFAULT

  private static final int FLUSH_TIMEOUT_MILLIS_DEFAULT

  See Also:

  Constant Field Values

• FLUSH_WAKE_MILLIS_KEY

  private static final String FLUSH_WAKE_MILLIS_KEY

  See Also:

  Constant Field Values

• FLUSH_WAKE_MILLIS_DEFAULT

  private static final int FLUSH_WAKE_MILLIS_DEFAULT

  See Also:

  Constant Field Values

• FLUSH_PROC_POOL_THREADS_KEY

  private static final String FLUSH_PROC_POOL_THREADS_KEY

  See Also:

  Constant Field Values

• FLUSH_PROC_POOL_THREADS_DEFAULT

  private static final int FLUSH_PROC_POOL_THREADS_DEFAULT

  See Also:

  Constant Field Values

• LOG

  private static final org.apache.commons.logging.Log LOG

• master

  private MasterServices master

• coordinator

  private ProcedureCoordinator coordinator

• procMap

  private Map<TableName,Procedure> procMap

• stopped

  private boolean stopped

Constructor Detail

• MasterFlushTableProcedureManager

  public MasterFlushTableProcedureManager()

Method Detail

• stop

  public void stop(String why)

  Description copied from interface: Stoppable
  Stop this service.

  Parameters:

  why - Why we're stopping.

• isStopped

  public boolean isStopped()

  Returns:

  True if Stoppable.stop(String) has been closed.

• initialize

  public void initialize(MasterServices master,
                MetricsMaster metricsMaster)
                  throws org.apache.zookeeper.KeeperException,
                         IOException,
                         UnsupportedOperationException

  Description copied from class: MasterProcedureManager
  Initialize a globally barriered procedure for master.

  Specified by:

  initialize in class MasterProcedureManager

  Parameters:

  master - Master service interface

  Throws:

  org.apache.zookeeper.KeeperException

  IOException

  UnsupportedOperationException

• 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

• execProcedure

  public void execProcedure(org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.ProcedureDescription desc)
                     throws IOException

  Description copied from class: MasterProcedureManager
  Execute a distributed procedure on cluster

  Overrides:

  execProcedure in class MasterProcedureManager

  Parameters:

  desc - Procedure description

  Throws:

  IOException

• isProcedureDone

  public boolean isProcedureDone(org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.ProcedureDescription desc)
                          throws IOException

  Description copied from class: MasterProcedureManager
  Check if the procedure is finished successfully

  Specified by:

  isProcedureDone in class MasterProcedureManager

  Parameters:

  desc - Procedure description

  Returns:

  true if the specified procedure is finished successfully

  Throws:

  IOException