org.apache.hadoop.hbase.replication.regionserver

Class TestReplicator.ReplicationEndpointForTest.ReplicatorForTest

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.TestReplicator.ReplicationEndpointForTest.ReplicatorForTest

All Implemented Interfaces:

Callable<Integer>

Direct Known Subclasses:

TestReplicator.FailureInjectingReplicationEndpointForTest.FailureInjectingReplicatorForTest

Enclosing class:

TestReplicator.ReplicationEndpointForTest

public class TestReplicator.ReplicationEndpointForTest.ReplicatorForTest
extends Object

Constructor Summary

Constructors

Constructor and Description
ReplicatorForTest(List<org.apache.hadoop.hbase.wal.WAL.Entry> entries, int ordinal)

Method Summary

Modifier and Type	Method and Description
protected void	replicateEntries(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface rrs, List<org.apache.hadoop.hbase.wal.WAL.Entry> entries, String replicationClusterId, org.apache.hadoop.fs.Path baseNamespaceDir, org.apache.hadoop.fs.Path hfileArchiveDir)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicatorForTest

public ReplicatorForTest(List<org.apache.hadoop.hbase.wal.WAL.Entry> entries,
                         int ordinal)

Method Detail

replicateEntries

protected void replicateEntries(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface rrs,
                                List<org.apache.hadoop.hbase.wal.WAL.Entry> entries,
                                String replicationClusterId,
                                org.apache.hadoop.fs.Path baseNamespaceDir,
                                org.apache.hadoop.fs.Path hfileArchiveDir)
                         throws IOException

Throws:

IOException