org.apache.hadoop.hbase.master

Class MasterCoprocessorHost

java.lang.Object

org.apache.hadoop.hbase.coprocessor.CoprocessorHost<org.apache.hadoop.hbase.master.MasterCoprocessorHost.MasterEnvironment>

org.apache.hadoop.hbase.master.MasterCoprocessorHost

@InterfaceAudience.Private
public class MasterCoprocessorHost
extends CoprocessorHost<org.apache.hadoop.hbase.master.MasterCoprocessorHost.MasterEnvironment>

Provides the coprocessor framework and environment for master oriented operations. HMaster interacts with the loaded coprocessors through this class.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.coprocessor.CoprocessorHost

CoprocessorHost.Environment

Field Summary

Fields inherited from class org.apache.hadoop.hbase.coprocessor.CoprocessorHost

ABORT_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 Summary

Constructors

Constructor and Description
MasterCoprocessorHost(MasterServices services, Configuration conf)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.hbase.master.MasterCoprocessorHost.MasterEnvironment	createEnvironment(Class<?> implClass, Coprocessor instance, int priority, int seq, Configuration conf) Called when a new Coprocessor class is loaded
void	postAbortProcedure()
void	postAddColumn(TableName tableName, HColumnDescriptor column)
void	postAddColumnHandler(TableName tableName, HColumnDescriptor column)
void	postAddRSGroup(String name)
void	postAssign(HRegionInfo regionInfo)
void	postBalance(List<RegionPlan> plans)
void	postBalanceRSGroup(String name, boolean balanceRan)
void	postBalanceSwitch(boolean oldValue, boolean newValue)
void	postCloneSnapshot(HBaseProtos.SnapshotDescription snapshot, HTableDescriptor hTableDescriptor)
void	postCreateNamespace(NamespaceDescriptor ns)
void	postCreateTable(HTableDescriptor htd, HRegionInfo[] regions)
void	postCreateTableHandler(HTableDescriptor htd, HRegionInfo[] regions)
void	postDeleteColumn(TableName tableName, byte[] c)
void	postDeleteColumnHandler(TableName tableName, byte[] c)
void	postDeleteNamespace(String namespaceName)
void	postDeleteSnapshot(HBaseProtos.SnapshotDescription snapshot)
void	postDeleteTable(TableName tableName)
void	postDeleteTableHandler(TableName tableName)
void	postDisableTable(TableName tableName)
void	postDisableTableHandler(TableName tableName)
void	postEnableTable(TableName tableName)
void	postEnableTableHandler(TableName tableName)
void	postGetNamespaceDescriptor(NamespaceDescriptor ns)
void	postGetTableDescriptors(List<HTableDescriptor> descriptors) Deprecated.
void	postGetTableDescriptors(List<TableName> tableNamesList, List<HTableDescriptor> descriptors, String regex)
void	postGetTableNames(List<HTableDescriptor> descriptors, String regex)
void	postListNamespaceDescriptors(List<NamespaceDescriptor> descriptors)
void	postListProcedures(List<ProcedureInfo> procInfoList)
void	postListSnapshot(HBaseProtos.SnapshotDescription snapshot)
void	postModifyColumn(TableName tableName, HColumnDescriptor descriptor)
void	postModifyColumnHandler(TableName tableName, HColumnDescriptor descriptor)
void	postModifyNamespace(NamespaceDescriptor ns)
void	postModifyTable(TableName tableName, HTableDescriptor htd)
void	postModifyTableHandler(TableName tableName, HTableDescriptor htd)
void	postMove(HRegionInfo region, ServerName srcServer, ServerName destServer)
void	postMoveServers(Set<HostAndPort> servers, String targetGroup)
void	postMoveTables(Set<TableName> tables, String targetGroup)
void	postRegionOffline(HRegionInfo regionInfo)
void	postRemoveRSGroup(String name)
void	postRestoreSnapshot(HBaseProtos.SnapshotDescription snapshot, HTableDescriptor hTableDescriptor)
void	postSetNamespaceQuota(String namespace, QuotaProtos.Quotas quotas)
void	postSetTableQuota(TableName table, QuotaProtos.Quotas quotas)
void	postSetUserQuota(String user, QuotaProtos.Quotas quotas)
void	postSetUserQuota(String user, String namespace, QuotaProtos.Quotas quotas)
void	postSetUserQuota(String user, TableName table, QuotaProtos.Quotas quotas)
void	postSnapshot(HBaseProtos.SnapshotDescription snapshot, HTableDescriptor hTableDescriptor)
void	postStartMaster()
void	postTableFlush(TableName tableName)
void	postTruncateTable(TableName tableName)
void	postTruncateTableHandler(TableName tableName)
void	postUnassign(HRegionInfo regionInfo, boolean force)
boolean	preAbortProcedure(ProcedureExecutor<MasterProcedureEnv> procEnv, long procId)
boolean	preAddColumn(TableName tableName, HColumnDescriptor column)
boolean	preAddColumnHandler(TableName tableName, HColumnDescriptor column)
void	preAddRSGroup(String name)
boolean	preAssign(HRegionInfo regionInfo)
boolean	preBalance()
void	preBalanceRSGroup(String name)
boolean	preBalanceSwitch(boolean b)
void	preCloneSnapshot(HBaseProtos.SnapshotDescription snapshot, HTableDescriptor hTableDescriptor)
boolean	preCreateNamespace(NamespaceDescriptor ns)
void	preCreateTable(HTableDescriptor htd, HRegionInfo[] regions)
void	preCreateTableHandler(HTableDescriptor htd, HRegionInfo[] regions)
boolean	preDeleteColumn(TableName tableName, byte[] c)
boolean	preDeleteColumnHandler(TableName tableName, byte[] c)
boolean	preDeleteNamespace(String namespaceName)
void	preDeleteSnapshot(HBaseProtos.SnapshotDescription snapshot)
void	preDeleteTable(TableName tableName)
void	preDeleteTableHandler(TableName tableName)
void	preDisableTable(TableName tableName)
void	preDisableTableHandler(TableName tableName)
void	preEnableTable(TableName tableName)
void	preEnableTableHandler(TableName tableName)
void	preGetNamespaceDescriptor(String namespaceName)
boolean	preGetTableDescriptors(List<TableName> tableNamesList, List<HTableDescriptor> descriptors) Deprecated.
boolean	preGetTableDescriptors(List<TableName> tableNamesList, List<HTableDescriptor> descriptors, String regex)
boolean	preGetTableNames(List<HTableDescriptor> descriptors, String regex)
boolean	preListNamespaceDescriptors(List<NamespaceDescriptor> descriptors)
boolean	preListProcedures()
void	preListSnapshot(HBaseProtos.SnapshotDescription snapshot)
void	preMasterInitialization()
boolean	preModifyColumn(TableName tableName, HColumnDescriptor descriptor)
boolean	preModifyColumnHandler(TableName tableName, HColumnDescriptor descriptor)
boolean	preModifyNamespace(NamespaceDescriptor ns)
void	preModifyTable(TableName tableName, HTableDescriptor htd)
void	preModifyTableHandler(TableName tableName, HTableDescriptor htd)
boolean	preMove(HRegionInfo region, ServerName srcServer, ServerName destServer)
void	preMoveServers(Set<HostAndPort> servers, String targetGroup)
void	preMoveTables(Set<TableName> tables, String targetGroup)
void	preRegionOffline(HRegionInfo regionInfo)
void	preRemoveRSGroup(String name)
void	preRestoreSnapshot(HBaseProtos.SnapshotDescription snapshot, HTableDescriptor hTableDescriptor)
void	preSetNamespaceQuota(String namespace, QuotaProtos.Quotas quotas)
void	preSetTableQuota(TableName table, QuotaProtos.Quotas quotas)
void	preSetUserQuota(String user, QuotaProtos.Quotas quotas)
void	preSetUserQuota(String user, String namespace, QuotaProtos.Quotas quotas)
void	preSetUserQuota(String user, TableName table, QuotaProtos.Quotas quotas)
void	preShutdown()
void	preSnapshot(HBaseProtos.SnapshotDescription snapshot, HTableDescriptor hTableDescriptor)
void	preStopMaster()
void	preTableFlush(TableName tableName)
void	preTruncateTable(TableName tableName)
void	preTruncateTableHandler(TableName tableName)
boolean	preUnassign(HRegionInfo regionInfo, boolean force)

Methods inherited from class org.apache.hadoop.hbase.coprocessor.CoprocessorHost

abortServer, abortServer, findCoprocessor, findCoprocessorEnvironment, findCoprocessors, getCoprocessors, getLoadedCoprocessors, handleCoprocessorThrowable, legacyWarning, load, load, loadInstance, loadSystemCoprocessors, shutdown, useLegacyMethod

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MasterCoprocessorHost

public MasterCoprocessorHost(MasterServices services,
                             Configuration conf)

Method Detail

createEnvironment

public org.apache.hadoop.hbase.master.MasterCoprocessorHost.MasterEnvironment createEnvironment(Class<?> implClass,
                                                                                                Coprocessor instance,
                                                                                                int priority,
                                                                                                int seq,
                                                                                                Configuration conf)

Description copied from class: CoprocessorHost

Called when a new Coprocessor class is loaded

Specified by:

createEnvironment in class CoprocessorHost<org.apache.hadoop.hbase.master.MasterCoprocessorHost.MasterEnvironment>

preCreateNamespace

public boolean preCreateNamespace(NamespaceDescriptor ns)
                           throws IOException

Throws:

IOException

postCreateNamespace

public void postCreateNamespace(NamespaceDescriptor ns)
                         throws IOException

Throws:

IOException

preDeleteNamespace

public boolean preDeleteNamespace(String namespaceName)
                           throws IOException

Throws:

IOException

postDeleteNamespace

public void postDeleteNamespace(String namespaceName)
                         throws IOException

Throws:

IOException

preModifyNamespace

public boolean preModifyNamespace(NamespaceDescriptor ns)
                           throws IOException

Throws:

IOException

postModifyNamespace

public void postModifyNamespace(NamespaceDescriptor ns)
                         throws IOException

Throws:

IOException

preGetNamespaceDescriptor

public void preGetNamespaceDescriptor(String namespaceName)
                               throws IOException

Throws:

IOException

postGetNamespaceDescriptor

public void postGetNamespaceDescriptor(NamespaceDescriptor ns)
                                throws IOException

Throws:

IOException

preListNamespaceDescriptors

public boolean preListNamespaceDescriptors(List<NamespaceDescriptor> descriptors)
                                    throws IOException

Throws:

IOException

postListNamespaceDescriptors

public void postListNamespaceDescriptors(List<NamespaceDescriptor> descriptors)
                                  throws IOException

Throws:

IOException

preCreateTable

public void preCreateTable(HTableDescriptor htd,
                           HRegionInfo[] regions)
                    throws IOException

Throws:

IOException

postCreateTable

public void postCreateTable(HTableDescriptor htd,
                            HRegionInfo[] regions)
                     throws IOException

Throws:

IOException

preCreateTableHandler

public void preCreateTableHandler(HTableDescriptor htd,
                                  HRegionInfo[] regions)
                           throws IOException

Throws:

IOException

postCreateTableHandler

public void postCreateTableHandler(HTableDescriptor htd,
                                   HRegionInfo[] regions)
                            throws IOException

Throws:

IOException

preDeleteTable

public void preDeleteTable(TableName tableName)
                    throws IOException

Throws:

IOException

postDeleteTable

public void postDeleteTable(TableName tableName)
                     throws IOException

Throws:

IOException

preDeleteTableHandler

public void preDeleteTableHandler(TableName tableName)
                           throws IOException

Throws:

IOException

postDeleteTableHandler

public void postDeleteTableHandler(TableName tableName)
                            throws IOException

Throws:

IOException

preTruncateTable

public void preTruncateTable(TableName tableName)
                      throws IOException

Throws:

IOException

postTruncateTable

public void postTruncateTable(TableName tableName)
                       throws IOException

Throws:

IOException

preTruncateTableHandler

public void preTruncateTableHandler(TableName tableName)
                             throws IOException

Throws:

IOException

postTruncateTableHandler

public void postTruncateTableHandler(TableName tableName)
                              throws IOException

Throws:

IOException

preModifyTable

public void preModifyTable(TableName tableName,
                           HTableDescriptor htd)
                    throws IOException

Throws:

IOException

postModifyTable

public void postModifyTable(TableName tableName,
                            HTableDescriptor htd)
                     throws IOException

Throws:

IOException

preModifyTableHandler

public void preModifyTableHandler(TableName tableName,
                                  HTableDescriptor htd)
                           throws IOException

Throws:

IOException

postModifyTableHandler

public void postModifyTableHandler(TableName tableName,
                                   HTableDescriptor htd)
                            throws IOException

Throws:

IOException

preAddColumn

public boolean preAddColumn(TableName tableName,
                            HColumnDescriptor column)
                     throws IOException

Throws:

IOException

postAddColumn

public void postAddColumn(TableName tableName,
                          HColumnDescriptor column)
                   throws IOException

Throws:

IOException

preAddColumnHandler

public boolean preAddColumnHandler(TableName tableName,
                                   HColumnDescriptor column)
                            throws IOException

Throws:

IOException

postAddColumnHandler

public void postAddColumnHandler(TableName tableName,
                                 HColumnDescriptor column)
                          throws IOException

Throws:

IOException

preModifyColumn

public boolean preModifyColumn(TableName tableName,
                               HColumnDescriptor descriptor)
                        throws IOException

Throws:

IOException

postModifyColumn

public void postModifyColumn(TableName tableName,
                             HColumnDescriptor descriptor)
                      throws IOException

Throws:

IOException

preModifyColumnHandler

public boolean preModifyColumnHandler(TableName tableName,
                                      HColumnDescriptor descriptor)
                               throws IOException

Throws:

IOException

postModifyColumnHandler

public void postModifyColumnHandler(TableName tableName,
                                    HColumnDescriptor descriptor)
                             throws IOException

Throws:

IOException

preDeleteColumn

public boolean preDeleteColumn(TableName tableName,
                               byte[] c)
                        throws IOException

Throws:

IOException

postDeleteColumn

public void postDeleteColumn(TableName tableName,
                             byte[] c)
                      throws IOException

Throws:

IOException

preDeleteColumnHandler

public boolean preDeleteColumnHandler(TableName tableName,
                                      byte[] c)
                               throws IOException

Throws:

IOException

postDeleteColumnHandler

public void postDeleteColumnHandler(TableName tableName,
                                    byte[] c)
                             throws IOException

Throws:

IOException

preEnableTable

public void preEnableTable(TableName tableName)
                    throws IOException

Throws:

IOException

postEnableTable

public void postEnableTable(TableName tableName)
                     throws IOException

Throws:

IOException

preEnableTableHandler

public void preEnableTableHandler(TableName tableName)
                           throws IOException

Throws:

IOException

postEnableTableHandler

public void postEnableTableHandler(TableName tableName)
                            throws IOException

Throws:

IOException

preDisableTable

public void preDisableTable(TableName tableName)
                     throws IOException

Throws:

IOException

postDisableTable

public void postDisableTable(TableName tableName)
                      throws IOException

Throws:

IOException

preDisableTableHandler

public void preDisableTableHandler(TableName tableName)
                            throws IOException

Throws:

IOException

postDisableTableHandler

public void postDisableTableHandler(TableName tableName)
                             throws IOException

Throws:

IOException

preAbortProcedure

public boolean preAbortProcedure(ProcedureExecutor<MasterProcedureEnv> procEnv,
                                 long procId)
                          throws IOException

Throws:

IOException

postAbortProcedure

public void postAbortProcedure()
                        throws IOException

Throws:

IOException

preListProcedures

public boolean preListProcedures()
                          throws IOException

Throws:

IOException

postListProcedures

public void postListProcedures(List<ProcedureInfo> procInfoList)
                        throws IOException

Throws:

IOException

preMove

public boolean preMove(HRegionInfo region,
                       ServerName srcServer,
                       ServerName destServer)
                throws IOException

Throws:

IOException

postMove

public void postMove(HRegionInfo region,
                     ServerName srcServer,
                     ServerName destServer)
              throws IOException

Throws:

IOException

preAssign

public boolean preAssign(HRegionInfo regionInfo)
                  throws IOException

Throws:

IOException

postAssign

public void postAssign(HRegionInfo regionInfo)
                throws IOException

Throws:

IOException

preUnassign

public boolean preUnassign(HRegionInfo regionInfo,
                           boolean force)
                    throws IOException

Throws:

IOException

postUnassign

public void postUnassign(HRegionInfo regionInfo,
                         boolean force)
                  throws IOException

Throws:

IOException

preRegionOffline

public void preRegionOffline(HRegionInfo regionInfo)
                      throws IOException

Throws:

IOException

postRegionOffline

public void postRegionOffline(HRegionInfo regionInfo)
                       throws IOException

Throws:

IOException

preBalance

public boolean preBalance()
                   throws IOException

Throws:

IOException

postBalance

public void postBalance(List<RegionPlan> plans)
                 throws IOException

Throws:

IOException

preBalanceSwitch

public boolean preBalanceSwitch(boolean b)
                         throws IOException

Throws:

IOException

postBalanceSwitch

public void postBalanceSwitch(boolean oldValue,
                              boolean newValue)
                       throws IOException

Throws:

IOException

preShutdown

public void preShutdown()
                 throws IOException

Throws:

IOException

preStopMaster

public void preStopMaster()
                   throws IOException

Throws:

IOException

preMasterInitialization

public void preMasterInitialization()
                             throws IOException

Throws:

IOException

postStartMaster

public void postStartMaster()
                     throws IOException

Throws:

IOException

preSnapshot

public void preSnapshot(HBaseProtos.SnapshotDescription snapshot,
                        HTableDescriptor hTableDescriptor)
                 throws IOException

Throws:

IOException

postSnapshot

public void postSnapshot(HBaseProtos.SnapshotDescription snapshot,
                         HTableDescriptor hTableDescriptor)
                  throws IOException

Throws:

IOException

preListSnapshot

public void preListSnapshot(HBaseProtos.SnapshotDescription snapshot)
                     throws IOException

Throws:

IOException

postListSnapshot

public void postListSnapshot(HBaseProtos.SnapshotDescription snapshot)
                      throws IOException

Throws:

IOException

preCloneSnapshot

public void preCloneSnapshot(HBaseProtos.SnapshotDescription snapshot,
                             HTableDescriptor hTableDescriptor)
                      throws IOException

Throws:

IOException

postCloneSnapshot

public void postCloneSnapshot(HBaseProtos.SnapshotDescription snapshot,
                              HTableDescriptor hTableDescriptor)
                       throws IOException

Throws:

IOException

preRestoreSnapshot

public void preRestoreSnapshot(HBaseProtos.SnapshotDescription snapshot,
                               HTableDescriptor hTableDescriptor)
                        throws IOException

Throws:

IOException

postRestoreSnapshot

public void postRestoreSnapshot(HBaseProtos.SnapshotDescription snapshot,
                                HTableDescriptor hTableDescriptor)
                         throws IOException

Throws:

IOException

preDeleteSnapshot

public void preDeleteSnapshot(HBaseProtos.SnapshotDescription snapshot)
                       throws IOException

Throws:

IOException

postDeleteSnapshot

public void postDeleteSnapshot(HBaseProtos.SnapshotDescription snapshot)
                        throws IOException

Throws:

IOException

preGetTableDescriptors

@Deprecated
public boolean preGetTableDescriptors(List<TableName> tableNamesList,
                                                  List<HTableDescriptor> descriptors)
                                           throws IOException

Deprecated.

Throws:

IOException

postGetTableDescriptors

@Deprecated
public void postGetTableDescriptors(List<HTableDescriptor> descriptors)
                                         throws IOException

Deprecated.

Throws:

IOException

preGetTableDescriptors

public boolean preGetTableDescriptors(List<TableName> tableNamesList,
                                      List<HTableDescriptor> descriptors,
                                      String regex)
                               throws IOException

Throws:

IOException

postGetTableDescriptors

public void postGetTableDescriptors(List<TableName> tableNamesList,
                                    List<HTableDescriptor> descriptors,
                                    String regex)
                             throws IOException

Throws:

IOException

preGetTableNames

public boolean preGetTableNames(List<HTableDescriptor> descriptors,
                                String regex)
                         throws IOException

Throws:

IOException

postGetTableNames

public void postGetTableNames(List<HTableDescriptor> descriptors,
                              String regex)
                       throws IOException

Throws:

IOException

preTableFlush

public void preTableFlush(TableName tableName)
                   throws IOException

Throws:

IOException

postTableFlush

public void postTableFlush(TableName tableName)
                    throws IOException

Throws:

IOException

preSetUserQuota

public void preSetUserQuota(String user,
                            QuotaProtos.Quotas quotas)
                     throws IOException

Throws:

IOException

postSetUserQuota

public void postSetUserQuota(String user,
                             QuotaProtos.Quotas quotas)
                      throws IOException

Throws:

IOException

preSetUserQuota

public void preSetUserQuota(String user,
                            TableName table,
                            QuotaProtos.Quotas quotas)
                     throws IOException

Throws:

IOException

postSetUserQuota

public void postSetUserQuota(String user,
                             TableName table,
                             QuotaProtos.Quotas quotas)
                      throws IOException

Throws:

IOException

preSetUserQuota

public void preSetUserQuota(String user,
                            String namespace,
                            QuotaProtos.Quotas quotas)
                     throws IOException

Throws:

IOException

postSetUserQuota

public void postSetUserQuota(String user,
                             String namespace,
                             QuotaProtos.Quotas quotas)
                      throws IOException

Throws:

IOException

preSetTableQuota

public void preSetTableQuota(TableName table,
                             QuotaProtos.Quotas quotas)
                      throws IOException

Throws:

IOException

postSetTableQuota

public void postSetTableQuota(TableName table,
                              QuotaProtos.Quotas quotas)
                       throws IOException

Throws:

IOException

preSetNamespaceQuota

public void preSetNamespaceQuota(String namespace,
                                 QuotaProtos.Quotas quotas)
                          throws IOException

Throws:

IOException

postSetNamespaceQuota

public void postSetNamespaceQuota(String namespace,
                                  QuotaProtos.Quotas quotas)
                           throws IOException

Throws:

IOException

preMoveServers

public void preMoveServers(Set<HostAndPort> servers,
                           String targetGroup)
                    throws IOException

Throws:

IOException

postMoveServers

public void postMoveServers(Set<HostAndPort> servers,
                            String targetGroup)
                     throws IOException

Throws:

IOException

preMoveTables

public void preMoveTables(Set<TableName> tables,
                          String targetGroup)
                   throws IOException

Throws:

IOException

postMoveTables

public void postMoveTables(Set<TableName> tables,
                           String targetGroup)
                    throws IOException

Throws:

IOException

preAddRSGroup

public void preAddRSGroup(String name)
                   throws IOException

Throws:

IOException

postAddRSGroup

public void postAddRSGroup(String name)
                    throws IOException

Throws:

IOException

preRemoveRSGroup

public void preRemoveRSGroup(String name)
                      throws IOException

Throws:

IOException

postRemoveRSGroup

public void postRemoveRSGroup(String name)
                       throws IOException

Throws:

IOException

preBalanceRSGroup

public void preBalanceRSGroup(String name)
                       throws IOException

Throws:

IOException

postBalanceRSGroup

public void postBalanceRSGroup(String name,
                               boolean balanceRan)
                        throws IOException

Throws:

IOException