Package | Description |
---|---|
org.apache.bookkeeper.client |
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.
|
Modifier and Type | Field and Description |
---|---|
(package private) LedgerHandle |
BookKeeperAdmin.LedgerEntriesIterator.handle |
(package private) LedgerHandle |
TryReadLastConfirmedOp.lh |
(package private) LedgerHandle |
SyncCounter.lh |
(package private) LedgerHandle |
ReadLastConfirmedOp.lh |
(package private) LedgerHandle |
PendingWriteLacOp.lh |
(package private) LedgerHandle |
PendingReadOp.lh |
(package private) LedgerHandle |
PendingReadLacOp.lh |
(package private) LedgerHandle |
PendingAddOp.lh |
(package private) LedgerHandle |
LedgerRecoveryOp.lh |
(package private) LedgerHandle |
LedgerOpenOp.lh |
(package private) LedgerHandle |
LedgerFragmentReplicator.SingleFragmentCallback.lh |
(package private) LedgerHandle |
LedgerCreateOp.lh |
(package private) LedgerHandle |
ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl.lh |
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,
Map<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,
Map<String,byte[]> customMetadata)
Synchronous call to create ledger.
|
LedgerHandle |
BookKeeper.createLedgerAdv(long ledgerId,
int ensSize,
int writeQuorumSize,
int ackQuorumSize,
BookKeeper.DigestType digestType,
byte[] passwd,
Map<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
|
Modifier and Type | Method and Description |
---|---|
void |
LedgerRecoveryOp.addComplete(int rc,
LedgerHandle lh,
long entryId,
Object ctx) |
void |
LedgerHandle.SyncAddCallback.addComplete(int rc,
LedgerHandle lh,
long entry,
Object ctx)
Implementation of callback interface for synchronous read method.
|
void |
AsyncCallback.AddCallback.addComplete(int rc,
LedgerHandle lh,
long entryId,
Object ctx)
Callback declaration
|
void |
LedgerHandle.LastAddConfirmedCallback.addLacComplete(int rc,
LedgerHandle lh,
Object ctx)
Implementation of callback interface for synchronous read method.
|
void |
AsyncCallback.AddLacCallback.addLacComplete(int rc,
LedgerHandle lh,
Object ctx)
Callback declaration
|
void |
LedgerChecker.checkLedger(LedgerHandle lh,
org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.GenericCallback<Set<LedgerFragment>> cb)
Check that all the fragments in the passed in ledger, and report those
which are missing.
|
void |
LedgerHandle.NoopCloseCallback.closeComplete(int rc,
LedgerHandle lh,
Object ctx) |
void |
LedgerHandle.SyncCloseCallback.closeComplete(int rc,
LedgerHandle lh,
Object ctx)
Close callback method
|
void |
AsyncCallback.CloseCallback.closeComplete(int rc,
LedgerHandle lh,
Object ctx)
Callback definition
|
void |
AsyncCallback.CreateCallback.createComplete(int rc,
LedgerHandle lh,
Object ctx)
Declaration of callback method
|
LedgerMetadata |
BookKeeperAdmin.getLedgerMetadata(LedgerHandle lh) |
void |
LedgerRecoveryOp.onEntryComplete(int rc,
LedgerHandle lh,
LedgerEntry entry,
Object ctx) |
(package private) void |
LedgerOpenOp.openComplete(int rc,
LedgerHandle lh) |
void |
BookKeeper.SyncOpenCallback.openComplete(int rc,
LedgerHandle lh,
Object ctx)
Callback method for synchronous open operation
|
void |
AsyncCallback.OpenCallback.openComplete(int rc,
LedgerHandle lh,
Object ctx)
Callback for asynchronous call to open ledger
|
void |
LedgerHandle.SyncReadCallback.readComplete(int rc,
LedgerHandle lh,
Enumeration<LedgerEntry> seq,
Object ctx)
Implementation of callback interface for synchronous read method.
|
void |
AsyncCallback.ReadCallback.readComplete(int rc,
LedgerHandle lh,
Enumeration<LedgerEntry> seq,
Object ctx)
Callback declaration
|
(package private) void |
LedgerFragmentReplicator.replicate(LedgerHandle lh,
LedgerFragment lf,
org.apache.zookeeper.AsyncCallback.VoidCallback ledgerFragmentMcb,
org.apache.bookkeeper.net.BookieSocketAddress targetBookieAddress)
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,
org.apache.bookkeeper.net.BookieSocketAddress targetBookieAddress)
Replicate the Ledger fragment to target Bookie passed.
|
(package private) void |
SyncCounter.setLh(LedgerHandle lh) |
(package private) static 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
|
Constructor and Description |
---|
ExplicitLacFlushPolicyImpl(LedgerHandle lh) |
LedgerFragment(LedgerHandle lh,
long firstEntryId,
long lastKnownEntryId,
int bookieIndex) |
LedgerRecoveryOp(LedgerHandle lh,
org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.GenericCallback<Void> cb) |
ListenerBasedPendingReadOp(LedgerHandle lh,
ScheduledExecutorService scheduler,
long startEntryId,
long endEntryId,
org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryListener listener,
Object ctx) |
PendingAddOp(LedgerHandle lh,
AsyncCallback.AddCallback cb,
Object ctx) |
PendingReadLacOp(LedgerHandle lh,
PendingReadLacOp.LacCallback cb) |
PendingReadOp(LedgerHandle lh,
ScheduledExecutorService scheduler,
long startEntryId,
long endEntryId,
AsyncCallback.ReadCallback cb,
Object ctx) |
PendingWriteLacOp(LedgerHandle lh,
AsyncCallback.AddLacCallback cb,
Object ctx) |
ReadLastConfirmedAndEntryOp(LedgerHandle lh,
ReadLastConfirmedAndEntryOp.LastConfirmedAndEntryCallback cb,
long prevEntryId,
long timeOutInMillis,
ScheduledExecutorService scheduler) |
ReadLastConfirmedOp(LedgerHandle lh,
ReadLastConfirmedOp.LastConfirmedDataCallback cb) |
RecoveryReadOp(LedgerHandle lh,
ScheduledExecutorService scheduler,
long startEntryId,
long endEntryId,
org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryListener cb,
Object ctx) |
SingleFragmentCallback(org.apache.zookeeper.AsyncCallback.VoidCallback ledgerFragmentsMcb,
LedgerHandle lh,
long fragmentStartId,
org.apache.bookkeeper.net.BookieSocketAddress oldBookie,
org.apache.bookkeeper.net.BookieSocketAddress newBookie) |
TryReadLastConfirmedOp(LedgerHandle lh,
ReadLastConfirmedOp.LastConfirmedDataCallback cb,
long lac) |
Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.