alluxio.master.journal.tool

Class AbstractJournalDumper

java.lang.Object

alluxio.master.journal.tool.AbstractJournalDumper

Direct Known Subclasses:

RaftJournalDumper, UfsJournalDumper

public abstract class AbstractJournalDumper
extends Object

An abstract class for journal dumpers.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	mCheckpointsDir
protected long	mEnd
protected String	mInputDir
protected String	mJournalEntryFile
protected String	mMaster
protected String	mOutputDir
protected long	mStart

Constructor Summary

Constructors

Constructor and Description
AbstractJournalDumper(String master, long start, long end, String outputDir, String inputDir)

Method Summary

Modifier and Type	Method and Description
protected void	readCheckpoint(CheckpointInputStream checkpoint, Path path) Used to read checkpoint streams.

Methods inherited from class java.lang.Object

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

Field Detail

mMaster

protected final String mMaster

mStart

protected final long mStart

mEnd

protected final long mEnd

mInputDir

protected final String mInputDir

mOutputDir

protected final String mOutputDir

mCheckpointsDir

protected final String mCheckpointsDir

mJournalEntryFile

protected final String mJournalEntryFile

Constructor Detail

AbstractJournalDumper

public AbstractJournalDumper(String master,
                             long start,
                             long end,
                             String outputDir,
                             String inputDir)
                      throws IOException

Parameters:

master - journal master

start - journal start sequence

end - journal end sequence

outputDir - output dir for journal dump

inputDir - input dir for journal files

Throws:

IOException

Method Detail

readCheckpoint

protected void readCheckpoint(CheckpointInputStream checkpoint,
                              Path path)
                       throws IOException

Used to read checkpoint streams.

Parameters:

checkpoint - the checkpoint stream

path - persistence path

Throws:

IOException - if checkpoint read fails