Uses of Class
org.apache.bookkeeper.versioning.Versioned
-
Packages that use Versioned Package Description org.apache.bookkeeper.bookie Provides a Bookie server that stores entries for clients.org.apache.bookkeeper.client BookKeeper Client.org.apache.bookkeeper.discover Classes related to service discovery.org.apache.bookkeeper.meta Classes for interacting with bookkeeper ledgers and ledger metadata.org.apache.bookkeeper.metastore MetaStore-related classes.org.apache.bookkeeper.proto Classes related to the Bookkeeper protocol.org.apache.bookkeeper.replication Classes for replicating Bookkeeper data. -
-
Uses of Versioned in org.apache.bookkeeper.bookie
Methods in org.apache.bookkeeper.bookie that return Versioned Modifier and Type Method Description static Versioned<Cookie>
Cookie. readFromRegistrationManager(RegistrationManager rm, ServerConfiguration conf)
Read cookie from registration manager.static Versioned<Cookie>
Cookie. readFromRegistrationManager(RegistrationManager rm, BookieId address)
Read cookie from registration manager for a given bookie address. -
Uses of Versioned in org.apache.bookkeeper.client
Fields in org.apache.bookkeeper.client declared as Versioned Modifier and Type Field Description (package private) Versioned<LedgerMetadata>
ReadOnlyLedgerHandle.MetadataUpdater. newMetadata
Methods in org.apache.bookkeeper.client that return Versioned Modifier and Type Method Description (package private) Versioned<LedgerMetadata>
LedgerHandle. getVersionedLedgerMetadata()
Methods in org.apache.bookkeeper.client that return types with arguments of type Versioned Modifier and Type Method Description (package private) java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
ReadOnlyLedgerHandle. closeRecovered()
(package private) java.util.concurrent.CompletableFuture<Versioned<LedgerMetadata>>
MetadataUpdateLoop. run()
Methods in org.apache.bookkeeper.client with parameters of type Versioned Modifier and Type Method Description 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)
Constructors in org.apache.bookkeeper.client with parameters of type Versioned 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)
MetadataUpdater(Versioned<LedgerMetadata> metadata)
ReadOnlyLedgerHandle(ClientContext clientCtx, long ledgerId, Versioned<LedgerMetadata> metadata, BookKeeper.DigestType digestType, byte[] password, boolean watch)
Constructor parameters in org.apache.bookkeeper.client with type arguments of type Versioned Constructor Description 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. -
Uses of Versioned in org.apache.bookkeeper.discover
Methods in org.apache.bookkeeper.discover that return Versioned Modifier and Type Method Description Versioned<byte[]>
RegistrationManager. readCookie(BookieId bookieId)
Read the cookie data, which will be used for verifying the integrity of the bookie environment.Versioned<byte[]>
ZKRegistrationManager. readCookie(BookieId bookieId)
Methods in org.apache.bookkeeper.discover that return types with arguments of type Versioned Modifier and Type Method Description java.util.concurrent.CompletableFuture<Versioned<java.util.Set<BookieId>>>
RegistrationClient. getAllBookies()
Get the list of all bookies identifiers.java.util.concurrent.CompletableFuture<Versioned<java.util.Set<BookieId>>>
ZKRegistrationClient. getAllBookies()
default java.util.concurrent.CompletableFuture<Versioned<BookieServiceInfo>>
RegistrationClient. getBookieServiceInfo(BookieId bookieId)
Get detailed information about the services exposed by a Bookie.java.util.concurrent.CompletableFuture<Versioned<BookieServiceInfo>>
ZKRegistrationClient. getBookieServiceInfo(BookieId bookieId)
java.util.concurrent.CompletableFuture<Versioned<java.util.Set<BookieId>>>
RegistrationClient. getReadOnlyBookies()
Get the list of readonly bookie identifiers.java.util.concurrent.CompletableFuture<Versioned<java.util.Set<BookieId>>>
ZKRegistrationClient. getReadOnlyBookies()
java.util.concurrent.CompletableFuture<Versioned<java.util.Set<BookieId>>>
RegistrationClient. getWritableBookies()
Get the list of writable bookie identifiers.java.util.concurrent.CompletableFuture<Versioned<java.util.Set<BookieId>>>
ZKRegistrationClient. getWritableBookies()
Methods in org.apache.bookkeeper.discover with parameters of type Versioned Modifier and Type Method Description void
ZKRegistrationClient.WatchTask. accept(Versioned<java.util.Set<BookieId>> bookieSet, java.lang.Throwable throwable)
void
RegistrationClient.RegistrationListener. onBookiesChanged(Versioned<java.util.Set<BookieId>> bookies)
void
RegistrationManager. writeCookie(BookieId bookieId, Versioned<byte[]> cookieData)
Write the cookie data, which will be used for verifying the integrity of the bookie environment.void
ZKRegistrationManager. writeCookie(BookieId bookieId, Versioned<byte[]> cookieData)
-
Uses of Versioned in org.apache.bookkeeper.meta
Methods in org.apache.bookkeeper.meta that return Versioned Modifier and Type Method Description Versioned<byte[]>
NullMetadataBookieDriver.NullRegistrationManager. readCookie(BookieId bookieId)
Methods in org.apache.bookkeeper.meta that return types with arguments of type Versioned 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 Versioned Modifier and Type Method Description void
NullMetadataBookieDriver.NullRegistrationManager. writeCookie(BookieId bookieId, Versioned<byte[]> cookieData)
-
Uses of Versioned in org.apache.bookkeeper.metastore
Methods in org.apache.bookkeeper.metastore that return Versioned Modifier and Type Method Description (package private) static Versioned<Value>
InMemoryMetastoreTable. cloneValue(Value value, Version version, java.util.Set<java.lang.String> fields)
Versioned<Value>
MetastoreTableItem. getValue()
Get the value of the item.Methods in org.apache.bookkeeper.metastore with parameters of type Versioned Modifier and Type Method Description void
MetastoreTableItem. setValue(Versioned<Value> value)
Set the value of the item.Method parameters in org.apache.bookkeeper.metastore with type arguments of type Versioned Modifier and Type Method Description void
InMemoryMetastoreTable. get(java.lang.String key, java.util.Set<java.lang.String> fields, MetastoreCallback<Versioned<Value>> cb, java.lang.Object ctx)
void
InMemoryMetastoreTable. get(java.lang.String key, MetastoreCallback<Versioned<Value>> cb, java.lang.Object ctx)
void
InMemoryMetastoreTable. get(java.lang.String key, MetastoreWatcher watcher, MetastoreCallback<Versioned<Value>> cb, java.lang.Object ctx)
void
MetastoreTable. get(java.lang.String key, java.util.Set<java.lang.String> fields, MetastoreCallback<Versioned<Value>> cb, java.lang.Object ctx)
Get specified fields of a key.void
MetastoreTable. get(java.lang.String key, MetastoreCallback<Versioned<Value>> cb, java.lang.Object ctx)
Get all fields of a key.void
MetastoreTable. get(java.lang.String key, MetastoreWatcher watcher, MetastoreCallback<Versioned<Value>> cb, java.lang.Object ctx)
Get all fields of a key.void
InMemoryMetastoreTable. scheduleGet(java.lang.String key, java.util.Set<java.lang.String> fields, MetastoreCallback<Versioned<Value>> cb, java.lang.Object ctx)
Constructors in org.apache.bookkeeper.metastore with parameters of type Versioned Constructor Description MetastoreTableItem(java.lang.String key, Versioned<Value> value)
Constructor parameters in org.apache.bookkeeper.metastore with type arguments of type Versioned Constructor Description InMemoryMetastoreCursor(java.util.SortedMap<java.lang.String,Versioned<Value>> map, java.util.Set<java.lang.String> fields, java.util.concurrent.ScheduledExecutorService scheduler)
-
Uses of Versioned in org.apache.bookkeeper.proto
Methods in org.apache.bookkeeper.proto with parameters of type Versioned Modifier and Type Method Description void
BookkeeperInternalCallbacks.LedgerMetadataListener. onChanged(long ledgerId, Versioned<LedgerMetadata> metadata)
Triggered each time ledger metadata changed. -
Uses of Versioned in org.apache.bookkeeper.replication
Methods in org.apache.bookkeeper.replication with parameters of type Versioned Modifier and Type Method Description (package private) void
AuditorPlacementPolicyCheckTask. doPlacementPolicyCheck(java.lang.Long ledgerId, org.apache.zookeeper.AsyncCallback.VoidCallback iterCallback, Versioned<LedgerMetadata> metadataVer)
-