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
All Methods Instance Methods Concrete Methods 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)
-
-
-
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 interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.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()
-
-