Package org.apache.bookkeeper.bookie

Class DefaultEntryLogger.RecentEntryLogsStatus

java.lang.Object
org.apache.bookkeeper.bookie.DefaultEntryLogger.RecentEntryLogsStatus
Enclosing class:
DefaultEntryLogger
static class DefaultEntryLogger.RecentEntryLogsStatus extends Object
Datastructure which maintains the status of logchannels. When a logChannel is created entry of < entryLogId, false > will be made to this sortedmap and when logChannel is rotated and flushed then the entry is updated to < entryLogId, true > and all the lowest entries with < entryLogId, true > status will be removed from the sortedmap. So that way we could get least unflushed LogId.

  • Constructor Details

    • RecentEntryLogsStatus

      RecentEntryLogsStatus(long leastUnflushedLogId)

  • Method Details

    • createdEntryLog

      void createdEntryLog(Long entryLogId)

    • flushRotatedEntryLog

      void flushRotatedEntryLog(Long entryLogId)

    • getLeastUnflushedLogId

      long getLeastUnflushedLogId()

    • isFlushedLogId

      boolean isFlushedLogId(long entryLogId)