Package org.apache.hadoop.hbase.master.cleaner

Class TestHFileLinkCleaner

java.lang.Object

org.apache.hadoop.hbase.master.cleaner.TestHFileLinkCleaner

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

Test the HFileLink Cleaner. HFiles with links cannot be deleted until a link is present.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	TestHFileLinkCleaner.DummyServer

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.fs.Path	archiveDir
private org.apache.hadoop.fs.Path	archiveStoreDir
private org.apache.hadoop.fs.FileStatus[]	backRefs
private org.apache.hadoop.hbase.master.cleaner.HFileCleaner	cleaner
private org.apache.hadoop.conf.Configuration	conf
private org.apache.hadoop.fs.Path	familyLinkPath
private String	familyName
private org.apache.hadoop.fs.Path	familyPath
private org.apache.hadoop.fs.FileSystem	fs
private String	hfileLinkName
private String	hfileName
private org.apache.hadoop.fs.Path	hfilePath
private org.apache.hadoop.hbase.client.RegionInfo	hri
private org.apache.hadoop.hbase.client.RegionInfo	hriLink
private org.apache.hadoop.fs.Path	linkBackRef
private org.apache.hadoop.fs.Path	linkBackRefDir
private static org.apache.hadoop.hbase.master.cleaner.DirScanPool	POOL
private org.apache.hadoop.fs.Path	rootDir
private org.apache.hadoop.hbase.TableName	tableLinkName
private org.apache.hadoop.hbase.TableName	tableName
private static final HBaseTestingUtil	TEST_UTIL
private static final long	TTL

Constructor Summary

Constructors

Constructor	Description
TestHFileLinkCleaner()

Method Summary

Modifier and Type	Method	Description
void	cleanup()
void	configureDirectoriesAndLinks(org.junit.jupiter.api.TestInfo testInfo)
private void	createLink(org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker sft, boolean createBackReference)
private static org.apache.hadoop.fs.Path	getFamilyDirPath(org.apache.hadoop.fs.Path rootDir, org.apache.hadoop.hbase.TableName table, String region, String family)
static void	setUp()
static void	tearDown()
void	testHFileLinkByRemovingReference()
void	testHFileLinkCleaning()
void	testHFileLinkEmptyBackReferenceDirectory()

Methods inherited from class java.lang.Object

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

Field Details

conf

private org.apache.hadoop.conf.Configuration conf

rootDir

private org.apache.hadoop.fs.Path rootDir

fs

private org.apache.hadoop.fs.FileSystem fs

tableName

private org.apache.hadoop.hbase.TableName tableName

tableLinkName

private org.apache.hadoop.hbase.TableName tableLinkName

hfileName

private String hfileName

familyName

private String familyName

hri

private org.apache.hadoop.hbase.client.RegionInfo hri

hriLink

private org.apache.hadoop.hbase.client.RegionInfo hriLink

archiveDir

private org.apache.hadoop.fs.Path archiveDir

archiveStoreDir

private org.apache.hadoop.fs.Path archiveStoreDir

familyPath

private org.apache.hadoop.fs.Path familyPath

hfilePath

private org.apache.hadoop.fs.Path hfilePath

familyLinkPath

private org.apache.hadoop.fs.Path familyLinkPath

hfileLinkName

private String hfileLinkName

linkBackRefDir

private org.apache.hadoop.fs.Path linkBackRefDir

linkBackRef

private org.apache.hadoop.fs.Path linkBackRef

backRefs

private org.apache.hadoop.fs.FileStatus[] backRefs

cleaner

private org.apache.hadoop.hbase.master.cleaner.HFileCleaner cleaner

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

POOL

private static org.apache.hadoop.hbase.master.cleaner.DirScanPool POOL

TTL

private static final long TTL

See Also:

• Constant Field Values

Constructor Details

TestHFileLinkCleaner

public TestHFileLinkCleaner()

Method Details

setUp

@BeforeAll
public static void setUp()

tearDown

@AfterAll
public static void tearDown()

configureDirectoriesAndLinks

@BeforeEach
public void configureDirectoriesAndLinks(org.junit.jupiter.api.TestInfo testInfo)
                                  throws IOException

Throws:

IOException

createLink

private void createLink(org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker sft,
 boolean createBackReference)
                 throws IOException

Throws:

IOException

cleanup

@AfterEach
public void cleanup()
             throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testHFileLinkCleaning

@Test
public void testHFileLinkCleaning()
                           throws Exception

Throws:

Exception

testHFileLinkByRemovingReference

@Test
public void testHFileLinkByRemovingReference()
                                      throws Exception

Throws:

Exception

testHFileLinkEmptyBackReferenceDirectory

@Test
public void testHFileLinkEmptyBackReferenceDirectory()
                                              throws Exception

Throws:

Exception

getFamilyDirPath

private static org.apache.hadoop.fs.Path getFamilyDirPath(org.apache.hadoop.fs.Path rootDir,
 org.apache.hadoop.hbase.TableName table,
 String region,
 String family)