Uses of Class
org.apache.bookkeeper.replication.ReplicationException.UnavailableException

Packages that use ReplicationException.UnavailableException

Package	Description
org.apache.bookkeeper.client	BookKeeper Client.
org.apache.bookkeeper.meta	Classes for interacting with bookkeeper ledgers and ledger metadata.
org.apache.bookkeeper.proto	Classes related to the Bookkeeper protocol.
org.apache.bookkeeper.replication	Classes for replicating Bookkeeper data.
org.apache.bookkeeper.tools.cli.commands.autorecovery

Uses of ReplicationException.UnavailableException in org.apache.bookkeeper.client

Methods in org.apache.bookkeeper.client that throw ReplicationException.UnavailableException

Modifier and Type	Method	Description
void	BookKeeperAdmin.decommissionBookie(BookieId bookieAddress)	Triggers AuditTask by resetting lostBookieRecoveryDelay and then make sure the ledgers stored in the given decommissioning bookie are properly replicated and they are not underreplicated because of the given bookie.
int	BookKeeperAdmin.getLostBookieRecoveryDelay()	Returns the current LostBookieRecoveryDelay value (in seconds) in Zookeeper.
void	BookKeeperAdmin.setLostBookieRecoveryDelay(int lostBookieRecoveryDelay)	Setter for LostBookieRecoveryDelay value (in seconds) in Zookeeper.
void	BookKeeperAdmin.triggerAudit()	Trigger AuditTask by resetting lostBookieRecoveryDelay to its current value.

Uses of ReplicationException.UnavailableException in org.apache.bookkeeper.meta

Methods in org.apache.bookkeeper.meta that throw ReplicationException.UnavailableException

Modifier and Type	Method	Description
static java.lang.String	ZkLedgerUnderreplicationManager.acquireUnderreplicatedLedgerLock(org.apache.zookeeper.ZooKeeper zkc, java.lang.String zkLedgersRootPath, long ledgerId, java.util.List<org.apache.zookeeper.data.ACL> zkAcls)	Acquire the underreplicated ledger lock.
void	LedgerUnderreplicationManager.close()	Release all resources held by the ledger underreplication manager.
void	ZkLedgerUnderreplicationManager.close()
void	LedgerUnderreplicationManager.disableLedgerReplication()	Stop ledger replication.
void	ZkLedgerUnderreplicationManager.disableLedgerReplication()
void	LedgerUnderreplicationManager.enableLedgerReplication()	Resuming ledger replication.
void	ZkLedgerUnderreplicationManager.enableLedgerReplication()
long	LedgerUnderreplicationManager.getCheckAllLedgersCTime()	Getter for the CheckAllLedgers last executed ctime.
long	ZkLedgerUnderreplicationManager.getCheckAllLedgersCTime()
long	LedgerUnderreplicationManager.getLedgerToRereplicate()	Acquire a underreplicated ledger for rereplication.
long	NullMetadataBookieDriver.NullLedgerUnderreplicationManager.getLedgerToRereplicate()
long	ZkLedgerUnderreplicationManager.getLedgerToRereplicate()
UnderreplicatedLedger	LedgerUnderreplicationManager.getLedgerUnreplicationInfo(long ledgerId)	Get the UnderreplicatedLedger info if this ledger is marked underreplicated otherwise it returns null.
UnderreplicatedLedger	NullMetadataBookieDriver.NullLedgerUnderreplicationManager.getLedgerUnreplicationInfo(long ledgerId)
UnderreplicatedLedger	ZkLedgerUnderreplicationManager.getLedgerUnreplicationInfo(long ledgerId)
int	LedgerUnderreplicationManager.getLostBookieRecoveryDelay()	Getter for the lostBookieRecoveryDelay.
int	ZkLedgerUnderreplicationManager.getLostBookieRecoveryDelay()
long	LedgerUnderreplicationManager.getPlacementPolicyCheckCTime()	Getter for the PlacementPolicyCheck last executed ctime.
long	ZkLedgerUnderreplicationManager.getPlacementPolicyCheckCTime()
long	LedgerUnderreplicationManager.getReplicasCheckCTime()	Getter for the ReplicasCheck last executed ctime.
long	ZkLedgerUnderreplicationManager.getReplicasCheckCTime()
java.lang.String	LedgerUnderreplicationManager.getReplicationWorkerIdRereplicatingLedger(long ledgerId)	If a replicationworker has acquired lock on an underreplicated ledger, then getReplicationWorkerIdRereplicatingLedger should return ReplicationWorkerId (BookieId) of the ReplicationWorker that is holding lock.
java.lang.String	NullMetadataBookieDriver.NullLedgerUnderreplicationManager.getReplicationWorkerIdRereplicatingLedger(long ledgerId)
java.lang.String	ZkLedgerUnderreplicationManager.getReplicationWorkerIdRereplicatingLedger(long ledgerId)
boolean	LedgerUnderreplicationManager.initializeLostBookieRecoveryDelay(int lostBookieRecoveryDelay)	Creates the zNode for lostBookieRecoveryDelay with the specified value and returns true.
boolean	ZkLedgerUnderreplicationManager.initializeLostBookieRecoveryDelay(int lostBookieRecoveryDelay)
boolean	LedgerUnderreplicationManager.isLedgerReplicationEnabled()	Check whether the ledger replication is enabled or not.
boolean	ZkLedgerUnderreplicationManager.isLedgerReplicationEnabled()
void	LedgerUnderreplicationManager.markLedgerReplicated(long ledgerId)	Mark a ledger as fully replicated.
void	NullMetadataBookieDriver.NullLedgerUnderreplicationManager.markLedgerReplicated(long ledgerId)
void	ZkLedgerUnderreplicationManager.markLedgerReplicated(long ledgerId)
LedgerUnderreplicationManager	FlatLedgerManagerFactory.newLedgerUnderreplicationManager()	Deprecated.
LedgerUnderreplicationManager	LedgerManagerFactory.newLedgerUnderreplicationManager()	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.
LedgerUnderreplicationManager	LegacyHierarchicalLedgerManagerFactory.newLedgerUnderreplicationManager()
LedgerUnderreplicationManager	MSLedgerManagerFactory.newLedgerUnderreplicationManager()	Deprecated.
void	LedgerUnderreplicationManager.notifyLedgerReplicationEnabled(BookkeeperInternalCallbacks.GenericCallback<java.lang.Void> cb)	Receive notification asynchronously when the ledger replication process is enabled.
void	ZkLedgerUnderreplicationManager.notifyLedgerReplicationEnabled(BookkeeperInternalCallbacks.GenericCallback<java.lang.Void> cb)
void	LedgerUnderreplicationManager.notifyLostBookieRecoveryDelayChanged(BookkeeperInternalCallbacks.GenericCallback<java.lang.Void> cb)	Receive notification asynchronously when the lostBookieRecoveryDelay value is Changed.
void	ZkLedgerUnderreplicationManager.notifyLostBookieRecoveryDelayChanged(BookkeeperInternalCallbacks.GenericCallback<java.lang.Void> cb)
default void	LedgerUnderreplicationManager.notifyUnderReplicationLedgerChanged(BookkeeperInternalCallbacks.GenericCallback<java.lang.Void> cb)	Deprecated.
void	ZkLedgerUnderreplicationManager.notifyUnderReplicationLedgerChanged(BookkeeperInternalCallbacks.GenericCallback<java.lang.Void> cb)
long	LedgerUnderreplicationManager.pollLedgerToRereplicate()	Poll for a underreplicated ledger to rereplicate.
long	NullMetadataBookieDriver.NullLedgerUnderreplicationManager.pollLedgerToRereplicate()
long	ZkLedgerUnderreplicationManager.pollLedgerToRereplicate()
void	LedgerUnderreplicationManager.releaseUnderreplicatedLedger(long ledgerId)	Release a previously acquired ledger.
void	ZkLedgerUnderreplicationManager.releaseUnderreplicatedLedger(long ledgerId)
void	LedgerUnderreplicationManager.setCheckAllLedgersCTime(long checkAllLedgersCTime)	Setter for the CheckAllLedgers last executed ctime.
void	ZkLedgerUnderreplicationManager.setCheckAllLedgersCTime(long checkAllLedgersCTime)
void	LedgerUnderreplicationManager.setLostBookieRecoveryDelay(int lostBookieRecoveryDelay)	Setter for the lostBookieRecoveryDelay znode.
void	ZkLedgerUnderreplicationManager.setLostBookieRecoveryDelay(int lostBookieRecoveryDelay)
void	LedgerUnderreplicationManager.setPlacementPolicyCheckCTime(long placementPolicyCheckCTime)	Setter for the PlacementPolicyCheck last executed ctime.
void	ZkLedgerUnderreplicationManager.setPlacementPolicyCheckCTime(long placementPolicyCheckCTime)
void	LedgerUnderreplicationManager.setReplicasCheckCTime(long replicasCheckCTime)	Setter for the ReplicasCheck last executed ctime.
void	ZkLedgerUnderreplicationManager.setReplicasCheckCTime(long replicasCheckCTime)

Constructors in org.apache.bookkeeper.meta that throw ReplicationException.UnavailableException

Constructor	Description
ZkLedgerUnderreplicationManager(AbstractConfiguration conf, org.apache.zookeeper.ZooKeeper zkc)

Uses of ReplicationException.UnavailableException in org.apache.bookkeeper.proto

Methods in org.apache.bookkeeper.proto that throw ReplicationException.UnavailableException

Modifier and Type	Method	Description
static BookieServer	BookieServer.newBookieServer(ServerConfiguration conf, Bookie bookie, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, UncleanShutdownDetection uncleanShutdownDetection)

Constructors in org.apache.bookkeeper.proto that throw ReplicationException.UnavailableException

Constructor	Description
BookieServer(ServerConfiguration conf, Bookie bookie, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, UncleanShutdownDetection uncleanShutdownDetection)

Uses of ReplicationException.UnavailableException in org.apache.bookkeeper.replication

Subclasses of ReplicationException.UnavailableException in org.apache.bookkeeper.replication

Modifier and Type	Class	Description
static class	ReplicationException.NonRecoverableReplicationException	The replication service encountered an error that requires service restart.

Methods in org.apache.bookkeeper.replication that return ReplicationException.UnavailableException

Modifier and Type	Method	Description
static ReplicationException.UnavailableException	ReplicationException.fromKeeperException(java.lang.String message, org.apache.zookeeper.KeeperException ke)

Methods in org.apache.bookkeeper.replication that throw ReplicationException.UnavailableException

Modifier and Type	Method	Description
(package private) static BookKeeper	Auditor.createBookKeeperClientThrowUnavailableException(ServerConfiguration conf)
protected boolean	AuditorTask.isLedgerReplicationEnabled()
protected void	AuditorBookieCheckTask.waitIfLedgerReplicationDisabled()

Constructors in org.apache.bookkeeper.replication that throw ReplicationException.UnavailableException

Constructor	Description
Auditor(java.lang.String bookieIdentifier, ServerConfiguration conf, BookKeeper bkc, boolean ownBkc, BookKeeperAdmin admin, boolean ownAdmin, StatsLogger statsLogger)
Auditor(java.lang.String bookieIdentifier, ServerConfiguration conf, BookKeeper bkc, boolean ownBkc, StatsLogger statsLogger)
Auditor(java.lang.String bookieIdentifier, ServerConfiguration conf, StatsLogger statsLogger)
AuditorCheckAllLedgersTask(ServerConfiguration conf, AuditorStats auditorStats, BookKeeperAdmin admin, LedgerManager ledgerManager, LedgerUnderreplicationManager ledgerUnderreplicationManager, AuditorTask.ShutdownTaskHandler shutdownTaskHandler, java.util.function.BiConsumer<java.util.concurrent.atomic.AtomicBoolean,java.lang.Throwable> hasAuditCheckTask)
AuditorElector(java.lang.String bookieId, ServerConfiguration conf)
AuditorElector(java.lang.String bookieId, ServerConfiguration conf, BookKeeper bkc, boolean ownBkc)	AuditorElector for performing the auditor election.
AuditorElector(java.lang.String bookieId, ServerConfiguration conf, BookKeeper bkc, StatsLogger statsLogger, boolean ownBkc)	AuditorElector for performing the auditor election.
AutoRecoveryMain(ServerConfiguration conf)
AutoRecoveryMain(ServerConfiguration conf, StatsLogger statsLogger)
ReplicationWorker(ServerConfiguration conf)	Replication worker for replicating the ledger fragments from UnderReplicationManager to the targetBookie.
ReplicationWorker(ServerConfiguration conf, BookKeeper bkc, boolean ownBkc, StatsLogger statsLogger)
ReplicationWorker(ServerConfiguration conf, StatsLogger statsLogger)	Replication worker for replicating the ledger fragments from UnderReplicationManager to the targetBookie.

Uses of ReplicationException.UnavailableException in org.apache.bookkeeper.tools.cli.commands.autorecovery

Methods in org.apache.bookkeeper.tools.cli.commands.autorecovery that throw ReplicationException.UnavailableException

Modifier and Type	Method	Description
boolean	LostBookieRecoveryDelayCommand.handler(ServerConfiguration conf, LostBookieRecoveryDelayCommand.LBRDFlags flags)