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

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.