org.apache.hadoop.hbase.util

Class HFileArchiveTestingUtil

java.lang.Object

org.apache.hadoop.hbase.util.HFileArchiveTestingUtil

public class HFileArchiveTestingUtil
extends Object

Test helper for testing archiving of HFiles

Method Summary

Modifier and Type	Method and Description
static void	assertArchiveEqualToOriginal(FileStatus[] expected, FileStatus[] actual, FileSystem fs) Compare the archived files to the files in the original directory
static void	assertArchiveEqualToOriginal(FileStatus[] expected, FileStatus[] actual, FileSystem fs, boolean hasTimedBackup) Compare the archived files to the files in the original directory
static boolean	compareArchiveToOriginal(FileStatus[] previous, FileStatus[] archived, FileSystem fs, boolean hasTimedBackup)
static Path	getRegionArchiveDir(Configuration conf, HRegion region) Helper method to get the archive directory for the specified region
static Path	getStoreArchivePath(Configuration conf, HRegion region, Store store) Helper method to get the store archive directory for the specified region
static Path	getStoreArchivePath(HBaseTestingUtility util, String tableName, byte[] storeName)

Methods inherited from class java.lang.Object

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

Method Detail

compareArchiveToOriginal

public static boolean compareArchiveToOriginal(FileStatus[] previous,
                                               FileStatus[] archived,
                                               FileSystem fs,
                                               boolean hasTimedBackup)

assertArchiveEqualToOriginal

public static void assertArchiveEqualToOriginal(FileStatus[] expected,
                                                FileStatus[] actual,
                                                FileSystem fs)
                                         throws IOException

Compare the archived files to the files in the original directory

Parameters:

expected - original files that should have been archived

actual - files that were archived

fs - filessystem on which the archiving took place

Throws:

IOException

assertArchiveEqualToOriginal

public static void assertArchiveEqualToOriginal(FileStatus[] expected,
                                                FileStatus[] actual,
                                                FileSystem fs,
                                                boolean hasTimedBackup)
                                         throws IOException

Compare the archived files to the files in the original directory

Parameters:

expected - original files that should have been archived

actual - files that were archived

fs - FileSystem on which the archiving took place

hasTimedBackup - true if we expect to find an archive backup directory with a copy of the files in the archive directory (and the original files).

Throws:

IOException

getRegionArchiveDir

public static Path getRegionArchiveDir(Configuration conf,
                                       HRegion region)
                                throws IOException

Helper method to get the archive directory for the specified region

Parameters:

conf - Configuration to check for the name of the archive directory

region - region that is being archived

Returns:

Path to the archive directory for the given region

Throws:

IOException

getStoreArchivePath

public static Path getStoreArchivePath(Configuration conf,
                                       HRegion region,
                                       Store store)
                                throws IOException

Helper method to get the store archive directory for the specified region

Parameters:

conf - Configuration to check for the name of the archive directory

region - region that is being archived

store - store that is archiving files

Returns:

Path to the store archive directory for the given region

Throws:

IOException

getStoreArchivePath

public static Path getStoreArchivePath(HBaseTestingUtility util,
                                       String tableName,
                                       byte[] storeName)
                                throws IOException

Throws:

IOException