org.apache.hadoop.hbase.replication.regionserver

Class HFileReplicator

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.HFileReplicator

@InterfaceAudience.Private
public class HFileReplicator
extends java.lang.Object

It is used for replicating HFile entries. It will first copy parallely all the hfiles to a local staging directory and then it will use (LoadIncrementalHFiles to prepare a collection of LoadIncrementalHFiles.LoadQueueItem which will finally be loaded(replicated) into the table of this cluster.

Field Summary

Fields

Modifier and Type	Field and Description
static int	REPLICATION_BULKLOAD_COPY_HFILES_PERTHREAD_DEFAULT
static java.lang.String	REPLICATION_BULKLOAD_COPY_HFILES_PERTHREAD_KEY Number of hfiles to copy per thread during replication
static int	REPLICATION_BULKLOAD_COPY_MAXTHREADS_DEFAULT
static java.lang.String	REPLICATION_BULKLOAD_COPY_MAXTHREADS_KEY Maximum number of threads to allow in pool to copy hfiles during replication

Constructor Summary

Constructors

Constructor and Description
HFileReplicator(Configuration sourceClusterConf, java.lang.String sourceBaseNamespaceDirPath, java.lang.String sourceHFileArchiveDirPath, java.util.Map<java.lang.String,java.util.List<Pair<byte[],java.util.List<java.lang.String>>>> tableQueueMap, Configuration conf, Connection connection)

Method Summary

Modifier and Type	Method and Description
java.lang.Void	replicate()

Methods inherited from class java.lang.Object

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

Field Detail

REPLICATION_BULKLOAD_COPY_MAXTHREADS_KEY

public static final java.lang.String REPLICATION_BULKLOAD_COPY_MAXTHREADS_KEY

Maximum number of threads to allow in pool to copy hfiles during replication

See Also:

Constant Field Values

REPLICATION_BULKLOAD_COPY_MAXTHREADS_DEFAULT

public static final int REPLICATION_BULKLOAD_COPY_MAXTHREADS_DEFAULT

See Also:

Constant Field Values

REPLICATION_BULKLOAD_COPY_HFILES_PERTHREAD_KEY

public static final java.lang.String REPLICATION_BULKLOAD_COPY_HFILES_PERTHREAD_KEY

Number of hfiles to copy per thread during replication

See Also:

Constant Field Values

REPLICATION_BULKLOAD_COPY_HFILES_PERTHREAD_DEFAULT

public static final int REPLICATION_BULKLOAD_COPY_HFILES_PERTHREAD_DEFAULT

See Also:

Constant Field Values

Constructor Detail

HFileReplicator

public HFileReplicator(Configuration sourceClusterConf,
                       java.lang.String sourceBaseNamespaceDirPath,
                       java.lang.String sourceHFileArchiveDirPath,
                       java.util.Map<java.lang.String,java.util.List<Pair<byte[],java.util.List<java.lang.String>>>> tableQueueMap,
                       Configuration conf,
                       Connection connection)
                throws java.io.IOException

Throws:

java.io.IOException

Method Detail

replicate

public java.lang.Void replicate()
                         throws java.io.IOException

Throws:

java.io.IOException