Package org.apache.hadoop.hbase.mapreduce

Class TestSyncTable

java.lang.Object

org.apache.hadoop.hbase.mapreduce.TestSyncTable

public class TestSyncTable
extends Object

Basic test for the SyncTable M/R tool

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static final org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static final HBaseTestingUtil	UTIL1
private static final HBaseTestingUtil	UTIL2

Constructor Summary

Constructors

Constructor	Description
TestSyncTable()

Method Summary

Modifier and Type	Method	Description
static void	afterClass()
private void	assertCellEquals(org.apache.hadoop.hbase.Cell sourceCell, org.apache.hadoop.hbase.Cell targetCell, BooleanSupplier checkTimestamp)
private void	assertEqualTables(int expectedRows, HBaseTestingUtil sourceCluster, org.apache.hadoop.hbase.TableName sourceTableName, HBaseTestingUtil targetCluster, org.apache.hadoop.hbase.TableName targetTableName, boolean ignoreTimestamps)
private void	assertTargetDoDeletesFalse(int expectedRows, HBaseTestingUtil sourceCluster, org.apache.hadoop.hbase.TableName sourceTableName, HBaseTestingUtil targetCluster, org.apache.hadoop.hbase.TableName targetTableName)
private void	assertTargetDoPutsFalse(int expectedRows, HBaseTestingUtil sourceCluster, org.apache.hadoop.hbase.TableName sourceTableName, HBaseTestingUtil targetCluster, org.apache.hadoop.hbase.TableName targetTableName)
static void	beforeClass()
private static byte[][]	generateSplits(int numRows, int numRegions)
private void	hashSourceTable(HBaseTestingUtil sourceCluster, org.apache.hadoop.hbase.TableName sourceTableName, org.apache.hadoop.fs.Path testDir, String... options)
private org.apache.hadoop.mapreduce.Counters	syncTables(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.TableName sourceTableName, org.apache.hadoop.hbase.TableName targetTableName, org.apache.hadoop.fs.Path testDir, String... options)
void	testSyncTable()
private void	testSyncTable(HBaseTestingUtil source, HBaseTestingUtil target, String... options)
void	testSyncTableDoDeletesFalse()
void	testSyncTableDoPutsFalse()
void	testSyncTableFromSourceToPeerCluster()
void	testSyncTableFromSourceToPeerClusterWithClusterKey()
void	testSyncTableIgnoreTimestampsTrue()
void	testSyncTableToPeerCluster()
private void	writeTestData(HBaseTestingUtil sourceCluster, org.apache.hadoop.hbase.TableName sourceTableName, HBaseTestingUtil targetCluster, org.apache.hadoop.hbase.TableName targetTableName, long... timestamps)

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

UTIL1

private static final HBaseTestingUtil UTIL1

UTIL2

private static final HBaseTestingUtil UTIL2

name

public org.junit.rules.TestName name

Constructor Details

TestSyncTable

public TestSyncTable()

Method Details

beforeClass

public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

public static void afterClass()
                       throws Exception

Throws:

Exception

generateSplits

private static byte[][] generateSplits(int numRows,
 int numRegions)

testSyncTable

private void testSyncTable(HBaseTestingUtil source,
 HBaseTestingUtil target,
 String... options)
                    throws Exception

Throws:

Exception

testSyncTable

public void testSyncTable()
                   throws Exception

Throws:

Exception

testSyncTableToPeerCluster

public void testSyncTableToPeerCluster()
                                throws Exception

Throws:

Exception

testSyncTableFromSourceToPeerCluster

public void testSyncTableFromSourceToPeerCluster()
                                          throws Exception

Throws:

Exception

testSyncTableFromSourceToPeerClusterWithClusterKey

public void testSyncTableFromSourceToPeerClusterWithClusterKey()
                                                        throws Exception

Throws:

Exception

testSyncTableDoDeletesFalse

public void testSyncTableDoDeletesFalse()
                                 throws Exception

Throws:

Exception

testSyncTableDoPutsFalse

public void testSyncTableDoPutsFalse()
                              throws Exception

Throws:

Exception

testSyncTableIgnoreTimestampsTrue

public void testSyncTableIgnoreTimestampsTrue()
                                       throws Exception

Throws:

Exception

assertCellEquals

private void assertCellEquals(org.apache.hadoop.hbase.Cell sourceCell,
 org.apache.hadoop.hbase.Cell targetCell,
 BooleanSupplier checkTimestamp)

assertEqualTables

private void assertEqualTables(int expectedRows,
 HBaseTestingUtil sourceCluster,
 org.apache.hadoop.hbase.TableName sourceTableName,
 HBaseTestingUtil targetCluster,
 org.apache.hadoop.hbase.TableName targetTableName,
 boolean ignoreTimestamps)
                        throws Exception

Throws:

Exception

assertTargetDoDeletesFalse

private void assertTargetDoDeletesFalse(int expectedRows,
 HBaseTestingUtil sourceCluster,
 org.apache.hadoop.hbase.TableName sourceTableName,
 HBaseTestingUtil targetCluster,
 org.apache.hadoop.hbase.TableName targetTableName)
                                 throws Exception

Throws:

Exception

assertTargetDoPutsFalse

private void assertTargetDoPutsFalse(int expectedRows,
 HBaseTestingUtil sourceCluster,
 org.apache.hadoop.hbase.TableName sourceTableName,
 HBaseTestingUtil targetCluster,
 org.apache.hadoop.hbase.TableName targetTableName)
                              throws Exception

Throws:

Exception

syncTables

private org.apache.hadoop.mapreduce.Counters syncTables(org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.hbase.TableName sourceTableName,
 org.apache.hadoop.hbase.TableName targetTableName,
 org.apache.hadoop.fs.Path testDir,
 String... options)
                                                 throws Exception

Throws:

Exception

hashSourceTable

private void hashSourceTable(HBaseTestingUtil sourceCluster,
 org.apache.hadoop.hbase.TableName sourceTableName,
 org.apache.hadoop.fs.Path testDir,
 String... options)
                      throws Exception

Throws:

Exception

writeTestData

private void writeTestData(HBaseTestingUtil sourceCluster,
 org.apache.hadoop.hbase.TableName sourceTableName,
 HBaseTestingUtil targetCluster,
 org.apache.hadoop.hbase.TableName targetTableName,
 long... timestamps)
                    throws Exception

Throws:

Exception