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

Class AssignmentManagerUtil

java.lang.Object

org.apache.hadoop.hbase.master.assignment.AssignmentManagerUtil

@Private
final class AssignmentManagerUtil
extends Object

Utility for this assignment package only.

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	DEFAULT_REGION_REPLICA
private static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Modifier	Constructor	Description
private	AssignmentManagerUtil()

Method Summary

Modifier and Type	Method	Description
(package private) static void	checkClosedRegion(MasterProcedureEnv env, RegionInfo regionInfo)
private static TransitRegionStateProcedure[]	createAssignProcedures(MasterProcedureEnv env, List<RegionInfo> regions, int regionReplication, ServerName targetServer, boolean ignoreIfInTransition)	Create assign procedures for the give regions, according to the regionReplication.
(package private) static TransitRegionStateProcedure[]	createAssignProceduresForOpeningNewRegions(MasterProcedureEnv env, List<RegionInfo> regions, int regionReplication, ServerName targetServer)
(package private) static TransitRegionStateProcedure[]	createAssignProceduresForSplitDaughters(MasterProcedureEnv env, List<RegionInfo> daughters, int regionReplication, ServerName parentServer)
private static TransitRegionStateProcedure[]	createRoundRobinAssignProcedures(MasterProcedureEnv env, List<RegionInfo> regions, int regionReplication, List<ServerName> serversToExclude, boolean ignoreIfInTransition)	Create round robin assign procedures for the given regions, according to the regionReplication.
(package private) static TransitRegionStateProcedure[]	createUnassignProceduresForSplitOrMerge(MasterProcedureEnv env, Stream<RegionInfo> regions, int regionReplication)
private static boolean	dropStaleEditsUnder(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path regionDir, long durableSeqId, RegionInfo regionInfo)
(package private) static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoResponse	getRegionInfoResponse(MasterProcedureEnv env, ServerName regionLocation, RegionInfo hri)	Raw call to remote regionserver to get info on a particular region.
(package private) static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoResponse	getRegionInfoResponse(MasterProcedureEnv env, ServerName regionLocation, RegionInfo hri, boolean includeBestSplitRow)
(package private) static boolean	isSplitOrMerged(RegionStateNode regionStateNode)	For splitting, need to test both region info and state, and will return true if either of the test returns true.
private static void	lock(List<RegionStateNode> regionNodes)
(package private) static void	removeNonDefaultReplicas(MasterProcedureEnv env, Stream<RegionInfo> regions, int regionReplication)
(package private) static void	reopenRegionsForRollback(MasterProcedureEnv env, List<RegionInfo> regions, int regionReplication, ServerName targetServer)
private static boolean	tryDropStaleRecoveredEdits(MasterProcedureEnv env, RegionInfo regionInfo)	Try to remove recovered.edits files that are provably below the region's last flushed seqid.
private static void	unlock(List<RegionStateNode> regionNodes)

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

DEFAULT_REGION_REPLICA

private static final int DEFAULT_REGION_REPLICA

See Also:

• Constant Field Values

Constructor Details

AssignmentManagerUtil

private AssignmentManagerUtil()

Method Details

getRegionInfoResponse

static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoResponse getRegionInfoResponse(MasterProcedureEnv env,
 ServerName regionLocation,
 RegionInfo hri)
                                                                                                          throws IOException

Raw call to remote regionserver to get info on a particular region.

Throws:

IOException - Let it out so can report this IOE as reason for failure

getRegionInfoResponse

static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoResponse getRegionInfoResponse(MasterProcedureEnv env,
 ServerName regionLocation,
 RegionInfo hri,
 boolean includeBestSplitRow)
                                                                                                          throws IOException

Throws:

IOException

lock

private static void lock(List<RegionStateNode> regionNodes)

unlock

private static void unlock(List<RegionStateNode> regionNodes)

createUnassignProceduresForSplitOrMerge

static TransitRegionStateProcedure[] createUnassignProceduresForSplitOrMerge(MasterProcedureEnv env,
 Stream<RegionInfo> regions,
 int regionReplication)
                                                                      throws IOException

Throws:

IOException

createAssignProcedures

private static TransitRegionStateProcedure[] createAssignProcedures(MasterProcedureEnv env,
 List<RegionInfo> regions,
 int regionReplication,
 ServerName targetServer,
 boolean ignoreIfInTransition)

Create assign procedures for the give regions, according to the regionReplication.

For rolling back, we will submit procedures directly to the ProcedureExecutor, so it is possible that we persist the newly scheduled procedures, and then crash before persisting the rollback state, so when we arrive here the second time, it is possible that some regions have already been associated with a TRSP.

Parameters:

ignoreIfInTransition - if true, will skip creating TRSP for the given region if it is already in transition, otherwise we will add an assert that it should not in transition.

createRoundRobinAssignProcedures

private static TransitRegionStateProcedure[] createRoundRobinAssignProcedures(MasterProcedureEnv env,
 List<RegionInfo> regions,
 int regionReplication,
 List<ServerName> serversToExclude,
 boolean ignoreIfInTransition)

Create round robin assign procedures for the given regions, according to the regionReplication.

For rolling back, we will submit procedures directly to the ProcedureExecutor, so it is possible that we persist the newly scheduled procedures, and then crash before persisting the rollback state, so when we arrive here the second time, it is possible that some regions have already been associated with a TRSP.

Parameters:

ignoreIfInTransition - if true, will skip creating TRSP for the given region if it is already in transition, otherwise we will add an assert that it should not in transition.

createAssignProceduresForSplitDaughters

static TransitRegionStateProcedure[] createAssignProceduresForSplitDaughters(MasterProcedureEnv env,
 List<RegionInfo> daughters,
 int regionReplication,
 ServerName parentServer)

createAssignProceduresForOpeningNewRegions

static TransitRegionStateProcedure[] createAssignProceduresForOpeningNewRegions(MasterProcedureEnv env,
 List<RegionInfo> regions,
 int regionReplication,
 ServerName targetServer)

reopenRegionsForRollback

static void reopenRegionsForRollback(MasterProcedureEnv env,
 List<RegionInfo> regions,
 int regionReplication,
 ServerName targetServer)

removeNonDefaultReplicas

static void removeNonDefaultReplicas(MasterProcedureEnv env,
 Stream<RegionInfo> regions,
 int regionReplication)

checkClosedRegion

static void checkClosedRegion(MasterProcedureEnv env,
 RegionInfo regionInfo)
                       throws IOException

Throws:

IOException

tryDropStaleRecoveredEdits

private static boolean tryDropStaleRecoveredEdits(MasterProcedureEnv env,
 RegionInfo regionInfo)

Try to remove recovered.edits files that are provably below the region's last flushed seqid.

Returns:

true if, after cleanup, no recovered.edits remain for the region

dropStaleEditsUnder

private static boolean dropStaleEditsUnder(org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.fs.Path regionDir,
 long durableSeqId,
 RegionInfo regionInfo)
                                    throws IOException

Throws:

IOException

isSplitOrMerged

static boolean isSplitOrMerged(RegionStateNode regionStateNode)

For splitting, need to test both region info and state, and will return true if either of the test returns true. Please see the comments in AssignmentManager.markRegionAsSplit(RegionInfo, ServerName, RegionInfo, RegionInfo) for more details on why we need to test two conditions.