public static final class TestReplicationWithWALExtendedAttributes.TestReplicationSinkRegionServerEndpoint extends Object implements org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessor, org.apache.hadoop.hbase.coprocessor.RegionServerObserver
Constructor and Description |
---|
TestReplicationSinkRegionServerEndpoint() |
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
postClearCompactionQueues, postCreateReplicationEndPoint, postExecuteProcedures, postReplicateLogEntries, postRollWALWriterRequest, preClearCompactionQueues, preExecuteProcedures, preReplicateLogEntries, preRollWALWriterRequest, preStopRegionServer
public TestReplicationSinkRegionServerEndpoint()
public Optional<org.apache.hadoop.hbase.coprocessor.RegionServerObserver> getRegionServerObserver()
getRegionServerObserver
in interface org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessor
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
preReplicationSinkBatchMutate
in interface org.apache.hadoop.hbase.coprocessor.RegionServerObserver
IOException
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
postReplicationSinkBatchMutate
in interface org.apache.hadoop.hbase.coprocessor.RegionServerObserver
IOException
private void attachWALExtendedAttributesToMutation(org.apache.hadoop.hbase.client.Mutation mutation, List<org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.Attribute> attributeList)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.