S- Generic type of the state object that is created as handle to snapshots.
public interface Snapshotable<S extends StateObject>
|Modifier and Type||Method and Description|
Restores state that was previously snapshotted from the provided parameters.
RunnableFuture<S> snapshot(long checkpointId, long timestamp, CheckpointStreamFactory streamFactory) 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.
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.