public interface StorageEngineFactory<K,V>
Modifier and Type | Method and Description |
---|---|
StorageEngine |
getStorageEngine(java.lang.String storeName,
java.io.File storeDir,
Serde<K> keySerde,
Serde<V> msgSerde,
MessageCollector collector,
MetricsRegistry registry,
SystemStreamPartition changeLogSystemStreamPartition,
SamzaContainerContext containerContext)
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, SamzaContainerContext containerContext)
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.containerContext
- Information about the container in which the task is executing.