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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

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

public static void beforeClass()
                        throws Exception

Throws:

Exception

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)

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,
InterruptedException

Throws:

IOException

InterruptedException

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