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, DaVinciRecordTransformerFunctionalInterface recordTransformerFunction)

Method Summary

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

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,
                      DaVinciRecordTransformerFunctionalInterface recordTransformerFunction)

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 IngestionBackend getIngestionBackend()

verifyCacheConfigEquality

public void verifyCacheConfigEquality(@Nullable
                                      ObjectCacheConfig newObjectCacheConfig,
                                      java.lang.String storeName)

getCompressorFactory

public StorageEngineBackedCompressorFactory getCompressorFactory()

reportPushStatus

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

reportPushStatus

protected void reportPushStatus(java.lang.String kafkaTopic,
                                int partition,
                                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)

hasCurrentVersionBootstrapping

public boolean hasCurrentVersionBootstrapping()