Class LogRollBackupSubprocedure
java.lang.Object
org.apache.hadoop.hbase.procedure.Subprocedure
org.apache.hadoop.hbase.backup.regionserver.LogRollBackupSubprocedure
This backup sub-procedure implementation forces a WAL rolling on a RS.
-
Nested Class Summary
Modifier and TypeClassDescription(package private) class
Callable task.Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure.Subprocedure
Subprocedure.SubprocedureImpl
-
Field Summary
Modifier and TypeFieldDescriptionprivate String
private static final org.slf4j.Logger
private final RegionServerServices
private final LogRollBackupSubprocedurePool
Fields inherited from class org.apache.hadoop.hbase.procedure.Subprocedure
executionTimeoutTimer, monitor, rpcs, wakeFrequency
-
Constructor Summary
ConstructorDescriptionLogRollBackupSubprocedure
(RegionServerServices rss, ProcedureMember member, ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout, LogRollBackupSubprocedurePool taskManager, byte[] data) -
Method Summary
Modifier and TypeMethodDescriptionvoid
The implementation of this method should gather and hold required resources (locks, disk space, etc) to satisfy the Procedures barrier condition.void
Cancel threads if they haven't finished.byte[]
do a log roll.void
Hooray!private void
rolllog()
Methods inherited from class org.apache.hadoop.hbase.procedure.Subprocedure
call, cancel, getMemberName, getName, receiveReachedGlobalBarrier, waitForLocallyCompleted
-
Field Details
-
LOG
-
rss
-
taskManager
-
backupRoot
-
-
Constructor Details
-
LogRollBackupSubprocedure
public LogRollBackupSubprocedure(RegionServerServices rss, ProcedureMember member, ForeignExceptionDispatcher errorListener, long wakeFrequency, long timeout, LogRollBackupSubprocedurePool taskManager, byte[] data)
-
-
Method Details
-
rolllog
- Throws:
ForeignException
-
acquireBarrier
Description copied from class:Subprocedure
The implementation of this method should gather and hold required resources (locks, disk space, etc) to satisfy the Procedures barrier condition. For example, this would be where to make all the regions on a RS on the quiescent for an procedure that required all regions to be globally quiesed. Users should override this method. If a quiescent is not required, this is overkill but can still be used to execute a procedure on all members and to propagate any exceptions.- Specified by:
acquireBarrier
in classSubprocedure
-
insideBarrier
do a log roll.- Specified by:
insideBarrier
in classSubprocedure
- Returns:
- some bytes
- Throws:
ForeignException
-
cleanup
Cancel threads if they haven't finished.- Specified by:
cleanup
in classSubprocedure
-
releaseBarrier
Hooray!
-