Package org.apache.bookkeeper.bookie.storage.ldb

Class PersistentEntryLogMetadataMap

java.lang.Object

org.apache.bookkeeper.bookie.storage.ldb.PersistentEntryLogMetadataMap

All Implemented Interfaces:

Closeable, AutoCloseable, EntryLogMetadataMap

public class PersistentEntryLogMetadataMap
extends Object
implements EntryLogMetadataMap

Persistent entryLogMetadata-map that stores entry-loggers metadata into rocksDB.

Constructor Summary

Constructors

Constructor	Description
PersistentEntryLogMetadataMap(String metadataPath, ServerConfiguration conf)

Method Summary

Modifier and Type	Method	Description
void	clear()	Clear all records from the map.
void	close()
boolean	containsKey(long entryLogId)	Checks if record with entryLogId exists into the map.
void	forEach(BiConsumer<Long,EntryLogMetadata> action)	EntryLogMetadata life-cycle in supplied action will be transient and it will be recycled as soon as supplied action is completed.
void	forKey(long entryLogId, BiConsumer<Long,EntryLogMetadata> action)	EntryLogMetadata life-cycle in supplied action will be transient and it will be recycled as soon as supplied action is completed.
void	put(long entryLogId, EntryLogMetadata entryLogMeta)	Adds entryLogMetadata record into the map.
void	remove(long entryLogId)	Removes entryLogMetadata record from the map.
int	size()	Returns number of entryLogMetadata records presents into the map.
void	throwIfClosed()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.bookkeeper.bookie.EntryLogMetadataMap

isEmpty

Constructor Details

PersistentEntryLogMetadataMap

public PersistentEntryLogMetadataMap(String metadataPath,
 ServerConfiguration conf)
                              throws IOException

Throws:

IOException

Method Details

containsKey

public boolean containsKey(long entryLogId)
                    throws BookieException.EntryLogMetadataMapException

Description copied from interface: EntryLogMetadataMap

Checks if record with entryLogId exists into the map.

Specified by:

containsKey in interface EntryLogMetadataMap

Returns:

Throws:

BookieException.EntryLogMetadataMapException

put

public void put(long entryLogId,
 EntryLogMetadata entryLogMeta)
         throws BookieException.EntryLogMetadataMapException

Description copied from interface: EntryLogMetadataMap

Adds entryLogMetadata record into the map.

Specified by:

put in interface EntryLogMetadataMap

Throws:

BookieException.EntryLogMetadataMapException

forEach

public void forEach(BiConsumer<Long,EntryLogMetadata> action)
             throws BookieException.EntryLogMetadataMapException

EntryLogMetadata life-cycle in supplied action will be transient and it will be recycled as soon as supplied action is completed.

Specified by:

forEach in interface EntryLogMetadataMap

Throws:

BookieException.EntryLogMetadataMapException

forKey

public void forKey(long entryLogId,
 BiConsumer<Long,EntryLogMetadata> action)
            throws BookieException.EntryLogMetadataMapException

EntryLogMetadata life-cycle in supplied action will be transient and it will be recycled as soon as supplied action is completed.

Specified by:

forKey in interface EntryLogMetadataMap

Throws:

BookieException.EntryLogMetadataMapException

remove

public void remove(long entryLogId)
            throws BookieException.EntryLogMetadataMapException

Description copied from interface: EntryLogMetadataMap

Removes entryLogMetadata record from the map.

Specified by:

remove in interface EntryLogMetadataMap

Throws:

BookieException.EntryLogMetadataMapException

size

public int size()
         throws BookieException.EntryLogMetadataMapException

Description copied from interface: EntryLogMetadataMap

Returns number of entryLogMetadata records presents into the map.

Specified by:

size in interface EntryLogMetadataMap

Returns:

Throws:

BookieException.EntryLogMetadataMapException

clear

public void clear()
           throws BookieException.EntryLogMetadataMapException

Description copied from interface: EntryLogMetadataMap

Clear all records from the map. For unit tests.

Specified by:

clear in interface EntryLogMetadataMap

Throws:

BookieException.EntryLogMetadataMapException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

throwIfClosed

public void throwIfClosed()
                   throws BookieException.EntryLogMetadataMapException

Throws:

BookieException.EntryLogMetadataMapException