public interface CheckpointStreamFactory
Modifier and Type | Interface and Description |
---|---|
static class |
CheckpointStreamFactory.CheckpointStateOutputStream
A dedicated output stream that produces a
StreamStateHandle when closed. |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the stream factory, releasing all internal resources, but does not delete any
persistent checkpoint data.
|
CheckpointStreamFactory.CheckpointStateOutputStream |
createCheckpointStateOutputStream(long checkpointID,
long timestamp)
Creates an new
CheckpointStreamFactory.CheckpointStateOutputStream . |
CheckpointStreamFactory.CheckpointStateOutputStream createCheckpointStateOutputStream(long checkpointID, long timestamp) throws Exception
CheckpointStreamFactory.CheckpointStateOutputStream
. When the stream
is closed, it returns a state handle that can retrieve the state back.checkpointID
- The ID of the checkpoint.timestamp
- The timestamp of the checkpoint.Exception
- Exceptions may occur while creating the stream and should be forwarded.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.