public interface StorageEngineFactory<K,V>
|Modifier and Type||Interface and Description|
Enum to describe different modes a
|Modifier and Type||Method and Description|
Create an instance of the given storage engine.
StorageEngine getStorageEngine(java.lang.String storeName, java.io.File storeDir, Serde<K> keySerde, Serde<V> msgSerde, MessageCollector collector, MetricsRegistry registry, SystemStreamPartition changeLogSystemStreamPartition, JobContext jobContext, ContainerContext containerContext, StorageEngineFactory.StoreMode storeMode)
storeName- The name of the storage engine.
storeDir- The directory of the storage engine.
keySerde- The serializer to use for serializing keys when reading or writing to the store.
msgSerde- The serializer to use for serializing messages when reading or writing to the store.
collector- MessageCollector the storage engine uses to persist changes.
registry- MetricsRegistry to which to publish storage-engine specific metrics.
changeLogSystemStreamPartition- Samza stream partition from which to receive the changelog.
jobContext- Information about the job in which the task is executing
containerContext- Information about the container in which the task is executing.
storeMode- The mode in which the instance should be created in.