alluxio.master.journal.ufs

Class UfsJournalCheckpointThread

java.lang.Object

java.lang.Thread

alluxio.master.journal.ufs.UfsJournalCheckpointThread

All Implemented Interfaces:

Runnable

@NotThreadSafe
public final class UfsJournalCheckpointThread
extends Thread

This thread continually replays the journal and applies it to the master, until the master initiates the shutdown of the thread. It periodically creates checkpoints. When the thread is stopped while it is writing checkpoint, the checkpoint being written will be cancelled. Once awaitTermination is called, the thread will ignore InterruptedException and shut down like normal (replaying all completed journal logs and waiting for a quiet period to elapse).

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
UfsJournalCheckpointThread(Master master, UfsJournal journal, long startSequence, java.util.function.Supplier<Set<JournalSink>> journalSinks) Creates a new instance of UfsJournalCheckpointThread.
UfsJournalCheckpointThread(Master master, UfsJournal journal, java.util.function.Supplier<Set<JournalSink>> journalSinks) Creates a new instance of UfsJournalCheckpointThread.

Method Summary

Modifier and Type	Method and Description
void	awaitTermination(boolean waitQuietPeriod) Initiates the shutdown of this checkpointer thread, and also waits for it to finish.
long	getNextSequenceNumber() This should only be called after awaitTermination(boolean).
void	run()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

UfsJournalCheckpointThread

public UfsJournalCheckpointThread(Master master,
                                  UfsJournal journal,
                                  java.util.function.Supplier<Set<JournalSink>> journalSinks)

Creates a new instance of UfsJournalCheckpointThread.

Parameters:

master - the master to apply the journal entries to

journal - the journal

journalSinks - a supplier for journal sinks

UfsJournalCheckpointThread

public UfsJournalCheckpointThread(Master master,
                                  UfsJournal journal,
                                  long startSequence,
                                  java.util.function.Supplier<Set<JournalSink>> journalSinks)

Creates a new instance of UfsJournalCheckpointThread.

Parameters:

master - the master to apply the journal entries to

journal - the journal

startSequence - the journal start sequence

journalSinks - a supplier for journal sinks

Method Detail

awaitTermination

public void awaitTermination(boolean waitQuietPeriod)

Initiates the shutdown of this checkpointer thread, and also waits for it to finish.

Parameters:

waitQuietPeriod - whether to wait for a quiet period to pass before terminating the thread

getNextSequenceNumber

public long getNextSequenceNumber()

This should only be called after awaitTermination(boolean).

Returns:

the last edit log sequence number read plus 1

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread