Package org.apache.bookkeeper.bookie

Class EntryLogMetadata

java.lang.Object

org.apache.bookkeeper.bookie.EntryLogMetadata

Direct Known Subclasses:

EntryLogMetadata.EntryLogMetadataRecyclable

public class EntryLogMetadata
extends Object

Records the total size, remaining size and the set of ledgers that comprise a entry log.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	EntryLogMetadata.EntryLogMetadataRecyclable	Recyclable EntryLogMetadata class.

Field Summary

Fields

Modifier and Type	Field	Description
protected long	entryLogId
protected final ConcurrentLongLongHashMap	ledgersMap
protected long	remainingSize
protected long	totalSize

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	EntryLogMetadata()
	EntryLogMetadata(long logId)

Method Summary

Modifier and Type	Method	Description
void	addLedgerSize(long ledgerId, long size)
void	clear()
boolean	containsLedger(long ledgerId)
static EntryLogMetadata.EntryLogMetadataRecyclable	deserialize(DataInputStream in)	Deserializes EntryLogMetadata.EntryLogMetadataRecyclable from given DataInputStream.
long	getEntryLogId()
ConcurrentLongLongHashMap	getLedgersMap()
long	getRemainingSize()
long	getTotalSize()
double	getUsage()
boolean	isEmpty()
void	removeLedgerIf(LongPredicate predicate)
void	serialize(DataOutputStream out)	Serializes EntryLogMetadata and writes to DataOutputStream.
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

entryLogId

protected long entryLogId

totalSize

protected long totalSize

remainingSize

protected long remainingSize

ledgersMap

protected final ConcurrentLongLongHashMap ledgersMap

Constructor Details

EntryLogMetadata

protected EntryLogMetadata()

EntryLogMetadata

public EntryLogMetadata(long logId)

Method Details

addLedgerSize

public void addLedgerSize(long ledgerId,
 long size)

containsLedger

public boolean containsLedger(long ledgerId)

getUsage

public double getUsage()

isEmpty

public boolean isEmpty()

getEntryLogId

public long getEntryLogId()

getTotalSize

public long getTotalSize()

getRemainingSize

public long getRemainingSize()

getLedgersMap

public ConcurrentLongLongHashMap getLedgersMap()

removeLedgerIf

public void removeLedgerIf(LongPredicate predicate)

toString

public String toString()

Overrides:

toString in class Object

serialize

public void serialize(DataOutputStream out)
               throws IOException,
IllegalStateException

Serializes EntryLogMetadata and writes to DataOutputStream.

 schema:
 2-bytes: schema-version
 8-bytes: entrylog-entryLogId
 8-bytes: entrylog-totalSize
 8-bytes: entrylog-remainingSize
 8-bytes: total number of ledgers
 ledgers-map
 [repeat]: (8-bytes::ledgerId, 8-bytes::size-of-ledger)
 

Parameters:

out -

Throws:

IOException - throws if it couldn't serialize metadata-fields

IllegalStateException - throws if it couldn't serialize ledger-map

deserialize

public static EntryLogMetadata.EntryLogMetadataRecyclable deserialize(DataInputStream in)
                                                               throws IOException

Deserializes EntryLogMetadata.EntryLogMetadataRecyclable from given DataInputStream. Caller has to recycle returned EntryLogMetadata.EntryLogMetadataRecyclable.

Parameters:

in -

Returns:

Throws:

IOException

clear

public void clear()