alluxio.master.journal.raft

Class RaftJournalUtils

java.lang.Object

alluxio.master.journal.raft.RaftJournalUtils

public class RaftJournalUtils
extends Object

Helper class for raft journal operations.

Field Summary

Fields

Modifier and Type	Field and Description
static String	RAFT_DIR

Method Summary

Modifier and Type	Method and Description
static <T> CompletableFuture<T>	completeExceptionally(Exception e) Creates a future that is completed exceptionally.
static File	createTempSnapshotFile(org.apache.ratis.statemachine.impl.SimpleStateMachineStorage storage) Creates a temporary snapshot file.
static org.apache.ratis.protocol.RaftPeerId	getPeerId(InetSocketAddress address) Gets the raft peer id.
static org.apache.ratis.protocol.RaftPeerId	getPeerId(String host, int port) Gets the raft peer id.
static File	getRaftJournalDir(File baseDir) Gets the raft journal dir.

Methods inherited from class java.lang.Object

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

Field Detail

RAFT_DIR

public static final String RAFT_DIR

See Also:

Constant Field Values

Method Detail

getPeerId

public static org.apache.ratis.protocol.RaftPeerId getPeerId(InetSocketAddress address)

Gets the raft peer id.

Parameters:

address - the address of the server

Returns:

the raft peer id

getPeerId

public static org.apache.ratis.protocol.RaftPeerId getPeerId(String host,
                                                             int port)

Gets the raft peer id.

Parameters:

host - the hostname of the server

port - the port of the server

Returns:

the raft peer id

getRaftJournalDir

public static File getRaftJournalDir(File baseDir)

Gets the raft journal dir.

Parameters:

baseDir - the journal base dir

Returns:

the raft peer id

createTempSnapshotFile

public static File createTempSnapshotFile(org.apache.ratis.statemachine.impl.SimpleStateMachineStorage storage)
                                   throws IOException

Creates a temporary snapshot file.

Parameters:

storage - the snapshot storage

Returns:

the temporary snapshot file

Throws:

IOException - if error occurred while creating the snapshot file

completeExceptionally

public static <T> CompletableFuture<T> completeExceptionally(Exception e)

Creates a future that is completed exceptionally.

Type Parameters:

T - the type of the future

Parameters:

e - the exception to be returned by the future

Returns:

the completed future