未验证 提交 1bc3e3b5 编写于 作者: 片刻小哥哥's avatar 片刻小哥哥 提交者: GitHub

Merge pull request #22 from ggjj917/feature/flink_1.7_doc_zh_31

31章节修改完成
......@@ -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操作作为转换应用于数据流
以下代码示例说明了基本模式:
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册