diff --git a/docs/1.7-SNAPSHOT/30.md b/docs/1.7-SNAPSHOT/30.md index d558f4e58296c9747c754977f25c3700e44619b8..a616f7584d075f3f798453a10a29667b5136bd9b 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流转换: -* 发送一个异步函数请求 -* 获取操作结果并将其传给`ResultFuture`的回调 -* 将异步I/O操作作为转换应用于数据流 +* 的实现`AsyncFunction`是把请求分派 +* 一个_回调_,它接受 算子操作的结果并将其交给`ResultFuture` +* 在DataStream上应用异步I / O 算子操作作为转换 以下代码示例说明了基本模式: diff --git a/docs/1.7-SNAPSHOT/31.md b/docs/1.7-SNAPSHOT/31.md index d35eab594f3c536646387698f6f0e1165358a9c0..996a2c4710fd5b290b30a424046c1353fd161132 100644 --- a/docs/1.7-SNAPSHOT/31.md +++ b/docs/1.7-SNAPSHOT/31.md @@ -1,6 +1,6 @@ -# 流连接器 +# 流连接器(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) 连接器提供用于与各种第三方系统连接的代码。目前支持这些系统: