Package org.apache.bookkeeper.meta

Class MSLedgerManagerFactory

java.lang.Object

org.apache.bookkeeper.meta.AbstractZkLedgerManagerFactory

org.apache.bookkeeper.meta.MSLedgerManagerFactory

All Implemented Interfaces:

AutoCloseable, LedgerManagerFactory

public class MSLedgerManagerFactory
extends AbstractZkLedgerManagerFactory

Deprecated.

since 4.7.0

MetaStore Based Ledger Manager Factory.

MSLedgerManagerFactory is a legacy abstraction that mixing zookeeper with a metadata store interface. It is not used by any production systems. It should be deprecated soon.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	MSLedgerManagerFactory.MsLedgerManager	Deprecated.
(package private) static class	MSLedgerManagerFactory.SyncResult<T>	Deprecated.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) AbstractConfiguration	conf	Deprecated.
static final int	CUR_VERSION	Deprecated.
static final String	META_FIELD	Deprecated.
(package private) MetaStore	metastore	Deprecated.
static final String	NAME	Deprecated.
static final String	TABLE_NAME	Deprecated.

Fields inherited from class org.apache.bookkeeper.meta.AbstractZkLedgerManagerFactory

V1, zk

Constructor Summary

Constructors

Constructor	Description
MSLedgerManagerFactory()	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	close()	Deprecated. Uninitialize the factory.
(package private) static SortedSet<Long>	entries2Ledgers(Iterator<MetastoreTableItem> entries)	Deprecated.
void	format(AbstractConfiguration<?> conf, LayoutManager layoutManager)	Deprecated. Format the ledger metadata for LedgerManager.
int	getCurrentVersion()	Deprecated. Return current factory version.
LedgerManagerFactory	initialize(AbstractConfiguration conf, LayoutManager layoutManager, int factoryVersion)	Deprecated. Initialize a factory.
(package private) static Long	key2LedgerId(String key)	Deprecated.
(package private) static String	ledgerId2Key(Long lid)	Deprecated.
LedgerAuditorManager	newLedgerAuditorManager()	Deprecated. Return a ledger auditor manager, which is used to coordinate the auto-recovery process.
LedgerIdGenerator	newLedgerIdGenerator()	Deprecated. Return the ledger id generator, which is used for global unique ledger id generation.
LedgerManager	newLedgerManager()	Deprecated. return ledger manager for client-side to manage ledger metadata.
LedgerUnderreplicationManager	newLedgerUnderreplicationManager()	Deprecated. Return a ledger underreplication manager, which is used to mark ledgers as unreplicated, and to retrieve a ledger which is underreplicated so that it can be rereplicated.
(package private) static String	rangeToString(Long firstLedger, boolean firstInclusive, Long lastLedger, boolean lastInclusive)	Deprecated.
boolean	validateAndNukeExistingCluster(AbstractConfiguration<?> conf, LayoutManager layoutManager)	Deprecated. This method makes sure there are no unexpected znodes under ledgersRootPath and then it proceeds with ledger metadata formatting and nuking the cluster ZK state info.

Methods inherited from class org.apache.bookkeeper.meta.AbstractZkLedgerManagerFactory

createNewLMFactory, newLedgerManagerFactory

Methods inherited from class java.lang.Object

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

Field Details

CUR_VERSION

public static final int CUR_VERSION

Deprecated.

See Also:

• Constant Field Values

NAME

public static final String NAME

Deprecated.

See Also:

• Constant Field Values

TABLE_NAME

public static final String TABLE_NAME

Deprecated.

See Also:

• Constant Field Values

META_FIELD

public static final String META_FIELD

Deprecated.

See Also:

• Constant Field Values

conf

AbstractConfiguration conf

Deprecated.

metastore

MetaStore metastore

Deprecated.

Constructor Details

MSLedgerManagerFactory

public MSLedgerManagerFactory()

Deprecated.

Method Details

getCurrentVersion

public int getCurrentVersion()

Deprecated.

Description copied from interface: LedgerManagerFactory

Return current factory version.

Returns:

current version used by factory.

initialize

public LedgerManagerFactory initialize(AbstractConfiguration conf,
 LayoutManager layoutManager,
 int factoryVersion)
                                throws IOException

Deprecated.

Description copied from interface: LedgerManagerFactory

Initialize a factory.

Parameters:

conf - Configuration object used to initialize factory

layoutManager - Layout manager used for initialize ledger manager factory

factoryVersion - What version used to initialize factory.

Returns:

ledger manager factory instance

Throws:

IOException - when fail to initialize the factory.

close

public void close()
           throws IOException

Deprecated.

Description copied from interface: LedgerManagerFactory

Uninitialize the factory.

Throws:

IOException - when fail to uninitialize the factory.

key2LedgerId

static Long key2LedgerId(String key)

Deprecated.

ledgerId2Key

static String ledgerId2Key(Long lid)

Deprecated.

rangeToString

static String rangeToString(Long firstLedger,
 boolean firstInclusive,
 Long lastLedger,
 boolean lastInclusive)

Deprecated.

entries2Ledgers

static SortedSet<Long> entries2Ledgers(Iterator<MetastoreTableItem> entries)

Deprecated.

newLedgerIdGenerator

public LedgerIdGenerator newLedgerIdGenerator()

Deprecated.

Description copied from interface: LedgerManagerFactory

Return the ledger id generator, which is used for global unique ledger id generation.

Returns:

ledger id generator.

newLedgerManager

public LedgerManager newLedgerManager()

Deprecated.

Description copied from interface: LedgerManagerFactory

return ledger manager for client-side to manage ledger metadata.

Returns:

ledger manager

See Also:

• LedgerManager

newLedgerUnderreplicationManager

public LedgerUnderreplicationManager newLedgerUnderreplicationManager()
                                                               throws ReplicationException.UnavailableException,
InterruptedException,
ReplicationException.CompatibilityException

Deprecated.

Description copied from interface: LedgerManagerFactory

Return a ledger underreplication manager, which is used to mark ledgers as unreplicated, and to retrieve a ledger which is underreplicated so that it can be rereplicated.

Returns:

ledger underreplication manager

Throws:

ReplicationException.UnavailableException

InterruptedException

ReplicationException.CompatibilityException

See Also:

• LedgerUnderreplicationManager

format

public void format(AbstractConfiguration<?> conf,
 LayoutManager layoutManager)
            throws InterruptedException,
org.apache.zookeeper.KeeperException,
IOException

Deprecated.

Description copied from interface: LedgerManagerFactory

Format the ledger metadata for LedgerManager.

Specified by:

format in interface LedgerManagerFactory

Overrides:

format in class AbstractZkLedgerManagerFactory

Parameters:

conf - Configuration instance

layoutManager - Layout manager

Throws:

InterruptedException

org.apache.zookeeper.KeeperException

IOException

validateAndNukeExistingCluster

public boolean validateAndNukeExistingCluster(AbstractConfiguration<?> conf,
 LayoutManager layoutManager)
                                       throws InterruptedException,
org.apache.zookeeper.KeeperException,
IOException

Deprecated.

Description copied from interface: LedgerManagerFactory

This method makes sure there are no unexpected znodes under ledgersRootPath and then it proceeds with ledger metadata formatting and nuking the cluster ZK state info.

Specified by:

validateAndNukeExistingCluster in interface LedgerManagerFactory

Overrides:

validateAndNukeExistingCluster in class AbstractZkLedgerManagerFactory

Parameters:

conf - Configuration instance

layoutManager - Layout manager

Throws:

InterruptedException

org.apache.zookeeper.KeeperException

IOException

newLedgerAuditorManager

public LedgerAuditorManager newLedgerAuditorManager()

Deprecated.

Description copied from interface: LedgerManagerFactory

Return a ledger auditor manager, which is used to coordinate the auto-recovery process.

Returns:

ledger auditor manager

See Also:

• LedgerAuditorManager