alluxio.master.journal.ufs

Class UfsJournalProgressLogger

java.lang.Object

alluxio.master.journal.AbstractJournalProgressLogger

alluxio.master.journal.ufs.UfsJournalProgressLogger

public class UfsJournalProgressLogger
extends AbstractJournalProgressLogger

Journal replay logger for the UfsJournal.

Field Summary

Fields inherited from class alluxio.master.journal.AbstractJournalProgressLogger

MAX_LOG_INTERVAL_MS

Constructor Summary

Constructors

Constructor and Description
UfsJournalProgressLogger(UfsJournal journal, OptionalLong endCommitIdx, java.util.function.Supplier<Long> lastIndexSupplier) Creates a new instance of the journal replay progress logger.

Method Summary

Modifier and Type	Method and Description
String	getJournalName()
long	getLastAppliedIndex()

Methods inherited from class alluxio.master.journal.AbstractJournalProgressLogger

logProgress

Methods inherited from class java.lang.Object

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

Constructor Detail

UfsJournalProgressLogger

public UfsJournalProgressLogger(UfsJournal journal,
                                OptionalLong endCommitIdx,
                                java.util.function.Supplier<Long> lastIndexSupplier)

Creates a new instance of the journal replay progress logger.

Parameters:

journal - the journal being replayed

endCommitIdx - the final commit index (sequence number) in the journal

lastIndexSupplier - supplier that gives the last applied commit (sequence number)

Method Detail

getLastAppliedIndex

public long getLastAppliedIndex()

Specified by:

getLastAppliedIndex in class AbstractJournalProgressLogger

Returns:

the last applied commit index to a journal

getJournalName

public String getJournalName()

Specified by:

getJournalName in class AbstractJournalProgressLogger

Returns:

the name of the journal