org.apache.hadoop.hbase.replication.regionserver

Class TestReplicator.FailureInjectingReplicationEndpointForTest.FailureInjectingReplicatorForTest

java.lang.Object

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

org.apache.hadoop.hbase.replication.regionserver.TestReplicator.FailureInjectingReplicationEndpointForTest.FailureInjectingReplicatorForTest

All Implemented Interfaces:

Callable<Integer>

Enclosing class:

TestReplicator.FailureInjectingReplicationEndpointForTest

public class TestReplicator.FailureInjectingReplicationEndpointForTest.FailureInjectingReplicatorForTest
extends TestReplicator.ReplicationEndpointForTest.ReplicatorForTest

Constructor Summary

Constructors

Constructor and Description
FailureInjectingReplicatorForTest(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

FailureInjectingReplicatorForTest

public FailureInjectingReplicatorForTest(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

Overrides:

replicateEntries in class TestReplicator.ReplicationEndpointForTest.ReplicatorForTest

Throws:

IOException