| Package | Description |
|---|---|
| org.apache.bookkeeper.client |
BookKeeper Client.
|
| org.apache.bookkeeper.client.api |
BookKeeper Client Public API.
|
| Modifier and Type | Class and Description |
|---|---|
(package private) class |
LedgerMetadataImpl
This class encapsulates all the ledger metadata that is persistently stored
in metadata store.
|
| Modifier and Type | Field and Description |
|---|---|
(package private) LedgerMetadata |
LedgerCreateOp.metadata |
(package private) LedgerMetadata |
LedgerRecoveryOp.metadataForRecovery |
| Modifier and Type | Field and Description |
|---|---|
(package private) org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> |
ReadOnlyLedgerHandle.MetadataUpdater.newMetadata |
| Modifier and Type | Method and Description |
|---|---|
LedgerMetadata |
LedgerMetadataBuilder.build() |
protected LedgerMetadata |
PendingReadOp.getLedgerMetadata() |
protected LedgerMetadata |
LedgerRecoveryOp.RecoveryReadOp.getLedgerMetadata() |
LedgerMetadata |
LedgerHandle.getLedgerMetadata()
Returns the metadata of this ledger.
|
protected LedgerMetadata |
ReadLastConfirmedAndEntryOp.getLedgerMetadata() |
LedgerMetadata |
BookKeeperAdmin.getLedgerMetadata(LedgerHandle lh) |
LedgerMetadata |
MetadataUpdateLoop.MetadataTransform.transform(LedgerMetadata metadata) |
| Modifier and Type | Method and Description |
|---|---|
(package private) java.util.concurrent.CompletableFuture<org.apache.bookkeeper.versioning.Versioned<LedgerMetadata>> |
ReadOnlyLedgerHandle.closeRecovered() |
java.util.concurrent.CompletableFuture<LedgerMetadata> |
BookKeeper.getLedgerMetadata(long ledgerId) |
java.util.SortedMap<java.lang.Long,LedgerMetadata> |
BookKeeperAdmin.getLedgersContainBookies(java.util.Set<org.apache.bookkeeper.net.BookieId> bookies) |
(package private) org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> |
LedgerHandle.getVersionedLedgerMetadata() |
(package private) java.util.concurrent.CompletableFuture<org.apache.bookkeeper.versioning.Versioned<LedgerMetadata>> |
MetadataUpdateLoop.run() |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
BookKeeperAdmin.areEntriesOfLedgerStoredInTheBookie(long ledgerId,
org.apache.bookkeeper.net.BookieId bookieAddress,
LedgerMetadata ledgerMetadata) |
static LedgerMetadataBuilder |
LedgerMetadataBuilder.from(LedgerMetadata other) |
(package private) static java.util.Set<org.apache.bookkeeper.net.BookieId> |
LedgerMetadataUtils.getBookiesInThisLedger(LedgerMetadata metadata) |
(package private) static java.util.List<org.apache.bookkeeper.net.BookieId> |
LedgerMetadataUtils.getCurrentEnsemble(LedgerMetadata metadata) |
(package private) static java.lang.Long |
LedgerMetadataUtils.getLastEnsembleKey(LedgerMetadata metadata) |
(package private) static java.util.List<org.apache.bookkeeper.net.BookieId> |
LedgerMetadataUtils.getLastEnsembleValue(LedgerMetadata metadata) |
(package private) static long |
LedgerMetadataUtils.getNextEnsembleChange(LedgerMetadata metadata,
long entryId)
the entry id greater than the given entry-id at which the next ensemble change takes
place.
|
default int |
EnsemblePlacementPolicy.getStickyReadBookieIndex(LedgerMetadata metadata,
java.util.Optional<java.lang.Integer> currentStickyBookieIndex)
Select one bookie to the "sticky" bookie where all reads for a particular
ledger will be directed to.
|
boolean |
MetadataUpdateLoop.NeedsUpdatePredicate.needsUpdate(LedgerMetadata metadata) |
(package private) static java.util.List<org.apache.bookkeeper.net.BookieId> |
EnsembleUtils.replaceBookiesInEnsemble(BookieWatcher bookieWatcher,
LedgerMetadata metadata,
java.util.List<org.apache.bookkeeper.net.BookieId> oldEnsemble,
java.util.Map<java.lang.Integer,org.apache.bookkeeper.net.BookieId> failedBookies,
java.lang.String logContext) |
static boolean |
LedgerMetadataUtils.shouldStoreCtime(LedgerMetadata metadata) |
LedgerMetadata |
MetadataUpdateLoop.MetadataTransform.transform(LedgerMetadata metadata) |
| Modifier and Type | Method and Description |
|---|---|
void |
BookKeeperAdmin.asyncGetLedgersContainBookies(java.util.Set<org.apache.bookkeeper.net.BookieId> bookies,
org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.GenericCallback<java.util.SortedMap<java.lang.Long,LedgerMetadata>> callback) |
void |
ReadOnlyLedgerHandle.onChanged(long lid,
org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> newMetadata) |
(package private) boolean |
LedgerHandle.setLedgerMetadata(org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> expected,
org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> newMetadata) |
(package private) boolean |
LedgerHandle.setLedgerMetadata(org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> expected,
org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> newMetadata) |
boolean |
MetadataUpdateLoop.LocalValueUpdater.updateValue(org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> oldValue,
org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> newValue) |
boolean |
MetadataUpdateLoop.LocalValueUpdater.updateValue(org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> oldValue,
org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> newValue) |
| Constructor and Description |
|---|
LedgerHandle(ClientContext clientCtx,
long ledgerId,
org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> versionedMetadata,
BookKeeper.DigestType digestType,
byte[] password,
java.util.EnumSet<WriteFlag> writeFlags) |
LedgerHandleAdv(ClientContext clientCtx,
long ledgerId,
org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> metadata,
BookKeeper.DigestType digestType,
byte[] password,
java.util.EnumSet<WriteFlag> writeFlags) |
MetadataUpdateLoop(org.apache.bookkeeper.meta.LedgerManager lm,
long ledgerId,
java.util.function.Supplier<org.apache.bookkeeper.versioning.Versioned<LedgerMetadata>> currentLocalValue,
MetadataUpdateLoop.NeedsUpdatePredicate needsTransformation,
MetadataUpdateLoop.MetadataTransform transform,
MetadataUpdateLoop.LocalValueUpdater updateLocalValue) |
MetadataUpdateLoop(org.apache.bookkeeper.meta.LedgerManager lm,
long ledgerId,
java.util.function.Supplier<org.apache.bookkeeper.versioning.Versioned<LedgerMetadata>> currentLocalValue,
MetadataUpdateLoop.NeedsUpdatePredicate needsTransformation,
MetadataUpdateLoop.MetadataTransform transform,
MetadataUpdateLoop.LocalValueUpdater updateLocalValue,
com.google.common.util.concurrent.RateLimiter throttler)
Construct the loop.
|
MetadataUpdater(org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> metadata) |
ReadOnlyLedgerHandle(ClientContext clientCtx,
long ledgerId,
org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> metadata,
BookKeeper.DigestType digestType,
byte[] password,
boolean watch) |
| Modifier and Type | Method and Description |
|---|---|
LedgerMetadata |
Handle.getLedgerMetadata()
Returns the metadata of this ledger.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.concurrent.CompletableFuture<LedgerMetadata> |
BookKeeper.getLedgerMetadata(long ledgerId)
Get ledger metadata of a given ledger id.
|
Copyright © 2011–2024 The Apache Software Foundation. All rights reserved.