alluxio.master

Class BackupManager

java.lang.Object

alluxio.master.BackupManager

public class BackupManager
extends Object

Manages creating and restoring from backups. Journals are written as a series of entries in gzip format. TODO(ggezer) Abstract out common logic for backup/initFromBackup methods.

Field Summary

Fields

Modifier and Type	Field and Description
static String	BACKUP_FILE_FORMAT The name format of the backup files (E.g., alluxio-backup-2018-12-14-1544749081561.gz).
static Pattern	BACKUP_FILE_PATTERN

Constructor Summary

Constructors

Constructor and Description
BackupManager(MasterRegistry registry)

Method Summary

Modifier and Type	Method and Description
void	backup(OutputStream os, AtomicLong entryCount) Writes a backup to the specified stream.
void	initFromBackup(InputStream is) Restores master state from the specified backup.

Methods inherited from class java.lang.Object

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

Field Detail

BACKUP_FILE_FORMAT

public static final String BACKUP_FILE_FORMAT

The name format of the backup files (E.g., alluxio-backup-2018-12-14-1544749081561.gz). The first value is the current local date of UTC time zone. The second value is the number of milliseconds from the epoch of 1970-01-01T00:00:00Z to the current time.

See Also:

Constant Field Values

BACKUP_FILE_PATTERN

public static final Pattern BACKUP_FILE_PATTERN

Constructor Detail

BackupManager

public BackupManager(MasterRegistry registry)

Parameters:

registry - a master registry containing the masters to backup or restore

Method Detail

backup

public void backup(OutputStream os,
                   AtomicLong entryCount)
            throws IOException

Writes a backup to the specified stream.

Parameters:

os - the stream to write to

entryCount - will receive total entry count that are backed up

Throws:

IOException

initFromBackup

public void initFromBackup(InputStream is)
                    throws IOException

Restores master state from the specified backup.

Parameters:

is - an input stream to read from the backup

Throws:

IOException