Uses of Class
org.apache.hadoop.hbase.procedure.Subprocedure
Packages that use Subprocedure
Package
Description
-
Uses of Subprocedure in org.apache.hadoop.hbase.backup.regionserver
Subclasses of Subprocedure in org.apache.hadoop.hbase.backup.regionserverModifier and TypeClassDescriptionclass
This backup sub-procedure implementation forces a WAL rolling on a RS.Methods in org.apache.hadoop.hbase.backup.regionserver that return SubprocedureModifier and TypeMethodDescriptionLogRollRegionServerProcedureManager.BackupSubprocedureBuilder.buildSubprocedure
(String name, byte[] data) LogRollRegionServerProcedureManager.buildSubprocedure
(byte[] data) If in a running state, creates the specified subprocedure for handling a backup procedure. -
Uses of Subprocedure in org.apache.hadoop.hbase.procedure
Subclasses of Subprocedure in org.apache.hadoop.hbase.procedureModifier and TypeClassDescriptionstatic class
Empty Subprocedure for testing.Fields in org.apache.hadoop.hbase.procedure with type parameters of type SubprocedureModifier and TypeFieldDescriptionprivate final ConcurrentMap<String,
Subprocedure> ProcedureMember.subprocs
Methods in org.apache.hadoop.hbase.procedure that return SubprocedureModifier and TypeMethodDescriptionSubprocedureFactory.buildSubprocedure
(String procName, byte[] procArgs) BuildSubprocedure
when requested.ProcedureMember.createSubprocedure
(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)Methods in org.apache.hadoop.hbase.procedure with parameters of type SubprocedureModifier and TypeMethodDescriptionvoid
ProcedureMemberRpcs.sendMemberAborted
(Subprocedure sub, ForeignException cause) Notify the coordinator that we aborted the specifiedSubprocedure
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 specifiedSubprocedure
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 specifiedSubprocedure
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 procedureboolean
ProcedureMember.submitSubprocedure
(Subprocedure subproc) Submit an subprocedure for execution. -
Uses of Subprocedure in org.apache.hadoop.hbase.procedure.flush
Subclasses of Subprocedure in org.apache.hadoop.hbase.procedure.flushModifier and TypeClassDescriptionclass
This flush region implementation uses the distributed procedure framework to flush table regions.Methods in org.apache.hadoop.hbase.procedure.flush that return SubprocedureModifier and TypeMethodDescriptionRegionServerFlushTableProcedureManager.buildSubprocedure
(String table, List<String> families) If in a running state, creates the specified subprocedure to flush table regions.RegionServerFlushTableProcedureManager.FlushTableSubprocedureBuilder.buildSubprocedure
(String name, byte[] data) -
Uses of Subprocedure in org.apache.hadoop.hbase.regionserver.snapshot
Subclasses of Subprocedure in org.apache.hadoop.hbase.regionserver.snapshotModifier and TypeClassDescriptionclass
This online snapshot implementation uses the distributed procedure framework to force a store flush and then records the hfiles.Methods in org.apache.hadoop.hbase.regionserver.snapshot that return SubprocedureModifier and TypeMethodDescriptionRegionServerSnapshotManager.buildSubprocedure
(org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot) If in a running state, creates the specified subprocedure for handling an online snapshot.RegionServerSnapshotManager.SnapshotSubprocedureBuilder.buildSubprocedure
(String name, byte[] data)