Package com.linkedin.davinci

Class StoreBackend

java.lang.Object

com.linkedin.davinci.StoreBackend

public class StoreBackend
extends Object

Method Summary

Modifier and Type	Method	Description
ReferenceCounted<VersionBackend>	getDaVinciCurrentVersion()
StoreBackendStats	getStats()
StoreDeserializerCache	getStoreDeserializerCache()
String	getStoreName()
ComplementSet<Integer>	getSubscription()
boolean	isManaged()
CompletableFuture<Void>	seekToCheckpoint(DaVinciSeekCheckpointInfo checkpointInfo, Optional<Version> storeVersion)
void	setManaged(boolean isManaged)
CompletableFuture<Void>	subscribe(ComplementSet<Integer> partitions)
CompletableFuture<Void>	subscribe(ComplementSet<Integer> partitions, Optional<Version> bootstrapVersion, DaVinciSeekCheckpointInfo checkpointInfo)
void	unsubscribe(ComplementSet<Integer> partitions)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

isManaged

public boolean isManaged()

setManaged

public void setManaged(boolean isManaged)

getStats

public StoreBackendStats getStats()

getSubscription

public ComplementSet<Integer> getSubscription()

getDaVinciCurrentVersion

public ReferenceCounted<VersionBackend> getDaVinciCurrentVersion()

subscribe

public CompletableFuture<Void> subscribe(ComplementSet<Integer> partitions)

seekToCheckpoint

public CompletableFuture<Void> seekToCheckpoint(DaVinciSeekCheckpointInfo checkpointInfo,
 Optional<Version> storeVersion)

subscribe

public CompletableFuture<Void> subscribe(ComplementSet<Integer> partitions,
 Optional<Version> bootstrapVersion,
 DaVinciSeekCheckpointInfo checkpointInfo)

unsubscribe

public void unsubscribe(ComplementSet<Integer> partitions)

getStoreDeserializerCache

public StoreDeserializerCache getStoreDeserializerCache()

getStoreName

public String getStoreName()