| Package | Description |
|---|---|
| org.apache.hadoop.hbase | |
| org.apache.hadoop.hbase.master | |
| org.apache.hadoop.hbase.zookeeper |
| Modifier and Type | Field and Description |
|---|---|
private Map<String,RegionState> |
ClusterStatus.intransition |
| Modifier and Type | Method and Description |
|---|---|
Map<String,RegionState> |
ClusterStatus.getRegionsInTransition() |
| Constructor and Description |
|---|
ClusterStatus(String hbaseVersion,
String clusterid,
Map<ServerName,ServerLoad> servers,
Collection<ServerName> deadServers,
ServerName master,
Collection<ServerName> backupMasters,
Map<String,RegionState> rit,
String[] masterCoprocessors,
Boolean balancerOn) |
| Modifier and Type | Field and Description |
|---|---|
(package private) HashMap<String,RegionState> |
RegionStates.regionsInTransition
Regions currently in transition.
|
private Map<String,RegionState> |
RegionStates.regionStates
Region encoded name to state map.
|
private Map<TableName,Map<String,RegionState>> |
RegionStates.regionStatesTableIndex
Holds mapping of table -> region state
|
| Modifier and Type | Method and Description |
|---|---|
static RegionState |
RegionState.convert(org.apache.hadoop.hbase.protobuf.generated.ClusterStatusProtos.RegionState proto)
Convert a protobuf HBaseProtos.RegionState to a RegionState
|
RegionState |
RegionStates.createRegionState(HRegionInfo hri)
Add a region to RegionStates.
|
RegionState |
RegionStates.createRegionState(HRegionInfo hri,
RegionState.State newState,
ServerName serverName,
ServerName lastHost)
Add a region to RegionStates with the specified state.
|
private RegionState |
AssignmentManager.forceRegionStateToOffline(HRegionInfo region,
boolean forceNewPlan)
Set region to OFFLINE unless it is opening and forceNewPlan is false.
|
protected RegionState |
RegionStates.getRegionState(HRegionInfo hri) |
protected RegionState |
RegionStates.getRegionState(String encodedName) |
RegionState |
RegionStates.getRegionTransitionState(HRegionInfo hri)
Get region transition state
|
RegionState |
RegionStates.getRegionTransitionState(String encodedName)
Get region transition state
|
private RegionState |
RegionStates.putRegionState(RegionState regionState) |
RegionState |
RegionStates.setRegionStateTOCLOSED(byte[] regionName,
ServerName serverName)
Set the region state to CLOSED
|
RegionState |
RegionStates.setRegionStateTOCLOSED(HRegionInfo regionInfo,
ServerName serverName)
Set the region state to CLOSED
|
RegionState |
RegionStates.transitionOpenFromPendingOpenOrOpeningOnServer(RegionTransition transition,
RegionState fromState,
ServerName sn)
Transition a region state to OPEN from OPENING/PENDING_OPEN
|
RegionState |
RegionStates.updateRegionState(HRegionInfo hri,
RegionState.State state)
Update a region state.
|
RegionState |
RegionStates.updateRegionState(HRegionInfo hri,
RegionState.State state,
ServerName serverName)
Update a region state.
|
private RegionState |
RegionStates.updateRegionState(HRegionInfo hri,
RegionState.State state,
ServerName serverName,
long openSeqNum)
Update a region state.
|
RegionState |
RegionStates.updateRegionState(RegionTransition transition,
RegionState.State state)
Update a region state.
|
| Modifier and Type | Method and Description |
|---|---|
Map<String,RegionState> |
RegionStates.getRegionsInTransition()
Get regions in transition and their states
|
| Modifier and Type | Method and Description |
|---|---|
void |
AssignmentManager.assign(RegionState state,
boolean setOfflineInZK,
boolean forceNewPlan)
Caller must hold lock on the passed
state object. |
private void |
HMaster.assignMetaZkLess(RegionStates regionStates,
RegionState regionState,
long timeout,
Set<ServerName> previouslyFailedRs) |
private boolean |
AssignmentManager.asyncSetOfflineInZooKeeper(RegionState state,
org.apache.zookeeper.AsyncCallback.StringCallback cb,
ServerName destination)
Set region as OFFLINED up in zookeeper asynchronously.
|
(package private) static boolean |
RegionStates.isOneOfStates(RegionState regionState,
RegionState.State... states) |
private RegionState |
RegionStates.putRegionState(RegionState regionState) |
private void |
AssignmentManager.retrySendRegionClose(RegionState regionState)
At master failover, for pending_close region, make sure
sendRegionClose RPC call is sent to the target regionserver
|
private void |
AssignmentManager.retrySendRegionOpen(RegionState regionState)
At master failover, for pending_open region, make sure
sendRegionOpen RPC call is sent to the target regionserver
|
private int |
AssignmentManager.setOfflineInZooKeeper(RegionState state,
ServerName destination)
Set region as OFFLINED up in zookeeper
|
private boolean |
RegionStateStore.shouldPersistStateChange(HRegionInfo hri,
RegionState state,
RegionState oldState)
Check if we should persist a state change in meta.
|
RegionState |
RegionStates.transitionOpenFromPendingOpenOrOpeningOnServer(RegionTransition transition,
RegionState fromState,
ServerName sn)
Transition a region state to OPEN from OPENING/PENDING_OPEN
|
private void |
AssignmentManager.unassign(HRegionInfo region,
RegionState state,
int versionOfClosingNode,
ServerName dest,
boolean transitionInZK,
ServerName src)
Send CLOSE RPC if the server is online, otherwise, offline the region.
|
(package private) void |
RegionStateStore.updateRegionState(long openSeqNum,
RegionState newState,
RegionState oldState) |
| Modifier and Type | Method and Description |
|---|---|
static RegionState |
MetaTableLocator.getMetaRegionState(ZooKeeperWatcher zkw)
Load the meta region state from the meta server ZNode.
|
static RegionState |
MetaTableLocator.getMetaRegionState(ZooKeeperWatcher zkw,
int replicaId)
Load the meta region state from the meta server ZNode.
|
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.