Package org.apache.bookkeeper.bookie.storage.directentrylogger

Class DirectCompactionEntryLog

java.lang.Object

org.apache.bookkeeper.bookie.storage.directentrylogger.DirectCompactionEntryLog

All Implemented Interfaces:

CompactionEntryLog

public abstract class DirectCompactionEntryLog
extends Object
implements CompactionEntryLog

DirectCompactionEntryLog.

Field Summary

Fields

Modifier and Type	Field	Description
protected final File	compactedFile
protected final File	compactingFile
protected final File	completeFile
protected final int	dstLogId
protected final Slogger	slog
protected final int	srcLogId

Method Summary

Modifier and Type	Method	Description
void	abort()	Abort the compaction log.
static File	compactedFile(File directory, int newLogId, int compactedLogId)
static File	compactingFile(File directory, int logId)
void	finalizeAndCleanup()	Clean up any temporary resources that were used by the compaction process.
long	getDstLogId()	Get the log ID of the entrylog to which compacted entries are being written.
long	getSrcLogId()	Get the log ID of the entrylog which is being compacted.
void	makeAvailable()	Make the log written by the compaction process available for reads.
(package private) static CompactionEntryLog	newLog(int srcLogId, int dstLogId, File ledgerDir, long maxFileSize, ExecutorService writeExecutor, BufferPool writeBuffers, NativeIO nativeIO, io.netty.buffer.ByteBufAllocator allocator, Slogger slog)
(package private) static CompactionEntryLog	recoverLog(int srcLogId, int dstLogId, File ledgerDir, int readBufferSize, int maxSaneEntrySize, NativeIO nativeIO, io.netty.buffer.ByteBufAllocator allocator, OpStatsLogger readBlockStats, Slogger slog)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.bookkeeper.bookie.storage.CompactionEntryLog

addEntry, flush, markCompacted, scan

Field Details

srcLogId

protected final int srcLogId

dstLogId

protected final int dstLogId

slog

protected final Slogger slog

compactingFile

protected final File compactingFile

compactedFile

protected final File compactedFile

completeFile

protected final File completeFile

Method Details

newLog

static CompactionEntryLog newLog(int srcLogId,
 int dstLogId,
 File ledgerDir,
 long maxFileSize,
 ExecutorService writeExecutor,
 BufferPool writeBuffers,
 NativeIO nativeIO,
 io.netty.buffer.ByteBufAllocator allocator,
 Slogger slog)
                          throws IOException

Throws:

IOException

recoverLog

static CompactionEntryLog recoverLog(int srcLogId,
 int dstLogId,
 File ledgerDir,
 int readBufferSize,
 int maxSaneEntrySize,
 NativeIO nativeIO,
 io.netty.buffer.ByteBufAllocator allocator,
 OpStatsLogger readBlockStats,
 Slogger slog)

abort

public void abort()

Description copied from interface: CompactionEntryLog

Abort the compaction log. This should delete any resources held by this log.

Specified by:

abort in interface CompactionEntryLog

makeAvailable

public void makeAvailable()
                   throws IOException

Description copied from interface: CompactionEntryLog

Make the log written by the compaction process available for reads.

Specified by:

makeAvailable in interface CompactionEntryLog

Throws:

IOException

finalizeAndCleanup

public void finalizeAndCleanup()

Description copied from interface: CompactionEntryLog

Clean up any temporary resources that were used by the compaction process.

Specified by:

finalizeAndCleanup in interface CompactionEntryLog

getDstLogId

public long getDstLogId()

Description copied from interface: CompactionEntryLog

Get the log ID of the entrylog to which compacted entries are being written.

Specified by:

getDstLogId in interface CompactionEntryLog

getSrcLogId

public long getSrcLogId()

Description copied from interface: CompactionEntryLog

Get the log ID of the entrylog which is being compacted.

Specified by:

getSrcLogId in interface CompactionEntryLog

compactingFile

public static File compactingFile(File directory,
 int logId)

compactedFile

public static File compactedFile(File directory,
 int newLogId,
 int compactedLogId)