@InterfaceAudience.Private public class MasterCoprocessorHost extends CoprocessorHost<org.apache.hadoop.hbase.master.MasterCoprocessorHost.MasterEnvironment>
HMaster interacts with the loaded coprocessors
through this class.CoprocessorHost.EnvironmentABORT_ON_ERROR_KEY, abortable, conf, coprocessors, COPROCESSORS_ENABLED_CONF_KEY, DEFAULT_ABORT_ON_ERROR, DEFAULT_COPROCESSORS_ENABLED, DEFAULT_USER_COPROCESSORS_ENABLED, loadSequence, MASTER_COPROCESSOR_CONF_KEY, pathPrefix, REGION_COPROCESSOR_CONF_KEY, REGIONSERVER_COPROCESSOR_CONF_KEY, USER_COPROCESSORS_ENABLED_CONF_KEY, USER_REGION_COPROCESSOR_CONF_KEY, WAL_COPROCESSOR_CONF_KEY| Constructor and Description |
|---|
MasterCoprocessorHost(MasterServices services,
Configuration conf) |
abortServer, abortServer, findCoprocessor, findCoprocessorEnvironment, findCoprocessors, getCoprocessors, getLoadedCoprocessors, handleCoprocessorThrowable, legacyWarning, load, load, loadInstance, loadSystemCoprocessors, shutdown, useLegacyMethodpublic MasterCoprocessorHost(MasterServices services, Configuration conf)
public org.apache.hadoop.hbase.master.MasterCoprocessorHost.MasterEnvironment createEnvironment(java.lang.Class<?> implClass,
Coprocessor instance,
int priority,
int seq,
Configuration conf)
CoprocessorHostcreateEnvironment in class CoprocessorHost<org.apache.hadoop.hbase.master.MasterCoprocessorHost.MasterEnvironment>public boolean preCreateNamespace(NamespaceDescriptor ns) throws java.io.IOException
java.io.IOExceptionpublic void postCreateNamespace(NamespaceDescriptor ns) throws java.io.IOException
java.io.IOExceptionpublic boolean preDeleteNamespace(java.lang.String namespaceName)
throws java.io.IOException
java.io.IOExceptionpublic void postDeleteNamespace(java.lang.String namespaceName)
throws java.io.IOException
java.io.IOExceptionpublic boolean preModifyNamespace(NamespaceDescriptor ns) throws java.io.IOException
java.io.IOExceptionpublic void postModifyNamespace(NamespaceDescriptor ns) throws java.io.IOException
java.io.IOExceptionpublic void preGetNamespaceDescriptor(java.lang.String namespaceName)
throws java.io.IOException
java.io.IOExceptionpublic void postGetNamespaceDescriptor(NamespaceDescriptor ns) throws java.io.IOException
java.io.IOExceptionpublic boolean preListNamespaceDescriptors(java.util.List<NamespaceDescriptor> descriptors) throws java.io.IOException
java.io.IOExceptionpublic void postListNamespaceDescriptors(java.util.List<NamespaceDescriptor> descriptors) throws java.io.IOException
java.io.IOExceptionpublic void preCreateTable(HTableDescriptor htd, HRegionInfo[] regions) throws java.io.IOException
java.io.IOExceptionpublic void postCreateTable(HTableDescriptor htd, HRegionInfo[] regions) throws java.io.IOException
java.io.IOExceptionpublic void preCreateTableHandler(HTableDescriptor htd, HRegionInfo[] regions) throws java.io.IOException
java.io.IOExceptionpublic void postCreateTableHandler(HTableDescriptor htd, HRegionInfo[] regions) throws java.io.IOException
java.io.IOExceptionpublic void preDeleteTable(TableName tableName) throws java.io.IOException
java.io.IOExceptionpublic void postDeleteTable(TableName tableName) throws java.io.IOException
java.io.IOExceptionpublic void preDeleteTableHandler(TableName tableName) throws java.io.IOException
java.io.IOExceptionpublic void postDeleteTableHandler(TableName tableName) throws java.io.IOException
java.io.IOExceptionpublic void preTruncateTable(TableName tableName) throws java.io.IOException
java.io.IOExceptionpublic void postTruncateTable(TableName tableName) throws java.io.IOException
java.io.IOExceptionpublic void preTruncateTableHandler(TableName tableName) throws java.io.IOException
java.io.IOExceptionpublic void postTruncateTableHandler(TableName tableName) throws java.io.IOException
java.io.IOExceptionpublic void preModifyTable(TableName tableName, HTableDescriptor htd) throws java.io.IOException
java.io.IOExceptionpublic void postModifyTable(TableName tableName, HTableDescriptor htd) throws java.io.IOException
java.io.IOExceptionpublic void preModifyTableHandler(TableName tableName, HTableDescriptor htd) throws java.io.IOException
java.io.IOExceptionpublic void postModifyTableHandler(TableName tableName, HTableDescriptor htd) throws java.io.IOException
java.io.IOExceptionpublic boolean preAddColumn(TableName tableName, HColumnDescriptor column) throws java.io.IOException
java.io.IOExceptionpublic void postAddColumn(TableName tableName, HColumnDescriptor column) throws java.io.IOException
java.io.IOExceptionpublic boolean preAddColumnHandler(TableName tableName, HColumnDescriptor column) throws java.io.IOException
java.io.IOExceptionpublic void postAddColumnHandler(TableName tableName, HColumnDescriptor column) throws java.io.IOException
java.io.IOExceptionpublic boolean preModifyColumn(TableName tableName, HColumnDescriptor descriptor) throws java.io.IOException
java.io.IOExceptionpublic void postModifyColumn(TableName tableName, HColumnDescriptor descriptor) throws java.io.IOException
java.io.IOExceptionpublic boolean preModifyColumnHandler(TableName tableName, HColumnDescriptor descriptor) throws java.io.IOException
java.io.IOExceptionpublic void postModifyColumnHandler(TableName tableName, HColumnDescriptor descriptor) throws java.io.IOException
java.io.IOExceptionpublic boolean preDeleteColumn(TableName tableName, byte[] c) throws java.io.IOException
java.io.IOExceptionpublic void postDeleteColumn(TableName tableName, byte[] c) throws java.io.IOException
java.io.IOExceptionpublic boolean preDeleteColumnHandler(TableName tableName, byte[] c) throws java.io.IOException
java.io.IOExceptionpublic void postDeleteColumnHandler(TableName tableName, byte[] c) throws java.io.IOException
java.io.IOExceptionpublic void preEnableTable(TableName tableName) throws java.io.IOException
java.io.IOExceptionpublic void postEnableTable(TableName tableName) throws java.io.IOException
java.io.IOExceptionpublic void preEnableTableHandler(TableName tableName) throws java.io.IOException
java.io.IOExceptionpublic void postEnableTableHandler(TableName tableName) throws java.io.IOException
java.io.IOExceptionpublic void preDisableTable(TableName tableName) throws java.io.IOException
java.io.IOExceptionpublic void postDisableTable(TableName tableName) throws java.io.IOException
java.io.IOExceptionpublic void preDisableTableHandler(TableName tableName) throws java.io.IOException
java.io.IOExceptionpublic void postDisableTableHandler(TableName tableName) throws java.io.IOException
java.io.IOExceptionpublic boolean preAbortProcedure(ProcedureExecutor<MasterProcedureEnv> procEnv, long procId) throws java.io.IOException
java.io.IOExceptionpublic void postAbortProcedure()
throws java.io.IOException
java.io.IOExceptionpublic boolean preListProcedures()
throws java.io.IOException
java.io.IOExceptionpublic void postListProcedures(java.util.List<ProcedureInfo> procInfoList) throws java.io.IOException
java.io.IOExceptionpublic boolean preMove(HRegionInfo region, ServerName srcServer, ServerName destServer) throws java.io.IOException
java.io.IOExceptionpublic void postMove(HRegionInfo region, ServerName srcServer, ServerName destServer) throws java.io.IOException
java.io.IOExceptionpublic boolean preAssign(HRegionInfo regionInfo) throws java.io.IOException
java.io.IOExceptionpublic void postAssign(HRegionInfo regionInfo) throws java.io.IOException
java.io.IOExceptionpublic boolean preUnassign(HRegionInfo regionInfo, boolean force) throws java.io.IOException
java.io.IOExceptionpublic void postUnassign(HRegionInfo regionInfo, boolean force) throws java.io.IOException
java.io.IOExceptionpublic void preRegionOffline(HRegionInfo regionInfo) throws java.io.IOException
java.io.IOExceptionpublic void postRegionOffline(HRegionInfo regionInfo) throws java.io.IOException
java.io.IOExceptionpublic boolean preBalance()
throws java.io.IOException
java.io.IOExceptionpublic void postBalance(java.util.List<RegionPlan> plans) throws java.io.IOException
java.io.IOExceptionpublic boolean preBalanceSwitch(boolean b)
throws java.io.IOException
java.io.IOExceptionpublic void postBalanceSwitch(boolean oldValue,
boolean newValue)
throws java.io.IOException
java.io.IOExceptionpublic void preShutdown()
throws java.io.IOException
java.io.IOExceptionpublic void preStopMaster()
throws java.io.IOException
java.io.IOExceptionpublic void preMasterInitialization()
throws java.io.IOException
java.io.IOExceptionpublic void postStartMaster()
throws java.io.IOException
java.io.IOExceptionpublic void preSnapshot(HBaseProtos.SnapshotDescription snapshot, HTableDescriptor hTableDescriptor) throws java.io.IOException
java.io.IOExceptionpublic void postSnapshot(HBaseProtos.SnapshotDescription snapshot, HTableDescriptor hTableDescriptor) throws java.io.IOException
java.io.IOExceptionpublic void preListSnapshot(HBaseProtos.SnapshotDescription snapshot) throws java.io.IOException
java.io.IOExceptionpublic void postListSnapshot(HBaseProtos.SnapshotDescription snapshot) throws java.io.IOException
java.io.IOExceptionpublic void preCloneSnapshot(HBaseProtos.SnapshotDescription snapshot, HTableDescriptor hTableDescriptor) throws java.io.IOException
java.io.IOExceptionpublic void postCloneSnapshot(HBaseProtos.SnapshotDescription snapshot, HTableDescriptor hTableDescriptor) throws java.io.IOException
java.io.IOExceptionpublic void preRestoreSnapshot(HBaseProtos.SnapshotDescription snapshot, HTableDescriptor hTableDescriptor) throws java.io.IOException
java.io.IOExceptionpublic void postRestoreSnapshot(HBaseProtos.SnapshotDescription snapshot, HTableDescriptor hTableDescriptor) throws java.io.IOException
java.io.IOExceptionpublic void preDeleteSnapshot(HBaseProtos.SnapshotDescription snapshot) throws java.io.IOException
java.io.IOExceptionpublic void postDeleteSnapshot(HBaseProtos.SnapshotDescription snapshot) throws java.io.IOException
java.io.IOException@Deprecated public boolean preGetTableDescriptors(java.util.List<TableName> tableNamesList, java.util.List<HTableDescriptor> descriptors) throws java.io.IOException
java.io.IOException@Deprecated public void postGetTableDescriptors(java.util.List<HTableDescriptor> descriptors) throws java.io.IOException
java.io.IOExceptionpublic boolean preGetTableDescriptors(java.util.List<TableName> tableNamesList, java.util.List<HTableDescriptor> descriptors, java.lang.String regex) throws java.io.IOException
java.io.IOExceptionpublic void postGetTableDescriptors(java.util.List<TableName> tableNamesList, java.util.List<HTableDescriptor> descriptors, java.lang.String regex) throws java.io.IOException
java.io.IOExceptionpublic boolean preGetTableNames(java.util.List<HTableDescriptor> descriptors, java.lang.String regex) throws java.io.IOException
java.io.IOExceptionpublic void postGetTableNames(java.util.List<HTableDescriptor> descriptors, java.lang.String regex) throws java.io.IOException
java.io.IOExceptionpublic void preTableFlush(TableName tableName) throws java.io.IOException
java.io.IOExceptionpublic void postTableFlush(TableName tableName) throws java.io.IOException
java.io.IOExceptionpublic void preSetUserQuota(java.lang.String user,
QuotaProtos.Quotas quotas)
throws java.io.IOException
java.io.IOExceptionpublic void postSetUserQuota(java.lang.String user,
QuotaProtos.Quotas quotas)
throws java.io.IOException
java.io.IOExceptionpublic void preSetUserQuota(java.lang.String user,
TableName table,
QuotaProtos.Quotas quotas)
throws java.io.IOException
java.io.IOExceptionpublic void postSetUserQuota(java.lang.String user,
TableName table,
QuotaProtos.Quotas quotas)
throws java.io.IOException
java.io.IOExceptionpublic void preSetUserQuota(java.lang.String user,
java.lang.String namespace,
QuotaProtos.Quotas quotas)
throws java.io.IOException
java.io.IOExceptionpublic void postSetUserQuota(java.lang.String user,
java.lang.String namespace,
QuotaProtos.Quotas quotas)
throws java.io.IOException
java.io.IOExceptionpublic void preSetTableQuota(TableName table, QuotaProtos.Quotas quotas) throws java.io.IOException
java.io.IOExceptionpublic void postSetTableQuota(TableName table, QuotaProtos.Quotas quotas) throws java.io.IOException
java.io.IOExceptionpublic void preSetNamespaceQuota(java.lang.String namespace,
QuotaProtos.Quotas quotas)
throws java.io.IOException
java.io.IOExceptionpublic void postSetNamespaceQuota(java.lang.String namespace,
QuotaProtos.Quotas quotas)
throws java.io.IOException
java.io.IOExceptionpublic void preMoveServers(java.util.Set<HostAndPort> servers,
java.lang.String targetGroup)
throws java.io.IOException
java.io.IOExceptionpublic void postMoveServers(java.util.Set<HostAndPort> servers,
java.lang.String targetGroup)
throws java.io.IOException
java.io.IOExceptionpublic void preMoveTables(java.util.Set<TableName> tables, java.lang.String targetGroup) throws java.io.IOException
java.io.IOExceptionpublic void postMoveTables(java.util.Set<TableName> tables, java.lang.String targetGroup) throws java.io.IOException
java.io.IOExceptionpublic void preAddRSGroup(java.lang.String name)
throws java.io.IOException
java.io.IOExceptionpublic void postAddRSGroup(java.lang.String name)
throws java.io.IOException
java.io.IOExceptionpublic void preRemoveRSGroup(java.lang.String name)
throws java.io.IOException
java.io.IOExceptionpublic void postRemoveRSGroup(java.lang.String name)
throws java.io.IOException
java.io.IOExceptionpublic void preBalanceRSGroup(java.lang.String name)
throws java.io.IOException
java.io.IOExceptionpublic void postBalanceRSGroup(java.lang.String name,
boolean balanceRan)
throws java.io.IOException
java.io.IOException