public class HFileReplicator
extends java.lang.Object
LoadIncrementalHFiles
to prepare a collection of
LoadIncrementalHFiles.LoadQueueItem
which will finally be loaded(replicated) into the table of this cluster.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 and Description |
---|
HFileReplicator(Configuration sourceClusterConf,
java.lang.String sourceBaseNamespaceDirPath,
java.lang.String sourceHFileArchiveDirPath,
java.util.Map<java.lang.String,java.util.List<<any>>> tableQueueMap,
Configuration conf,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
java.lang.Void |
replicate() |
public static final java.lang.String REPLICATION_BULKLOAD_COPY_MAXTHREADS_KEY
public static final int REPLICATION_BULKLOAD_COPY_MAXTHREADS_DEFAULT
public static final java.lang.String REPLICATION_BULKLOAD_COPY_HFILES_PERTHREAD_KEY
public static final int REPLICATION_BULKLOAD_COPY_HFILES_PERTHREAD_DEFAULT
public HFileReplicator(Configuration sourceClusterConf, java.lang.String sourceBaseNamespaceDirPath, java.lang.String sourceHFileArchiveDirPath, java.util.Map<java.lang.String,java.util.List<<any>>> tableQueueMap, Configuration conf, Connection connection) throws java.io.IOException
java.io.IOException