Package | Description |
---|---|
org.apache.hadoop.hbase.master.assignment | |
org.apache.hadoop.hbase.master.procedure |
Modifier and Type | Field and Description |
---|---|
private RegionStateNode |
RegionStates.RegionFailedOpen.regionNode |
Modifier and Type | Field and Description |
---|---|
private ArrayList<RegionStateNode> |
AssignmentManager.pendingAssignQueue |
private ConcurrentSkipListMap<RegionInfo,RegionStateNode> |
RegionStates.regionInTransition |
private ConcurrentSkipListMap<RegionInfo,RegionStateNode> |
RegionStates.regionOffline
Regions marked as offline on a read of hbase:meta.
|
private Set<RegionStateNode> |
ServerStateNode.regions |
private ConcurrentSkipListMap<byte[],RegionStateNode> |
RegionStates.regionsMap
RegionName -- i.e.
|
private ConcurrentMap<RegionInfo,RegionStateNode> |
RegionStateNode.ritMap |
Modifier and Type | Method and Description |
---|---|
(package private) RegionStateNode |
RegionStates.createRegionStateNode(RegionInfo regionInfo) |
RegionStateNode |
RegionStates.getOrCreateRegionStateNode(RegionInfo regionInfo) |
private RegionStateNode |
RegionRemoteProcedureBase.getRegionNode(MasterProcedureEnv env) |
RegionStateNode |
RegionTransitionProcedure.getRegionState(MasterProcedureEnv env)
Deprecated.
|
RegionStateNode |
RegionStates.RegionFailedOpen.getRegionStateNode() |
private RegionStateNode |
TransitRegionStateProcedure.getRegionStateNode(MasterProcedureEnv env) |
RegionStateNode |
RegionStates.getRegionStateNode(RegionInfo regionInfo) |
RegionStateNode |
RegionStates.getRegionStateNodeFromName(byte[] regionName) |
Modifier and Type | Method and Description |
---|---|
List<RegionStateNode> |
RegionStates.getRegionsInTransition() |
List<RegionStateNode> |
AssignmentManager.getRegionsInTransition() |
Collection<RegionStateNode> |
RegionStates.getRegionStateNodes()
Returns A view of region state nodes for all the regions.
|
private Stream<RegionStateNode> |
AssignmentManager.getRegionStateNodes(TableName tableName,
boolean excludeOfflinedSplitParents) |
(package private) List<RegionStateNode> |
RegionStates.getTableRegionStateNodes(TableName tableName) |
private HashMap<RegionInfo,RegionStateNode> |
AssignmentManager.waitOnAssignQueue() |
Modifier and Type | Method and Description |
---|---|
void |
ServerStateNode.addRegion(RegionStateNode regionNode) |
ServerStateNode |
RegionStates.addRegionToServer(RegionStateNode regionNode) |
RegionStates.RegionFailedOpen |
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) |
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 |
UnassignProcedure.finishTransition(MasterProcedureEnv env,
RegionStateNode regionNode)
Deprecated.
|
protected void |
AssignProcedure.finishTransition(MasterProcedureEnv env,
RegionStateNode regionNode)
Deprecated.
|
protected abstract void |
RegionTransitionProcedure.finishTransition(MasterProcedureEnv env,
RegionStateNode regionNode)
Deprecated.
|
private TransitRegionStateProcedure |
AssignmentManager.forceCreateUnssignProcedure(RegionStateNode regionNode) |
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) void |
AssignmentManager.persistToMeta(RegionStateNode regionNode) |
private void |
AssignmentManager.preTransitCheck(RegionStateNode regionNode,
RegionState.State[] expectedStates) |
private void |
TransitRegionStateProcedure.queueAssign(MasterProcedureEnv env,
RegionStateNode regionNode) |
protected void |
AssignmentManager.queueAssign(RegionStateNode regionNode)
Add the assign operation to the assignment queue.
|
void |
AssignmentManager.regionClosedAbnormally(RegionStateNode regionNode) |
(package private) void |
AssignmentManager.regionClosedWithoutPersistingToMeta(RegionStateNode regionNode) |
(package private) void |
AssignmentManager.regionClosing(RegionStateNode regionNode) |
(package private) void |
AssignmentManager.regionFailedOpen(RegionStateNode regionNode,
boolean giveUp) |
private void |
OpenRegionProcedure.regionOpenedWithoutPersistingToMeta(AssignmentManager am,
RegionStateNode regionNode,
org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode,
long openSeqNum) |
(package private) void |
AssignmentManager.regionOpenedWithoutPersistingToMeta(RegionStateNode regionNode) |
(package private) void |
AssignmentManager.regionOpening(RegionStateNode regionNode) |
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.
|
protected boolean |
AssignProcedure.remoteCallFailed(MasterProcedureEnv env,
RegionStateNode regionNode,
IOException exception)
Deprecated.
|
protected abstract boolean |
RegionTransitionProcedure.remoteCallFailed(MasterProcedureEnv env,
RegionStateNode regionNode,
IOException exception)
Deprecated.
|
void |
ServerStateNode.removeRegion(RegionStateNode regionNode) |
ServerStateNode |
RegionStates.removeRegionFromServer(ServerName serverName,
RegionStateNode regionNode) |
protected void |
UnassignProcedure.reportTransition(MasterProcedureEnv env,
RegionStateNode regionNode,
org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code,
long seqId)
Deprecated.
|
protected void |
AssignProcedure.reportTransition(MasterProcedureEnv env,
RegionStateNode regionNode,
org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code,
long openSeqNum)
Deprecated.
|
protected abstract void |
RegionTransitionProcedure.reportTransition(MasterProcedureEnv env,
RegionStateNode regionNode,
org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code,
long seqId)
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) |
void |
TransitRegionStateProcedure.reportTransition(MasterProcedureEnv env,
RegionStateNode regionNode,
ServerName serverName,
org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code,
long seqId,
long procId) |
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 |
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) |
void |
TransitRegionStateProcedure.serverCrashed(MasterProcedureEnv env,
RegionStateNode regionNode,
ServerName serverName,
boolean forceNewPlan) |
protected boolean |
UnassignProcedure.startTransition(MasterProcedureEnv env,
RegionStateNode regionNode)
Deprecated.
|
protected boolean |
AssignProcedure.startTransition(MasterProcedureEnv env,
RegionStateNode regionNode)
Deprecated.
|
protected abstract boolean |
RegionTransitionProcedure.startTransition(MasterProcedureEnv env,
RegionStateNode regionNode)
Deprecated.
|
(package private) void |
TransitRegionStateProcedure.stateLoaded(AssignmentManager am,
RegionStateNode regionNode) |
(package private) void |
RegionRemoteProcedureBase.stateLoaded(AssignmentManager am,
RegionStateNode regionNode) |
private void |
AssignmentManager.transitStateAndUpdate(RegionStateNode regionNode,
RegionState.State newState,
RegionState.State... expectedStates) |
(package private) void |
RegionStateStore.updateRegionLocation(RegionStateNode regionStateNode) |
protected boolean |
UnassignProcedure.updateTransition(MasterProcedureEnv env,
RegionStateNode regionNode)
Deprecated.
|
protected boolean |
AssignProcedure.updateTransition(MasterProcedureEnv env,
RegionStateNode regionNode)
Deprecated.
|
protected abstract boolean |
RegionTransitionProcedure.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 Type | Method and Description |
---|---|
private 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 void |
AssignmentManager.processAssignmentPlans(HashMap<RegionInfo,RegionStateNode> regions,
HashMap<RegionInfo,ServerName> retainMap,
List<RegionInfo> hris,
List<ServerName> servers) |
private static void |
AssignmentManagerUtil.unlock(List<RegionStateNode> regionNodes) |
Constructor and Description |
---|
RegionFailedOpen(RegionStateNode regionNode) |
Constructor and Description |
---|
RegionStateNode(RegionInfo regionInfo,
ConcurrentMap<RegionInfo,RegionStateNode> ritMap) |
Modifier and Type | Method and Description |
---|---|
protected 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'.
|
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.