|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.accumulo.server.master.balancer.TabletBalancer
public abstract class TabletBalancer
Field Summary | |
---|---|
protected ServerConfiguration |
configuration
|
Constructor Summary | |
---|---|
TabletBalancer()
|
Method Summary | |
---|---|
abstract long |
balance(SortedMap<TServerInstance,TabletServerStatus> current,
Set<KeyExtent> migrations,
List<TabletMigration> migrationsOut)
Ask the balancer if any migrations are necessary. |
static List<TabletMigration> |
checkMigrationSanity(Set<TServerInstance> current,
List<TabletMigration> migrations)
Utility to ensure that the migrations from balance() are consistent: Tablet objects are not null Source and destination tablet servers are not null and current |
abstract void |
getAssignments(SortedMap<TServerInstance,TabletServerStatus> current,
Map<KeyExtent,TServerInstance> unassigned,
Map<KeyExtent,TServerInstance> assignments)
Assign tablets to tablet servers. |
List<TabletStats> |
getOnlineTabletsForTable(TServerInstance tserver,
String tableId)
Fetch the tablets for the given table by asking the tablet server. |
void |
init(ServerConfiguration conf)
Initialize the TabletBalancer. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected ServerConfiguration configuration
Constructor Detail |
---|
public TabletBalancer()
Method Detail |
---|
public void init(ServerConfiguration conf)
public abstract void getAssignments(SortedMap<TServerInstance,TabletServerStatus> current, Map<KeyExtent,TServerInstance> unassigned, Map<KeyExtent,TServerInstance> assignments)
current
- The current table-summary state of all the online tablet servers. Read-only. The TabletServerStatus for each server may be null if the tablet
server has not yet responded to a recent request for status.unassigned
- A map from unassigned tablet to the last known tablet server. Read-only.assignments
- A map from tablet to assigned server. Write-only.public abstract long balance(SortedMap<TServerInstance,TabletServerStatus> current, Set<KeyExtent> migrations, List<TabletMigration> migrationsOut)
current
- The current table-summary state of all the online tablet servers. Read-only.migrations
- the current set of migrations. Read-only.migrationsOut
- new migrations to perform; should not contain tablets in the current set of migrations. Write-only.
public List<TabletStats> getOnlineTabletsForTable(TServerInstance tserver, String tableId) throws ThriftSecurityException, org.apache.thrift.TException
tserver
- The tablet server to ask.tableId
- The table id
ThriftSecurityException
- tablet server disapproves of your internal System password.
org.apache.thrift.TException
- any other problempublic static List<TabletMigration> checkMigrationSanity(Set<TServerInstance> current, List<TabletMigration> migrations)
current
- migrations
-
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |