Package org.apache.hadoop.hbase.mapreduce

Class TestSyncTable

java.lang.Object

org.apache.hadoop.hbase.mapreduce.TestSyncTable

@Tag("org.apache.hadoop.hbase.testclassification.MapReduceTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestSyncTable
extends Object

Basic test for the SyncTable M/R tool

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
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(org.junit.jupiter.api.TestInfo testInfo)
private void	testSyncTable(org.junit.jupiter.api.TestInfo testInfo, HBaseTestingUtil source, HBaseTestingUtil target, String... options)
void	testSyncTableDoDeletesFalse(org.junit.jupiter.api.TestInfo testInfo)
void	testSyncTableDoPutsFalse(org.junit.jupiter.api.TestInfo testInfo)
void	testSyncTableFromSourceToPeerCluster(org.junit.jupiter.api.TestInfo testInfo)
void	testSyncTableFromSourceToPeerClusterWithClusterKey(org.junit.jupiter.api.TestInfo testInfo)
void	testSyncTableIgnoreTimestampsTrue(org.junit.jupiter.api.TestInfo testInfo)
void	testSyncTableToPeerCluster(org.junit.jupiter.api.TestInfo testInfo)
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

LOG

private static final org.slf4j.Logger LOG

UTIL1

private static final HBaseTestingUtil UTIL1

UTIL2

private static final HBaseTestingUtil UTIL2

Constructor Details

TestSyncTable

public TestSyncTable()

Method Details

beforeClass

@BeforeAll
public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

@AfterAll
public static void afterClass()
                       throws Exception

Throws:

Exception

generateSplits

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

testSyncTable

private void testSyncTable(org.junit.jupiter.api.TestInfo testInfo,
 HBaseTestingUtil source,
 HBaseTestingUtil target,
 String... options)
                    throws Exception

Throws:

Exception

testSyncTable

@Test
public void testSyncTable(org.junit.jupiter.api.TestInfo testInfo)
                   throws Exception

Throws:

Exception

testSyncTableToPeerCluster

@Test
public void testSyncTableToPeerCluster(org.junit.jupiter.api.TestInfo testInfo)
                                throws Exception

Throws:

Exception

testSyncTableFromSourceToPeerCluster

@Test
public void testSyncTableFromSourceToPeerCluster(org.junit.jupiter.api.TestInfo testInfo)
                                          throws Exception

Throws:

Exception

testSyncTableFromSourceToPeerClusterWithClusterKey

@Test
public void testSyncTableFromSourceToPeerClusterWithClusterKey(org.junit.jupiter.api.TestInfo testInfo)
                                                        throws Exception

Throws:

Exception

testSyncTableDoDeletesFalse

@Test
public void testSyncTableDoDeletesFalse(org.junit.jupiter.api.TestInfo testInfo)
                                 throws Exception

Throws:

Exception

testSyncTableDoPutsFalse

@Test
public void testSyncTableDoPutsFalse(org.junit.jupiter.api.TestInfo testInfo)
                              throws Exception

Throws:

Exception

testSyncTableIgnoreTimestampsTrue

@Test
public void testSyncTableIgnoreTimestampsTrue(org.junit.jupiter.api.TestInfo testInfo)
                                       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