S- type of the returned state object that represents the result of the snapshot operation.
@Internal public interface Snapshotable<S extends StateObject>
|Modifier and Type||Method and Description|
Operation that writes a snapshot into a stream that is provided by the given
@Nonnull RunnableFuture<S> snapshot(long checkpointId, long timestamp, @Nonnull CheckpointStreamFactory streamFactory, @Nonnull CheckpointOptions checkpointOptions) throws Exception
CheckpointStreamFactoryand returns a @
RunnableFuturethat gives a state handle to the snapshot. It is up to the implementation if the operation is performed synchronous or asynchronous. In the later case, the returned Runnable must be executed first before obtaining the handle.
checkpointId- The ID of the checkpoint.
timestamp- The timestamp of the checkpoint.
streamFactory- The factory that we can use for writing our state to streams.
checkpointOptions- Options for how to perform this checkpoint.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.