alluxio.master.journal.raft

Class RaftSnapshotManager

java.lang.Object

alluxio.master.journal.raft.RaftSnapshotManager

All Implemented Interfaces:

AutoCloseable

public class RaftSnapshotManager
extends Object
implements AutoCloseable

Manages a snapshot download.

Method Summary

Modifier and Type	Method and Description
void	close()
long	downloadSnapshotFromOtherMasters() Launches an asynchronous download of the most updated snapshot found on other masters in the cluster.
long	waitForAttemptToComplete() Waits synchronously for the download attempt to be complete.

Methods inherited from class java.lang.Object

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

Method Detail

waitForAttemptToComplete

public long waitForAttemptToComplete()

Waits synchronously for the download attempt to be complete.

Returns:

the result of the download attempt, or RaftLog.INVALID_LOG_INDEX if no attempt is underway

downloadSnapshotFromOtherMasters

public long downloadSnapshotFromOtherMasters()

Launches an asynchronous download of the most updated snapshot found on other masters in the cluster. If the asynchronous download is already in flight, it polls for the results.

Returns:

the log index of the last successful snapshot installation, or -1 if the download is in flight or has failed.

close

public void close()

Specified by:

close in interface AutoCloseable