@Deprecated public interface CheckpointedRestoringOperator
StreamOperators
that can restore from a Flink 1.1
legacy snapshot that was done using the StreamCheckpointedOperator
interface.Modifier and Type | Method and Description |
---|---|
void |
restoreState(FSDataInputStream in)
Deprecated.
Restores the operator state, if this operator's execution is recovering from a checkpoint.
|
void restoreState(FSDataInputStream in) throws Exception
This method is called after StreamOperator.setup(StreamTask, StreamConfig, Output)
and before StreamOperator.open()
.
in
- The stream from which we have to restore our state.Exception
- Exceptions during state restore should be forwarded, so that the system can
properly react to failed state restore and fail the execution attempt.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.