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