Package com.linkedin.davinci

Class DaVinciBackend

java.lang.Object

com.linkedin.davinci.DaVinciBackend

All Implemented Interfaces:

Closeable, AutoCloseable

public class DaVinciBackend
extends Object
implements Closeable

Constructor Summary

Constructors

Constructor	Description
DaVinciBackend(ClientConfig clientConfig, VeniceConfigLoader configLoader, Optional<Set<String>> managedClients, ICProvider icProvider, Optional<ObjectCacheConfig> cacheConfig, DaVinciRecordTransformerConfig recordTransformerConfig)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

DaVinciBackend

public DaVinciBackend(ClientConfig clientConfig,
 VeniceConfigLoader configLoader,
 Optional<Set<String>> managedClients,
 ICProvider icProvider,
 Optional<ObjectCacheConfig> cacheConfig,
 DaVinciRecordTransformerConfig recordTransformerConfig)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

getStoreOrThrow

public StoreBackend getStoreOrThrow(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,
 String storeName)

getCompressorFactory

public StorageEngineBackedCompressorFactory getCompressorFactory()

reportPushStatus

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

reportPushStatus

protected void reportPushStatus(String kafkaTopic,
 int partition,
 ExecutionStatus status,
 Optional<String> incrementalPushVersion)

deleteStore

protected void deleteStore(String storeName)

isIsolatedIngestion

protected final boolean isIsolatedIngestion()

handleStoreChanged

protected void handleStoreChanged(StoreBackend storeBackend)

hasCurrentVersionBootstrapping

public boolean hasCurrentVersionBootstrapping()