org.apache.hadoop.hbase.replication.regionserver

Class HBaseInterClusterReplicationEndpoint.Replicator

java.lang.Object

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

All Implemented Interfaces:

java.util.concurrent.Callable<java.lang.Integer>

Enclosing class:

HBaseInterClusterReplicationEndpoint

protected class HBaseInterClusterReplicationEndpoint.Replicator
extends java.lang.Object
implements java.util.concurrent.Callable<java.lang.Integer>

Constructor Summary

Constructors

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

Method Summary

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

Replicator

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

Method Detail

replicateEntries

protected void replicateEntries(BlockingInterface rrs,
                                java.util.List<Entry> batch,
                                java.lang.String replicationClusterId,
                                Path baseNamespaceDir,
                                Path hfileArchiveDir)
                         throws java.io.IOException

Throws:

java.io.IOException

call

public java.lang.Integer call()
                       throws java.io.IOException

Specified by:

call in interface java.util.concurrent.Callable<java.lang.Integer>

Throws:

java.io.IOException