FlushTableSubprocedure (Apache HBase 1.2.12 API)

java.lang.Object
- org.apache.hadoop.hbase.procedure.Subprocedure
- - org.apache.hadoop.hbase.procedure.flush.FlushTableSubprocedure

All Implemented Interfaces:

Callable<Void>
```
@InterfaceAudience.Private
public class FlushTableSubprocedure
extends Subprocedure
```
This flush region implementation uses the distributed procedure framework to flush table regions. Its acquireBarrier stage does nothing. Its insideBarrier stage flushes the regions.

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

private static class FlushTableSubprocedure.RegionFlushTask
- Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure.Subprocedure
  Subprocedure.SubprocedureImpl

Nested Classes
Modifier and Type	Class and Description
`private static class`	`FlushTableSubprocedure.RegionFlushTask`

Field Summary

Fields
Modifier and Type	Field and Description
`private static org.apache.commons.logging.Log`	`LOG`
`private List<Region>`	`regions`
`private String`	`table`
`private RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool`	`taskManager`

Fields inherited from class org.apache.hadoop.hbase.procedure.Subprocedure
executionTimeoutTimer, monitor, rpcs, wakeFrequency

Constructor Summary

Constructors
Constructor and Description
`FlushTableSubprocedure(ProcedureMember member, ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout, List<Region> regions, String table, RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool taskManager)`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`acquireBarrier()` Flush the online regions on this rs for the target table.
`void`	`cleanup(Exception e)` Cancel threads if they haven't finished.
`private void`	`flushRegions()`
`byte[]`	`insideBarrier()` The implementation of this method should act with the assumption that the barrier condition has been satisfied.
`void`	`releaseBarrier()`

Methods inherited from class org.apache.hadoop.hbase.procedure.Subprocedure
call, cancel, getMemberName, getName, receiveReachedGlobalBarrier, waitForLocallyCompleted

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - LOG
```
private static final org.apache.commons.logging.Log LOG
```
  - table
```
private final String table
```
  - regions
```
private final List<Region> regions
```
  - taskManager
```
private final RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool taskManager
```
- Constructor Detail
  - FlushTableSubprocedure
```
public FlushTableSubprocedure(ProcedureMember member,
                      ForeignExceptionDispatcher errorListener,
                      long wakeFrequency,
                      long timeout,
                      List<Region> regions,
                      String table,
                      RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool taskManager)
```
- Method Detail
  - flushRegions
```
private void flushRegions()
                   throws ForeignException
```
    Throws:
    
    ForeignException
  - acquireBarrier
```
public void acquireBarrier()
                    throws ForeignException
```
    Flush the online regions on this rs for the target table.
    
    Specified by:
    
    acquireBarrier in class Subprocedure
    
    Throws:
    
    ForeignException
  - insideBarrier
```
public byte[] insideBarrier()
                     throws ForeignException
```
    Description copied from class: Subprocedure
    
    The implementation of this method should act with the assumption that the barrier condition has been satisfied. Continuing the previous example, a condition could be that all RS's globally have been quiesced, and procedures that require this precondition could be implemented here. The implementation should also collect the result of the subprocedure as data to be returned to the coordinator upon successful completion. Users should override this method.
    
    Specified by:
    
    insideBarrier in class Subprocedure
    
    Returns:
    the data the subprocedure wants to return to coordinator side.
    
    Throws:
    
    ForeignException
  - cleanup
```
public void cleanup(Exception e)
```
    Cancel threads if they haven't finished.
    
    Specified by:
    
    cleanup in class Subprocedure
  - releaseBarrier
```
public void releaseBarrier()
```

Class FlushTableSubprocedure

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure.Subprocedure

Field Summary

Fields inherited from class org.apache.hadoop.hbase.procedure.Subprocedure

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Object

Field Detail

LOG

table

regions

taskManager

Constructor Detail

FlushTableSubprocedure

Method Detail

flushRegions

acquireBarrier

insideBarrier

cleanup

releaseBarrier