Uses of Class
org.apache.hadoop.hbase.master.assignment.RegionStateNode
Package
Description
-
Uses of RegionStateNode in org.apache.hadoop.hbase.master.assignment
Modifier and TypeFieldDescriptionprivate final RegionStateNode
RegionStates.RegionFailedOpen.regionNode
Modifier and TypeFieldDescriptionprivate final ConcurrentSkipListMap<String,
RegionStateNode> RegionStates.encodedRegionsMap
this map is a hack to lookup of region in master by encoded region name is O(n).private final ArrayList<RegionStateNode>
AssignmentManager.pendingAssignQueue
private final ConcurrentSkipListMap<RegionInfo,
RegionStateNode> RegionStates.regionInTransition
private final ConcurrentSkipListMap<RegionInfo,
RegionStateNode> RegionStates.regionOffline
Regions marked as offline on a read of hbase:meta.private final Set<RegionStateNode>
ServerStateNode.regions
private final ConcurrentSkipListMap<byte[],
RegionStateNode> RegionStates.regionsMap
A Map fromRegionInfo.getRegionName()
toRegionStateNode
private final ConcurrentMap<RegionInfo,
RegionStateNode> RegionStateNode.ritMap
Modifier and TypeMethodDescription(package private) RegionStateNode
RegionStates.createRegionStateNode
(RegionInfo regionInfo) RegionStates.getOrCreateRegionStateNode
(RegionInfo regionInfo) private RegionStateNode
RegionRemoteProcedureBase.getRegionNode
(MasterProcedureEnv env) RegionTransitionProcedure.getRegionState
(MasterProcedureEnv env) Deprecated.RegionStates.getRegionStateNode
(RegionInfo regionInfo) RegionStates.RegionFailedOpen.getRegionStateNode()
private RegionStateNode
TransitRegionStateProcedure.getRegionStateNode
(MasterProcedureEnv env) RegionStates.getRegionStateNodeFromEncodedRegionName
(String encodedRegionName) RegionStates.getRegionStateNodeFromName
(byte[] regionName) Modifier and TypeMethodDescriptionAssignmentManager.getRegionsInTransition()
RegionStates.getRegionsInTransition()
private Stream<RegionStateNode>
AssignmentManager.getRegionStateNodes
(TableName tableName, boolean excludeOfflinedSplitParents) RegionStates.getRegionStateNodes()
Returns A view of region state nodes for all the regions.(package private) List<RegionStateNode>
RegionStates.getTableRegionStateNodes
(TableName tableName) private HashMap<RegionInfo,
RegionStateNode> AssignmentManager.waitOnAssignQueue()
Modifier and TypeMethodDescriptionvoid
ServerStateNode.addRegion
(RegionStateNode regionNode) void
RegionStates.addRegionToServer
(RegionStateNode regionNode) RegionStates.addToFailedOpen
(RegionStateNode regionNode) void
RegionStates.addToOfflineRegions
(RegionStateNode regionNode) protected void
CloseRegionProcedure.checkTransition
(RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long seqId) protected void
OpenRegionProcedure.checkTransition
(RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long openSeqNum) protected abstract void
RegionRemoteProcedureBase.checkTransition
(RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long seqId) private void
TransitRegionStateProcedure.closeRegion
(MasterProcedureEnv env, RegionStateNode regionNode) private void
TransitRegionStateProcedure.closeRegionAfterUpdatingMeta
(MasterProcedureEnv env, RegionStateNode regionNode) int
RegionStateNode.compareTo
(RegionStateNode other) private StateMachineProcedure.Flow
TransitRegionStateProcedure.confirmClosed
(MasterProcedureEnv env, RegionStateNode regionNode) private StateMachineProcedure.Flow
TransitRegionStateProcedure.confirmOpened
(MasterProcedureEnv env, RegionStateNode regionNode) private TransitRegionStateProcedure
AssignmentManager.createAssignProcedure
(RegionStateNode regionNode, ServerName targetServer) Create an assign TransitRegionStateProcedure.private HRegionLocation
RegionStates.createRegionForReopen
(RegionStateNode node) private void
RegionStates.createSnapshot
(RegionStateNode node, Map<ServerName, List<RegionInfo>> result) protected void
AssignProcedure.finishTransition
(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.protected abstract void
RegionTransitionProcedure.finishTransition
(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.protected void
UnassignProcedure.finishTransition
(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.private TransitRegionStateProcedure
AssignmentManager.forceCreateUnssignProcedure
(RegionStateNode regionNode) private Put
RegionStateStore.generateUpdateRegionLocationPut
(RegionStateNode regionStateNode) private RegionInfo
AssignmentManager.getRegionInfo
(RegionStateNode rsn) private boolean
RegionStates.include
(RegionStateNode node, boolean offline) Utility.private void
TransitRegionStateProcedure.openRegion
(MasterProcedureEnv env, RegionStateNode regionNode) private void
RegionRemoteProcedureBase.persistAndWake
(MasterProcedureEnv env, RegionStateNode regionNode) (package private) CompletableFuture<Void>
AssignmentManager.persistToMeta
(RegionStateNode regionNode) private void
AssignmentManager.preTransitCheck
(RegionStateNode regionNode, RegionState.State[] expectedStates) protected void
AssignmentManager.queueAssign
(RegionStateNode regionNode) Add the assign operation to the assignment queue.private void
TransitRegionStateProcedure.queueAssign
(MasterProcedureEnv env, RegionStateNode regionNode) AssignmentManager.regionClosedAbnormally
(RegionStateNode regionNode) (package private) void
AssignmentManager.regionClosedWithoutPersistingToMeta
(RegionStateNode regionNode) (package private) CompletableFuture<Void>
AssignmentManager.regionClosing
(RegionStateNode regionNode) (package private) CompletableFuture<Void>
AssignmentManager.regionFailedOpen
(RegionStateNode regionNode, boolean giveUp) private void
TransitRegionStateProcedure.regionFailedOpenAfterUpdatingMeta
(MasterProcedureEnv env, RegionStateNode regionNode) (package private) void
AssignmentManager.regionOpenedWithoutPersistingToMeta
(RegionStateNode regionNode) private void
OpenRegionProcedure.regionOpenedWithoutPersistingToMeta
(AssignmentManager am, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long openSeqNum) (package private) CompletableFuture<Void>
AssignmentManager.regionOpening
(RegionStateNode regionNode) protected boolean
AssignProcedure.remoteCallFailed
(MasterProcedureEnv env, RegionStateNode regionNode, IOException exception) Deprecated.protected abstract boolean
RegionTransitionProcedure.remoteCallFailed
(MasterProcedureEnv env, RegionStateNode regionNode, IOException exception) Deprecated.protected boolean
UnassignProcedure.remoteCallFailed
(MasterProcedureEnv env, RegionStateNode regionNode, IOException exception) Deprecated.Returns If true, we will re-wake up this procedure; if false, the procedure stays suspended.void
ServerStateNode.removeRegion
(RegionStateNode regionNode) void
RegionStates.removeRegionFromServer
(ServerName serverName, RegionStateNode regionNode) private boolean
AssignmentManager.reportTransition
(RegionStateNode regionNode, ServerStateNode serverNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode state, long seqId, long procId) protected void
AssignProcedure.reportTransition
(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code, long openSeqNum) Deprecated.(package private) void
RegionRemoteProcedureBase.reportTransition
(MasterProcedureEnv env, RegionStateNode regionNode, ServerName serverName, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long seqId) protected abstract void
RegionTransitionProcedure.reportTransition
(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code, long seqId) Deprecated.void
TransitRegionStateProcedure.reportTransition
(MasterProcedureEnv env, RegionStateNode regionNode, ServerName serverName, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code, long seqId, long procId) protected void
UnassignProcedure.reportTransition
(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code, long seqId) Deprecated.protected void
CloseRegionProcedure.restoreSucceedState
(AssignmentManager am, RegionStateNode regionNode, long seqId) protected void
OpenRegionProcedure.restoreSucceedState
(AssignmentManager am, RegionStateNode regionNode, long openSeqNum) protected abstract void
RegionRemoteProcedureBase.restoreSucceedState
(AssignmentManager am, RegionStateNode regionNode, long seqId) (package private) void
RegionRemoteProcedureBase.serverCrashed
(MasterProcedureEnv env, RegionStateNode regionNode, ServerName serverName) TransitRegionStateProcedure.serverCrashed
(MasterProcedureEnv env, RegionStateNode regionNode, ServerName serverName, boolean forceNewPlan) protected boolean
AssignProcedure.startTransition
(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.protected abstract boolean
RegionTransitionProcedure.startTransition
(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.protected boolean
UnassignProcedure.startTransition
(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.(package private) void
RegionRemoteProcedureBase.stateLoaded
(AssignmentManager am, RegionStateNode regionNode) (package private) void
TransitRegionStateProcedure.stateLoaded
(AssignmentManager am, RegionStateNode regionNode) private CompletableFuture<Void>
AssignmentManager.transitStateAndUpdate
(RegionStateNode regionNode, RegionState.State newState, RegionState.State... expectedStates) (package private) CompletableFuture<Void>
RegionStateStore.updateRegionLocation
(RegionStateNode regionStateNode) protected boolean
AssignProcedure.updateTransition
(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.protected abstract boolean
RegionTransitionProcedure.updateTransition
(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.protected boolean
UnassignProcedure.updateTransition
(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.protected void
CloseRegionProcedure.updateTransitionWithoutPersistingToMeta
(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long seqId) protected void
OpenRegionProcedure.updateTransitionWithoutPersistingToMeta
(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long openSeqNum) protected abstract void
RegionRemoteProcedureBase.updateTransitionWithoutPersistingToMeta
(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long seqId) Modifier and TypeMethodDescriptionprivate void
AssignmentManager.acceptPlan
(HashMap<RegionInfo, RegionStateNode> regions, Map<ServerName, List<RegionInfo>> plan) private void
AssignmentManager.addToPendingAssignment
(HashMap<RegionInfo, RegionStateNode> regions, Collection<RegionInfo> pendingRegions) private boolean
AssignmentManager.containsBogusAssignments
(Map<RegionInfo, RegionStateNode> regions, List<RegionInfo> hirs) private List<RegionInfo>
RegionStates.getRegionsOfTable
(TableName table, Predicate<RegionStateNode> filter) Returns Return the regions of the table and filter them.private static void
AssignmentManagerUtil.lock
(List<RegionStateNode> regionNodes) private int
AssignmentManager.numberOfUnclosedRegions
(TableName tableName, Function<RegionStateNode, Boolean> shouldSubmit) private void
AssignmentManager.processAssignmentPlans
(HashMap<RegionInfo, RegionStateNode> regions, HashMap<RegionInfo, ServerName> retainMap, List<RegionInfo> hris, List<ServerName> servers) private int
AssignmentManager.submitUnassignProcedure
(TableName tableName, Function<RegionStateNode, Boolean> shouldSubmit, Consumer<RegionStateNode> logRIT, Consumer<TransitRegionStateProcedure> submit) private int
AssignmentManager.submitUnassignProcedure
(TableName tableName, Function<RegionStateNode, Boolean> shouldSubmit, Consumer<RegionStateNode> logRIT, Consumer<TransitRegionStateProcedure> submit) private static void
AssignmentManagerUtil.unlock
(List<RegionStateNode> regionNodes) ModifierConstructorDescription(package private)
RegionStateNode
(RegionInfo regionInfo, ConcurrentMap<RegionInfo, RegionStateNode> ritMap) -
Uses of RegionStateNode in org.apache.hadoop.hbase.master.procedure
Modifier and TypeMethodDescriptionprotected boolean
HBCKServerCrashProcedure.isMatchingRegionLocation
(RegionStateNode rsn) The RegionStateNode will not have a location if a confirm of an OPEN fails.protected boolean
ServerCrashProcedure.isMatchingRegionLocation
(RegionStateNode rsn) Moved out here so can be overridden by the HBCK fix-up SCP to be less strict about what it will tolerate as a 'match'.