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

Merge pull request #23 from ggjj917/feature/flink_1.7_doc_zh_32

32章节修改
......@@ -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流转换:
* 发送一个异步函数请求
* 获取操作结果并将其传给`ResultFuture`的回调
* 将异步I/O操作作为转换应用于数据流
* 的实现`AsyncFunction`是把请求分派
* 一个_回调_,它接受 算子操作的结果并将其交给`ResultFuture`
* 在DataStream上应用异步I / O 算子操作作为转换
以下代码示例说明了基本模式:
......
# 流连接器
# 流连接器(Streaming Connectors)
> 译者:[flink.sojb.cn](https://flink.sojb.cn/)
......@@ -9,7 +9,7 @@
Flink内置了一些基本数据源和接收器,并且始终可用。该[预定义的数据源](https://flink.sojb.cn/dev/datastream_api.html#data-sources)包括文件,目录和插座读书,并从摄取集合和迭代器的数据。该[预定义的数据接收器](https://flink.sojb.cn/dev/datastream_api.html#data-sinks)支持写入文件,以输出和错误,并插槽。
## 捆绑连接器
## 捆绑连接器(Bundled Connectors)
连接器提供用于与各种第三方系统连接的代码。目前支持这些系统:
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册