Modifier and Type | Class and Description |
---|---|
class |
LogRollBackupSubprocedure
This backup subprocedure implementation forces a log roll on the RS.
|
Modifier and Type | Method and Description |
---|---|
Subprocedure |
LogRollRegionServerProcedureManager.buildSubprocedure(byte[] data)
If in a running state, creates the specified subprocedure for handling a backup procedure.
|
Subprocedure |
LogRollRegionServerProcedureManager.BackupSubprocedureBuilder.buildSubprocedure(java.lang.String name,
byte[] data) |
Modifier and Type | Class and Description |
---|---|
class |
SimpleRSProcedureManager.SimpleSubprocedure |
static class |
Subprocedure.SubprocedureImpl
Empty Subprocedure for testing.
|
class |
TestProcedureMember.EmptySubprocedure
Helper
Procedure who's phase for each step is just empty |
Modifier and Type | Method and Description |
---|---|
Subprocedure |
SimpleRSProcedureManager.buildSubprocedure(java.lang.String name)
If in a running state, creates the specified subprocedure for handling a procedure.
|
Subprocedure |
SubprocedureFactory.buildSubprocedure(java.lang.String procName,
byte[] procArgs)
Build
Subprocedure when requested. |
Subprocedure |
SimpleRSProcedureManager.SimleSubprocedureBuilder.buildSubprocedure(java.lang.String name,
byte[] data) |
Subprocedure |
ProcedureMember.createSubprocedure(java.lang.String opName,
byte[] data)
This is separated from execution so that we can detect and handle the case where the
subprocedure is invalid and inactionable due to bad info (like DISABLED snapshot type being
sent here)
|
Modifier and Type | Method and Description |
---|---|
void |
ProcedureMemberRpcs.sendMemberAborted(Subprocedure sub,
ForeignException cause)
Notify the coordinator that we aborted the specified
Subprocedure |
void |
ZKProcedureMemberRpcs.sendMemberAborted(Subprocedure sub,
ForeignException ee)
This should be called by the member and should write a serialized root cause exception as
to the abort znode.
|
void |
ProcedureMemberRpcs.sendMemberAcquired(Subprocedure sub)
Notify the coordinator that the specified
Subprocedure has acquired the locally required
barrier condition. |
void |
ZKProcedureMemberRpcs.sendMemberAcquired(Subprocedure sub)
This attempts to create an acquired state znode for the procedure (snapshot name).
|
void |
ProcedureMemberRpcs.sendMemberCompleted(Subprocedure sub,
byte[] data)
Notify the coordinator that the specified
Subprocedure has completed the work that
needed to be done under the global barrier. |
void |
ZKProcedureMemberRpcs.sendMemberCompleted(Subprocedure sub,
byte[] data)
This acts as the ack for a completed procedure
|
boolean |
ProcedureMember.submitSubprocedure(Subprocedure subproc)
Submit an subprocedure for execution.
|
Modifier and Type | Class and Description |
---|---|
class |
FlushTableSubprocedure
This flush region implementation uses the distributed procedure framework to flush
table regions.
|
Modifier and Type | Method and Description |
---|---|
Subprocedure |
RegionServerFlushTableProcedureManager.buildSubprocedure(java.lang.String table)
If in a running state, creates the specified subprocedure to flush table regions.
|
Subprocedure |
RegionServerFlushTableProcedureManager.FlushTableSubprocedureBuilder.buildSubprocedure(java.lang.String name,
byte[] data) |
Modifier and Type | Class and Description |
---|---|
class |
FlushSnapshotSubprocedure
This online snapshot implementation uses the distributed procedure framework to force a
store flush and then records the hfiles.
|
Modifier and Type | Method and Description |
---|---|
Subprocedure |
RegionServerSnapshotManager.buildSubprocedure(HBaseProtos.SnapshotDescription snapshot)
If in a running state, creates the specified subprocedure for handling an online snapshot.
|
Subprocedure |
RegionServerSnapshotManager.SnapshotSubprocedureBuilder.buildSubprocedure(java.lang.String name,
byte[] data) |