org.apache.hadoop.hbase.master.assignment

Class OpenRegionProcedure

java.lang.Object

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

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

org.apache.hadoop.hbase.master.assignment.OpenRegionProcedure

All Implemented Interfaces:

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

@InterfaceAudience.Private
public class OpenRegionProcedure
extends RegionRemoteProcedureBase

The remote procedure used to open 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 static org.slf4j.Logger	LOG

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
OpenRegionProcedure()
OpenRegionProcedure(TransitRegionStateProcedure parent, RegionInfo region, ServerName targetServer)

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 openSeqNum)
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()
private void	regionOpenedWithoutPersistingToMeta(AssignmentManager am, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long openSeqNum)
protected void	restoreSucceedState(AssignmentManager am, RegionStateNode regionNode, long openSeqNum)
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 openSeqNum)

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

LOG

private static final org.slf4j.Logger LOG

Constructor Detail

OpenRegionProcedure

public OpenRegionProcedure()

OpenRegionProcedure

public OpenRegionProcedure(TransitRegionStateProcedure parent,
                           RegionInfo region,
                           ServerName targetServer)

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

regionOpenedWithoutPersistingToMeta

private void regionOpenedWithoutPersistingToMeta(AssignmentManager am,
                                                 RegionStateNode regionNode,
                                                 org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode,
                                                 long openSeqNum)
                                          throws IOException

Throws:

IOException

checkTransition

protected void checkTransition(RegionStateNode regionNode,
                               org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode,
                               long openSeqNum)
                        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 openSeqNum)
                                                throws IOException

Specified by:

updateTransitionWithoutPersistingToMeta in class RegionRemoteProcedureBase

Throws:

IOException

restoreSucceedState

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

Specified by:

restoreSucceedState in class RegionRemoteProcedureBase

Throws:

IOException