Package org.apache.bookkeeper.bookie
Interface EntryLogManager
-
- All Known Implementing Classes:
EntryLogManagerBase,EntryLogManagerForEntryLogPerLedger,EntryLogManagerForSingleEntryLog
interface EntryLogManager
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description longaddEntry(long ledger, io.netty.buffer.ByteBuf entry, boolean rollLog)voidcheckpoint()voidclose()booleancommitEntryMemTableFlush()DefaultEntryLogger.BufferedLogChannelcreateNewLogForCompaction()voidflush()voidforceClose()DefaultEntryLogger.BufferedLogChannelgetCurrentLogIfPresent(long entryLogId)java.io.FilegetDirForNextEntryLog(java.util.List<java.io.File> writableLedgerDirs)voidprepareEntryMemTableFlush()voidprepareSortedLedgerStorageCheckpoint(long numBytesFlushed)
-
-
-
Method Detail
-
addEntry
long addEntry(long ledger, io.netty.buffer.ByteBuf entry, boolean rollLog) throws java.io.IOException- Throws:
java.io.IOException
-
getCurrentLogIfPresent
DefaultEntryLogger.BufferedLogChannel getCurrentLogIfPresent(long entryLogId)
-
getDirForNextEntryLog
java.io.File getDirForNextEntryLog(java.util.List<java.io.File> writableLedgerDirs)
-
checkpoint
void checkpoint() throws java.io.IOException- Throws:
java.io.IOException
-
flush
void flush() throws java.io.IOException- Throws:
java.io.IOException
-
close
void close() throws java.io.IOException- Throws:
java.io.IOException
-
forceClose
void forceClose()
-
prepareSortedLedgerStorageCheckpoint
void prepareSortedLedgerStorageCheckpoint(long numBytesFlushed) throws java.io.IOException- Throws:
java.io.IOException
-
prepareEntryMemTableFlush
void prepareEntryMemTableFlush()
-
commitEntryMemTableFlush
boolean commitEntryMemTableFlush() throws java.io.IOException- Throws:
java.io.IOException
-
createNewLogForCompaction
DefaultEntryLogger.BufferedLogChannel createNewLogForCompaction() throws java.io.IOException
- Throws:
java.io.IOException
-
-