@InterfaceAudience.Private public class HFileReplicator extends 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 String |
REPLICATION_BULKLOAD_COPY_HFILES_PERTHREAD_KEY
Number of hfiles to copy per thread during replication
|
static int |
REPLICATION_BULKLOAD_COPY_MAXTHREADS_DEFAULT |
static String |
REPLICATION_BULKLOAD_COPY_MAXTHREADS_KEY
Maximum number of threads to allow in pool to copy hfiles during replication
|
Constructor and Description |
---|
HFileReplicator(org.apache.hadoop.conf.Configuration sourceClusterConf,
String sourceBaseNamespaceDirPath,
String sourceHFileArchiveDirPath,
Map<String,List<Pair<byte[],List<String>>>> tableQueueMap,
org.apache.hadoop.conf.Configuration conf,
Connection connection,
List<String> sourceClusterIds) |
public static final String REPLICATION_BULKLOAD_COPY_MAXTHREADS_KEY
public static final int REPLICATION_BULKLOAD_COPY_MAXTHREADS_DEFAULT
public static final String REPLICATION_BULKLOAD_COPY_HFILES_PERTHREAD_KEY
public static final int REPLICATION_BULKLOAD_COPY_HFILES_PERTHREAD_DEFAULT
public HFileReplicator(org.apache.hadoop.conf.Configuration sourceClusterConf, String sourceBaseNamespaceDirPath, String sourceHFileArchiveDirPath, Map<String,List<Pair<byte[],List<String>>>> tableQueueMap, org.apache.hadoop.conf.Configuration conf, Connection connection, List<String> sourceClusterIds) throws IOException
IOException
public Void replicate() throws IOException
IOException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.