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>	seekToCheckPoints(Map<Integer,PubSubPosition> checkpoints, Optional<Version> storeVersion)
CompletableFuture<Void>	seekToTimestamps(Long allPartitionTimestamp, Optional<Version> storeVersion)
CompletableFuture<Void>	seekToTimestamps(Map<Integer,Long> timestamps, Optional<Version> storeVersion)
void	setManaged(boolean isManaged)
CompletableFuture<Void>	subscribe(ComplementSet<Integer> partitions)
CompletableFuture<Void>	subscribe(ComplementSet<Integer> partitions, Optional<Version> bootstrapVersion, Map<Integer,Long> timestamps, Long allPartitionsTimestamp, Map<Integer,PubSubPosition> positionMap)
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)

seekToTimestamps

public CompletableFuture<Void> seekToTimestamps(Long allPartitionTimestamp,
 Optional<Version> storeVersion)

seekToCheckPoints

public CompletableFuture<Void> seekToCheckPoints(Map<Integer,PubSubPosition> checkpoints,
 Optional<Version> storeVersion)

seekToTimestamps

public CompletableFuture<Void> seekToTimestamps(Map<Integer,Long> timestamps,
 Optional<Version> storeVersion)

subscribe

public CompletableFuture<Void> subscribe(ComplementSet<Integer> partitions,
 Optional<Version> bootstrapVersion,
 Map<Integer,Long> timestamps,
 Long allPartitionsTimestamp,
 Map<Integer,PubSubPosition> positionMap)

unsubscribe

public void unsubscribe(ComplementSet<Integer> partitions)

getStoreDeserializerCache

public StoreDeserializerCache getStoreDeserializerCache()

getStoreName

public String getStoreName()