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 java.lang.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 Summary

Constructors

Constructor	Description
RecentEntryLogsStatus(long leastUnflushedLogId)

Method Summary

Modifier and Type	Method	Description
(package private) void	createdEntryLog(java.lang.Long entryLogId)
(package private) void	flushRotatedEntryLog(java.lang.Long entryLogId)
(package private) long	getLeastUnflushedLogId()
(package private) boolean	isFlushedLogId(long entryLogId)

Methods inherited from class java.lang.Object

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

Constructor Detail

RecentEntryLogsStatus

RecentEntryLogsStatus(long leastUnflushedLogId)

Method Detail

createdEntryLog

void createdEntryLog(java.lang.Long entryLogId)

flushRotatedEntryLog

void flushRotatedEntryLog(java.lang.Long entryLogId)

getLeastUnflushedLogId

long getLeastUnflushedLogId()

isFlushedLogId

boolean isFlushedLogId(long entryLogId)