Package com.linkedin.davinci

Class DaVinciBackend

java.lang.Object

com.linkedin.davinci.DaVinciBackend

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class DaVinciBackend
extends java.lang.Object
implements java.io.Closeable

Constructor Summary

Constructors

Constructor	Description
DaVinciBackend(ClientConfig clientConfig, VeniceConfigLoader configLoader, java.util.Optional<java.util.Set<java.lang.String>> managedClients, ICProvider icProvider, java.util.Optional<ObjectCacheConfig> cacheConfig, java.util.function.Function<java.lang.Integer,DaVinciRecordTransformer> getRecordTransformer)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	compareCacheConfig(java.util.Optional<ObjectCacheConfig> config)
protected void	deleteStore(java.lang.String storeName)
StorageEngineBackedCompressorFactory	getCompressorFactory()
DaVinciIngestionBackend	getIngestionBackend()
ObjectCacheBackend	getObjectCache()
ReadOnlySchemaRepository	getSchemaRepository()
StoreBackend	getStoreOrThrow(java.lang.String storeName)
SubscriptionBasedReadOnlyStoreRepository	getStoreRepository()
protected void	handleStoreChanged(StoreBackend storeBackend)
protected boolean	isIsolatedIngestion()
protected void	reportPushStatus(java.lang.String kafkaTopic, int subPartition, ExecutionStatus status)
protected void	reportPushStatus(java.lang.String kafkaTopic, int subPartition, ExecutionStatus status, java.util.Optional<java.lang.String> incrementalPushVersion)

Methods inherited from class java.lang.Object

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

Constructor Detail

DaVinciBackend

public DaVinciBackend(ClientConfig clientConfig,
                      VeniceConfigLoader configLoader,
                      java.util.Optional<java.util.Set<java.lang.String>> managedClients,
                      ICProvider icProvider,
                      java.util.Optional<ObjectCacheConfig> cacheConfig,
                      java.util.function.Function<java.lang.Integer,DaVinciRecordTransformer> getRecordTransformer)

Method Detail

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

getStoreOrThrow

public StoreBackend getStoreOrThrow(java.lang.String storeName)

getStoreRepository

public SubscriptionBasedReadOnlyStoreRepository getStoreRepository()

getObjectCache

public ObjectCacheBackend getObjectCache()

getSchemaRepository

public ReadOnlySchemaRepository getSchemaRepository()

getIngestionBackend

public DaVinciIngestionBackend getIngestionBackend()

compareCacheConfig

public boolean compareCacheConfig(java.util.Optional<ObjectCacheConfig> config)

getCompressorFactory

public StorageEngineBackedCompressorFactory getCompressorFactory()

reportPushStatus

protected void reportPushStatus(java.lang.String kafkaTopic,
                                int subPartition,
                                ExecutionStatus status)

reportPushStatus

protected void reportPushStatus(java.lang.String kafkaTopic,
                                int subPartition,
                                ExecutionStatus status,
                                java.util.Optional<java.lang.String> incrementalPushVersion)

deleteStore

protected void deleteStore(java.lang.String storeName)

isIsolatedIngestion

protected final boolean isIsolatedIngestion()

handleStoreChanged

protected void handleStoreChanged(StoreBackend storeBackend)