XBaith commented on a change in pull request #11808:
URL: https://github.com/apache/flink/pull/11808#discussion_r416851827
##########
File path: docs/dev/stream/operators/process_function.zh.md
##########
@@ -215,18 +214,18 @@ class CountWithTimeoutFunction extends
KeyedProcessFunction[Tuple, (String, Stri
ctx: KeyedProcessFunction[Tuple, (String, String), (String,
Long)]#Context,
out: Collector[(String, Long)]): Unit = {
- // initialize or retrieve/update the state
+ // 初始化或更新状态
val current: CountWithTimestamp = state.value match {
case null =>
CountWithTimestamp(value._1, 1, ctx.timestamp)
case CountWithTimestamp(key, count, lastModified) =>
CountWithTimestamp(key, count + 1, ctx.timestamp)
}
- // write the state back
+ // 将更新后的状态写回
state.update(current)
- // schedule the next timer 60 seconds from the current event time
+ // 注册一个60s之后的事件时间回调
Review comment:
```suggestion
// 注册一个 60s 之后的事件时间回调
```
----------------------------------------------------------------
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:
us...@infra.apache.org
