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()
boolean
compareCacheConfig(java.util.Optional<ObjectCacheConfig> config)
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)
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)
-
-
-
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()
-
compareCacheConfig
public boolean compareCacheConfig(java.util.Optional<ObjectCacheConfig> config)
-
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)
-
-