@@ -6,15 +6,15 @@ import FunctionDescription from '@site/src/components/FunctionDescription';
6
6
7
7
<FunctionDescription description =" 引入版本: v1.1.70 " />
8
8
9
- [ Apache Flink] ( https://github.com/apache/flink ) CDC ( Change Data Capture) 指的是 Apache Flink 使用基于 SQL 的查询捕获和处理来自各种来源的实时数据变化的能力 。CDC 允许您监控和捕获数据库或流系统中发生的数据修改 (插入、更新和删除),并实时响应这些变化 。您可以利用 [ Flink SQL 连接器 for Databend] ( https://github.com/databendcloud/flink-connector-databend ) 将其他数据库中的数据实时加载到 Databend 中。Flink SQL 连接器 for Databend 提供了一个连接器,将 Flink 的流处理能力与 Databend 集成。通过配置此连接器,您可以将来自各种数据库的数据变化捕获为流 ,并实时加载到 Databend 中进行处理和分析。
9
+ [ Apache Flink] ( https://github.com/apache/flink ) CDC( Change Data Capture,变更数据捕获) 指的是 Apache Flink 通过基于 SQL 的查询捕获和处理来自各种来源的实时数据变更的能力 。CDC 使您能够监控和捕获数据库或流系统中发生的数据修改 (插入、更新和删除),并实时响应这些变更 。您可以利用 [ Flink SQL 连接器 for Databend] ( https://github.com/databendcloud/flink-connector-databend ) 将其他数据库中的数据实时加载到 Databend 中。Flink SQL 连接器 for Databend 提供了一个连接器,将 Flink 的流处理能力与 Databend 集成。通过配置此连接器,您可以将来自各种数据库的数据变更捕获为流 ,并实时加载到 Databend 中进行处理和分析。
10
10
11
11
## 下载与安装连接器
12
12
13
13
要下载和安装 Flink SQL 连接器 for Databend,请按照以下步骤操作:
14
14
15
15
1 . 下载并设置 Flink:在安装 Flink SQL 连接器 for Databend 之前,请确保您已经在系统上下载并设置了 Flink。您可以从官方网站下载 Flink:https://flink.apache.org/downloads/
16
16
17
- 2 . 下载连接器:访问 GitHub 上 Flink SQL 连接器 for Databend 的发布页面:https://github.com/databendcloud/flink-connector-databend/releases。下载最新版本的连接器(例如,flink-connector-databend-0.0.2.jar)。
17
+ 2 . 下载连接器:访问 GitHub 上 Flink SQL 连接器 for Databend 的发布页面:[ https://github.com/databendcloud/flink-connector-databend/releases ] ( https://github.com/databendcloud/flink-connector-databend/releases ) 。下载最新版本的连接器(例如,flink-connector-databend-0.0.2.jar)。
18
18
19
19
请注意,您也可以从源代码编译 Flink SQL 连接器 for Databend:
20
20
@@ -56,17 +56,17 @@ CREATE TABLE products (id INT NOT NULL, name VARCHAR(255) NOT NULL, description
56
56
```
57
57
58
58
2 . 下载 [ Flink] ( https://flink.apache.org/downloads/ ) 以及以下 SQL 连接器到您的系统:
59
- - Flink SQL 连接器 for Databend:https://github.com/databendcloud/flink-connector-databend/releases
60
- - Flink SQL 连接器 for MySQL:https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/2.3.0/flink-sql-connector-mysql-cdc-2.3.0.jar
61
- 3 . 将两个连接器 JAR 文件移动到 Flink 安装目录中的 _ lib_ 文件夹 。
59
+ - Flink SQL 连接器 for Databend:[ https://github.com/databendcloud/flink-connector-databend/releases ] ( https://github.com/databendcloud/flink-connector-databend/releases )
60
+ - Flink SQL 连接器 for MySQL:[ https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/2.3.0/flink-sql-connector-mysql-cdc-2.3.0.jar ] ( https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/2.3.0/flink-sql-connector-mysql-cdc-2.3.0.jar )
61
+ 3 . 将两个连接器的 JAR 文件移动到 Flink 安装目录的 _ lib_ 文件夹中 。
62
62
4 . 启动 Flink:
63
63
64
64
``` shell
65
65
cd flink-16.0
66
66
./bin/start-cluster.sh
67
67
```
68
68
69
- 您现在可以在浏览器中访问 http://localhost:8081 打开 Apache Flink 仪表板:
69
+ 现在,如果您在浏览器中访问 http://localhost:8081,可以打开 Apache Flink 仪表板:
70
70
71
71
![ Alt text] ( /img/load/cdc-dashboard.png )
72
72
@@ -118,7 +118,7 @@ cd flink-16.0
118
118
Welcome! Enter ' HELP;' to list all available commands. ' QUIT;' to exit.
119
119
```
120
120
121
- 6 . 将检查点间隔设置为 3 秒,并在 Flink SQL 客户端中使用 MySQL 和 Databend 连接器创建相应的表。有关可用的连接参数,请参阅 https://github.com/databendcloud/flink-connector-databend#connector-options:
121
+ 6 . 将检查点间隔设置为 3 秒,并在 Flink SQL 客户端中使用 MySQL 和 Databend 连接器创建相应的表。有关可用的连接参数,请参阅 [ https://github.com/databendcloud/flink-connector-databend#connector-options ] ( https://github.com/databendcloud/flink-connector-databend#connector-options ) :
122
122
123
123
``` sql
124
124
Flink SQL> SET execution .checkpointing .interval = 3s;
@@ -159,8 +159,8 @@ Flink SQL> INSERT INTO databend_products SELECT * FROM mysql_products;
159
159
Job ID: b14645f34937c7cf3672ffba35733734
160
160
```
161
161
162
- 您现在可以在 Apache Flink 仪表板中看到一个正在运行的作业:
162
+ 现在,您可以在 Apache Flink 仪表板中看到一个正在运行的作业:
163
163
164
164
![ Alt text] ( /img/load/cdc-job.png )
165
165
166
- 您已经准备就绪 !如果您查询 Databend 中的 _ products_ 表,您将看到 MySQL 中的数据已成功同步。您可以自由地在 MySQL 中执行插入、更新或删除操作,并观察到 Databend 中相应的变化 。
166
+ 一切就绪 !如果您查询 Databend 中的 _ products_ 表,您将看到 MySQL 中的数据已成功同步。您可以自由地在 MySQL 中执行插入、更新或删除操作,并观察到相应的变更也会反映在 Databend 中 。
0 commit comments