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

Class TestManageTableErasureCodingPolicy

java.lang.Object

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

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
static final HBaseClassTestRule	CLASS_RULE
private static final org.apache.hadoop.hbase.TableName	EC_TABLE
private static final org.apache.hadoop.hbase.client.TableDescriptor	EC_TABLE_DESC
private static boolean	erasureCodingSupported
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 HBaseTestingUtility	UTIL

Constructor Summary

Constructors

Constructor	Description
TestManageTableErasureCodingPolicy()

Method Summary

Modifier and Type	Method	Description
static void	afterClass()
private void	assertPolicyValidationException(String message, String expected)
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)
private static boolean	enableErasureCoding(org.apache.hadoop.hdfs.DistributedFileSystem fs)
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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

UTIL

private static final HBaseTestingUtility 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

erasureCodingSupported

private static boolean erasureCodingSupported

Constructor Details

TestManageTableErasureCodingPolicy

public TestManageTableErasureCodingPolicy()

Method Details

beforeClass

public static void beforeClass()
                        throws Exception

Throws:

Exception

enableErasureCoding

private static boolean enableErasureCoding(org.apache.hadoop.hdfs.DistributedFileSystem fs)
                                    throws IOException

Throws:

IOException

afterClass

public static void afterClass()
                       throws Exception

Throws:

Exception

itValidatesPolicyNameForCreate

public void itValidatesPolicyNameForCreate()

itValidatesPolicyNameForAlter

public void itValidatesPolicyNameForAlter()

runValidatePolicyNameTest

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

assertPolicyValidationException

private void assertPolicyValidationException(String message,
 String expected)

testCreateTableErasureCodingSync

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

public void testModifyTableErasureCodingSync()
                                      throws IOException

Throws:

IOException

compactAwayOldFiles

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

Throws:

IOException

testRestoreSnapshot

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