THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block |
|---|
/**
* Factory class for AdjunctDataStoreManager
*/
public interface AdjunctDataStoreManagerFactory {
AdjunctDataStoreManager getAdjunctDataStoreManager(
TaskName taskName,
Config config,
Collection<SystemStreamPartition> ssps,
BaseStorageManager containerStorageManager,
Set<SystemStreamPartition>BaseStorageManager sspstaskStorageManager,
boolean Map<String, StorageEngine> storageEngines);shouldWriteToContainerStores,
OffsetManager offsetManager
} |
AdjunctDataStoreManager
| Code Block |
|---|
/**
* An AdjunctDataStoreManager instance is responsible for
* 1. maintaining the mapping between system streams and adjunct data stores
* 2. extracting the key and value from an IncomingMessageEnvelop
* 3. populating adjunct data stores
* 4. Determine system stream partitions, whose offset need to be reset
* during startup
*/
public interface AdjunctDataStoreManager {
/**
* Invoked before a message is passed to a task
* @returns true if the message is saved in a store, false otherwise
*/
AdjunctDataStoreManager boolean process(IncomingMessageEnvelop message);
} |
...