protected class HBaseInterClusterReplicationEndpoint.Replicator
extends java.lang.Object
implements java.util.concurrent.Callable<java.lang.Integer>
Constructor and Description |
---|
Replicator(java.util.List<Entry> entries,
int ordinal) |
Modifier and Type | Method and Description |
---|---|
java.lang.Integer |
call() |
protected void |
replicateEntries(BlockingInterface rrs,
java.util.List<Entry> batch,
java.lang.String replicationClusterId,
Path baseNamespaceDir,
Path hfileArchiveDir) |
protected void replicateEntries(BlockingInterface rrs, java.util.List<Entry> batch, java.lang.String replicationClusterId, Path baseNamespaceDir, Path hfileArchiveDir) throws java.io.IOException
java.io.IOException
public java.lang.Integer call() throws java.io.IOException
call
in interface java.util.concurrent.Callable<java.lang.Integer>
java.io.IOException