/*
 * 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 java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CompareOperator;
import org.apache.hadoop.hbase.HBaseInterfaceAudience;
import org.apache.hadoop.hbase.client.Append;
import org.apache.hadoop.hbase.client.CheckAndMutate;
import org.apache.hadoop.hbase.client.CheckAndMutateResult;
import org.apache.hadoop.hbase.client.Delete;
import org.apache.hadoop.hbase.client.Durability;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Increment;
import org.apache.hadoop.hbase.client.Mutation;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.RegionInfo;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.filter.BinaryComparator;
import org.apache.hadoop.hbase.filter.ByteArrayComparable;
import org.apache.hadoop.hbase.filter.Filter;
import org.apache.hadoop.hbase.io.FSDataInputStreamWrapper;
import org.apache.hadoop.hbase.io.Reference;
import org.apache.hadoop.hbase.io.hfile.CacheConfig;
import org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
import org.apache.hadoop.hbase.regionserver.MiniBatchOperationInProgress;
import org.apache.hadoop.hbase.regionserver.OperationStatus;
import org.apache.hadoop.hbase.regionserver.Region;
import org.apache.hadoop.hbase.regionserver.Region.Operation;
import org.apache.hadoop.hbase.regionserver.RegionScanner;
import org.apache.hadoop.hbase.regionserver.ScanOptions;
import org.apache.hadoop.hbase.regionserver.ScanType;
import org.apache.hadoop.hbase.regionserver.Shipper;
import org.apache.hadoop.hbase.regionserver.Store;
import org.apache.hadoop.hbase.regionserver.StoreFile;
import org.apache.hadoop.hbase.regionserver.StoreFileReader;
import org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker;
import org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest;
import org.apache.hadoop.hbase.regionserver.querymatcher.DeleteTracker;
import org.apache.hadoop.hbase.util.Pair;
import org.apache.hadoop.hbase.wal.WALEdit;
import org.apache.hadoop.hbase.wal.WALKey;
import org.apache.yetus.audience.InterfaceAudience;
import org.apache.yetus.audience.InterfaceStability;

/**
 * Coprocessors implement this interface to observe and mediate client actions on the region.
 * <p>
 * Since most implementations will be interested in only a subset of hooks, this class uses
 * 'default' functions to avoid having to add unnecessary overrides. When the functions are
 * non-empty, it's simply to satisfy the compiler by returning value of expected (non-void) type. It
 * is done in a way that these default definitions act as no-op. So our suggestion to implementation
 * would be to not call these 'default' methods from overrides.
 * <p>
 * <h3>Exception Handling</h3><br>
 * For all functions, exception handling is done as follows:
 * <ul>
 * <li>Exceptions of type {@link IOException} are reported back to client.</li>
 * <li>For any other kind of exception:
 * <ul>
 * <li>If the configuration {@link CoprocessorHost#ABORT_ON_ERROR_KEY} is set to true, then the
 * server aborts.</li>
 * <li>Otherwise, coprocessor is removed from the server and
 * {@link org.apache.hadoop.hbase.DoNotRetryIOException} is returned to the client.</li>
 * </ul>
 * </li>
 * </ul>
 * <p>
 * <h3>For Split Related Hooks</h3> <br>
 * In hbase2/AMv2, master runs splits, so the split related hooks are moved to
 * {@link MasterObserver}.
 * <p>
 * <h3>Increment Column Value</h3><br>
 * We do not call this hook anymore.
 */
@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.COPROC)
@InterfaceStability.Evolving
public interface RegionObserver {
  /** Mutation type for postMutationBeforeWAL hook */
  enum MutationType {
    APPEND,
    INCREMENT
  }

  /**
   * Called before the region is reported as open to the master.
   * @param c the environment provided by the region server
   */
  default void preOpen(ObserverContext<? extends RegionCoprocessorEnvironment> c)
    throws IOException {
  }

  /**
   * Called after the region is reported as open to the master.
   * @param c the environment provided by the region server
   */
  default void postOpen(ObserverContext<? extends RegionCoprocessorEnvironment> c) {
  }

  /**
   * Called before the memstore is flushed to disk.
   * @param c       the environment provided by the region server
   * @param tracker tracker used to track the life cycle of a flush
   */
  default void preFlush(final ObserverContext<? extends RegionCoprocessorEnvironment> c,
    FlushLifeCycleTracker tracker) throws IOException {
  }

  /**
   * Called before we open store scanner for flush. You can use the {@code options} to change max
   * versions and TTL for the scanner being opened.
   * @param c       the environment provided by the region server
   * @param store   the store where flush is being requested
   * @param options used to change max versions and TTL for the scanner being opened
   */
  default void preFlushScannerOpen(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    Store store, ScanOptions options, FlushLifeCycleTracker tracker) throws IOException {
  }

  /**
   * Called before a Store's memstore is flushed to disk.
   * @param c       the environment provided by the region server
   * @param store   the store where flush is being requested
   * @param scanner the scanner over existing data used in the memstore
   * @param tracker tracker used to track the life cycle of a flush
   * @return the scanner to use during flush. Should not be {@code null} unless the implementation
   *         is writing new store files on its own.
   */
  default InternalScanner preFlush(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    Store store, InternalScanner scanner, FlushLifeCycleTracker tracker) throws IOException {
    return scanner;
  }

  /**
   * Called after the memstore is flushed to disk.
   * @param c       the environment provided by the region server
   * @param tracker tracker used to track the life cycle of a flush
   * @throws IOException if an error occurred on the coprocessor
   */
  default void postFlush(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    FlushLifeCycleTracker tracker) throws IOException {
  }

  /**
   * Called after a Store's memstore is flushed to disk.
   * @param c          the environment provided by the region server
   * @param store      the store being flushed
   * @param resultFile the new store file written out during compaction
   * @param tracker    tracker used to track the life cycle of a flush
   */
  default void postFlush(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store,
    StoreFile resultFile, FlushLifeCycleTracker tracker) throws IOException {
  }

  /**
   * Called before in memory compaction started.
   * @param c     the environment provided by the region server
   * @param store the store where in memory compaction is being requested
   */
  default void preMemStoreCompaction(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    Store store) throws IOException {
  }

  /**
   * Called before we open store scanner for in memory compaction. You can use the {@code options}
   * to change max versions and TTL for the scanner being opened. Notice that this method will only
   * be called when you use {@code eager} mode. For {@code basic} mode we will not drop any cells
   * thus we do not open a store scanner.
   * @param c       the environment provided by the region server
   * @param store   the store where in memory compaction is being requested
   * @param options used to change max versions and TTL for the scanner being opened
   */
  default void preMemStoreCompactionCompactScannerOpen(
    ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, ScanOptions options)
    throws IOException {
  }

  /**
   * Called before we do in memory compaction. Notice that this method will only be called when you
   * use {@code eager} mode. For {@code basic} mode we will not drop any cells thus there is no
   * {@link InternalScanner}.
   * @param c       the environment provided by the region server
   * @param store   the store where in memory compaction is being executed
   * @param scanner the scanner over existing data used in the memstore segments being compact
   * @return the scanner to use during in memory compaction. Must be non-null.
   */
  default InternalScanner preMemStoreCompactionCompact(
    ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner)
    throws IOException {
    return scanner;
  }

  /**
   * Called after the in memory compaction is finished.
   * @param c     the environment provided by the region server
   * @param store the store where in memory compaction is being executed
   */
  default void postMemStoreCompaction(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    Store store) throws IOException {
  }

  /**
   * Called prior to selecting the {@link StoreFile StoreFiles} to compact from the list of
   * available candidates. To alter the files used for compaction, you may mutate the passed in list
   * of candidates. If you remove all the candidates then the compaction will be canceled.
   * <p>
   * Supports Coprocessor 'bypass' -- 'bypass' is how this method indicates that it changed the
   * passed in <code>candidates</code>. If 'bypass' is set, we skip out on calling any subsequent
   * chained coprocessors.
   * @param c          the environment provided by the region server
   * @param store      the store where compaction is being requested
   * @param candidates the store files currently available for compaction
   * @param tracker    tracker used to track the life cycle of a compaction
   */
  default void preCompactSelection(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    Store store, List<? extends StoreFile> candidates, CompactionLifeCycleTracker tracker)
    throws IOException {
  }

  /**
   * Called after the {@link StoreFile}s to compact have been selected from the available
   * candidates.
   * @param c        the environment provided by the region server
   * @param store    the store being compacted
   * @param selected the store files selected to compact
   * @param tracker  tracker used to track the life cycle of a compaction
   * @param request  the requested compaction
   */
  default void postCompactSelection(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    Store store, List<? extends StoreFile> selected, CompactionLifeCycleTracker tracker,
    CompactionRequest request) {
  }

  /**
   * Called before we open store scanner for compaction. You can use the {@code options} to change
   * max versions and TTL for the scanner being opened.
   * @param c        the environment provided by the region server
   * @param store    the store being compacted
   * @param scanType type of Scan
   * @param options  used to change max versions and TTL for the scanner being opened
   * @param tracker  tracker used to track the life cycle of a compaction
   * @param request  the requested compaction
   */
  default void preCompactScannerOpen(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    Store store, ScanType scanType, ScanOptions options, CompactionLifeCycleTracker tracker,
    CompactionRequest request) throws IOException {
  }

  /**
   * Called prior to writing the {@link StoreFile}s selected for compaction into a new
   * {@code StoreFile}.
   * <p>
   * To override or modify the compaction process, implementing classes can wrap the provided
   * {@link InternalScanner} with a custom implementation that is returned from this method. The
   * custom scanner can then inspect {@link org.apache.hadoop.hbase.Cell}s from the wrapped scanner,
   * applying its own policy to what gets written.
   * <p>
   * If implementations are wrapping the passed in {@link InternalScanner}, they can also have their
   * implementation implement {@link Shipper} and delegate to the original scanner. This will cause
   * compactions to free up memory as they progress, which is especially important for people using
   * off-heap memory pools.
   * <p>
   * Keep in mind that when {@link Shipper#shipped()} is called, any cell references you maintain in
   * your implementation may get corrupted. As such you should make sure to deep clone any cells
   * that you need to keep reference to across invocations of shipped.
   * @param c        the environment provided by the region server
   * @param store    the store being compacted
   * @param scanner  the scanner over existing data used in the store file rewriting
   * @param scanType type of Scan
   * @param tracker  tracker used to track the life cycle of a compaction
   * @param request  the requested compaction
   * @return the scanner to use during compaction. Should not be {@code null} unless the
   *         implementation is writing new store files on its own.
   */
  default InternalScanner preCompact(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker,
    CompactionRequest request) throws IOException {
    return scanner;
  }

  /**
   * Called after compaction has completed and the new store file has been moved in to place.
   * @param c          the environment provided by the region server
   * @param store      the store being compacted
   * @param resultFile the new store file written out during compaction
   * @param tracker    used to track the life cycle of a compaction
   * @param request    the requested compaction
   */
  default void postCompact(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store,
    StoreFile resultFile, CompactionLifeCycleTracker tracker, CompactionRequest request)
    throws IOException {
  }

  /**
   * Called before the region is reported as closed to the master.
   * @param c              the environment provided by the region server
   * @param abortRequested true if the region server is aborting
   */
  default void preClose(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    boolean abortRequested) throws IOException {
  }

  /**
   * Called after the region is reported as closed to the master.
   * @param c              the environment provided by the region server
   * @param abortRequested true if the region server is aborting
   */
  default void postClose(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    boolean abortRequested) {
  }

  /**
   * Called before the client performs a Get
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * @param c      the environment provided by the region server
   * @param get    the Get request
   * @param result The result to return to the client if default processing is bypassed. Can be
   *               modified. Will not be used if default processing is not bypassed.
   */
  default void preGetOp(ObserverContext<? extends RegionCoprocessorEnvironment> c, Get get,
    List<Cell> result) throws IOException {
  }

  /**
   * Called after the client performs a Get
   * <p>
   * Note: Do not retain references to any Cells in 'result' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c      the environment provided by the region server
   * @param get    the Get request
   * @param result the result to return to the client, modify as necessary
   */
  default void postGetOp(ObserverContext<? extends RegionCoprocessorEnvironment> c, Get get,
    List<Cell> result) throws IOException {
  }

  /**
   * Called before the client tests for existence using a Get.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * @param c      the environment provided by the region server
   * @param get    the Get request
   * @param exists the result returned by the region server
   * @return the value to return to the client if bypassing default processing
   */
  default boolean preExists(ObserverContext<? extends RegionCoprocessorEnvironment> c, Get get,
    boolean exists) throws IOException {
    return exists;
  }

  /**
   * Called after the client tests for existence using a Get.
   * @param c      the environment provided by the region server
   * @param get    the Get request
   * @param exists the result returned by the region server
   * @return the result to return to the client
   */
  default boolean postExists(ObserverContext<? extends RegionCoprocessorEnvironment> c, Get get,
    boolean exists) throws IOException {
    return exists;
  }

  /**
   * Called before the client stores a value.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in 'put' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c          the environment provided by the region server
   * @param put        The Put object
   * @param edit       The WALEdit object that will be written to the wal
   * @param durability Persistence guarantee for this Put
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #prePut(ObserverContext, Put, WALEdit)} instead.
   */
  @Deprecated
  default void prePut(ObserverContext<? extends RegionCoprocessorEnvironment> c, Put put,
    WALEdit edit, Durability durability) throws IOException {
  }

  /**
   * Called before the client stores a value.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in 'put' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c    the environment provided by the region server
   * @param put  The Put object
   * @param edit The WALEdit object that will be written to the wal
   */
  default void prePut(ObserverContext<? extends RegionCoprocessorEnvironment> c, Put put,
    WALEdit edit) throws IOException {
    prePut(c, put, edit, put.getDurability());
  }

  /**
   * Called after the client stores a value.
   * <p>
   * Note: Do not retain references to any Cells in 'put' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c          the environment provided by the region server
   * @param put        The Put object
   * @param edit       The WALEdit object for the wal
   * @param durability Persistence guarantee for this Put
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #postPut(ObserverContext, Put, WALEdit)} instead.
   */
  @Deprecated
  default void postPut(ObserverContext<? extends RegionCoprocessorEnvironment> c, Put put,
    WALEdit edit, Durability durability) throws IOException {
  }

  /**
   * Called after the client stores a value.
   * <p>
   * Note: Do not retain references to any Cells in 'put' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c    the environment provided by the region server
   * @param put  The Put object
   * @param edit The WALEdit object for the wal
   */
  default void postPut(ObserverContext<? extends RegionCoprocessorEnvironment> c, Put put,
    WALEdit edit) throws IOException {
    postPut(c, put, edit, put.getDurability());
  }

  /**
   * Called before the client deletes a value.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in 'delete' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c          the environment provided by the region server
   * @param delete     The Delete object
   * @param edit       The WALEdit object for the wal
   * @param durability Persistence guarantee for this Delete
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #preDelete(ObserverContext, Delete, WALEdit)} instead.
   */
  @Deprecated
  default void preDelete(ObserverContext<? extends RegionCoprocessorEnvironment> c, Delete delete,
    WALEdit edit, Durability durability) throws IOException {
  }

  /**
   * Called before the client deletes a value.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in 'delete' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c      the environment provided by the region server
   * @param delete The Delete object
   * @param edit   The WALEdit object for the wal
   */
  default void preDelete(ObserverContext<? extends RegionCoprocessorEnvironment> c, Delete delete,
    WALEdit edit) throws IOException {
    preDelete(c, delete, edit, delete.getDurability());
  }

  /**
   * Called before the server updates the timestamp for version delete with latest timestamp.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * @param c        the environment provided by the region server
   * @param mutation - the parent mutation associated with this delete cell
   * @param cell     - The deleteColumn with latest version cell
   * @param byteNow  - timestamp bytes
   * @param get      - the get formed using the current cell's row. Note that the get does not
   *                 specify the family and qualifier
   * @deprecated Since hbase-2.0.0. No replacement. To be removed in hbase-4.0.0 and replaced with
   *             something that doesn't expose IntefaceAudience.Private classes.
   *             VisibilityController still needs this, need to change the logic there first.
   */
  @Deprecated
  default void prePrepareTimeStampForDeleteVersion(
    ObserverContext<? extends RegionCoprocessorEnvironment> c, Mutation mutation, Cell cell,
    byte[] byteNow, Get get) throws IOException {
  }

  /**
   * Called after the client deletes a value.
   * <p>
   * Note: Do not retain references to any Cells in 'delete' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c          the environment provided by the region server
   * @param delete     The Delete object
   * @param edit       The WALEdit object for the wal
   * @param durability Persistence guarantee for this Delete
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #postDelete(ObserverContext, Delete, WALEdit)} instead.
   */
  @Deprecated
  default void postDelete(ObserverContext<? extends RegionCoprocessorEnvironment> c, Delete delete,
    WALEdit edit, Durability durability) throws IOException {
  }

  /**
   * Called after the client deletes a value.
   * <p>
   * Note: Do not retain references to any Cells in 'delete' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c      the environment provided by the region server
   * @param delete The Delete object
   * @param edit   The WALEdit object for the wal
   */
  default void postDelete(ObserverContext<? extends RegionCoprocessorEnvironment> c, Delete delete,
    WALEdit edit) throws IOException {
    postDelete(c, delete, edit, delete.getDurability());
  }

  /**
   * This will be called for every batch mutation operation happening at the server. This will be
   * called after acquiring the locks on the mutating rows and after applying the proper timestamp
   * for each Mutation at the server. The batch may contain Put/Delete/Increment/Append. By setting
   * OperationStatus of Mutations
   * ({@link MiniBatchOperationInProgress#setOperationStatus(int, OperationStatus)}),
   * {@link RegionObserver} can make Region to skip these Mutations.
   * <p>
   * Note: Do not retain references to any Cells in Mutations beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c           the environment provided by the region server
   * @param miniBatchOp batch of Mutations getting applied to region.
   */
  default void preBatchMutate(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    MiniBatchOperationInProgress<Mutation> miniBatchOp) throws IOException {
  }

  /**
   * This will be called after applying a batch of Mutations on a region. The Mutations are added to
   * memstore and WAL. The difference of this one with
   * {@link #postPut(ObserverContext, Put, WALEdit)} and
   * {@link #postDelete(ObserverContext, Delete, WALEdit)} and
   * {@link #postIncrement(ObserverContext, Increment, Result, WALEdit)} and
   * {@link #postAppend(ObserverContext, Append, Result, WALEdit)} is this hook will be executed
   * before the mvcc transaction completion.
   * <p>
   * Note: Do not retain references to any Cells in Mutations beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c           the environment provided by the region server
   * @param miniBatchOp batch of Mutations applied to region. Coprocessors are discouraged from
   *                    manipulating its state.
   */
  // Coprocessors can do a form of bypass by changing state in miniBatchOp.
  default void postBatchMutate(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    MiniBatchOperationInProgress<Mutation> miniBatchOp) throws IOException {
  }

  /**
   * This will be called for region operations where read lock is acquired in
   * {@link Region#startRegionOperation()}.
   * @param operation The operation is about to be taken on the region
   */
  default void postStartRegionOperation(ObserverContext<? extends RegionCoprocessorEnvironment> ctx,
    Operation operation) throws IOException {
  }

  /**
   * Called after releasing read lock in {@link Region#closeRegionOperation()}.
   */
  default void postCloseRegionOperation(ObserverContext<? extends RegionCoprocessorEnvironment> ctx,
    Operation operation) throws IOException {
  }

  /**
   * Called after the completion of batch put/delete/increment/append and will be called even if the
   * batch operation fails.
   * <p>
   * Note: Do not retain references to any Cells in Mutations beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param success true if batch operation is successful otherwise false.
   */
  default void postBatchMutateIndispensably(
    ObserverContext<? extends RegionCoprocessorEnvironment> ctx,
    MiniBatchOperationInProgress<Mutation> miniBatchOp, boolean success) throws IOException {
  }

  /**
   * Called before checkAndPut.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in 'put' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c          the environment provided by the region server
   * @param row        row to check
   * @param family     column family
   * @param qualifier  column qualifier
   * @param op         the comparison operation
   * @param comparator the comparator
   * @param put        data to put if check succeeds
   * @param result     the default value of the result
   * @return the return value to return to client if bypassing default processing
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #preCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)}
   *             instead.
   */
  @Deprecated
  default boolean preCheckAndPut(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator,
    Put put, boolean result) throws IOException {
    return result;
  }

  /**
   * Called before checkAndPut.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in 'put' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c      the environment provided by the region server
   * @param row    row to check
   * @param filter filter
   * @param put    data to put if check succeeds
   * @param result the default value of the result
   * @return the return value to return to client if bypassing default processing
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #preCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)}
   *             instead.
   */
  @Deprecated
  default boolean preCheckAndPut(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    byte[] row, Filter filter, Put put, boolean result) throws IOException {
    return result;
  }

  /**
   * Called before checkAndPut but after acquiring rowlock.
   * <p>
   * <b>Note:</b> Caution to be taken for not doing any long time operation in this hook. Row will
   * be locked for longer time. Trying to acquire lock on another row, within this, can lead to
   * potential deadlock.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in 'put' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c          the environment provided by the region server
   * @param row        row to check
   * @param family     column family
   * @param qualifier  column qualifier
   * @param op         the comparison operation
   * @param comparator the comparator
   * @param put        data to put if check succeeds
   * @param result     the default value of the result
   * @return the return value to return to client if bypassing default processing
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #preCheckAndMutateAfterRowLock(ObserverContext, CheckAndMutate,CheckAndMutateResult)}
   *             instead.
   */
  @Deprecated
  default boolean preCheckAndPutAfterRowLock(
    ObserverContext<? extends RegionCoprocessorEnvironment> c, byte[] row, byte[] family,
    byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Put put, boolean result)
    throws IOException {
    return result;
  }

  /**
   * Called before checkAndPut but after acquiring rowlock.
   * <p>
   * <b>Note:</b> Caution to be taken for not doing any long time operation in this hook. Row will
   * be locked for longer time. Trying to acquire lock on another row, within this, can lead to
   * potential deadlock.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in 'put' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c      the environment provided by the region server
   * @param row    row to check
   * @param filter filter
   * @param put    data to put if check succeeds
   * @param result the default value of the result
   * @return the return value to return to client if bypassing default processing
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #preCheckAndMutateAfterRowLock(ObserverContext, CheckAndMutate,CheckAndMutateResult)}
   *             instead.
   */
  @Deprecated
  default boolean preCheckAndPutAfterRowLock(
    ObserverContext<? extends RegionCoprocessorEnvironment> c, byte[] row, Filter filter, Put put,
    boolean result) throws IOException {
    return result;
  }

  /**
   * Called after checkAndPut
   * <p>
   * Note: Do not retain references to any Cells in 'put' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c          the environment provided by the region server
   * @param row        row to check
   * @param family     column family
   * @param qualifier  column qualifier
   * @param op         the comparison operation
   * @param comparator the comparator
   * @param put        data to put if check succeeds
   * @param result     from the checkAndPut
   * @return the possibly transformed return value to return to client
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #postCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)}
   *             instead.
   */
  @Deprecated
  default boolean postCheckAndPut(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator,
    Put put, boolean result) throws IOException {
    return result;
  }

  /**
   * Called after checkAndPut
   * <p>
   * Note: Do not retain references to any Cells in 'put' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c      the environment provided by the region server
   * @param row    row to check
   * @param filter filter
   * @param put    data to put if check succeeds
   * @param result from the checkAndPut
   * @return the possibly transformed return value to return to client
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #postCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)}
   *             instead.
   */
  @Deprecated
  default boolean postCheckAndPut(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    byte[] row, Filter filter, Put put, boolean result) throws IOException {
    return result;
  }

  /**
   * Called before checkAndDelete.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in 'delete' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c          the environment provided by the region server
   * @param row        row to check
   * @param family     column family
   * @param qualifier  column qualifier
   * @param op         the comparison operation
   * @param comparator the comparator
   * @param delete     delete to commit if check succeeds
   * @param result     the default value of the result
   * @return the value to return to client if bypassing default processing
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #preCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)}
   *             instead.
   */
  @Deprecated
  default boolean preCheckAndDelete(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator,
    Delete delete, boolean result) throws IOException {
    return result;
  }

  /**
   * Called before checkAndDelete.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in 'delete' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c      the environment provided by the region server
   * @param row    row to check
   * @param filter column family
   * @param delete delete to commit if check succeeds
   * @param result the default value of the result
   * @return the value to return to client if bypassing default processing
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #preCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)}
   *             instead.
   */
  @Deprecated
  default boolean preCheckAndDelete(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    byte[] row, Filter filter, Delete delete, boolean result) throws IOException {
    return result;
  }

  /**
   * Called before checkAndDelete but after acquiring rowock.
   * <p>
   * <b>Note:</b> Caution to be taken for not doing any long time operation in this hook. Row will
   * be locked for longer time. Trying to acquire lock on another row, within this, can lead to
   * potential deadlock.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in 'delete' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c          the environment provided by the region server
   * @param row        row to check
   * @param family     column family
   * @param qualifier  column qualifier
   * @param op         the comparison operation
   * @param comparator the comparator
   * @param delete     delete to commit if check succeeds
   * @param result     the default value of the result
   * @return the value to return to client if bypassing default processing
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #preCheckAndMutateAfterRowLock(ObserverContext, CheckAndMutate,CheckAndMutateResult)}
   *             instead.
   */
  @Deprecated
  default boolean preCheckAndDeleteAfterRowLock(
    ObserverContext<? extends RegionCoprocessorEnvironment> c, byte[] row, byte[] family,
    byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Delete delete,
    boolean result) throws IOException {
    return result;
  }

  /**
   * Called before checkAndDelete but after acquiring rowock.
   * <p>
   * <b>Note:</b> Caution to be taken for not doing any long time operation in this hook. Row will
   * be locked for longer time. Trying to acquire lock on another row, within this, can lead to
   * potential deadlock.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in 'delete' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c      the environment provided by the region server
   * @param row    row to check
   * @param filter filter
   * @param delete delete to commit if check succeeds
   * @param result the default value of the result
   * @return the value to return to client if bypassing default processing
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #preCheckAndMutateAfterRowLock(ObserverContext, CheckAndMutate,CheckAndMutateResult)}
   *             instead.
   */
  @Deprecated
  default boolean preCheckAndDeleteAfterRowLock(
    ObserverContext<? extends RegionCoprocessorEnvironment> c, byte[] row, Filter filter,
    Delete delete, boolean result) throws IOException {
    return result;
  }

  /**
   * Called after checkAndDelete
   * <p>
   * Note: Do not retain references to any Cells in 'delete' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c          the environment provided by the region server
   * @param row        row to check
   * @param family     column family
   * @param qualifier  column qualifier
   * @param op         the comparison operation
   * @param comparator the comparator
   * @param delete     delete to commit if check succeeds
   * @param result     from the CheckAndDelete
   * @return the possibly transformed returned value to return to client
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #postCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)}
   *             instead.
   */
  @Deprecated
  default boolean postCheckAndDelete(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator,
    Delete delete, boolean result) throws IOException {
    return result;
  }

  /**
   * Called after checkAndDelete
   * <p>
   * Note: Do not retain references to any Cells in 'delete' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c      the environment provided by the region server
   * @param row    row to check
   * @param filter filter
   * @param delete delete to commit if check succeeds
   * @param result from the CheckAndDelete
   * @return the possibly transformed returned value to return to client
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #postCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)}
   *             instead.
   */
  @Deprecated
  default boolean postCheckAndDelete(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    byte[] row, Filter filter, Delete delete, boolean result) throws IOException {
    return result;
  }

  /**
   * Called before checkAndMutate
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in actions beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c              the environment provided by the region server
   * @param checkAndMutate the CheckAndMutate object
   * @param result         the default value of the result
   * @return the return value to return to client if bypassing default processing
   * @throws IOException if an error occurred on the coprocessor
   */
  default CheckAndMutateResult preCheckAndMutate(
    ObserverContext<? extends RegionCoprocessorEnvironment> c, CheckAndMutate checkAndMutate,
    CheckAndMutateResult result) throws IOException {
    if (checkAndMutate.getAction() instanceof Put) {
      boolean success;
      if (checkAndMutate.hasFilter()) {
        success = preCheckAndPut(c, checkAndMutate.getRow(), checkAndMutate.getFilter(),
          (Put) checkAndMutate.getAction(), result.isSuccess());
      } else {
        success = preCheckAndPut(c, checkAndMutate.getRow(), checkAndMutate.getFamily(),
          checkAndMutate.getQualifier(), checkAndMutate.getCompareOp(),
          new BinaryComparator(checkAndMutate.getValue()), (Put) checkAndMutate.getAction(),
          result.isSuccess());
      }
      return new CheckAndMutateResult(success, null);
    } else if (checkAndMutate.getAction() instanceof Delete) {
      boolean success;
      if (checkAndMutate.hasFilter()) {
        success = preCheckAndDelete(c, checkAndMutate.getRow(), checkAndMutate.getFilter(),
          (Delete) checkAndMutate.getAction(), result.isSuccess());
      } else {
        success = preCheckAndDelete(c, checkAndMutate.getRow(), checkAndMutate.getFamily(),
          checkAndMutate.getQualifier(), checkAndMutate.getCompareOp(),
          new BinaryComparator(checkAndMutate.getValue()), (Delete) checkAndMutate.getAction(),
          result.isSuccess());
      }
      return new CheckAndMutateResult(success, null);
    }
    return result;
  }

  /**
   * Called before checkAndDelete but after acquiring rowlock.
   * <p>
   * <b>Note:</b> Caution to be taken for not doing any long time operation in this hook. Row will
   * be locked for longer time. Trying to acquire lock on another row, within this, can lead to
   * potential deadlock.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in actions beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c              the environment provided by the region server
   * @param checkAndMutate the CheckAndMutate object
   * @param result         the default value of the result
   * @return the value to return to client if bypassing default processing
   * @throws IOException if an error occurred on the coprocessor
   */
  default CheckAndMutateResult preCheckAndMutateAfterRowLock(
    ObserverContext<? extends RegionCoprocessorEnvironment> c, CheckAndMutate checkAndMutate,
    CheckAndMutateResult result) throws IOException {
    if (checkAndMutate.getAction() instanceof Put) {
      boolean success;
      if (checkAndMutate.hasFilter()) {
        success = preCheckAndPutAfterRowLock(c, checkAndMutate.getRow(), checkAndMutate.getFilter(),
          (Put) checkAndMutate.getAction(), result.isSuccess());
      } else {
        success = preCheckAndPutAfterRowLock(c, checkAndMutate.getRow(), checkAndMutate.getFamily(),
          checkAndMutate.getQualifier(), checkAndMutate.getCompareOp(),
          new BinaryComparator(checkAndMutate.getValue()), (Put) checkAndMutate.getAction(),
          result.isSuccess());
      }
      return new CheckAndMutateResult(success, null);
    } else if (checkAndMutate.getAction() instanceof Delete) {
      boolean success;
      if (checkAndMutate.hasFilter()) {
        success = preCheckAndDeleteAfterRowLock(c, checkAndMutate.getRow(),
          checkAndMutate.getFilter(), (Delete) checkAndMutate.getAction(), result.isSuccess());
      } else {
        success = preCheckAndDeleteAfterRowLock(c, checkAndMutate.getRow(),
          checkAndMutate.getFamily(), checkAndMutate.getQualifier(), checkAndMutate.getCompareOp(),
          new BinaryComparator(checkAndMutate.getValue()), (Delete) checkAndMutate.getAction(),
          result.isSuccess());
      }
      return new CheckAndMutateResult(success, null);
    }
    return result;
  }

  /**
   * Called after checkAndMutate
   * <p>
   * Note: Do not retain references to any Cells in actions beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c              the environment provided by the region server
   * @param checkAndMutate the CheckAndMutate object
   * @param result         from the checkAndMutate
   * @return the possibly transformed returned value to return to client
   * @throws IOException if an error occurred on the coprocessor
   */
  default CheckAndMutateResult postCheckAndMutate(
    ObserverContext<? extends RegionCoprocessorEnvironment> c, CheckAndMutate checkAndMutate,
    CheckAndMutateResult result) throws IOException {
    if (checkAndMutate.getAction() instanceof Put) {
      boolean success;
      if (checkAndMutate.hasFilter()) {
        success = postCheckAndPut(c, checkAndMutate.getRow(), checkAndMutate.getFilter(),
          (Put) checkAndMutate.getAction(), result.isSuccess());
      } else {
        success = postCheckAndPut(c, checkAndMutate.getRow(), checkAndMutate.getFamily(),
          checkAndMutate.getQualifier(), checkAndMutate.getCompareOp(),
          new BinaryComparator(checkAndMutate.getValue()), (Put) checkAndMutate.getAction(),
          result.isSuccess());
      }
      return new CheckAndMutateResult(success, null);
    } else if (checkAndMutate.getAction() instanceof Delete) {
      boolean success;
      if (checkAndMutate.hasFilter()) {
        success = postCheckAndDelete(c, checkAndMutate.getRow(), checkAndMutate.getFilter(),
          (Delete) checkAndMutate.getAction(), result.isSuccess());
      } else {
        success = postCheckAndDelete(c, checkAndMutate.getRow(), checkAndMutate.getFamily(),
          checkAndMutate.getQualifier(), checkAndMutate.getCompareOp(),
          new BinaryComparator(checkAndMutate.getValue()), (Delete) checkAndMutate.getAction(),
          result.isSuccess());
      }
      return new CheckAndMutateResult(success, null);
    }
    return result;
  }

  /**
   * Called before Append.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in 'append' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c      the environment provided by the region server
   * @param append Append object
   * @return result to return to the client if bypassing default processing
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #preAppend(ObserverContext, Append, WALEdit)} instead.
   */
  @Deprecated
  default Result preAppend(ObserverContext<? extends RegionCoprocessorEnvironment> c, Append append)
    throws IOException {
    return null;
  }

  /**
   * Called before Append.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in 'append' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c      the environment provided by the region server
   * @param append Append object
   * @param edit   The WALEdit object that will be written to the wal
   * @return result to return to the client if bypassing default processing
   */
  default Result preAppend(ObserverContext<? extends RegionCoprocessorEnvironment> c, Append append,
    WALEdit edit) throws IOException {
    return preAppend(c, append);
  }

  /**
   * Called before Append but after acquiring rowlock.
   * <p>
   * <b>Note:</b> Caution to be taken for not doing any long time operation in this hook. Row will
   * be locked for longer time. Trying to acquire lock on another row, within this, can lead to
   * potential deadlock.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in 'append' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c      the environment provided by the region server
   * @param append Append object
   * @return result to return to the client if bypassing default processing
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #preBatchMutate(ObserverContext, MiniBatchOperationInProgress)} instead.
   */
  @Deprecated
  default Result preAppendAfterRowLock(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    Append append) throws IOException {
    return null;
  }

  /**
   * Called after Append
   * <p>
   * Note: Do not retain references to any Cells in 'append' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c      the environment provided by the region server
   * @param append Append object
   * @param result the result returned by increment
   * @return the result to return to the client
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #postAppend(ObserverContext, Append, Result, WALEdit)} instead.
   */
  @Deprecated
  default Result postAppend(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    Append append, Result result) throws IOException {
    return result;
  }

  /**
   * Called after Append
   * <p>
   * Note: Do not retain references to any Cells in 'append' beyond the life of this invocation. If
   * need a Cell reference for later use, copy the cell and use that.
   * @param c      the environment provided by the region server
   * @param append Append object
   * @param result the result returned by increment
   * @param edit   The WALEdit object for the wal
   * @return the result to return to the client
   */
  default Result postAppend(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    Append append, Result result, WALEdit edit) throws IOException {
    return postAppend(c, append, result);
  }

  /**
   * Called before Increment.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in 'increment' beyond the life of this invocation.
   * If need a Cell reference for later use, copy the cell and use that.
   * @param c         the environment provided by the region server
   * @param increment increment object
   * @return result to return to the client if bypassing default processing
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #preIncrement(ObserverContext, Increment, WALEdit)} instead.
   */
  @Deprecated
  default Result preIncrement(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    Increment increment) throws IOException {
    return null;
  }

  /**
   * Called before Increment.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in 'increment' beyond the life of this invocation.
   * If need a Cell reference for later use, copy the cell and use that.
   * @param c         the environment provided by the region server
   * @param increment increment object
   * @param edit      The WALEdit object that will be written to the wal
   * @return result to return to the client if bypassing default processing
   */
  default Result preIncrement(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    Increment increment, WALEdit edit) throws IOException {
    return preIncrement(c, increment);
  }

  /**
   * Called before Increment but after acquiring rowlock.
   * <p>
   * <b>Note:</b> Caution to be taken for not doing any long time operation in this hook. Row will
   * be locked for longer time. Trying to acquire lock on another row, within this, can lead to
   * potential deadlock.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells in 'increment' beyond the life of this invocation.
   * If need a Cell reference for later use, copy the cell and use that.
   * @param c         the environment provided by the region server
   * @param increment increment object
   * @return result to return to the client if bypassing default processing
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #preBatchMutate(ObserverContext, MiniBatchOperationInProgress)} instead.
   */
  @Deprecated
  default Result preIncrementAfterRowLock(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    Increment increment) throws IOException {
    return null;
  }

  /**
   * Called after increment
   * <p>
   * Note: Do not retain references to any Cells in 'increment' beyond the life of this invocation.
   * If need a Cell reference for later use, copy the cell and use that.
   * @param c         the environment provided by the region server
   * @param increment increment object
   * @param result    the result returned by increment
   * @return the result to return to the client
   * @deprecated since 3.0.0 and will be removed in 4.0.0. Use
   *             {@link #postIncrement(ObserverContext, Increment, Result, WALEdit)} instead.
   */
  @Deprecated
  default Result postIncrement(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    Increment increment, Result result) throws IOException {
    return result;
  }

  /**
   * Called after increment
   * <p>
   * Note: Do not retain references to any Cells in 'increment' beyond the life of this invocation.
   * If need a Cell reference for later use, copy the cell and use that.
   * @param c         the environment provided by the region server
   * @param increment increment object
   * @param result    the result returned by increment
   * @param edit      The WALEdit object for the wal
   * @return the result to return to the client
   */
  default Result postIncrement(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    Increment increment, Result result, WALEdit edit) throws IOException {
    return postIncrement(c, increment, result);
  }

  /**
   * Called before the client opens a new scanner.
   * <p>
   * Note: Do not retain references to any Cells returned by scanner, beyond the life of this
   * invocation. If need a Cell reference for later use, copy the cell and use that.
   * @param c    the environment provided by the region server
   * @param scan the Scan specification
   */
  default void preScannerOpen(ObserverContext<? extends RegionCoprocessorEnvironment> c, Scan scan)
    throws IOException {
  }

  /**
   * Called after the client opens a new scanner.
   * <p>
   * Note: Do not retain references to any Cells returned by scanner, beyond the life of this
   * invocation. If need a Cell reference for later use, copy the cell and use that.
   * @param c    the environment provided by the region server
   * @param scan the Scan specification
   * @param s    if not null, the base scanner
   * @return the scanner instance to use
   */
  default RegionScanner postScannerOpen(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    Scan scan, RegionScanner s) throws IOException {
    return s;
  }

  /**
   * Called before the client asks for the next row on a scanner.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * <p>
   * Note: Do not retain references to any Cells returned by scanner, beyond the life of this
   * invocation. If need a Cell reference for later use, copy the cell and use that.
   * @param c       the environment provided by the region server
   * @param s       the scanner
   * @param result  The result to return to the client if default processing is bypassed. Can be
   *                modified. Will not be returned if default processing is not bypassed.
   * @param limit   the maximum number of results to return
   * @param hasNext the 'has more' indication
   * @return 'has more' indication that should be sent to client
   */
  default boolean preScannerNext(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    InternalScanner s, List<Result> result, int limit, boolean hasNext) throws IOException {
    return hasNext;
  }

  /**
   * Called after the client asks for the next row on a scanner.
   * <p>
   * Note: Do not retain references to any Cells returned by scanner, beyond the life of this
   * invocation. If need a Cell reference for later use, copy the cell and use that.
   * @param c       the environment provided by the region server
   * @param s       the scanner
   * @param result  the result to return to the client, can be modified
   * @param limit   the maximum number of results to return
   * @param hasNext the 'has more' indication
   * @return 'has more' indication that should be sent to client
   */
  default boolean postScannerNext(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    InternalScanner s, List<Result> result, int limit, boolean hasNext) throws IOException {
    return hasNext;
  }

  /**
   * This will be called by the scan flow when the current scanned row is being filtered out by the
   * filter. The filter may be filtering out the row via any of the below scenarios
   * <ol>
   * <li><code>boolean filterRowKey(byte [] buffer, int offset, int length)</code> returning
   * true</li>
   * <li><code>boolean filterRow()</code> returning true</li>
   * <li><code>default void filterRow(List&lt;KeyValue&gt; kvs)</code> removing all the kvs from the
   * passed List</li>
   * </ol>
   * <p>
   * Note: Do not retain references to any Cells returned by scanner, beyond the life of this
   * invocation. If need a Cell reference for later use, copy the cell and use that.
   * @param c          the environment provided by the region server
   * @param s          the scanner
   * @param curRowCell The cell in the current row which got filtered out
   * @param hasMore    the 'has more' indication
   * @return whether more rows are available for the scanner or not
   */
  default boolean postScannerFilterRow(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    InternalScanner s, Cell curRowCell, boolean hasMore) throws IOException {
    return hasMore;
  }

  /**
   * Called before the client closes a scanner.
   * <p>
   * Call CoprocessorEnvironment#bypass to skip default actions. If 'bypass' is set, we skip out on
   * calling any subsequent chained coprocessors.
   * @param c the environment provided by the region server
   * @param s the scanner
   */
  default void preScannerClose(ObserverContext<? extends RegionCoprocessorEnvironment> c,
    InternalScanner s) throws IOException {
  }

  /**
   * Called after the client closes a scanner.
   * @param ctx the environment provided by the region server
   * @param s   the scanner
   */
  default void postScannerClose(ObserverContext<? extends RegionCoprocessorEnvironment> ctx,
    InternalScanner s) throws IOException {
  }

  /**
   * Called before a store opens a new scanner.
   * <p>
   * This hook is called when a "user" scanner is opened. Use {@code preFlushScannerOpen} and
   * {@code preCompactScannerOpen} to inject flush/compaction.
   * <p>
   * Notice that, this method is used to change the inherent max versions and TTL for a Store. For
   * example, you can change the max versions option for a {@link Scan} object to 10 in
   * {@code preScannerOpen}, but if the max versions config on the Store is 1, then you still can
   * only read 1 version. You need also to inject here to change the max versions to 10 if you want
   * to get more versions.
   * @param ctx     the environment provided by the region server
   * @param store   the store which we want to get scanner from
   * @param options used to change max versions and TTL for the scanner being opened
   * @see #preFlushScannerOpen(ObserverContext, Store, ScanOptions, FlushLifeCycleTracker)
   * @see #preCompactScannerOpen(ObserverContext, Store, ScanType, ScanOptions,
   *      CompactionLifeCycleTracker, CompactionRequest)
   */
  default void preStoreScannerOpen(ObserverContext<? extends RegionCoprocessorEnvironment> ctx,
    Store store, ScanOptions options) throws IOException {
  }

  /**
   * Called before replaying WALs for this region. Calling
   * {@link org.apache.hadoop.hbase.coprocessor.ObserverContext#bypass()} has no effect in this
   * hook.
   * @param ctx   the environment provided by the region server
   * @param info  the RegionInfo for this region
   * @param edits the file of recovered edits
   */
  // todo: what about these?
  default void preReplayWALs(ObserverContext<? extends RegionCoprocessorEnvironment> ctx,
    RegionInfo info, Path edits) throws IOException {
  }

  /**
   * Called after replaying WALs for this region.
   * @param ctx   the environment provided by the region server
   * @param info  the RegionInfo for this region
   * @param edits the file of recovered edits
   */
  default void postReplayWALs(ObserverContext<? extends RegionCoprocessorEnvironment> ctx,
    RegionInfo info, Path edits) throws IOException {
  }

  /**
   * Called before bulkLoadHFile. Users can create a StoreFile instance to access the contents of a
   * HFile.
   * @param ctx         the environment provided by the region server
   * @param familyPaths pairs of { CF, HFile path } submitted for bulk load. Adding or removing from
   *                    this list will add or remove HFiles to be bulk loaded.
   */
  default void preBulkLoadHFile(ObserverContext<? extends RegionCoprocessorEnvironment> ctx,
    List<Pair<byte[], String>> familyPaths) throws IOException {
  }

  /**
   * Called before moving bulk loaded hfile to region directory.
   * @param ctx    the environment provided by the region server
   * @param family column family
   * @param pairs  List of pairs of { HFile location in staging dir, HFile path in region dir } Each
   *               pair are for the same hfile.
   */
  default void preCommitStoreFile(ObserverContext<? extends RegionCoprocessorEnvironment> ctx,
    byte[] family, List<Pair<Path, Path>> pairs) throws IOException {
  }

  /**
   * Called after moving bulk loaded hfile to region directory.
   * @param ctx     the environment provided by the region server
   * @param family  column family
   * @param srcPath Path to file before the move
   * @param dstPath Path to file after the move
   */
  default void postCommitStoreFile(ObserverContext<? extends RegionCoprocessorEnvironment> ctx,
    byte[] family, Path srcPath, Path dstPath) throws IOException {
  }

  /**
   * Called after bulkLoadHFile.
   * @param ctx                the environment provided by the region server
   * @param stagingFamilyPaths pairs of { CF, HFile path } submitted for bulk load
   * @param finalPaths         Map of CF to List of file paths for the loaded files if the Map is
   *                           not null, the bulkLoad was successful. Otherwise the bulk load
   *                           failed. bulkload is done by the time this hook is called.
   */
  default void postBulkLoadHFile(ObserverContext<? extends RegionCoprocessorEnvironment> ctx,
    List<Pair<byte[], String>> stagingFamilyPaths, Map<byte[], List<Path>> finalPaths)
    throws IOException {
  }

  /**
   * Called before creation of Reader for a store file. Calling
   * {@link org.apache.hadoop.hbase.coprocessor.ObserverContext#bypass()} has no effect in this
   * hook.
   * @param ctx    the environment provided by the region server
   * @param fs     fileystem to read from
   * @param p      path to the file
   * @param in     {@link FSDataInputStreamWrapper}
   * @param size   Full size of the file
   * @param r      original reference file. This will be not null only when reading a split file.
   * @param reader the base reader, if not {@code null}, from previous RegionObserver in the chain
   * @return a Reader instance to use instead of the base reader if overriding default behavior,
   *         null otherwise
   * @deprecated For Phoenix only, StoreFileReader is not a stable interface.
   */
  @Deprecated
  // Passing InterfaceAudience.Private args FSDataInputStreamWrapper, CacheConfig and Reference.
  // This is fine as the hook is deprecated any way.
  default StoreFileReader preStoreFileReaderOpen(
    ObserverContext<? extends RegionCoprocessorEnvironment> ctx, FileSystem fs, Path p,
    FSDataInputStreamWrapper in, long size, CacheConfig cacheConf, Reference r,
    StoreFileReader reader) throws IOException {
    return reader;
  }

  /**
   * Called after the creation of Reader for a store file.
   * @param ctx    the environment provided by the region server
   * @param fs     fileystem to read from
   * @param p      path to the file
   * @param in     {@link FSDataInputStreamWrapper}
   * @param size   Full size of the file
   * @param r      original reference file. This will be not null only when reading a split file.
   * @param reader the base reader instance
   * @return The reader to use
   * @deprecated For Phoenix only, StoreFileReader is not a stable interface.
   */
  @Deprecated
  // Passing InterfaceAudience.Private args FSDataInputStreamWrapper, CacheConfig and Reference.
  // This is fine as the hook is deprecated any way.
  default StoreFileReader postStoreFileReaderOpen(
    ObserverContext<? extends RegionCoprocessorEnvironment> ctx, FileSystem fs, Path p,
    FSDataInputStreamWrapper in, long size, CacheConfig cacheConf, Reference r,
    StoreFileReader reader) throws IOException {
    return reader;
  }

  /**
   * Called after a new cell has been created during an increment operation, but before it is
   * committed to the WAL or memstore. Calling
   * {@link org.apache.hadoop.hbase.coprocessor.ObserverContext#bypass()} has no effect in this
   * hook.
   * @param ctx      the environment provided by the region server
   * @param opType   the operation type
   * @param mutation the current mutation
   * @param oldCell  old cell containing previous value
   * @param newCell  the new cell containing the computed value
   * @return the new cell, possibly changed
   * @deprecated since 2.2.0 and will be removedin 4.0.0. Use
   *             {@link #postIncrementBeforeWAL(ObserverContext, Mutation, List)} or
   *             {@link #postAppendBeforeWAL(ObserverContext, Mutation, List)} instead.
   * @see #postIncrementBeforeWAL(ObserverContext, Mutation, List)
   * @see #postAppendBeforeWAL(ObserverContext, Mutation, List)
   * @see <a href="https://issues.apache.org/jira/browse/HBASE-21643">HBASE-21643</a>
   */
  @Deprecated
  default Cell postMutationBeforeWAL(ObserverContext<? extends RegionCoprocessorEnvironment> ctx,
    MutationType opType, Mutation mutation, Cell oldCell, Cell newCell) throws IOException {
    return newCell;
  }

  /**
   * Called after a list of new cells has been created during an increment operation, but before
   * they are committed to the WAL or memstore.
   * @param ctx       the environment provided by the region server
   * @param mutation  the current mutation
   * @param cellPairs a list of cell pair. The first cell is old cell which may be null. And the
   *                  second cell is the new cell.
   * @return a list of cell pair, possibly changed.
   */
  default List<Pair<Cell, Cell>> postIncrementBeforeWAL(
    ObserverContext<? extends RegionCoprocessorEnvironment> ctx, Mutation mutation,
    List<Pair<Cell, Cell>> cellPairs) throws IOException {
    List<Pair<Cell, Cell>> resultPairs = new ArrayList<>(cellPairs.size());
    for (Pair<Cell, Cell> pair : cellPairs) {
      resultPairs.add(new Pair<>(pair.getFirst(), postMutationBeforeWAL(ctx, MutationType.INCREMENT,
        mutation, pair.getFirst(), pair.getSecond())));
    }
    return resultPairs;
  }

  /**
   * Called after a list of new cells has been created during an append operation, but before they
   * are committed to the WAL or memstore.
   * @param ctx       the environment provided by the region server
   * @param mutation  the current mutation
   * @param cellPairs a list of cell pair. The first cell is old cell which may be null. And the
   *                  second cell is the new cell.
   * @return a list of cell pair, possibly changed.
   */
  default List<Pair<Cell, Cell>> postAppendBeforeWAL(
    ObserverContext<? extends RegionCoprocessorEnvironment> ctx, Mutation mutation,
    List<Pair<Cell, Cell>> cellPairs) throws IOException {
    List<Pair<Cell, Cell>> resultPairs = new ArrayList<>(cellPairs.size());
    for (Pair<Cell, Cell> pair : cellPairs) {
      resultPairs.add(new Pair<>(pair.getFirst(), postMutationBeforeWAL(ctx, MutationType.APPEND,
        mutation, pair.getFirst(), pair.getSecond())));
    }
    return resultPairs;
  }

  /**
   * Called after the ScanQueryMatcher creates ScanDeleteTracker. Implementing this hook would help
   * in creating customised DeleteTracker and returning the newly created DeleteTracker
   * <p>
   * Warn: This is used by internal coprocessors. Should not be implemented by user coprocessors
   * @param ctx        the environment provided by the region server
   * @param delTracker the deleteTracker that is created by the QueryMatcher
   * @return the Delete Tracker
   * @deprecated Since 2.0.0, will be removed in 4.0.0. Visibility label feature still use this
   *             method, so it can not be removed in 3.0.0
   */
  @Deprecated
  default DeleteTracker postInstantiateDeleteTracker(
    ObserverContext<? extends RegionCoprocessorEnvironment> ctx, DeleteTracker delTracker)
    throws IOException {
    return delTracker;
  }

  /**
   * Called just before the WAL Entry is appended to the WAL. Implementing this hook allows
   * coprocessors to add extended attributes to the WALKey that then get persisted to the WAL, and
   * are available to replication endpoints to use in processing WAL Entries.
   * @param ctx the environment provided by the region server
   * @param key the WALKey associated with a particular append to a WAL
   */
  default void preWALAppend(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, WALKey key,
    WALEdit edit) throws IOException {
  }
}