@Override
    public void run() {
        if (incrementalPersistenceStore != null) {
            if (log.isDebugEnabled()) {
                log.debug("Persisting...");
            }
            incrementalPersistenceStore.save(snapshotInfo, snapshots);
            if (log.isDebugEnabled()) {
                log.debug("Persisted.");
            }
        } else {
            throw new NoPersistenceStoreException("No persistence store assigned for siddhi app " +
                    snapshotInfo.getSiddhiAppId());
        }

    }
{@link Runnable} which is responsible for persisting the snapshots that are taken
modules/siddhi-core/src/main/java/io/siddhi/core/util/snapshot/AsyncIncrementalSnapshotPersistor.java