Package org.apache.bookkeeper.meta

Class MSLedgerManagerFactory.MsLedgerManager

java.lang.Object

org.apache.bookkeeper.meta.MSLedgerManagerFactory.MsLedgerManager

All Implemented Interfaces:

Closeable, AutoCloseable, LedgerManager, MetastoreWatcher

Enclosing class:

MSLedgerManagerFactory

static class MSLedgerManagerFactory.MsLedgerManager
extends Object
implements LedgerManager, MetastoreWatcher

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	MSLedgerManagerFactory.MsLedgerManager.MSLedgerRangeIterator
protected class	MSLedgerManagerFactory.MsLedgerManager.ReadLedgerMetadataTask

Nested classes/interfaces inherited from interface org.apache.bookkeeper.meta.LedgerManager

LedgerManager.LedgerRange, LedgerManager.LedgerRangeIterator

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final AbstractConfiguration	conf
(package private) static final String	IDGEN_ZNODE
(package private) final MetastoreScannableTable	ledgerTable
protected final ConcurrentMap<Long,Set<BookkeeperInternalCallbacks.LedgerMetadataListener>>	listeners
(package private) final int	maxEntriesPerScan
(package private) final MetaStore	metastore
(package private) ScheduledExecutorService	scheduler
(package private) final org.apache.zookeeper.ZooKeeper	zk

Constructor Summary

Constructors

Constructor	Description
MsLedgerManager(AbstractConfiguration conf, org.apache.zookeeper.ZooKeeper zk, MetaStore metastore)

Method Summary

Modifier and Type	Method	Description
(package private) void	asyncProcessLedgers(MetastoreCursor cursor, BookkeeperInternalCallbacks.Processor<Long> processor, org.apache.zookeeper.AsyncCallback.VoidCallback finalCb, Object context, int successRc, int failureRc)
void	asyncProcessLedgers(BookkeeperInternalCallbacks.Processor<Long> processor, org.apache.zookeeper.AsyncCallback.VoidCallback finalCb, Object context, int successRc, int failureRc)	Loop to process all ledgers.
void	close()
CompletableFuture<Versioned<LedgerMetadata>>	createLedgerMetadata(long lid, LedgerMetadata metadata)	Create a new ledger with provided ledger id and metadata.
(package private) void	doAsyncProcessLedgers(MetastoreCursor cursor, BookkeeperInternalCallbacks.Processor<Long> processor, org.apache.zookeeper.AsyncCallback.VoidCallback finalCb, Object context, int successRc, int failureRc)
LedgerManager.LedgerRangeIterator	getLedgerRanges(long zkOpTimeoutMs)	Loop to scan a range of metadata from metadata storage.
static boolean	isSpecialZnode(String znode)	Whether the znode a special znode.
void	process(MSWatchedEvent e)
CompletableFuture<Versioned<LedgerMetadata>>	readLedgerMetadata(long ledgerId)	Read ledger metadata of a specified ledger.
void	registerLedgerMetadataListener(long ledgerId, BookkeeperInternalCallbacks.LedgerMetadataListener listener)	Register the ledger metadata listener on ledgerId.
CompletableFuture<Void>	removeLedgerMetadata(long ledgerId, Version version)	Remove a specified ledger metadata by ledgerId and version.
void	unregisterLedgerMetadataListener(long ledgerId, BookkeeperInternalCallbacks.LedgerMetadataListener listener)	Unregister the ledger metadata listener on ledgerId.
CompletableFuture<Versioned<LedgerMetadata>>	writeLedgerMetadata(long ledgerId, LedgerMetadata metadata, Version currentVersion)	Write ledger metadata.

Methods inherited from class java.lang.Object

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

Field Details

zk

final org.apache.zookeeper.ZooKeeper zk

conf

final AbstractConfiguration conf

metastore

final MetaStore metastore

ledgerTable

final MetastoreScannableTable ledgerTable

maxEntriesPerScan

final int maxEntriesPerScan

IDGEN_ZNODE

static final String IDGEN_ZNODE

See Also:

• Constant Field Values

listeners

protected final ConcurrentMap<Long,Set<BookkeeperInternalCallbacks.LedgerMetadataListener>> listeners

scheduler

ScheduledExecutorService scheduler

Constructor Details

MsLedgerManager

MsLedgerManager(AbstractConfiguration conf,
 org.apache.zookeeper.ZooKeeper zk,
 MetaStore metastore)

Method Details

process

public void process(MSWatchedEvent e)

Specified by:

process in interface MetastoreWatcher

registerLedgerMetadataListener

public void registerLedgerMetadataListener(long ledgerId,
 BookkeeperInternalCallbacks.LedgerMetadataListener listener)

Description copied from interface: LedgerManager

Register the ledger metadata listener on ledgerId.

Specified by:

registerLedgerMetadataListener in interface LedgerManager

Parameters:

ledgerId - ledger id.

listener - listener.

unregisterLedgerMetadataListener

public void unregisterLedgerMetadataListener(long ledgerId,
 BookkeeperInternalCallbacks.LedgerMetadataListener listener)

Description copied from interface: LedgerManager

Unregister the ledger metadata listener on ledgerId.

Specified by:

unregisterLedgerMetadataListener in interface LedgerManager

Parameters:

ledgerId - ledger id.

listener - ledger metadata listener.

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

createLedgerMetadata

public CompletableFuture<Versioned<LedgerMetadata>> createLedgerMetadata(long lid,
 LedgerMetadata metadata)

Description copied from interface: LedgerManager

Create a new ledger with provided ledger id and metadata.

Specified by:

createLedgerMetadata in interface LedgerManager

Parameters:

lid - Ledger id provided to be created

metadata - Metadata provided when creating the new ledger

Returns:

Future which, when completed returns the metadata of the newly created ledger. Completed with an exception:

• BKException.BKLedgerExistException if given ledger id exist
• BKException.ZKException /BKException.BKMetadataSerializationException for other issues

removeLedgerMetadata

public CompletableFuture<Void> removeLedgerMetadata(long ledgerId,
 Version version)

Description copied from interface: LedgerManager

Remove a specified ledger metadata by ledgerId and version.

Specified by:

removeLedgerMetadata in interface LedgerManager

Parameters:

ledgerId - Ledger Id

version - Ledger metadata version

Returns:

Future which, when completed, denotes that the ledger metadata has been removed. Completed with an exception:

• BKException.BKMetadataVersionException if version doesn't match
• BKException.BKNoSuchLedgerExistsOnMetadataServerException if ledger not exist
• BKException.ZKException for other issues

readLedgerMetadata

public CompletableFuture<Versioned<LedgerMetadata>> readLedgerMetadata(long ledgerId)

Description copied from interface: LedgerManager

Read ledger metadata of a specified ledger.

Specified by:

readLedgerMetadata in interface LedgerManager

Parameters:

ledgerId - Ledger Id

Returns:

Future which, when completed, contains the requested versioned metadata. Completed with an exception::

• BKException.BKNoSuchLedgerExistsOnMetadataServerException if ledger not exist
• BKException.ZKException for other issues

writeLedgerMetadata

public CompletableFuture<Versioned<LedgerMetadata>> writeLedgerMetadata(long ledgerId,
 LedgerMetadata metadata,
 Version currentVersion)

Description copied from interface: LedgerManager

Write ledger metadata.

Specified by:

writeLedgerMetadata in interface LedgerManager

Parameters:

ledgerId - Ledger Id

metadata - Ledger Metadata to write

currentVersion - The version of the metadata we expect to be overwriting.

Returns:

Future which, when completed, contains the newly written metadata. Completed with an exception:

• BKException.BKMetadataVersionException if version in metadata doesn't match
• BKException.ZKException for other issue

asyncProcessLedgers

public void asyncProcessLedgers(BookkeeperInternalCallbacks.Processor<Long> processor,
 org.apache.zookeeper.AsyncCallback.VoidCallback finalCb,
 Object context,
 int successRc,
 int failureRc)

Description copied from interface: LedgerManager

Loop to process all ledgers.

After all ledgers were processed, finalCb will be triggered:
• if all ledgers are processed done with OK, success rc will be passed to finalCb.
• if some ledgers are processed failed, failure rc will be passed to finalCb.

Specified by:

asyncProcessLedgers in interface LedgerManager

Parameters:

processor - Ledger Processor to process a specific ledger

finalCb - Callback triggered after all ledgers are processed

context - Context of final callback

successRc - Success RC code passed to finalCb when callback

failureRc - Failure RC code passed to finalCb when exceptions occurred.

asyncProcessLedgers

void asyncProcessLedgers(MetastoreCursor cursor,
 BookkeeperInternalCallbacks.Processor<Long> processor,
 org.apache.zookeeper.AsyncCallback.VoidCallback finalCb,
 Object context,
 int successRc,
 int failureRc)

doAsyncProcessLedgers

void doAsyncProcessLedgers(MetastoreCursor cursor,
 BookkeeperInternalCallbacks.Processor<Long> processor,
 org.apache.zookeeper.AsyncCallback.VoidCallback finalCb,
 Object context,
 int successRc,
 int failureRc)

getLedgerRanges

public LedgerManager.LedgerRangeIterator getLedgerRanges(long zkOpTimeoutMs)

Description copied from interface: LedgerManager

Loop to scan a range of metadata from metadata storage.

Specified by:

getLedgerRanges in interface LedgerManager

Parameters:

zkOpTimeoutMs - Iterator considers timeout while fetching ledger-range from zk.

Returns:

will return a iterator of the Ranges

isSpecialZnode

public static boolean isSpecialZnode(String znode)

Whether the znode a special znode.

Parameters:

znode - Znode Name

Returns:

true if the znode is a special znode otherwise false