Package org.apache.hadoop.hbase.master.procedure

Class TestManageTableErasureCodingPolicy

java.lang.Object

org.apache.hadoop.hbase.master.procedure.TestManageTableErasureCodingPolicy

@Tag("org.apache.hadoop.hbase.testclassification.MasterTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestManageTableErasureCodingPolicy
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static interface	TestManageTableErasureCodingPolicy.ThrowingTableDescriptorConsumer

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.apache.hadoop.hbase.TableName	EC_TABLE
private static final org.apache.hadoop.hbase.client.TableDescriptor	EC_TABLE_DESC
private static final byte[]	FAMILY
private static final org.slf4j.Logger	LOG
private static final org.apache.hadoop.hbase.TableName	NON_EC_TABLE
private static final org.apache.hadoop.hbase.client.TableDescriptor	NON_EC_TABLE_DESC
private static final HBaseTestingUtil	UTIL

Constructor Summary

Constructors

Constructor	Description
TestManageTableErasureCodingPolicy()

Method Summary

Modifier and Type	Method	Description
static void	afterClass()
static void	beforeClass()
private void	checkPolicy(org.apache.hadoop.hdfs.DistributedFileSystem dfs, org.apache.hadoop.fs.Path path, String expectedPolicy)
private void	checkRegionDirAndFilePolicies(org.apache.hadoop.hdfs.DistributedFileSystem dfs, org.apache.hadoop.fs.Path rootDir, org.apache.hadoop.hbase.TableName testTable, String expectedDirPolicy, String expectedFilePolicy)
private void	compactAwayOldFiles(org.apache.hadoop.hbase.TableName tableName)
void	itValidatesPolicyNameForAlter()
void	itValidatesPolicyNameForCreate()
private void	recreateTable(org.apache.hadoop.hbase.client.Admin admin, org.apache.hadoop.hbase.client.TableDescriptor desc)
private void	runValidatePolicyNameTest(Function<org.apache.hadoop.hbase.client.Admin,org.apache.hadoop.hbase.client.TableDescriptor> descriptorSupplier, TestManageTableErasureCodingPolicy.ThrowingTableDescriptorConsumer consumer)
void	testCreateTableErasureCodingSync()
void	testModifyTableErasureCodingSync()
void	testRestoreSnapshot()

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

UTIL

private static final HBaseTestingUtil UTIL

FAMILY

private static final byte[] FAMILY

NON_EC_TABLE

private static final org.apache.hadoop.hbase.TableName NON_EC_TABLE

NON_EC_TABLE_DESC

private static final org.apache.hadoop.hbase.client.TableDescriptor NON_EC_TABLE_DESC

EC_TABLE

private static final org.apache.hadoop.hbase.TableName EC_TABLE

EC_TABLE_DESC

private static final org.apache.hadoop.hbase.client.TableDescriptor EC_TABLE_DESC

Constructor Details

TestManageTableErasureCodingPolicy

public TestManageTableErasureCodingPolicy()

Method Details

beforeClass

@BeforeAll
public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

@AfterAll
public static void afterClass()
                       throws Exception

Throws:

Exception

itValidatesPolicyNameForCreate

@Test
public void itValidatesPolicyNameForCreate()

itValidatesPolicyNameForAlter

@Test
public void itValidatesPolicyNameForAlter()

runValidatePolicyNameTest

private void runValidatePolicyNameTest(Function<org.apache.hadoop.hbase.client.Admin,org.apache.hadoop.hbase.client.TableDescriptor> descriptorSupplier,
 TestManageTableErasureCodingPolicy.ThrowingTableDescriptorConsumer consumer)

testCreateTableErasureCodingSync

@Test
public void testCreateTableErasureCodingSync()
                                      throws IOException

Throws:

IOException

recreateTable

private void recreateTable(org.apache.hadoop.hbase.client.Admin admin,
 org.apache.hadoop.hbase.client.TableDescriptor desc)
                    throws IOException

Throws:

IOException

testModifyTableErasureCodingSync

@Test
public void testModifyTableErasureCodingSync()
                                      throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

compactAwayOldFiles

private void compactAwayOldFiles(org.apache.hadoop.hbase.TableName tableName)
                          throws IOException

Throws:

IOException

testRestoreSnapshot

@Test
public void testRestoreSnapshot()
                         throws IOException

Throws:

IOException

checkRegionDirAndFilePolicies

private void checkRegionDirAndFilePolicies(org.apache.hadoop.hdfs.DistributedFileSystem dfs,
 org.apache.hadoop.fs.Path rootDir,
 org.apache.hadoop.hbase.TableName testTable,
 String expectedDirPolicy,
 String expectedFilePolicy)
                                    throws IOException

Throws:

IOException

checkPolicy

private void checkPolicy(org.apache.hadoop.hdfs.DistributedFileSystem dfs,
 org.apache.hadoop.fs.Path path,
 String expectedPolicy)
                  throws IOException

Throws:

IOException