Package com.linkedin.davinci.ingestion

Interface DaVinciIngestionBackend

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable, IngestionBackendBase

All Known Implementing Classes:

DefaultIngestionBackend, IsolatedIngestionBackend

public interface DaVinciIngestionBackend
extends IngestionBackendBase

Method Summary

Modifier and Type	Method	Description
void	removeStorageEngine(java.lang.String topicName)
void	setStorageEngineReference(java.lang.String topicName, java.util.concurrent.atomic.AtomicReference<AbstractStorageEngine> storageEngineReference)

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface com.linkedin.davinci.ingestion.IngestionBackendBase

addIngestionNotifier, dropStoragePartitionGracefully, dropStoragePartitionGracefully, getLoadedStoreUserPartitionsMapping, getStoreIngestionService, killConsumptionTask, shutdownIngestionTask, startConsumption, startConsumption, stopConsumption

Method Detail

removeStorageEngine

void removeStorageEngine(java.lang.String topicName)

setStorageEngineReference

void setStorageEngineReference(java.lang.String topicName,
                               java.util.concurrent.atomic.AtomicReference<AbstractStorageEngine> storageEngineReference)