@@ -6,7 +6,7 @@ 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
@@ -32,7 +32,7 @@ import FunctionDescription from '@site/src/components/FunctionDescription';
32
32
33
33
1 . 在 MySQL 中创建一个表并填充示例数据。然后,在 Databend 中创建相应的目标表。
34
34
35
- ``` sql title='在 MySQL 中: '
35
+ ``` sql title='在 MySQL 中: '
36
36
CREATE DATABASE mydb ;
37
37
USE mydb;
38
38
@@ -51,22 +51,22 @@ INSERT INTO products VALUES (default,"scooter","Small 2-wheel scooter"),
51
51
(default," spare tire" ," 24 inch spare tire" );
52
52
```
53
53
54
- ``` sql title='在 Databend 中: '
54
+ ``` sql title='在 Databend 中: '
55
55
CREATE TABLE products (id INT NOT NULL , name VARCHAR (255 ) NOT NULL , description VARCHAR (512 ) );
56
56
```
57
57
58
- 2 . 下载 [ Flink] ( https://flink.apache.org/downloads/ ) 以及以下 SQL 连接器到您的系统:
58
+ 2 . 下载 [ Flink] ( https://flink.apache.org/downloads/ ) 和以下 SQL 连接器到您的系统:
59
59
- Flink SQL 连接器 for Databend:[ https://github.com/databendcloud/flink-connector-databend/releases ] ( https://github.com/databendcloud/flink-connector-databend/releases )
60
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_ 文件夹中 。
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 ] ( 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 ] ( 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;
@@ -163,4 +163,4 @@ Job ID: b14645f34937c7cf3672ffba35733734
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