StateManagerUtil¶
registerStateStores¶
void registerStateStores(
Logger log,
String logPrefix,
ProcessorTopology topology,
ProcessorStateManager stateMgr,
StateDirectory stateDirectory,
InternalProcessorContext processorContext)
registerStateStores
...FIXME
registerStateStores
is used when:
StandbyTask
is requested to initializeIfNeededStreamTask
is requested to initializeIfNeeded