public class FsSavepointStreamFactory extends FsCheckpointStreamFactory
CheckpointStreamFactory
that produces streams that write to a
FileSystem
.
The difference to the parent FsCheckpointStreamFactory
is only
in the created directory layout. All checkpoint files go to the checkpoint
directory.
FsCheckpointStreamFactory.FsCheckpointStateOutputStream
CheckpointStreamFactory.CheckpointStateOutputStream
Constructor and Description |
---|
FsSavepointStreamFactory(Path checkpointDataUri,
JobID jobId,
int fileStateSizeThreshold) |
Modifier and Type | Method and Description |
---|---|
protected Path |
createBasePath(FileSystem fs,
Path checkpointDirectory,
JobID jobID) |
protected Path |
createCheckpointDirPath(Path checkpointDirectory,
long checkpointID) |
close, createCheckpointStateOutputStream, toString
public FsSavepointStreamFactory(Path checkpointDataUri, JobID jobId, int fileStateSizeThreshold) throws IOException
IOException
protected Path createBasePath(FileSystem fs, Path checkpointDirectory, JobID jobID) throws IOException
createBasePath
in class FsCheckpointStreamFactory
IOException
protected Path createCheckpointDirPath(Path checkpointDirectory, long checkpointID)
createCheckpointDirPath
in class FsCheckpointStreamFactory
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.