Uses of Class
org.apache.bookkeeper.client.LedgerHandle

Packages that use LedgerHandle

Package	Description
org.apache.bookkeeper.client	BookKeeper Client.

Uses of LedgerHandle in org.apache.bookkeeper.client

Subclasses of LedgerHandle in org.apache.bookkeeper.client

Modifier and Type	Class and Description
class	LedgerHandleAdv Ledger Advanced handle extends LedgerHandle to provide API to add entries with user supplied entryIds.
(package private) class	ReadOnlyLedgerHandle Read only ledger handle.

Fields in org.apache.bookkeeper.client declared as LedgerHandle

Modifier and Type	Field and Description
(package private) LedgerHandle	BookKeeperAdmin.LedgerEntriesIterator.handle
(package private) LedgerHandle	LedgerFragmentReplicator.SingleFragmentCallback.lh
(package private) LedgerHandle	PendingAddOp.lh
(package private) LedgerHandle	LedgerCreateOp.lh
(package private) LedgerHandle	ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl.lh
(package private) LedgerHandle	PendingWriteLacOp.lh
(package private) LedgerHandle	LedgerRecoveryOp.lh
(package private) LedgerHandle	PendingReadOp.lh
(package private) LedgerHandle	SyncCounter.lh
(package private) LedgerHandle	PendingReadLacOp.lh
(package private) LedgerHandle	TryReadLastConfirmedOp.lh
(package private) LedgerHandle	ForceLedgerOp.lh

Fields in org.apache.bookkeeper.client with type parameters of type LedgerHandle

Modifier and Type	Field and Description
(package private) java.util.concurrent.CompletableFuture<LedgerHandle>	LedgerRecoveryOp.promise

Methods in org.apache.bookkeeper.client that return LedgerHandle

Modifier and Type	Method and Description
LedgerHandle	BookKeeper.createLedger(BookKeeper.DigestType digestType, byte[] passwd) Creates a new ledger.
LedgerHandle	BookKeeper.createLedger(int ensSize, int qSize, BookKeeper.DigestType digestType, byte[] passwd) Synchronous call to create ledger.
LedgerHandle	BookKeeper.createLedger(int ensSize, int writeQuorumSize, int ackQuorumSize, BookKeeper.DigestType digestType, byte[] passwd) Synchronous call to create ledger.
LedgerHandle	BookKeeper.createLedger(int ensSize, int writeQuorumSize, int ackQuorumSize, BookKeeper.DigestType digestType, byte[] passwd, java.util.Map<java.lang.String,byte[]> customMetadata) Synchronous call to create ledger.
LedgerHandle	BookKeeper.createLedgerAdv(int ensSize, int writeQuorumSize, int ackQuorumSize, BookKeeper.DigestType digestType, byte[] passwd) Synchronous call to create ledger.
LedgerHandle	BookKeeper.createLedgerAdv(int ensSize, int writeQuorumSize, int ackQuorumSize, BookKeeper.DigestType digestType, byte[] passwd, java.util.Map<java.lang.String,byte[]> customMetadata) Synchronous call to create ledger.
LedgerHandle	BookKeeper.createLedgerAdv(long ledgerId, int ensSize, int writeQuorumSize, int ackQuorumSize, BookKeeper.DigestType digestType, byte[] passwd, java.util.Map<java.lang.String,byte[]> customMetadata) Synchronously creates a new ledger using the interface which accepts a ledgerId as input.
(package private) LedgerHandle	SyncCounter.getLh()
LedgerHandle	BookKeeperAdmin.openLedger(long lId) Open a ledger as an administrator.
LedgerHandle	BookKeeper.openLedger(long lId, BookKeeper.DigestType digestType, byte[] passwd) Synchronous open ledger call.
LedgerHandle	BookKeeperAdmin.openLedgerNoRecovery(long lId) Open a ledger as an administrator without recovering the ledger.
LedgerHandle	BookKeeper.openLedgerNoRecovery(long lId, BookKeeper.DigestType digestType, byte[] passwd) Synchronous, unsafe open ledger call.

Methods in org.apache.bookkeeper.client that return types with arguments of type LedgerHandle

Modifier and Type	Method and Description
java.util.concurrent.CompletableFuture<LedgerHandle>	LedgerRecoveryOp.initiate()

Methods in org.apache.bookkeeper.client with parameters of type LedgerHandle

Modifier and Type	Method and Description
void	LedgerRecoveryOp.addComplete(int rc, LedgerHandle lh, long entryId, java.lang.Object ctx)
void	AsyncCallback.AddCallback.addComplete(int rc, LedgerHandle lh, long entryId, java.lang.Object ctx) Callback to implement if latency information is not desired.
void	SyncCallbackUtils.SyncAddCallback.addComplete(int rc, LedgerHandle lh, long entry, java.lang.Object ctx) Implementation of callback interface for synchronous read method.
void	AsyncCallback.AddCallbackWithLatency.addCompleteWithLatency(int rc, LedgerHandle lh, long entryId, long qwcLatency, java.lang.Object ctx) Callback declaration which additionally passes quorum write complete latency.
default void	AsyncCallback.AddCallback.addCompleteWithLatency(int rc, LedgerHandle lh, long entryId, long qwcLatency, java.lang.Object ctx) Callback declaration which additionally passes quorum write complete latency.
void	AsyncCallback.AddLacCallback.addLacComplete(int rc, LedgerHandle lh, java.lang.Object ctx) Callback declaration.
void	SyncCallbackUtils.LastAddConfirmedCallback.addLacComplete(int rc, LedgerHandle lh, java.lang.Object ctx) Implementation of callback interface for synchronous read method.
void	LedgerChecker.checkLedger(LedgerHandle lh, org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.GenericCallback<java.util.Set<LedgerFragment>> cb) Check that all the fragments in the passed in ledger, and report those which are missing.
void	LedgerChecker.checkLedger(LedgerHandle lh, org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.GenericCallback<java.util.Set<LedgerFragment>> cb, long percentageOfLedgerFragmentToBeVerified)
void	LedgerHandle.NoopCloseCallback.closeComplete(int rc, LedgerHandle lh, java.lang.Object ctx)
void	AsyncCallback.CloseCallback.closeComplete(int rc, LedgerHandle lh, java.lang.Object ctx) Callback definition.
void	SyncCallbackUtils.SyncCloseCallback.closeComplete(int rc, LedgerHandle lh, java.lang.Object ctx) Close callback method.
(package private) static PendingAddOp	PendingAddOp.create(LedgerHandle lh, ClientContext clientCtx, java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, io.netty.buffer.ByteBuf payload, java.util.EnumSet<WriteFlag> writeFlags, AsyncCallback.AddCallbackWithLatency cb, java.lang.Object ctx)
void	AsyncCallback.CreateCallback.createComplete(int rc, LedgerHandle lh, java.lang.Object ctx) Declaration of callback method.
void	SyncCallbackUtils.SyncCreateCallback.createComplete(int rc, LedgerHandle lh, java.lang.Object ctx) Create callback implementation for synchronous create call.
void	SyncCallbackUtils.SyncCreateAdvCallback.createComplete(int rc, LedgerHandle lh, java.lang.Object ctx) Create callback implementation for synchronous create call.
LedgerMetadata	BookKeeperAdmin.getLedgerMetadata(LedgerHandle lh)
void	LedgerRecoveryOp.onEntryComplete(int rc, LedgerHandle lh, LedgerEntry entry, java.lang.Object ctx)
(package private) void	LedgerOpenOp.openComplete(int rc, LedgerHandle lh)
void	AsyncCallback.OpenCallback.openComplete(int rc, LedgerHandle lh, java.lang.Object ctx) Callback for asynchronous call to open ledger.
void	SyncCallbackUtils.SyncOpenCallback.openComplete(int rc, LedgerHandle lh, java.lang.Object ctx) Callback method for synchronous open operation.
void	AsyncCallback.ReadCallback.readComplete(int rc, LedgerHandle lh, java.util.Enumeration<LedgerEntry> seq, java.lang.Object ctx) Callback declaration.
void	SyncCallbackUtils.SyncReadCallback.readComplete(int rc, LedgerHandle lh, java.util.Enumeration<LedgerEntry> seq, java.lang.Object ctx) Implementation of callback interface for synchronous read method.
(package private) void	LedgerFragmentReplicator.replicate(LedgerHandle lh, LedgerFragment lf, org.apache.zookeeper.AsyncCallback.VoidCallback ledgerFragmentMcb, java.util.Set<org.apache.bookkeeper.net.BookieId> targetBookieAddresses, java.util.function.BiConsumer<java.lang.Long,java.lang.Long> onReadEntryFailureCallback) This method replicate a ledger fragment which is a contiguous portion of a ledger that was stored in an ensemble that included the failed bookie.
void	BookKeeperAdmin.replicateLedgerFragment(LedgerHandle lh, LedgerFragment ledgerFragment, java.util.function.BiConsumer<java.lang.Long,java.lang.Long> onReadEntryFailureCallback) Replicate the Ledger fragment to target Bookie passed.
(package private) void	SyncCounter.setLh(LedgerHandle lh)
(package private) static java.util.Set<LedgerFragment>	LedgerFragmentReplicator.splitIntoSubFragments(LedgerHandle lh, LedgerFragment ledgerFragment, long rereplicationEntryBatchSize) Split the full fragment into batched entry fragments by keeping rereplicationEntryBatchSize of entries in each one and can treat them as sub fragments.

Constructors in org.apache.bookkeeper.client with parameters of type LedgerHandle

Constructor and Description
ExplicitLacFlushPolicyImpl(LedgerHandle lh, ClientContext clientCtx)
ForceLedgerOp(LedgerHandle lh, org.apache.bookkeeper.proto.BookieClient bookieClient, java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, java.util.concurrent.CompletableFuture<java.lang.Void> cb)
LedgerFragment(LedgerHandle lh, long firstEntryId, long lastKnownEntryId, java.util.Set<java.lang.Integer> bookieIndexes)
LedgerRecoveryOp(LedgerHandle lh, ClientContext clientCtx)
ListenerBasedPendingReadOp(LedgerHandle lh, ClientContext clientCtx, long startEntryId, long endEntryId, org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryListener listener, java.lang.Object ctx, boolean isRecoveryRead)
PendingReadLacOp(LedgerHandle lh, org.apache.bookkeeper.proto.BookieClient bookieClient, java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, PendingReadLacOp.LacCallback cb)
PendingReadOp(LedgerHandle lh, ClientContext clientCtx, long startEntryId, long endEntryId, boolean isRecoveryRead)
PendingWriteLacOp(LedgerHandle lh, ClientContext clientCtx, java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, AsyncCallback.AddLacCallback cb, java.lang.Object ctx)
ReadLastConfirmedAndEntryOp(LedgerHandle lh, ClientContext clientCtx, java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, ReadLastConfirmedAndEntryOp.LastConfirmedAndEntryCallback cb, long prevEntryId, long timeOutInMillis)
RecoveryReadOp(LedgerHandle lh, ClientContext clientCtx, long startEntryId, long endEntryId, org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryListener cb, java.lang.Object ctx)
SingleFragmentCallback(org.apache.zookeeper.AsyncCallback.VoidCallback ledgerFragmentsMcb, LedgerHandle lh, org.apache.bookkeeper.meta.LedgerManager ledgerManager, long fragmentStartId, java.util.Map<org.apache.bookkeeper.net.BookieId,org.apache.bookkeeper.net.BookieId> oldBookie2NewBookie)
TryReadLastConfirmedOp(LedgerHandle lh, org.apache.bookkeeper.proto.BookieClient bookieClient, java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, ReadLastConfirmedOp.LastConfirmedDataCallback cb, long lac)

Constructor parameters in org.apache.bookkeeper.client with type arguments of type LedgerHandle

Constructor and Description
SyncCreateCallback(java.util.concurrent.CompletableFuture<? super LedgerHandle> future)
SyncOpenCallback(java.util.concurrent.CompletableFuture<? super LedgerHandle> future)