MasterFlushTableProcedureManager (Apache HBase 2.5.0 API)

java.lang.Object
- org.apache.hadoop.hbase.procedure.ProcedureManager
- - org.apache.hadoop.hbase.procedure.MasterProcedureManager
  - - org.apache.hadoop.hbase.procedure.flush.MasterFlushTableProcedureManager

All Implemented Interfaces:: Stoppable

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class MasterFlushTableProcedureManager
extends MasterProcedureManager

Field Summary

Fields
Modifier and Type	Field and Description
`private ProcedureCoordinator`	`coordinator`
`private static int`	`FLUSH_PROC_POOL_THREADS_DEFAULT`
`private static String`	`FLUSH_PROC_POOL_THREADS_KEY`
`static String`	`FLUSH_TABLE_PROCEDURE_SIGNATURE`
`private static int`	`FLUSH_TIMEOUT_MILLIS_DEFAULT`
`private static String`	`FLUSH_TIMEOUT_MILLIS_KEY`
`private static int`	`FLUSH_WAKE_MILLIS_DEFAULT`
`private static String`	`FLUSH_WAKE_MILLIS_KEY`
`private static org.slf4j.Logger`	`LOG`
`private MasterServices`	`master`
`private Map<TableName,Procedure>`	`procMap`
`private boolean`	`stopped`

Constructor Summary

Constructors
Constructor and Description

MasterFlushTableProcedureManager()

Constructors
Constructor and Description
`MasterFlushTableProcedureManager()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`checkPermissions(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc, AccessChecker accessChecker, User user)` Check for required permissions before executing the procedure.
`void`	`execProcedure(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc)` Execute a distributed procedure on cluster
`String`	`getProcedureSignature()` Return the unique signature of the procedure.
`void`	`initialize(MasterServices master, MetricsMaster metricsMaster)` Initialize a globally barriered procedure for master.
`boolean`	`isProcedureDone(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc)` Check if the procedure is finished successfully
`boolean`	`isStopped()` Returns True if `Stoppable.stop(String)` has been closed.
`void`	`stop(String why)` Stop this service.

Methods inherited from class org.apache.hadoop.hbase.procedure.MasterProcedureManager
execProcedureWithRet

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
  - 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.slf4j.Logger 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. Implementers should favor logging errors over throwing RuntimeExceptions.
    
    Parameters:
    
    why - Why we're stopping.
  - isStopped
```
public boolean isStopped()
```
    Description copied from interface: Stoppable
    
    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 nnn
    
    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.shaded.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 n
    
    Throws:
    
    IOException
  - checkPermissions
```
public void checkPermissions(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc,
                             AccessChecker accessChecker,
                             User user)
                      throws IOException
```
    Description copied from class: MasterProcedureManager
    
    Check for required permissions before executing the procedure.
    
    Specified by:
    
    checkPermissions in class MasterProcedureManager
    
    Throws:
    
    IOException - if permissions requirements are not met.
  - isProcedureDone
```
public boolean isProcedureDone(org.apache.hadoop.hbase.shaded.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 n
    
    Throws:
    
    IOException

Class MasterFlushTableProcedureManager

Field Summary

Constructor Summary

Method Summary

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

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

Methods inherited from class java.lang.Object

Field Detail

FLUSH_TABLE_PROCEDURE_SIGNATURE

FLUSH_TIMEOUT_MILLIS_KEY

FLUSH_TIMEOUT_MILLIS_DEFAULT

FLUSH_WAKE_MILLIS_KEY

FLUSH_WAKE_MILLIS_DEFAULT

FLUSH_PROC_POOL_THREADS_KEY

FLUSH_PROC_POOL_THREADS_DEFAULT

LOG

master

coordinator

procMap

stopped

Constructor Detail

MasterFlushTableProcedureManager

Method Detail

stop

isStopped

initialize

getProcedureSignature

execProcedure

checkPermissions

isProcedureDone