Modifier and Type | Method and Description |
---|---|
ServerName |
SplitWALManager.acquireSplitWALWorker(Procedure<?> procedure)
Acquire a split WAL worker
|
Modifier and Type | Method and Description |
---|---|
void |
RegionStateNodeLock.QueueEntry.await()
Called when we can not hold the lock and should wait.
|
private void |
TransitRegionStateProcedure.checkAndWaitForOriginalServer(MasterProcedureEnv env,
ServerName lastHost) |
private void |
TransitRegionStateProcedure.closeRegion(MasterProcedureEnv env,
RegionStateNode regionNode) |
private StateMachineProcedure.Flow |
TransitRegionStateProcedure.confirmOpened(MasterProcedureEnv env,
RegionStateNode regionNode) |
protected Procedure[] |
TransitRegionStateProcedure.execute(MasterProcedureEnv env) |
protected Procedure<MasterProcedureEnv>[] |
RegionRemoteProcedureBase.execute(MasterProcedureEnv env) |
protected StateMachineProcedure.Flow |
GCMultipleMergedRegionsProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.GCMergedRegionsState state) |
protected StateMachineProcedure.Flow |
GCMergedRegionsProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.GCMergedRegionsState state)
Deprecated.
|
protected StateMachineProcedure.Flow |
GCRegionProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.GCRegionState state) |
protected StateMachineProcedure.Flow |
TransitRegionStateProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RegionStateTransitionState state) |
protected abstract void |
RegionTransitionProcedure.finishTransition(MasterProcedureEnv env,
RegionStateNode regionNode)
Deprecated.
|
(package private) void |
RegionStateNodeLock.lock(Procedure<?> proc,
Runnable wakeUp)
Lock by a procedure.
|
void |
RegionStateNode.lock(Procedure<?> proc,
Runnable wakeUp) |
private void |
RegionStateNodeLock.lock0(RegionStateNodeLock.QueueEntry entry) |
private void |
TransitRegionStateProcedure.openRegion(MasterProcedureEnv env,
RegionStateNode regionNode) |
private void |
TransitRegionStateProcedure.queueAssign(MasterProcedureEnv env,
RegionStateNode regionNode) |
protected abstract boolean |
RegionTransitionProcedure.startTransition(MasterProcedureEnv env,
RegionStateNode regionNode)
Deprecated.
|
protected abstract boolean |
RegionTransitionProcedure.updateTransition(MasterProcedureEnv env,
RegionStateNode regionNode)
Deprecated.
|
protected boolean |
AssignProcedure.updateTransition(MasterProcedureEnv env,
RegionStateNode regionNode)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected Procedure<MasterProcedureEnv>[] |
LockProcedure.execute(MasterProcedureEnv env) |
Modifier and Type | Method and Description |
---|---|
private void |
ServerCrashProcedure.assignRegions(MasterProcedureEnv env,
List<RegionInfo> regions)
Assign the regions on the crashed RS to other Rses.
|
protected Procedure<MasterProcedureEnv>[] |
ServerRemoteProcedure.execute(MasterProcedureEnv env) |
protected Procedure<MasterProcedureEnv>[] |
SnapshotVerifyProcedure.execute(MasterProcedureEnv env) |
protected Procedure<MasterProcedureEnv>[] |
FlushRegionProcedure.execute(MasterProcedureEnv env) |
protected Procedure<MasterProcedureEnv>[] |
SnapshotRegionProcedure.execute(MasterProcedureEnv env) |
protected StateMachineProcedure.Flow |
FlushTableProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.FlushTableState state) |
protected StateMachineProcedure.Flow |
InitMetaProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.InitMetaState state) |
protected StateMachineProcedure.Flow |
MigrateNamespaceTableProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.MigrateNamespaceTableProcedureState state) |
protected StateMachineProcedure.Flow |
ModifyTableDescriptorProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyTableDescriptorState state) |
protected StateMachineProcedure.Flow |
RecoverMetaProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RecoverMetaState state)
Deprecated.
|
protected StateMachineProcedure.Flow |
ReopenTableRegionsProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ReopenTableRegionsState state) |
protected StateMachineProcedure.Flow |
ServerCrashProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ServerCrashState state) |
protected StateMachineProcedure.Flow |
SnapshotProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SnapshotState state) |
protected StateMachineProcedure.Flow |
SplitWALProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SplitWALState state) |
protected StateMachineProcedure.Flow |
SwitchRpcThrottleProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SwitchRpcThrottleState state) |
private void |
SnapshotProcedure.prepareSnapshot(MasterProcedureEnv env) |
private StateMachineProcedure.Flow |
ReopenTableRegionsProcedure.reopenIfSchedulable(MasterProcedureEnv env,
List<HRegionLocation> regionsToReopen,
boolean shouldBatchBackoff) |
Modifier and Type | Method and Description |
---|---|
private ProcedureSuspendedException |
MigrateReplicationQueueFromZkToTableProcedure.suspend(org.apache.hadoop.conf.Configuration conf,
LongConsumer backoffConsumer) |
protected ProcedureSuspendedException |
AbstractPeerNoLockProcedure.suspend(org.apache.hadoop.conf.Configuration conf,
LongConsumer backoffConsumer) |
Modifier and Type | Method and Description |
---|---|
ServerName |
SyncReplicationReplayWALManager.acquirePeerWorker(String peerId,
Procedure<?> proc)
Get a worker for replaying remote wal for a give peer.
|
private void |
RemovePeerProcedure.checkAssignReplicationQueuesFinished(MasterProcedureEnv env) |
private void |
MigrateReplicationQueueFromZkToTableProcedure.disableReplicationLogCleaner(MasterProcedureEnv env) |
protected Procedure<MasterProcedureEnv>[] |
ClaimReplicationQueuesProcedure.execute(MasterProcedureEnv env)
Deprecated.
|
protected Procedure<MasterProcedureEnv>[] |
ClaimReplicationQueueRemoteProcedure.execute(MasterProcedureEnv env) |
protected StateMachineProcedure.Flow |
AssignReplicationQueuesProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.AssignReplicationQueuesState state) |
protected StateMachineProcedure.Flow |
MigrateReplicationQueueFromZkToTableProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.MigrateReplicationQueueFromZkToTableState state) |
protected StateMachineProcedure.Flow |
ModifyPeerProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState state) |
protected StateMachineProcedure.Flow |
TransitPeerSyncReplicationStateProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState state) |
protected StateMachineProcedure.Flow |
RecoverStandbyProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RecoverStandbyState state) |
protected StateMachineProcedure.Flow |
SyncReplicationReplayWALProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SyncReplicationReplayWALState state) |
protected void |
RemovePeerProcedure.postPeerModification(MasterProcedureEnv env) |
protected abstract void |
ModifyPeerProcedure.postPeerModification(MasterProcedureEnv env)
Called before we finish the procedure.
|
protected abstract void |
ModifyPeerProcedure.prePeerModification(MasterProcedureEnv env)
Called before we start the actual processing.
|
protected void |
AddPeerProcedure.prePeerModification(MasterProcedureEnv env) |
private ProcedureSuspendedException |
MigrateReplicationQueueFromZkToTableProcedure.suspend(org.apache.hadoop.conf.Configuration conf,
LongConsumer backoffConsumer) |
protected ProcedureSuspendedException |
AbstractPeerNoLockProcedure.suspend(org.apache.hadoop.conf.Configuration conf,
LongConsumer backoffConsumer) |
private void |
MigrateReplicationQueueFromZkToTableProcedure.waitUntilNoPeerProcedure(MasterProcedureEnv env) |
Modifier and Type | Method and Description |
---|---|
ServerName |
SnapshotManager.acquireSnapshotVerifyWorker(SnapshotVerifyProcedure procedure) |
Modifier and Type | Method and Description |
---|---|
protected ProcedureSuspendedException |
Procedure.suspend(int timeoutMillis,
boolean jitter) |
Modifier and Type | Method and Description |
---|---|
protected Procedure[] |
SequentialProcedure.doExecute(TEnvironment env) |
protected Procedure<TEnvironment>[] |
Procedure.doExecute(TEnvironment env)
Internal method called by the ProcedureExecutor that starts the user-level code execute().
|
protected Procedure<TEnvironment>[] |
FailedProcedure.execute(TEnvironment env) |
protected abstract Procedure<TEnvironment>[] |
Procedure.execute(TEnvironment env)
The main code of the procedure.
|
protected Procedure[] |
StateMachineProcedure.execute(TEnvironment env) |
protected abstract StateMachineProcedure.Flow |
StateMachineProcedure.executeFromState(TEnvironment env,
TState state)
called to perform a single step of the specified 'state' of the procedure
|
protected ProcedureSuspendedException |
Procedure.suspend(int timeoutMillis,
boolean jitter) |
static void |
ProcedureFutureUtil.suspend(Procedure<?> proc) |
static void |
ProcedureFutureUtil.suspendIfNecessary(Procedure<?> proc,
Consumer<CompletableFuture<Void>> setFuture,
CompletableFuture<Void> future,
MasterProcedureEnv env,
Runnable actionAfterDone) |
Modifier and Type | Method and Description |
---|---|
protected StateMachineProcedure.Flow |
ModifyStoreFileTrackerProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyStoreFileTrackerState state) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.