| /* |
| * |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| package org.apache.hadoop.hbase.coprocessor; |
| |
| import com.google.common.net.HostAndPort; |
| |
| import java.io.IOException; |
| import java.util.List; |
| import java.util.Set; |
| |
| import org.apache.hadoop.hbase.Coprocessor; |
| import org.apache.hadoop.hbase.HBaseInterfaceAudience; |
| import org.apache.hadoop.hbase.HColumnDescriptor; |
| import org.apache.hadoop.hbase.HRegionInfo; |
| import org.apache.hadoop.hbase.HTableDescriptor; |
| import org.apache.hadoop.hbase.NamespaceDescriptor; |
| import org.apache.hadoop.hbase.ProcedureInfo; |
| import org.apache.hadoop.hbase.ServerName; |
| import org.apache.hadoop.hbase.TableName; |
| import org.apache.hadoop.hbase.classification.InterfaceAudience; |
| import org.apache.hadoop.hbase.classification.InterfaceStability; |
| import org.apache.hadoop.hbase.client.MasterSwitchType; |
| import org.apache.hadoop.hbase.master.RegionPlan; |
| import org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv; |
| import org.apache.hadoop.hbase.procedure2.ProcedureExecutor; |
| import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.SnapshotDescription; |
| import org.apache.hadoop.hbase.protobuf.generated.QuotaProtos.Quotas; |
| |
| /** |
| * Defines coprocessor hooks for interacting with operations on the |
| * {@link org.apache.hadoop.hbase.master.HMaster} process. |
| */ |
| @InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.COPROC) |
| @InterfaceStability.Evolving |
| public interface MasterObserver extends Coprocessor { |
| |
| /** |
| * Called before a new table is created by |
| * {@link org.apache.hadoop.hbase.master.HMaster}. Called as part of create |
| * table RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param desc the HTableDescriptor for the table |
| * @param regions the initial regions created for the table |
| * @throws IOException if something went wrong |
| */ |
| void preCreateTable(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| HTableDescriptor desc, HRegionInfo[] regions) throws IOException; |
| |
| /** |
| * Called after the createTable operation has been requested. Called as part |
| * of create table RPC call. |
| * @param ctx the environment to interact with the framework and master |
| * @param desc the HTableDescriptor for the table |
| * @param regions the initial regions created for the table |
| * @throws IOException if something went wrong |
| */ |
| void postCreateTable(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| HTableDescriptor desc, HRegionInfo[] regions) throws IOException; |
| |
| /** |
| * Called before a new table is created by |
| * {@link org.apache.hadoop.hbase.master.HMaster}. Called as part of create |
| * table handler and it is async to the create RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param desc the HTableDescriptor for the table |
| * @param regions the initial regions created for the table |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-15575">HBASE-15575</a>). |
| * Use {@link #preCreateTableAction(ObserverContext, HTableDescriptor, HRegionInfo[])}. |
| */ |
| @Deprecated |
| void preCreateTableHandler(final ObserverContext<MasterCoprocessorEnvironment> |
| ctx, HTableDescriptor desc, HRegionInfo[] regions) throws IOException; |
| |
| /** |
| * Called after the createTable operation has been requested. Called as part |
| * of create table RPC call. Called as part of create table handler and |
| * it is async to the create RPC call. |
| * @param ctx the environment to interact with the framework and master |
| * @param desc the HTableDescriptor for the table |
| * @param regions the initial regions created for the table |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-15575">HBASE-15575</a>). |
| * Use {@link #postCompletedCreateTableAction(ObserverContext, HTableDescriptor, HRegionInfo[])} |
| */ |
| @Deprecated |
| void postCreateTableHandler(final ObserverContext<MasterCoprocessorEnvironment> |
| ctx, HTableDescriptor desc, HRegionInfo[] regions) throws IOException; |
| |
| /** |
| * Called before a new table is created by |
| * {@link org.apache.hadoop.hbase.master.HMaster}. Called as part of create |
| * table procedure and it is async to the create RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #preCreateTableHandler(ObserverContext, HTableDescriptor, HRegionInfo[])} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param desc the HTableDescriptor for the table |
| * @param regions the initial regions created for the table |
| * @throws IOException if something went wrong |
| */ |
| void preCreateTableAction( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final HTableDescriptor desc, |
| final HRegionInfo[] regions) throws IOException; |
| |
| /** |
| * Called after the createTable operation has been requested. Called as part |
| * of create table RPC call. Called as part of create table procedure and |
| * it is async to the create RPC call. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #postCreateTableHandler(ObserverContext, HTableDescriptor, HRegionInfo[])} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param desc the HTableDescriptor for the table |
| * @param regions the initial regions created for the table |
| * @throws IOException if something went wrong |
| */ |
| void postCompletedCreateTableAction( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final HTableDescriptor desc, |
| final HRegionInfo[] regions) throws IOException; |
| |
| /** |
| * Called before {@link org.apache.hadoop.hbase.master.HMaster} deletes a |
| * table. Called as part of delete table RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| */ |
| void preDeleteTable(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| TableName tableName) throws IOException; |
| |
| /** |
| * Called after the deleteTable operation has been requested. Called as part |
| * of delete table RPC call. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| */ |
| void postDeleteTable(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| TableName tableName) throws IOException; |
| |
| /** |
| * Called before {@link org.apache.hadoop.hbase.master.HMaster} deletes a |
| * table. Called as part of delete table handler and |
| * it is async to the delete RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-15575">HBASE-15575</a>). |
| * Use {@link #preDeleteTableAction(ObserverContext, TableName)}. |
| */ |
| @Deprecated |
| void preDeleteTableHandler( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) |
| throws IOException; |
| |
| /** |
| * Called after {@link org.apache.hadoop.hbase.master.HMaster} deletes a |
| * table. Called as part of delete table handler and it is async to the |
| * delete RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-15575">HBASE-15575</a>). |
| * Use {@link #postCompletedDeleteTableAction(ObserverContext, TableName)}. |
| */ |
| @Deprecated |
| void postDeleteTableHandler( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) |
| throws IOException; |
| |
| /** |
| * Called before {@link org.apache.hadoop.hbase.master.HMaster} deletes a |
| * table. Called as part of delete table procedure and |
| * it is async to the delete RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #preDeleteTableHandler(ObserverContext, TableName)} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| */ |
| void preDeleteTableAction( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, final TableName tableName) |
| throws IOException; |
| |
| /** |
| * Called after {@link org.apache.hadoop.hbase.master.HMaster} deletes a |
| * table. Called as part of delete table procedure and it is async to the |
| * delete RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #postDeleteTableHandler(ObserverContext, TableName)} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| */ |
| void postCompletedDeleteTableAction( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, final TableName tableName) |
| throws IOException; |
| |
| /** |
| * Called before {@link org.apache.hadoop.hbase.master.HMaster} truncates a |
| * table. Called as part of truncate table RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| */ |
| void preTruncateTable(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| TableName tableName) throws IOException; |
| |
| /** |
| * Called after the truncateTable operation has been requested. Called as part |
| * of truncate table RPC call. |
| * The truncate is synchronous, so this method will be called when the |
| * truncate operation is terminated. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| */ |
| void postTruncateTable(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| TableName tableName) throws IOException; |
| |
| /** |
| * Called before {@link org.apache.hadoop.hbase.master.HMaster} truncates a |
| * table. Called as part of truncate table handler and it is sync |
| * to the truncate RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-15575">HBASE-15575</a>). |
| * Use {@link #preTruncateTableAction(ObserverContext, TableName)}. |
| */ |
| @Deprecated |
| void preTruncateTableHandler( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) |
| throws IOException; |
| |
| /** |
| * Called after {@link org.apache.hadoop.hbase.master.HMaster} truncates a |
| * table. Called as part of truncate table handler and it is sync to the |
| * truncate RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-15575">HBASE-15575</a>). |
| * Use {@link #postCompletedTruncateTableAction(ObserverContext, TableName)}. |
| */ |
| @Deprecated |
| void postTruncateTableHandler( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) |
| throws IOException; |
| |
| /** |
| * Called before {@link org.apache.hadoop.hbase.master.HMaster} truncates a |
| * table. Called as part of truncate table procedure and it is async |
| * to the truncate RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #preTruncateTableHandler(ObserverContext, TableName)} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| */ |
| void preTruncateTableAction( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, final TableName tableName) |
| throws IOException; |
| |
| /** |
| * Called after {@link org.apache.hadoop.hbase.master.HMaster} truncates a |
| * table. Called as part of truncate table procedure and it is async to the |
| * truncate RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #postTruncateTableHandler(ObserverContext, TableName)} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| */ |
| void postCompletedTruncateTableAction( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, final TableName tableName) |
| throws IOException; |
| |
| /** |
| * Called prior to modifying a table's properties. Called as part of modify |
| * table RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param htd the HTableDescriptor |
| * @throws IOException if something went wrong |
| */ |
| void preModifyTable(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, HTableDescriptor htd) throws IOException; |
| |
| /** |
| * Called after the modifyTable operation has been requested. Called as part |
| * of modify table RPC call. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param htd the HTableDescriptor |
| * @throws IOException if something went wrong |
| */ |
| void postModifyTable(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, HTableDescriptor htd) throws IOException; |
| |
| /** |
| * Called prior to modifying a table's properties. Called as part of modify |
| * table handler and it is async to the modify table RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param htd the HTableDescriptor |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-15575">HBASE-15575</a>). |
| * Use {@link #preModifyTableAction(ObserverContext, TableName, HTableDescriptor)}. |
| */ |
| @Deprecated |
| void preModifyTableHandler( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, HTableDescriptor htd) throws IOException; |
| |
| /** |
| * Called after to modifying a table's properties. Called as part of modify |
| * table handler and it is async to the modify table RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param htd the HTableDescriptor |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-13645">HBASE-13645</a>). |
| * Use {@link #postCompletedModifyTableAction(ObserverContext, TableName, HTableDescriptor)}. |
| */ |
| @Deprecated |
| void postModifyTableHandler( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, HTableDescriptor htd) throws IOException; |
| |
| /** |
| * Called prior to modifying a table's properties. Called as part of modify |
| * table procedure and it is async to the modify table RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #preModifyTableHandler(ObserverContext, TableName, HTableDescriptor)} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param htd the HTableDescriptor |
| * @throws IOException if something went wrong |
| */ |
| void preModifyTableAction( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, |
| final HTableDescriptor htd) throws IOException; |
| |
| /** |
| * Called after to modifying a table's properties. Called as part of modify |
| * table procedure and it is async to the modify table RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #postModifyTableHandler(ObserverContext, TableName, HTableDescriptor)} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param htd the HTableDescriptor |
| * @throws IOException if something went wrong |
| */ |
| void postCompletedModifyTableAction( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, |
| final HTableDescriptor htd) throws IOException; |
| |
| /** |
| * Called prior to adding a new column family to the table. Called as part of |
| * add column RPC call. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the HColumnDescriptor |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-13645">HBASE-13645</a>). |
| * Use {@link #preAddColumnFamily(ObserverContext, TableName, HColumnDescriptor)}. |
| */ |
| @Deprecated |
| void preAddColumn(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| TableName tableName, HColumnDescriptor columnFamily) throws IOException; |
| |
| /** |
| * Called prior to adding a new column family to the table. Called as part of |
| * add column RPC call. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #preAddColumn(ObserverContext, TableName, HColumnDescriptor)} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the HColumnDescriptor |
| * @throws IOException if something went wrong |
| */ |
| void preAddColumnFamily(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| TableName tableName, HColumnDescriptor columnFamily) throws IOException; |
| |
| /** |
| * Called after the new column family has been created. Called as part of |
| * add column RPC call. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the HColumnDescriptor |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-13645">HBASE-13645</a>). |
| * Use {@link #postAddColumnFamily(ObserverContext, TableName, HColumnDescriptor)}. |
| */ |
| @Deprecated |
| void postAddColumn(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| TableName tableName, HColumnDescriptor columnFamily) throws IOException; |
| |
| /** |
| * Called after the new column family has been created. Called as part of |
| * add column RPC call. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #postAddColumn(ObserverContext, TableName, HColumnDescriptor)} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the HColumnDescriptor |
| * @throws IOException if something went wrong |
| */ |
| void postAddColumnFamily(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| TableName tableName, HColumnDescriptor columnFamily) throws IOException; |
| |
| /** |
| * Called prior to adding a new column family to the table. Called as part of |
| * add column handler. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the HColumnDescriptor |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-13645">HBASE-13645</a>). Use |
| * {@link #preAddColumnFamilyAction(ObserverContext, TableName, HColumnDescriptor)}. |
| */ |
| @Deprecated |
| void preAddColumnHandler( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| TableName tableName, HColumnDescriptor columnFamily) throws IOException; |
| |
| /** |
| * Called prior to adding a new column family to the table. Called as part of |
| * add column procedure. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #preAddColumnHandler(ObserverContext, TableName, HColumnDescriptor)} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the HColumnDescriptor |
| * @throws IOException if something went wrong |
| */ |
| void preAddColumnFamilyAction( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, |
| final HColumnDescriptor columnFamily) throws IOException; |
| |
| /** |
| * Called after the new column family has been created. Called as part of |
| * add column handler. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the HColumnDescriptor |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-13645">HBASE-13645</a>). Use |
| * {@link #postCompletedAddColumnFamilyAction(ObserverContext, TableName, HColumnDescriptor)}. |
| */ |
| @Deprecated |
| void postAddColumnHandler( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| TableName tableName, HColumnDescriptor columnFamily) throws IOException; |
| |
| /** |
| * Called after the new column family has been created. Called as part of |
| * add column procedure. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #postAddColumnHandler(ObserverContext, TableName, HColumnDescriptor)} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the HColumnDescriptor |
| * @throws IOException if something went wrong |
| */ |
| void postCompletedAddColumnFamilyAction( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, |
| final HColumnDescriptor columnFamily) throws IOException; |
| |
| /** |
| * Called prior to modifying a column family's attributes. Called as part of |
| * modify column RPC call. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the HColumnDescriptor |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-13645">HBASE-13645</a>). |
| * Use {@link #preModifyColumnFamily(ObserverContext, TableName, HColumnDescriptor)}. |
| */ |
| @Deprecated |
| void preModifyColumn(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| TableName tableName, HColumnDescriptor columnFamily) throws IOException; |
| |
| /** |
| * Called prior to modifying a column family's attributes. Called as part of |
| * modify column RPC call. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #preModifyColumn(ObserverContext, TableName, HColumnDescriptor)} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the HColumnDescriptor |
| * @throws IOException if something went wrong |
| */ |
| void preModifyColumnFamily(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| TableName tableName, HColumnDescriptor columnFamily) throws IOException; |
| |
| /** |
| * Called after the column family has been updated. Called as part of modify |
| * column RPC call. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the HColumnDescriptor |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-13645">HBASE-13645</a>). |
| * Use {@link #postModifyColumnFamily(ObserverContext, TableName, HColumnDescriptor)}. |
| */ |
| @Deprecated |
| void postModifyColumn(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| TableName tableName, HColumnDescriptor columnFamily) throws IOException; |
| |
| /** |
| * Called after the column family has been updated. Called as part of modify |
| * column RPC call. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #postModifyColumn(ObserverContext, TableName, HColumnDescriptor)} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the HColumnDescriptor |
| * @throws IOException if something went wrong |
| */ |
| void postModifyColumnFamily(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| TableName tableName, HColumnDescriptor columnFamily) throws IOException; |
| |
| /** |
| * Called prior to modifying a column family's attributes. Called as part of |
| * modify column handler. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the HColumnDescriptor |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-13645">HBASE-13645</a>). |
| * Use {@link #preModifyColumnFamilyAction(ObserverContext, TableName, HColumnDescriptor)}. |
| */ |
| @Deprecated |
| void preModifyColumnHandler( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| TableName tableName, HColumnDescriptor columnFamily) throws IOException; |
| |
| /** |
| * Called prior to modifying a column family's attributes. Called as part of |
| * modify column procedure. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #preModifyColumnHandler(ObserverContext, TableName, HColumnDescriptor)} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the HColumnDescriptor |
| * @throws IOException if something went wrong |
| */ |
| void preModifyColumnFamilyAction( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, |
| final HColumnDescriptor columnFamily) throws IOException; |
| |
| /** |
| * Called after the column family has been updated. Called as part of modify |
| * column handler. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the HColumnDescriptor |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-13645">HBASE-13645</a>). Use |
| * {@link #postCompletedModifyColumnFamilyAction(ObserverContext,TableName,HColumnDescriptor)}. |
| */ |
| @Deprecated |
| void postModifyColumnHandler( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| TableName tableName, HColumnDescriptor columnFamily) throws IOException; |
| |
| /** |
| * Called after the column family has been updated. Called as part of modify |
| * column procedure. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #postModifyColumnHandler(ObserverContext, TableName, HColumnDescriptor)} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the HColumnDescriptor |
| * @throws IOException if something went wrong |
| */ |
| void postCompletedModifyColumnFamilyAction( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, |
| final HColumnDescriptor columnFamily) throws IOException; |
| |
| /** |
| * Called prior to deleting the entire column family. Called as part of |
| * delete column RPC call. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the column family |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-13645">HBASE-13645</a>). |
| * Use {@link #preDeleteColumnFamily(ObserverContext, TableName, byte[])}. |
| */ |
| @Deprecated |
| void preDeleteColumn(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, final byte[] columnFamily) throws IOException; |
| |
| /** |
| * Called prior to deleting the entire column family. Called as part of |
| * delete column RPC call. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #preDeleteColumn(ObserverContext, TableName, byte[])} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the column |
| * @throws IOException if something went wrong |
| */ |
| void preDeleteColumnFamily(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, final byte[] columnFamily) throws IOException; |
| |
| /** |
| * Called after the column family has been deleted. Called as part of delete |
| * column RPC call. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the column family |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-13645">HBASE-13645</a>). |
| * Use {@link #postDeleteColumnFamily(ObserverContext, TableName, byte[])}. |
| */ |
| @Deprecated |
| void postDeleteColumn(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, final byte[] columnFamily) throws IOException; |
| |
| /** |
| * Called after the column family has been deleted. Called as part of delete |
| * column RPC call. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #postDeleteColumn(ObserverContext, TableName, byte[])} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the column family |
| * @throws IOException if something went wrong |
| */ |
| void postDeleteColumnFamily(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, final byte[] columnFamily) throws IOException; |
| |
| /** |
| * Called prior to deleting the entire column family. Called as part of |
| * delete column handler. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the column family |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-13645">HBASE-13645</a>). |
| * Use {@link #preDeleteColumnFamilyAction(ObserverContext, TableName, byte[])}. |
| */ |
| @Deprecated |
| void preDeleteColumnHandler( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, final byte[] columnFamily) throws IOException; |
| |
| /** |
| * Called prior to deleting the entire column family. Called as part of |
| * delete column procedure. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #preDeleteColumnHandler(ObserverContext, TableName, byte[])} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the column family |
| * @throws IOException if something went wrong |
| */ |
| void preDeleteColumnFamilyAction( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, final byte[] columnFamily) throws IOException; |
| |
| /** |
| * Called after the column family has been deleted. Called as part of |
| * delete column handler. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the column family |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-13645">HBASE-13645</a>). |
| * Use {@link #postCompletedDeleteColumnFamilyAction(ObserverContext, TableName, byte[])}. |
| */ |
| @Deprecated |
| void postDeleteColumnHandler( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, final byte[] columnFamily) throws IOException; |
| |
| /** |
| * Called after the column family has been deleted. Called as part of |
| * delete column procedure. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #postDeleteColumnHandler(ObserverContext, TableName, byte[])} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param columnFamily the column family |
| * @throws IOException if something went wrong |
| */ |
| void postCompletedDeleteColumnFamilyAction( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, final byte[] columnFamily) throws IOException; |
| |
| /** |
| * Called prior to enabling a table. Called as part of enable table RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| */ |
| void preEnableTable(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName) throws IOException; |
| |
| /** |
| * Called after the enableTable operation has been requested. Called as part |
| * of enable table RPC call. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| */ |
| void postEnableTable(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName) throws IOException; |
| |
| /** |
| * Called prior to enabling a table. Called as part of enable table handler |
| * and it is async to the enable table RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-15575">HBASE-15575</a>). |
| * Use {@link #preEnableTableAction(ObserverContext, TableName)}. |
| */ |
| @Deprecated |
| void preEnableTableHandler( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName) throws IOException; |
| |
| /** |
| * Called after the enableTable operation has been requested. Called as part |
| * of enable table handler and it is async to the enable table RPC call. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-15575">HBASE-15575</a>). |
| * Use {@link #postCompletedEnableTableAction(ObserverContext, TableName)}. |
| */ |
| @Deprecated |
| void postEnableTableHandler( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName) throws IOException; |
| |
| /** |
| * Called prior to enabling a table. Called as part of enable table procedure |
| * and it is async to the enable table RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #preEnableTableHandler(ObserverContext, TableName)} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| */ |
| void preEnableTableAction( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName) throws IOException; |
| |
| /** |
| * Called after the enableTable operation has been requested. Called as part |
| * of enable table procedure and it is async to the enable table RPC call. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #postEnableTableHandler(ObserverContext, TableName)} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| */ |
| void postCompletedEnableTableAction( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName) throws IOException; |
| |
| /** |
| * Called prior to disabling a table. Called as part of disable table RPC |
| * call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| */ |
| void preDisableTable(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName) throws IOException; |
| |
| /** |
| * Called after the disableTable operation has been requested. Called as part |
| * of disable table RPC call. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| */ |
| void postDisableTable(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName) throws IOException; |
| |
| /** |
| * Called prior to disabling a table. Called as part of disable table handler |
| * and it is asyn to the disable table RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-15575">HBASE-15575</a>). |
| * Use {@link #preDisableTableAction(ObserverContext, TableName)}. |
| */ |
| @Deprecated |
| void preDisableTableHandler( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName) throws IOException; |
| |
| /** |
| * Called after the disableTable operation has been requested. Called as part |
| * of disable table handler and it is asyn to the disable table RPC call. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0 |
| * (<a href="https://issues.apache.org/jira/browse/HBASE-15575">HBASE-15575</a>). |
| * Use {@link #postCompletedDisableTableAction(ObserverContext, TableName)}. |
| */ |
| @Deprecated |
| void postDisableTableHandler( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName) throws IOException; |
| |
| /** |
| * Called prior to disabling a table. Called as part of disable table procedure |
| * and it is asyn to the disable table RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #preDisableTableHandler(ObserverContext, TableName)} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| */ |
| void preDisableTableAction( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName) throws IOException; |
| |
| /** |
| * Called after the disableTable operation has been requested. Called as part |
| * of disable table procedure and it is asyn to the disable table RPC call. |
| * |
| * Implementation note: This replaces the deprecated |
| * {@link #postDisableTableHandler(ObserverContext, TableName)} method. |
| * Make sure to implement only one of the two as both are called. |
| * |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| */ |
| void postCompletedDisableTableAction( |
| final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName) throws IOException; |
| |
| /** |
| * Called before a abortProcedure request has been processed. |
| * @param ctx the environment to interact with the framework and master |
| * @param procEnv procedure executor |
| * @param procId the Id of the procedure |
| * @throws IOException if something went wrong |
| */ |
| public void preAbortProcedure( |
| ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final ProcedureExecutor<MasterProcedureEnv> procEnv, |
| final long procId) throws IOException; |
| |
| /** |
| * Called after a abortProcedure request has been processed. |
| * @param ctx the environment to interact with the framework and master |
| * @throws IOException if something went wrong |
| */ |
| public void postAbortProcedure(ObserverContext<MasterCoprocessorEnvironment> ctx) |
| throws IOException; |
| |
| /** |
| * Called before a listProcedures request has been processed. |
| * @param ctx the environment to interact with the framework and master |
| * @throws IOException if something went wrong |
| */ |
| void preListProcedures(ObserverContext<MasterCoprocessorEnvironment> ctx) |
| throws IOException; |
| |
| /** |
| * Called after a listProcedures request has been processed. |
| * @param ctx the environment to interact with the framework and master |
| * @param procInfoList the list of procedures about to be returned |
| * @throws IOException if something went wrong |
| */ |
| void postListProcedures( |
| ObserverContext<MasterCoprocessorEnvironment> ctx, |
| List<ProcedureInfo> procInfoList) throws IOException; |
| |
| /** |
| * Called prior to moving a given region from one region server to another. |
| * @param ctx the environment to interact with the framework and master |
| * @param region the HRegionInfo |
| * @param srcServer the source ServerName |
| * @param destServer the destination ServerName |
| */ |
| void preMove(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final HRegionInfo region, final ServerName srcServer, |
| final ServerName destServer) |
| throws IOException; |
| |
| /** |
| * Called after the region move has been requested. |
| * @param ctx the environment to interact with the framework and master |
| * @param region the HRegionInfo |
| * @param srcServer the source ServerName |
| * @param destServer the destination ServerName |
| */ |
| void postMove(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final HRegionInfo region, final ServerName srcServer, |
| final ServerName destServer) |
| throws IOException; |
| |
| /** |
| * Called prior to assigning a specific region. |
| * @param ctx the environment to interact with the framework and master |
| * @param regionInfo the regionInfo of the region |
| */ |
| void preAssign(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final HRegionInfo regionInfo) throws IOException; |
| |
| /** |
| * Called after the region assignment has been requested. |
| * @param ctx the environment to interact with the framework and master |
| * @param regionInfo the regionInfo of the region |
| */ |
| void postAssign(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final HRegionInfo regionInfo) throws IOException; |
| |
| /** |
| * Called prior to unassigning a given region. |
| * @param ctx the environment to interact with the framework and master |
| * @param regionInfo |
| * @param force whether to force unassignment or not |
| */ |
| void preUnassign(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final HRegionInfo regionInfo, final boolean force) throws IOException; |
| |
| /** |
| * Called after the region unassignment has been requested. |
| * @param ctx the environment to interact with the framework and master |
| * @param regionInfo |
| * @param force whether to force unassignment or not |
| */ |
| void postUnassign(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final HRegionInfo regionInfo, final boolean force) throws IOException; |
| |
| /** |
| * Called prior to marking a given region as offline. <code>ctx.bypass()</code> will not have any |
| * impact on this hook. |
| * @param ctx the environment to interact with the framework and master |
| * @param regionInfo |
| */ |
| void preRegionOffline(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final HRegionInfo regionInfo) throws IOException; |
| |
| /** |
| * Called after the region has been marked offline. |
| * @param ctx the environment to interact with the framework and master |
| * @param regionInfo |
| */ |
| void postRegionOffline(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final HRegionInfo regionInfo) throws IOException; |
| |
| /** |
| * Called prior to requesting rebalancing of the cluster regions, though after |
| * the initial checks for regions in transition and the balance switch flag. |
| * @param ctx the environment to interact with the framework and master |
| */ |
| void preBalance(final ObserverContext<MasterCoprocessorEnvironment> ctx) |
| throws IOException; |
| |
| /** |
| * Called after the balancing plan has been submitted. |
| * @param ctx the environment to interact with the framework and master |
| * @param plans the RegionPlans which master has executed. RegionPlan serves as hint |
| * as for the final destination for the underlying region but may not represent the |
| * final state of assignment |
| */ |
| void postBalance(final ObserverContext<MasterCoprocessorEnvironment> ctx, List<RegionPlan> plans) |
| throws IOException; |
| |
| /** |
| * Called prior to setting split / merge switch |
| * @param ctx the coprocessor instance's environment |
| * @param newValue the new value submitted in the call |
| * @param switchType type of switch |
| */ |
| boolean preSetSplitOrMergeEnabled(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final boolean newValue, final MasterSwitchType switchType) throws IOException; |
| |
| /** |
| * Called after setting split / merge switch |
| * @param ctx the coprocessor instance's environment |
| * @param newValue the new value submitted in the call |
| * @param switchType type of switch |
| */ |
| void postSetSplitOrMergeEnabled(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final boolean newValue, final MasterSwitchType switchType) throws IOException; |
| |
| /** |
| * Called prior to modifying the flag used to enable/disable region balancing. |
| * @param ctx the coprocessor instance's environment |
| * @param newValue the new flag value submitted in the call |
| */ |
| boolean preBalanceSwitch(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final boolean newValue) throws IOException; |
| |
| /** |
| * Called after the flag to enable/disable balancing has changed. |
| * @param ctx the coprocessor instance's environment |
| * @param oldValue the previously set balanceSwitch value |
| * @param newValue the newly set balanceSwitch value |
| */ |
| void postBalanceSwitch(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final boolean oldValue, final boolean newValue) throws IOException; |
| |
| /** |
| * Called prior to shutting down the full HBase cluster, including this |
| * {@link org.apache.hadoop.hbase.master.HMaster} process. |
| */ |
| void preShutdown(final ObserverContext<MasterCoprocessorEnvironment> ctx) |
| throws IOException; |
| |
| |
| /** |
| * Called immediately prior to stopping this |
| * {@link org.apache.hadoop.hbase.master.HMaster} process. |
| */ |
| void preStopMaster(final ObserverContext<MasterCoprocessorEnvironment> ctx) |
| throws IOException; |
| |
| /** |
| * Called immediately after an active master instance has completed |
| * initialization. Will not be called on standby master instances unless |
| * they take over the active role. |
| */ |
| void postStartMaster(final ObserverContext<MasterCoprocessorEnvironment> ctx) |
| throws IOException; |
| |
| /** |
| * Call before the master initialization is set to true. |
| * {@link org.apache.hadoop.hbase.master.HMaster} process. |
| */ |
| void preMasterInitialization(final ObserverContext<MasterCoprocessorEnvironment> ctx) |
| throws IOException; |
| |
| /** |
| * Called before a new snapshot is taken. |
| * Called as part of snapshot RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param snapshot the SnapshotDescriptor for the snapshot |
| * @param hTableDescriptor the hTableDescriptor of the table to snapshot |
| * @throws IOException if something went wrong |
| */ |
| void preSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final SnapshotDescription snapshot, final HTableDescriptor hTableDescriptor) |
| throws IOException; |
| |
| /** |
| * Called after the snapshot operation has been requested. |
| * Called as part of snapshot RPC call. |
| * @param ctx the environment to interact with the framework and master |
| * @param snapshot the SnapshotDescriptor for the snapshot |
| * @param hTableDescriptor the hTableDescriptor of the table to snapshot |
| * @throws IOException if something went wrong |
| */ |
| void postSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final SnapshotDescription snapshot, final HTableDescriptor hTableDescriptor) |
| throws IOException; |
| |
| /** |
| * Called before listSnapshots request has been processed. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param snapshot the SnapshotDescriptor of the snapshot to list |
| * @throws IOException if something went wrong |
| */ |
| void preListSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final SnapshotDescription snapshot) throws IOException; |
| |
| /** |
| * Called after listSnapshots request has been processed. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param snapshot the SnapshotDescriptor of the snapshot to list |
| * @throws IOException if something went wrong |
| */ |
| void postListSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final SnapshotDescription snapshot) throws IOException; |
| |
| /** |
| * Called before a snapshot is cloned. |
| * Called as part of restoreSnapshot RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param snapshot the SnapshotDescriptor for the snapshot |
| * @param hTableDescriptor the hTableDescriptor of the table to create |
| * @throws IOException if something went wrong |
| */ |
| void preCloneSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final SnapshotDescription snapshot, final HTableDescriptor hTableDescriptor) |
| throws IOException; |
| |
| /** |
| * Called after a snapshot clone operation has been requested. |
| * Called as part of restoreSnapshot RPC call. |
| * @param ctx the environment to interact with the framework and master |
| * @param snapshot the SnapshotDescriptor for the snapshot |
| * @param hTableDescriptor the hTableDescriptor of the table to create |
| * @throws IOException if something went wrong |
| */ |
| void postCloneSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final SnapshotDescription snapshot, final HTableDescriptor hTableDescriptor) |
| throws IOException; |
| |
| /** |
| * Called before a snapshot is restored. |
| * Called as part of restoreSnapshot RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param snapshot the SnapshotDescriptor for the snapshot |
| * @param hTableDescriptor the hTableDescriptor of the table to restore |
| * @throws IOException if something went wrong |
| */ |
| void preRestoreSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final SnapshotDescription snapshot, final HTableDescriptor hTableDescriptor) |
| throws IOException; |
| |
| /** |
| * Called after a snapshot restore operation has been requested. |
| * Called as part of restoreSnapshot RPC call. |
| * @param ctx the environment to interact with the framework and master |
| * @param snapshot the SnapshotDescriptor for the snapshot |
| * @param hTableDescriptor the hTableDescriptor of the table to restore |
| * @throws IOException if something went wrong |
| */ |
| void postRestoreSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final SnapshotDescription snapshot, final HTableDescriptor hTableDescriptor) |
| throws IOException; |
| |
| /** |
| * Called before a snapshot is deleted. |
| * Called as part of deleteSnapshot RPC call. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param snapshot the SnapshotDescriptor of the snapshot to delete |
| * @throws IOException if something went wrong |
| */ |
| void preDeleteSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final SnapshotDescription snapshot) throws IOException; |
| |
| /** |
| * Called after the delete snapshot operation has been requested. |
| * Called as part of deleteSnapshot RPC call. |
| * @param ctx the environment to interact with the framework and master |
| * @param snapshot the SnapshotDescriptor of the snapshot to delete |
| * @throws IOException if something went wrong |
| */ |
| void postDeleteSnapshot(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final SnapshotDescription snapshot) throws IOException; |
| |
| /** |
| * Called before a getTableDescriptors request has been processed. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableNamesList the list of table names, or null if querying for all |
| * @param descriptors an empty list, can be filled with what to return if bypassing |
| * @param regex regular expression used for filtering the table names |
| * @throws IOException if something went wrong |
| */ |
| void preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx, |
| List<TableName> tableNamesList, List<HTableDescriptor> descriptors, |
| String regex) throws IOException; |
| |
| /** |
| * Called after a getTableDescriptors request has been processed. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableNamesList the list of table names, or null if querying for all |
| * @param descriptors the list of descriptors about to be returned |
| * @param regex regular expression used for filtering the table names |
| * @throws IOException if something went wrong |
| */ |
| void postGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx, |
| List<TableName> tableNamesList, List<HTableDescriptor> descriptors, |
| String regex) throws IOException; |
| |
| /** |
| * Called before a getTableNames request has been processed. |
| * @param ctx the environment to interact with the framework and master |
| * @param descriptors an empty list, can be filled with what to return if bypassing |
| * @param regex regular expression used for filtering the table names |
| * @throws IOException if something went wrong |
| */ |
| void preGetTableNames(ObserverContext<MasterCoprocessorEnvironment> ctx, |
| List<HTableDescriptor> descriptors, String regex) throws IOException; |
| |
| /** |
| * Called after a getTableNames request has been processed. |
| * @param ctx the environment to interact with the framework and master |
| * @param descriptors the list of descriptors about to be returned |
| * @param regex regular expression used for filtering the table names |
| * @throws IOException if something went wrong |
| */ |
| void postGetTableNames(ObserverContext<MasterCoprocessorEnvironment> ctx, |
| List<HTableDescriptor> descriptors, String regex) throws IOException; |
| |
| |
| |
| /** |
| * Called before a new namespace is created by |
| * {@link org.apache.hadoop.hbase.master.HMaster}. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param ns the NamespaceDescriptor for the table |
| * @throws IOException if something went wrong |
| */ |
| void preCreateNamespace(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| NamespaceDescriptor ns) throws IOException; |
| /** |
| * Called after the createNamespace operation has been requested. |
| * @param ctx the environment to interact with the framework and master |
| * @param ns the NamespaceDescriptor for the table |
| * @throws IOException if something went wrong |
| */ |
| void postCreateNamespace(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| NamespaceDescriptor ns) throws IOException; |
| |
| /** |
| * Called before {@link org.apache.hadoop.hbase.master.HMaster} deletes a |
| * namespace |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param namespace the name of the namespace |
| * @throws IOException if something went wrong |
| */ |
| void preDeleteNamespace(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| String namespace) throws IOException; |
| |
| /** |
| * Called after the deleteNamespace operation has been requested. |
| * @param ctx the environment to interact with the framework and master |
| * @param namespace the name of the namespace |
| * @throws IOException if something went wrong |
| */ |
| void postDeleteNamespace(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| String namespace) throws IOException; |
| |
| /** |
| * Called prior to modifying a namespace's properties. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx the environment to interact with the framework and master |
| * @param ns the NamespaceDescriptor |
| * @throws IOException if something went wrong |
| */ |
| void preModifyNamespace(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| NamespaceDescriptor ns) throws IOException; |
| |
| /** |
| * Called after the modifyNamespace operation has been requested. |
| * @param ctx the environment to interact with the framework and master |
| * @param ns the NamespaceDescriptor |
| * @throws IOException if something went wrong |
| */ |
| void postModifyNamespace(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| NamespaceDescriptor ns) throws IOException; |
| |
| /** |
| * Called before a getNamespaceDescriptor request has been processed. |
| * @param ctx the environment to interact with the framework and master |
| * @param namespace the name of the namespace |
| * @throws IOException if something went wrong |
| */ |
| void preGetNamespaceDescriptor(ObserverContext<MasterCoprocessorEnvironment> ctx, |
| String namespace) throws IOException; |
| |
| /** |
| * Called after a getNamespaceDescriptor request has been processed. |
| * @param ctx the environment to interact with the framework and master |
| * @param ns the NamespaceDescriptor |
| * @throws IOException if something went wrong |
| */ |
| void postGetNamespaceDescriptor(ObserverContext<MasterCoprocessorEnvironment> ctx, |
| NamespaceDescriptor ns) throws IOException; |
| |
| /** |
| * Called before a listNamespaceDescriptors request has been processed. |
| * @param ctx the environment to interact with the framework and master |
| * @param descriptors an empty list, can be filled with what to return if bypassing |
| * @throws IOException if something went wrong |
| */ |
| void preListNamespaceDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx, |
| List<NamespaceDescriptor> descriptors) throws IOException; |
| |
| /** |
| * Called after a listNamespaceDescriptors request has been processed. |
| * @param ctx the environment to interact with the framework and master |
| * @param descriptors the list of descriptors about to be returned |
| * @throws IOException if something went wrong |
| */ |
| void postListNamespaceDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx, |
| List<NamespaceDescriptor> descriptors) throws IOException; |
| |
| |
| /** |
| * Called before the table memstore is flushed to disk. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| */ |
| void preTableFlush(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName) throws IOException; |
| |
| /** |
| * Called after the table memstore is flushed to disk. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @throws IOException if something went wrong |
| */ |
| void postTableFlush(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName) throws IOException; |
| |
| /** |
| * Called before the quota for the user is stored. |
| * @param ctx the environment to interact with the framework and master |
| * @param userName the name of user |
| * @param quotas the quota settings |
| * @throws IOException if something went wrong |
| */ |
| void preSetUserQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final String userName, final Quotas quotas) throws IOException; |
| |
| /** |
| * Called after the quota for the user is stored. |
| * @param ctx the environment to interact with the framework and master |
| * @param userName the name of user |
| * @param quotas the quota settings |
| * @throws IOException if something went wrong |
| */ |
| void postSetUserQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final String userName, final Quotas quotas) throws IOException; |
| |
| /** |
| * Called before the quota for the user on the specified table is stored. |
| * @param ctx the environment to interact with the framework and master |
| * @param userName the name of user |
| * @param tableName the name of the table |
| * @param quotas the quota settings |
| * @throws IOException if something went wrong |
| */ |
| void preSetUserQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final String userName, final TableName tableName, final Quotas quotas) throws IOException; |
| |
| /** |
| * Called after the quota for the user on the specified table is stored. |
| * @param ctx the environment to interact with the framework and master |
| * @param userName the name of user |
| * @param tableName the name of the table |
| * @param quotas the quota settings |
| * @throws IOException if something went wrong |
| */ |
| void postSetUserQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final String userName, final TableName tableName, final Quotas quotas) throws IOException; |
| |
| /** |
| * Called before the quota for the user on the specified namespace is stored. |
| * @param ctx the environment to interact with the framework and master |
| * @param userName the name of user |
| * @param namespace the name of the namespace |
| * @param quotas the quota settings |
| * @throws IOException if something went wrong |
| */ |
| void preSetUserQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final String userName, final String namespace, final Quotas quotas) throws IOException; |
| |
| /** |
| * Called after the quota for the user on the specified namespace is stored. |
| * @param ctx the environment to interact with the framework and master |
| * @param userName the name of user |
| * @param namespace the name of the namespace |
| * @param quotas the quota settings |
| * @throws IOException if something went wrong |
| */ |
| void postSetUserQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final String userName, final String namespace, final Quotas quotas) throws IOException; |
| |
| /** |
| * Called before the quota for the table is stored. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param quotas the quota settings |
| * @throws IOException if something went wrong |
| */ |
| void preSetTableQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, final Quotas quotas) throws IOException; |
| |
| /** |
| * Called after the quota for the table is stored. |
| * @param ctx the environment to interact with the framework and master |
| * @param tableName the name of the table |
| * @param quotas the quota settings |
| * @throws IOException if something went wrong |
| */ |
| void postSetTableQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final TableName tableName, final Quotas quotas) throws IOException; |
| |
| /** |
| * Called before the quota for the namespace is stored. |
| * @param ctx the environment to interact with the framework and master |
| * @param namespace the name of the namespace |
| * @param quotas the quota settings |
| * @throws IOException if something went wrong |
| */ |
| void preSetNamespaceQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final String namespace, final Quotas quotas) throws IOException; |
| |
| /** |
| * Called after the quota for the namespace is stored. |
| * @param ctx the environment to interact with the framework and master |
| * @param namespace the name of the namespace |
| * @param quotas the quota settings |
| * @throws IOException if something went wrong |
| */ |
| void postSetNamespaceQuota(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| final String namespace, final Quotas quotas) throws IOException; |
| |
| /** |
| * Called before dispatching region merge request. |
| * It can't bypass the default action, e.g., ctx.bypass() won't have effect. |
| * @param ctx coprocessor environment |
| * @param regionA first region to be merged |
| * @param regionB second region to be merged |
| * @throws IOException if an error occurred on the coprocessor |
| */ |
| public void preDispatchMerge(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| HRegionInfo regionA, HRegionInfo regionB) throws IOException; |
| |
| /** |
| * called after dispatching the region merge request. |
| * @param c coprocessor environment |
| * @param regionA first region to be merged |
| * @param regionB second region to be merged |
| * @throws IOException if an error occurred on the coprocessor |
| */ |
| void postDispatchMerge(final ObserverContext<MasterCoprocessorEnvironment> c, |
| final HRegionInfo regionA, final HRegionInfo regionB) throws IOException; |
| |
| /** |
| * Called before servers are moved to target region server group |
| * @param ctx the environment to interact with the framework and master |
| * @param servers set of servers to move |
| * @param targetGroup destination group |
| * @throws IOException on failure |
| */ |
| void preMoveServers(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| Set<HostAndPort> servers, String targetGroup) throws IOException; |
| |
| /** |
| * Called after servers are moved to target region server group |
| * @param ctx the environment to interact with the framework and master |
| * @param servers set of servers to move |
| * @param targetGroup name of group |
| * @throws IOException on failure |
| */ |
| void postMoveServers(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| Set<HostAndPort> servers, String targetGroup) throws IOException; |
| |
| /** |
| * Called before tables are moved to target region server group |
| * @param ctx the environment to interact with the framework and master |
| * @param tables set of tables to move |
| * @param targetGroup name of group |
| * @throws IOException on failure |
| */ |
| void preMoveTables(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| Set<TableName> tables, String targetGroup) throws IOException; |
| |
| /** |
| * Called after servers are moved to target region server group |
| * @param ctx the environment to interact with the framework and master |
| * @param tables set of tables to move |
| * @param targetGroup name of group |
| * @throws IOException on failure |
| */ |
| void postMoveTables(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| Set<TableName> tables, String targetGroup) throws IOException; |
| |
| /** |
| * Called before a new region server group is added |
| * @param ctx the environment to interact with the framework and master |
| * @param name group name |
| * @throws IOException on failure |
| */ |
| void preAddRSGroup(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| String name) throws IOException; |
| |
| /** |
| * Called after a new region server group is added |
| * @param ctx the environment to interact with the framework and master |
| * @param name group name |
| * @throws IOException on failure |
| */ |
| void postAddRSGroup(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| String name) throws IOException; |
| |
| /** |
| * Called before a region server group is removed |
| * @param ctx the environment to interact with the framework and master |
| * @param name group name |
| * @throws IOException on failure |
| */ |
| void preRemoveRSGroup(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| String name) throws IOException; |
| |
| /** |
| * Called after a region server group is removed |
| * @param ctx the environment to interact with the framework and master |
| * @param name group name |
| * @throws IOException on failure |
| */ |
| void postRemoveRSGroup(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| String name) throws IOException; |
| |
| /** |
| * Called before a region server group is removed |
| * @param ctx the environment to interact with the framework and master |
| * @param groupName group name |
| * @throws IOException on failure |
| */ |
| void preBalanceRSGroup(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| String groupName) throws IOException; |
| |
| /** |
| * Called after a region server group is removed |
| * @param ctx the environment to interact with the framework and master |
| * @param groupName group name |
| * @throws IOException on failure |
| */ |
| void postBalanceRSGroup(final ObserverContext<MasterCoprocessorEnvironment> ctx, |
| String groupName, boolean balancerRan) throws IOException; |
| |
| } |