@InterfaceAudience.Private @InterfaceStability.Unstable public class FlushSnapshotSubprocedure extends Subprocedure
Subprocedure.SubprocedureImpl
executionTimeoutTimer, monitor, rpcs, wakeFrequency
Constructor and Description |
---|
FlushSnapshotSubprocedure(ProcedureMember member,
ForeignExceptionDispatcher errorListener,
long wakeFrequency,
long timeout,
List<Region> regions,
HBaseProtos.SnapshotDescription snapshot,
org.apache.hadoop.hbase.regionserver.snapshot.RegionServerSnapshotManager.SnapshotSubprocedurePool taskManager) |
Modifier and Type | Method and Description |
---|---|
void |
acquireBarrier()
do nothing, core of snapshot is executed in
insideBarrier() step. |
void |
cleanup(Exception e)
Cancel threads if they haven't finished.
|
byte[] |
insideBarrier()
do a flush snapshot of every region on this rs from the target table.
|
void |
releaseBarrier()
Hooray!
|
call, cancel, getMemberName, getName, receiveReachedGlobalBarrier, waitForLocallyCompleted
public FlushSnapshotSubprocedure(ProcedureMember member, ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout, List<Region> regions, HBaseProtos.SnapshotDescription snapshot, org.apache.hadoop.hbase.regionserver.snapshot.RegionServerSnapshotManager.SnapshotSubprocedurePool taskManager)
public void acquireBarrier() throws ForeignException
insideBarrier()
step.acquireBarrier
in class Subprocedure
ForeignException
public byte[] insideBarrier() throws ForeignException
insideBarrier
in class Subprocedure
ForeignException
public void cleanup(Exception e)
cleanup
in class Subprocedure
public void releaseBarrier()
Copyright © 2007-2016 The Apache Software Foundation. All Rights Reserved.