Package com.linkedin.davinci.client

Class VersionSpecificAvroGenericDaVinciClient<K,V>

java.lang.Object
com.linkedin.davinci.client.AvroGenericDaVinciClient<K,V>
com.linkedin.davinci.client.VersionSpecificAvroGenericDaVinciClient<K,V>
All Implemented Interfaces:
DaVinciClient<K,V>, AvroGenericReadComputeStoreClient<K,V>, AvroGenericStoreClient<K,V>, Closeable, AutoCloseable
public class VersionSpecificAvroGenericDaVinciClient<K,V> extends AvroGenericDaVinciClient<K,V>
Version-specific DaVinci client implementation that subscribes to a specific store version. This is only intended for internal Venice use. Must be used with set to false. Otherwise, the client may subscribe to an unintended version based on what's on disk. Key features: - Subscribes to a specific version (does not follow version swaps) - Validates version existence when subscribing - Cannot be mixed with regular DaVinci clients on the same store with the same {@link com.linkedin.davinci.DaVinciBackend} or JVM. Please note that when the client is subscribed to the backup version, on restart {@link com.linkedin.davinci.DaVinciBackend#functionToCheckWhetherStorageEngineShouldBeKeptOrNot(Optional)} will automatically delete the backup version data on disk and it will have to reingest. We are ok with this behavior because the plan is to use {@link DaVinciRecordTransformer} in diskless mode where the user will need to prevent the PubSub position to seek to instead of relying on the {@link com.linkedin.venice.offsets.OffsetRecord}.