Package org.apache.bookkeeper.bookie

Interface EntryLogManager

All Known Implementing Classes:

EntryLogManagerBase, EntryLogManagerForEntryLogPerLedger, EntryLogManagerForSingleEntryLog

interface EntryLogManager

Method Summary

Modifier and Type	Method	Description
long	addEntry(long ledger, io.netty.buffer.ByteBuf entry, boolean rollLog)
void	checkpoint()
void	close()
boolean	commitEntryMemTableFlush()
DefaultEntryLogger.BufferedLogChannel	createNewLogForCompaction()
void	flush()
void	forceClose()
DefaultEntryLogger.BufferedLogChannel	getCurrentLogIfPresent(long entryLogId)
File	getDirForNextEntryLog(List<File> writableLedgerDirs)
void	prepareEntryMemTableFlush()
void	prepareSortedLedgerStorageCheckpoint(long numBytesFlushed)

Method Details

addEntry

long addEntry(long ledger,
 io.netty.buffer.ByteBuf entry,
 boolean rollLog)
       throws IOException

Throws:

IOException

getCurrentLogIfPresent

DefaultEntryLogger.BufferedLogChannel getCurrentLogIfPresent(long entryLogId)

getDirForNextEntryLog

File getDirForNextEntryLog(List<File> writableLedgerDirs)

checkpoint

void checkpoint()
         throws IOException

Throws:

IOException

flush

void flush()
    throws IOException

Throws:

IOException

close

void close()
    throws IOException

Throws:

IOException

forceClose

void forceClose()

prepareSortedLedgerStorageCheckpoint

void prepareSortedLedgerStorageCheckpoint(long numBytesFlushed)
                                   throws IOException

Throws:

IOException

prepareEntryMemTableFlush

void prepareEntryMemTableFlush()

commitEntryMemTableFlush

boolean commitEntryMemTableFlush()
                          throws IOException

Throws:

IOException

createNewLogForCompaction

DefaultEntryLogger.BufferedLogChannel createNewLogForCompaction()
                                                         throws IOException

Throws:

IOException