org.apache.hadoop.hbase.mapreduce

Class TestCopyTable

java.lang.Object

org.apache.hadoop.hbase.mapreduce.TestCopyTable

public class TestCopyTable
extends Object

Basic test for the CopyTable M/R tool

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static byte[]	FAMILY_A
private static String	FAMILY_A_STRING
private static byte[]	FAMILY_B
private static String	FAMILY_B_STRING
org.junit.rules.TestName	name
private static byte[]	QUALIFIER
private static byte[]	ROW1
private static byte[]	ROW2
private static HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestCopyTable()

Method Summary

Modifier and Type	Method and Description
static void	afterClass()
static void	beforeClass()
private org.apache.hadoop.hbase.client.Table	createTable(org.apache.hadoop.hbase.TableName tableName, byte[] family, boolean isMob)
private void	doCopyTableTest(boolean bulkload)
private void	doCopyTableTestWithMob(boolean bulkload)
private void	loadData(org.apache.hadoop.hbase.client.Table t, byte[] family, byte[] column)
private boolean	runCopy(String[] args)
void	testCopyTable() Simple end-to-end test
private void	testCopyTableBySnapshot(String tablePrefix, boolean bulkLoad, boolean isMob)
void	testCopyTableWithBulkload() Simple end-to-end test with bulkload.
void	testCopyTableWithBulkloadWithMob() Simple end-to-end test with bulkload on table with MOB.
void	testCopyTableWithMob() Simple end-to-end test on table with MOB
void	testLoadingSnapshotAndBulkLoadToMobTable()
void	testLoadingSnapshotAndBulkLoadToTable()
void	testLoadingSnapshotToRemoteCluster()
void	testLoadingSnapshotToTable()
void	testLoadingSnapshotWithoutDestTable()
void	testLoadingSnapshotWithoutSnapshotName()
void	testMainMethod() Test main method of CopyTable.
void	testRenameFamily() Test copy of table from sourceTable to targetTable all rows from family a
void	testStartStopRow()
void	tsetLoadingSnapshotToMobTable()
private void	verifyRows(org.apache.hadoop.hbase.client.Table t, byte[] family, byte[] column)

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

ROW1

private static final byte[] ROW1

ROW2

private static final byte[] ROW2

FAMILY_A_STRING

private static final String FAMILY_A_STRING

See Also:

Constant Field Values

FAMILY_B_STRING

private static final String FAMILY_B_STRING

See Also:

Constant Field Values

FAMILY_A

private static final byte[] FAMILY_A

FAMILY_B

private static final byte[] FAMILY_B

QUALIFIER

private static final byte[] QUALIFIER

name

public org.junit.rules.TestName name

Constructor Detail

TestCopyTable

public TestCopyTable()

Method Detail

beforeClass

public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

public static void afterClass()
                       throws Exception

Throws:

Exception

doCopyTableTest

private void doCopyTableTest(boolean bulkload)
                      throws Exception

Throws:

Exception

doCopyTableTestWithMob

private void doCopyTableTestWithMob(boolean bulkload)
                             throws Exception

Throws:

Exception

testCopyTable

public void testCopyTable()
                   throws Exception

Simple end-to-end test

Throws:

Exception

testCopyTableWithBulkload

public void testCopyTableWithBulkload()
                               throws Exception

Simple end-to-end test with bulkload.

Throws:

Exception

testCopyTableWithMob

public void testCopyTableWithMob()
                          throws Exception

Simple end-to-end test on table with MOB

Throws:

Exception

testCopyTableWithBulkloadWithMob

public void testCopyTableWithBulkloadWithMob()
                                      throws Exception

Simple end-to-end test with bulkload on table with MOB.

Throws:

Exception

testStartStopRow

public void testStartStopRow()
                      throws Exception

Throws:

Exception

testRenameFamily

public void testRenameFamily()
                      throws Exception

Test copy of table from sourceTable to targetTable all rows from family a

Throws:

Exception

testMainMethod

public void testMainMethod()
                    throws Exception

Test main method of CopyTable.

Throws:

Exception

runCopy

private boolean runCopy(String[] args)
                 throws Exception

Throws:

Exception

loadData

private void loadData(org.apache.hadoop.hbase.client.Table t,
                      byte[] family,
                      byte[] column)
               throws IOException

Throws:

IOException

verifyRows

private void verifyRows(org.apache.hadoop.hbase.client.Table t,
                        byte[] family,
                        byte[] column)
                 throws IOException

Throws:

IOException

createTable

private org.apache.hadoop.hbase.client.Table createTable(org.apache.hadoop.hbase.TableName tableName,
                                                         byte[] family,
                                                         boolean isMob)
                                                  throws IOException

Throws:

IOException

testCopyTableBySnapshot

private void testCopyTableBySnapshot(String tablePrefix,
                                     boolean bulkLoad,
                                     boolean isMob)
                              throws Exception

Throws:

Exception

testLoadingSnapshotToTable

public void testLoadingSnapshotToTable()
                                throws Exception

Throws:

Exception

tsetLoadingSnapshotToMobTable

public void tsetLoadingSnapshotToMobTable()
                                   throws Exception

Throws:

Exception

testLoadingSnapshotAndBulkLoadToTable

public void testLoadingSnapshotAndBulkLoadToTable()
                                           throws Exception

Throws:

Exception

testLoadingSnapshotAndBulkLoadToMobTable

public void testLoadingSnapshotAndBulkLoadToMobTable()
                                              throws Exception

Throws:

Exception

testLoadingSnapshotToRemoteCluster

public void testLoadingSnapshotToRemoteCluster()
                                        throws Exception

Throws:

Exception

testLoadingSnapshotWithoutSnapshotName

public void testLoadingSnapshotWithoutSnapshotName()
                                            throws Exception

Throws:

Exception

testLoadingSnapshotWithoutDestTable

public void testLoadingSnapshotWithoutDestTable()
                                         throws Exception

Throws:

Exception