Package | Description |
---|---|
org.apache.hadoop.hbase.master.assignment |
Modifier and Type | Field and Description |
---|---|
private RegionStates.RegionStateNode |
RegionStates.RegionFailedOpen.regionNode |
Modifier and Type | Field and Description |
---|---|
private ArrayList<RegionStates.RegionStateNode> |
AssignmentManager.pendingAssignQueue |
private ConcurrentSkipListMap<RegionInfo,RegionStates.RegionStateNode> |
RegionStates.regionInTransition |
private ConcurrentSkipListMap<RegionInfo,RegionStates.RegionStateNode> |
RegionStates.regionOffline
Regions marked as offline on a read of hbase:meta.
|
private Set<RegionStates.RegionStateNode> |
RegionStates.ServerStateNode.regions |
private ConcurrentSkipListMap<byte[],RegionStates.RegionStateNode> |
RegionStates.regionsMap
RegionName -- i.e.
|
Modifier and Type | Method and Description |
---|---|
protected RegionStates.RegionStateNode |
RegionStates.createRegionStateNode(RegionInfo regionInfo) |
protected RegionStates.RegionStateNode |
RegionStates.getOrCreateRegionStateNode(RegionInfo regionInfo) |
RegionStates.RegionStateNode |
RegionTransitionProcedure.getRegionState(MasterProcedureEnv env) |
RegionStates.RegionStateNode |
RegionStates.RegionFailedOpen.getRegionStateNode() |
RegionStates.RegionStateNode |
RegionStates.getRegionStateNode(RegionInfo regionInfo) |
(package private) RegionStates.RegionStateNode |
RegionStates.getRegionStateNodeFromName(byte[] regionName) |
Modifier and Type | Method and Description |
---|---|
Set<RegionStates.RegionStateNode> |
RegionStates.ServerStateNode.getRegions() |
List<RegionStates.RegionStateNode> |
RegionStates.getRegionsInTransition() |
List<RegionStates.RegionStateNode> |
AssignmentManager.getRegionsInTransition() |
(package private) Collection<RegionStates.RegionStateNode> |
RegionStates.getRegionStateNodes() |
(package private) ArrayList<RegionStates.RegionStateNode> |
RegionStates.getTableRegionStateNodes(TableName tableName) |
private HashMap<RegionInfo,RegionStates.RegionStateNode> |
AssignmentManager.waitOnAssignQueue() |
Modifier and Type | Method and Description |
---|---|
void |
RegionStates.ServerStateNode.addRegion(RegionStates.RegionStateNode regionNode) |
protected boolean |
RegionStates.addRegionInTransition(RegionStates.RegionStateNode regionNode,
RegionTransitionProcedure procedure) |
protected boolean |
AssignmentManager.addRegionInTransition(RegionStates.RegionStateNode regionNode,
RegionTransitionProcedure procedure) |
(package private) RegionStates.ServerStateNode |
RegionStates.addRegionToServer(RegionStates.RegionStateNode regionNode)
Add reference to region to serverstatenode.
|
RegionStates.RegionFailedOpen |
RegionStates.addToFailedOpen(RegionStates.RegionStateNode regionNode) |
void |
RegionStates.addToOfflineRegions(RegionStates.RegionStateNode regionNode) |
protected static boolean |
AssignProcedure.assign(MasterServices masterServices,
RegionStates.RegionStateNode regionNode) |
int |
RegionStates.RegionStateNode.compareTo(RegionStates.RegionStateNode other) |
private HRegionLocation |
RegionStates.createRegionForReopen(RegionStates.RegionStateNode node) |
protected void |
UnassignProcedure.finishTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
protected void |
AssignProcedure.finishTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
protected abstract void |
RegionTransitionProcedure.finishTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
private void |
AssignProcedure.handleFailure(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode)
Called when dispatch or subsequent OPEN request fail.
|
(package private) boolean |
RegionStates.include(RegionStates.RegionStateNode node,
boolean offline)
Utility.
|
private boolean |
AssignProcedure.incrementAndCheckMaxAttempts(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
private boolean |
UnassignProcedure.isSafeToProceed(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode,
IOException exception)
Our remote call failed but there are a few states where it is safe to proceed with the
unassign; e.g.
|
protected boolean |
RegionTransitionProcedure.isServerOnline(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
void |
AssignmentManager.markRegionAsClosed(RegionStates.RegionStateNode regionNode) |
void |
AssignmentManager.markRegionAsClosing(RegionStates.RegionStateNode regionNode) |
void |
AssignmentManager.markRegionAsOpened(RegionStates.RegionStateNode regionNode) |
void |
AssignmentManager.markRegionAsOpening(RegionStates.RegionStateNode regionNode) |
protected void |
UnassignProcedure.proceed(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode)
Set it up so when procedure is unsuspended, we'll move to the procedure finish.
|
protected void |
AssignmentManager.queueAssign(RegionStates.RegionStateNode regionNode)
Add the assign operation to the assignment queue.
|
protected boolean |
UnassignProcedure.remoteCallFailed(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode,
IOException exception) |
protected boolean |
AssignProcedure.remoteCallFailed(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode,
IOException exception) |
protected abstract boolean |
RegionTransitionProcedure.remoteCallFailed(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode,
IOException exception) |
void |
RegionStates.ServerStateNode.removeRegion(RegionStates.RegionStateNode regionNode) |
RegionStates.ServerStateNode |
RegionStates.removeRegionFromServer(ServerName serverName,
RegionStates.RegionStateNode regionNode) |
protected void |
RegionStates.removeRegionInTransition(RegionStates.RegionStateNode regionNode,
RegionTransitionProcedure procedure) |
protected void |
AssignmentManager.removeRegionInTransition(RegionStates.RegionStateNode regionNode,
RegionTransitionProcedure procedure) |
protected void |
UnassignProcedure.reportTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode,
org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code,
long seqId) |
protected void |
AssignProcedure.reportTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode,
org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code,
long openSeqNum) |
protected abstract void |
RegionTransitionProcedure.reportTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode,
org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code,
long seqId) |
private boolean |
AssignmentManager.reportTransition(RegionStates.RegionStateNode regionNode,
ServerName serverName,
org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode state,
long seqId) |
protected boolean |
UnassignProcedure.startTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
protected boolean |
AssignProcedure.startTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
protected abstract boolean |
RegionTransitionProcedure.startTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
void |
AssignmentManager.undoRegionAsClosing(RegionStates.RegionStateNode regionNode) |
void |
AssignmentManager.undoRegionAsOpening(RegionStates.RegionStateNode regionNode) |
void |
RegionStateStore.updateRegionLocation(RegionStates.RegionStateNode regionStateNode) |
protected boolean |
UnassignProcedure.updateTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
protected boolean |
AssignProcedure.updateTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
protected abstract boolean |
RegionTransitionProcedure.updateTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode)
Called when the Procedure is in the REGION_TRANSITION_DISPATCH state.
|
Modifier and Type | Method and Description |
---|---|
private void |
AssignmentManager.acceptPlan(HashMap<RegionInfo,RegionStates.RegionStateNode> regions,
Map<ServerName,List<RegionInfo>> plan) |
private void |
AssignmentManager.addToPendingAssignment(HashMap<RegionInfo,RegionStates.RegionStateNode> regions,
Collection<RegionInfo> pendingRegions) |
(package private) UnassignProcedure[] |
AssignmentManager.createUnassignProcedures(Collection<RegionStates.RegionStateNode> nodes) |
private List<RegionInfo> |
RegionStates.getRegionsOfTable(TableName table,
Predicate<RegionStates.RegionStateNode> filter) |
private void |
AssignmentManager.processAssignmentPlans(HashMap<RegionInfo,RegionStates.RegionStateNode> regions,
HashMap<RegionInfo,ServerName> retainMap,
List<RegionInfo> hris,
List<ServerName> servers) |
Constructor and Description |
---|
RegionFailedOpen(RegionStates.RegionStateNode regionNode) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.