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 and Description
TestReplicationSinkRegionServerEndpoint()

Method Summary

Modifier and Type	Method and 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, postCreateReplicationEndPoint, postExecuteProcedures, postReplicateLogEntries, postRollWALWriterRequest, preClearCompactionQueues, preExecuteProcedures, preReplicateLogEntries, preRollWALWriterRequest, preStopRegionServer

Constructor Detail

TestReplicationSinkRegionServerEndpoint

public TestReplicationSinkRegionServerEndpoint()

Method Detail

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)