Package | Description |
---|---|
org.apache.hadoop.hbase.master.assignment |
Modifier and Type | Field and Description |
---|---|
private TransitRegionStateProcedure |
RegionStateNode.procedure |
Modifier and Type | Method and Description |
---|---|
static TransitRegionStateProcedure |
TransitRegionStateProcedure.assign(MasterProcedureEnv env,
RegionInfo region,
boolean forceNewPlan,
ServerName targetServer) |
static TransitRegionStateProcedure |
TransitRegionStateProcedure.assign(MasterProcedureEnv env,
RegionInfo region,
ServerName targetServer) |
private TransitRegionStateProcedure |
AssignmentManager.createAssignProcedure(RegionInfo regionInfo,
ServerName sn,
boolean override)
Create an assign TransitRegionStateProcedure.
|
private TransitRegionStateProcedure |
AssignmentManager.createAssignProcedure(RegionStateNode regionNode,
ServerName targetServer)
Create an assign TransitRegionStateProcedure.
|
TransitRegionStateProcedure[] |
AssignmentManager.createAssignProcedures(List<RegionInfo> hris)
Create an array of TransitRegionStateProcedure w/o specifying a target server.
|
private TransitRegionStateProcedure[] |
AssignmentManager.createAssignProcedures(Map<ServerName,List<RegionInfo>> assignments)
Tied to
AssignmentManager.createAssignProcedures(List) in that it is called if caller is unable to run
this method. |
private TransitRegionStateProcedure[] |
SplitTableRegionProcedure.createAssignProcedures(MasterProcedureEnv env) |
private TransitRegionStateProcedure[] |
MergeTableRegionsProcedure.createAssignProcedures(MasterProcedureEnv env) |
private static TransitRegionStateProcedure[] |
AssignmentManagerUtil.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[] |
AssignmentManagerUtil.createAssignProceduresForOpeningNewRegions(MasterProcedureEnv env,
List<RegionInfo> regions,
int regionReplication,
ServerName targetServer) |
(package private) static TransitRegionStateProcedure[] |
AssignmentManagerUtil.createAssignProceduresForSplitDaughters(MasterProcedureEnv env,
List<RegionInfo> daughters,
int regionReplication,
ServerName parentServer) |
TransitRegionStateProcedure |
AssignmentManager.createMoveRegionProcedure(RegionInfo regionInfo,
ServerName targetServer) |
TransitRegionStateProcedure |
AssignmentManager.createOneAssignProcedure(RegionInfo ri,
boolean override)
Create one TransitRegionStateProcedure to assign a region w/o specifying a target server.
|
TransitRegionStateProcedure |
AssignmentManager.createOneUnassignProcedure(RegionInfo ri,
boolean override)
Create one TransitRegionStateProcedure to unassign a region.
|
TransitRegionStateProcedure[] |
AssignmentManager.createRoundRobinAssignProcedures(List<RegionInfo> hris)
Create round-robin assigns.
|
TransitRegionStateProcedure[] |
AssignmentManager.createRoundRobinAssignProcedures(List<RegionInfo> hris,
List<ServerName> serversToExclude)
Create round-robin assigns.
|
private static TransitRegionStateProcedure[] |
AssignmentManagerUtil.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 . |
private TransitRegionStateProcedure[] |
SplitTableRegionProcedure.createUnassignProcedures(MasterProcedureEnv env) |
private TransitRegionStateProcedure[] |
MergeTableRegionsProcedure.createUnassignProcedures(MasterProcedureEnv env) |
TransitRegionStateProcedure[] |
AssignmentManager.createUnassignProceduresForClosingExcessRegionReplicas(TableName tableName,
int newReplicaCount)
Called by ModifyTableProcedures to unassign all the excess region replicas for a table.
|
TransitRegionStateProcedure[] |
AssignmentManager.createUnassignProceduresForDisabling(TableName tableName)
Called by DisableTableProcedure to unassign all the regions for a table.
|
(package private) static TransitRegionStateProcedure[] |
AssignmentManagerUtil.createUnassignProceduresForSplitOrMerge(MasterProcedureEnv env,
Stream<RegionInfo> regions,
int regionReplication) |
private TransitRegionStateProcedure |
AssignmentManager.forceCreateUnssignProcedure(RegionStateNode regionNode) |
private TransitRegionStateProcedure |
RegionRemoteProcedureBase.getParent(MasterProcedureEnv env) |
TransitRegionStateProcedure |
RegionStateNode.getProcedure() |
static TransitRegionStateProcedure |
TransitRegionStateProcedure.move(MasterProcedureEnv env,
RegionInfo region,
ServerName targetServer) |
static TransitRegionStateProcedure |
TransitRegionStateProcedure.reopen(MasterProcedureEnv env,
RegionInfo region) |
private static TransitRegionStateProcedure |
TransitRegionStateProcedure.setOwner(MasterProcedureEnv env,
TransitRegionStateProcedure proc) |
TransitRegionStateProcedure |
RegionStateNode.setProcedure(TransitRegionStateProcedure proc) |
static TransitRegionStateProcedure |
TransitRegionStateProcedure.unassign(MasterProcedureEnv env,
RegionInfo region) |
Modifier and Type | Method and Description |
---|---|
(package private) static int |
AssignmentManager.compare(TransitRegionStateProcedure left,
TransitRegionStateProcedure right) |
private static TransitRegionStateProcedure |
TransitRegionStateProcedure.setOwner(MasterProcedureEnv env,
TransitRegionStateProcedure proc) |
TransitRegionStateProcedure |
RegionStateNode.setProcedure(TransitRegionStateProcedure proc) |
void |
RegionStateNode.unsetProcedure(TransitRegionStateProcedure proc) |
Modifier and Type | Method and Description |
---|---|
void |
AssignmentManager.setupRIT(List<TransitRegionStateProcedure> procs)
Create RegionStateNode based on the TRSP list, and attach the TRSP to the RegionStateNode.
|
Constructor and Description |
---|
CloseRegionProcedure(TransitRegionStateProcedure parent,
RegionInfo region,
ServerName targetServer,
ServerName assignCandidate) |
OpenRegionProcedure(TransitRegionStateProcedure parent,
RegionInfo region,
ServerName targetServer) |
RegionRemoteProcedureBase(TransitRegionStateProcedure parent,
RegionInfo region,
ServerName targetServer) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.