org.apache.samza.storage

Class KafkaChangelogRestoreParams

java.lang.Object

org.apache.samza.storage.KafkaChangelogRestoreParams

public class KafkaChangelogRestoreParams
extends java.lang.Object

Provides the required for Kafka Changelog restore managers

Constructor Summary

Constructors

Constructor and Description

KafkaChangelogRestoreParams(java.util.Map<java.lang.String,SystemConsumer> storeConsumers, java.util.Map<java.lang.String,StorageEngine> inMemoryStores, java.util.Map<java.lang.String,SystemAdmin> systemAdmins, java.util.Map<java.lang.String,StorageEngineFactory<java.lang.Object,java.lang.Object>> storageEngineFactories, java.util.Map<java.lang.String,Serde<java.lang.Object>> serdes, MessageCollector collector)

Method Summary

Modifier and Type	Method and Description
MessageCollector	getCollector()
java.util.Map<java.lang.String,StorageEngine>	getInMemoryStores()
java.util.Map<java.lang.String,Serde<java.lang.Object>>	getSerdes()
java.util.Map<java.lang.String,StorageEngineFactory<java.lang.Object,java.lang.Object>>	getStorageEngineFactories()
java.util.Map<java.lang.String,SystemConsumer>	getStoreConsumers()
java.util.Map<java.lang.String,SystemAdmin>	getSystemAdmins()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaChangelogRestoreParams

public KafkaChangelogRestoreParams(java.util.Map<java.lang.String,SystemConsumer> storeConsumers,
                                   java.util.Map<java.lang.String,StorageEngine> inMemoryStores,
                                   java.util.Map<java.lang.String,SystemAdmin> systemAdmins,
                                   java.util.Map<java.lang.String,StorageEngineFactory<java.lang.Object,java.lang.Object>> storageEngineFactories,
                                   java.util.Map<java.lang.String,Serde<java.lang.Object>> serdes,
                                   MessageCollector collector)

Method Detail

getStoreConsumers

public java.util.Map<java.lang.String,SystemConsumer> getStoreConsumers()

getInMemoryStores

public java.util.Map<java.lang.String,StorageEngine> getInMemoryStores()

getSystemAdmins

public java.util.Map<java.lang.String,SystemAdmin> getSystemAdmins()

getStorageEngineFactories

public java.util.Map<java.lang.String,StorageEngineFactory<java.lang.Object,java.lang.Object>> getStorageEngineFactories()

getSerdes

public java.util.Map<java.lang.String,Serde<java.lang.Object>> getSerdes()

getCollector

public MessageCollector getCollector()