org.apache.samza.storage

Interface StorageEngineFactory<K,V>

public interface StorageEngineFactory<K,V>

An object provided by the storage engine implementation to create instances of the given storage engine type.

Method Summary

Methods

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.

Method Detail

getStorageEngine

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.

Parameters:

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.

Returns:

The storage engine instance.