Uses of Class
org.apache.hadoop.hbase.master.assignment.RegionStateNode
Packages that use RegionStateNode
Package
Description
-
Uses of RegionStateNode in org.apache.hadoop.hbase.master.assignment
Fields in org.apache.hadoop.hbase.master.assignment declared as RegionStateNodeModifier and TypeFieldDescriptionprivate final RegionStateNodeRegionStates.RegionFailedOpen.regionNodeFields in org.apache.hadoop.hbase.master.assignment with type parameters of type RegionStateNodeModifier and TypeFieldDescriptionprivate final ConcurrentSkipListMap<String,RegionStateNode> RegionStates.encodedRegionsMapthis map is a hack to lookup of region in master by encoded region name is O(n).private final ArrayList<RegionStateNode>AssignmentManager.pendingAssignQueueprivate final ConcurrentSkipListMap<RegionInfo,RegionStateNode> RegionStates.regionInTransitionprivate final ConcurrentSkipListMap<RegionInfo,RegionStateNode> RegionStates.regionOfflineRegions marked as offline on a read of hbase:meta.private final Set<RegionStateNode>ServerStateNode.regionsprivate final ConcurrentSkipListMap<byte[],RegionStateNode> RegionStates.regionsMapA Map fromRegionInfo.getRegionName()toRegionStateNodeprivate final ConcurrentMap<RegionInfo,RegionStateNode> RegionStateNode.ritMapMethods in org.apache.hadoop.hbase.master.assignment that return RegionStateNodeModifier and TypeMethodDescription(package private) RegionStateNodeRegionStates.createRegionStateNode(RegionInfo regionInfo) RegionStates.getOrCreateRegionStateNode(RegionInfo regionInfo) private RegionStateNodeRegionRemoteProcedureBase.getRegionNode(MasterProcedureEnv env) RegionTransitionProcedure.getRegionState(MasterProcedureEnv env) Deprecated.RegionStates.getRegionStateNode(RegionInfo regionInfo) RegionStates.RegionFailedOpen.getRegionStateNode()private RegionStateNodeTransitRegionStateProcedure.getRegionStateNode(MasterProcedureEnv env) RegionStates.getRegionStateNodeFromEncodedRegionName(String encodedRegionName) RegionStates.getRegionStateNodeFromName(byte[] regionName) Methods in org.apache.hadoop.hbase.master.assignment that return types with arguments of type RegionStateNodeModifier 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()Methods in org.apache.hadoop.hbase.master.assignment with parameters of type RegionStateNodeModifier and TypeMethodDescriptionvoidServerStateNode.addRegion(RegionStateNode regionNode) voidRegionStates.addRegionToServer(RegionStateNode regionNode) RegionStates.addToFailedOpen(RegionStateNode regionNode) voidRegionStates.addToOfflineRegions(RegionStateNode regionNode) protected voidCloseRegionProcedure.checkTransition(RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long seqId) protected voidOpenRegionProcedure.checkTransition(RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long openSeqNum) protected abstract voidRegionRemoteProcedureBase.checkTransition(RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long seqId) private voidTransitRegionStateProcedure.closeRegion(MasterProcedureEnv env, RegionStateNode regionNode) private voidTransitRegionStateProcedure.closeRegionAfterUpdatingMeta(MasterProcedureEnv env, RegionStateNode regionNode) intRegionStateNode.compareTo(RegionStateNode other) private StateMachineProcedure.FlowTransitRegionStateProcedure.confirmClosed(MasterProcedureEnv env, RegionStateNode regionNode) private StateMachineProcedure.FlowTransitRegionStateProcedure.confirmOpened(MasterProcedureEnv env, RegionStateNode regionNode) private TransitRegionStateProcedureAssignmentManager.createAssignProcedure(RegionStateNode regionNode, ServerName targetServer) Create an assign TransitRegionStateProcedure.private HRegionLocationRegionStates.createRegionForReopen(RegionStateNode node) private voidRegionStates.createSnapshot(RegionStateNode node, Map<ServerName, List<RegionInfo>> result) protected voidAssignProcedure.finishTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.protected abstract voidRegionTransitionProcedure.finishTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.protected voidUnassignProcedure.finishTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.private TransitRegionStateProcedureAssignmentManager.forceCreateUnssignProcedure(RegionStateNode regionNode) private PutRegionStateStore.generateUpdateRegionLocationPut(RegionStateNode regionStateNode) private RegionInfoAssignmentManager.getRegionInfo(RegionStateNode rsn) private booleanRegionStates.include(RegionStateNode node, boolean offline) Utility.private voidTransitRegionStateProcedure.openRegion(MasterProcedureEnv env, RegionStateNode regionNode) private voidRegionRemoteProcedureBase.persistAndWake(MasterProcedureEnv env, RegionStateNode regionNode) (package private) CompletableFuture<Void>AssignmentManager.persistToMeta(RegionStateNode regionNode) private voidAssignmentManager.preTransitCheck(RegionStateNode regionNode, RegionState.State[] expectedStates) protected voidAssignmentManager.queueAssign(RegionStateNode regionNode) Add the assign operation to the assignment queue.private voidTransitRegionStateProcedure.queueAssign(MasterProcedureEnv env, RegionStateNode regionNode) AssignmentManager.regionClosedAbnormally(RegionStateNode regionNode) (package private) voidAssignmentManager.regionClosedWithoutPersistingToMeta(RegionStateNode regionNode) (package private) CompletableFuture<Void>AssignmentManager.regionClosing(RegionStateNode regionNode) (package private) CompletableFuture<Void>AssignmentManager.regionFailedOpen(RegionStateNode regionNode, boolean giveUp) private voidTransitRegionStateProcedure.regionFailedOpenAfterUpdatingMeta(MasterProcedureEnv env, RegionStateNode regionNode) (package private) voidAssignmentManager.regionOpenedWithoutPersistingToMeta(RegionStateNode regionNode) private voidOpenRegionProcedure.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 booleanAssignProcedure.remoteCallFailed(MasterProcedureEnv env, RegionStateNode regionNode, IOException exception) Deprecated.protected abstract booleanRegionTransitionProcedure.remoteCallFailed(MasterProcedureEnv env, RegionStateNode regionNode, IOException exception) Deprecated.protected booleanUnassignProcedure.remoteCallFailed(MasterProcedureEnv env, RegionStateNode regionNode, IOException exception) Deprecated.Returns If true, we will re-wake up this procedure; if false, the procedure stays suspended.voidServerStateNode.removeRegion(RegionStateNode regionNode) voidRegionStates.removeRegionFromServer(ServerName serverName, RegionStateNode regionNode) private booleanAssignmentManager.reportTransition(RegionStateNode regionNode, ServerStateNode serverNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode state, long seqId, long procId) protected voidAssignProcedure.reportTransition(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code, long openSeqNum) Deprecated.(package private) voidRegionRemoteProcedureBase.reportTransition(MasterProcedureEnv env, RegionStateNode regionNode, ServerName serverName, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long seqId) protected abstract voidRegionTransitionProcedure.reportTransition(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code, long seqId) Deprecated.voidTransitRegionStateProcedure.reportTransition(MasterProcedureEnv env, RegionStateNode regionNode, ServerName serverName, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code, long seqId, long procId) protected voidUnassignProcedure.reportTransition(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code, long seqId) Deprecated.protected voidCloseRegionProcedure.restoreSucceedState(AssignmentManager am, RegionStateNode regionNode, long seqId) protected voidOpenRegionProcedure.restoreSucceedState(AssignmentManager am, RegionStateNode regionNode, long openSeqNum) protected abstract voidRegionRemoteProcedureBase.restoreSucceedState(AssignmentManager am, RegionStateNode regionNode, long seqId) (package private) voidRegionRemoteProcedureBase.serverCrashed(MasterProcedureEnv env, RegionStateNode regionNode, ServerName serverName) TransitRegionStateProcedure.serverCrashed(MasterProcedureEnv env, RegionStateNode regionNode, ServerName serverName, boolean forceNewPlan) protected booleanAssignProcedure.startTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.protected abstract booleanRegionTransitionProcedure.startTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.protected booleanUnassignProcedure.startTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.(package private) voidRegionRemoteProcedureBase.stateLoaded(AssignmentManager am, RegionStateNode regionNode) (package private) voidTransitRegionStateProcedure.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 booleanAssignProcedure.updateTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.protected abstract booleanRegionTransitionProcedure.updateTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.protected booleanUnassignProcedure.updateTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.protected voidCloseRegionProcedure.updateTransitionWithoutPersistingToMeta(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long seqId) protected voidOpenRegionProcedure.updateTransitionWithoutPersistingToMeta(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long openSeqNum) protected abstract voidRegionRemoteProcedureBase.updateTransitionWithoutPersistingToMeta(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long seqId) Method parameters in org.apache.hadoop.hbase.master.assignment with type arguments of type RegionStateNodeModifier and TypeMethodDescriptionprivate voidAssignmentManager.acceptPlan(HashMap<RegionInfo, RegionStateNode> regions, Map<ServerName, List<RegionInfo>> plan) private voidAssignmentManager.addToPendingAssignment(HashMap<RegionInfo, RegionStateNode> regions, Collection<RegionInfo> pendingRegions) private booleanAssignmentManager.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 voidAssignmentManagerUtil.lock(List<RegionStateNode> regionNodes) private intAssignmentManager.numberOfUnclosedRegions(TableName tableName, Function<RegionStateNode, Boolean> shouldSubmit) private voidAssignmentManager.processAssignmentPlans(HashMap<RegionInfo, RegionStateNode> regions, HashMap<RegionInfo, ServerName> retainMap, List<RegionInfo> hris, List<ServerName> servers) private intAssignmentManager.submitUnassignProcedure(TableName tableName, Function<RegionStateNode, Boolean> shouldSubmit, Consumer<RegionStateNode> logRIT, Consumer<TransitRegionStateProcedure> submit) private intAssignmentManager.submitUnassignProcedure(TableName tableName, Function<RegionStateNode, Boolean> shouldSubmit, Consumer<RegionStateNode> logRIT, Consumer<TransitRegionStateProcedure> submit) private static voidAssignmentManagerUtil.unlock(List<RegionStateNode> regionNodes) Constructors in org.apache.hadoop.hbase.master.assignment with parameters of type RegionStateNodeConstructor parameters in org.apache.hadoop.hbase.master.assignment with type arguments of type RegionStateNodeModifierConstructorDescription(package private)RegionStateNode(RegionInfo regionInfo, ConcurrentMap<RegionInfo, RegionStateNode> ritMap) -
Uses of RegionStateNode in org.apache.hadoop.hbase.master.procedure
Methods in org.apache.hadoop.hbase.master.procedure with parameters of type RegionStateNodeModifier and TypeMethodDescriptionprotected booleanHBCKServerCrashProcedure.isMatchingRegionLocation(RegionStateNode rsn) The RegionStateNode will not have a location if a confirm of an OPEN fails.protected booleanServerCrashProcedure.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'.