[FLINK-8433] [doc] Remove ununsed CheckpointedRestoring interface
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/77df20bc Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/77df20bc Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/77df20bc Branch: refs/heads/release-1.4 Commit: 77df20bc50322166a517cb293abfbf35320586a1 Parents: e4d7ea2 Author: zhangminglei <[email protected]> Authored: Mon Jan 15 17:37:41 2018 +0800 Committer: zentol <[email protected]> Committed: Wed Jan 24 10:50:29 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/77df20bc/docs/dev/stream/state/state.md ---------------------------------------------------------------------- diff --git a/docs/dev/stream/state/state.md b/docs/dev/stream/state/state.md index 9956998..ce1ce82 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>
