@InterfaceAudience.Private @InterfaceStability.Evolving public final class BackupServerUtil 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 void |
cleanupBackupData(BackupInfo context,
Configuration conf) |
static void |
copyTableRegionInfo(BackupInfo backupContext,
Configuration conf)
copy out Table RegionInfo into incremental backup image need to consider move this logic into
HBackupFileSystem
|
static long |
getFilesLength(FileSystem fs,
Path dir)
Get the total length of files under the given directory recursively.
|
static java.util.List<java.lang.String> |
getListOfWALFiles(Configuration c)
Get list of all WAL files (WALs and archive)
|
static java.util.List<java.lang.String> |
getListOfWALFiles(Configuration c,
PathFilter filter)
Get list of all WAL files (WALs and archive)
|
static java.util.HashMap<java.lang.String,java.lang.Long> |
getRSLogTimestampMins(java.util.HashMap<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> rsLogTimestampMap)
Loop through the RS log timestamp map for the tables, for each RS, find the min timestamp
value for the RS among the tables.
|
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 java.util.List<java.lang.String> |
getWALFilesOlderThan(Configuration c,
java.util.HashMap<java.lang.String,java.lang.Long> hostTimestampMap)
Get list of all old WAL files (WALs and archive)
|
static java.lang.String |
join(TableName[] names) |
static java.lang.String |
parseHostNameFromLogFile(Path p)
TODO: return hostname:port
|
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.
|
static void |
waitForSnapshot(HBaseProtos.SnapshotDescription snapshot,
long max,
SnapshotManager snapshotMgr,
Configuration conf) |
static void |
writeRegioninfoOnFilesystem(Configuration conf,
FileSystem fs,
Path regionInfoDir,
HRegionInfo regionInfo)
Write the .regioninfo file on-disk.
|
protected static final Log LOG
public static final java.lang.String LOGNAME_SEPARATOR
public static void waitForSnapshot(HBaseProtos.SnapshotDescription snapshot, long max, SnapshotManager snapshotMgr, Configuration conf) throws java.io.IOException
java.io.IOException
public static java.util.HashMap<java.lang.String,java.lang.Long> getRSLogTimestampMins(java.util.HashMap<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> rsLogTimestampMap)
rsLogTimestampMap
- timestamp mappublic static void copyTableRegionInfo(BackupInfo backupContext, Configuration conf) throws java.io.IOException, java.lang.InterruptedException
backupContext
- backup contextconf
- configurationjava.io.IOException
- exceptionjava.lang.InterruptedException
- exceptionpublic static void writeRegioninfoOnFilesystem(Configuration conf, FileSystem fs, Path regionInfoDir, HRegionInfo regionInfo) throws java.io.IOException
java.io.IOException
public static java.lang.String parseHostNameFromLogFile(Path p) throws java.io.IOException
p
- java.io.IOException
public 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 long getFilesLength(FileSystem fs, Path dir) throws java.io.IOException
fs
- The hadoop file systemdir
- The target directoryjava.io.IOException
- exceptionpublic static java.util.ArrayList<BackupInfo> sortHistoryListDesc(java.util.ArrayList<BackupInfo> historyList)
historyList
- history listpublic static java.util.List<java.lang.String> getListOfWALFiles(Configuration c) throws java.io.IOException
c
- - configurationjava.io.IOException
- exceptionpublic static java.util.List<java.lang.String> getListOfWALFiles(Configuration c, PathFilter filter) throws java.io.IOException
c
- - configurationjava.io.IOException
- exceptionpublic static java.util.List<java.lang.String> getWALFilesOlderThan(Configuration c, java.util.HashMap<java.lang.String,java.lang.Long> hostTimestampMap) throws java.io.IOException
c
- - configurationhostTimestampMap
- - host timestamp mapjava.io.IOException
- exceptionpublic static java.lang.String join(TableName[] names)
public static TableName[] parseTableNames(java.lang.String tables)
public static void cleanupBackupData(BackupInfo context, Configuration conf) throws java.io.IOException
java.io.IOException