Package org.apache.hadoop.hbase.mapreduce

Class TestCopyTable

java.lang.Object

org.apache.hadoop.hbase.mapreduce.CopyTableTestBase

org.apache.hadoop.hbase.mapreduce.TestCopyTable

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

Basic test for the CopyTable M/R tool

Field Summary

Fields

Modifier and Type	Field	Description
private static final HBaseTestingUtil	TEST_UTIL

Fields inherited from class org.apache.hadoop.hbase.mapreduce.CopyTableTestBase

FAMILY_A, FAMILY_A_STRING, FAMILY_B, FAMILY_B_STRING, QUALIFIER, ROW1, ROW2

Constructor Summary

Constructors

Constructor	Description
TestCopyTable()

Method Summary

Modifier and Type	Method	Description
static void	afterClass()
static void	beforeClass()
protected org.apache.hadoop.hbase.client.Table	createSourceTable(org.apache.hadoop.hbase.client.TableDescriptor desc)
private org.apache.hadoop.hbase.client.Table	createTable(org.apache.hadoop.hbase.TableName tableName, byte[] family, boolean isMob)
protected org.apache.hadoop.hbase.client.Table	createTargetTable(org.apache.hadoop.hbase.client.TableDescriptor desc)
protected void	dropSourceTable(org.apache.hadoop.hbase.TableName tableName)
protected void	dropTargetTable(org.apache.hadoop.hbase.TableName tableName)
protected String[]	getPeerClusterOptions()
void	testCopyTable(org.junit.jupiter.api.TestInfo testInfo)	Simple end-to-end test
private void	testCopyTableBySnapshot(String tablePrefix, boolean bulkLoad, boolean isMob)
void	testCopyTableWithBulkload(org.junit.jupiter.api.TestInfo testInfo)	Simple end-to-end test with bulkload.
void	testCopyTableWithBulkloadWithMob(org.junit.jupiter.api.TestInfo testInfo)	Simple end-to-end test with bulkload on table with MOB.
void	testCopyTableWithMob(org.junit.jupiter.api.TestInfo testInfo)	Simple end-to-end test on table with MOB
void	testLoadingSnapshotAndBulkLoadToMobTable()
void	testLoadingSnapshotAndBulkLoadToTable()
void	testLoadingSnapshotToTable()
void	testLoadingSnapshotWithoutDestTable()
void	testLoadingSnapshotWithoutSnapshotName()
void	testLoadingTtlExpiredSnapshotToTable()
void	testMainMethod()	Test main method of CopyTable.
void	testRenameFamily(org.junit.jupiter.api.TestInfo testInfo)	Test copy of table from sourceTable to targetTable all rows from family a
void	testStartStopRow(org.junit.jupiter.api.TestInfo testInfo)
void	tsetLoadingSnapshotToMobTable()

Methods inherited from class org.apache.hadoop.hbase.mapreduce.CopyTableTestBase

doCopyTableTest, doCopyTableTestWithMob, loadData, runCopy, testRenameFamily, testStartStopRow, verifyRows

Methods inherited from class java.lang.Object

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

Field Details

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

Constructor Details

TestCopyTable

public TestCopyTable()

Method Details

beforeClass

@BeforeAll
public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

@AfterAll
public static void afterClass()
                       throws Exception

Throws:

Exception

createSourceTable

protected org.apache.hadoop.hbase.client.Table createSourceTable(org.apache.hadoop.hbase.client.TableDescriptor desc)
                                                          throws Exception

Specified by:

createSourceTable in class CopyTableTestBase

Throws:

Exception

createTargetTable

protected org.apache.hadoop.hbase.client.Table createTargetTable(org.apache.hadoop.hbase.client.TableDescriptor desc)
                                                          throws Exception

Specified by:

createTargetTable in class CopyTableTestBase

Throws:

Exception

dropSourceTable

protected void dropSourceTable(org.apache.hadoop.hbase.TableName tableName)
                        throws Exception

Specified by:

dropSourceTable in class CopyTableTestBase

Throws:

Exception

dropTargetTable

protected void dropTargetTable(org.apache.hadoop.hbase.TableName tableName)
                        throws Exception

Specified by:

dropTargetTable in class CopyTableTestBase

Throws:

Exception

getPeerClusterOptions

protected String[] getPeerClusterOptions()
                                  throws Exception

Specified by:

getPeerClusterOptions in class CopyTableTestBase

Throws:

Exception

testCopyTable

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

Simple end-to-end test

Throws:

Exception

testCopyTableWithBulkload

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

Simple end-to-end test with bulkload.

Throws:

Exception

testCopyTableWithMob

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

Simple end-to-end test on table with MOB

Throws:

Exception

testCopyTableWithBulkloadWithMob

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

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

Throws:

Exception

testStartStopRow

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

Throws:

Exception

testRenameFamily

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

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

Throws:

Exception

testMainMethod

@Test
public void testMainMethod()
                    throws Exception

Test main method of CopyTable.

Throws:

Exception

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

@Test
public void testLoadingSnapshotToTable()
                                throws Exception

Throws:

Exception

testLoadingTtlExpiredSnapshotToTable

@Test
public void testLoadingTtlExpiredSnapshotToTable()
                                          throws Exception

Throws:

Exception

tsetLoadingSnapshotToMobTable

@Test
public void tsetLoadingSnapshotToMobTable()
                                   throws Exception

Throws:

Exception

testLoadingSnapshotAndBulkLoadToTable

@Test
public void testLoadingSnapshotAndBulkLoadToTable()
                                           throws Exception

Throws:

Exception

testLoadingSnapshotAndBulkLoadToMobTable

@Test
public void testLoadingSnapshotAndBulkLoadToMobTable()
                                              throws Exception

Throws:

Exception

testLoadingSnapshotWithoutSnapshotName

@Test
public void testLoadingSnapshotWithoutSnapshotName()
                                            throws Exception

Throws:

Exception

testLoadingSnapshotWithoutDestTable

@Test
public void testLoadingSnapshotWithoutDestTable()
                                         throws Exception

Throws:

Exception