Uses of Interface
org.apache.bookkeeper.client.api.LedgerMetadata
-
Packages that use LedgerMetadata Package Description org.apache.bookkeeper.bookie Provides a Bookie server that stores entries for clients.org.apache.bookkeeper.bookie.datainteg Package of the classes for defining bookie stats.org.apache.bookkeeper.client BookKeeper Client.org.apache.bookkeeper.client.api BookKeeper Client Public API.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. -
-
Uses of LedgerMetadata in org.apache.bookkeeper.bookie
Methods in org.apache.bookkeeper.bookie with parameters of type LedgerMetadata Modifier and Type Method Description (package private) void
BookieShell. printLedgerMetadata(long ledgerId, LedgerMetadata md, boolean printMeta)
-
Uses of LedgerMetadata in org.apache.bookkeeper.bookie.datainteg
Methods in org.apache.bookkeeper.bookie.datainteg that return LedgerMetadata Modifier and Type Method Description (package private) LedgerMetadata
DataIntegrityCheckImpl.LedgerResult. getMetadata()
Methods in org.apache.bookkeeper.bookie.datainteg that return types with arguments of type LedgerMetadata Modifier and Type Method Description (package private) java.util.concurrent.CompletableFuture<java.util.Map<java.lang.Long,LedgerMetadata>>
DataIntegrityCheckImpl. getCachedOrReadMetadata(java.lang.String runId)
(package private) io.reactivex.rxjava3.core.Single<LedgerMetadata>
DataIntegrityCheckImpl. recoverLedger(long ledgerId, java.lang.String runId)
(package private) io.reactivex.rxjava3.core.Maybe<LedgerMetadata>
DataIntegrityCheckImpl. recoverLedgerIfInLimbo(long ledgerId, LedgerMetadata origMetadata, java.lang.String runId)
Run ledger recovery on all a ledger if it has been marked as in limbo.Methods in org.apache.bookkeeper.bookie.datainteg with parameters of type LedgerMetadata Modifier and Type Method Description (package private) io.reactivex.rxjava3.core.Single<java.lang.Long>
DataIntegrityCheckImpl. checkAndRecoverLedgerEntries(long ledgerId, LedgerMetadata metadata, java.lang.String runId)
Check whether the local storage has all the entries as specified in the metadata.(package private) static boolean
DataIntegrityCheckImpl. ensemblesContainBookie(LedgerMetadata metadata, BookieId bookieId)
(package private) static DataIntegrityCheckImpl.LedgerResult
DataIntegrityCheckImpl.LedgerResult. error(long ledgerId, LedgerMetadata metadata, java.lang.Throwable t)
EntryCopier.Batch
EntryCopier. newBatch(long ledgerId, LedgerMetadata metadata)
Start copying a new batch.EntryCopier.Batch
EntryCopierImpl. newBatch(long ledgerId, LedgerMetadata metadata)
(package private) static DataIntegrityCheckImpl.LedgerResult
DataIntegrityCheckImpl.LedgerResult. ok(long ledgerId, LedgerMetadata metadata)
(package private) static com.google.common.collect.ImmutableSortedMap<java.lang.Long,com.google.common.collect.ImmutableList<java.lang.Integer>>
EntryCopierImpl. preferredBookieIndices(BookieId bookieId, LedgerMetadata metadata, java.util.Set<BookieId> errorBookies, long seed)
Generate a map of preferred bookie indices.(package private) io.reactivex.rxjava3.core.Maybe<LedgerMetadata>
DataIntegrityCheckImpl. recoverLedgerIfInLimbo(long ledgerId, LedgerMetadata origMetadata, java.lang.String runId)
Run ledger recovery on all a ledger if it has been marked as in limbo.Method parameters in org.apache.bookkeeper.bookie.datainteg with type arguments of type LedgerMetadata Modifier and Type Method Description (package private) java.util.concurrent.CompletableFuture<java.util.Set<DataIntegrityCheckImpl.LedgerResult>>
DataIntegrityCheckImpl. checkAndRecoverLedgers(java.util.Map<java.lang.Long,LedgerMetadata> ledgers, java.lang.String runId)
Check each ledger passed.java.util.concurrent.CompletableFuture<java.lang.Void>
MetadataAsyncIterator. forEach(java.util.function.BiFunction<java.lang.Long,LedgerMetadata,java.util.concurrent.CompletableFuture<java.lang.Void>> consumer)
(package private) void
DataIntegrityCheckImpl. updateMetadataCache(java.util.Map<java.lang.Long,LedgerMetadata> ledgers)
Constructors in org.apache.bookkeeper.bookie.datainteg with parameters of type LedgerMetadata Constructor Description BatchImpl(BookieId bookieId, long ledgerId, LedgerMetadata metadata, EntryCopierImpl.SinBin sinBin)
-
Uses of LedgerMetadata in org.apache.bookkeeper.client
Classes in org.apache.bookkeeper.client that implement LedgerMetadata Modifier and Type Class Description (package private) class
LedgerMetadataImpl
This class encapsulates all the ledger metadata that is persistently stored in metadata store.Fields in org.apache.bookkeeper.client declared as LedgerMetadata Modifier and Type Field Description (package private) LedgerMetadata
LedgerCreateOp. metadata
(package private) LedgerMetadata
LedgerRecoveryOp. metadataForRecovery
Fields in org.apache.bookkeeper.client with type parameters of type LedgerMetadata Modifier and Type Field Description (package private) Versioned<LedgerMetadata>
ReadOnlyLedgerHandle.MetadataUpdater. newMetadata
Methods in org.apache.bookkeeper.client that return LedgerMetadata Modifier and Type Method Description LedgerMetadata
LedgerMetadataBuilder. build()
LedgerMetadata
BookKeeperAdmin. getLedgerMetadata(LedgerHandle lh)
LedgerMetadata
LedgerHandle. getLedgerMetadata()
Returns the metadata of this ledger.protected LedgerMetadata
LedgerRecoveryOp.RecoveryReadOp. getLedgerMetadata()
protected LedgerMetadata
ReadLastConfirmedAndEntryOp. getLedgerMetadata()
protected LedgerMetadata
ReadOpBase. getLedgerMetadata()
LedgerMetadata
MetadataUpdateLoop.MetadataTransform. transform(LedgerMetadata metadata)
Methods in org.apache.bookkeeper.client that return types with arguments of type LedgerMetadata Modifier and Type Method Description (package private) java.util.concurrent.CompletableFuture<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<BookieId> bookies)
(package private) Versioned<LedgerMetadata>
LedgerHandle. getVersionedLedgerMetadata()
(package private) java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
MetadataUpdateLoop. run()
Methods in org.apache.bookkeeper.client with parameters of type LedgerMetadata Modifier and Type Method Description static boolean
BookKeeperAdmin. areEntriesOfLedgerStoredInTheBookie(long ledgerId, BookieId bookieAddress, LedgerMetadata ledgerMetadata)
static LedgerMetadataBuilder
LedgerMetadataBuilder. from(LedgerMetadata other)
(package private) static java.util.Set<BookieId>
LedgerMetadataUtils. getBookiesInThisLedger(LedgerMetadata metadata)
(package private) static java.util.List<BookieId>
LedgerMetadataUtils. getCurrentEnsemble(LedgerMetadata metadata)
(package private) static java.lang.Long
LedgerMetadataUtils. getLastEnsembleKey(LedgerMetadata metadata)
(package private) static java.util.List<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<BookieId>
EnsembleUtils. replaceBookiesInEnsemble(BookieWatcher bookieWatcher, LedgerMetadata metadata, java.util.List<BookieId> oldEnsemble, java.util.Map<java.lang.Integer,BookieId> failedBookies, java.lang.String logContext)
static boolean
LedgerMetadataUtils. shouldStoreCtime(LedgerMetadata metadata)
LedgerMetadata
MetadataUpdateLoop.MetadataTransform. transform(LedgerMetadata metadata)
Method parameters in org.apache.bookkeeper.client with type arguments of type LedgerMetadata Modifier and Type Method Description void
BookKeeperAdmin. asyncGetLedgersContainBookies(java.util.Set<BookieId> bookies, BookkeeperInternalCallbacks.GenericCallback<java.util.SortedMap<java.lang.Long,LedgerMetadata>> callback)
void
ReadOnlyLedgerHandle. onChanged(long lid, Versioned<LedgerMetadata> newMetadata)
(package private) boolean
LedgerHandle. setLedgerMetadata(Versioned<LedgerMetadata> expected, Versioned<LedgerMetadata> newMetadata)
boolean
MetadataUpdateLoop.LocalValueUpdater. updateValue(Versioned<LedgerMetadata> oldValue, Versioned<LedgerMetadata> newValue)
Constructor parameters in org.apache.bookkeeper.client with type arguments of type LedgerMetadata Constructor Description LedgerHandle(ClientContext clientCtx, long ledgerId, Versioned<LedgerMetadata> versionedMetadata, BookKeeper.DigestType digestType, byte[] password, java.util.EnumSet<WriteFlag> writeFlags)
LedgerHandleAdv(ClientContext clientCtx, long ledgerId, Versioned<LedgerMetadata> metadata, BookKeeper.DigestType digestType, byte[] password, java.util.EnumSet<WriteFlag> writeFlags)
MetadataUpdateLoop(LedgerManager lm, long ledgerId, java.util.function.Supplier<Versioned<LedgerMetadata>> currentLocalValue, MetadataUpdateLoop.NeedsUpdatePredicate needsTransformation, MetadataUpdateLoop.MetadataTransform transform, MetadataUpdateLoop.LocalValueUpdater updateLocalValue)
MetadataUpdateLoop(LedgerManager lm, long ledgerId, java.util.function.Supplier<Versioned<LedgerMetadata>> currentLocalValue, MetadataUpdateLoop.NeedsUpdatePredicate needsTransformation, MetadataUpdateLoop.MetadataTransform transform, MetadataUpdateLoop.LocalValueUpdater updateLocalValue, com.google.common.util.concurrent.RateLimiter throttler)
Construct the loop.MetadataUpdater(Versioned<LedgerMetadata> metadata)
ReadOnlyLedgerHandle(ClientContext clientCtx, long ledgerId, Versioned<LedgerMetadata> metadata, BookKeeper.DigestType digestType, byte[] password, boolean watch)
-
Uses of LedgerMetadata in org.apache.bookkeeper.client.api
Methods in org.apache.bookkeeper.client.api that return LedgerMetadata Modifier and Type Method Description LedgerMetadata
Handle. getLedgerMetadata()
Returns the metadata of this ledger.Methods in org.apache.bookkeeper.client.api that return types with arguments of type LedgerMetadata Modifier and Type Method Description java.util.concurrent.CompletableFuture<LedgerMetadata>
BookKeeper. getLedgerMetadata(long ledgerId)
Get ledger metadata of a given ledger id. -
Uses of LedgerMetadata in org.apache.bookkeeper.meta
Methods in org.apache.bookkeeper.meta that return LedgerMetadata Modifier and Type Method Description LedgerMetadata
LedgerMetadataSerDe. parseConfig(byte[] bytes, long ledgerId, java.util.Optional<java.lang.Long> metadataStoreCtime)
Parses a given byte array and transforms into a LedgerConfig object.Methods in org.apache.bookkeeper.meta that return types with arguments of type LedgerMetadata Modifier and Type Method Description java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
AbstractZkLedgerManager. createLedgerMetadata(long ledgerId, LedgerMetadata inputMetadata)
java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
CleanupLedgerManager. createLedgerMetadata(long lid, LedgerMetadata metadata)
java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
LedgerManager. createLedgerMetadata(long ledgerId, LedgerMetadata metadata)
Create a new ledger with provided ledger id and metadata.java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
MSLedgerManagerFactory.MsLedgerManager. createLedgerMetadata(long lid, LedgerMetadata metadata)
java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
NullMetadataBookieDriver.NullLedgerManager. createLedgerMetadata(long ledgerId, LedgerMetadata metadata)
java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
AbstractZkLedgerManager. readLedgerMetadata(long ledgerId)
protected java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
AbstractZkLedgerManager. readLedgerMetadata(long ledgerId, org.apache.zookeeper.Watcher watcher)
java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
CleanupLedgerManager. readLedgerMetadata(long ledgerId)
java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
LedgerManager. readLedgerMetadata(long ledgerId)
Read ledger metadata of a specified ledger.java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
MSLedgerManagerFactory.MsLedgerManager. readLedgerMetadata(long ledgerId)
java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
NullMetadataBookieDriver.NullLedgerManager. readLedgerMetadata(long ledgerId)
java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
AbstractZkLedgerManager. writeLedgerMetadata(long ledgerId, LedgerMetadata metadata, Version currentVersion)
java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
CleanupLedgerManager. writeLedgerMetadata(long ledgerId, LedgerMetadata metadata, Version currentVersion)
java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
LedgerManager. writeLedgerMetadata(long ledgerId, LedgerMetadata metadata, Version currentVersion)
Write ledger metadata.java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
MSLedgerManagerFactory.MsLedgerManager. writeLedgerMetadata(long ledgerId, LedgerMetadata metadata, Version currentVersion)
java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
NullMetadataBookieDriver.NullLedgerManager. writeLedgerMetadata(long ledgerId, LedgerMetadata metadata, Version currentVersion)
Methods in org.apache.bookkeeper.meta with parameters of type LedgerMetadata Modifier and Type Method Description java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
AbstractZkLedgerManager. createLedgerMetadata(long ledgerId, LedgerMetadata inputMetadata)
java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
CleanupLedgerManager. createLedgerMetadata(long lid, LedgerMetadata metadata)
java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
LedgerManager. createLedgerMetadata(long ledgerId, LedgerMetadata metadata)
Create a new ledger with provided ledger id and metadata.java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
MSLedgerManagerFactory.MsLedgerManager. createLedgerMetadata(long lid, LedgerMetadata metadata)
java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
NullMetadataBookieDriver.NullLedgerManager. createLedgerMetadata(long ledgerId, LedgerMetadata metadata)
byte[]
LedgerMetadataSerDe. serialize(LedgerMetadata metadata)
java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
AbstractZkLedgerManager. writeLedgerMetadata(long ledgerId, LedgerMetadata metadata, Version currentVersion)
java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
CleanupLedgerManager. writeLedgerMetadata(long ledgerId, LedgerMetadata metadata, Version currentVersion)
java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
LedgerManager. writeLedgerMetadata(long ledgerId, LedgerMetadata metadata, Version currentVersion)
Write ledger metadata.java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
MSLedgerManagerFactory.MsLedgerManager. writeLedgerMetadata(long ledgerId, LedgerMetadata metadata, Version currentVersion)
java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
NullMetadataBookieDriver.NullLedgerManager. writeLedgerMetadata(long ledgerId, LedgerMetadata metadata, Version currentVersion)
-
Uses of LedgerMetadata in org.apache.bookkeeper.proto
Method parameters in org.apache.bookkeeper.proto with type arguments of type LedgerMetadata Modifier and Type Method Description void
BookkeeperInternalCallbacks.LedgerMetadataListener. onChanged(long ledgerId, Versioned<LedgerMetadata> metadata)
Triggered each time ledger metadata changed. -
Uses of LedgerMetadata in org.apache.bookkeeper.replication
Method parameters in org.apache.bookkeeper.replication with type arguments of type LedgerMetadata Modifier and Type Method Description (package private) void
AuditorPlacementPolicyCheckTask. doPlacementPolicyCheck(java.lang.Long ledgerId, org.apache.zookeeper.AsyncCallback.VoidCallback iterCallback, Versioned<LedgerMetadata> metadataVer)
-