FileCheckpointer
constructor(directory: Path, serializer: StateSerializer<State>, fileSystem: FileSystem = SystemFileSystem, maxHistory: Int = Int.MAX_VALUE)
Parameters
directory
where checkpoint files are stored. Created if it does not exist.
serializer
converts the graph state to and from a string.
fileSystem
the file system to use; replaceable in tests.
maxHistory
how many checkpoints a thread keeps, counted from the latest. The default keeps all of them; 1 keeps only the latest.