diff --git a/docs/1.7-SNAPSHOT/30.md b/docs/1.7-SNAPSHOT/30.md index a616f7584d075f3f798453a10a29667b5136bd9b..d558f4e58296c9747c754977f25c3700e44619b8 100644 --- a/docs/1.7-SNAPSHOT/30.md +++ b/docs/1.7-SNAPSHOT/30.md @@ -9,7 +9,7 @@ 注:有关异步I / O实用程序的设计和实现的详细信息,请参阅提议和设计文档 [FLIP-12:异步I / O设计和实现](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=65870673)。 -## 需要异步I / O 算子操作 +## 异步I / O 操作的必要性 当与外部系统交互时(例如,当使用存储在数据库中的数据来丰富流事件时),需要注意与外部系统的通信延迟不会主导流应用程序的总工作。 @@ -33,9 +33,9 @@ Flink的Async I / O API允许用户将异步请求客户端与数据流一起使 假设有一个目标数据库的异步客户端,则需要三个部分来实现对数据库的异步I / O流转换: -* 的实现`AsyncFunction`是把请求分派 -* 一个_回调_,它接受 算子操作的结果并将其交给`ResultFuture` -* 在DataStream上应用异步I / O 算子操作作为转换 +* 发送一个异步函数请求 +* 获取操作结果并将其传给`ResultFuture`的回调 +* 将异步I/O操作作为转换应用于数据流 以下代码示例说明了基本模式: