org.apache.hadoop.hbase.master.snapshot

Class TestSnapshotFileCache

java.lang.Object

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

Direct Known Subclasses:

TestSnapshotFileCacheWithDifferentWorkingDir

public class TestSnapshotFileCache
extends Object

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

Nested Class Summary

Nested Classes

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
TestSnapshotFileCache()

Method Summary

Modifier and Type	Method and 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 Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

protected static final org.slf4j.Logger LOG

UTIL

protected static final HBaseTestingUtility 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 Detail

TestSnapshotFileCache

public TestSnapshotFileCache()

Method Detail

initCommon

protected static void initCommon()
                          throws Exception

Throws:

Exception

startCluster

public static void startCluster()
                         throws Exception

Throws:

Exception

stopCluster

public static void stopCluster()
                        throws Exception

Throws:

Exception

cleanupFiles

public void cleanupFiles()
                  throws Exception

Throws:

Exception

testLoadAndDelete

public void testLoadAndDelete()
                       throws IOException

Throws:

IOException

testReloadModifiedDirectory

public void testReloadModifiedDirectory()
                                 throws IOException

Throws:

IOException

testSnapshotTempDirReload

public void testSnapshotTempDirReload()
                               throws IOException

Throws:

IOException

testCacheUpdatedWhenLastModifiedOfSnapDirNotUpdated

public void testCacheUpdatedWhenLastModifiedOfSnapDirNotUpdated()
                                                         throws IOException

Throws:

IOException

testWeNeverCacheTmpDirAndLoadIt

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