org.apache.samza.storage

Interface StateBackendFactory

public interface StateBackendFactory

Factory to build the Samza TaskBackupManager, TaskRestoreManager and StateBackendAdmin for a particular state storage backend, which are used to durably backup the Samza task state.

Method Summary

Modifier and Type	Method and Description
StateBackendAdmin	getAdmin(JobModel jobModel, Config config)
TaskBackupManager	getBackupManager(JobContext jobContext, ContainerModel containerModel, TaskModel taskModel, java.util.Map<java.lang.String,SystemAdmin> systemNameSystemAdminMap, java.util.concurrent.ExecutorService backupExecutor, MetricsRegistry taskInstanceMetricsRegistry, Config config, Clock clock, java.io.File loggedStoreBaseDir, java.io.File nonLoggedStoreBaseDir)
TaskRestoreManager	getRestoreManager(JobContext jobContext, ContainerContext containerContext, TaskModel taskModel, java.util.concurrent.ExecutorService restoreExecutor, MetricsRegistry metricsRegistry, java.util.Set<java.lang.String> storesToRestore, Config config, Clock clock, java.io.File loggedStoreBaseDir, java.io.File nonLoggedStoreBaseDir, KafkaChangelogRestoreParams kafkaChangelogRestoreParams)

Method Detail

getBackupManager

TaskBackupManager getBackupManager(JobContext jobContext,
                                   ContainerModel containerModel,
                                   TaskModel taskModel,
                                   java.util.Map<java.lang.String,SystemAdmin> systemNameSystemAdminMap,
                                   java.util.concurrent.ExecutorService backupExecutor,
                                   MetricsRegistry taskInstanceMetricsRegistry,
                                   Config config,
                                   Clock clock,
                                   java.io.File loggedStoreBaseDir,
                                   java.io.File nonLoggedStoreBaseDir)

getRestoreManager

TaskRestoreManager getRestoreManager(JobContext jobContext,
                                     ContainerContext containerContext,
                                     TaskModel taskModel,
                                     java.util.concurrent.ExecutorService restoreExecutor,
                                     MetricsRegistry metricsRegistry,
                                     java.util.Set<java.lang.String> storesToRestore,
                                     Config config,
                                     Clock clock,
                                     java.io.File loggedStoreBaseDir,
                                     java.io.File nonLoggedStoreBaseDir,
                                     KafkaChangelogRestoreParams kafkaChangelogRestoreParams)

getAdmin

StateBackendAdmin getAdmin(JobModel jobModel,
                           Config config)