Package org.apache.hadoop.hbase.master.assignment

Class RegionInTransitionTracker

java.lang.Object

org.apache.hadoop.hbase.master.assignment.RegionInTransitionTracker

@Private
public class RegionInTransitionTracker
extends Object

Tracks regions that are currently in transition (RIT) - those not yet in their terminal state.

Field Summary

Fields

Modifier and Type	Field	Description
private final List<RegionState.State>	DISABLE_TABLE_REGION_STATE
private final List<RegionState.State>	ENABLE_TABLE_REGION_STATE
private static final org.slf4j.Logger	LOG
private final ConcurrentSkipListMap<RegionInfo,RegionStateNode>	regionInTransition
private TableStateManager	tableStateManager

Constructor Summary

Constructors

Constructor	Description
RegionInTransitionTracker()

Method Summary

Modifier and Type	Method	Description
private boolean	addRegionInTransition(RegionStateNode regionStateNode)
List<RegionStateNode>	getRegionsInTransition()
void	handleRegionDelete(RegionInfo regionInfo)	Handles the deletion of a region by removing it from RIT tracking.
void	handleRegionStateNodeOperation(RegionStateNode regionStateNode)	Processes a region state change and updates the RIT tracking accordingly.
boolean	hasRegionsInTransition()
boolean	isRegionInTransition(RegionInfo regionInfo)
private boolean	isTableEnabled(TableName tableName)
void	regionCrashed(RegionStateNode regionStateNode)	Handles a region whose hosting RegionServer has crashed.
private boolean	removeRegionInTransition(RegionInfo regionInfo)
void	setTableStateManager(TableStateManager tableStateManager)
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

DISABLE_TABLE_REGION_STATE

private final List<RegionState.State> DISABLE_TABLE_REGION_STATE

ENABLE_TABLE_REGION_STATE

private final List<RegionState.State> ENABLE_TABLE_REGION_STATE

regionInTransition

private final ConcurrentSkipListMap<RegionInfo,RegionStateNode> regionInTransition

tableStateManager

private TableStateManager tableStateManager

Constructor Details

RegionInTransitionTracker

public RegionInTransitionTracker()

Method Details

isRegionInTransition

public boolean isRegionInTransition(RegionInfo regionInfo)

regionCrashed

public void regionCrashed(RegionStateNode regionStateNode)

Handles a region whose hosting RegionServer has crashed. When a RegionServer fails, all regions it was hosting are automatically added to the RIT list since they need to be reassigned to other servers.

handleRegionStateNodeOperation

public void handleRegionStateNodeOperation(RegionStateNode regionStateNode)

Processes a region state change and updates the RIT tracking accordingly. This is the core method that determines whether a region should be added to or removed from the RIT list based on its current state and the table's enabled/disabled status. This method should be called whenever a region state changes get stored to hbase:meta Note: Only default replicas (replica ID 0) are tracked. Read replicas are ignored.

Parameters:

regionStateNode - the region state node with the current state information

isTableEnabled

private boolean isTableEnabled(TableName tableName)

handleRegionDelete

public void handleRegionDelete(RegionInfo regionInfo)

Handles the deletion of a region by removing it from RIT tracking. This is called when a region is permanently removed from the cluster, typically after a successful merge operation where the parent regions are cleaned up. During table deletion, table should be already disabled and all the region are already OFFLINE

Parameters:

regionInfo - the region being deleted

addRegionInTransition

private boolean addRegionInTransition(RegionStateNode regionStateNode)

removeRegionInTransition

private boolean removeRegionInTransition(RegionInfo regionInfo)

stop

public void stop()

hasRegionsInTransition

public boolean hasRegionsInTransition()

getRegionsInTransition

public List<RegionStateNode> getRegionsInTransition()

setTableStateManager

public void setTableStateManager(TableStateManager tableStateManager)