alluxio.master.journal.raft

Class SnapshotDirStateMachineStorage

java.lang.Object

alluxio.master.journal.raft.SnapshotDirStateMachineStorage

All Implemented Interfaces:

org.apache.ratis.statemachine.StateMachineStorage

public class SnapshotDirStateMachineStorage
extends Object
implements org.apache.ratis.statemachine.StateMachineStorage

Simple state machine storage that can handle directories.

Constructor Summary

Constructors

Constructor and Description
SnapshotDirStateMachineStorage()

Method Summary

Modifier and Type	Method and Description
void	cleanupOldSnapshots(org.apache.ratis.statemachine.SnapshotRetentionPolicy retentionPolicy)
void	format()
org.apache.ratis.statemachine.SnapshotInfo	getLatestSnapshot()
File	getSnapshotDir()
File	getTmpDir()
void	init(org.apache.ratis.server.storage.RaftStorage raftStorage)
void	loadLatestSnapshot() Loads the latest snapshot information into the StateMachineStorage.
static Matcher	matchSnapshotPath(Path path)
void	signalNewSnapshot() Signal to the StateMachineStorage that a new snapshot was taken.

Methods inherited from class java.lang.Object

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

Constructor Detail

SnapshotDirStateMachineStorage

public SnapshotDirStateMachineStorage()

Method Detail

matchSnapshotPath

public static Matcher matchSnapshotPath(Path path)

Parameters:

path - to evaluate

Returns:

a matcher to evaluate if the leaf of the provided path has a name that matches the pattern of snapshot directories

init

public void init(org.apache.ratis.server.storage.RaftStorage raftStorage)
          throws IOException

Specified by:

init in interface org.apache.ratis.statemachine.StateMachineStorage

Throws:

IOException

loadLatestSnapshot

public void loadLatestSnapshot()

Loads the latest snapshot information into the StateMachineStorage.

getLatestSnapshot

@Nullable
public org.apache.ratis.statemachine.SnapshotInfo getLatestSnapshot()

Specified by:

getLatestSnapshot in interface org.apache.ratis.statemachine.StateMachineStorage

format

public void format()
            throws IOException

Specified by:

format in interface org.apache.ratis.statemachine.StateMachineStorage

Throws:

IOException

signalNewSnapshot

public void signalNewSnapshot()

Signal to the StateMachineStorage that a new snapshot was taken.

cleanupOldSnapshots

public void cleanupOldSnapshots(org.apache.ratis.statemachine.SnapshotRetentionPolicy retentionPolicy)
                         throws IOException

Specified by:

cleanupOldSnapshots in interface org.apache.ratis.statemachine.StateMachineStorage

Throws:

IOException

getSnapshotDir

public File getSnapshotDir()

getTmpDir

public File getTmpDir()