alluxio.master.backup

Class BackupTracker

java.lang.Object

alluxio.master.backup.BackupTracker

public class BackupTracker
extends java.lang.Object

Used to track and update status of a backup.

Constructor Summary

Constructors

Constructor and Description
BackupTracker() Creates a tracker.

Method Summary

Modifier and Type	Method and Description
BackupStatus	getCurrentStatus()
java.util.concurrent.atomic.AtomicLong	getEntryCounter()
BackupStatus	getStatus(java.util.UUID backupId)
boolean	inProgress()
void	reset() Resets this tracker.
void	update(BackupStatus status) Replaces the internal status with given status.
void	updateBackupUri(AlluxioURI backupUri) Updates backup URI of status.
void	updateError(AlluxioException error) Updates the error of backup status.
void	updateHostname(java.lang.String hostname) Updates hostname of backup status.
void	updateState(BackupState state) Updates the state of backup status.
void	waitUntilFinished() Used to wait until this backup is finished.
boolean	waitUntilFinished(long timeout, java.util.concurrent.TimeUnit unit) Used to wait until this backup is finished.

Methods inherited from class java.lang.Object

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

Constructor Detail

BackupTracker

public BackupTracker()

Creates a tracker.

Method Detail

reset

public void reset()

Resets this tracker.

getCurrentStatus

public BackupStatus getCurrentStatus()

Returns:

the status of the current backup

getStatus

public BackupStatus getStatus(java.util.UUID backupId)

Parameters:

backupId - the backup id

Returns:

the status of a backup

getEntryCounter

public java.util.concurrent.atomic.AtomicLong getEntryCounter()

Returns:

the entry counter

update

public void update(BackupStatus status)

Replaces the internal status with given status.

Parameters:

status - the backup status

updateHostname

public void updateHostname(java.lang.String hostname)

Updates hostname of backup status.

Parameters:

hostname - the hostname

updateBackupUri

public void updateBackupUri(AlluxioURI backupUri)

Updates backup URI of status.

Parameters:

backupUri - the backup URI

updateState

public void updateState(BackupState state)

Updates the state of backup status.

Parameters:

state - the backup state

updateError

public void updateError(AlluxioException error)

Updates the error of backup status.

Parameters:

error - the backup error

waitUntilFinished

public void waitUntilFinished()
                       throws AlluxioException

Used to wait until this backup is finished.

Throws:

AlluxioStatusException - if backup failed

AlluxioException

waitUntilFinished

public boolean waitUntilFinished(long timeout,
                                 java.util.concurrent.TimeUnit unit)

Used to wait until this backup is finished.

Parameters:

timeout - timeout duration

unit - time unit

Returns:

true if backup is finished

inProgress

public boolean inProgress()

Returns:

true if a backup is in progress