[FLINK-8433] [doc] Remove ununsed CheckpointedRestoring interface This closes #5298.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2e5b9dd2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2e5b9dd2 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2e5b9dd2 Branch: refs/heads/master Commit: 2e5b9dd24309855b9977b8256c35ebb2fff69bb9 Parents: dcacdb9 Author: zhangminglei <[email protected]> Authored: Mon Jan 15 17:37:41 2018 +0800 Committer: zentol <[email protected]> Committed: Wed Jan 24 12:46:38 2018 +0100 ---------------------------------------------------------------------- docs/dev/stream/state/state.md | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/2e5b9dd2/docs/dev/stream/state/state.md ---------------------------------------------------------------------- diff --git a/docs/dev/stream/state/state.md b/docs/dev/stream/state/state.md index 7d37691..3ea9b7a 100644 --- a/docs/dev/stream/state/state.md +++ b/docs/dev/stream/state/state.md @@ -331,8 +331,7 @@ the basic even-split redistribution list state: {% highlight java %} public class BufferingSink implements SinkFunction<Tuple2<String, Integer>>, - CheckpointedFunction, - CheckpointedRestoring<ArrayList<Tuple2<String, Integer>>> { + CheckpointedFunction { private final int threshold; @@ -379,12 +378,6 @@ public class BufferingSink } } } - - @Override - public void restoreState(ArrayList<Tuple2<String, Integer>> state) throws Exception { - // this is from the CheckpointedRestoring interface. - this.bufferedElements.addAll(state); - } } {% endhighlight %} </div>
