Package org.apache.hadoop.hbase.procedure.flush

Class FlushTableSubprocedure

java.lang.Object

org.apache.hadoop.hbase.procedure.Subprocedure

org.apache.hadoop.hbase.procedure.flush.FlushTableSubprocedure

All Implemented Interfaces:

Callable<Void>

@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	Description
private static class	FlushTableSubprocedure.RegionFlushTask

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

Subprocedure.SubprocedureImpl

Field Summary

Fields

Modifier and Type	Field	Description
private final List<String>	families
private static final org.slf4j.Logger	LOG
private final List<HRegion>	regions
private final String	table
private final RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool	taskManager

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

executionTimeoutTimer, monitor, rpcs, wakeFrequency

Constructor Summary

Constructors

Constructor	Description
FlushTableSubprocedure(ProcedureMember member, ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout, List<HRegion> regions, String table, List<String> families, RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool taskManager)

Method Summary

Modifier and Type	Method	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 Details

LOG

private static final org.slf4j.Logger LOG

table

private final String table

families

private final List<String> families

regions

private final List<HRegion> regions

taskManager

private final RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool taskManager

Constructor Details

FlushTableSubprocedure

public FlushTableSubprocedure(ProcedureMember member,
 ForeignExceptionDispatcher errorListener,
 long wakeFrequency,
 long timeout,
 List<HRegion> regions,
 String table,
 List<String> families,
 RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool taskManager)

Method Details

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()