You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/01/24 11:46:52 UTC
[3/4] flink git commit: [FLINK-8433] [doc] Remove ununsed
CheckpointedRestoring interface
[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 <zm...@163.com>
Authored: Mon Jan 15 17:37:41 2018 +0800
Committer: zentol <ch...@apache.org>
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>