Package org.apache.hadoop.hbase.master.snapshot

Class TestSnapshotFileCache

java.lang.Object

org.apache.hadoop.hbase.master.snapshot.TestSnapshotFileCache

Direct Known Subclasses:

TestSnapshotFileCacheWithDifferentWorkingDir

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

Test that we correctly reload the cache, filter directories, etc.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	TestSnapshotFileCache.SnapshotFiles

Field Summary

Fields

Modifier and Type	Field	Description
protected static org.apache.hadoop.conf.Configuration	conf
protected static org.apache.hadoop.fs.FileSystem	fs
protected static final org.slf4j.Logger	LOG
protected static final long	PERIOD
protected static org.apache.hadoop.fs.Path	rootDir
protected static org.apache.hadoop.fs.Path	snapshotDir
protected static final HBaseTestingUtil	UTIL
protected static org.apache.hadoop.fs.Path	workingDir
protected static org.apache.hadoop.fs.FileSystem	workingFs

Constructor Summary

Constructors

Constructor	Description
TestSnapshotFileCache()

Method Summary

Modifier and Type	Method	Description
void	cleanupFiles()
private static boolean	contains(Iterable<org.apache.hadoop.fs.FileStatus> files, org.apache.hadoop.fs.Path filePath)
private void	createAndTestSnapshot(org.apache.hadoop.hbase.master.snapshot.SnapshotFileCache cache, SnapshotTestingUtils.SnapshotMock.SnapshotBuilder builder, boolean tmp, boolean removeOnExit, boolean setFolderTime)
private SnapshotTestingUtils.SnapshotMock.SnapshotBuilder	createAndTestSnapshotV1(org.apache.hadoop.hbase.master.snapshot.SnapshotFileCache cache, String name, boolean tmp, boolean removeOnExit, boolean setFolderTime)
private void	createAndTestSnapshotV2(org.apache.hadoop.hbase.master.snapshot.SnapshotFileCache cache, String name, boolean tmp, boolean removeOnExit, boolean setFolderTime)
private static Iterable<org.apache.hadoop.fs.FileStatus>	getNonSnapshotFiles(org.apache.hadoop.hbase.master.snapshot.SnapshotFileCache cache, org.apache.hadoop.fs.Path storeFile)
private List<org.apache.hadoop.fs.FileStatus>	getStoreFilesForSnapshot(SnapshotTestingUtils.SnapshotMock.SnapshotBuilder builder)
protected static void	initCommon()
private org.apache.hadoop.fs.FileStatus	mockStoreFile(String storeFileName)
static void	startCluster()
static void	stopCluster()
void	testCacheUpdatedWhenLastModifiedOfSnapDirNotUpdated()
void	testLoadAndDelete()
void	testReloadModifiedDirectory()
void	testSnapshotTempDirReload()
void	testWeNeverCacheTmpDirAndLoadIt()

Methods inherited from class java.lang.Object

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

Field Details

LOG

protected static final org.slf4j.Logger LOG

UTIL

protected static final HBaseTestingUtil UTIL

PERIOD

protected static final long PERIOD

See Also:

• Constant Field Values

fs

protected static org.apache.hadoop.fs.FileSystem fs

rootDir

protected static org.apache.hadoop.fs.Path rootDir

snapshotDir

protected static org.apache.hadoop.fs.Path snapshotDir

conf

protected static org.apache.hadoop.conf.Configuration conf

workingFs

protected static org.apache.hadoop.fs.FileSystem workingFs

workingDir

protected static org.apache.hadoop.fs.Path workingDir

Constructor Details

TestSnapshotFileCache

public TestSnapshotFileCache()

Method Details

initCommon

protected static void initCommon()
                          throws Exception

Throws:

Exception

startCluster

@BeforeAll
public static void startCluster()
                         throws Exception

Throws:

Exception

stopCluster

@AfterAll
public static void stopCluster()
                        throws Exception

Throws:

Exception

cleanupFiles

@AfterEach
public void cleanupFiles()
                  throws Exception

Throws:

Exception

testLoadAndDelete

@Test
public void testLoadAndDelete()
                       throws IOException

Throws:

IOException

testReloadModifiedDirectory

@Test
public void testReloadModifiedDirectory()
                                 throws IOException

Throws:

IOException

testSnapshotTempDirReload

@Test
public void testSnapshotTempDirReload()
                               throws IOException

Throws:

IOException

testCacheUpdatedWhenLastModifiedOfSnapDirNotUpdated

@Test
public void testCacheUpdatedWhenLastModifiedOfSnapDirNotUpdated()
                                                         throws IOException

Throws:

IOException

testWeNeverCacheTmpDirAndLoadIt

@Test
public void testWeNeverCacheTmpDirAndLoadIt()
                                     throws Exception

Throws:

Exception

getStoreFilesForSnapshot

private List<org.apache.hadoop.fs.FileStatus> getStoreFilesForSnapshot(SnapshotTestingUtils.SnapshotMock.SnapshotBuilder builder)
                                                                throws IOException

Throws:

IOException

mockStoreFile

private org.apache.hadoop.fs.FileStatus mockStoreFile(String storeFileName)

createAndTestSnapshotV1

private SnapshotTestingUtils.SnapshotMock.SnapshotBuilder createAndTestSnapshotV1(org.apache.hadoop.hbase.master.snapshot.SnapshotFileCache cache,
 String name,
 boolean tmp,
 boolean removeOnExit,
 boolean setFolderTime)
                                                                           throws IOException

Throws:

IOException

createAndTestSnapshotV2

private void createAndTestSnapshotV2(org.apache.hadoop.hbase.master.snapshot.SnapshotFileCache cache,
 String name,
 boolean tmp,
 boolean removeOnExit,
 boolean setFolderTime)
                              throws IOException

Throws:

IOException

createAndTestSnapshot

private void createAndTestSnapshot(org.apache.hadoop.hbase.master.snapshot.SnapshotFileCache cache,
 SnapshotTestingUtils.SnapshotMock.SnapshotBuilder builder,
 boolean tmp,
 boolean removeOnExit,
 boolean setFolderTime)
                            throws IOException

Throws:

IOException

contains

private static boolean contains(Iterable<org.apache.hadoop.fs.FileStatus> files,
 org.apache.hadoop.fs.Path filePath)

getNonSnapshotFiles

private static Iterable<org.apache.hadoop.fs.FileStatus> getNonSnapshotFiles(org.apache.hadoop.hbase.master.snapshot.SnapshotFileCache cache,
 org.apache.hadoop.fs.Path storeFile)
                                                                      throws IOException

Throws:

IOException