public static class TestRSGroups.CPMasterObserver
extends java.lang.Object
Constructor and Description |
---|
CPMasterObserver() |
Modifier and Type | Method and Description |
---|---|
java.util.Optional<MasterObserver> |
getMasterObserver() |
void |
postAddRSGroup(<any> ctx,
java.lang.String name) |
void |
postBalanceRSGroup(<any> ctx,
java.lang.String groupName,
boolean balancerRan) |
void |
postMoveServers(<any> ctx,
java.util.Set<Address> servers,
java.lang.String targetGroup) |
void |
postMoveServersAndTables(<any> ctx,
java.util.Set<Address> servers,
java.util.Set<TableName> tables,
java.lang.String targetGroup) |
void |
postMoveTables(<any> ctx,
java.util.Set<TableName> tables,
java.lang.String targetGroup) |
void |
postRemoveRSGroup(<any> ctx,
java.lang.String name) |
void |
postRemoveServers(<any> ctx,
java.util.Set<Address> servers) |
void |
preAddRSGroup(<any> ctx,
java.lang.String name) |
void |
preBalanceRSGroup(<any> ctx,
java.lang.String groupName) |
void |
preMoveServers(<any> ctx,
java.util.Set<Address> servers,
java.lang.String targetGroup) |
void |
preMoveServersAndTables(<any> ctx,
java.util.Set<Address> servers,
java.util.Set<TableName> tables,
java.lang.String targetGroup) |
void |
preMoveTables(<any> ctx,
java.util.Set<TableName> tables,
java.lang.String targetGroup) |
void |
preRemoveRSGroup(<any> ctx,
java.lang.String name) |
void |
preRemoveServers(<any> ctx,
java.util.Set<Address> servers) |
public java.util.Optional<MasterObserver> getMasterObserver()
public void preMoveServersAndTables(<any> ctx, java.util.Set<Address> servers, java.util.Set<TableName> tables, java.lang.String targetGroup) throws java.io.IOException
java.io.IOException
public void postMoveServersAndTables(<any> ctx, java.util.Set<Address> servers, java.util.Set<TableName> tables, java.lang.String targetGroup) throws java.io.IOException
java.io.IOException
public void preRemoveServers(<any> ctx, java.util.Set<Address> servers) throws java.io.IOException
java.io.IOException
public void postRemoveServers(<any> ctx, java.util.Set<Address> servers) throws java.io.IOException
java.io.IOException
public void preRemoveRSGroup(<any> ctx, java.lang.String name) throws java.io.IOException
java.io.IOException
public void postRemoveRSGroup(<any> ctx, java.lang.String name) throws java.io.IOException
java.io.IOException
public void preAddRSGroup(<any> ctx, java.lang.String name) throws java.io.IOException
java.io.IOException
public void postAddRSGroup(<any> ctx, java.lang.String name) throws java.io.IOException
java.io.IOException
public void preMoveTables(<any> ctx, java.util.Set<TableName> tables, java.lang.String targetGroup) throws java.io.IOException
java.io.IOException
public void postMoveTables(<any> ctx, java.util.Set<TableName> tables, java.lang.String targetGroup) throws java.io.IOException
java.io.IOException
public void preMoveServers(<any> ctx, java.util.Set<Address> servers, java.lang.String targetGroup) throws java.io.IOException
java.io.IOException
public void postMoveServers(<any> ctx, java.util.Set<Address> servers, java.lang.String targetGroup) throws java.io.IOException
java.io.IOException
public void preBalanceRSGroup(<any> ctx, java.lang.String groupName) throws java.io.IOException
java.io.IOException
public void postBalanceRSGroup(<any> ctx, java.lang.String groupName, boolean balancerRan) throws java.io.IOException
java.io.IOException