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 HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestSyncTable()

Method Summary

Modifier and Type	Method	Description
static void	afterClass()
private void	assertEqualTables(int expectedRows, org.apache.hadoop.hbase.TableName sourceTableName, org.apache.hadoop.hbase.TableName targetTableName, boolean ignoreTimestamps)
private void	assertTargetDoDeletesFalse(int expectedRows, org.apache.hadoop.hbase.TableName sourceTableName, org.apache.hadoop.hbase.TableName targetTableName)
private void	assertTargetDoPutsFalse(int expectedRows, org.apache.hadoop.hbase.TableName sourceTableName, org.apache.hadoop.hbase.TableName targetTableName)
static void	beforeClass()
private static byte[][]	generateSplits(int numRows, int numRegions)
private void	hashSourceTable(org.apache.hadoop.hbase.TableName sourceTableName, org.apache.hadoop.fs.Path testDir, String... options)
private org.apache.hadoop.mapreduce.Counters	syncTables(org.apache.hadoop.hbase.TableName sourceTableName, org.apache.hadoop.hbase.TableName targetTableName, org.apache.hadoop.fs.Path testDir, String... options)
void	testSyncTable()
void	testSyncTableDoDeletesFalse()
void	testSyncTableDoPutsFalse()
void	testSyncTableIgnoreTimestampsTrue()
private void	writeTestData(org.apache.hadoop.hbase.TableName sourceTableName, 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

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

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

public void testSyncTable()
                   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

assertEqualTables

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

Throws:

Exception

assertTargetDoDeletesFalse

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

Throws:

Exception

assertTargetDoPutsFalse

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

Throws:

Exception

syncTables

private org.apache.hadoop.mapreduce.Counters syncTables(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(org.apache.hadoop.hbase.TableName sourceTableName,
 org.apache.hadoop.fs.Path testDir,
 String... options)
                      throws Exception

Throws:

Exception

writeTestData

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

Throws:

Exception