klion26 commented on a change in pull request #12621:
URL: https://github.com/apache/flink/pull/12621#discussion_r442833681
##########
File path: docs/dev/stream/state/state.zh.md
##########
@@ -718,14 +705,17 @@ void restoreState(List<T> state) throws Exception;
{% highlight java %}
public static class CounterSource
extends RichParallelSourceFunction<Long>
- implements ListCheckpointed<Long> {
+ implements CheckpointedFunction {
/** current offset for exactly once semantics */
private Long offset = 0L;
/** flag for job cancellation */
private volatile boolean isRunning = true;
-
+
+ /** Our state object. */
Review comment:
能否把这些代码的注释也翻译下呢？
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
