Local executor checkpointing

[dmvk]

For streaming apps, we should implement simple checkpointing for LocalExecutor. Eg. when reading from kafka, we want to resume from last commited offset, so we can restart the app.

[je-ik]

Implementation note: we should periodically persist state to local disk and add parameter to continue processing from given checkpointId.