Skip to content
Open
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions docs/content.zh/docs/learn-flink/streaming_analytics.md
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,7 @@ Flink 中事件时间的处理取决于 *watermark 生成器*,后者将带有
<a name="latency-vs-completeness"></a>
### 延迟 VS 正确性

watermarks 给了开发者流处理的一种选择,它们使开发人员在开发应用程序时可以控制延迟和完整性之间的权衡。与批处理不同,批处理中的奢侈之处在于可以在产生任何结果之前完全了解输入,而使用流式传输,我们不被允许等待所有的时间都产生了,才输出排序好的数据,这与流相违背。
watermarks 给了开发者流处理的一种选择,它们使开发人员在开发应用程序时可以控制延迟和完整性之间的权衡。与批处理不同,批处理中的奢侈之处在于可以在产生任何结果之前完全了解输入,而使用流式传输,我们不被允许等待所有的数据都产生了,才输出排序好的数据,这与流相违背。
Comment thread
arvindKandpal-ksolves marked this conversation as resolved.
Outdated

我们可以把 watermarks 的边界时间配置的相对较短,从而冒着在输入了解不完全的情况下产生结果的风险-即可能会很快产生错误结果。或者,你可以等待更长的时间,并利用对输入流的更全面的了解来产生结果。

Expand Down Expand Up @@ -180,7 +180,7 @@ Flink 有一些内置的窗口分配器,如下所示:
以下都是一些可以使用的间隔时间 `Duration.ofMillis(n)`, `Duration.ofSeconds(n)`, `Duration.ofMinutes(n)`,
`Duration.ofHours(n)`, 和 `Duration.ofDays(n)`。

基于时间的窗口分配器(包括会话时间)既可以处理 `事件时间`,也可以处理 `处理时间`。这两种基于时间的处理没有哪一个更好,我们必须折中。使用 `处理时间`,我们必须接受以下限制:
基于时间的窗口分配器(包括会话窗口)既可以处理 `事件时间`,也可以处理 `处理时间`。这两种基于时间的处理没有哪一个更好,我们必须折中。使用 `处理时间`,我们必须接受以下限制:

* 无法正确处理历史数据,
* 无法正确处理超过最大无序边界的数据,
Expand Down