@InterfaceAudience.Private @InterfaceStability.Evolving public final class BackupClientUtil extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected static Log |
LOG |
static java.lang.String |
LOGNAME_SEPARATOR |
Modifier and Type | Method and Description |
---|---|
static boolean |
checkPathExist(java.lang.String backupStr,
Configuration conf)
Check whether the backup path exist
|
static void |
checkTargetDir(java.lang.String backupRootPath,
Configuration conf) |
static void |
cleanupBackupData(BackupInfo context,
Configuration conf) |
static java.lang.Long |
getCreationTime(Path p)
Given the log file, parse the timestamp from the file name.
|
static java.util.List<java.lang.String> |
getFiles(FileSystem fs,
Path rootDir,
java.util.List<java.lang.String> files,
PathFilter filter) |
static java.lang.String |
getLogBackupDir(java.lang.String backupRootDir,
java.lang.String backupId)
Given the backup root dir and the backup id, return the log file location for an incremental
backup.
|
static <T> java.lang.Long |
getMinValue(java.util.HashMap<T,java.lang.Long> map)
Get the min value for all the Values a map.
|
static java.lang.String |
getPath(Path p)
Return the 'path' component of a Path.
|
static java.lang.String |
getTableBackupDir(java.lang.String backupRootDir,
java.lang.String backupId,
TableName tableName)
Given the backup root dir, backup id and the table name, return the backup image location,
which is also where the backup manifest file is.
|
static java.lang.String |
getUniqueWALFileNamePart(Path p)
Returns WAL file name
|
static java.lang.String |
getUniqueWALFileNamePart(java.lang.String walFileName)
Returns WAL file name
|
static FileStatus[] |
listStatus(FileSystem fs,
Path dir,
PathFilter filter)
Calls fs.listStatus() and treats FileNotFoundException as non-fatal
This accommodates differences between hadoop versions, where hadoop 1
does not throw a FileNotFoundException, and return an empty FileStatus[]
while Hadoop 2 will throw FileNotFoundException.
|
static java.lang.String |
parseHostFromOldLog(Path p)
Parses host name:port from archived WAL path
|
static TableName[] |
parseTableNames(java.lang.String tables) |
static java.util.ArrayList<BackupInfo> |
sortHistoryListDesc(java.util.ArrayList<BackupInfo> historyList)
Sort history list by start time in descending order.
|
protected static final Log LOG
public static final java.lang.String LOGNAME_SEPARATOR
public static boolean checkPathExist(java.lang.String backupStr, Configuration conf) throws java.io.IOException
backupStr
- backupconf
- configurationjava.io.IOException
- exceptionpublic static void checkTargetDir(java.lang.String backupRootPath, Configuration conf) throws java.io.IOException
java.io.IOException
public static <T> java.lang.Long getMinValue(java.util.HashMap<T,java.lang.Long> map)
map
- mappublic static java.lang.String parseHostFromOldLog(Path p) throws java.io.IOException
p
- pathjava.io.IOException
- exceptionpublic static java.lang.Long getCreationTime(Path p) throws java.io.IOException
p
- a path to the log filejava.io.IOException
- exceptionpublic static java.util.List<java.lang.String> getFiles(FileSystem fs, Path rootDir, java.util.List<java.lang.String> files, PathFilter filter) throws java.io.FileNotFoundException, java.io.IOException
java.io.FileNotFoundException
java.io.IOException
public static void cleanupBackupData(BackupInfo context, Configuration conf) throws java.io.IOException
java.io.IOException
public static java.lang.String getTableBackupDir(java.lang.String backupRootDir, java.lang.String backupId, TableName tableName)
backupRootDir
- backup root directorybackupId
- backup idtable
- table namepublic static TableName[] parseTableNames(java.lang.String tables)
public static java.util.ArrayList<BackupInfo> sortHistoryListDesc(java.util.ArrayList<BackupInfo> historyList)
historyList
- history listpublic static java.lang.String getUniqueWALFileNamePart(java.lang.String walFileName) throws java.io.IOException
walFileName
- WAL file namejava.io.IOException
- exceptionjava.lang.IllegalArgumentException
- exceptionpublic static java.lang.String getUniqueWALFileNamePart(Path p) throws java.io.IOException
p
- - WAL file pathjava.io.IOException
- exceptionpublic static FileStatus[] listStatus(FileSystem fs, Path dir, PathFilter filter) throws java.io.IOException
fs
- file systemdir
- directoryfilter
- path filterjava.io.IOException
public static java.lang.String getPath(Path p)
hdfs://example.org:9000/hbase_trunk/TestTable/compaction.dir
,
this method returns /hbase_trunk/TestTable/compaction.dir
.
This method is useful if you want to print out a Path without qualifying
Filesystem instance.p
- Filesystem Path whose 'path' component we are to return.public static java.lang.String getLogBackupDir(java.lang.String backupRootDir, java.lang.String backupId)
backupRootDir
- backup root directorybackupId
- backup id