alluxio.master.file

Class FileSystemJournalEntryMerger

java.lang.Object

alluxio.master.file.FileSystemJournalEntryMerger

All Implemented Interfaces:

JournalEntryMerger

@ThreadSafe
public class FileSystemJournalEntryMerger
extends Object
implements JournalEntryMerger

A file system journal entry merger which merges inode creation and inode update journals on the same inode object into one. This class is not thread-safe and should not be shared across threads.

Constructor Summary

Constructors

Constructor and Description
FileSystemJournalEntryMerger()

Method Summary

Modifier and Type	Method and Description
void	add(Journal.JournalEntry entry) Adds a new journal entry and merges it on the fly.
void	clear() Clears the existing journal entries.
List<Journal.JournalEntry>	getMergedJournalEntries() Returns a list of journal entries which have been merged.

Methods inherited from class java.lang.Object

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

Constructor Detail

FileSystemJournalEntryMerger

public FileSystemJournalEntryMerger()

Method Detail

add

public void add(Journal.JournalEntry entry)

Adds a new journal entry and merges it on the fly.

Specified by:

add in interface JournalEntryMerger

Parameters:

entry - the new journal entry to add

getMergedJournalEntries

public List<Journal.JournalEntry> getMergedJournalEntries()

Description copied from interface: JournalEntryMerger

Returns a list of journal entries which have been merged.

Specified by:

getMergedJournalEntries in interface JournalEntryMerger

Returns:

the merged journal entries

clear

public void clear()

Description copied from interface: JournalEntryMerger

Clears the existing journal entries.

Specified by:

clear in interface JournalEntryMerger