Package-level declarations
Types
Link copied to clipboard
class FileCheckpointer<State>(directory: Path, serializer: StateSerializer<State>, fileSystem: FileSystem = SystemFileSystem, maxHistory: Int = Int.MAX_VALUE) : Checkpointer<State>
A persistent Checkpointer that stores the checkpoints of each thread in one file inside directory: one line of JSON for each step of the thread, oldest first.