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 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)
java.io.File
getDirForNextEntryLog(java.util.List<java.io.File> writableLedgerDirs)
void
prepareEntryMemTableFlush()
void
prepareSortedLedgerStorageCheckpoint(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
-
-