alluxio.master.scheduler

Class JournaledJobMetaStore

java.lang.Object

alluxio.master.scheduler.JournaledJobMetaStore

All Implemented Interfaces:

Checkpointed, Journaled, JournalEntryIterable, JobMetaStore

public class JournaledJobMetaStore
extends Object
implements JobMetaStore, Journaled

A journaled job meta store.

Constructor Summary

Constructors

Constructor and Description
JournaledJobMetaStore(FileSystemMaster fileSystemMaster) Creates a new instance of JournaledJobMetaStore.

Method Summary

Modifier and Type	Method and Description
CheckpointName	getCheckpointName()
Set<Job<?>>	getJobs()
CloseableIterator<Journal.JournalEntry>	getJournalEntryIterator()
boolean	processJournalEntry(Journal.JournalEntry entry) Attempts to apply a journal entry.
void	resetState() Resets the object's journaled state.
void	updateJob(Job<?> job) Update existing job in the meta store with the new job.

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.master.journal.Journaled

applyAndJournal, restoreFromCheckpoint, writeToCheckpoint

Constructor Detail

JournaledJobMetaStore

public JournaledJobMetaStore(FileSystemMaster fileSystemMaster)

Creates a new instance of JournaledJobMetaStore.

Parameters:

fileSystemMaster - the file system master

Method Detail

getJournalEntryIterator

public CloseableIterator<Journal.JournalEntry> getJournalEntryIterator()

Specified by:

getJournalEntryIterator in interface JournalEntryIterable

Returns:

an CloseableIterator that iterates all the journal entries

processJournalEntry

public boolean processJournalEntry(Journal.JournalEntry entry)

Description copied from interface: Journaled

Attempts to apply a journal entry.

Specified by:

processJournalEntry in interface Journaled

Parameters:

entry - the entry to apply

Returns:

whether the entry type is supported by this journaled object

resetState

public void resetState()

Description copied from interface: Journaled

Resets the object's journaled state.

Specified by:

resetState in interface Journaled

getCheckpointName

public CheckpointName getCheckpointName()

Specified by:

getCheckpointName in interface Checkpointed

Returns:

a name for this checkpointed class

updateJob

public void updateJob(Job<?> job)

Description copied from interface: JobMetaStore

Update existing job in the meta store with the new job.

Specified by:

updateJob in interface JobMetaStore

Parameters:

job - the job used to update the existing job in the meta store

getJobs

public Set<Job<?>> getJobs()

Specified by:

getJobs in interface JobMetaStore

Returns:

all the jobs in the meta store