@Deprecated public interface StreamCheckpointedOperator extends CheckpointedRestoringOperator
Modifier and Type | Method and Description |
---|---|
void |
snapshotState(FSDataOutputStream out,
long checkpointId,
long timestamp)
Deprecated.
Called to draw a state snapshot from the operator.
|
restoreState
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–2018 The Apache Software Foundation. All rights reserved.