org.apache.hadoop.hbase.master.assignment

Class CloseRegionProcedure

java.lang.Object

org.apache.hadoop.hbase.procedure2.Procedure<MasterProcedureEnv>

org.apache.hadoop.hbase.master.assignment.RegionRemoteProcedureBase

org.apache.hadoop.hbase.master.assignment.CloseRegionProcedure

All Implemented Interfaces:

Comparable<Procedure<MasterProcedureEnv>>, TableProcedureInterface, RemoteProcedureDispatcher.RemoteProcedure<MasterProcedureEnv,ServerName>

@InterfaceAudience.Private
public class CloseRegionProcedure
extends RegionRemoteProcedureBase

The remote procedure used to close a region.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure2.Procedure

Procedure.LockState

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.master.procedure.TableProcedureInterface

TableProcedureInterface.TableOperationType

Field Summary

Fields

Modifier and Type	Field and Description
private ServerName	assignCandidate

Fields inherited from class org.apache.hadoop.hbase.master.assignment.RegionRemoteProcedureBase

region, targetServer

Fields inherited from class org.apache.hadoop.hbase.procedure2.Procedure

NO_PROC_ID, NO_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
CloseRegionProcedure()
CloseRegionProcedure(TransitRegionStateProcedure parent, RegionInfo region, ServerName targetServer, ServerName assignCandidate)

Method Summary

Modifier and Type	Method and Description
protected void	checkTransition(RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long seqId)
protected void	deserializeStateData(ProcedureStateSerializer serializer) Called on store load to allow the user to decode the previously serialized state.
protected ProcedureMetrics	getProcedureMetrics(MasterProcedureEnv env) Override this method to provide procedure specific counters for submitted count, failed count and time histogram.
TableProcedureInterface.TableOperationType	getTableOperationType() Given an operation type we can take decisions about what to do with pending operations.
RemoteProcedureDispatcher.RemoteOperation	newRemoteOperation()
protected void	restoreSucceedState(AssignmentManager am, RegionStateNode regionNode, long seqId)
protected void	serializeStateData(ProcedureStateSerializer serializer) The user-level code of the procedure may have some state to persist (e.g.
protected void	updateTransitionWithoutPersistingToMeta(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long seqId)

Methods inherited from class org.apache.hadoop.hbase.master.assignment.RegionRemoteProcedureBase

abort, afterReplay, execute, getProcName, getTableName, remoteCallBuild, remoteCallFailed, remoteOperationCompleted, remoteOperationFailed, reportTransition, rollback, serverCrashed, setTimeoutFailure, stateLoaded, storeInDispatchedQueue, toStringClassDetails, waitInitialized

Methods inherited from class org.apache.hadoop.hbase.procedure2.Procedure

acquireLock, addStackIndex, beforeReplay, bypass, compareTo, completionCleanup, doExecute, doRollback, elapsedTime, getChildrenLatch, getException, getLastUpdate, getNonceKey, getOwner, getParentProcId, getProcId, getProcIdHashCode, getResult, getRootProcedureId, getRootProcId, getStackIndexes, getState, getSubmittedTime, getTimeout, getTimeoutTimestamp, hasChildren, hasException, hasLock, hasOwner, hasParent, hasTimeout, haveSameParent, holdLock, incChildrenLatch, isBypass, isFailed, isFinished, isInitializing, isLockedWhenLoading, isRunnable, isSuccess, isWaiting, isYieldAfterExecutionStep, releaseLock, removeStackIndex, setAbortFailure, setChildrenLatch, setFailure, setFailure, setLastUpdate, setNonceKey, setOwner, setOwner, setParentProcId, setProcId, setResult, setRootProcId, setStackIndexes, setState, setSubmittedTime, setTimeout, shouldWaitClientAck, skipPersistence, toString, toStringClass, toStringDetails, toStringSimpleSB, toStringState, updateMetricsOnFinish, updateMetricsOnSubmit, updateTimestamp, wasExecuted

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

assignCandidate

private ServerName assignCandidate

Constructor Detail

CloseRegionProcedure

public CloseRegionProcedure()

CloseRegionProcedure

public CloseRegionProcedure(TransitRegionStateProcedure parent,
                            RegionInfo region,
                            ServerName targetServer,
                            ServerName assignCandidate)

Method Detail

getTableOperationType

public TableProcedureInterface.TableOperationType getTableOperationType()

Description copied from interface: TableProcedureInterface

Given an operation type we can take decisions about what to do with pending operations. e.g. if we get a delete and we have some table operation pending (e.g. add column) we can abort those operations.

Returns:

the operation type that the procedure is executing.

newRemoteOperation

public RemoteProcedureDispatcher.RemoteOperation newRemoteOperation()

Specified by:

newRemoteOperation in class RegionRemoteProcedureBase

serializeStateData

protected void serializeStateData(ProcedureStateSerializer serializer)
                           throws IOException

Description copied from class: Procedure

The user-level code of the procedure may have some state to persist (e.g. input arguments or current position in the processing state) to be able to resume on failure.

Overrides:

serializeStateData in class RegionRemoteProcedureBase

Parameters:

serializer - stores the serializable state

Throws:

IOException

deserializeStateData

protected void deserializeStateData(ProcedureStateSerializer serializer)
                             throws IOException

Description copied from class: Procedure

Called on store load to allow the user to decode the previously serialized state.

Overrides:

deserializeStateData in class RegionRemoteProcedureBase

Parameters:

serializer - contains the serialized state

Throws:

IOException

getProcedureMetrics

protected ProcedureMetrics getProcedureMetrics(MasterProcedureEnv env)

Description copied from class: Procedure

Override this method to provide procedure specific counters for submitted count, failed count and time histogram.

Overrides:

getProcedureMetrics in class Procedure<MasterProcedureEnv>

Parameters:

env - The environment passed to the procedure executor

Returns:

Container object for procedure related metric

checkTransition

protected void checkTransition(RegionStateNode regionNode,
                               org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode,
                               long seqId)
                        throws UnexpectedStateException

Specified by:

checkTransition in class RegionRemoteProcedureBase

Throws:

UnexpectedStateException

updateTransitionWithoutPersistingToMeta

protected void updateTransitionWithoutPersistingToMeta(MasterProcedureEnv env,
                                                       RegionStateNode regionNode,
                                                       org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode,
                                                       long seqId)
                                                throws IOException

Specified by:

updateTransitionWithoutPersistingToMeta in class RegionRemoteProcedureBase

Throws:

IOException

restoreSucceedState

protected void restoreSucceedState(AssignmentManager am,
                                   RegionStateNode regionNode,
                                   long seqId)
                            throws IOException

Specified by:

restoreSucceedState in class RegionRemoteProcedureBase

Throws:

IOException