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.IOExceptionpublic void postMoveServersAndTables(<any> ctx,
java.util.Set<Address> servers,
java.util.Set<TableName> tables,
java.lang.String targetGroup)
throws java.io.IOException
java.io.IOExceptionpublic void preRemoveServers(<any> ctx,
java.util.Set<Address> servers)
throws java.io.IOException
java.io.IOExceptionpublic void postRemoveServers(<any> ctx,
java.util.Set<Address> servers)
throws java.io.IOException
java.io.IOExceptionpublic void preRemoveRSGroup(<any> ctx,
java.lang.String name)
throws java.io.IOException
java.io.IOExceptionpublic void postRemoveRSGroup(<any> ctx,
java.lang.String name)
throws java.io.IOException
java.io.IOExceptionpublic void preAddRSGroup(<any> ctx,
java.lang.String name)
throws java.io.IOException
java.io.IOExceptionpublic void postAddRSGroup(<any> ctx,
java.lang.String name)
throws java.io.IOException
java.io.IOExceptionpublic void preMoveTables(<any> ctx,
java.util.Set<TableName> tables,
java.lang.String targetGroup)
throws java.io.IOException
java.io.IOExceptionpublic void postMoveTables(<any> ctx,
java.util.Set<TableName> tables,
java.lang.String targetGroup)
throws java.io.IOException
java.io.IOExceptionpublic void preMoveServers(<any> ctx,
java.util.Set<Address> servers,
java.lang.String targetGroup)
throws java.io.IOException
java.io.IOExceptionpublic void postMoveServers(<any> ctx,
java.util.Set<Address> servers,
java.lang.String targetGroup)
throws java.io.IOException
java.io.IOExceptionpublic void preBalanceRSGroup(<any> ctx,
java.lang.String groupName)
throws java.io.IOException
java.io.IOExceptionpublic void postBalanceRSGroup(<any> ctx,
java.lang.String groupName,
boolean balancerRan)
throws java.io.IOException
java.io.IOException