Package org.apache.hadoop.hbase.backup

Class PITRTestUtil

java.lang.Object

org.apache.hadoop.hbase.backup.PITRTestUtil

@Private
public final class PITRTestUtil
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	DEFAULT_WAIT_FOR_REPLICATION_MS
private static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Modifier	Constructor	Description
private	PITRTestUtil()

Method Summary

Modifier and Type	Method	Description
static String[]	buildBackupArgs(String backupType, org.apache.hadoop.hbase.TableName[] tables, boolean continuousEnabled, String backupRootDir)
static String[]	buildPITRArgs(org.apache.hadoop.hbase.TableName[] sourceTables, org.apache.hadoop.hbase.TableName[] targetTables, long endTime, String backupRootDir)
static void	bulkLoadHFiles(org.apache.hadoop.hbase.TableName tableName, org.apache.hadoop.fs.Path inputDir, org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.conf.Configuration conf)
static void	generateHFiles(org.apache.hadoop.fs.Path outputDir, org.apache.hadoop.conf.Configuration conf, String cfName)
static int	getRowCount(HBaseTestingUtil testUtil, org.apache.hadoop.hbase.TableName tableName)
static void	loadRandomData(HBaseTestingUtil testUtil, org.apache.hadoop.hbase.TableName tableName, byte[] family, int totalRows)
static void	waitForReplication()

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

DEFAULT_WAIT_FOR_REPLICATION_MS

private static final int DEFAULT_WAIT_FOR_REPLICATION_MS

See Also:

• Constant Field Values

Constructor Details

PITRTestUtil

private PITRTestUtil()

Method Details

buildPITRArgs

public static String[] buildPITRArgs(org.apache.hadoop.hbase.TableName[] sourceTables,
 org.apache.hadoop.hbase.TableName[] targetTables,
 long endTime,
 String backupRootDir)

buildBackupArgs

public static String[] buildBackupArgs(String backupType,
 org.apache.hadoop.hbase.TableName[] tables,
 boolean continuousEnabled,
 String backupRootDir)

loadRandomData

public static void loadRandomData(HBaseTestingUtil testUtil,
 org.apache.hadoop.hbase.TableName tableName,
 byte[] family,
 int totalRows)
                           throws IOException

Throws:

IOException

waitForReplication

public static void waitForReplication()

getRowCount

public static int getRowCount(HBaseTestingUtil testUtil,
 org.apache.hadoop.hbase.TableName tableName)
                       throws IOException

Throws:

IOException

generateHFiles

public static void generateHFiles(org.apache.hadoop.fs.Path outputDir,
 org.apache.hadoop.conf.Configuration conf,
 String cfName)
                           throws IOException

Throws:

IOException

bulkLoadHFiles

public static void bulkLoadHFiles(org.apache.hadoop.hbase.TableName tableName,
 org.apache.hadoop.fs.Path inputDir,
 org.apache.hadoop.hbase.client.Connection conn,
 org.apache.hadoop.conf.Configuration conf)
                           throws IOException

Throws:

IOException