doris: Flink导入数据

使用 Flink Doris Connector 可以及时的将 Flink 产生的数据（如：Flink 读取 Kafka，MySQL 中的数据）导入到 Doris 中。
使用限定​

必要依赖用户部署的 Flink 集群。
使用 Flink 导入数据​

使用 Flink 导入数据，具体步骤可以参考 Flink-Doris-Connector。在以下步骤中，演示怎样通过 Flink 快速导入数据。
第 1 步：创建表​

1. CREATE TABLE `students` (
2.   `id` INT NULL,
3.   `name` VARCHAR(256) NULL,
4.   `age` INT NULL
5. ) ENGINE=OLAP
6. UNIQUE KEY(`id`)      
7. COMMENT 'OLAP'
8. DISTRIBUTED BY HASH(`id`) BUCKETS 1  
9. PROPERTIES (                                                         
10. "replication_allocation" = "tag.location.default: 1"
11. );

复制代码

第 2 步：使用 Flink 导入数据​

运行 bin/sql-client.sh 打开 FlinkSQL 的控制台

1. CREATE TABLE student_sink (
2.     id INT,
3.     name STRING,
4.     age INT
5.     )
6.     WITH (
7.       'connector' = 'doris',
8.       'fenodes' = '10.16.10.6:28737',
9.       'table.identifier' = 'test.students',
10.       'username' = 'root',
11.       'password' = '',
12.       'sink.label-prefix' = 'doris_label'
13. );
15. INSERT INTO student_sink values(1,'zhangsan',123)

复制代码

第 3 步：检查导入数据​

1. mysql> select * from test.students;                                                                                                                        
2. +------+----------+------+      
3. | id   | name     | age  |   
4. +------+----------+------+                                                                                                                             
5. |  1   | zhangsan |  123 |   
6. +------+----------+------+   
7. 1 rows in set (0.05 sec)  

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。