Constructor Detail

• FlushTableSubprocedure

  public FlushTableSubprocedure(ProcedureMember member,
                        ForeignExceptionDispatcher errorListener,
                        long wakeFrequency,
                        long timeout,
                        List<Region> regions,
                        String table,
                        org.apache.hadoop.hbase.procedure.flush.RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool taskManager)

Method Detail

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