org.apache.hadoop.hbase.replication.regionserver

Class HBaseInterClusterReplicationEndpoint.Replicator

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.HBaseInterClusterReplicationEndpoint.Replicator

All Implemented Interfaces:

Callable<Integer>

Enclosing class:

HBaseInterClusterReplicationEndpoint

protected class HBaseInterClusterReplicationEndpoint.Replicator
extends Object
implements Callable<Integer>

Field Summary

Fields

Modifier and Type	Field and Description
private List<WAL.Entry>	entries
private int	ordinal

Constructor Summary

Constructors

Constructor and Description
Replicator(List<WAL.Entry> entries, int ordinal)

Method Summary

Modifier and Type	Method and Description
Integer	call()
protected void	replicateEntries(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface rrs, List<WAL.Entry> batch, 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

Field Detail

entries

private List<WAL.Entry> entries

ordinal

private int ordinal

Constructor Detail

Replicator

public Replicator(List<WAL.Entry> entries,
                  int ordinal)

Method Detail

replicateEntries

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

Throws:

IOException

call

public Integer call()
             throws IOException

Specified by:

call in interface Callable<Integer>

Throws:

IOException