Package org.apache.hadoop.hbase.replication

Class TestReplicationWithWALExtendedAttributes.TestReplicationSinkRegionServerEndpoint

java.lang.Object
org.apache.hadoop.hbase.replication.TestReplicationWithWALExtendedAttributes.TestReplicationSinkRegionServerEndpoint
All Implemented Interfaces:
org.apache.hadoop.hbase.Coprocessor, org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessor, org.apache.hadoop.hbase.coprocessor.RegionServerObserver
Enclosing class:
TestReplicationWithWALExtendedAttributes
public static final class TestReplicationWithWALExtendedAttributes.TestReplicationSinkRegionServerEndpoint extends Object implements org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessor, org.apache.hadoop.hbase.coprocessor.RegionServerObserver

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.Coprocessor

    org.apache.hadoop.hbase.Coprocessor.State

  • Field Summary

    Fields inherited from interface org.apache.hadoop.hbase.Coprocessor

    PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

  • Constructor Summary

    Constructors
    Constructor
    Description
    TestReplicationSinkRegionServerEndpoint()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    private void
    attachWALExtendedAttributesToMutation(org.apache.hadoop.hbase.client.Mutation mutation, List<org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.Attribute> attributeList)
     
    Optional<org.apache.hadoop.hbase.coprocessor.RegionServerObserver>
    getRegionServerObserver()
     
    void
    postReplicationSinkBatchMutate(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessorEnvironment> ctx, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry walEntry, org.apache.hadoop.hbase.client.Mutation mutation)
     
    void
    preReplicationSinkBatchMutate(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessorEnvironment> ctx, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry walEntry, org.apache.hadoop.hbase.client.Mutation mutation)
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.apache.hadoop.hbase.Coprocessor

    getServices, start, stop

    Methods inherited from interface org.apache.hadoop.hbase.coprocessor.RegionServerObserver

    postClearCompactionQueues, postClearRegionBlockCache, postCreateReplicationEndPoint, postExecuteProcedures, postReplicateLogEntries, postRollWALWriterRequest, postUpdateRegionServerConfiguration, preClearCompactionQueues, preClearRegionBlockCache, preExecuteProcedures, preReplicateLogEntries, preRollWALWriterRequest, preStopRegionServer, preUpdateRegionServerConfiguration

  • Constructor Details

  • Method Details

    • getRegionServerObserver

      public Optional<org.apache.hadoop.hbase.coprocessor.RegionServerObserver> getRegionServerObserver()
      Specified by:
      getRegionServerObserver in interface org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessor

    • preReplicationSinkBatchMutate

      public void preReplicationSinkBatchMutate(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessorEnvironment> ctx, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry walEntry, org.apache.hadoop.hbase.client.Mutation mutation) throws IOException
      Specified by:
      preReplicationSinkBatchMutate in interface org.apache.hadoop.hbase.coprocessor.RegionServerObserver
      Throws:
      IOException

    • postReplicationSinkBatchMutate

      public void postReplicationSinkBatchMutate(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessorEnvironment> ctx, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry walEntry, org.apache.hadoop.hbase.client.Mutation mutation) throws IOException
      Specified by:
      postReplicationSinkBatchMutate in interface org.apache.hadoop.hbase.coprocessor.RegionServerObserver
      Throws:
      IOException

    • attachWALExtendedAttributesToMutation

      private void attachWALExtendedAttributesToMutation(org.apache.hadoop.hbase.client.Mutation mutation, List<org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.Attribute> attributeList)