Checkpointing in Streaming java API