@Deprecated public interface StreamCheckpointedOperator extends CheckpointedRestoringOperator
|Modifier and Type||Method and Description|
Called to draw a state snapshot from the operator.
void snapshotState(FSDataOutputStream out, long checkpointId, long timestamp) throws Exception
out- The stream to which we have to write our state.
checkpointId- The ID of the checkpoint.
timestamp- The timestamp of the checkpoint.
Exception- Forwards exceptions that occur while drawing snapshots from the operator and the key/value state.
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.