org.apache.hadoop.hbase.master.snapshot

Class TestSnapshotFileCache

java.lang.Object

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

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
private static org.apache.hadoop.fs.FileSystem	fs
private static org.slf4j.Logger	LOG
private static org.apache.hadoop.fs.Path	rootDir
private static HBaseTestingUtility	UTIL

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)
private SnapshotTestingUtils.SnapshotMock.SnapshotBuilder	createAndTestSnapshotV1(org.apache.hadoop.hbase.master.snapshot.SnapshotFileCache cache, String name, boolean tmp, boolean removeOnExit)
private void	createAndTestSnapshotV2(org.apache.hadoop.hbase.master.snapshot.SnapshotFileCache cache, String name, boolean tmp, boolean removeOnExit)
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)
private org.apache.hadoop.fs.FileStatus	mockStoreFile(String storeFileName)
static void	startCluster()
static void	stopCluster()
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

private static final org.slf4j.Logger LOG

UTIL

private static final HBaseTestingUtility UTIL

fs

private static org.apache.hadoop.fs.FileSystem fs

rootDir

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

Constructor Detail

TestSnapshotFileCache

public TestSnapshotFileCache()

Method Detail

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

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)
                                                                           throws IOException

Throws:

IOException

createAndTestSnapshotV2

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

Throws:

IOException

createAndTestSnapshot

private void createAndTestSnapshot(org.apache.hadoop.hbase.master.snapshot.SnapshotFileCache cache,
                                   SnapshotTestingUtils.SnapshotMock.SnapshotBuilder builder,
                                   boolean tmp,
                                   boolean removeOnExit)
                            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